From 24ceb7b6168f04d1727ad1bbf4ee44d33a545cf4 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 19 May 2023 10:12:38 +0800
Subject: [PATCH] twoCoin项目修改
---
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | 48 ++++++++++++++++++++++++------------------------
1 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
index cb62c56..038a434 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -49,20 +49,20 @@
/**层级奖励分发消息
* @param id
*/
- @RabbitListener(queues = QueueConstants.QUEUE_LEVEL_PROFIT)
- public void levelProfit(Long id) {
- log.info("消费层级奖励分发消息:{}", id);
- dappSystemService.levelProfit(id);
- }
+// @RabbitListener(queues = QueueConstants.QUEUE_LEVEL_PROFIT)
+// public void levelProfit(Long id) {
+// log.info("消费层级奖励分发消息:{}", id);
+// dappSystemService.levelProfit(id);
+// }
/**计算是否有人出局分发消息
* @param id
*/
- @RabbitListener(queues = QueueConstants.QUEUE_MEMBER_OUT)
- public void memberOut(Long id) {
- log.info("消费计算是否有人出局:{}", id);
- dappSystemService.memberOut(id);
- }
+// @RabbitListener(queues = QueueConstants.QUEUE_MEMBER_OUT)
+// public void memberOut(Long id) {
+// log.info("消费计算是否有人出局:{}", id);
+// dappSystemService.memberOut(id);
+// }
/**转账拨币
* @param id
@@ -76,18 +76,18 @@
/**转账拨币
* @param id
*/
- @RabbitListener(queues = QueueConstants.QUEUE_BNB_TRANSFER_TEST)
- public void bnbTransferTest(Long id) {
- log.info("消费转账拨币第二步:{}", id);
- dappSystemService.bnbTransferTest(id);
- }
-
- /**代理升级
- * @param id
- */
- @RabbitListener(queues = QueueConstants.QUEUE_BNB_AGENT_UP)
- public void agentUp(Long id) {
- log.info("代理升级:{}", id);
- dappSystemService.agentUp(id);
- }
+// @RabbitListener(queues = QueueConstants.QUEUE_BNB_TRANSFER_TEST)
+// public void bnbTransferTest(Long id) {
+// log.info("消费转账拨币第二步:{}", id);
+// dappSystemService.bnbTransferTest(id);
+// }
+//
+// /**代理升级
+// * @param id
+// */
+// @RabbitListener(queues = QueueConstants.QUEUE_BNB_AGENT_UP)
+// public void agentUp(Long id) {
+// log.info("代理升级:{}", id);
+// dappSystemService.agentUp(id);
+// }
}
--
Gitblit v1.9.1