From 7e389247b3b2877c12f1eaae6e33c9c33e91d2dd Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 08 一月 2021 18:41:59 +0800
Subject: [PATCH] 活动添加后台完善
---
service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java | 55 ++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 54 insertions(+), 1 deletions(-)
diff --git a/service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java b/service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java
index 6a06d3b..f6c4cef 100644
--- a/service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java
+++ b/service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java
@@ -3,6 +3,7 @@
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.ActivityDrwanOutDateMsg;
import com.ks.lucky.pojo.DTO.ActivityMQMsg;
import java.util.Date;
@@ -13,11 +14,63 @@
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;
+ }
+
+ /**
+ * 娲诲姩濂栧搧棰嗗彇鏃堕棿鍒版湡
+ *
+ * @param resultId
+ * @param outDate
+ * @return
+ */
+
+ public static LuckyMQ createActivityDrawnOutDate(Long resultId, Date outDate) {
+ LuckyMQ mq = new LuckyMQ();
+ mq.setState(LuckyMQ.STATE_NOT_SEND);
+ mq.setCreateTime(new Date());
+ //璁剧疆寮�濂栨椂闂�
+ mq.setPreSendTime(outDate);
+ mq.setQueueContent(new Gson().toJson(new ActivityDrwanOutDateMsg(resultId)));
+ mq.setQueueName(CMQManager.QUEUENAME_LUCKY_ACTIVITY_DRAWN_OUTDATE_EXEC);
+ mq.setTaskId("activity-drawn-outdate-" + resultId);
+ mq.setTaskName("娲诲姩涓棰嗗彇鏃堕棿鍒版湡");
+ return mq;
+ }
}
--
Gitblit v1.8.0