From 4bb9e8497a255cb4e7b7218e07bbd788978ca846 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Fri, 07 Feb 2025 17:22:46 +0800 Subject: [PATCH] feat(pay): 添加支付成功和失败页面并更新回调逻辑 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 50 +++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 49 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..5c4f242 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,55 @@ @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 orderCouponExchange() { + return new DirectExchange(RabbitQueueEnum.ORDER_COUPON.getExchange()); + } + + @Bean + public Queue orderCouponQueue() { + return new Queue(QueueConstants.ORDER_COUPON); + } + + @Bean + public Binding orderCouponBind() { + return BindingBuilder.bind(orderCouponQueue()).to(orderCouponExchange()).with(RabbitQueueEnum.ORDER_COUPON.getRoute()); + } + + + @Bean + public DirectExchange getScoreMsgExchange() { + return new DirectExchange(RabbitQueueEnum.GET_SCORE_MSG.getExchange()); + } + + @Bean + public Queue getScoreMsgQueue() { + return new Queue(QueueConstants.GET_SCORE_MSG); + } + + @Bean + public Binding getScoreMsgBind() { + 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()); } } -- Gitblit v1.9.1