From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/order/TeamOrderCMQManager.java | 205 ++++++++++++++-------------------------------------
1 files changed, 57 insertions(+), 148 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 dbd5ce3..e6ab8c3 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,57 @@
-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;
-
-public class TeamOrderCMQManager {
-
- private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
- private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
- private static TeamOrderCMQManager jdOrderCMQManager;
- private static CMQUtil cmqUtil;
-
- // 鍥㈤槦鍒嗙孩
- 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";
-
- 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;
- }
-
- 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 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 = 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) {
- cmqUtil.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 deleteTeamIncomePreMsg(String receiptHandle) {
- cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
- }
-
- // 鍥㈤槦鍒嗙孩鍒拌处
- public void addTeamDividentsMsg(UidDateDTO dto) {
- cmqUtil.sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));
- }
-
- 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;
- }
-
- 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 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 void deleteTeamIncomeMsg(String receiptHandle) {
- cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
- }
-}
+package com.yeshi.fanli.util.mq.cmq.order;
+
+import com.google.gson.Gson;
+import com.yeshi.fanli.dto.mq.UidDateDTO;
+import com.yeshi.fanli.util.Constant;
+import com.yeshi.fanli.util.mq.rabbit.RabbitmqSenderUtil;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Component
+public class TeamOrderCMQManager {
+
+ @Resource
+ private RabbitTemplate rabbitTemplate;
+
+
+ // 鍥㈤槦鍒嗙孩
+ 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";
+
+ static {
+
+ 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();
+ }
+
+ // 鍥㈤槦鍒嗙孩棰勫埌璐�
+ public void addTeamDividentsPreMsg(UidDateDTO dto) {
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, TEAM_DIVIDENTS_PRE, new Gson().toJson(dto));
+ }
+
+ // 鍥㈤槦鏀剁泭棰勫埌璐�
+ public void addFanLiTeamIncomePreMsg(UidDateDTO dto) {
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
+ }
+
+
+ // 鍥㈤槦鍒嗙孩鍒拌处
+ public void addTeamDividentsMsg(UidDateDTO dto) {
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, TEAM_DIVIDENTS, new Gson().toJson(dto));
+ }
+
+ // 鍥㈤槦鏀剁泭鍒拌处
+ public void addFanLiTeamIncomeMsg(UidDateDTO dto) {
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto)+"");
+ }
+}
--
Gitblit v1.8.0