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/consumer/AcitivtyConsumer.java | 152 +++++++++++++++++++++++++-------------------------
1 files changed, 77 insertions(+), 75 deletions(-)
diff --git a/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/AcitivtyConsumer.java b/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/AcitivtyConsumer.java
index 8e5d828..718aba5 100644
--- a/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/AcitivtyConsumer.java
+++ b/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/AcitivtyConsumer.java
@@ -7,8 +7,9 @@
import com.ks.lucky.pojo.DTO.ActivityMQMsg;
import com.ks.lucky.remote.service.LuckyActivityOpenService;
import com.ks.lucky.service.impl.LuckyActivityManager;
-import com.ks.lucky.util.mq.CMQConsumeRunner;
import com.ks.lucky.util.mq.CMQManager;
+import com.ks.lucky.utils.mq.CMQConsumeRunner;
+import org.yeshi.utils.mq.JobThreadExecutorServiceImpl;
import javax.annotation.Resource;
import java.util.Iterator;
@@ -39,95 +40,96 @@
@Override
public void start() {
- while (true) {
- Map<String, ActivityMQMsg> map = CMQManager.getInstance().consumeActivityMsg(16);
- if (map != null) {
- for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
- String handler = its.next();
- ActivityMQMsg msg = map.get(handler);
- if (msg != null) {
- switch (msg.getType()) {
- case ActivityMQMsg.TYPE_EXEC_START:
- //鍚姩娲诲姩
- try {
- luckyActivityManager.startUpActivity(msg.getActivityId());
- CMQManager.getInstance().deleteActivityMsg(handler);
- } catch (LuckyActivityException e) {
- e.printStackTrace();
- } catch (LuckyMQException e) {
- e.printStackTrace();
- }
+ new JobThreadExecutorServiceImpl().run(new Runnable() {
+ @Override
+ public void run() {
+ Map<String, ActivityMQMsg> map = CMQManager.getInstance().consumeActivityMsg(16);
+ if (map != null) {
+ for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
+ String handler = its.next();
+ ActivityMQMsg msg = map.get(handler);
+ if (msg != null) {
+ switch (msg.getType()) {
+ case ActivityMQMsg.TYPE_EXEC_START:
+ //鍚姩娲诲姩
+ try {
+ luckyActivityManager.startUpActivity(msg.getActivityId());
+ CMQManager.getInstance().deleteActivityMsg(handler);
+ } catch (LuckyActivityException e) {
+ e.printStackTrace();
+ } catch (LuckyMQException e) {
+ e.printStackTrace();
+ }
- break;
- case ActivityMQMsg.TYPE_EXEC_FINSIH:
- //缁撴潫娲诲姩
- try {
- luckyActivityManager.finishActivity(msg.getActivityId(), false, "瀹氭椂缁撴潫");
- CMQManager.getInstance().deleteActivityMsg(handler);
- } catch (LuckyActivityException e) {
- e.printStackTrace();
- } catch (LuckyMQException e) {
- e.printStackTrace();
- }
+ break;
+ case ActivityMQMsg.TYPE_EXEC_FINSIH:
+ //缁撴潫娲诲姩
+ try {
+ luckyActivityManager.finishActivity(msg.getActivityId(), false, "瀹氭椂缁撴潫");
+ CMQManager.getInstance().deleteActivityMsg(handler);
+ } catch (LuckyActivityException e) {
+ e.printStackTrace();
+ } catch (LuckyMQException e) {
+ e.printStackTrace();
+ }
- break;
+ break;
- case ActivityMQMsg.TYPE_REACH_MIN_PERSON:
- try {
- luckyActivityOpenService.reachMinPerson(msg.getActivityId());
- CMQManager.getInstance().deleteActivityMsg(handler);
- } catch (LuckyActivityException e) {
- e.printStackTrace();
- }
- break;
+ case ActivityMQMsg.TYPE_REACH_MIN_PERSON:
+ try {
+ luckyActivityOpenService.reachMinPerson(msg.getActivityId());
+ CMQManager.getInstance().deleteActivityMsg(handler);
+ } catch (LuckyActivityException e) {
+ e.printStackTrace();
+ }
+ break;
- case ActivityMQMsg.TYPE_REACH_MAX_PERSON:
- try {
- luckyActivityManager.finishActivity(msg.getActivityId(), false, "娲诲姩杈惧埌鏈�澶у紑濂栦汉鏁�");
- CMQManager.getInstance().deleteActivityMsg(handler);
- } catch (LuckyActivityException e) {
- e.printStackTrace();
- } catch (LuckyMQException e) {
- e.printStackTrace();
- }
+ case ActivityMQMsg.TYPE_REACH_MAX_PERSON:
+ try {
+ luckyActivityManager.finishActivity(msg.getActivityId(), false, "娲诲姩杈惧埌鏈�澶у紑濂栦汉鏁�");
+ CMQManager.getInstance().deleteActivityMsg(handler);
+ } catch (LuckyActivityException e) {
+ e.printStackTrace();
+ } catch (LuckyMQException e) {
+ e.printStackTrace();
+ }
- break;
+ break;
- case ActivityMQMsg.TYPE_REACH_OPEN_TIME:
- try {
- luckyActivityManager.finishActivity(msg.getActivityId(), false, "娲诲姩杈惧埌寮�濂栨椂闂�");
- CMQManager.getInstance().deleteActivityMsg(handler);
- } catch (LuckyActivityException e) {
- e.printStackTrace();
- } catch (LuckyMQException e) {
- e.printStackTrace();
- }
- break;
+ case ActivityMQMsg.TYPE_REACH_OPEN_TIME:
+ try {
+ luckyActivityManager.finishActivity(msg.getActivityId(), false, "娲诲姩杈惧埌寮�濂栨椂闂�");
+ CMQManager.getInstance().deleteActivityMsg(handler);
+ } catch (LuckyActivityException e) {
+ e.printStackTrace();
+ } catch (LuckyMQException e) {
+ e.printStackTrace();
+ }
+ break;
- case ActivityMQMsg.TYPE_OPEN_SHOW:
- try {
- luckyActivityOpenService.showOpenAward(msg.getActivityId());
- CMQManager.getInstance().deleteActivityMsg(handler);
- } catch (LuckyActivityException e) {
- e.printStackTrace();
- }
- break;
+ case ActivityMQMsg.TYPE_OPEN_SHOW:
+ try {
+ luckyActivityOpenService.showOpenAward(msg.getActivityId());
+ CMQManager.getInstance().deleteActivityMsg(handler);
+ } catch (LuckyActivityException e) {
+ e.printStackTrace();
+ }
+ break;
- case ActivityMQMsg.TYPE_EXEC_OPEN:
- preOpen(msg.getActivityId(), handler);
- break;
+ case ActivityMQMsg.TYPE_EXEC_OPEN:
+ preOpen(msg.getActivityId(), handler);
+ break;
+ }
}
+
+
}
-
-
}
-
-
}
+ });
- }
}
--
Gitblit v1.8.0