From 1d0d712b4f2b489e020cbf23eaf20e386eee1561 Mon Sep 17 00:00:00 2001
From: Hentua <wangdoubleone@gmail.com>
Date: Thu, 15 Jun 2023 01:46:42 +0800
Subject: [PATCH] fix

---
 src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java |  123 +++++++++++++++++++++++++++++++++++++++++
 1 files changed, 123 insertions(+), 0 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
index cdca235..232d796 100644
--- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
+++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -81,5 +81,128 @@
         return BindingBuilder.bind(orderDelayQueueTtl()).to(delayTtlExchange()).with(RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getRoute());
     }
 
+    @Bean
+    public Queue autoLevelUpAgentQueue() {
+        return new Queue(QueueConstants.AGENT_AUTO_LEVEL_UP);
+    }
 
+    @Bean
+    public Binding autoLevelUpBind() {
+        return BindingBuilder.bind(autoLevelUpAgentQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT);
+    }
+
+    @Bean
+    public DirectExchange agentReturnMoneyExchange() {
+        return new DirectExchange(RabbitQueueEnum.AGENT_REUTRN_MONEY.getExchange());
+    }
+
+    @Bean
+    public Queue agentReturnMoneyQueue() {
+        return new Queue(QueueConstants.AGENT_RETURN_MONEY);
+    }
+
+    @Bean
+    public Binding agentReturnMoneyBind() {
+        return BindingBuilder.bind(agentReturnMoneyQueue()).to(agentReturnMoneyExchange()).with(RabbitQueueEnum.AGENT_REUTRN_MONEY.getRoute());
+    }
+
+
+    @Bean
+    public DirectExchange orderReturnMoneyExchange() {
+        return new DirectExchange(RabbitQueueEnum.ORDER_RETURN_MONEY.getExchange());
+    }
+
+    @Bean
+    public Queue orderReturnMoneyQueue() {
+        return new Queue(QueueConstants.ORDER_RETURN_MONEY);
+    }
+
+    @Bean
+    public Binding orderReturnMoneyBind() {
+        return BindingBuilder.bind(orderReturnMoneyQueue()).to(orderReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute());
+    }
+
+    /**
+     * 补贴金额
+     * @return
+     */
+    //补贴金额 start
+    @Bean
+    public DirectExchange perkMoneyExchange() {
+        return new DirectExchange(RabbitQueueEnum.PERK_MONEY.getExchange());
+    }
+
+    @Bean
+    public Queue perkMoneyQueue() {
+        return new Queue(QueueConstants.PERK_MONEY);
+    }
+
+    @Bean
+    public Binding perkMoneyBind() {
+        return BindingBuilder.bind(perkMoneyQueue()).to(perkMoneyExchange()).with(RabbitQueueEnum.PERK_MONEY.getRoute());
+    }
+    //补贴金额 end
+
+    /**
+     * 强制卖出
+     * @return
+     */
+    //强制卖出 start
+    @Bean
+    public DirectExchange forceVoucherSaleExchange() {
+        return new DirectExchange(RabbitQueueEnum.FORCE_VOUCHER_SALE.getExchange());
+    }
+
+    @Bean
+    public Queue forceVoucherSaleQueue() {
+        return new Queue(QueueConstants.FORCE_VOUCHER_SALE);
+    }
+
+    @Bean
+    public Binding forceVoucherSaleBind() {
+        return BindingBuilder.bind(forceVoucherSaleQueue()).to(forceVoucherSaleExchange()).with(RabbitQueueEnum.FORCE_VOUCHER_SALE.getRoute());
+    }
+    //强制卖出 end
+
+
+    /**
+     * 订单分红
+     * @return
+     */
+    //订单分红 start
+    @Bean
+    public DirectExchange orderBonusExchange() {
+        return new DirectExchange(RabbitQueueEnum.ORDER_BONUS.getExchange());
+    }
+
+    @Bean
+    public Queue orderBonusQueue() {
+        return new Queue(QueueConstants.ORDER_BONUS);
+    }
+
+    @Bean
+    public Binding orderBonusBind() {
+        return BindingBuilder.bind(orderBonusQueue()).to(orderBonusExchange()).with(RabbitQueueEnum.ORDER_BONUS.getRoute());
+    }
+    //订单分红 end
+
+
+    /**
+     * 矩阵节点
+     * @return
+     */
+    @Bean
+    public DirectExchange matrixTreeExchange() {
+        return new DirectExchange(RabbitQueueEnum.MATRIX_TREE.getExchange());
+    }
+
+    @Bean
+    public Queue matrixTreeQueue() {
+        return new Queue(QueueConstants.MATRIX_TREE);
+    }
+
+    @Bean
+    public Binding matrixTreeBind() {
+        return BindingBuilder.bind(matrixTreeQueue()).to(matrixTreeExchange()).with(RabbitQueueEnum.MATRIX_TREE.getRoute());
+    }
 }

--
Gitblit v1.9.1