From 0e9b6603d4ae9d11c1fbc90257ce816c5807b8ff Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 28 十月 2022 16:55:02 +0800
Subject: [PATCH] 批量添加结算消息
---
app/src/main/java/com/yeshi/makemoney/app/Application.java | 15 ++++++++++++++-
1 files changed, 14 insertions(+), 1 deletions(-)
diff --git a/app/src/main/java/com/yeshi/makemoney/app/Application.java b/app/src/main/java/com/yeshi/makemoney/app/Application.java
index 4589173..571cd03 100644
--- a/app/src/main/java/com/yeshi/makemoney/app/Application.java
+++ b/app/src/main/java/com/yeshi/makemoney/app/Application.java
@@ -1,5 +1,6 @@
package com.yeshi.makemoney.app;
+import com.google.gson.Gson;
import com.ks.lib.common.exception.ParamsException;
import com.yeshi.makemoney.app.dto.mq.ExtractTransferResultMQMsg;
import com.yeshi.makemoney.app.dto.mq.GoldCornSettleMQMsg;
@@ -10,6 +11,7 @@
import com.yeshi.makemoney.app.service.inter.goldcorn.GoldCornSettleService;
import com.yeshi.makemoney.app.service.inter.money.ExtractService;
import com.yeshi.makemoney.app.utils.Constant;
+import com.yeshi.makemoney.app.utils.LogUtil;
import com.yeshi.makemoney.app.utils.mq.CMQManager;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
@@ -40,6 +42,7 @@
@EnableTransactionManagement
//@EnableDubbo(scanBasePackages = "com.ks.push.service.remote")
public class Application implements ApplicationListener<ContextRefreshedEvent> {
+ Logger settleLogger= LoggerFactory.getLogger("settleLog");
private final static Logger logger = LoggerFactory.getLogger(Application.class);
public static void main(String[] args) {
@@ -54,6 +57,8 @@
logger.info("瀹瑰櫒鍔犺浇瀹屾瘯");
initMQMsgConsumer();
initCOS();
+ LogUtil.settleLogger.info("test123");
+
}
@Resource
@@ -70,24 +75,32 @@
new JobThreadExecutorServiceImpl().run(new Runnable() {
@Override
public void run() {
+
Map<String, GoldCornSettleMQMsg> map = CMQManager.getInstance().consumeGoldCornSettleMsg(10);
if (map != null) {
for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
String key = its.next();
GoldCornSettleMQMsg msg = map.get(key);
try {
+ settleLogger.info("娑堣垂缁撶畻娑堟伅寮�濮嬶細{}",new Gson().toJson(msg));
goldCornSettleService.settle(msg.getUid(), msg.getDay(),msg.getSettleId());
CMQManager.getInstance().deleteGoldCornSettleMsg(key);
+ settleLogger.info("娑堣垂缁撶畻娑堟伅鎴愬姛锛歿}",new Gson().toJson(msg));
} catch (UserInfoException e) {
e.printStackTrace();
+ settleLogger.error("娑堣垂缁撶畻娑堟伅寮傚父锛歿} ",new Gson().toJson(msg),e);
} catch (GoldCornMoneyExchangeRateRecordException e) {
e.printStackTrace();
+ settleLogger.error("娑堣垂缁撶畻娑堟伅寮傚父锛歿} ",new Gson().toJson(msg),e);
} catch (UserMoneyRecordException e) {
e.printStackTrace();
+ settleLogger.error("娑堣垂缁撶畻娑堟伅寮傚父锛歿} ",new Gson().toJson(msg),e);
} catch (GoldCornConsumeRecordException e) {
e.printStackTrace();
+ settleLogger.error("娑堣垂缁撶畻娑堟伅寮傚父锛歿} ",new Gson().toJson(msg),e);
} catch (Exception e) {
e.printStackTrace();
+ settleLogger.error("娑堣垂缁撶畻娑堟伅寮傚父锛歿} ",new Gson().toJson(msg),e);
}
}
}
@@ -101,7 +114,7 @@
new JobThreadExecutorServiceImpl().run(new Runnable() {
@Override
public void run() {
- Map<String, ExtractTransferResultMQMsg> map = CMQManager.getInstance().consumeExtractResultMsg(10);
+ Map<String, ExtractTransferResultMQMsg> map = CMQManager.getInstance().consumeExtractResultMsg(1);
if (map != null) {
for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
String key = its.next();
--
Gitblit v1.8.0