From 7a408cba1b66e4e644d42a747f427938e6274dd8 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期四, 14 五月 2020 16:35:05 +0800
Subject: [PATCH] 粉丝信息消息
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java | 35 ++++++++++++++++++++++++++++++-----
1 files changed, 30 insertions(+), 5 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 74d2a21..c7fddce 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
@@ -12,11 +12,14 @@
import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
import com.yeshi.fanli.dto.mq.user.body.BeComeValidUserMQMsg;
import com.yeshi.fanli.dto.mq.user.body.TaoBaoBindSuccessMQMsg;
+import com.yeshi.fanli.dto.mq.user.body.UserAccountBindingMQMsg;
import com.yeshi.fanli.dto.mq.user.body.UserActiveMQMsg;
import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg;
import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg.UserInfoUpdateTypeEnum;
import com.yeshi.fanli.dto.mq.user.body.UserInviteMQMsg;
+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.log.LogHelper;
import com.yeshi.fanli.service.inter.user.invite.TeamFansInfoService;
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleDetailService;
@@ -49,7 +52,6 @@
tag = "";
// 璁㈤槄绮変笣澧炲姞/绮変笣鎴愪负鏈夋晥鐢ㄦ埛 娑堟伅,娣樺疂鎺堟潈锛屽井淇″彿缁戝畾锛屾渶杩戠櫥褰曪紝鐢ㄦ埛璧勯噾澧炲姞
-
if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
if (tag.equalsIgnoreCase(UserTopicTagEnum.userActve.name())) {// 鐢ㄦ埛娲昏穬
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
@@ -66,6 +68,8 @@
teamFansInfoService.updateNickName(mqMsg.getUid(), mqMsg.getValue());
} else if (UserInfoUpdateTypeEnum.wxId == mqMsg.getType()) { // 寰俊鍙风粦瀹�
teamFansInfoService.updateWeixinId(mqMsg.getUid(), mqMsg.getValue());
+ } else if (UserInfoUpdateTypeEnum.inviteCode == mqMsg.getType()) { // 閭�璇风爜鏇存敼
+ teamFansInfoService.updateInviteCode(mqMsg.getUid(), mqMsg.getValue());
}
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.taobaoBindSuccess.name())) {// 娣樺疂缁戝畾鎴愬姛
@@ -73,7 +77,6 @@
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
TaoBaoBindSuccessMQMsg mqMsg = new Gson().fromJson(json.toString(), TaoBaoBindSuccessMQMsg.class);
if (mqMsg != null) {
- // 鏇存柊娣樺疂缁戝畾
teamFansInfoService.updateTaobaoBind(mqMsg.getUid(), true);
Long fromUid = mqMsg.getFromUid();
if (fromUid != null) { // 娣樺疂琚В缁�
@@ -81,28 +84,50 @@
}
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteSuccess.name())) {// 閭�璇锋垚鍔�
- // 鏇存柊绮変笣鏁伴噺
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(), UserInviteMQMsg.class);
if (mqMsg != null) {
+ // 鏇存柊涓婄骇鐨勭矇涓濇暟閲�
teamFansInfoService.updateFansNum(mqMsg.getBossId());
+ // 娣诲姞绮変笣淇℃伅
+ teamFansInfoService.addFansInfo(mqMsg.getWorkerId(), mqMsg.getBossId());
+
threeSaleDetailService.addByWorkerUid(mqMsg.getWorkerId());
}
} 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) {
+ // 鏇存柊杩�60澶╁埌璐�
teamFansInfoService.updateIncome(mqMsg.getUid(), mqMsg.getChangeMoney());
}
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.becomeValidUser.name())) {// 鎴愪负鏈夋晥鐢ㄦ埛
- // 鏈夋晥鐢ㄦ埛鏍囪瘑
JSONObject json = JSONObject.fromObject(new String(message.getBody()));
BeComeValidUserMQMsg mqMsg = new Gson().fromJson(json.toString(), BeComeValidUserMQMsg.class);
if (mqMsg != null) {
// 鏇存柊鎴愪负鏈夋晥绮変笣
teamFansInfoService.updateStateValid(mqMsg.getUid(), true);
}
+ } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userAccountBinding.name())) {// 缁戝畾淇℃伅
+ JSONObject json = JSONObject.fromObject(new String(message.getBody()));
+ UserAccountBindingMQMsg mqMsg = new Gson().fromJson(json.toString(), UserAccountBindingMQMsg.class);
+ if (mqMsg != null) {
+ if (mqMsg.getType() == UserAccountBindingMQMsg.TYPE_PHONE) { // 缁戝畾鐢佃瘽鍙风爜
+ teamFansInfoService.updatePhone(mqMsg.getUid(), mqMsg.getValue());
+ }
+ }
+ } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userLevelChanged.name())) {// 绛夌骇鍙樺寲
+ JSONObject json = JSONObject.fromObject(new String(message.getBody()));
+ UserLevelChangedMQMsg mqMsg = new Gson().fromJson(json.toString(), UserLevelChangedMQMsg.class);
+ if (mqMsg != null) {
+ teamFansInfoService.updateLevel(mqMsg.getUid(), mqMsg.getToLevel());
+ }
+ } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userPhoneOpen.name())) {// 鐢佃瘽鍙风爜鍏紑
+ JSONObject json = JSONObject.fromObject(new String(message.getBody()));
+ UserPhoneOpenMQMsg mqMsg = new Gson().fromJson(json.toString(), UserPhoneOpenMQMsg.class);
+ if (mqMsg != null) {
+ teamFansInfoService.updatePhoneOpen(mqMsg.getUid(), mqMsg.isState());
+ }
}
}
return Action.CommitMessage;
--
Gitblit v1.8.0