| | |
| | | import com.ks.lucky.query.ActivityAwardResultQuery; |
| | | import com.ks.lucky.service.LuckyMQService; |
| | | import com.ks.lucky.util.Constant; |
| | | import com.ks.lucky.util.LoggerUtil; |
| | | import com.ks.lucky.util.RedPackageUtil; |
| | | import com.ks.lucky.util.mq.CMQManager; |
| | | import com.ks.lucky.util.mq.LuckyMQFactory; |
| | |
| | | if (result.getState() != LuckyActivityAwardResult.STATE_NOT_RECIEVE) { |
| | | return; |
| | | } |
| | | LoggerUtil.activityJoinLogger.info("设置中奖过期未领开始:awardResultId-{}",id); |
| | | |
| | | LuckyActivityAwardResult update = new LuckyActivityAwardResult(); |
| | | update.setId(id); |
| | |
| | | result.setState(update.getState()); |
| | | //发布消息 |
| | | CMQManager.getInstance().publishActivityDrawnMsg(ActivityDrawnMsgDTO.create(result)); |
| | | LoggerUtil.activityJoinLogger.info("设置中奖过期未领成功:awardResultId-{}",id); |
| | | } |
| | | |
| | | /** |