admin
2021-02-06 6c09cbd70388ae53ec593de253f69cfa1a3eeda7
service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java
@@ -2,6 +2,7 @@
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;
@@ -36,19 +37,15 @@
    }
    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;
    }