From fb6c882e19ea2d5a7d6ee6bbb7664bdb8b2f2503 Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Sat, 27 Aug 2022 01:21:11 +0800
Subject: [PATCH] add sdm withdraw fee
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 5 +++++
src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java | 9 +++++++++
src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java | 2 ++
src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java | 1 +
src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java | 3 ++-
src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java | 17 +++++++++++++++++
6 files changed, 36 insertions(+), 1 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java b/src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java
index 33731b8..cec8d5b 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/DappSystemService.java
@@ -55,4 +55,6 @@
BigDecimal newestPrice();
boolean hasProfit(String address);
+
+ void sdmWithdrawFee(String data);
}
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
index 8cfe42b..6c361d4 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -730,4 +730,9 @@
return true;
}
+
+ @Override
+ public void sdmWithdrawFee(String data) {
+
+ }
}
diff --git a/src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java b/src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java
index 63e3b2b..0dbeabc 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/QueueConstants.java
@@ -10,4 +10,5 @@
public static final String DISTRIB_PROFIT = "queue_tfc_distrib_profit";
public static final String USER_BUY_REWARD = "queue_tfc_user_buy_reward";
public static final String NFT_BOX = "queue_tfc_nft_box";
+ public static final String WITHDRAW_FEE = "queue_withdraw_fee";
}
diff --git a/src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java b/src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java
index b5a3827..234a80a 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/QueueEnum.java
@@ -9,7 +9,8 @@
ONLINE_TRANSFER("exchange_online_transfer", "route_key_online_transfer", "queue_tfc_online_transfer"),
DISTRIB_PROFIT("exchange_distrib_profit", "route_key_distrib_profit", "queue_tfc_distrib_profit"),
USER_BUY_REWARD("exchange_user_buy_reward", "route_key_user_buy_reward", "queue_tfc_user_buy_reward"),
- NFT_BOX("exchange_nft_box", "route_key_nft_box", "queue_tfc_nft_box");
+ NFT_BOX("exchange_nft_box", "route_key_nft_box", "queue_tfc_nft_box"),
+ WITHDRAW_FEE("exchange_withdraw_fee", "route_key_withdraw_fee", "queue_withdraw_fee");
private String exchange;
diff --git a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
index 0e6c190..c3c282d 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
@@ -93,4 +93,21 @@
return BindingBuilder.bind(nftBoxQueue()).to(nftBoxExchange()).with(QueueEnum.NFT_BOX.getRoute());
}
// === nft卡牌盲盒 end ===
+
+ // === 提现手续费 start ===
+ @Bean
+ public DirectExchange withdrawFeeExchange() {
+ return new DirectExchange(QueueEnum.WITHDRAW_FEE.getExchange());
+ }
+
+ @Bean
+ public Queue withdrawFeeQueue() {
+ return new Queue(QueueEnum.WITHDRAW_FEE.getQueue());
+ }
+
+ @Bean
+ public Binding withdrawFeeBind() {
+ return BindingBuilder.bind(withdrawFeeQueue()).to(withdrawFeeExchange()).with(QueueEnum.WITHDRAW_FEE.getRoute());
+ }
+ // === 提现手续费 end ===
}
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 3c9172b..b8f984d 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -45,4 +45,13 @@
log.info("收到nft盲盒消息:{}", id);
dappSystemService.boxCnt(Long.parseLong(id));
}
+
+ /**
+ * 生产者在影子生态(矩阵)项目
+ * @param data
+ */
+ @RabbitListener(queues = QueueConstants.WITHDRAW_FEE)
+ public void withdrawFeeMsg(String data) {
+ log.info("收到影子生态手续费消息:{}", data);
+ }
}
--
Gitblit v1.9.1