积分明细

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

@@ -43,7 +43,7 @@ import java.util.List;
 public class DataImpl {
 
     @Value("${liquidnet.service.stone.url}")
-    private String stoneUrl ;
+    private String stoneUrl;
 
     @Autowired
     private MongoTemplate mongoTemplate;
@@ -66,9 +66,9 @@ public class DataImpl {
             //查询全部用户
             List<AdamUser> adamUserList = userMapper.selectList(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1)
                     .select(AdamUser::getUid).last("limit " + ((page - 1) * size) + "," + ((page) * size)));
-            log.info("AdamUserSize = "+adamUserList.size());
+            log.info("AdamUserSize = " + adamUserList.size());
+            int finishCount = 0;
             for (AdamUser item : adamUserList) {
-                int finishCount = 0;
                 //获取用户相关信息
                 String uid = item.getUid();
                 String mobile = item.getMobile();
@@ -138,10 +138,11 @@ public class DataImpl {
                     params.add("content", "历史积分");
                     HttpUtil.post(stoneUrl + "/user/logs/in2111", params);
                 }
-                finishCount+=1;
-                log.info("finishCount = "+finishCount);
+                finishCount += 1;
             }
+            log.info("完成次数 = " + finishCount);
         } catch (Exception e) {
+            log.info("异常 : {} ", e);
             e.printStackTrace();
             return false;
         }
@@ -239,20 +240,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();
+            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);
+        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);
+        redisDataSourceUtil.getRedisStoneUtil().set(useKey, scoreUse);
+        redisDataSourceUtil.getRedisStoneUtil().set(restKey, scoreAll - scoreUse);
         return true;
     }
 
@@ -289,7 +290,7 @@ public class DataImpl {
     }
 
     public HashMap<String, Object> logList(String uid, int page, int size) {
-        LocalDateTime now  = LocalDateTime.now();
+        LocalDateTime now = LocalDateTime.now();
         HashMap<String, Object> info = CollectionUtil.mapStringObject();
         // 排序 分页
         Pageable pageable = PageRequest.of(page - 1, size, Sort.by(Sort.Direction.DESC, "createdAt"));