admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

解决 解析异常

Browse Source
This commit is contained in:
ZLI263
2025-09-19 22:02:18 +08:00
parent 7fc35dafa7
commit 3cbcbd5a54
1 changed files with 3 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmTelephoneCorpusServiceImpl.java
View File

@@ -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 非正常状态");