From 10ad2e710d2bd52aac31d5d63a7bb6beae76b6a8 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Tue, 07 Nov 2023 14:35:32 +0800
Subject: [PATCH] 用户列表增加搜索条件

---
 src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java |  101 +++++++++++++++-----------------------------------
 1 files changed, 30 insertions(+), 71 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 1e7d307..0822743 100644
--- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
+++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -31,96 +31,55 @@
         return new RabbitTemplate(connectionFactory);
     }
 
+    // === 添加机器人  start ===
     @Bean
-    public DirectExchange defaultExchange() {
-        return new DirectExchange(ExchangeConstants.EXCHANGE_DEFAULT);
+    public DirectExchange imAddRobotExchange() {
+        return new DirectExchange(RabbitQueueEnum.IM_REDBAG_GET_ADD_ROBOT.getExchange());
     }
 
     @Bean
-    public Queue defaultQueue() {
-        return new Queue(QueueConstants.QUEUE_DEFAULT);
+    public Queue imAddRobotQueue() {
+        return new Queue(RabbitQueueEnum.IM_REDBAG_GET_ADD_ROBOT.getQueue());
     }
 
     @Bean
-    public Binding defaultBind() {
-        return BindingBuilder.bind(defaultQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT);
+    public Binding imAddRobotBind() {
+        return BindingBuilder.bind(imAddRobotQueue()).to(imAddRobotExchange()).with(RabbitQueueEnum.IM_REDBAG_GET_ADD_ROBOT.getRoute());
+    }
+    // === 添加机器人  end ===
+
+    // === 自动发送  start ===
+    @Bean
+    public DirectExchange imAutoSendExchange() {
+        return new DirectExchange(RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getExchange());
     }
 
     @Bean
-    public DirectExchange delayTtlExchange() {
-        return new DirectExchange(RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getExchange());
+    public Queue imAutoSendQueue() {
+        return new Queue(RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getQueue());
     }
 
     @Bean
-    public DirectExchange orderDelayExchange() {
-        return new DirectExchange(RabbitQueueEnum.ORDER_CANCEL_DELAY.getExchange());
+    public Binding imAutoSendBind() {
+        return BindingBuilder.bind(imAutoSendQueue()).to(imAutoSendExchange()).with(RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getRoute());
+    }
+    // === 自动发送  end ===
+
+    // === 自动发送  start ===
+    @Bean
+    public DirectExchange imOverdueSendExchange() {
+        return new DirectExchange(RabbitQueueEnum.IM_REDBAG_OVERDUE.getExchange());
     }
 
     @Bean
-    public Queue orderDelayQueue() {
-        return new Queue(RabbitQueueEnum.ORDER_CANCEL_DELAY.getQueue());
+    public Queue imOverdueSendQueue() {
+        return new Queue(RabbitQueueEnum.IM_REDBAG_OVERDUE.getQueue());
     }
 
     @Bean
-    public Queue orderDelayQueueTtl() {
-        return QueueBuilder.durable(RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getQueue())
-                //到期后转发的交换机
-                .withArgument("x-dead-letter-exchange", RabbitQueueEnum.ORDER_CANCEL_DELAY.getExchange())
-                //到期后转发的路由键
-                .withArgument("x-dead-letter-routing-key", RabbitQueueEnum.ORDER_CANCEL_DELAY.getRoute())
-                .build();
+    public Binding imOverdueSendBind() {
+        return BindingBuilder.bind(imOverdueSendQueue()).to(imOverdueSendExchange()).with(RabbitQueueEnum.IM_REDBAG_OVERDUE.getRoute());
     }
-
-    @Bean
-    public Binding orderDelayBind() {
-        return BindingBuilder.bind(orderDelayQueue()).to(orderDelayExchange()).with(RabbitQueueEnum.ORDER_CANCEL_DELAY.getRoute());
-    }
-
-    @Bean
-    public Binding orderDelayBindTtl() {
-        return BindingBuilder.bind(orderDelayQueueTtl()).to(delayTtlExchange()).with(RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getRoute());
-    }
-
-    @Bean
-    public Queue autoLevelUpAgentQueue() {
-        return new Queue(QueueConstants.AGENT_AUTO_LEVEL_UP);
-    }
-
-    @Bean
-    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());
-    }
+    // === 自动发送  end ===
 
 }

--
Gitblit v1.9.1