package com.ks.lucky.util.mq;
|
|
import com.google.gson.Gson;
|
import com.ks.lucky.pojo.DO.LuckyActivity;
|
import com.ks.lucky.pojo.DO.LuckyMQ;
|
import com.ks.lucky.pojo.DTO.ActivityMQMsg;
|
|
import java.util.Date;
|
|
public class LuckyMQFactory {
|
|
public static LuckyMQ createStartUpActivity(LuckyActivity activity) {
|
LuckyMQ mq = new LuckyMQ();
|
mq.setState(LuckyMQ.STATE_NOT_SEND);
|
mq.setCreateTime(new Date());
|
mq.setPreSendTime(activity.getStartTime());
|
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;
|
}
|
}
|
