From 6c09cbd70388ae53ec593de253f69cfa1a3eeda7 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 06 二月 2021 15:41:25 +0800
Subject: [PATCH] 活动管理界面完善
---
service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java | 35 +++++++++++++++++++++++++++--------
1 files changed, 27 insertions(+), 8 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 e4d3928..cc9d79b 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
@@ -2,7 +2,9 @@
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;
import java.util.Date;
@@ -35,20 +37,37 @@
}
- 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;
}
+
+ /**
+ * 娲诲姩濂栧搧棰嗗彇鏃堕棿鍒版湡
+ *
+ * @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