From 7cd5e4d9e5450aaf5617a1e69c14ceefb55c011b Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 24 Nov 2022 10:47:50 +0800
Subject: [PATCH] 20221117 挂机极差，以自己的等级为基准
---
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