From eec7e789a87863c25d92c10ad5dfc22ad80c448d Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 14 七月 2020 12:36:48 +0800 Subject: [PATCH] 系统区分BUG修复 --- fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java | 26 +++++++++++++++++++++++--- 1 files changed, 23 insertions(+), 3 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java index a64262a..c9b492d 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java @@ -20,9 +20,13 @@ import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg; import com.yeshi.fanli.dto.mq.user.body.UserMoneyChangeMQMsg; import com.yeshi.fanli.dto.mq.user.body.UserPhoneOpenMQMsg; +import com.yeshi.fanli.entity.bus.user.ThreeSale; +import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.user.invite.TeamFansInfoService; import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService; +import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce; +import com.yeshi.fanli.service.inter.user.vip.TeamUserLevelStatisticService; import com.yeshi.fanli.util.rocketmq.MQTopicName; import net.sf.json.JSONObject; @@ -41,6 +45,12 @@ @Resource private ThreeSaleDetailService threeSaleDetailService; + + @Resource + private ThreeSaleSerivce threeSaleSerivce; + + @Resource + private TeamUserLevelStatisticService teamUserLevelStatisticService; @Override public Action consume(Message message, ConsumeContext context) { @@ -87,12 +97,22 @@ JSONObject json = JSONObject.fromObject(new String(message.getBody())); UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(), UserInviteMQMsg.class); if (mqMsg != null) { + ThreeSale ts = threeSaleSerivce.selectByWorkerId(mqMsg.getWorkerId()); + if (ts == null) + return Action.ReconsumeLater; + // 鏇存柊涓婄骇鐨勭矇涓濇暟閲� teamFansInfoService.updateFansNum(mqMsg.getBossId()); - // 娣诲姞绮変笣淇℃伅 - teamFansInfoService.addFansInfo(mqMsg.getWorkerId(), mqMsg.getBossId(),mqMsg.getSuccessTime()); - + threeSaleDetailService.addByWorkerUid(mqMsg.getWorkerId()); + + // 鏇存柊闃熷憳缁熻淇℃伅 + teamUserLevelStatisticService.initData(mqMsg.getBossId()); + UserInfo boss = threeSaleSerivce.getBoss(mqMsg.getBossId()); + if (boss != null) { + teamUserLevelStatisticService.initData(boss.getId()); + } + } } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userMoneyAdd.name())) {// 璧勯噾鍒拌处 JSONObject json = JSONObject.fromObject(new String(message.getBody())); -- Gitblit v1.8.0