From efbff9ca8ef6bdf2966f80fe05984ed45b1b8519 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 29 Nov 2022 16:29:41 +0800
Subject: [PATCH] 20221124
---
src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java | 38 ++++++++++++++++++++++++++++++++++++++
1 files changed, 38 insertions(+), 0 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
index cb11d30..a8a326e 100644
--- a/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
+++ b/src/main/java/cc/mrbird/febs/rabbit/RabbitConfiguration.java
@@ -101,4 +101,42 @@
return BindingBuilder.bind(feeDistributeQueue()).to(feeDistributeExchange()).with(QueueEnum.DISTRIB_PROFIT.getRoute());
}
// === 手续费分发 end ===
+
+
+
+ // === 层级奖励分发 start ===
+ @Bean
+ public DirectExchange levelProfitExchange() {
+ return new DirectExchange(QueueEnum.LEVEL_PROFIT.getExchange());
+ }
+
+ @Bean
+ public Queue levelProfitQueue() {
+ return new Queue(QueueEnum.LEVEL_PROFIT.getQueue());
+ }
+
+ @Bean
+ public Binding levelProfitBind() {
+ return BindingBuilder.bind(levelProfitQueue()).to(levelProfitExchange()).with(QueueEnum.LEVEL_PROFIT.getRoute());
+ }
+ // === 层级奖励分发 end ===
+
+
+
+ // === 计算是否有人出局 start ===
+ @Bean
+ public DirectExchange memberOutExchange() {
+ return new DirectExchange(QueueEnum.MEMBER_OUT.getExchange());
+ }
+
+ @Bean
+ public Queue memberOutQueue() {
+ return new Queue(QueueEnum.MEMBER_OUT.getQueue());
+ }
+
+ @Bean
+ public Binding memberOutBind() {
+ return BindingBuilder.bind(memberOutQueue()).to(memberOutExchange()).with(QueueEnum.MEMBER_OUT.getRoute());
+ }
+ // === 计算是否有人出局 end ===
}
--
Gitblit v1.9.1