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:12:10 +08:00
parent 3cbcbd5a54
commit 7777da8d0e
1 changed files with 8 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -107,7 +107,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
public void saveTelephoneCorpus(TmTelephoneCorpus tmTelephoneCorpus) { public void saveTelephoneCorpus(TmTelephoneCorpus tmTelephoneCorpus) {
this.save(tmTelephoneCorpus); this.save(tmTelephoneCorpus);
} }
private String communicateDateStr = "communicateDate";
@Override @Override
public void runTelephoneCorpusDify(AicorpusTelephoneDTO aicorpusTelephone) { public void runTelephoneCorpusDify(AicorpusTelephoneDTO aicorpusTelephone) {
@@ -201,7 +201,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
semaphore.acquire(); semaphore.acquire();
// 创建新的DiFyReq对象以避免线程安全问题 // 创建新的DiFyReq对象以避免线程安全问题
inputMap.put("businessId",aicorpusTelephone.getSourceId()); inputMap.put("businessId",aicorpusTelephone.getSourceId());
inputMap.put("communicateDate",aicorpusTelephone.getTranscribeTime()); inputMap.put(communicateDateStr,aicorpusTelephone.getTranscribeTime());
inputMap.put("analysisScene", "2"); inputMap.put("analysisScene", "2");
diFyImageReq.setInputs(inputMap); diFyImageReq.setInputs(inputMap);
@@ -234,21 +234,15 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
try { try {
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){ if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
JSONObject outputs = execDifyFlow.getJSONObject("outputs"); String outputs = execDifyFlow.getString("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);
// 发送MQ // 发送MQ
if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像 if (BusinessTypeEnum.CORPUS_PORTRAIT_DCC.getCode().equals(businessType)){//DCC 客户画像
log.info("send mq 电话语料场景，客户画像需求， {}",ltoMap); log.info("send mq 电话语料场景，客户画像需求， {}",outputs);
sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(ltoMap)); sendMq( CategoryEnum.PORTRAIT_ALLIN.getCode(), JSONObject.toJSONString(outputs));
}else{ // dcc 总结 }else{ // dcc 总结
log.info("send mq 电话语料场景，总结需求， {}",ltoMap); log.info("send mq 电话语料场景，总结需求， {}",outputs);
sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(ltoMap)); sendMq( CategoryEnum.PHONE_VOICE.getCode(), JSONObject.toJSONString(outputs));
} }
try { try {
if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){ if(StringUtils.isNotEmpty(aiAnalysisRequestIdDB)){
@@ -257,7 +251,7 @@ public class TmTelephoneCorpusServiceImpl extends ServiceImpl<TmTelephoneCorpusM
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors); aiAnalysisErrorsService.updateAiAnalysisErrors(aiAnalysisErrors);
} }
aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(JSONObject.toJSONString(ltoMap)).build()); aiAnalysisRequestLogsService.saveOrUpdateAiAnalysisRequestLogs(AiAnalysisRequestLogs.builder().aiAnalysisRequestId(execDifyFlow.getString("aiAnalysisRequestId")).businessResponse(outputs).build());
} catch (Exception e) { } catch (Exception e) {
log.info(" 电话语料处理保存报告异常processItem：{} ", e.getMessage()); log.info(" 电话语料处理保存报告异常processItem：{} ", e.getMessage());