From d6df4ca797ee1c6ce8fa78768f5425f187734bd9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 18 一月 2021 18:44:08 +0800
Subject: [PATCH] 外网部署参数修改
---
service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/ActivityConsumer.java | 26 ++++++++++++++++++--------
1 files changed, 18 insertions(+), 8 deletions(-)
diff --git a/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/ActivityConsumer.java b/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/ActivityConsumer.java
index 0c561b8..8737d8a 100644
--- a/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/ActivityConsumer.java
+++ b/service-lucky/src/main/java/com/ks/lucky/util/mq/consumer/ActivityConsumer.java
@@ -22,14 +22,15 @@
private LuckyActivityOpenService luckyActivityOpenService;
private void preOpen(Long activityId, String handler) {
-
try {
luckyActivityOpenService.preOpenAward(activityId);
CMQManager.getInstance().deleteActivityMsg(handler);
} catch (LuckyActivityException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("棰勫紑濂栧紓甯�:activityId-{}", activityId, e);
} catch (LuckyActivityAwardException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("棰勫紑濂栧紓甯�:activityId-{}", activityId, e);
} catch (LuckyActivityOpenException e) {
CMQManager.getInstance().deleteActivityMsg(handler);
}
@@ -49,7 +50,7 @@
if (msg != null) {
switch (msg.getType()) {
case ActivityMQMsg.TYPE_EXEC_START:
- LoggerUtil.activityLogger.info("鎵ц鍚姩娲诲姩:"+msg.getActivityId());
+ LoggerUtil.activityLogger.info("鎵ц鍚姩娲诲姩:activityId-{}", msg.getActivityId());
//鍚姩娲诲姩
try {
luckyActivityManager.startUpActivity(msg.getActivityId());
@@ -63,70 +64,79 @@
break;
case ActivityMQMsg.TYPE_EXEC_FINSIH:
- LoggerUtil.activityLogger.info("鎵ц缁撴潫娲诲姩:"+msg.getActivityId());
+ LoggerUtil.activityLogger.info("鎵ц缁撴潫娲诲姩:activityId-{}", msg.getActivityId());
//缁撴潫娲诲姩
try {
luckyActivityManager.finishActivity(msg.getActivityId(), false, "瀹氭椂缁撴潫");
CMQManager.getInstance().deleteActivityMsg(handler);
} catch (LuckyActivityException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("娲诲姩鎴愬姛缁撴潫寮傚父:activityId-{}", msg.getActivityId(), e);
} catch (LuckyMQException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("娲诲姩鎴愬姛缁撴潫寮傚父:activityId-{}", msg.getActivityId(), e);
}
break;
case ActivityMQMsg.TYPE_REACH_MIN_PERSON:
- LoggerUtil.activityLogger.info("鍙備笌浜烘暟鍒拌揪鏈�浣庡紑濂栦汉鏁�:"+msg.getActivityId());
+ LoggerUtil.activityLogger.info("鍙備笌浜烘暟鍒拌揪鏈�浣庡紑濂栦汉鏁�:activityId-{}", msg.getActivityId());
try {
luckyActivityOpenService.reachMinPerson(msg.getActivityId());
CMQManager.getInstance().deleteActivityMsg(handler);
} catch (LuckyActivityException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("鍙備笌浜烘暟鍒拌揪鏈�浣庡紑濂栦汉鏁板紓甯�:activityId-{}", msg.getActivityId(), e);
}
break;
case ActivityMQMsg.TYPE_REACH_MAX_PERSON:
- LoggerUtil.activityLogger.info("鍙備笌浜烘暟鍒拌揪鏈�澶у弬涓庝汉鏁�:"+msg.getActivityId());
+ LoggerUtil.activityLogger.info("鍙備笌浜烘暟鍒拌揪鏈�澶у弬涓庝汉鏁�:activityId-{}", msg.getActivityId());
try {
luckyActivityManager.finishActivity(msg.getActivityId(), false, "娲诲姩杈惧埌鏈�澶у紑濂栦汉鏁�");
CMQManager.getInstance().deleteActivityMsg(handler);
} catch (LuckyActivityException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("娲诲姩杈惧埌鏈�澶у紑濂栦汉鏁帮紝娲诲姩缁撴潫寮傚父:activityId-{}", msg.getActivityId(), e);
} catch (LuckyMQException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("娲诲姩杈惧埌鏈�澶у紑濂栦汉鏁帮紝娲诲姩缁撴潫寮傚父:activityId-{}", msg.getActivityId(), e);
}
break;
case ActivityMQMsg.TYPE_REACH_OPEN_TIME:
- LoggerUtil.activityLogger.info("娲诲姩杈惧埌寮�濂栨椂闂�:"+msg.getActivityId());
+ LoggerUtil.activityLogger.info("娲诲姩杈惧埌寮�濂栨椂闂�:activityId-{}", msg.getActivityId());
try {
luckyActivityManager.finishActivity(msg.getActivityId(), false, "娲诲姩杈惧埌寮�濂栨椂闂�");
CMQManager.getInstance().deleteActivityMsg(handler);
} catch (LuckyActivityException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("娲诲姩杈惧埌寮�濂栨椂闂达紝娲诲姩缁撴潫寮傚父:activityId-{}", msg.getActivityId(), e);
} catch (LuckyMQException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("娲诲姩杈惧埌寮�濂栨椂闂达紝娲诲姩缁撴潫寮傚父:activityId-{}", msg.getActivityId(), e);
}
break;
case ActivityMQMsg.TYPE_OPEN_SHOW:
- LoggerUtil.activityLogger.info("鏄剧ず寮�濂栫粨鏋�:"+msg.getActivityId());
+ LoggerUtil.activityLogger.info("鏄剧ず寮�濂栫粨鏋�:activityId-{}", msg.getActivityId());
try {
luckyActivityOpenService.showOpenAward(msg.getActivityId());
CMQManager.getInstance().deleteActivityMsg(handler);
} catch (LuckyActivityException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("鏄剧ず寮�濂栫粨鏋滃紓甯�:activityId-{}", msg.getActivityId(), e);
} catch (LuckyActivityOpenInfoException e) {
e.printStackTrace();
+ LoggerUtil.activityLogger.error("鏄剧ず寮�濂栫粨鏋滃紓甯�:activityId-{}", msg.getActivityId(), e);
}
break;
case ActivityMQMsg.TYPE_EXEC_OPEN:
- LoggerUtil.activityLogger.info("鎵ц棰勫紑濂�:"+msg.getActivityId());
+ LoggerUtil.activityLogger.info("鎵ц棰勫紑濂�:activityId-{}", msg.getActivityId());
preOpen(msg.getActivityId(), handler);
break;
}
--
Gitblit v1.8.0