From 2ec42a5aacea35d2918f0e17f07685cf5b4d25c8 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 12 五月 2020 20:20:41 +0800 Subject: [PATCH] 包名引用路径更改 --- fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java | 18 ++++++++++++++++++ 1 files changed, 18 insertions(+), 0 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java index b0652a6..2f1df19 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java @@ -50,6 +50,7 @@ @Resource private UserActiveLogService userActiveLogService; + @Override public Action consume(Message message, ConsumeContext context) { @@ -69,6 +70,12 @@ if (tag.equalsIgnoreCase(UserTopicTagEnum.userLevelChanged.name())) {// 鐢ㄦ埛绛夌骇鍙戠敓鍙樺寲 UserLevelChangedMQMsg msg = new Gson().fromJson(new String(message.getBody()), UserLevelChangedMQMsg.class); + + for (Long fuid : Constant.NO_UPGRADE_UIDS) {// 绂佹涓嶈兘鍗囩骇鐨勭敤鎴峰崌绾� + if (msg.getUid().longValue() == fuid) + return Action.CommitMessage; + } + // 鏇存柊涓�2绾х殑閭�璇风粺璁� teamUserLevelStatisticService.updateUserLevel(msg.getUid()); UserInfo boss = threeSaleSerivce.getBoss(msg.getUid()); @@ -78,11 +85,13 @@ if (boss != null) { teamUserLevelStatisticService.initData(boss.getId()); } + } return Action.CommitMessage; } else if (tag.equalsIgnoreCase(UserTopicTagEnum.threeSaleSeparate.name())) {// 閭�璇峰叧绯昏劚绂� ThreeSaleSeparateMQMsg msg = new Gson().fromJson(new String(message.getBody()), ThreeSaleSeparateMQMsg.class); + // 鏇存柊涓婁袱绾ч個璇风粺璁� teamUserLevelStatisticService.initData(msg.getBossUid()); UserInfo boss = threeSaleSerivce.getBoss(msg.getBossUid()); @@ -98,6 +107,10 @@ OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(message.getBody()), OrderMoneyRecievedMQMsg.class); if (dto != null) { + for (Long fuid : Constant.NO_UPGRADE_UIDS) {// 绂佹涓嶈兘鍗囩骇鐨勭敤鎴峰崌绾� + if (dto.getUid().longValue() == fuid) + return Action.CommitMessage; + } // 鍒ゆ柇鐗堟湰 UserActiveLog log = userActiveLogService.getUserLatestActiveInfo(dto.getUid()); @@ -117,6 +130,11 @@ } else if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderConfirm.name())) { OrderConfirmMQMsg dto = new Gson().fromJson(new String(message.getBody()), OrderConfirmMQMsg.class); if (dto != null) { + for (Long fuid : Constant.NO_UPGRADE_UIDS) {// 绂佹涓嶈兘鍗囩骇鐨勭敤鎴峰崌绾� + if (dto.getSourceUid().longValue() == fuid) + return Action.CommitMessage; + } + // 浼氬憳绛夌骇鍗囩骇-绮変笣鏁伴噺楠岃瘉 userVIPPreInfoService.upgradeVipByTeamNum(dto.getSourceUid()); userInviteValidNumService.addValidTeamNum(dto.getSourceUid(), dto.getSettleMent(), -- Gitblit v1.8.0