From a2fe11f549f52e887937dbdb63d967a09d3a3f21 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 02 十二月 2020 18:54:38 +0800
Subject: [PATCH] 抽奖核心服务完善，天天抽奖服务基本搭建
---
service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java | 33 ++++++++++++++++++++++++++++++++-
1 files changed, 32 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..e4d3928 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
@@ -13,11 +13,42 @@
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;
+ }
}
--
Gitblit v1.8.0