From d6df4ca797ee1c6ce8fa78768f5425f187734bd9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 18 一月 2021 18:44:08 +0800
Subject: [PATCH] 外网部署参数修改
---
service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java | 26 ++++++++------------------
1 files changed, 8 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..995453f 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,14 @@
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.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 +25,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,7 +93,7 @@
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) {
@@ -131,7 +122,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 +133,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 +152,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 +170,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 +209,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 +222,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