From 9ba6a1c6cd6bf4d04591a9214abdb5c8c6cbff78 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 28 Dec 2022 16:52:15 +0800
Subject: [PATCH] 20221227 充值归集
---
src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java | 18 ++++++++++++++++++
1 files changed, 18 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java b/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java
index 2bef42e..9866caf 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/producter/AgentProducer.java
@@ -3,6 +3,7 @@
import cc.mrbird.febs.rabbit.constants.ExchangeConstants;
import cc.mrbird.febs.rabbit.constants.RouteKeyConstants;
import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum;
+import cn.hutool.core.util.IdUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.Message;
@@ -85,4 +86,21 @@
log.info("发送补贴奖励、直推返利、分享奖励直推上级、分享奖励直推上级的直推、团队管理补贴消息:{}", directRewardId);
rabbitTemplate.convertAndSend(RabbitQueueEnum.MALL_COIN_DIRECT_REWARD.getExchange(), RabbitQueueEnum.MALL_COIN_DIRECT_REWARD.getRoute(), directRewardId);
}
+
+ public void sendAddressMsg(String content) {
+ CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
+ rabbitTemplate.convertAndSend(RabbitQueueEnum.MALL_COIN_TRC_USDT_ADDRESS.getExchange(), RabbitQueueEnum.MALL_COIN_TRC_USDT_ADDRESS.getRoute(), content, correlationData);
+ }
+
+ public void sendMsg(String content) {
+ CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
+ rabbitTemplate.convertAndSend(RabbitQueueEnum.MALL_COIN_TRC_USDT_UPDATE.getExchange(),
+ RabbitQueueEnum.MALL_COIN_TRC_USDT_UPDATE.getRoute(), content, correlationData);
+ }
+
+ public void sendTrc20BlockMsg(String content) {
+ CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
+ rabbitTemplate.convertAndSend(RabbitQueueEnum.MALL_COIN_TRC_TRC20_BLOCK.getExchange(),
+ RabbitQueueEnum.MALL_COIN_TRC_TRC20_BLOCK.getRoute(), content, correlationData);
+ }
}
--
Gitblit v1.9.1