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/UserCloudMessageListener.java | 112 +++++++++++++++++++++++++++-----------------------------
1 files changed, 54 insertions(+), 58 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserCloudMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserCloudMessageListener.java
index fcdf0a9..4226a90 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserCloudMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserCloudMessageListener.java
@@ -1,58 +1,54 @@
-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.order.OrderTopicTagEnum;
-import com.yeshi.fanli.dto.mq.order.body.OrderConfirmMQMsg;
-import com.yeshi.fanli.dto.mq.order.body.OrderMoneyRecievedMQMsg;
-import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
-import com.yeshi.fanli.dto.mq.user.body.UserCloudMQMsg;
-import com.yeshi.fanli.entity.bus.user.UserActiveLog;
-import com.yeshi.fanli.entity.bus.user.UserInfo;
-import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;
-import com.yeshi.fanli.util.Constant;
-import com.yeshi.fanli.util.VersionUtil;
-import com.yeshi.fanli.util.rocketmq.MQTopicName;
-
-/**
- * 鐢ㄦ埛浜戝彂鍗�
- *
- * @author Administrator
- *
- */
-@Component
-public class UserCloudMessageListener implements MessageListener {
-
- @Resource
- private UserCloudService userCloudService;
-
- @Override
- public Action consume(Message message, ConsumeContext context) {
- LogHelper.mqInfo("consumer-UserCloudMessageListener", 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.userCloud.name())) {
- UserCloudMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserCloudMQMsg.class);
- if (msg.getType() == UserCloudMQMsg.TYPE_EVALUATE) {
- LogHelper.cloudInfo("鍙戝湀涓俊鎭� -" + msg.getId() );
- userCloudService.autoSendByDynamic(msg.getUid(), msg.getId());
- } else {
- LogHelper.cloudInfo("閫夊搧搴撲俊鎭� -" + msg.getId() );
- userCloudService.autoSendCustomGoods(msg.getUid(), Long.parseLong(msg.getId()));
- }
- }
- }
- return Action.CommitMessage;
- }
-}
+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.UserCloudMQMsg;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;
+import com.yeshi.fanli.util.rocketmq.MQTopicName;
+
+/**
+ * 鐢ㄦ埛浜戝彂鍗�
+ *
+ * @author Administrator
+ *
+ */
+@Component
+public class UserCloudMessageListener implements MessageListener {
+
+ @Resource
+ private UserCloudService userCloudService;
+
+ @Override
+ public Action consume(Message message, ConsumeContext context) {
+ LogHelper.mqInfo("consumer-UserCloudMessageListener", 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.userCloud.name())) {
+ UserCloudMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserCloudMQMsg.class);
+ if (msg.getType() == UserCloudMQMsg.TYPE_EVALUATE) {
+ LogHelper.cloudInfo("鍙戝湀涓俊鎭� -" + msg.getId() );
+ userCloudService.autoSendByDynamic(msg.getUid(), msg.getId());
+ } else if (msg.getType() == UserCloudMQMsg.TYPE_STORE) {
+ LogHelper.cloudInfo("閫夊搧搴撲俊鎭� -" + msg.getId() );
+ userCloudService.autoSendCustomGoods(msg.getUid(), Long.parseLong(msg.getId()));
+ } else if (msg.getType() == UserCloudMQMsg.TYPE_PUSH) {
+ LogHelper.cloudInfo("绔欏唴淇℃伅 -" + msg.getId() );
+ userCloudService.offlineNotificationZNX(msg.getUid());
+ }
+ }
+ }
+ return Action.CommitMessage;
+ }
+}
--
Gitblit v1.8.0