From a9c9da611563738e2974103a45270d5857b746b6 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期四, 07 五月 2020 19:30:28 +0800
Subject: [PATCH] 队员相关 + 消息删除
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserTeamMessageListener.java | 84 ++++++++++++++++++++++++++++++++++--------
1 files changed, 68 insertions(+), 16 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 23e2eda..fdc3bc2 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
@@ -1,14 +1,28 @@
package com.yeshi.fanli.util.rocketmq.consumer.user;
+import javax.annotation.Resource;
+
import org.springframework.stereotype.Component;
import com.aliyun.openservices.ons.api.Action;
import com.aliyun.openservices.ons.api.ConsumeContext;
import com.aliyun.openservices.ons.api.Message;
import com.aliyun.openservices.ons.api.MessageListener;
+import com.google.gson.Gson;
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.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.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.util.rocketmq.MQTopicName;
+
+import net.sf.json.JSONObject;
/**
* 鐢ㄦ埛绮変笣娑堟伅
@@ -19,6 +33,12 @@
@Component
public class UserTeamMessageListener implements MessageListener {
+ @Resource
+ private ThreeSaleFocusInfoService threeSaleFocusInfoService;
+
+ @Resource
+ private TeamLevelDailyRecordService teamLevelDailyRecordService;
+
@Override
public Action consume(Message message, ConsumeContext context) {
@@ -32,27 +52,59 @@
if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
if (tag.equalsIgnoreCase(UserTopicTagEnum.userActve.name())) {// 鐢ㄦ埛娲昏穬
- // TODO 鏇存敼鐢ㄦ埛娲昏穬鏃堕棿
-
+ JSONObject json = JSONObject.fromObject(new String(message.getBody()));
+ UserActiveMQMsg userActiveMQMsg = new Gson().fromJson(json.toString(),UserActiveMQMsg.class);
+ if (userActiveMQMsg != null) {
+ // 鏇存敼鐢ㄦ埛娲昏穬鏃堕棿
+ threeSaleFocusInfoService.updateActiveTime(userActiveMQMsg.getUid(), userActiveMQMsg.getCreateTime());
+ }
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 鐢ㄦ埛淇℃伅鏇存柊
-
- // TODO 鏇存敼寰俊鍙风粦瀹�
-
+ 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());
+ } else if (UserInfoUpdateTypeEnum.wxId == mqMsg.getType()) { // 寰俊鍙风粦瀹�
+ threeSaleFocusInfoService.updateWeixinBind(mqMsg.getUid(), true);
+ }
+ }
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.taobaoBindSuccess.name())) {// 娣樺疂缁戝畾鎴愬姛
-
- // TODO 鏇存敼娣樺疂缁戝畾鐘舵�佷笌鍘熺敤鎴锋窐瀹濈粦瀹氱姸鎬�
-
+ // 鏇存敼娣樺疂缁戝畾鐘舵�佷笌鍘熺敤鎴锋窐瀹濈粦瀹氱姸鎬�
+ JSONObject json = JSONObject.fromObject(new String(message.getBody()));
+ TaoBaoBindSuccessMQMsg mqMsg = new Gson().fromJson(json.toString(),TaoBaoBindSuccessMQMsg.class);
+ if (mqMsg != null) {
+ // 鏇存柊娣樺疂缁戝畾
+ threeSaleFocusInfoService.updateWeixinBind(mqMsg.getUid(), true);
+ Long fromUid = mqMsg.getFromUid();
+ if (fromUid != null) { // 娣樺疂琚В缁�
+ threeSaleFocusInfoService.updateWeixinBind(fromUid, false);
+ }
+ }
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteSuccess.name())) {// 閭�璇锋垚鍔�
-
- // TODO 鏇存柊绮変笣鏁伴噺
-
+ // 鏇存柊绮変笣鏁伴噺
+ JSONObject json = JSONObject.fromObject(new String(message.getBody()));
+ UserInviteMQMsg mqMsg = new Gson().fromJson(json.toString(),UserInviteMQMsg.class);
+ if (mqMsg != null) {
+ threeSaleFocusInfoService.updateFansNum(mqMsg.getBossId());
+
+ // 閲嶆柊缁熻绮変笣绛夌骇鏁伴噺
+ teamLevelDailyRecordService.addStatisticByUid(mqMsg.getBossId());
+ }
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.userMoneyAdd.name())) {// 璧勯噾鍒拌处
-
- // TODO 鏇存柊杩�60澶╁埌璐�
-
+ // 鏇存柊杩�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());
+ }
} else if (tag.equalsIgnoreCase(UserTopicTagEnum.becomeValidUser.name())) {// 鎴愪负鏈夋晥鐢ㄦ埛
-
- // TODO 鏈夋晥鐢ㄦ埛鏍囪瘑
+ // 鏈夋晥鐢ㄦ埛鏍囪瘑
+ JSONObject json = JSONObject.fromObject(new String(message.getBody()));
+ BeComeValidUserMQMsg mqMsg = new Gson().fromJson(json.toString(),BeComeValidUserMQMsg.class);
+ if (mqMsg != null) {
+ // 鏇存柊鎴愪负鏈夋晥绮変笣
+ threeSaleFocusInfoService.updateStateValid(mqMsg.getUid(), true);
+ }
}
}
return Action.CommitMessage;
--
Gitblit v1.8.0