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/UserMoneyChangeCMQManager.java | 133 ++++++++++++++------------------------------ 1 files changed, 42 insertions(+), 91 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/UserMoneyChangeCMQManager.java b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/UserMoneyChangeCMQManager.java index f74f842..8c090ed 100644 --- a/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/UserMoneyChangeCMQManager.java +++ b/fanli/src/main/java/com/yeshi/fanli/util/mq/cmq/UserMoneyChangeCMQManager.java @@ -1,91 +1,42 @@ -package com.yeshi.fanli.util.mq.cmq; - -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.money.UserMoneyChangeDTO; -import com.yeshi.fanli.log.LogHelper; - -public class UserMoneyChangeCMQManager { - - private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25"; - private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo"; - private static UserMoneyChangeCMQManager userMoneyChangeCMQManager; - private static CMQUtil cmqUtil; - - private final static String TOPIC_NAME = "topic_user_money"; - - public static String QUEUE_DEBT = TOPIC_NAME + "_" + "debt"; - - public static String SUBSCRIBE_DEBT = "debt"; - - static { - cmqUtil = CMQUtil.getInstance(secretId, secretKey); - // 鍒涘缓涓婚锛屾坊鍔犺闃� - cmqUtil.createTopic(TOPIC_NAME); - // 鐢ㄦ埛鍒歌闃� - String[] subscripts = new String[] { SUBSCRIBE_DEBT }; - String[] queues = new String[] { QUEUE_DEBT }; - - for (int i = 0; i < subscripts.length; i++) { - String queueName = queues[i]; - try { - cmqUtil.createQueue(queueName); - } catch (Exception e) { - } - try { - cmqUtil.subscribeTopic(TOPIC_NAME, subscripts[i], queueName); - } catch (Exception e) { - - } - } - } - - public static UserMoneyChangeCMQManager getInstance() { - if (userMoneyChangeCMQManager == null) - userMoneyChangeCMQManager = new UserMoneyChangeCMQManager(); - return userMoneyChangeCMQManager; - } - - /** - * 鍙戝竷 - * - * @param history - */ - public void addUserMoneyChangeMsg(UserMoneyChangeDTO dto) { - if (dto == null) - return; - cmqUtil.publishTopicMessage(TOPIC_NAME, new Gson().toJson(dto)); - LogHelper.test("璧勯噾娑堟伅鎶曢�掓垚鍔�"); - } - - /** - * 娑堣垂闃熷垪娑堟伅 - * - * @param queueName - * @param count - * @return - */ - public Map<String, UserMoneyChangeDTO> consumeQueueMsg(String queueName, int count) { - List<Message> list = cmqUtil.recieveMsg(count, queueName); - Map<String, UserMoneyChangeDTO> map = new HashMap<>(); - - if (list != null) - for (Message msg : list) { - String result = msg.msgBody; - UserMoneyChangeDTO dto = new Gson().fromJson(result, UserMoneyChangeDTO.class); - map.put(msg.receiptHandle, dto); - } - return map; - } - - public void deleteQueueMsg(String queueName, String receiptHandle) { - cmqUtil.deleteMsg(queueName, receiptHandle); - } - -} +package com.yeshi.fanli.util.mq.cmq; + +import com.google.gson.Gson; +import com.qcloud.cmq.Message; +import com.yeshi.fanli.dto.money.UserMoneyChangeDTO; +import com.yeshi.fanli.log.LogHelper; +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; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +@Component +public class UserMoneyChangeCMQManager { + + @Resource + private RabbitTemplate rabbitTemplate; + + + private final static String TOPIC_NAME = "topic_user_money"; + + public static String QUEUE_DEBT = TOPIC_NAME + "_" + "debt"; + + public static String SUBSCRIBE_DEBT = "debt"; + + /** + * 鍙戝竷 + * + * @param dto + */ + public void addUserMoneyChangeMsg(UserMoneyChangeDTO dto) { + if (dto == null) + return; + RabbitmqSenderUtil.sendExchangeMsg(rabbitTemplate, TOPIC_NAME,"*", new Gson().toJson(dto) ); + LogHelper.test("璧勯噾娑堟伅鎶曢�掓垚鍔�"); + } + +} -- Gitblit v1.8.0