From e1cc0d03fadc2d251d36c0dc3650f75e830d5363 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 07 四月 2022 19:12:42 +0800
Subject: [PATCH] 功能完善

---
 app/src/main/java/com/yeshi/makemoney/app/utils/mq/CMQManager.java |   79 +++++++++++++++++++++++++++++++++++----
 1 files changed, 71 insertions(+), 8 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 d66368a..822f83c 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
@@ -1,11 +1,10 @@
 package com.yeshi.makemoney.app.utils.mq;
 
-import com.alipay.api.response.AlipayFundTransUniTransferResponse;
 import com.google.gson.Gson;
 import com.qcloud.cmq.Message;
+import com.yeshi.makemoney.app.dto.mq.AddGoldCornMQMsg;
 import com.yeshi.makemoney.app.dto.mq.ExtractTransferResultMQMsg;
-import com.yeshi.makemoney.app.entity.money.Extract;
-import org.yeshi.utils.CMQUtil;
+import com.yeshi.makemoney.app.dto.mq.GoldCornSettleMQMsg;
 import org.yeshi.utils.StringUtil;
 import org.yeshi.utils.mq.TDMQUtil;
 
@@ -25,12 +24,18 @@
     private static CMQManager cmqManager;
     private static TDMQUtil tdmqUtil;
 
-    public static String EXTRACT_RESULT = "makemoney-extract-result";
+    public static String QUEUE_EXTRACT_RESULT = "makemoney-extract-result";
+
+    public static String QUEUE_ADD_GOLDCORN = "makemoney-add-goldcorn";
+
+    public static String QUEUE_GOLDCORN_SETTLE = "makemoney-goldcorn-settle";
 
     static {
         TDMQUtil.getInstance().init(secretId, secretKey, true);
         tdmqUtil = TDMQUtil.getInstance();
-        tdmqUtil.createQueue(EXTRACT_RESULT);
+        tdmqUtil.createQueue(QUEUE_EXTRACT_RESULT);
+        tdmqUtil.createQueue(QUEUE_ADD_GOLDCORN);
+        tdmqUtil.createQueue(QUEUE_GOLDCORN_SETTLE);
     }
 
     public static CMQManager getInstance() {
@@ -48,7 +53,7 @@
      */
     public void addExtractResultMsg(ExtractTransferResultMQMsg msg) {
         String content = new Gson().toJson(msg);
-        tdmqUtil.sendMsg(EXTRACT_RESULT, content);
+        tdmqUtil.sendMsg(QUEUE_EXTRACT_RESULT, content);
     }
 
     /**
@@ -58,7 +63,7 @@
      * @return
      */
     public Map<String, ExtractTransferResultMQMsg> consumeExtractResultMsg(int count) {
-        List<Message> list = tdmqUtil.recieveMsg(count, EXTRACT_RESULT);
+        List<Message> list = tdmqUtil.recieveMsg(count, QUEUE_EXTRACT_RESULT);
         Map<String, ExtractTransferResultMQMsg> map = new HashMap<>();
         if (list != null) {
             for (Message msg : list) {
@@ -79,8 +84,66 @@
      * @param receiptHandle
      */
     public void deleteExtractResultMsg(String receiptHandle) {
-        tdmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);
+        tdmqUtil.deleteMsg(QUEUE_EXTRACT_RESULT, receiptHandle);
+    }
 
+
+    /**
+     * 娣诲姞閲戝竵
+     **/
+
+    public void addAddGoldCornMsg(AddGoldCornMQMsg msg) {
+        String content = new Gson().toJson(msg);
+        tdmqUtil.sendMsg(QUEUE_ADD_GOLDCORN, content);
+    }
+
+    public Map<String, AddGoldCornMQMsg> consumeAddGoldCornMsg(int count) {
+        List<Message> list = tdmqUtil.recieveMsg(count, QUEUE_ADD_GOLDCORN);
+        Map<String, AddGoldCornMQMsg> map = new HashMap<>();
+        if (list != null) {
+            for (Message msg : list) {
+                String result = msg.msgBody;
+                if (!StringUtil.isNullOrEmpty(result)) {
+                    AddGoldCornMQMsg resultMQMsg = new Gson().fromJson(result,
+                            AddGoldCornMQMsg.class);
+                    map.put(msg.receiptHandle, resultMQMsg);
+                }
+            }
+        }
+        return map;
+    }
+
+    public void deleteAddGoldCornMsg(String receiptHandle) {
+        tdmqUtil.deleteMsg(QUEUE_ADD_GOLDCORN, receiptHandle);
+
+    }
+
+    /**
+     * 閲戝竵缁撶畻
+     **/
+    public void addGoldCornSettleMsg(GoldCornSettleMQMsg msg) {
+        String content = new Gson().toJson(msg);
+        tdmqUtil.sendMsg(QUEUE_GOLDCORN_SETTLE, content);
+    }
+
+    public Map<String, GoldCornSettleMQMsg> consumeGoldCornSettleMsg(int count) {
+        List<Message> list = tdmqUtil.recieveMsg(count, QUEUE_GOLDCORN_SETTLE);
+        Map<String, GoldCornSettleMQMsg> map = new HashMap<>();
+        if (list != null) {
+            for (Message msg : list) {
+                String result = msg.msgBody;
+                if (!StringUtil.isNullOrEmpty(result)) {
+                    GoldCornSettleMQMsg resultMQMsg = new Gson().fromJson(result,
+                            GoldCornSettleMQMsg.class);
+                    map.put(msg.receiptHandle, resultMQMsg);
+                }
+            }
+        }
+        return map;
+    }
+
+    public void deleteGoldCornSettleMsg(String receiptHandle) {
+        tdmqUtil.deleteMsg(QUEUE_GOLDCORN_SETTLE, receiptHandle);
     }
 
 

--
Gitblit v1.8.0