From 2f5935ed11672046c37f733d855214f6147b4b58 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 28 三月 2022 11:33:19 +0800
Subject: [PATCH] TDMQ兼容

---
 fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java |  104 +++++++++++++++++++++++++++------------------------
 1 files changed, 55 insertions(+), 49 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java
index 7499e8c..0c1d028 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/PDDOrderCMQManager.java
@@ -4,6 +4,7 @@
 import java.util.List;
 import java.util.Map;
 
+import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
 import org.yeshi.utils.CMQUtil;
 
 import com.qcloud.cmq.Message;
@@ -12,60 +13,65 @@
 
 public class PDDOrderCMQManager {
 
-	private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
-	private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
-	private static PDDOrderCMQManager pddOrderCMQManager;
-	private static CMQUtil cmqUtil;
+    private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
+    private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
+    private static PDDOrderCMQManager pddOrderCMQManager;
+    private static CMQUtil cmqUtil;
 
-	public static String PDD_ORDER = "order-pdd";
+    public static String PDD_ORDER = "order-pdd";
 
-	static {
-		cmqUtil = CMQUtil.getInstance(secretId, secretKey);
-		PDD_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
-		cmqUtil.createQueue(PDD_ORDER);
-	}
+    static {
+        cmqUtil = CMQUtil.getInstance(secretId, secretKey);
+        TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
+        PDD_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
+        TDMQUtil.getInstance().createQueue(PDD_ORDER);
+    }
 
-	public static PDDOrderCMQManager getInstance() {
-		if (pddOrderCMQManager == null)
-			pddOrderCMQManager = new PDDOrderCMQManager();
-		return pddOrderCMQManager;
-	}
+    public static PDDOrderCMQManager getInstance() {
+        if (pddOrderCMQManager == null)
+            pddOrderCMQManager = new PDDOrderCMQManager();
+        return pddOrderCMQManager;
+    }
 
-	/**
-	 * 娣诲姞浜笢璁㈠崟鍒伴槦鍒�
-	 * 
-	 * @param orderId
-	 */
-	public void addPDDOrder(String orderId) {
-		if (StringUtil.isNullOrEmpty(orderId))
-			return;
-		cmqUtil.sendMsg(PDD_ORDER, orderId);
-	}
+    /**
+     * 娣诲姞浜笢璁㈠崟鍒伴槦鍒�
+     *
+     * @param orderId
+     */
+    public void addPDDOrder(String orderId) {
+        if (StringUtil.isNullOrEmpty(orderId))
+            return;
+        TDMQUtil.getInstance().sendMsg(PDD_ORDER, orderId);
+    }
 
-	/**
-	 * 娑堣垂闃熷垪娑堟伅
-	 * 
-	 * @param count
-	 * @return
-	 */
-	public Map<String, String> consumePDDOrder(int count) {
-		List<Message> list = cmqUtil.recieveMsg(count, PDD_ORDER);
-		Map<String, String> map = new HashMap<>();
-		if (list != null)
-			for (Message msg : list) {
-				String result = msg.msgBody;
-				map.put(msg.receiptHandle, result);
-			}
-		return map;
-	}
+    /**
+     * 娑堣垂闃熷垪娑堟伅
+     *
+     * @param count
+     * @return
+     */
+    public Map<String, String> consumePDDOrder(int count) {
+        List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, PDD_ORDER) : cmqUtil.recieveMsg(count, PDD_ORDER);
+        Map<String, String> map = new HashMap<>();
+        if (list != null)
+            for (Message msg : list) {
+                String result = msg.msgBody;
+                map.put(msg.receiptHandle, result);
+            }
+        return map;
+    }
 
-	/**
-	 * 鍒犻櫎浜笢闃熷垪
-	 * 
-	 * @param receiptHandle
-	 */
-	public void deletePDDOrder(String receiptHandle) {
-		cmqUtil.deleteMsg(PDD_ORDER, receiptHandle);
-	}
+    /**
+     * 鍒犻櫎浜笢闃熷垪
+     *
+     * @param receiptHandle
+     */
+    public void deletePDDOrder(String receiptHandle) {
+        if (Constant.TDMQ_CONSUMER) {
+            TDMQUtil.getInstance().deleteMsg(PDD_ORDER, receiptHandle);
+        } else {
+            cmqUtil.deleteMsg(PDD_ORDER, receiptHandle);
+        }
+    }
 
 }

--
Gitblit v1.8.0