From bfa4d0fc1ce8d297fb2bea1c467ec335def8fa89 Mon Sep 17 00:00:00 2001
From: Hentua <wangdoubleone@gmail.com>
Date: Thu, 15 Jun 2023 01:26:41 +0800
Subject: [PATCH] 团队业绩
---
src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 62 +++++++++++++++++++++++++++++++
1 files changed, 62 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 8acc19d..232d796 100644
--- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
+++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -143,4 +143,66 @@
}
//补贴金额 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