记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 9cb23c7b authored by 胡佳晨's avatar 胡佳晨
Browse files
Options

修改脚本

parent bd68b976
Hide whitespace changes
Inline Side-by-side
Showing with 69 additions and 59 deletions
liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java
View file @ 9cb23c7b
...@@ -66,75 +66,80 @@ public class DataImpl { ...@@ -66,75 +66,80 @@ public class DataImpl {
public boolean initScore(int page, int size) { public boolean initScore(int page, int size) {
try { try {
//查询全部用户 long adamUserListCount = userMapper.selectCount(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1)
List<AdamUser> adamUserList = userMapper.selectList(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1)
.lt(AdamUser::getMid, 2753166) .lt(AdamUser::getMid, 2753166)
.select(AdamUser::getUid).orderByAsc(AdamUser::getMid).last("limit " + ((page - 1) * size) + "," + ((page) * size))); .select(AdamUser::getUid).orderByAsc(AdamUser::getMid));
log.info("AdamUserSize = " + adamUserList.size()); int number = page;
for (AdamUser item : adamUserList) { int fount = 5000;
//获取用户相关信息 while (adamUserListCount > 0) {
String uid = item.getUid(); //查询全部用户
AdamUserInfoVo userInfoVo = (AdamUserInfoVo) redisDataSourceUtil.getRedisAdamUtil().get(AdamRedisConst.INFO_USER.concat(uid)); List<AdamUser> adamUserList = userMapper.selectList(Wrappers.lambdaQuery(AdamUser.class).eq(AdamUser::getState, 1)
if (userInfoVo == null) { .lt(AdamUser::getMid, 2753166)
continue; .select(AdamUser::getUid).orderByAsc(AdamUser::getMid).last("limit " + ((number - 1) * fount) + "," + ((number) * fount)));
} for (AdamUser item : adamUserList) {
String mobile = userInfoVo.getMobile(); //获取用户相关信息
if (mobile == null) { String uid = item.getUid();
continue; AdamUserInfoVo userInfoVo = (AdamUserInfoVo) redisDataSourceUtil.getRedisAdamUtil().get(AdamRedisConst.INFO_USER.concat(uid));
} if (userInfoVo == null) {
int score = 0; continue;
//创建 用户积分数据 }
int isExists = stoneScoreUserMapper.selectCount(Wrappers.lambdaQuery(StoneScoreUser.class).eq(StoneScoreUser::getUid, uid)); String mobile = userInfoVo.getMobile();
if (isExists <= 0) { if (mobile == null) {
StoneScoreUser data = StoneScoreUser.getNew(); continue;
data.setStatus(1); }
data.setScoreId(IDGenerator.nextTimeId2()); int score = 0;
data.setUid(uid); //创建 用户积分数据
data.setCreatedAt(LocalDateTime.now()); int isExists = stoneScoreUserMapper.selectCount(Wrappers.lambdaQuery(StoneScoreUser.class).eq(StoneScoreUser::getUid, uid));
stoneScoreUserMapper.insert(data); if (isExists <= 0) {
StoneUserVo userTaskVo = StoneUserVo.getNew(); StoneScoreUser data = StoneScoreUser.getNew();
userTaskVo.getTask(); data.setStatus(1);
userTaskVo.setUid(uid); data.setScoreId(IDGenerator.nextTimeId2());
userTaskVo.setStatus(1); data.setUid(uid);
userCreate(userTaskVo); data.setCreatedAt(LocalDateTime.now());
} stoneScoreUserMapper.insert(data);
//获取演出每日任务积分 StoneUserVo userTaskVo = StoneUserVo.getNew();
Integer performancePrice = orderTicketsMapper.getOrderScore(uid); userTaskVo.getTask();
score += (performancePrice.intValue()); userTaskVo.setUid(uid);
//获取商品每日任务积分 userTaskVo.setStatus(1);
String resultData = HttpUtil.get("http://mall.zhengzai.tv/admin/sumUserCost?user_id=" + uid, null); userCreate(userTaskVo);
int goodsPrice = (int) JSONObject.parseObject(resultData).get("cost"); }
try { //获取演出每日任务积分
score += (goodsPrice); Integer performancePrice = orderTicketsMapper.getOrderScore(uid);
} catch (Exception e) { score += (performancePrice.intValue());
//获取商品每日任务积分
String resultData = HttpUtil.get("http://mall.zhengzai.tv/admin/sumUserCost?user_id=" + uid, null);
int goodsPrice = (int) JSONObject.parseObject(resultData).get("cost");
try {
score += (goodsPrice);
} catch (Exception e) {
} }
//获取 关注摩登天空服务号 //获取 关注摩登天空服务号
if (getUnionIdByPhone(mobile) != null) { if (getUnionIdByPhone(mobile) != null) {
stoneIntegralClient.doTask(4, uid); stoneIntegralClient.doTask(4, uid);
// MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString(); // MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
// params.add("uid", uid); // params.add("uid", uid);
// params.add("taskId", 4 + ""); // params.add("taskId", 4 + "");
// HttpUtil.post(stoneUrl + "/user/inner/doTask", params); // HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
} }
//获取用户相关信息 //获取用户相关信息
if (null != userInfoVo.getSex()) { if (null != userInfoVo.getSex()) {
//获取 完善个人信息 //获取 完善个人信息
stoneIntegralClient.doTask(5, uid); stoneIntegralClient.doTask(5, uid);
// MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString(); // MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
// params.add("uid", uid); // params.add("uid", uid);
// params.add("taskId", 5 + ""); // params.add("taskId", 5 + "");
// HttpUtil.post(stoneUrl + "/user/inner/doTask", params); // HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
} }
if (StringUtils.isNotBlank(userInfoVo.getBackground()) && !defaultBackgroundList.contains(userInfoVo.getBackground())) { if (StringUtils.isNotBlank(userInfoVo.getBackground()) && !defaultBackgroundList.contains(userInfoVo.getBackground())) {
//获取 完善个人照片 //获取 完善个人照片
stoneIntegralClient.doTask(6, uid); stoneIntegralClient.doTask(6, uid);
// MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString(); // MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
// params.add("uid", uid); // params.add("uid", uid);
// params.add("taskId", 6 + ""); // params.add("taskId", 6 + "");
// HttpUtil.post(stoneUrl + "/user/inner/doTask", params); // HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
} }
// if (userInfoVo.getIsComplete() == 11) { // if (userInfoVo.getIsComplete() == 11) {
// //获取 首次体验在场 // //获取 首次体验在场
// MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString(); // MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
...@@ -142,18 +147,23 @@ public class DataImpl { ...@@ -142,18 +147,23 @@ public class DataImpl {
// params.add("taskId", 8 + ""); // params.add("taskId", 8 + "");
// HttpUtil.post(stoneUrl + "/user/inner/doTask", params); // HttpUtil.post(stoneUrl + "/user/inner/doTask", params);
// } // }
//生成用户积分日志 //生成用户积分日志
int isLog = stoneScoreLogsMapper.selectCount(Wrappers.lambdaQuery(StoneScoreLogs.class).eq(StoneScoreLogs::getUid, uid).eq(StoneScoreLogs::getContent, "历史积分")); int isLog = stoneScoreLogsMapper.selectCount(Wrappers.lambdaQuery(StoneScoreLogs.class).eq(StoneScoreLogs::getUid, uid).eq(StoneScoreLogs::getContent, "历史积分"));
if (isLog <= 0) { if (isLog <= 0) {
stoneIntegralClient.in2111(uid, score, "历史积分"); stoneIntegralClient.in2111(uid, score, "历史积分");
// MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString(); // MultiValueMap<String, String> params = CollectionUtil.linkedMultiValueMapStringString();
// params.add("uid", uid); // params.add("uid", uid);
// params.add("score", (score >= 12000 ? 12000 : score) + ""); // params.add("score", (score >= 12000 ? 12000 : score) + "");
// params.add("content", "历史积分"); // params.add("content", "历史积分");
// HttpUtil.post(stoneUrl + "/user/logs/in2111", params); // HttpUtil.post(stoneUrl + "/user/logs/in2111", params);
}
log.error("[ TASK INIT UID ] uid = " + uid);
} }
log.info("uid = " + uid); log.error("[ TASK INIT NUMBER ] number = " + number);
adamUserListCount -= fount;
number += 1;
} }
log.error("[ TASK INIT SCORE ] FINISH ");
} catch (Exception e) { } catch (Exception e) {
log.info("异常 : {} ", e); log.info("异常 : {} ", e);
e.printStackTrace(); e.printStackTrace();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment