From 5c53b4e1e7dc2bae956332a0dc446992725c80bb Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 14 Nov 2022 10:00:37 +0800
Subject: [PATCH] 20221114，内转改成不需要审核，通过mq处理
---
src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java b/src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java
index ad6292a..0d282f5 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/producer/UsdtUpdateProducer.java
@@ -27,6 +27,12 @@
rabbitTemplate.setConfirmCallback(this);
}
+ public void sendMemberCoinInside(Long withdrawId) {
+ log.info("发送用户内部转账的消息:{}", withdrawId);
+ CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
+ rabbitTemplate.convertAndSend(RabbitMqConfig.MEMBER_COIN_INSIDE_EXCHANGE, RabbitMqConfig.MEMBER_COIN_INSIDE__ROUTE_KEY, withdrawId, correlationData);
+ }
+
public void sendOnHookEnd(Long orderId) {
log.info("发送用户结束挂机的消息:{}", orderId);
CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
--
Gitblit v1.9.1