From 424ad35dcd1fafb51a0ba77523b11e6871f2858c Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 06 Jun 2024 11:36:25 +0800
Subject: [PATCH] 购买节点
---
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | 34 +++++++++-------------------------
1 files changed, 9 insertions(+), 25 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 8c1ff81..95bd8f7 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -22,30 +22,6 @@
@Autowired
private DappSystemService dappSystemService;
-// @RabbitListener(queues = QueueConstants.ONLINE_TRANSFER)
-// public void onlineTransfer(String batchNo) {
-// log.info("收到链上转账消息:{}", batchNo);
-// dappSystemService.onlineTransfer(batchNo);
-// }
-//
-// @RabbitListener(queues = QueueConstants.DISTRIB_PROFIT)
-// public void distrbProfit(String id) {
-// log.info("收到滑点分配消息:{}", id);
-// dappSystemService.tradeNftProfitDistribute(Long.parseLong(id));
-// }
-//
-// @RabbitListener(queues = QueueConstants.USER_BUY_REWARD)
-// public void userBuyReward(String id) {
-// log.info("收到用户购买奖励消息:{}", id);
-// dappSystemService.userBuyReward(Long.parseLong(id));
-// }
-//
-// @RabbitListener(queues = QueueConstants.NFT_BOX)
-// public void nftBox(String id) {
-// log.info("收到nft盲盒消息:{}", id);
-// dappSystemService.boxCnt(Long.parseLong(id));
-// }
-
@RabbitListener(queues = QueueConstants.ACHIEVE_TREE)
public void achieveTree(String id) {
log.info("收到业绩树消息");
@@ -58,6 +34,14 @@
*/
@RabbitListener(queues = QueueConstants.TFC_NEW_PRICE)
public void tfcNewPrice(String data) {
- dappSystemService.tfcNewPrice(data);
+// dappSystemService.tfcNewPrice(data);
+ }
+
+ /**
+ * @param data
+ */
+ @RabbitListener(queues = QueueConstants.DISTRIB_PROFIT)
+ public void feeDistribute(String data) {
+ dappSystemService.feeDistribute(data);
}
}
--
Gitblit v1.9.1