From c619972c50577bb699be6ee099b5e2741882fabb Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Wed, 27 Dec 2023 16:15:59 +0800 Subject: [PATCH] 直推奖励,冻结的用户,则直推奖励销毁,用户未冻结才能领取成功 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 18 +++++++++++++++++- 1 files changed, 17 insertions(+), 1 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 9f477f0..5871658 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -119,7 +119,23 @@ @Bean public Binding orderReturnMoneyBind() { - return BindingBuilder.bind(agentReturnMoneyQueue()).to(agentReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute()); + return BindingBuilder.bind(orderReturnMoneyQueue()).to(orderReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute()); + } + + + @Bean + public DirectExchange syAppOrderPayDoneExchange() { + return new DirectExchange(RabbitQueueEnum.SY_APP_ORDER_PAY_DONE.getExchange()); + } + + @Bean + public Queue syAppOrderPayDoneQueue() { + return new Queue(RabbitQueueEnum.SY_APP_ORDER_PAY_DONE.getQueue()); + } + + @Bean + public Binding syAppOrderPayDoneBind() { + return BindingBuilder.bind(syAppOrderPayDoneQueue()).to(syAppOrderPayDoneExchange()).with(RabbitQueueEnum.SY_APP_ORDER_PAY_DONE.getRoute()); } } -- Gitblit v1.9.1