From 1843c1a34fd6b67d715c688f61555ff6bc6c0fdc Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 19 Jan 2024 17:27:40 +0800 Subject: [PATCH] 余额互转,提现都扣除权益积分 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 32 ++++++++++++++++++++++++++++++++ 1 files changed, 32 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 b44e323..1e7d307 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -90,5 +90,37 @@ public Binding autoLevelUpBind() { return BindingBuilder.bind(autoLevelUpAgentQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT); } + // 订单返利 开始 + @Bean + public DirectExchange agentReturnMoneyExchange() { + return new DirectExchange(RabbitQueueEnum.AGENT_RETURN_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_RETURN_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()); + } } -- Gitblit v1.9.1