初始化用户积分

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java

@@ -9,6 +9,7 @@ import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.vo.AdamUserInfoVo;
 import com.liquidnet.service.adam.entity.AdamUser;
 import com.liquidnet.service.adam.mapper.AdamUserMapper;
+import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.stone.constant.StoneConstant;
 import com.liquidnet.service.stone.entity.StoneScoreLogs;
@@ -218,11 +219,12 @@ public class DataImpl {
 
     public boolean initLogs(String uid) {
         List<StoneScoreLogs> list = stoneScoreLogsMapper.selectList(Wrappers.lambdaQuery(StoneScoreLogs.class).eq(StoneScoreLogs::getUid, uid));
-        mongoTemplate.remove(Query.query(Criteria.where("uid").is(uid)));
+        mongoTemplate.remove(Query.query(Criteria.where("uid").is(uid)), StoneScoreLogs.class, StoneScoreLogs.class.getSimpleName());
         String redisKey = StoneConstant.LOGS_LIST.concat(uid);
         redisDataSourceUtil.getRedisStoneUtil().del(redisKey);
+        int scoreAll = 0;
+        int scoreUse = 0;
         for (StoneScoreLogs item : list) {
-            //初始化 redis
             //初始化 mongo
             StoneScoreLogs logs = new StoneScoreLogs();
             logs.setLogsId(item.getLogsId());
@@ -231,9 +233,20 @@ public class DataImpl {
             logs.setUid(uid);
             logs.setScore(item.getScore());
             logs.setCreatedAt(item.getCreatedAt());
+            if(item.getScore().intValue()<0){
+                scoreUse+=item.getScore().negate().intValue();
+            }else{
+                scoreAll+=item.getScore().intValue();
+            }
+            logCreate(logs);
         }
+        //初始化 redis
         List<StoneScoreLogs> getLogsList = (List<StoneScoreLogs>) logList(uid, 1, 40).get("data");
         redisDataSourceUtil.getRedisStoneUtil().set(redisKey,getLogsList);
+        String restKey = StoneConstant.USER.concat(uid).concat(StoneConstant.SURPLUS_SCORE);
+        String useKey = StoneConstant.USER.concat(uid).concat(StoneConstant.USE_SCORE);
+        redisDataSourceUtil.getRedisStoneUtil().set(useKey,scoreUse);
+        redisDataSourceUtil.getRedisStoneUtil().set(restKey,scoreAll-scoreUse);
         return true;
     }
 
@@ -265,6 +278,10 @@ public class DataImpl {
         }
     }
 
+    public Object logCreate(StoneScoreLogs data) {
+        return mongoTemplate.insert(data, StoneScoreLogs.class.getSimpleName());
+    }
+
     public HashMap<String, Object> logList(String uid, int page, int size) {
         LocalDateTime now  = LocalDateTime.now();
         HashMap<String, Object> info = CollectionUtil.mapStringObject();