From 9b51a95fa8bc9b3a86108c6900e17fc55f8db467 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Mon, 19 May 2025 17:02:07 +0800 Subject: [PATCH] refactor(vip): 优化积分和返佣计算逻辑 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 20 +++++++++++++++++++- 1 files changed, 19 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 af0f67a..89f0eaf 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -171,6 +171,24 @@ } + + + @Bean + public DirectExchange saleLevelUp() { + return new DirectExchange(RabbitQueueEnum.SALE_LEVEL_UP.getExchange()); + } + + @Bean + public Queue saleLevelUpQueue() { + return new Queue(RabbitQueueEnum.SALE_LEVEL_UP.getQueue()); + } + + @Bean + public Binding saleLevelUpBind() { + return BindingBuilder.bind(saleLevelUpQueue()).to(saleLevelUp()).with(RabbitQueueEnum.SALE_LEVEL_UP.getRoute()); + } + + @Bean public DirectExchange activityOrderCheckExchange() { return new DirectExchange(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getExchange()); @@ -178,7 +196,7 @@ @Bean public Queue activityOrderCheckQueue() { - return new Queue(QueueConstants.ACTIVITY_ORDER_ITEM_CHECK); + return new Queue(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getQueue()); } @Bean -- Gitblit v1.9.1