From 8f4a68065574a7ef1f9e8b53902d1f081ec69aab Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 17 三月 2020 10:58:14 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/div' into div
---
fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java | 69 ++++++++++++++++++++++++++++++++++
1 files changed, 69 insertions(+), 0 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
new file mode 100644
index 0000000..a523b45
--- /dev/null
+++ b/fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/user/UserVIPMessageListener.java
@@ -0,0 +1,69 @@
+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.OrderMoneyRecievedMQMsg;
+import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
+import com.yeshi.fanli.dto.mq.user.body.UserInviteMQMsg;
+import com.yeshi.fanli.exception.money.OrderMoneySettleException;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
+import com.yeshi.fanli.util.rocketmq.MQTopicName;
+
+/**
+ * 鐢ㄦ埛瓒呯骇浼氬憳
+ *
+ * @author Administrator
+ *
+ */
+//@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;
+// }
+}
--
Gitblit v1.8.0