脚本修改,增加历史积分不拦截每月上限,增加字段积分过期时间

docu/dev_stone.sql

@@ -7,6 +7,7 @@ create table stone_score_logs
     score decimal(8, 2) default 0 comment '积分',
     content varchar(255) default '' comment '积分动态明细',
     reason  varchar(255) default '' comment '变更原因',
+    overdue_at  datetime comment '过期时间',
     created_at datetime ,
     updated_at datetime ,
     comment    text

liquidnet-bus-do/liquidnet-service-stone-do/src/main/java/com/liquidnet/service/stone/entity/StoneScoreLogs.java

@@ -52,6 +52,11 @@ public class StoneScoreLogs implements Serializable ,Cloneable{
      */
     private String reason;
 
+    /**
+     * 过期时间
+     */
+    private LocalDateTime overdueAt;
+
     private LocalDateTime createdAt;
 
     private LocalDateTime updatedAt;

liquidnet-bus-service/liquidnet-service-stone/liquidnet-service-stone-impl/src/main/java/com/liquidnet/service/stone/service/impl/StoneScoreLogsServiceImpl.java

@@ -285,7 +285,7 @@ public class StoneScoreLogsServiceImpl implements IStoneScoreLogsService {
         stoneMongoUtils.logCreate(logs);
         //mysql 入库 积分日志
         queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_INSERT_LOGS.getKey(),
-                SqlMapping.get("stone_score_logs.insert", logs.getLogsId(), logs.getUid(), logs.getScore(), logs.getContent(), logs.getReason(), LocalDateTime.now())
+                SqlMapping.get("stone_score_logs.insert", logs.getLogsId(), logs.getUid(), logs.getScore(), logs.getContent(), logs.getReason(), getOverdueAt(), LocalDateTime.now())
         );
     }
 
@@ -304,7 +304,22 @@ public class StoneScoreLogsServiceImpl implements IStoneScoreLogsService {
         stoneMongoUtils.logCreate(logs);
         //mysql 入库 积分日志
         queueUtils.sendMsgByRedis(MQConst.StoneQueue.STONE_INSERT_LOGS.getKey(),
-                SqlMapping.get("stone_score_logs.insert", logs.getLogsId(), logs.getUid(), logs.getScore(), logs.getContent(), logs.getReason(), LocalDateTime.now())
+                SqlMapping.get("stone_score_logs.insert", logs.getLogsId(), logs.getUid(), logs.getScore(), logs.getContent(), logs.getReason(), getOverdueAt(), LocalDateTime.now())
         );
     }
+
+    /**
+     * 获取 积分过期时间
+     * @return
+     */
+    private LocalDateTime getOverdueAt() {
+        LocalDateTime now = LocalDateTime.now();
+        LocalDateTime overdueAt = LocalDateTime.of(now.getHour(), 10, 27, 0, 0, 0);
+        if (now.isAfter(overdueAt)) {
+            overdueAt = LocalDateTime.of(now.getHour() + 1, 12, 27, 0, 0, 0);
+        } else {
+            overdueAt = LocalDateTime.of(now.getHour(), 12, 27, 0, 0, 0);
+        }
+        return overdueAt;
+    }
 }

liquidnet-bus-service/liquidnet-service-stone/liquidnet-service-stone-impl/src/main/resources/sqlmap.properties

 # ----    添加日志纪录    ----
-stone_score_logs.insert=INSERT INTO `stone_score_logs`(`logs_id` ,`uid` ,`score` ,`content` ,`reason` ,`created_at`)VALUES(? ,? ,? ,? ,? ,? );
+stone_score_logs.insert=INSERT INTO `stone_score_logs`(`logs_id` ,`uid` ,`score` ,`content` ,`reason` , `overdue_at` ,`created_at`)VALUES(? ,? ,? ,? ,? ,? , ?);
 #----    添加用户积分表信息    ----
 stone_score_user.insert=INSERT INTO `stone_score_user`(`score_id` ,`uid` ,`status` ,`created_at`)VALUES(? ,? ,? ,? );
 #----    生成订单    ----