From 25680e135b5bdc15658622cbfde74bab73cfee77 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 25 十二月 2020 18:54:40 +0800
Subject: [PATCH] 功能完善
---
service-lucky/src/main/java/com/ks/lucky/util/mq/LuckyMQFactory.java | 22 ++++++++++++++++++++++
1 files changed, 22 insertions(+), 0 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..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;
@@ -51,4 +52,25 @@
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