From 3cbcbd5a5482a2cb684816182eed91552a3c129e Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Fri, 19 Sep 2025 22:02:18 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=20=20=E8=A7=A3=E6=9E=90?=
 =?UTF-8?q?=E5=BC=82=E5=B8=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/TmTelephoneCorpusServiceImpl.java  | 13 +++----------
 1 file changed, 3 insertions(+), 10 deletions(-)

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 a8115d2..807ba67 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
@@ -234,21 +234,14 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 		try {
 			if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
 
-				String text = execDifyFlow.getJSONObject("outputs").getString("text");
-				String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "任务1", "任务2");
-				String resultStrTwo =FlowResultSplitUtil.flowOutputTextSplit(text,  "任务2", null);
-				if (StringUtils.isBlank(resultStrOne) || StringUtils.isBlank(resultStrTwo)){
-					log.info("电话语料解析为空，text:{}", text);
-					return;
-				}
+				JSONObject outputs = execDifyFlow.getJSONObject("outputs");
+
 				String aiAnalysisRequestId = execDifyFlow.getString("aiAnalysisRequestId");
 				Map<String, String> ltoMap = new HashMap();
 				ltoMap.put("analysisRecordId", aiAnalysisRequestId);
 				ltoMap.put("analysisScene", "2");
 				ltoMap.put("recordId",recordId);
 				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);
@@ -267,7 +260,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
 					aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(JSONObject.toJSONString(ltoMap)).build());
 
 				} catch (Exception e) {
-					log.info(" 电话语料处理保存报告异常processItem：{} ", e);
+					log.info(" 电话语料处理保存报告异常processItem：{} ", e.getMessage());
 				}
 			}else {
 				log.info("dcc语料 parseDfiyResult 非正常状态");