From eec7e789a87863c25d92c10ad5dfc22ad80c448d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 14 七月 2020 12:36:48 +0800
Subject: [PATCH] 系统区分BUG修复
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java | 20 +++++++++++++++++++-
1 files changed, 19 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
index ee0daa5..3553d52 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java
@@ -2,6 +2,10 @@
import javax.annotation.Resource;
+import com.yeshi.fanli.entity.SystemEnum;
+import com.yeshi.fanli.entity.SystemFunction;
+import com.yeshi.fanli.service.inter.user.UserInfoService;
+import com.yeshi.fanli.util.SystemInfoUtil;
import org.springframework.stereotype.Component;
import com.aliyun.openservices.ons.api.Action;
@@ -28,6 +32,8 @@
@Resource
private SpreadUserImgService spreadUserImgService;
+ @Resource
+ private UserInfoService userInfoService;
@Override
public Action consume(Message message, ConsumeContext context) {
@@ -41,15 +47,27 @@
if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteCodeActive.name())) {// 閭�璇风爜婵�娲�
InviteCodeActiveMQMsg inviteCodeActiveMQMsg = new Gson().fromJson(new String(message.getBody()),
InviteCodeActiveMQMsg.class);
+
+ //鏄惁鏈変笁绾у垎閿�鏉冮檺
+ SystemEnum system = userInfoService.getUserSystem(inviteCodeActiveMQMsg.getUid());
+ if (!SystemInfoUtil.hasFunctions(system, SystemFunction.threeSale))
+ return Action.CommitMessage;
+
if (inviteCodeActiveMQMsg != null && inviteCodeActiveMQMsg.getUid() != null)
spreadUserImgService.deleteImgUrl(inviteCodeActiveMQMsg.getUid());
return Action.CommitMessage;
- } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 璁㈠崟缁熻
+ } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 鐢ㄦ埛淇℃伅鏇存柊
try {
UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),
UserInfoUpdateMQMsg.class);
+
+ //鏄惁鏈変笁绾у垎閿�鏉冮檺
+ SystemEnum system = userInfoService.getUserSystem(userInfoUpdateMQMsg.getUid());
+ if (!SystemInfoUtil.hasFunctions(system, SystemFunction.threeSale))
+ return Action.CommitMessage;
+
if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait
|| userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {
if (userInfoUpdateMQMsg.getUid() != null)
--
Gitblit v1.8.0