数据迁移

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

@@ -26,4 +26,11 @@ public class DataController {
         Boolean result = data.initScore(page,size);
         return ResponseDto.success(result);
     }
+
+    @PostMapping("initScoreSingle")
+    @ApiOperation("积分数据迁移(根据uid)")
+    public ResponseDto<Boolean> initScore(@RequestParam("uid") String uid) {
+        Boolean result = data.initScore(uid);
+        return ResponseDto.success(result);
+    }
 }

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

@@ -150,6 +150,73 @@ public class DataImpl {
         return true;
     }
 
+    public boolean initScore(String uid) {
+        try {
+            //获取用户相关信息
+            AdamUserInfoVo userInfoVo = (AdamUserInfoVo) redisUtil.get(AdamRedisConst.INFO_USER.concat(uid));
+            if (userInfoVo == null) {
+                System.out.println("REDIS KEY = " + AdamRedisConst.INFO_USER.concat(uid));
+            }
+            int score = 0;
+            //创建 用户积分数据
+            int isExists = stoneScoreUserMapper.selectCount(Wrappers.lambdaQuery(StoneScoreUser.class).eq(StoneScoreUser::getUid, uid));
+            if (isExists <= 0) {
+                StoneScoreUser data = new StoneScoreUser();
+                data.setStatus(1);
+                data.setScoreId(IDGenerator.nextTimeId2());
+                data.setUid(uid);
+                data.setCreatedAt(LocalDateTime.now());
+                stoneScoreUserMapper.insert(data);
+
+                StoneUserVo userTaskVo = StoneUserVo.getNew();
+                userTaskVo.getTask();
+                userTaskVo.setUid(uid);
+                userTaskVo.setStatus(1);
+                userCreate(userTaskVo);
+            }
+            //获取演出每日任务积分
+            int performanceCount = orderTicketsMapper.getOrderScore(uid).size();
+            score += performanceCount * 5;
+            //获取商品每日任务积分
+            //获取 关注摩登天空服务号
+            //获取用户相关信息
+            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);
+            }
+            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);
+            }
+            if (userInfoVo.getIsComplete() == 11) {
+                //获取 首次体验在场
+                MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
+                params.add("uid", uid);
+                params.add("taskId", 8 + "");
+                HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
+            }
+            //生成用户积分日志
+            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 + "");
+                params.add("content", "历史积分");
+                HttpUtil.post(stoneUrl + "/user/logs/in2111", params);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+        return true;
+    }
+
     /**
      * 创建 用户积分
      *