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:05:48 +08:00
parent f9b3ac9ec3
commit a43356828c
1 changed files with 20 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -108,35 +108,31 @@ public class CorpusFailJob {
// 发送MQ // 发送MQ
log.info("send mq {}", ltoMap); log.info("send mq {}", ltoMap);
tmTelephoneCorpusService.sendMq(tag, JSONObject.toJSONString(ltoMap)); tmTelephoneCorpusService.sendMq(tag, JSONObject.toJSONString(ltoMap));
try { // 保存报告
// 保存报告 tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder()
tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder() .aiAnalysisRequestId(oldAiAnalysisRequestLogs.getAiAnalysisRequestId())
.aiAnalysisRequestId(oldAiAnalysisRequestLogs.getAiAnalysisRequestId()) .corpusType(corpusReportDTO.getAnalysisScene())
.corpusType(corpusReportDTO.getAnalysisScene()) .corpusTime(DateUtil.parseTime(corpusReportDTO.getCorpusTime()))
.corpusTime(DateUtil.parseTime(corpusReportDTO.getCorpusTime())) .userId(corpusReportDTO.getUserId())
.userId(corpusReportDTO.getUserId()) .unionId(corpusReportDTO.getUnionId())
.unionId(corpusReportDTO.getUnionId()) .reportTitle(resultStrOne.replace("#", ""))
.reportTitle(resultStrOne.replace("#", "")) .reportInfo(resultStrTwo)
.reportInfo(resultStrTwo) .isLike(0)
.isLike(0) .isDeleted(0)
.isDeleted(0) .version(0)
.version(0) .createBy("system")
.createBy("system") .updateBy("")
.updateBy("") .createSqlby("")
.createSqlby("") .updateSqlby("")
.updateSqlby("") .createTime(new Date())
.createTime(new Date()) .build());
.build());
} catch (Exception e) {
log.info(" 企业语料处理保存报告异常processItem：{} ", e);
}
} }
oldAiAnalysisRequestLogs.setDifyResponse(JSON.toJSONString(execDifyFlow)); oldAiAnalysisRequestLogs.setDifyResponse(JSON.toJSONString(execDifyFlow));
aiAnalysisRequestLogsService.save(oldAiAnalysisRequestLogs); aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(oldAiAnalysisRequestLogs);
aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1); aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1);
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1");
aiAnalysisErrorsService.save(aiAnalysisErrors); aiAnalysisErrorsService.saveAiAnalysisErrors(aiAnalysisErrors);
} }
} catch (Exception e) { } catch (Exception e) {
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0");