活动管理界面完善

admin

2021-02-06 6c09cbd70388ae53ec593de253f69cfa1a3eeda7

 service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java

@@ -1,5 +1,6 @@
package com.ks.daylucky.util.mq.consumer;

import com.google.gson.Gson;
import com.ks.daylucky.exception.UserMsgException;
import com.ks.daylucky.pojo.DTO.UserMsgSettings;
import com.ks.daylucky.pojo.VO.SimpleUser;
@@ -99,10 +100,14 @@
                    for (Message message : messageList) {
                        BaseMQMsg baseMQMsg = JsonUtil.getSimpleGson().fromJson(message.msgBody, BaseMQMsg.class);
                        String tag = baseMQMsg.getCmqMsgTag();
                        LoggerUtil.mqLogger.info("消息消费：{}",new Gson().toJson(baseMQMsg));

                        if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE)) {

                            //活动状态改变
                            ActivityStateChangeMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityStateChangeMsgDTO.class);
                            LoggerUtil.mqLogger.info("活动状态改变：{}",new Gson().toJson(dto));

                            List<ActivitySimpleUser> userList;
                            switch (dto.getState()) {
                                //开奖