From 03f9370b85d930bd232f72721e826b5875f898cb Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期六, 16 五月 2020 13:52:58 +0800 Subject: [PATCH] 用户登录后要验证电话号码是否已经绑定 --- fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java | 13 +------------ 1 files changed, 1 insertions(+), 12 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 2f1df19..47c3d3e 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 @@ -88,18 +88,7 @@ } 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()); - if (boss != null) { - teamUserLevelStatisticService.initData(boss.getId()); - } - return Action.CommitMessage; - } + } } else if (MQTopicName.TOPIC_ORDER.name().equalsIgnoreCase(message.getTopic())) { // 璁㈠崟鍒拌处鐩稿叧 -- Gitblit v1.8.0