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:
zren25
2025-03-14 18:09:50 +08:00
parent a43356828c
commit 696ee93f61
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java
View File

@@ -80,17 +80,17 @@ public class CorpusFailJob {
CorpusReportDTO corpusReportDTO = JSONObject.parseObject(oldAiAnalysisRequestLogs.getBusinessRequest(), CorpusReportDTO.class); CorpusReportDTO corpusReportDTO = JSONObject.parseObject(oldAiAnalysisRequestLogs.getBusinessRequest(), CorpusReportDTO.class);
JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyReq); JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyReq);
log.info("runDify execDifyFlow {}",execDifyFlow); log.info(" corpusFailTask runDify execDifyFlow {}",execDifyFlow);
if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){ if(null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")){
String text = execDifyFlow.getJSONObject("outputs").getString("text"); String text = execDifyFlow.getJSONObject("outputs").getString("text");
String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "任务1", "任务2"); String resultStrOne = FlowResultSplitUtil.flowOutputTextSplit(text, "任务1", "任务2");
String resultStrTwo = FlowResultSplitUtil.flowOutputTextSplit(text, "任务2", null); String resultStrTwo = FlowResultSplitUtil.flowOutputTextSplit(text, "任务2", null);
if (StringUtils.isBlank(resultStrOne) || StringUtils.isBlank(resultStrTwo)) { if (StringUtils.isBlank(resultStrOne) || StringUtils.isBlank(resultStrTwo)) {
log.info("企微语料解析为空，text:{}", text); log.info(" corpusFailTask 企微语料解析为空，text:{}", text);
return; return;
} }
Map<String, String> ltoMap = new HashMap<>(); Map<String, String> ltoMap = new HashMap<>();
ltoMap.put("analysisRecordId", execDifyFlow.getString("aiAnalysisRequestId")); ltoMap.put("analysisRecordId", oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
ltoMap.put("analysisScene", corpusReportDTO.getAnalysisScene() + ""); ltoMap.put("analysisScene", corpusReportDTO.getAnalysisScene() + "");
String tag = ""; String tag = "";
if (corpusReportDTO.getAnalysisScene() == 1) { //企微 if (corpusReportDTO.getAnalysisScene() == 1) { //企微
@@ -106,7 +106,7 @@ public class CorpusFailJob {
ltoMap.put("analysisResult", resultStrOne.replace("#", "")); ltoMap.put("analysisResult", resultStrOne.replace("#", ""));
ltoMap.put("analysisDetail", resultStrTwo); ltoMap.put("analysisDetail", resultStrTwo);
// 发送MQ // 发送MQ
log.info("send mq {}", ltoMap); log.info("corpusFailTask send mq {}", ltoMap);
tmTelephoneCorpusService.sendMq(tag, JSONObject.toJSONString(ltoMap)); tmTelephoneCorpusService.sendMq(tag, JSONObject.toJSONString(ltoMap));
// 保存报告 // 保存报告
tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder() tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder()
@@ -136,7 +136,7 @@ public class CorpusFailJob {
} }
} catch (Exception e) { } catch (Exception e) {
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0");
aiAnalysisErrorsService.save(aiAnalysisErrors); aiAnalysisErrorsService.saveAiAnalysisErrors(aiAnalysisErrors);
} }
}); });