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 | 136 ++++-----------------------------------------
1 files changed, 13 insertions(+), 123 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 27ef879..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,24 +1,20 @@
package com.yeshi.fanli.util.mq.cmq.order;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
-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.rabbit.RabbitmqSenderUtil;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.stereotype.Component;
+import javax.annotation.Resource;
+
+@Component
public class TeamOrderCMQManager {
- private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
- private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
- private static TeamOrderCMQManager jdOrderCMQManager;
- private static CMQUtil cmqUtil;
+ @Resource
+ private RabbitTemplate rabbitTemplate;
+
// 鍥㈤槦鍒嗙孩
public static String TEAM_DIVIDENTS_PRE = "team_dividents_pre";
@@ -31,137 +27,31 @@
public static String FANLI_TEAM_INCOME_ORDER = "fanli-team-income-order";
static {
- cmqUtil = CMQUtil.getInstance(secretId, secretKey);
- TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);
-
- 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();
- 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);
- }
-
- 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 Map<String, UidDateDTO> consumeTeamDividentsPreMsg(int count) {
- Gson gson = new Gson();
- List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS_PRE) : 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) {
- if (Constant.TDMQ_CONSUMER) {
- TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS_PRE, receiptHandle);
- } else {
- cmqUtil.deleteMsg(TEAM_DIVIDENTS_PRE, receiptHandle);
- }
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, TEAM_DIVIDENTS_PRE, new Gson().toJson(dto));
}
// 鍥㈤槦鏀剁泭棰勫埌璐�
public void addFanLiTeamIncomePreMsg(UidDateDTO dto) {
- TDMQUtil.getInstance().sendMsg(FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, FANLI_TEAM_INCOME_ORDER_PRE, new Gson().toJson(dto) + "");
}
- public Map<String, UidDateDTO> consumeFanLiTeamIncomePreMsg(int count) {
- List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_ORDER_PRE) : 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) {
- if (Constant.TDMQ_CONSUMER) {
- TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
- } else {
- cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER_PRE, receiptHandle);
- }
- }
// 鍥㈤槦鍒嗙孩鍒拌处
public void addTeamDividentsMsg(UidDateDTO dto) {
- TDMQUtil.getInstance().sendMsg(TEAM_DIVIDENTS, new Gson().toJson(dto));
- }
-
- public Map<String, UidDateDTO> consumeTeamDividentsMsg(int count) {
- Gson gson = new Gson();
- List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, TEAM_DIVIDENTS) : 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) {
- if (Constant.TDMQ_CONSUMER) {
- TDMQUtil.getInstance().deleteMsg(TEAM_DIVIDENTS, receiptHandle);
- } else {
- cmqUtil.deleteMsg(TEAM_DIVIDENTS, receiptHandle);
- }
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, TEAM_DIVIDENTS, new Gson().toJson(dto));
}
// 鍥㈤槦鏀剁泭鍒拌处
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 = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, FANLI_TEAM_INCOME_ORDER) : 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) {
- if (Constant.TDMQ_CONSUMER) {
- TDMQUtil.getInstance().deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
- } else {
- cmqUtil.deleteMsg(FANLI_TEAM_INCOME_ORDER, receiptHandle);
- }
+ RabbitmqSenderUtil.sendQueueMsg(rabbitTemplate, FANLI_TEAM_INCOME_ORDER, new Gson().toJson(dto)+"");
}
}
--
Gitblit v1.8.0