| | |
| | | import com.ks.lucky.pojo.DO.LuckyActivityAwardResult; |
| | | import com.ks.lucky.pojo.DO.LuckyActivityAwards; |
| | | import com.ks.lucky.pojo.DTO.mq.ActivityDrawnMsgDTO; |
| | | import com.ks.lucky.pojo.DTO.mq.BaseMQMsg; |
| | | import com.ks.lucky.remote.service.LuckyActivityAwardResultService; |
| | | import com.ks.lucky.remote.service.LuckyActivityAwardService; |
| | | import com.ks.lucky.utils.LuckyCMQConstant; |
| | |
| | | |
| | | Logger logger = LoggerFactory.getLogger(ActivityDrawnNotifyConsumer.class); |
| | | |
| | | @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 |
| | |
| | | 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_DRAWN)) { |
| | | BaseMQMsg mqMsg = JsonUtil.getSimpleGson().fromJson(message.msgBody, BaseMQMsg.class); |
| | | String tag=mqMsg.getCmqMsgTag(); |
| | | if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_DRAWN)) { |
| | | |
| | | try { |
| | | //活动状态改变 |