From fd5d67411cc7afa7aff2b0a53da7c8075a20fe03 Mon Sep 17 00:00:00 2001 From: Administrator <15274802129@163.com> Date: Tue, 13 May 2025 17:13:58 +0800 Subject: [PATCH] fix: 修改商品类型查询逻辑 - 移除了商品类型为1 和非 3 时对现价不为 0 的限制 - 统一了商品类型查询条件,提高了查询的准确性 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 50 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 50 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 3dc6481..89f0eaf 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -154,4 +154,54 @@ return BindingBuilder.bind(getScoreMsgQueue()).to(getScoreMsgExchange()).with(RabbitQueueEnum.GET_SCORE_MSG.getRoute()); } + + @Bean + public DirectExchange vipLevelUp() { + return new DirectExchange(RabbitQueueEnum.VIP_LEVEL_UP.getExchange()); + } + + @Bean + public Queue vipLevelUpQueue() { + return new Queue(QueueConstants.VIP_LEVEL_UP); + } + + @Bean + public Binding vipLevelUpBind() { + return BindingBuilder.bind(vipLevelUpQueue()).to(vipLevelUp()).with(RabbitQueueEnum.VIP_LEVEL_UP.getRoute()); + } + + + + + @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()); + } + + @Bean + public Queue activityOrderCheckQueue() { + return new Queue(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getQueue()); + } + + @Bean + public Binding activityOrderCheckBind() { + return BindingBuilder.bind(activityOrderCheckQueue()).to(activityOrderCheckExchange()).with(RabbitQueueEnum.ACTIVITY_ORDER_ITEM_CHECK.getRoute()); + } + } -- Gitblit v1.9.1