From 5e7b0ed4a154ad067cbcf4aa1a1c7cce32f9864c Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 26 四月 2024 18:02:17 +0800
Subject: [PATCH] 唯品会链接解析升级
---
fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/TeamOrderCMQManager.java | 237 +++++++++++++++++++++++++++++------------------------------
1 files changed, 117 insertions(+), 120 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/TeamOrderCMQManager.java b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/TeamOrderCMQManager.java
index c24b7e7..43c7be9 100644
--- a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/TeamOrderCMQManager.java
+++ b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/TeamOrderCMQManager.java
@@ -1,148 +1,145 @@
package com.yeshi.fanli.util.mq.cmq.order;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.yeshi.utils.CMQUtil;
-
import com.google.gson.Gson;
import com.qcloud.cmq.Message;
import com.yeshi.fanli.dto.mq.UidDateDTO;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
+import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
public class TeamOrderCMQManager {
- private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
- private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
- private static TeamOrderCMQManager jdOrderCMQManager;
- private static CMQUtil cmqUtil;
+ private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
+ private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
+ private static TeamOrderCMQManager jdOrderCMQManager;
- // 鍥㈤槦鍒嗙孩
- public static String TEAM_DIVIDENTS_PRE = "team_dividents_pre";
- // 鍥㈤槦鏀剁泭
- public static String FANLI_TEAM_INCOME_ORDER_PRE = "fanli-team-income-order-pre";
+ // 鍥㈤槦鍒嗙孩
+ public static String TEAM_DIVIDENTS_PRE = "team_dividents_pre";
+ // 鍥㈤槦鏀剁泭
+ public static String FANLI_TEAM_INCOME_ORDER_PRE = "fanli-team-income-order-pre";
- // 鍥㈤槦鍒嗙孩
- public static String TEAM_DIVIDENTS = "team_dividents";
- // 鍥㈤槦鏀剁泭
- public static String FANLI_TEAM_INCOME_ORDER = "fanli-team-income-order";
+ // 鍥㈤槦鍒嗙孩
+ public static String TEAM_DIVIDENTS = "team_dividents";
+ // 鍥㈤槦鏀剁泭
+ public static String FANLI_TEAM_INCOME_ORDER = "fanli-team-income-order";
- static {
- cmqUtil = CMQUtil.getInstance(secretId, secretKey);
- if (Constant.IS_TEST) {
- TEAM_DIVIDENTS_PRE = "test-" + TEAM_DIVIDENTS_PRE;
- FANLI_TEAM_INCOME_ORDER_PRE = "test-" + FANLI_TEAM_INCOME_ORDER_PRE;
- TEAM_DIVIDENTS = "test-" + TEAM_DIVIDENTS;
- FANLI_TEAM_INCOME_ORDER = "test-" + FANLI_TEAM_INCOME_ORDER;
- }
+ static {
+ TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
+ TEAM_DIVIDENTS_PRE += "-" + Constant.systemCommonConfig.getProjectName();
+ FANLI_TEAM_INCOME_ORDER_PRE += "-" + Constant.systemCommonConfig.getProjectName();
+ TEAM_DIVIDENTS += "-" + Constant.systemCommonConfig.getProjectName();
+ FANLI_TEAM_INCOME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
+ TDMQUtil.getInstance().createQueue(TEAM_DIVIDENTS_PRE);
+ TDMQUtil.getInstance().createQueue(FANLI_TEAM_INCOME_ORDER_PRE);
+ TDMQUtil.getInstance().createQueue(TEAM_DIVIDENTS);
+ TDMQUtil.getInstance().createQueue(FANLI_TEAM_INCOME_ORDER);
+ }
- TEAM_DIVIDENTS_PRE += "-" + Constant.systemCommonConfig.getProjectName();
- FANLI_TEAM_INCOME_ORDER_PRE += "-" + Constant.systemCommonConfig.getProjectName();
- TEAM_DIVIDENTS += "-" + Constant.systemCommonConfig.getProjectName();
- FANLI_TEAM_INCOME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();
- cmqUtil.createQueue(TEAM_DIVIDENTS_PRE);
- cmqUtil.createQueue(FANLI_TEAM_INCOME_ORDER_PRE);
- cmqUtil.createQueue(TEAM_DIVIDENTS);
- cmqUtil.createQueue(FANLI_TEAM_INCOME_ORDER);
- }
+ public static TeamOrderCMQManager getInstance() {
+ if (jdOrderCMQManager == null)
+ jdOrderCMQManager = new TeamOrderCMQManager();
+ return jdOrderCMQManager;
+ }
- public static TeamOrderCMQManager getInstance() {
- if (jdOrderCMQManager == null)
- jdOrderCMQManager = new TeamOrderCMQManager();
- return jdOrderCMQManager;
- }
+ // 鍥㈤槦鍒嗙孩棰勫埌璐�
+ public void addTeamDividentsPreMsg(UidDateDTO dto) {
+ TDMQUtil.getInstance().sendMsg(TEAM_DIVIDENTS_PRE, new Gson().toJson(dto));
+ }
- // 鍥㈤槦鍒嗙孩棰勫埌璐�
- public void addTeamDividentsPreMsg(UidDateDTO dto) {
- cmqUtil.sendMsg(TEAM_DIVIDENTS_PRE, new Gson().toJson(dto));
- }
+ public Map<String, UidDateDTO> consumeTeamDividentsPreMsg(int count) {
+ Gson gson = new Gson();
+ List<Message> list = TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS_PRE);
+ Map<String, UidDateDTO> map = new HashMap<>();
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ map.put(msg.receiptHandle, gson.fromJson(result, UidDateDTO.class));
+ }
+ }
+ return map;
+ }
- public Map<String, UidDateDTO> consumeTeamDividentsPreMsg(int count) {
- Gson gson = new Gson();
- List<Message> list = cmqUtil.recieveMsg(count, TEAM_DIVIDENTS_PRE);
- Map<String, UidDateDTO> map = new HashMap<>();
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- map.put(msg.receiptHandle, gson.fromJson(result, UidDateDTO.class));
- }
- }
- return map;
- }
+ public void deleteTeamDividentsPreMsg(String receiptHandle) {
- public void deleteTeamDividentsPreMsg(String receiptHandle) {
- cmqUtil.deleteMsg(TEAM_DIVIDENTS_PRE, receiptHandle);
- }
+ TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS_PRE, receiptHandle);
- // 鍥㈤槦鏀剁泭棰勫埌璐�
- public void addFanLiTeamIncomePreMsg(UidDateDTO dto) {
- cmqUtil.sendMsg(FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
- }
+ }
- public Map<String, UidDateDTO> consumeFanLiTeamIncomePreMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, FANLI_TEAM_INCOME_ORDER_PRE);
- 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 addFanLiTeamIncomePreMsg(UidDateDTO dto) {
+ TDMQUtil.getInstance().sendMsg(FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
+ }
- public void deleteTeamIncomePreMsg(String receiptHandle) {
- cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
- }
+ public Map<String, UidDateDTO> consumeFanLiTeamIncomePreMsg(int count) {
+ List<Message> list = TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_ORDER_PRE);
+ 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 addTeamDividentsMsg(UidDateDTO dto) {
- cmqUtil.sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));
- }
+ public void deleteTeamIncomePreMsg(String receiptHandle) {
- public Map<String, UidDateDTO> consumeTeamDividentsMsg(int count) {
- Gson gson = new Gson();
- List<Message> list = cmqUtil.recieveMsg(count, TEAM_DIVIDENTS);
- Map<String, UidDateDTO> map = new HashMap<>();
- if (list != null)
- for (Message msg : list) {
- String result = msg.msgBody;
- if (!StringUtil.isNullOrEmpty(result)) {
- map.put(msg.receiptHandle, gson.fromJson(result, UidDateDTO.class));
- }
- }
- return map;
- }
+ TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
- public void deleteTeamDividentsMsg(String receiptHandle) {
- cmqUtil.deleteMsg(TEAM_DIVIDENTS, receiptHandle);
- }
+ }
- // 鍥㈤槦鏀剁泭鍒拌处
- public void addFanLiTeamIncomeMsg(UidDateDTO dto) {
- cmqUtil.sendMsg(FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto) + "");
- }
+ // 鍥㈤槦鍒嗙孩鍒拌处
+ public void addTeamDividentsMsg(UidDateDTO dto) {
+ TDMQUtil.getInstance().sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));
+ }
- public Map<String, UidDateDTO> consumeFanLiTeamIncomeMsg(int count) {
- List<Message> list = cmqUtil.recieveMsg(count, FANLI_TEAM_INCOME_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 Map<String, UidDateDTO> consumeTeamDividentsMsg(int count) {
+ Gson gson = new Gson();
+ List<Message> list = TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS);
+ Map<String, UidDateDTO> map = new HashMap<>();
+ if (list != null)
+ for (Message msg : list) {
+ String result = msg.msgBody;
+ if (!StringUtil.isNullOrEmpty(result)) {
+ map.put(msg.receiptHandle, gson.fromJson(result, UidDateDTO.class));
+ }
+ }
+ return map;
+ }
- public void deleteTeamIncomeMsg(String receiptHandle) {
- cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
- }
+ public void deleteTeamDividentsMsg(String receiptHandle) {
+
+ TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS, receiptHandle);
+
+ }
+
+ // 鍥㈤槦鏀剁泭鍒拌处
+ public void addFanLiTeamIncomeMsg(UidDateDTO dto) {
+ TDMQUtil.getInstance().sendMsg(FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto) + "");
+ }
+
+ public Map<String, UidDateDTO> consumeFanLiTeamIncomeMsg(int count) {
+ List<Message> list = TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_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 deleteTeamIncomeMsg(String receiptHandle) {
+ TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
+ }
}
--
Gitblit v1.8.0