From 4f687e346ad16fc3f0a2346bafd1049706575d1f Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Fri, 19 Sep 2025 20:30:56 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=BD=8D=E4=B8=8D=E6=8E=A8lto?=
 =?UTF-8?q?=E3=80=82=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ai/analytic/center/service/impl/DiFyServiceImpl.java  | 2 +-
 .../center/service/impl/TmTelephoneCorpusServiceImpl.java | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java
index 05cca36..8fdbb30 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DiFyServiceImpl.java
@@ -91,7 +91,7 @@ public class DiFyServiceImpl implements DiFyService{
                     .aiAnalysisRequestType(businessType)
                     .build());
 
-            log.info("给dify平台的数据 ,type: {}, 参数：{}",businessType,map);
+            log.info("给dify平台的数据 ,type: {}, 参数：{}",businessType,diFyReq);
             JSONObject difyResult = diFyFeign.runWorkflows("Bearer "+diFyReq.getFlowId(),map);
             JSONObject data = difyResult.getJSONObject("data");
             log.debug("execDifyFlow dify response aiID:{} , data:{}",aiAnalysisRequestId,data);
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 7fbb4f4..266f67d 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
@@ -121,7 +121,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 			Map<String, Object> inputMap = new HashMap();
 			DiFyReq diFyImageReq = new DiFyReq();
 			diFyImageReq.setUser(ConstantStr.corpus_user);
-			diFyImageReq.setFlowId(telephoneToken);
+
 
 
 			JSONObject jsonObject = JSONObject.parseObject(	aicorpusTelephone.getDisplay());
@@ -170,6 +170,8 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					log.info("铭牌语料可用许可授权数，总结和分类场景={}", semaphore.availablePermits());
 					// 获取许可 - 如果没有可用许可会阻塞等待
 					semaphore.acquire();
+					diFyImageReq.setFlowId(telephoneToken);
+					log.info("铭牌语料telephoneToken：", telephoneToken);
 					JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyImageReq, BusinessTypeEnum.SMART_ASSISTANT.getCode(),
 							JSONObject.toJSONString(corpusReportDTO), aicorpusTelephone.getAiAnalysisRequestId());
 
@@ -242,7 +244,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 				ltoMap.put("communicateDate", communicateDate);
 				ltoMap.put("analysisResult", resultStrOne);
 				ltoMap.put("analysisDetail", resultStrTwo);
-
 				// 发送MQ
 				if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像
 					log.info("send mq 电话语料场景，客户画像需求，  {}",ltoMap);
@@ -251,7 +252,6 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					log.info("send mq 电话语料场景，总结需求，  {}",ltoMap);
 					sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap));
 				}
-
 				try {
 					if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){
 						AiAnalysisErrors aiAnalysisErrors = new AiAnalysisErrors();
@@ -268,7 +268,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 				log.info("dcc语料 parseDfiyResult 非正常状态");
 			}
 		}catch (Exception e){
-			log.error("dcc语料 parseDfiyResult 异常，businessType: {} execDifyFlow: {}", businessType,execDifyFlow, e);
+			log.error("dcc语料 parseDfiyResult 异常，businessType: {} error: {}", businessType, e);
 		}