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/consumer/UsdtUpdateConsumer.java | 7 +++++++
1 files changed, 7 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
index 967c75f..f5d613c 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
@@ -40,6 +40,13 @@
@Resource
TrxUsdtUpdateService trxUsdtUpdateService;
+ @RabbitListener(queues = RabbitMqConfig.MEMBER_COIN_INSIDE_QUEUE)
+ public void memberCoinInside(Long withdrawId) {
+ log.info("处理用户内部转账的消息:{}#", withdrawId);
+
+ apiIgtOnHookPlanService.memberCoinInsideMessage(withdrawId);
+ }
+
@RabbitListener(queues = RabbitMqConfig.END_ON_HOOK_QUEUE)
public void endOnHook(Long orderId) {
log.info("处理用户结束挂机的消息:{}#", orderId);
--
Gitblit v1.9.1