From ffc56f912da5d6d842142ae4ea1856bc56f8bcb9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 30 九月 2022 19:20:23 +0800
Subject: [PATCH] 结算日志添加
---
app/src/main/java/com/yeshi/makemoney/app/utils/mq/CMQManager.java | 7 +++++++
1 files changed, 7 insertions(+), 0 deletions(-)
diff --git a/app/src/main/java/com/yeshi/makemoney/app/utils/mq/CMQManager.java b/app/src/main/java/com/yeshi/makemoney/app/utils/mq/CMQManager.java
index ba19a8c..79ab3fb 100644
--- a/app/src/main/java/com/yeshi/makemoney/app/utils/mq/CMQManager.java
+++ b/app/src/main/java/com/yeshi/makemoney/app/utils/mq/CMQManager.java
@@ -5,6 +5,8 @@
import com.yeshi.makemoney.app.dto.mq.AddGoldCornMQMsg;
import com.yeshi.makemoney.app.dto.mq.ExtractTransferResultMQMsg;
import com.yeshi.makemoney.app.dto.mq.GoldCornSettleMQMsg;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.yeshi.utils.StringUtil;
import org.yeshi.utils.mq.TDMQUtil;
@@ -19,6 +21,7 @@
* @date 2022/4/1 17:06
*/
public class CMQManager {
+ Logger logger= LoggerFactory.getLogger(CMQManager.class);
private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
private static CMQManager cmqManager;
@@ -94,6 +97,7 @@
public void addAddGoldCornMsg(AddGoldCornMQMsg msg) {
String content = new Gson().toJson(msg);
+
tdmqUtil.sendMsg(QUEUE_ADD_GOLDCORN, content);
}
@@ -123,7 +127,10 @@
**/
public void addGoldCornSettleMsg(GoldCornSettleMQMsg msg) {
String content = new Gson().toJson(msg);
+ logger.debug("娣诲姞缁撶畻娑堟伅寮�濮嬶細",content);
TDMQUtil.getInstance().sendMsg(QUEUE_GOLDCORN_SETTLE, content);
+ //娣诲姞鏃ュ織
+ logger.debug("娣诲姞缁撶畻娑堟伅缁撴潫锛歿}",content);
}
public Map<String, GoldCornSettleMQMsg> consumeGoldCornSettleMsg(int count) {
--
Gitblit v1.8.0