From 5f13dcc8eaac7cd26c0ec41bd1b3efbb70a08180 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 16 六月 2020 17:45:09 +0800
Subject: [PATCH] 云发单金额修改，增加获取电话号码接口
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserCloudMessageListener.java | 11 +++--------
1 files changed, 3 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 7b0ca3d..fcdf0a9 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
@@ -41,23 +41,18 @@
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 {
+ LogHelper.cloudInfo("閫夊搧搴撲俊鎭� -" + msg.getId() );
userCloudService.autoSendCustomGoods(msg.getUid(), Long.parseLong(msg.getId()));
}
}
}
-
return Action.CommitMessage;
}
}
--
Gitblit v1.8.0