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 | 12 ++++--------
1 files changed, 4 insertions(+), 8 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..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;
/**
@@ -47,9 +40,12 @@
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());
}
}
}
--
Gitblit v1.8.0