From b82493b0c083ed6bd5c0013bf21b8cb651a32eec Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 26 十二月 2020 17:21:40 +0800
Subject: [PATCH] 活动图片添加，自动生成代码框架初步搭建
---
service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java | 26 ++++++++++++--------------
1 files changed, 12 insertions(+), 14 deletions(-)
diff --git a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
index c48cf29..fe7be95 100644
--- a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
+++ b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
@@ -11,10 +11,7 @@
import com.ks.daylucky.util.mq.CMQManager;
import com.ks.lucky.pojo.DO.*;
import com.ks.lucky.pojo.DTO.ActivitySimpleUser;
-import com.ks.lucky.pojo.DTO.mq.ActivityAssistMsgDTO;
-import com.ks.lucky.pojo.DTO.mq.ActivityDrawnMsgDTO;
-import com.ks.lucky.pojo.DTO.mq.ActivityJoinMsgDTO;
-import com.ks.lucky.pojo.DTO.mq.ActivityStateChangeMsgDTO;
+import com.ks.lucky.pojo.DTO.mq.*;
import com.ks.lucky.remote.service.LuckyActivityAwardResultService;
import com.ks.lucky.remote.service.LuckyActivityAwardService;
import com.ks.lucky.remote.service.LuckyActivityJoinAssistService;
@@ -31,7 +28,6 @@
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
-import java.util.Vector;
public class MsgConsumer implements CMQConsumeRunner {
@@ -43,16 +39,16 @@
@Resource
private UserInfoService userInfoService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0",check = false)
private LuckyActivityJoinAssistService luckyActivityJoinAssistService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0",check = false)
private LuckyActivityJoinService luckyActivityJoinService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0",check = false)
private LuckyActivityAwardResultService luckyActivityAwardResultService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0",check = false)
private LuckyActivityAwardService luckyActivityAwardService;
@Resource
@@ -89,8 +85,10 @@
List<Message> messageList = CMQManager.getInstance().consumeMsgMsg(16);
if (messageList != null) {
for (Message message : messageList) {
- Vector<String> vectors = message.msgTag;
- if (vectors.contains(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE)) {
+ BaseMQMsg baseMQMsg = JsonUtil.getSimpleGson().fromJson(message.msgBody, BaseMQMsg.class);
+ String tag = baseMQMsg.getCmqMsgTag();
+
+ if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE)) {
//娲诲姩鐘舵�佹敼鍙�
ActivityStateChangeMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityStateChangeMsgDTO.class);
List<ActivitySimpleUser> userList;
@@ -145,7 +143,7 @@
}
- } else if (vectors.contains(LuckyCMQConstant.TAG_ACTIVITY_JOIN)) {
+ } else if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_JOIN)) {
ActivityJoinMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityJoinMsgDTO.class);
UserMsgSettings settings = getUserMsgSetting(Long.parseLong(dto.getUid()));
if (settings.getJoinActivityMsg()) {
@@ -176,7 +174,7 @@
}
- } else if (vectors.contains(LuckyCMQConstant.TAG_ASSIST)) {
+ } else if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ASSIST)) {
//鍔╁姏
ActivityAssistMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityAssistMsgDTO.class);
UserMsgSettings settings = getUserMsgSetting(Long.parseLong(dto.getUid()));
@@ -193,7 +191,7 @@
}
}
- } else if (vectors.contains(LuckyCMQConstant.TAG_ACTIVITY_DRAWN)) {
+ } else if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_DRAWN)) {
ActivityDrawnMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityDrawnMsgDTO.class);
switch (dto.getAwardResultState()) {
case LuckyActivityAwardResult.STATE_OUT_OF_DATE:
--
Gitblit v1.8.0