| | |
| | | |
| | | import com.google.gson.Gson; |
| | | import com.ks.lucky.pojo.DO.LuckyActivity; |
| | | import com.ks.lucky.pojo.DO.LuckyActivityOpenInfo; |
| | | import com.ks.lucky.pojo.DO.LuckyMQ; |
| | | import com.ks.lucky.pojo.DTO.ActivityDrwanOutDateMsg; |
| | | import com.ks.lucky.pojo.DTO.ActivityMQMsg; |
| | |
| | | } |
| | | |
| | | |
| | | public static LuckyMQ createOpenActivity(LuckyActivity activity) { |
| | | public static LuckyMQ createOpenActivity(Long activityId, Date preOpenTime) { |
| | | LuckyMQ mq = new LuckyMQ(); |
| | | mq.setState(LuckyMQ.STATE_NOT_SEND); |
| | | mq.setCreateTime(new Date()); |
| | | //设置开奖时间 |
| | | if (activity.getPreOpenTime() != null) { |
| | | mq.setPreSendTime(activity.getPreOpenTime()); |
| | | } else { |
| | | mq.setPreSendTime(activity.getActualFinishTime()); |
| | | } |
| | | mq.setQueueContent(new Gson().toJson(new ActivityMQMsg(activity.getId(), ActivityMQMsg.TYPE_EXEC_OPEN, new Date()))); |
| | | mq.setPreSendTime(preOpenTime); |
| | | mq.setQueueContent(new Gson().toJson(new ActivityMQMsg(activityId, ActivityMQMsg.TYPE_EXEC_OPEN, new Date()))); |
| | | mq.setQueueName(CMQManager.QUEUENAME_LUCKY_ACTIVITY); |
| | | mq.setTaskId("open-activity-" + activity.getId()); |
| | | mq.setTaskId("open-activity-" + activityId); |
| | | mq.setTaskName("活动开奖"); |
| | | return mq; |
| | | } |