From 8e4921e16114425082f71b0954a8334ff233cc30 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 03 Jan 2025 16:33:06 +0800
Subject: [PATCH] refactor(mall): 修改 ProfitJob 类的注释

---
 src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java |   85 +++++++++++++++++++++++++++++++++---------
 1 files changed, 67 insertions(+), 18 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 96a523b..d16c5f3 100644
--- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
+++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -1,26 +1,16 @@
 package cc.mrbird.febs.common.configure;
 
-import cc.mrbird.febs.rabbit.constants.ExchangeConstants;
-import cc.mrbird.febs.rabbit.constants.QueueConstants;
-import cc.mrbird.febs.rabbit.constants.RouteKeyConstants;
-import org.springframework.amqp.core.Binding;
-import org.springframework.amqp.core.BindingBuilder;
-import org.springframework.amqp.core.DirectExchange;
-import org.springframework.amqp.core.Queue;
+import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum;
+import org.springframework.amqp.core.*;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.config.ConfigurableBeanFactory;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Scope;
-import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 
-/**
- * @author wzy
- * @date 2021-09-25
- **/
 @Configuration
 public class RabbitConfigure {
 
@@ -33,18 +23,77 @@
         return new RabbitTemplate(connectionFactory);
     }
 
+
+
+
+    // === 充值自动过期 延时  start ===
     @Bean
-    public DirectExchange defaultExchange() {
-        return new DirectExchange(ExchangeConstants.EXCHANGE_DEFAULT);
+    public DirectExchange chargeDelayTtlExchange() {
+        return new DirectExchange(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL_TTL.getExchange());
+    }
+    @Bean
+    public Binding chargeDelayTtlBind() {
+        return BindingBuilder.bind(chargeDelayTtlQueue()).to(chargeDelayTtlExchange()).with(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL_TTL.getRoute());
+    }
+    @Bean
+    public Queue chargeDelayTtlQueue() {
+        return QueueBuilder.durable(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL_TTL.getQueue())
+                //到期后转发的交换机
+                .withArgument("x-dead-letter-exchange", RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL.getExchange())
+                //到期后转发的路由键
+                .withArgument("x-dead-letter-routing-key", RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL.getRoute())
+                .build();
+    }
+    @Bean
+    public DirectExchange chargeDelayExchange() {
+        return new DirectExchange(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL.getExchange());
+    }
+    @Bean
+    public Queue chargeDelayQueue() {
+        return new Queue(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL.getQueue());
+    }
+    @Bean
+    public Binding chargeDelayBind() {
+        return BindingBuilder.bind(chargeDelayQueue()).to(chargeDelayExchange()).with(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_FAIL.getRoute());
+    }
+    // === 充值自动过期 延时  end ===
+
+
+
+    // start
+    @Bean
+    public DirectExchange agentReturnExchange() {
+        return new DirectExchange(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE.getExchange());
     }
 
     @Bean
-    public Queue defaultQueue() {
-        return new Queue(QueueConstants.QUEUE_DEFAULT);
+    public Queue agentReturnQueue() {
+        return new Queue(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE.getQueue());
     }
 
     @Bean
-    public Binding defaultBind() {
-        return BindingBuilder.bind(defaultQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT);
+    public Binding agentReturnBind() {
+        return BindingBuilder.bind(agentReturnQueue()).to(agentReturnExchange()).with(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE.getRoute());
     }
+    // end
+
+
+
+    // start
+    @Bean
+    public DirectExchange nodeUpExchange() {
+        return new DirectExchange(RabbitQueueEnum.RUN_VIP_NODE_UP.getExchange());
+    }
+
+    @Bean
+    public Queue nodeUpQueue() {
+        return new Queue(RabbitQueueEnum.RUN_VIP_NODE_UP.getQueue());
+    }
+
+    @Bean
+    public Binding nodeUpBind() {
+        return BindingBuilder.bind(nodeUpQueue()).to(nodeUpExchange()).with(RabbitQueueEnum.RUN_VIP_NODE_UP.getRoute());
+    }
+    // end
+
 }

--
Gitblit v1.9.1