积分过期脚本

liquidnet-bus-do/liquidnet-service-stone-do/src/main/java/com/liquidnet/service/stone/mapper/StoneScoreLogsMapper.java

@@ -18,6 +18,6 @@ import java.util.List;
  */
 public interface StoneScoreLogsMapper extends BaseMapper<StoneScoreLogs> {
 
-    List<StoneInvalidDto> getInvalidScore(@Param("st") LocalDate st, @Param("et") LocalDate et);
+    List<StoneInvalidDto> getInvalidScore(@Param("st") LocalDate st, @Param("et") LocalDate et,@Param("strTime") String strTime);
 
 }

liquidnet-bus-do/liquidnet-service-stone-do/src/main/resources/com/liquidnet/service/stone/mapper/StoneScoreLogsMapper.xml

@@ -8,7 +8,13 @@
     </resultMap>
 
     <select id="getInvalidScore" resultMap="StoneScoreListDtoResult">
-        select uid,sum(score) as 'invalid_score' from stone_score_logs where created_at <![CDATA[>=]]> #{st} and created_at <![CDATA[<]]> #{et} group by uid
+        SELECT uid,sum(score) as 'invalid_score' from stone_score_logs
+        WHERE
+        (created_at <![CDATA[>=]]> #{st} and created_at <![CDATA[<]]> #{et})
+        OR
+        content = #{strTime}
+        GROUP BU uid
+        HAVING invalid_score <![CDATA[>]]> 0
         ORDER BY uid
     </select>
 

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

@@ -43,10 +43,12 @@ public class StoneServerImpl {
         //获取需要跑积分的用户
         LocalDate et = LocalDate.parse(time);
         LocalDate st = et.minusYears(1);
-        List<StoneInvalidDto> logsList = stoneScoreLogsMapper.getInvalidScore(st,et);
+        int year = et.getYear();
+        String strTime = year+"年积分过期";
+        List<StoneInvalidDto> logsList = stoneScoreLogsMapper.getInvalidScore(st,et,strTime);
         for (StoneInvalidDto logs : logsList) {
             if(logs.getInvalidScore()>0){
-                stoneIntegralClient.de2111(logs.getUid(), new BigDecimal(logs.getInvalidScore() + "").intValue(), "积分到期");
+                stoneIntegralClient.de2111(logs.getUid(), new BigDecimal(logs.getInvalidScore() + "").intValue(), strTime);
             }
         }
         return true;