From fb885c8bff26484f2bb21e697f182cc35bc4fa63 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期二, 12 五月 2020 15:27:08 +0800
Subject: [PATCH] 2.1.1 新需求
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java | 25 ++++++++++---------------
1 files changed, 10 insertions(+), 15 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 fdc3bc2..67f47ad 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
@@ -18,8 +18,7 @@
import com.yeshi.fanli.dto.mq.user.body.UserInviteMQMsg;
import com.yeshi.fanli.dto.mq.user.body.UserMoneyChangeMQMsg;
import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.user.invite.ThreeSaleFocusInfoService;
-import com.yeshi.fanli.service.inter.user.vip.TeamLevelDailyRecordService;
+import com.yeshi.fanli.service.inter.user.invite.TeamFansInfoService;
import com.yeshi.fanli.util.rocketmq.MQTopicName;
import net.sf.json.JSONObject;
@@ -34,10 +33,8 @@
public class UserTeamMessageListener implements MessageListener {
@Resource
- private ThreeSaleFocusInfoService threeSaleFocusInfoService;
+ private TeamFansInfoService teamFansInfoService;
- @Resource
- private TeamLevelDailyRecordService teamLevelDailyRecordService;
@Override
public Action consume(Message message, ConsumeContext context) {
@@ -56,16 +53,16 @@
UserActiveMQMsg userActiveMQMsg = new Gson().fromJson(json.toString(),UserActiveMQMsg.class);
if (userActiveMQMsg != null) {
// 鏇存敼鐢ㄦ埛娲昏穬鏃堕棿
- threeSaleFocusInfoService.updateActiveTime(userActiveMQMsg.getUid(), userActiveMQMsg.getCreateTime());
+ teamFansInfoService.updateActiveTime(userActiveMQMsg.getUid(), userActiveMQMsg.getCreateTime());
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 鐢ㄦ埛淇℃伅鏇存柊
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
UserInfoUpdateMQMsg mqMsg = new Gson().fromJson(json.toString(),UserInfoUpdateMQMsg.class);
if (mqMsg != null) {
if (UserInfoUpdateTypeEnum.nickName == mqMsg.getType()) { // 鏇存敼鏄电О
- threeSaleFocusInfoService.updateNickName(mqMsg.getUid(), mqMsg.getValue());
+ teamFansInfoService.updateNickName(mqMsg.getUid(), mqMsg.getValue());
} else if (UserInfoUpdateTypeEnum.wxId == mqMsg.getType()) { // 寰俊鍙风粦瀹�
- threeSaleFocusInfoService.updateWeixinBind(mqMsg.getUid(), true);
+ teamFansInfoService.updateWeixinBind(mqMsg.getUid(), true);
}
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.taobaoBindSuccess.name())) {// 娣樺疂缁戝畾鎴愬姛
@@ -74,10 +71,10 @@
TaoBaoBindSuccessMQMsg mqMsg = new Gson().fromJson(json.toString(),TaoBaoBindSuccessMQMsg.class);
if (mqMsg != null) {
// 鏇存柊娣樺疂缁戝畾
- threeSaleFocusInfoService.updateWeixinBind(mqMsg.getUid(), true);
+ teamFansInfoService.updateWeixinBind(mqMsg.getUid(), true);
Long fromUid = mqMsg.getFromUid();
if (fromUid != null) { // 娣樺疂琚В缁�
- threeSaleFocusInfoService.updateWeixinBind(fromUid, false);
+ teamFansInfoService.updateWeixinBind(fromUid, false);
}
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteSuccess.name())) {// 閭�璇锋垚鍔�
@@ -85,17 +82,15 @@
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(),UserInviteMQMsg.class);
if (mqMsg != null) {
- threeSaleFocusInfoService.updateFansNum(mqMsg.getBossId());
+ teamFansInfoService.updateFansNum(mqMsg.getBossId());
- // 閲嶆柊缁熻绮変笣绛夌骇鏁伴噺
- teamLevelDailyRecordService.addStatisticByUid(mqMsg.getBossId());
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.userMoneyAdd.name())) {// 璧勯噾鍒拌处
// 鏇存柊杩�60澶╁埌璐�
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
UserMoneyChangeMQMsg mqMsg = new Gson().fromJson(json.toString(),UserMoneyChangeMQMsg.class);
if (mqMsg != null) {
- threeSaleFocusInfoService.updateIncome(mqMsg.getUid(), mqMsg.getChangeMoney());
+ teamFansInfoService.updateIncome(mqMsg.getUid(), mqMsg.getChangeMoney());
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.becomeValidUser.name())) {// 鎴愪负鏈夋晥鐢ㄦ埛
// 鏈夋晥鐢ㄦ埛鏍囪瘑
@@ -103,7 +98,7 @@
BeComeValidUserMQMsg mqMsg = new Gson().fromJson(json.toString(),BeComeValidUserMQMsg.class);
if (mqMsg != null) {
// 鏇存柊鎴愪负鏈夋晥绮変笣
- threeSaleFocusInfoService.updateStateValid(mqMsg.getUid(), true);
+ teamFansInfoService.updateStateValid(mqMsg.getUid(), true);
}
}
}
--
Gitblit v1.8.0