添加 积分过期脚本(未完成)

liquidnet-bus-config/liquidnet-config/application-dev.yml

@@ -13,9 +13,9 @@ liquidnet:
     refresh-ttl: 525600
     blacklist_grace_period: 5
   mysql:
-    urlHostAndPort: 39.107.71.112:3308
-    username: root
-    password: Zhengzai@rd2U#
+    urlHostAndPort: zhengzai.mysql.polardb.rds.aliyuncs.com:3306
+    username: java
+    password: pOOs9Y3wj#2^
   rabbitmq:
     host: rabbitmq.zhengzai.tv
     port: 5672
@@ -93,7 +93,7 @@ liquidnet:
     candy:
       url: http://devcandy.zhengzai.tv/candy
     stone:
-      url: http://devstone.zhengzai.tv/stone
+      url: http://stone.zhengzai.tv/stone
     dragon:
       notifyUrl: https://devdragon.zhengzai.tv/dragon
       urls:

liquidnet-bus-config/liquidnet-config/liquidnet-service-platform-dev.yml

@@ -15,7 +15,7 @@ liquidnet:
   rabbitmq:
     connection-timeout: 5000
   mysql:
-    database-name: dev_ln_scene
+    database-name: prod_ln_scene
   mongodb:
     sslEnabled: false
     database: dev_ln_scene

liquidnet-bus-do/liquidnet-service-stone-do/src/main/java/com/liquidnet/service/stone/dto/StoneInvalidDto.java

+package com.liquidnet.service.stone.dto;
+
+import lombok.Data;
+
+
+@Data
+public class StoneInvalidDto implements Cloneable {
+    /**
+     * 昵称
+     */
+    private String uid;
+    /**
+     * 头像
+     */
+    private Integer invalidScore;
+
+
+    private static final StoneInvalidDto obj = new StoneInvalidDto();
+    public static StoneInvalidDto getNew() {
+        try {
+            return (StoneInvalidDto) obj.clone();
+        } catch (CloneNotSupportedException e) {
+            e.printStackTrace();
+        }
+        return new StoneInvalidDto();
+    }
+}

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

 package com.liquidnet.service.stone.mapper;
 
+import com.liquidnet.service.stone.dto.StoneInvalidDto;
 import com.liquidnet.service.stone.entity.StoneScoreLogs;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 
+import java.util.List;
+
 /**
  * <p>
  * 积分日志表 Mapper 接口
@@ -13,4 +16,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface StoneScoreLogsMapper extends BaseMapper<StoneScoreLogs> {
 
+    List<StoneInvalidDto> getInvalidScore(String time);
+
 }

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

@@ -2,4 +2,14 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.liquidnet.service.stone.mapper.StoneScoreLogsMapper">
 
+    <resultMap id="StoneScoreListDtoResult" type="com.liquidnet.service.stone.dto.StoneInvalidDto">
+        <result column="uid" property="uid"/>
+        <result column="invalid_score" property="invalidScore"/>
+    </resultMap>
+
+    <select id="getInvalidScore" resultMap="StoneScoreListDtoResult">
+        select uid,sum(score) as 'invalid_score' from stone_score_logs where created_at <![CDATA[<]]> #{time} group by uid
+        ORDER BY uid
+    </select>
+
 </mapper>

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

 package com.liquidnet.service.platform.controller.stone;
 
-import com.liquidnet.service.base.ResponseDto;
 import com.liquidnet.service.platform.service.impl.stone.StoneServerImpl;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -26,4 +27,14 @@ public class InnerController {
 //        return ResponseDto.success(result);
     }
 
+
+    @PostMapping("refreshScore")
+    @ApiOperation("积分过期")
+    @ApiImplicitParams({
+            @ApiImplicitParam(type = "form", required = true, dataType = "String", name = "time", value = "格式[2022-12-01]", example = "1"),
+    })
+    public void refreshScore(@RequestParam("time") String time) {
+        data.refreshScore(time);
+    }
+
 }

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

@@ -14,6 +14,7 @@ import com.liquidnet.service.adam.mapper.AdamUserMapper;
 import com.liquidnet.service.feign.stone.api.FeignStoneIntegralClient;
 import com.liquidnet.service.kylin.mapper.KylinOrderTicketsMapper;
 import com.liquidnet.service.stone.constant.StoneConstant;
+import com.liquidnet.service.stone.dto.StoneInvalidDto;
 import com.liquidnet.service.stone.entity.StoneScoreLogs;
 import com.liquidnet.service.stone.entity.StoneScoreUser;
 import com.liquidnet.service.stone.entity.TempScore;
@@ -60,6 +61,23 @@ public class StoneServerImpl {
     @Autowired
     TempScoreMapper tempScoreMapper;
 
+    public boolean refreshScore(String time) {
+        //获取需要跑积分的用户
+        List<StoneInvalidDto> logsList = stoneScoreLogsMapper.getInvalidScore();
+        log.debug("DATA SIZE = "+logsList.size());
+        for (StoneInvalidDto logs : logsList) {
+//            int restScore = getUserScoreRest(logs.getUid());
+//            if(logs.getScore().compareTo(new BigDecimal(restScore))<0){
+//                log.debug("积分过期 全量");
+//                stoneIntegralClient.de2111(logs.getUid(), new BigDecimal(logs.getScore() + "").intValue(), "积分到期");
+//            }else if(restScore>0){
+//                log.debug("积分过期 部分");
+//                stoneIntegralClient.de2111(logs.getUid(), new BigDecimal(restScore + "").intValue(), "积分到期");
+//            }
+        }
+        return true;
+    }
+
     public boolean initScore(String uid) {
         try {
             TempScore dataBean = tempScoreMapper.selectOne(Wrappers.lambdaQuery(TempScore.class).eq(TempScore::getUid, uid));