From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/InvitePictureChangeMessageListener.java | 152 ++++++++++++++++++++++++++++----------------------
1 files changed, 85 insertions(+), 67 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..867665e 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
@@ -1,67 +1,85 @@
-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.InviteCodeActiveMQMsg;
-import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg;
-import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg.UserInfoUpdateTypeEnum;
-import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.user.SpreadUserImgService;
-import com.yeshi.fanli.util.rocketmq.MQTopicName;
-
-/**
- * 鐢ㄦ埛閭�璇峰浘鏀瑰彉
- *
- * @author Administrator
- *
- */
-@Component
-public class InvitePictureChangeMessageListener implements MessageListener {
-
- @Resource
- private SpreadUserImgService spreadUserImgService;
-
- @Override
- public Action consume(Message message, ConsumeContext context) {
- LogHelper.mqInfo("consumer-InvitePictureChangeMessageListener", message.getMsgID(), message.getTopic(),
- message.getTag(), new String(message.getBody()));
- String tag = message.getTag();
- if (tag == null)
- tag = "";
-
- if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
- if (tag.equalsIgnoreCase(UserTopicTagEnum.inviteCodeActive.name())) {// 閭�璇风爜婵�娲�
- InviteCodeActiveMQMsg inviteCodeActiveMQMsg = new Gson().fromJson(new String(message.getBody()),
- InviteCodeActiveMQMsg.class);
- if (inviteCodeActiveMQMsg != null && inviteCodeActiveMQMsg.getUid() != null)
- spreadUserImgService.deleteImgUrl(inviteCodeActiveMQMsg.getUid());
-
- return Action.CommitMessage;
- } else if (tag.equalsIgnoreCase(UserTopicTagEnum.userInfoUpdate.name())) {// 璁㈠崟缁熻
-
- try {
- UserInfoUpdateMQMsg userInfoUpdateMQMsg = new Gson().fromJson(new String(message.getBody()),
- UserInfoUpdateMQMsg.class);
- if (userInfoUpdateMQMsg != null && (userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.portrait
- || userInfoUpdateMQMsg.getType() == UserInfoUpdateTypeEnum.inviteCode)) {
- if (userInfoUpdateMQMsg.getUid() != null)
- spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());
- }
- return Action.CommitMessage;
- } catch (Exception e) {
- LogHelper.errorDetailInfo(e, "msgId:" + message.getMsgID(), "");
- }
-
- }
- }
- return Action.CommitMessage;
- }
-}
+package com.yeshi.fanli.util.rocketmq.consumer.user;
+
+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;
+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.InviteCodeActiveMQMsg;
+import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg;
+import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg.UserInfoUpdateTypeEnum;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.user.SpreadUserImgService;
+import com.yeshi.fanli.util.rocketmq.MQTopicName;
+
+/**
+ * 鐢ㄦ埛閭�璇峰浘鏀瑰彉
+ *
+ * @author Administrator
+ *
+ */
+@Component
+public class InvitePictureChangeMessageListener implements MessageListener {
+
+ @Resource
+ private SpreadUserImgService spreadUserImgService;
+ @Resource
+ private UserInfoService userInfoService;
+
+ @Override
+ public Action consume(Message message, ConsumeContext context) {
+ LogHelper.mqInfo("consumer-InvitePictureChangeMessageListener", message.getMsgID(), message.getTopic(),
+ message.getTag(), new String(message.getBody()));
+ String tag = message.getTag();
+ if (tag == null)
+ tag = "";
+
+ if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
+ 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())) {// 鐢ㄦ埛淇℃伅鏇存柊
+
+ 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)
+ spreadUserImgService.deleteImgUrl(userInfoUpdateMQMsg.getUid());
+ }
+ return Action.CommitMessage;
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e, "msgId:" + message.getMsgID(), "");
+ }
+
+ }
+ }
+ return Action.CommitMessage;
+ }
+}
--
Gitblit v1.8.0