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/utils/mq/CMQManager.java | 14 ++++++++++++++
1 files changed, 14 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 79ab3fb..7ff1b4d 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
@@ -10,6 +10,7 @@
import org.yeshi.utils.StringUtil;
import org.yeshi.utils.mq.TDMQUtil;
+import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -132,6 +133,19 @@
//娣诲姞鏃ュ織
logger.debug("娣诲姞缁撶畻娑堟伅缁撴潫锛歿}",content);
}
+ /**
+ * 鎵归噺娣诲姞
+ **/
+ public void addGoldCornSettleMsg(List<GoldCornSettleMQMsg> msgList) throws Exception {
+ List<String> contentList=new ArrayList<>();
+ for(GoldCornSettleMQMsg msg:msgList) {
+ contentList.add(new Gson().toJson(msg));
+ }
+ logger.debug("娣诲姞缁撶畻娑堟伅寮�濮嬶細{}",msgList.size());
+ TDMQUtil.getInstance().batchSendMsg(QUEUE_GOLDCORN_SETTLE, contentList);
+ //娣诲姞鏃ュ織
+ logger.debug("娣诲姞缁撶畻娑堟伅缁撴潫锛歿}",msgList.size());
+ }
public Map<String, GoldCornSettleMQMsg> consumeGoldCornSettleMsg(int count) {
List<Message> list = TDMQUtil.getInstance().recieveMsg(count, QUEUE_GOLDCORN_SETTLE);
--
Gitblit v1.8.0