| | |
| | | LuckyMQ mq = new LuckyMQ(); |
| | | mq.setState(LuckyMQ.STATE_NOT_SEND); |
| | | mq.setCreateTime(new Date()); |
| | | mq.setPreSendTime(activity.getStartTime()); |
| | | mq.setPreSendTime(activity.getPreStartTime()); |
| | | mq.setQueueContent(new Gson().toJson(new ActivityMQMsg(activity.getId(), ActivityMQMsg.TYPE_EXEC_START, new Date()))); |
| | | mq.setQueueName(CMQManager.QUEUENAME_LUCKY_ACTIVITY); |
| | | mq.setTaskId("start-activity-" + activity.getId()); |
| | | mq.setTaskName("启动活动"); |
| | | return mq; |
| | | } |
| | | |
| | | |
| | | public static LuckyMQ createFinishActivity(LuckyActivity activity) { |
| | | LuckyMQ mq = new LuckyMQ(); |
| | | mq.setState(LuckyMQ.STATE_NOT_SEND); |
| | | mq.setCreateTime(new Date()); |
| | | mq.setPreSendTime(activity.getPreFinishTime()); |
| | | mq.setQueueContent(new Gson().toJson(new ActivityMQMsg(activity.getId(), ActivityMQMsg.TYPE_EXEC_FINSIH, new Date()))); |
| | | mq.setQueueName(CMQManager.QUEUENAME_LUCKY_ACTIVITY); |
| | | mq.setTaskId("finish-activity-" + activity.getId()); |
| | | mq.setTaskName("结束活动"); |
| | | return mq; |
| | | } |
| | | |
| | | |
| | | public static LuckyMQ createOpenActivity(LuckyActivity activity) { |
| | | 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.setQueueName(CMQManager.QUEUENAME_LUCKY_ACTIVITY); |
| | | mq.setTaskId("open-activity-" + activity.getId()); |
| | | mq.setTaskName("活动开奖"); |
| | | return mq; |
| | | } |
| | | } |