From 6c09cbd70388ae53ec593de253f69cfa1a3eeda7 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 06 二月 2021 15:41:25 +0800
Subject: [PATCH] 活动管理界面完善
---
service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java | 31 +++++++++++++------------------
1 files changed, 13 insertions(+), 18 deletions(-)
diff --git a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
index dc7aade..6ec3f3f 100644
--- a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
+++ b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
@@ -1,21 +1,15 @@
package com.ks.daylucky.util.mq.consumer;
-import com.alipay.api.AlipayApiException;
-import com.ks.app.entity.AppInfo;
-import com.ks.app.util.AlipayAppUtil;
+import com.google.gson.Gson;
import com.ks.daylucky.exception.UserMsgException;
-import com.ks.daylucky.pojo.DO.UserInfo;
-import com.ks.daylucky.pojo.DO.UserMsg;
import com.ks.daylucky.pojo.DTO.UserMsgSettings;
-import com.ks.daylucky.pojo.DTO.msg.LuckyMsgContent;
import com.ks.daylucky.pojo.VO.SimpleUser;
import com.ks.daylucky.service.UserInfoExtraService;
import com.ks.daylucky.service.UserInfoService;
import com.ks.daylucky.service.UserMsgService;
import com.ks.daylucky.service.impl.AlipayTemplateMsgManager;
import com.ks.daylucky.service.impl.AppManager;
-import com.ks.daylucky.util.UserInfoUtil;
-import com.ks.daylucky.util.activity.ActivityUtil;
+import com.ks.daylucky.util.LoggerUtil;
import com.ks.daylucky.util.factory.LuckyMsgContentFactory;
import com.ks.daylucky.util.factory.UserMsgFactory;
import com.ks.daylucky.util.mq.CMQManager;
@@ -32,8 +26,6 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.yeshi.utils.JsonUtil;
-import org.yeshi.utils.alipay.AlipayXcxUtil;
-import org.yeshi.utils.exception.AlipayXcxException;
import org.yeshi.utils.mq.JobThreadExecutorServiceImpl;
import javax.annotation.Resource;
@@ -102,16 +94,20 @@
new JobThreadExecutorServiceImpl().run(new Runnable() {
@Override
public void run() {
- logger.info("璇诲彇娑堟伅闃熷垪鏁版嵁");
+ LoggerUtil.mqLogger.info("鎺ユ敹娑堟伅 {}", MsgConsumer.class.getSimpleName());
List<Message> messageList = CMQManager.getInstance().consumeMsgMsg(16);
if (messageList != null) {
for (Message message : messageList) {
BaseMQMsg baseMQMsg = JsonUtil.getSimpleGson().fromJson(message.msgBody, BaseMQMsg.class);
String tag = baseMQMsg.getCmqMsgTag();
+ LoggerUtil.mqLogger.info("娑堟伅娑堣垂锛歿}",new Gson().toJson(baseMQMsg));
if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE)) {
+
//娲诲姩鐘舵�佹敼鍙�
ActivityStateChangeMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityStateChangeMsgDTO.class);
+ LoggerUtil.mqLogger.info("娲诲姩鐘舵�佹敼鍙橈細{}",new Gson().toJson(dto));
+
List<ActivitySimpleUser> userList;
switch (dto.getState()) {
//寮�濂�
@@ -131,7 +127,7 @@
try {
userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(result.getUid()), LuckyMsgContentFactory.createDrawn(dto.getActivityId(), activity.getCreateTime(), awards.getAwardName())));
} catch (UserMsgException e) {
- logger.error("娣诲姞涓娑堟伅鍑洪敊", e.getMessage(), result.getId());
+ logger.error("娣诲姞涓娑堟伅鍑洪敊 awardResultId-{}", result.getId(), e);
}
//鍙戦�佷腑濂栨ā鏉挎秷鎭�
@@ -142,9 +138,8 @@
try {
userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(user.getUid()), LuckyMsgContentFactory.createNotDrawn(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞鏈腑濂栨秷鎭嚭閿�", e.getMessage(), user.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鏈腑濂栨秷鎭嚭閿� activityId-{} uid-{} ", dto.getActivityId(),user.getUid(),e);
}
-
//鍙戦�佹湭涓妯℃澘娑堟伅
alipayTemplateMsgManager.sendUnDrawnMsg(activity, Long.parseLong(result.getUid()));
}
@@ -162,7 +157,7 @@
try {
userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(user.getUid()), LuckyMsgContentFactory.createOpenFail(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞鏈紑濂栨秷鎭嚭閿�", e.getMessage(), user.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鏈紑濂栨秷鎭嚭閿� activityId-{} uid-{}", dto.getActivityId(), user.getUid(), e);
}
}
}
@@ -180,7 +175,7 @@
try {
userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getUid()), LuckyMsgContentFactory.createJoinSuccess(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞鍙備笌鎴愬姛娑堟伅鍑洪敊", e.getMessage(), dto.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鍙備笌鎴愬姛娑堟伅鍑洪敊 activityId-{} uid-{}", dto.getActivityId(), dto.getUid(), e);
}
}
@@ -219,7 +214,7 @@
userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getTargetUid()), LuckyMsgContentFactory.createAssistAndJoin(dto.getActivityId(), activity.getCreateTime(), user, assist.getWeight())));
}
} catch (UserMsgException e) {
- logger.error("娣诲姞鍔╁姏鎴愬姛娑堟伅鍑洪敊", e.getMessage(), dto.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鍔╁姏鎴愬姛娑堟伅鍑洪敊锛歛ctivityId-{} uid-{}", dto.getActivityId(), dto.getUid(), e);
}
}
}
@@ -232,7 +227,7 @@
try {
userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getUid()), LuckyMsgContentFactory.createReceiveOutDate(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞杩囨湡鏈娑堟伅鍑洪敊", e.getMessage(), dto.getUid(), dto.getActivityId());
+ logger.error("娣诲姞杩囨湡鏈娑堟伅鍑洪敊锛�", dto.getActivityId(), dto.getUid(), e);
}
break;
--
Gitblit v1.8.0