From 05c40a68b5664c5ed41dbaa57ba30f0c73757b26 Mon Sep 17 00:00:00 2001 From: Hentua <wangdoubleone@gmail.com> Date: Tue, 25 Apr 2023 11:10:48 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 63 +++++++++++++++++++++++++++++++ 1 files changed, 63 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 50797b6..e1f7784 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -122,4 +122,67 @@ 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 } -- Gitblit v1.9.1