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/UserCloudMessageListener.java | 23 +++++++----------------
1 files changed, 7 insertions(+), 16 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 7b0ca3d..d06e6d3 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
@@ -9,17 +9,10 @@
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;
/**
@@ -41,23 +34,21 @@
String tag = message.getTag();
if (tag == null)
tag = "";
-
- if (java.lang.System.currentTimeMillis() <= Constant.NEW_ORDER_FANLI_RULE_TIME) {
- return Action.CommitMessage;
- }
-
- // 閭�璇风浉鍏�
if (MQTopicName.TOPIC_USER.name().equalsIgnoreCase(message.getTopic())) {
- if (tag.equalsIgnoreCase(UserTopicTagEnum.userCloud.name())) {// 鐢ㄦ埛绛夌骇鍙戠敓鍙樺寲
+ 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 {
+ } 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