From b83f56cbce86714acb66145d637c9d3f2beb94bf Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 19 Mar 2026 16:18:30 +0800
Subject: [PATCH] fix(ai): 修复阿里LLM策略服务中的返回数据映射问题

---
 src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java |   91 ++++-----------------------------------------
 1 files changed, 8 insertions(+), 83 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 50797b6..4f41ecf 100644
--- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
+++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -4,6 +4,7 @@
 import cc.mrbird.febs.rabbit.constants.QueueConstants;
 import cc.mrbird.febs.rabbit.constants.RouteKeyConstants;
 import cc.mrbird.febs.rabbit.enumerates.RabbitQueueEnum;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.*;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
@@ -19,6 +20,7 @@
  * @author wzy
  * @date 2021-09-25
  **/
+@Slf4j
 @Configuration
 public class RabbitConfigure {
 
@@ -32,94 +34,17 @@
     }
 
     @Bean
-    public DirectExchange defaultExchange() {
-        return new DirectExchange(ExchangeConstants.EXCHANGE_DEFAULT);
+    public DirectExchange pcCompanyAddExchange() {
+        return new DirectExchange(RabbitQueueEnum.PC_COMPANY_ADD_ALI.getExchange());
     }
 
     @Bean
-    public Queue defaultQueue() {
-        return new Queue(QueueConstants.QUEUE_DEFAULT);
+    public Queue pcCompanyAddQueue() {
+        return new Queue(RabbitQueueEnum.PC_COMPANY_ADD_ALI.getQueue());
     }
 
     @Bean
-    public Binding defaultBind() {
-        return BindingBuilder.bind(defaultQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT);
+    public Binding pcCompanyAddBind() {
+        return BindingBuilder.bind(pcCompanyAddQueue()).to(pcCompanyAddExchange()).with(RabbitQueueEnum.PC_COMPANY_ADD_ALI.getRoute());
     }
-
-    @Bean
-    public DirectExchange delayTtlExchange() {
-        return new DirectExchange(RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getExchange());
-    }
-
-    @Bean
-    public DirectExchange orderDelayExchange() {
-        return new DirectExchange(RabbitQueueEnum.ORDER_CANCEL_DELAY.getExchange());
-    }
-
-    @Bean
-    public Queue orderDelayQueue() {
-        return new Queue(RabbitQueueEnum.ORDER_CANCEL_DELAY.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();
-    }
-
-    @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_REUTRN_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_REUTRN_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());
-    }
-
 }

--
Gitblit v1.9.1