From 90e33a3a663743b8c6ee47edd64060dc6b0cd445 Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Fri, 12 Sep 2025 15:28:31 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9sonar=E6=89=AB=E5=87=BA?=
 =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../center/mq/CorpusProcessKafkaProducer.java   |  2 +-
 .../impl/TmTelephoneCorpusServiceImpl.java      | 17 +----------------
 2 files changed, 2 insertions(+), 17 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java
index 2fff9dd..1cd7808 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java
@@ -76,7 +76,7 @@ public class CorpusProcessKafkaProducer {
 							JSONObject jsonObject = JSONObject.parseObject(	aicorpusTelephone.getDisplay());
 
 							Long audioDuration = jsonObject.getLong("audio_duration"); // 毫秒
-							if(audioDuration/1000 <=10){
+							if(audioDuration <= 10000){//时间单位是 毫秒
 								log.info("电话语料时长小于10秒，不进行dify处理");
 								return;
 							}
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
index a2eebe9..91e7bbd 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
@@ -157,12 +157,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 
 			// 使用多线程并行执行两个业务场景
 			ExecutorService executorService = Executors.newFixedThreadPool(2);
-			//第一个业务场景  开始：    总结和分类业务场景
-//			JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
-//					JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
-//			log.info("runDify execDifyFlow 返回 ,总结场景 ： {}",execDifyFlow);
-//			parseDfiyResult(execDifyFlow, aicorpusTelephone.getSourceId(), formattedDateStartTime, aicorpusTelephone.getAiAnalysisRequestId(),
-//					BusinessTypeEnum.SMART_ASSISTANT.getCode());
+
 			long startTime = System.currentTimeMillis();
 			CompletableFuture<Void> summaryFuture = CompletableFuture.runAsync(() -> {
 				JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
@@ -176,16 +171,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 			log.info("第一个业务场景（总结和分类）执行时间: {} ms", (endTime - startTime));
              //第一个业务场景，    结束
 
-			//TODO 是否传给LOT  穿行改成并行
-			//第二个业务场景：  用户画像业务场景。  开始
-//			diFyImageReq.setFlowId(telephoneTokenPortrait);
-//			JSONObject execDifyFlowForPortrait = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode(),
-//					JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());  //调用dify平台。
-//			log.info("runDify execDifyFlow 返回 ,客户画像场景： {}",execDifyFlowForPortrait);
-//			parseDfiyResult(execDifyFlowForPortrait, aicorpusTelephone.getSourceId(), formattedDateStartTime,
-//					aicorpusTelephone.getAiAnalysisRequestId(), BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode()); // 发送mq消息。
-
-
 			long startTime2 = System.currentTimeMillis();
 			CompletableFuture<Void> portraitFuture = CompletableFuture.runAsync(() -> {