From 4e4af90184f5fa5b40d87e2d08d9192bfd237ef0 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 30 四月 2021 19:13:58 +0800
Subject: [PATCH] 拼多多备案,京东、拼多多，唯品会，苏宁支持小程序跳转
---
fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java | 895 +++++++++++++++++++++++++++++-----------------------------
1 files changed, 448 insertions(+), 447 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java b/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
index 82f5b33..60d3bdb 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java
@@ -1,447 +1,448 @@
-package com.yeshi.fanli.util;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.yeshi.utils.CMQUtil;
-
-import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;
-import com.google.gson.Gson;
-import com.google.gson.GsonBuilder;
-import com.qcloud.cmq.Message;
-import com.yeshi.fanli.dto.HongBao;
-import com.yeshi.fanli.dto.mq.UidDateDTO;
-import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;
-import com.yeshi.fanli.entity.bus.user.Extract;
-import com.yeshi.fanli.entity.bus.user.HongBaoV2;
-import com.yeshi.fanli.entity.common.AdminUser;
-import com.yeshi.fanli.entity.push.PushQueueRecord;
-import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
-
-public class CMQManager {
- private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
- private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
- private static CMQManager cmqManager;
- private static CMQUtil cmqUtil;
- // 璁㈠崟澶勭悊闃熷垪
- public static String QUEUENAME_ORDER = "fanli-orders";
-
- // 鍒氬垰浜х敓鐨勮鍗曞鐞嗛槦鍒�
- public static String QUEUENAME_NEW_ORDER = "fanli-new-orders";
-
- // 鎻愮幇缁撴灉澶勭悊闃熷垪
- public static String EXTRACT_RESULT = "extract-result";
- // IOS鎺ㄩ�侀槦鍒�
- public static String PUSH_IOS = "push-ios";
-
- // 杩斿埄闃熷垪
- public static String FANLI_ORDER = "fanli-order";
-
- // 杩斿埄闃熷垪
- public static String FANLI_ORDER_NEW = "fanli-order-new";
-
-
-
- // 鍒嗕韩璁㈠崟鏀剁泭
- public static String FANLI_SHARE_ORDER = "fanli-share-order";
-
- // 缁存潈璁㈠崟
- public static String ORDER_WEIQUAN = "weiquan-order";
-
- public static String GOODS_UPDATE = "goods_update_queue";
- // 閲嶈鏁版嵁鏇存柊
- public static String IMPORTANT_GOODS_UPDATE = "imp_goods_update_queue";
-
- static {
-
- if (Constant.IS_TEST) {
- QUEUENAME_ORDER = "test-" + QUEUENAME_ORDER;
- QUEUENAME_NEW_ORDER = "test-" + QUEUENAME_NEW_ORDER;
- EXTRACT_RESULT = "test-" + EXTRACT_RESULT;
- PUSH_IOS = "test-" + PUSH_IOS;
- FANLI_ORDER = "test-" + FANLI_ORDER;
- FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;
-
- ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;
- IMPORTANT_GOODS_UPDATE = "test-" + IMPORTANT_GOODS_UPDATE;
- FANLI_SHARE_ORDER = "test-" + FANLI_SHARE_ORDER;
- }
-
- QUEUENAME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
- QUEUENAME_NEW_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
- EXTRACT_RESULT += "-" + Constant.systemCommonConfig.getProjectName();
- PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();
- FANLI_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
- FANLI_ORDER_NEW += "-" + Constant.systemCommonConfig.getProjectName();
- ORDER_WEIQUAN += "-" + Constant.systemCommonConfig.getProjectName();
- IMPORTANT_GOODS_UPDATE += "-" + Constant.systemCommonConfig.getProjectName();
- FANLI_SHARE_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
-
- cmqUtil = CMQUtil.getInstance(secretId, secretKey);
- // 鏈�澶ф秷鎭负1M
- cmqUtil.createQueue(QUEUENAME_ORDER, 1024 * 1024);
- cmqUtil.createQueue(QUEUENAME_NEW_ORDER, 1024 * 1024);
- cmqUtil.createQueue(EXTRACT_RESULT);
- cmqUtil.createQueue(PUSH_IOS);
- cmqUtil.createQueue(FANLI_ORDER);
- cmqUtil.createQueue(FANLI_ORDER_NEW);
-
- cmqUtil.createQueue(ORDER_WEIQUAN);
- cmqUtil.createQueue(GOODS_UPDATE);
- cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);
-
- cmqUtil.createQueue(FANLI_SHARE_ORDER);
- }
-
- public static CMQManager getInstance() {
- if (cmqManager == null)
- cmqManager = new CMQManager();
- return cmqManager;
- }
-
- /**
- * 鍙戦�佽鍗曟秷鎭�
- *
- * @param orderMap
- */
- public void addTaoBaoOrderMsg(String orderId) {
- if (!StringUtil.isNullOrEmpty(orderId)) {
- cmqUtil.sendMsg(QUEUENAME_ORDER, orderId);
- }
- }
-
- /**
- * 娑堣垂娣樺疂璁㈠崟娑堟伅
- *
- * @param count
- */
- public List<String> consumeTaoBaoOrderMsg(int count) {
- List<String> resultList = new ArrayList<>();
- List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_ORDER);
-
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- resultList.add(result);
- // 鍒犻櫎娑堟伅
- cmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
- }
- return resultList;
- }
-
- /**
- * 鍒犻櫎娣樺疂璁㈠崟娑堟伅
- *
- * @param receiptHandle
- */
- public void deleteTaoBaoOrderMsg(String receiptHandle) {
- cmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);
- }
-
- /**
- * 鍙戦�佽鍗曟秷鎭紙鍒氬垰浜х敓鐨勮鍗曪級
- *
- * @param orderMap
- */
- public void addTaoBaoNewOrderMsg(String orderId) {
- if (!StringUtil.isNullOrEmpty(orderId)) {
- cmqUtil.sendMsg(QUEUENAME_NEW_ORDER, orderId);
- }
- }
-
- /**
- * 娑堣垂娣樺疂璁㈠崟娑堟伅锛堝垰鍒氫骇鐢熺殑璁㈠崟锛�
- *
- * @param count
- */
- public List<String> consumeTaoBaoNewOrderMsg(int count) {
- List<String> resultList = new ArrayList<>();
- List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);
-
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- resultList.add(result);
- // 鍒犻櫎娑堟伅
- cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
- }
- return resultList;
- }
-
- /**
- * 鍒犻櫎娣樺疂璁㈠崟娑堟伅锛堝垰鍒氫骇鐢熺殑璁㈠崟锛�
- *
- * @param receiptHandle
- */
- public void deleteTaoBaoNewOrderMsg(String receiptHandle) {
- cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);
- }
-
- /**
- * 娣诲姞鎻愮幇缁撴灉娑堟伅
- *
- * @param extract
- * @param response
- */
- public void addExtractResultMsg(Extract extract, AlipayFundTransToaccountTransferResponse response,
- AdminUser adminUser) {
- String content = new Gson().toJson(new AlipayTransferResultInfo(extract, response, adminUser));
- cmqUtil.sendMsg(EXTRACT_RESULT, content);
- }
-
- /**
- * 娑堣垂鎻愮幇缁撴灉娑堟伅
- *
- * @param count
- * @return
- */
- public Map<String, AlipayTransferResultInfo> consumeExtractResultMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, EXTRACT_RESULT);
- Map<String, AlipayTransferResultInfo> map = new HashMap<>();
-
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- AlipayTransferResultInfo alipayTransferResultInfo = new Gson().fromJson(result,
- AlipayTransferResultInfo.class);
- map.put(msg.receiptHandle, alipayTransferResultInfo);
- }
- }
- return map;
- }
-
- /**
- * 鍒犻櫎鎻愮幇缁撴灉娑堟伅
- *
- * @param receiptHandle
- */
- public void deleteExtractResultMsg(String receiptHandle) {
- cmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);
- }
-
- // 璁㈠崟杩斿埄
- public void addFanLiMsg(HongBao hongBao) {
- String content = new Gson().toJson(hongBao);
- cmqUtil.sendMsg(FANLI_ORDER, content);
- }
-
- // 鏂扮増璁㈠崟杩斿埄
- public void addFanLiMsgNew(HongBaoV2 hongBao) {
- String content = new Gson().toJson(hongBao);
- cmqUtil.sendMsg(FANLI_ORDER_NEW, content);
- }
-
- public Map<String, HongBao> consumeFanLiMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER);
- Map<String, HongBao> map = new HashMap<>();
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- HongBao hongBao = new Gson().fromJson(result, HongBao.class);
- map.put(msg.receiptHandle, hongBao);
- }
- }
- return map;
- }
-
- public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
- Map<String, HongBaoV2> map = new HashMap<>();
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- HongBaoV2 hongBao = new Gson().fromJson(result, HongBaoV2.class);
- map.put(msg.receiptHandle, hongBao);
- }
- }
- return map;
- }
-
- public void deleteFanLiMsg(String receiptHandle) {
- cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);
- }
-
- public void deleteFanLiMsgNew(String receiptHandle) {
- cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
- }
-
-
-
- // 鍒嗕韩璁㈠崟鏀剁泭
- public void addFanLiShareMsg(UidDateDTO dto) {
- cmqUtil.sendMsg(FANLI_SHARE_ORDER, new Gson().toJson(dto));
- }
-
- public Map<String, UidDateDTO> consumeFanLiShareMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, FANLI_SHARE_ORDER);
- Map<String, UidDateDTO> map = new HashMap<>();
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- UidDateDTO dto = new Gson().fromJson(result, UidDateDTO.class);
- if (!StringUtil.isNullOrEmpty(result)) {
- map.put(msg.receiptHandle, dto);
- }
- }
- return map;
- }
-
- public void deleteFanLiShareMsg(String receiptHandle) {
- cmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
- }
-
- // 缁存潈璁㈠崟
- public void addWeiQuanOrderMsg(TaoBaoWeiQuanOrder order) {
- cmqUtil.sendMsg(ORDER_WEIQUAN, new Gson().toJson(order));
- }
-
- public Map<String, TaoBaoWeiQuanOrder> consumeWeiQuanOrderMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, ORDER_WEIQUAN);
- Map<String, TaoBaoWeiQuanOrder> map = new HashMap<>();
- Gson gson = new Gson();
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- map.put(msg.receiptHandle, gson.fromJson(result, TaoBaoWeiQuanOrder.class));
- }
- }
- return map;
- }
-
- public void deleteWeiQuanOrderMsg(String receiptHandle) {
- cmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
- }
-
- /**
- * 娣诲姞IOS鎺ㄩ�佹秷鎭�
- *
- * @param count
- */
- public void addIOSPushMsg(PushQueueRecord pushQueueRecord) {
-
- String content = new GsonBuilder().create().toJson(pushQueueRecord);
- cmqUtil.sendMsg(PUSH_IOS, content);
- }
-
- /**
- * IOS鎺ㄩ��
- *
- * @param count
- */
- public Map<String, PushQueueRecord> consumeIOSPushMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, PUSH_IOS);
- if (list == null) {
- return null;
- }
-
- Map<String, PushQueueRecord> map = new HashMap<>();
- for (Message msg : list) {
-
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- PushQueueRecord pushQueueRecord = new Gson().fromJson(result, PushQueueRecord.class);
- map.put(msg.receiptHandle, pushQueueRecord);
- }
-
- }
-
- return map;
- }
-
- /**
- * 鍒犻櫎IOSPush娑堟伅
- *
- * @param receiptHandle
- */
- public void deleteIOSPushMsg(String receiptHandle) {
- cmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
- }
-
- /**
- * 娣诲姞闇�瑕佹洿鏂扮殑鍟嗗搧ID
- *
- * @param count
- */
- public void addNeedUpdateTaoBaoGoodsId(Long goodsId) {
- cmqUtil.sendMsg(GOODS_UPDATE, goodsId + "");
- }
-
- /**
- * 娑堣垂娑堟伅闇�瑕佹洿鏂扮殑鍟嗗搧娑堟伅
- *
- * @param count
- */
- public Map<String, Long> consumeNeedUpdateTaoBaoGoodsIdMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, GOODS_UPDATE);
- if (list == null) {
- return null;
- }
-
- Map<String, Long> map = new HashMap<>();
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- map.put(msg.receiptHandle, Long.parseLong(result));
- }
-
- }
-
- return map;
- }
-
- /**
- * 鍒犻櫎IOSPush娑堟伅
- *
- * @param receiptHandle
- */
- public void deleteNeedUpdateTaoBaoGoodsIdMsg(String receiptHandle) {
- cmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);
- }
-
- /**
- * 娣诲姞娣樺疂閲嶈鍟嗗搧鏇存柊
- *
- * @param actionId
- */
- public void addTBImpGoodsUpdate(Long actionId) {
- cmqUtil.sendMsg(IMPORTANT_GOODS_UPDATE, actionId + "");
- }
-
- /**
- * 璇诲彇閲嶈鍟嗗搧鏇存柊闃熷垪
- *
- * @param count
- * @return
- */
- public Map<String, Long> consumeTBImpGoodsUpdateMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);
- if (list == null) {
- return null;
- }
-
- Map<String, Long> map = new HashMap<>();
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- map.put(msg.receiptHandle, Long.parseLong(result));
- }
- }
- return map;
- }
-
- /**
- * 鍒犻櫎闃熷垪娑堟伅
- *
- * @param receiptHandle
- */
- public void deleteTBImpGoodsUpdateMsg(String receiptHandle) {
- cmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
- }
-
-}
+package com.yeshi.fanli.util;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.yeshi.utils.CMQUtil;
+
+import com.alipay.api.response.AlipayFundTransToaccountTransferResponse;
+import com.alipay.api.response.AlipayFundTransUniTransferResponse;
+import com.google.gson.Gson;
+import com.google.gson.GsonBuilder;
+import com.qcloud.cmq.Message;
+import com.yeshi.fanli.dto.HongBao;
+import com.yeshi.fanli.dto.mq.UidDateDTO;
+import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;
+import com.yeshi.fanli.entity.bus.user.Extract;
+import com.yeshi.fanli.entity.bus.user.HongBaoV2;
+import com.yeshi.fanli.entity.common.AdminUser;
+import com.yeshi.fanli.entity.push.PushQueueRecord;
+import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
+
+public class CMQManager {
+ private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
+ private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
+ private static CMQManager cmqManager;
+ private static CMQUtil cmqUtil;
+ // 璁㈠崟澶勭悊闃熷垪
+ public static String QUEUENAME_ORDER = "fanli-orders";
+
+ // 鍒氬垰浜х敓鐨勮鍗曞鐞嗛槦鍒�
+ public static String QUEUENAME_NEW_ORDER = "fanli-new-orders";
+
+ // 鎻愮幇缁撴灉澶勭悊闃熷垪
+ public static String EXTRACT_RESULT = "extract-result";
+ // IOS鎺ㄩ�侀槦鍒�
+ public static String PUSH_IOS = "push-ios";
+
+ // 杩斿埄闃熷垪
+ public static String FANLI_ORDER = "fanli-order";
+
+ // 杩斿埄闃熷垪
+ public static String FANLI_ORDER_NEW = "fanli-order-new";
+
+
+
+ // 鍒嗕韩璁㈠崟鏀剁泭
+ public static String FANLI_SHARE_ORDER = "fanli-share-order";
+
+ // 缁存潈璁㈠崟
+ public static String ORDER_WEIQUAN = "weiquan-order";
+
+ public static String GOODS_UPDATE = "goods_update_queue";
+ // 閲嶈鏁版嵁鏇存柊
+ public static String IMPORTANT_GOODS_UPDATE = "imp_goods_update_queue";
+
+ static {
+
+ if (Constant.IS_TEST) {
+ QUEUENAME_ORDER = "test-" + QUEUENAME_ORDER;
+ QUEUENAME_NEW_ORDER = "test-" + QUEUENAME_NEW_ORDER;
+ EXTRACT_RESULT = "test-" + EXTRACT_RESULT;
+ PUSH_IOS = "test-" + PUSH_IOS;
+ FANLI_ORDER = "test-" + FANLI_ORDER;
+ FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;
+
+ ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;
+ IMPORTANT_GOODS_UPDATE = "test-" + IMPORTANT_GOODS_UPDATE;
+ FANLI_SHARE_ORDER = "test-" + FANLI_SHARE_ORDER;
+ }
+
+ QUEUENAME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
+ QUEUENAME_NEW_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
+ EXTRACT_RESULT += "-" + Constant.systemCommonConfig.getProjectName();
+ PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();
+ FANLI_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
+ FANLI_ORDER_NEW += "-" + Constant.systemCommonConfig.getProjectName();
+ ORDER_WEIQUAN += "-" + Constant.systemCommonConfig.getProjectName();
+ IMPORTANT_GOODS_UPDATE += "-" + Constant.systemCommonConfig.getProjectName();
+ FANLI_SHARE_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
+
+ cmqUtil = CMQUtil.getInstance(secretId, secretKey);
+ // 鏈�澶ф秷鎭负1M
+ cmqUtil.createQueue(QUEUENAME_ORDER, 1024 * 1024);
+ cmqUtil.createQueue(QUEUENAME_NEW_ORDER, 1024 * 1024);
+ cmqUtil.createQueue(EXTRACT_RESULT);
+ cmqUtil.createQueue(PUSH_IOS);
+ cmqUtil.createQueue(FANLI_ORDER);
+ cmqUtil.createQueue(FANLI_ORDER_NEW);
+
+ cmqUtil.createQueue(ORDER_WEIQUAN);
+ cmqUtil.createQueue(GOODS_UPDATE);
+ cmqUtil.createQueue(IMPORTANT_GOODS_UPDATE);
+
+ cmqUtil.createQueue(FANLI_SHARE_ORDER);
+ }
+
+ public static CMQManager getInstance() {
+ if (cmqManager == null)
+ cmqManager = new CMQManager();
+ return cmqManager;
+ }
+
+ /**
+ * 鍙戦�佽鍗曟秷鎭�
+ *
+ * @param orderMap
+ */
+ public void addTaoBaoOrderMsg(String orderId) {
+ if (!StringUtil.isNullOrEmpty(orderId)) {
+ cmqUtil.sendMsg(QUEUENAME_ORDER, orderId);
+ }
+ }
+
+ /**
+ * 娑堣垂娣樺疂璁㈠崟娑堟伅
+ *
+ * @param count
+ */
+ public List<String> consumeTaoBaoOrderMsg(int count) {
+ List<String> resultList = new ArrayList<>();
+ List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_ORDER);
+
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ resultList.add(result);
+ // 鍒犻櫎娑堟伅
+ cmqUtil.deleteMsg(QUEUENAME_ORDER, msg.receiptHandle);
+ }
+ return resultList;
+ }
+
+ /**
+ * 鍒犻櫎娣樺疂璁㈠崟娑堟伅
+ *
+ * @param receiptHandle
+ */
+ public void deleteTaoBaoOrderMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(QUEUENAME_ORDER, receiptHandle);
+ }
+
+ /**
+ * 鍙戦�佽鍗曟秷鎭紙鍒氬垰浜х敓鐨勮鍗曪級
+ *
+ * @param orderMap
+ */
+ public void addTaoBaoNewOrderMsg(String orderId) {
+ if (!StringUtil.isNullOrEmpty(orderId)) {
+ cmqUtil.sendMsg(QUEUENAME_NEW_ORDER, orderId);
+ }
+ }
+
+ /**
+ * 娑堣垂娣樺疂璁㈠崟娑堟伅锛堝垰鍒氫骇鐢熺殑璁㈠崟锛�
+ *
+ * @param count
+ */
+ public List<String> consumeTaoBaoNewOrderMsg(int count) {
+ List<String> resultList = new ArrayList<>();
+ List<Message> list = cmqUtil.recieveMsg(count, QUEUENAME_NEW_ORDER);
+
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ resultList.add(result);
+ // 鍒犻櫎娑堟伅
+ cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, msg.receiptHandle);
+ }
+ return resultList;
+ }
+
+ /**
+ * 鍒犻櫎娣樺疂璁㈠崟娑堟伅锛堝垰鍒氫骇鐢熺殑璁㈠崟锛�
+ *
+ * @param receiptHandle
+ */
+ public void deleteTaoBaoNewOrderMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(QUEUENAME_NEW_ORDER, receiptHandle);
+ }
+
+ /**
+ * 娣诲姞鎻愮幇缁撴灉娑堟伅
+ *
+ * @param extract
+ * @param response
+ */
+ public void addExtractResultMsg(Extract extract, AlipayFundTransUniTransferResponse response,
+ AdminUser adminUser) {
+ String content = new Gson().toJson(new AlipayTransferResultInfo(extract, response, adminUser));
+ cmqUtil.sendMsg(EXTRACT_RESULT, content);
+ }
+
+ /**
+ * 娑堣垂鎻愮幇缁撴灉娑堟伅
+ *
+ * @param count
+ * @return
+ */
+ public Map<String, AlipayTransferResultInfo> consumeExtractResultMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, EXTRACT_RESULT);
+ Map<String, AlipayTransferResultInfo> map = new HashMap<>();
+
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ AlipayTransferResultInfo alipayTransferResultInfo = new Gson().fromJson(result,
+ AlipayTransferResultInfo.class);
+ map.put(msg.receiptHandle, alipayTransferResultInfo);
+ }
+ }
+ return map;
+ }
+
+ /**
+ * 鍒犻櫎鎻愮幇缁撴灉娑堟伅
+ *
+ * @param receiptHandle
+ */
+ public void deleteExtractResultMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(EXTRACT_RESULT, receiptHandle);
+ }
+
+ // 璁㈠崟杩斿埄
+ public void addFanLiMsg(HongBao hongBao) {
+ String content = new Gson().toJson(hongBao);
+ cmqUtil.sendMsg(FANLI_ORDER, content);
+ }
+
+ // 鏂扮増璁㈠崟杩斿埄
+ public void addFanLiMsgNew(HongBaoV2 hongBao) {
+ String content = new Gson().toJson(hongBao);
+ cmqUtil.sendMsg(FANLI_ORDER_NEW, content);
+ }
+
+ public Map<String, HongBao> consumeFanLiMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER);
+ Map<String, HongBao> map = new HashMap<>();
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ HongBao hongBao = new Gson().fromJson(result, HongBao.class);
+ map.put(msg.receiptHandle, hongBao);
+ }
+ }
+ return map;
+ }
+
+ public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);
+ Map<String, HongBaoV2> map = new HashMap<>();
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ HongBaoV2 hongBao = new Gson().fromJson(result, HongBaoV2.class);
+ map.put(msg.receiptHandle, hongBao);
+ }
+ }
+ return map;
+ }
+
+ public void deleteFanLiMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);
+ }
+
+ public void deleteFanLiMsgNew(String receiptHandle) {
+ cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);
+ }
+
+
+
+ // 鍒嗕韩璁㈠崟鏀剁泭
+ public void addFanLiShareMsg(UidDateDTO dto) {
+ cmqUtil.sendMsg(FANLI_SHARE_ORDER, new Gson().toJson(dto));
+ }
+
+ public Map<String, UidDateDTO> consumeFanLiShareMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, FANLI_SHARE_ORDER);
+ Map<String, UidDateDTO> map = new HashMap<>();
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ UidDateDTO dto = new Gson().fromJson(result, UidDateDTO.class);
+ if (!StringUtil.isNullOrEmpty(result)) {
+ map.put(msg.receiptHandle, dto);
+ }
+ }
+ return map;
+ }
+
+ public void deleteFanLiShareMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(FANLI_SHARE_ORDER, receiptHandle);
+ }
+
+ // 缁存潈璁㈠崟
+ public void addWeiQuanOrderMsg(TaoBaoWeiQuanOrder order) {
+ cmqUtil.sendMsg(ORDER_WEIQUAN, new Gson().toJson(order));
+ }
+
+ public Map<String, TaoBaoWeiQuanOrder> consumeWeiQuanOrderMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, ORDER_WEIQUAN);
+ Map<String, TaoBaoWeiQuanOrder> map = new HashMap<>();
+ Gson gson = new Gson();
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ map.put(msg.receiptHandle, gson.fromJson(result, TaoBaoWeiQuanOrder.class));
+ }
+ }
+ return map;
+ }
+
+ public void deleteWeiQuanOrderMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(ORDER_WEIQUAN, receiptHandle);
+ }
+
+ /**
+ * 娣诲姞IOS鎺ㄩ�佹秷鎭�
+ *
+ * @param count
+ */
+ public void addIOSPushMsg(PushQueueRecord pushQueueRecord) {
+
+ String content = new GsonBuilder().create().toJson(pushQueueRecord);
+ cmqUtil.sendMsg(PUSH_IOS, content);
+ }
+
+ /**
+ * IOS鎺ㄩ��
+ *
+ * @param count
+ */
+ public Map<String, PushQueueRecord> consumeIOSPushMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, PUSH_IOS);
+ if (list == null) {
+ return null;
+ }
+
+ Map<String, PushQueueRecord> map = new HashMap<>();
+ for (Message msg : list) {
+
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ PushQueueRecord pushQueueRecord = new Gson().fromJson(result, PushQueueRecord.class);
+ map.put(msg.receiptHandle, pushQueueRecord);
+ }
+
+ }
+
+ return map;
+ }
+
+ /**
+ * 鍒犻櫎IOSPush娑堟伅
+ *
+ * @param receiptHandle
+ */
+ public void deleteIOSPushMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(PUSH_IOS, receiptHandle);
+ }
+
+ /**
+ * 娣诲姞闇�瑕佹洿鏂扮殑鍟嗗搧ID
+ *
+ * @param count
+ */
+ public void addNeedUpdateTaoBaoGoodsId(Long goodsId) {
+ cmqUtil.sendMsg(GOODS_UPDATE, goodsId + "");
+ }
+
+ /**
+ * 娑堣垂娑堟伅闇�瑕佹洿鏂扮殑鍟嗗搧娑堟伅
+ *
+ * @param count
+ */
+ public Map<String, Long> consumeNeedUpdateTaoBaoGoodsIdMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, GOODS_UPDATE);
+ if (list == null) {
+ return null;
+ }
+
+ Map<String, Long> map = new HashMap<>();
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ map.put(msg.receiptHandle, Long.parseLong(result));
+ }
+
+ }
+
+ return map;
+ }
+
+ /**
+ * 鍒犻櫎IOSPush娑堟伅
+ *
+ * @param receiptHandle
+ */
+ public void deleteNeedUpdateTaoBaoGoodsIdMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(GOODS_UPDATE, receiptHandle);
+ }
+
+ /**
+ * 娣诲姞娣樺疂閲嶈鍟嗗搧鏇存柊
+ *
+ * @param actionId
+ */
+ public void addTBImpGoodsUpdate(Long actionId) {
+ cmqUtil.sendMsg(IMPORTANT_GOODS_UPDATE, actionId + "");
+ }
+
+ /**
+ * 璇诲彇閲嶈鍟嗗搧鏇存柊闃熷垪
+ *
+ * @param count
+ * @return
+ */
+ public Map<String, Long> consumeTBImpGoodsUpdateMsg(int count) {
+ List<Message> list = cmqUtil.recieveMsg(count, IMPORTANT_GOODS_UPDATE);
+ if (list == null) {
+ return null;
+ }
+
+ Map<String, Long> map = new HashMap<>();
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ map.put(msg.receiptHandle, Long.parseLong(result));
+ }
+ }
+ return map;
+ }
+
+ /**
+ * 鍒犻櫎闃熷垪娑堟伅
+ *
+ * @param receiptHandle
+ */
+ public void deleteTBImpGoodsUpdateMsg(String receiptHandle) {
+ cmqUtil.deleteMsg(IMPORTANT_GOODS_UPDATE, receiptHandle);
+ }
+
+}
--
Gitblit v1.8.0