From 301e261b415861cf64663e4ff57384230874749a Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Thu, 3 Apr 2025 15:11:53 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../analytic/center/mq/IntelligentCustomerMqConsumer.java   | 6 +++---
 .../center/service/impl/IntelligentCustomerServiceImpl.java | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java
index 72d7ea8..3b1e46b 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/IntelligentCustomerMqConsumer.java
@@ -60,14 +60,14 @@ public class IntelligentCustomerMqConsumer implements RocketMQListener<MessageEx
 			intelligentCustomerService.fourInOneMqService(fourRequestDTO);
 			log.info("FourInOneRequestDTO处理完成，耗时：{}", System.currentTimeMillis() - startTime);
 		} catch (JsonProcessingException e) {
-			log.info(" dcc mq 处理失败：{}", e.getMessage());
+			log.info("intelligentCustomerMqConsumer mq 处理失败：{}", e.getMessage());
 		}
 	}
 
 
 
-	@PostMapping("ntelligentCustomerMqConsumer")
-	public void onMessage(@RequestBody String message) {
+	@PostMapping("intelligentCustomerMqConsumer")
+	public void intelligentCustomerMqConsumer(@RequestBody String message) {
 		long startTime = System.currentTimeMillis();
 		try {
 			log.info("intelligentCustomerMqConsumer 当前线程: {}, 线程ID: {}", Thread.currentThread().getName(), Thread.currentThread().getId());
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java
index 4c7c4f8..9ef5c48 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/IntelligentCustomerServiceImpl.java
@@ -56,7 +56,7 @@ public class IntelligentCustomerServiceImpl implements IntelligentCustomerServic
 	@Resource
 	private RocketMQTemplate rocketMqTemplate;
 
-	@Value("${rocketmq.producer.corpus.topic}")
+	@Value("${rocketmq.producer.intelligentCustomer.topic}")
 	private String topic;
 	@Value("${dify.intelligentCustomer.fourInOneToken}")
 	private String fourInOneToken;