From b9d12b8542353be329c11f47508b62064077dc7c Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Tue, 16 Sep 2025 21:51:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=BD=8D=E7=94=BB=E5=83=8F=E6=88=AA?=
 =?UTF-8?q?=E5=8F=96=E7=B1=BB=E5=9E=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../volvo/ai/analytic/center/job/QiWeiCorpusJob.java |  1 -
 .../service/impl/TmNameplateCorpusServiceImpl.java   | 12 +++++++++++-
 2 files changed, 11 insertions(+), 2 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java
index cfa392f..adf74ae 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/QiWeiCorpusJob.java
@@ -84,7 +84,6 @@ public class QiWeiCorpusJob {
             List<AicorpusTelephoneDTO>  corpusDtoList = tmTelephoneCorpusMapper.queryTelephoneCorpusBySourceIds( Arrays.asList(param.split(",")));
             corpusDtoList.stream().forEach(item-> {
                         tmTelephoneCorpusService.runTelephoneCorpusDify(item);
-                        corpusPortraitService.portraitDcc(item);
                     });
         } catch (Exception e) {
             log.error(PROCESS_MESSAGE_TASK_ERROR,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 7beca2a..5274343 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
@@ -240,12 +240,22 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
 			String aiAnalysisRequestId = analysisResp.getString("aiAnalysisRequestId");
 			String difyResponse = analysisResp.getString("difyResponse");
 			String customerFlowId = analysisResp.getString("customerFlowId");
-			String businessType = analysisResp.getString("businessType");
+
+			String text = analysisResp.getString("outputs");
+			JSONObject outputs = JSONObject.parseObject(text);
+			String businessId = outputs.getString("businessId");
+			String businessType = outputs.getString("businessType");
+
+			if (aiAnalysisRequestId==null){
+				aiAnalysisRequestId = outputs.getString("aiAnalysisRequestId");
+			}
+
 			log.info("aiAnalysisRequestId is  : ",analysisResp.getString("aiAnalysisRequestId"));
 			log.info("businessType is  : ", businessType);
 
 			if (aiAnalysisRequestId.indexOf(BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode())>=0){
 				businessType=BusinessTypeEnum.CORPUS_PORTRAIT_NAMEPLATE.getCode();
+				customerFlowId = businessId;
 				log.info("客户画像场景 businessType is  : ", businessType);
 			}else {
 				businessType = BusinessTypeEnum.SMART_ASSISTANT_NAMEPLATE.getCode();