修改脚本

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.feign.stone.api.FeignStoneIntegralClient;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
 import com.liquidnet.service.kylin.mapper.*;
 import com.liquidnet.service.stone.constant.StoneConstant;
@@ -59,15 +60,17 @@ public class DataImpl {
     StoneScoreUserMapper stoneScoreUserMapper;
     @Autowired
     StoneScoreLogsMapper stoneScoreLogsMapper;
+    @Autowired
+    FeignStoneIntegralClient stoneIntegralClient;
 
 
     public boolean initScore(int page, int size) {
         try {
             //查询全部用户
             List<AdamUser> adamUserList = userMapper.selectList(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1)
-                    .select(AdamUser::getUid).last("limit " + ((page - 1) * size) + "," + ((page) * size)));
+                    .lt(AdamUser::getMid, 2753166)
+                    .select(AdamUser::getUid).orderByAsc(AdamUser::getMid).last("limit " + ((page - 1) * size) + "," + ((page) * size)));
             log.info("AdamUserSize = " + adamUserList.size());
-            int finishCount = 0;
             for (AdamUser item : adamUserList) {
                 //获取用户相关信息
                 String uid = item.getUid();
@@ -109,25 +112,28 @@ public class DataImpl {
 
                 //获取 关注摩登天空服务号
                 if (getUnionIdByPhone(mobile) != null) {
-                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
-                    params.add("uid", uid);
-                    params.add("taskId", 4 + "");
-                    HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
+                    stoneIntegralClient.doTask(4, uid);
+//                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+//                    params.add("uid", uid);
+//                    params.add("taskId", 4 + "");
+//                    HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
                 }
                 //获取用户相关信息
                 if (null != userInfoVo.getSex()) {
                     //获取 完善个人信息
-                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
-                    params.add("uid", uid);
-                    params.add("taskId", 5 + "");
-                    HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
+                    stoneIntegralClient.doTask(5, uid);
+//                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+//                    params.add("uid", uid);
+//                    params.add("taskId", 5 + "");
+//                    HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
                 }
                 if (StringUtils.isNotBlank(userInfoVo.getBackground()) && !defaultBackgroundList.contains(userInfoVo.getBackground())) {
                     //获取 完善个人照片
-                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
-                    params.add("uid", uid);
-                    params.add("taskId", 6 + "");
-                    HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
+                    stoneIntegralClient.doTask(6, uid);
+//                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+//                    params.add("uid", uid);
+//                    params.add("taskId", 6 + "");
+//                    HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
                 }
 //                if (userInfoVo.getIsComplete() == 11) {
 //                    //获取 首次体验在场
@@ -139,15 +145,15 @@ public class DataImpl {
                 //生成用户积分日志
                 int isLog = stoneScoreLogsMapper.selectCount(Wrappers.lambdaQuery(StoneScoreLogs.class).eq(StoneScoreLogs::getUid, uid).eq(StoneScoreLogs::getContent, "历史积分"));
                 if (isLog <= 0) {
-                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
-                    params.add("uid", uid);
-                    params.add("score", (score >= 12000 ? 12000 : score) + "");
-                    params.add("content", "历史积分");
-                    HttpUtil.post(stoneUrl + "/user/logs/in2111", params);
+                    stoneIntegralClient.in2111(uid, score, "历史积分");
+//                    MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+//                    params.add("uid", uid);
+//                    params.add("score", (score >= 12000 ? 12000 : score) + "");
+//                    params.add("content", "历史积分");
+//                    HttpUtil.post(stoneUrl + "/user/logs/in2111", params);
                 }
-                finishCount += 1;
+                log.info("uid = " + uid);
             }
-            log.info("完成次数 = " + finishCount);
         } catch (Exception e) {
             log.info("异常 : {} ", e);
             e.printStackTrace();