From 761422e416fcd7f8ac3b75a2b17f9c3977f3b787 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期二, 17 三月 2020 10:54:31 +0800
Subject: [PATCH] vip等级
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java | 75 +++++++++++++++++++------------------
1 files changed, 38 insertions(+), 37 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java
index ae47f52..a523b45 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java
@@ -24,45 +24,46 @@
* @author Administrator
*
*/
-@Component
-public class UserVIPMessageListener implements MessageListener {
+//@Component implements MessageListener
+public class UserVIPMessageListener {
@Resource
private UserVIPPreInfoService userVIPPreInfoService;
- @Override
- public Action consume(Message message, ConsumeContext context) {
- LogHelper.mqInfo("consumer-UserVIPMessageListener", 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.inviteSuccess.name())) {
- UserInviteMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserInviteMQMsg.class);
- // 浼氬憳绛夌骇鍗囩骇
- userVIPPreInfoService.verifyVipPreInfo(msg.getBossId(), true);
- }
- }
-
- // 璁㈠崟鍒拌处鐩稿叧
- if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {
- OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(message.getBody()),
- OrderMoneyRecievedMQMsg.class);
- if (dto != null) {
- if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 鑷喘鍒拌处
- // 浼氬憳绛夌骇鍗囩骇
- userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);
- } else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {// 鍒嗕韩鍒拌处
- // 浼氬憳绛夌骇鍗囩骇
- userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);
- }
- }
- }
-
- return Action.CommitMessage;
- }
+// @Override
+// public Action consume(Message message, ConsumeContext context) {
+//
+// LogHelper.mqInfo("consumer-UserVIPMessageListener", 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.inviteSuccess.name())) {
+// UserInviteMQMsg msg = new Gson().fromJson(new String(message.getBody()),UserInviteMQMsg.class);
+// // 浼氬憳绛夌骇鍗囩骇
+// userVIPPreInfoService.verifyVipPreInfo(msg.getBossId(), true);
+// }
+// }
+//
+// // 璁㈠崟鍒拌处鐩稿叧
+// if (tag.equalsIgnoreCase(OrderTopicTagEnum.orderFanLiActual.name())) {
+// OrderMoneyRecievedMQMsg dto = new Gson().fromJson(new String(message.getBody()),
+// OrderMoneyRecievedMQMsg.class);
+// if (dto != null) {
+// if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_ZIGOU) {// 鑷喘鍒拌处
+// // 浼氬憳绛夌骇鍗囩骇
+// userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);
+// } else if (dto.getType() == OrderMoneyRecievedMQMsg.TYPE_SHARE) {// 鍒嗕韩鍒拌处
+// // 浼氬憳绛夌骇鍗囩骇
+// userVIPPreInfoService.verifyVipPreInfo(dto.getUid(), false);
+// }
+// }
+// }
+//
+// return Action.CommitMessage;
+// }
}
--
Gitblit v1.8.0