From e74270e73d5d78673ec2f28b066fc6ae2317aecb Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Tue, 16 Sep 2025 11:48:26 +0800
Subject: [PATCH] =?UTF-8?q?=E9=93=AD=E7=89=8C=E7=9A=84=E7=AC=AC=E4=BA=8C?=
 =?UTF-8?q?=E4=B8=AA=E4=B8=9A=E5=8A=A1=E5=9C=BA=E6=99=AF=E7=94=BB=E5=83=8F?=
 =?UTF-8?q?=EF=BC=8C=20=E4=BC=98=E5=85=88=E6=89=A7=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java    | 6 ++++--
 .../center/service/impl/TmNameplateCorpusServiceImpl.java   | 2 +-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
index ee08c9b..1517465 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
@@ -54,8 +54,10 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt>  {
 			if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_DCC)){
 
 				//总结和客户画像都是这一个:Constant.CHANNEL_DCC
-				log.info(" dcc_mq接收到消息 ， 总结和客户画像业务场景: " + JSON.toJSONString(aicorpusTelephone));
+				log.info("dcc_mq接收到消息 ， 总结和客户画像业务场景: " + JSON.toJSONString(aicorpusTelephone));
 				tmTelephoneCorpusService.runTelephoneCorpusDify(aicorpusTelephone);
+			}else{
+				log.info("dcc_mq接收到消息,不是客户画像语料,分类是： "+aicorpusTelephone.getCategoryCode());
 			}
 			//channel_4in1场景
 			if(Objects.equals(aicorpusTelephone.getCategoryCode(), Constant.CHANNEL_4IN1)){
@@ -65,7 +67,7 @@ public class CorpusDccMqConsumer implements RocketMQListener<MessageExt>  {
 			log.info("corpusDccMqProducer mq 处理完成: {}", aicorpusTelephone.getSourceId());
 			log.info("dcc_mq 处理完成，耗时：{}", System.currentTimeMillis() - startTime);
 		} catch (JsonProcessingException e) {
-			log.info(" dcc mq 处理失败：{}", e.getMessage());
+			log.info("dcc mq 处理失败：{}", e.getMessage());
 		}
 	}
 
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
index 0a9671f..982573b 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
@@ -162,7 +162,7 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
 
 			// 使用多线程并行执行两个业务场景
 			ExecutorService executorService = Executors.newFixedThreadPool(2);
-
+			log.info("第二个业务场景， 优先执行。 ");
 			long startTime2 = System.currentTimeMillis();
 			CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> {
 				//"analysisScene": "分析类型",         // 1、企微会话 2、AI通话录音 3、AI铭牌(客流) 4、AI铭牌(试驾)