活动添加后台完善

admin

2021-01-08 7e389247b3b2877c12f1eaae6e33c9c33e91d2dd

 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: