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-17 13:54:08 +08:00
parent cc6a7b526c
commit edb2426620
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -107,12 +107,12 @@ public class CorpusFailJob {
ltoMap.put("analysisDetail", resultStrTwo); ltoMap.put("analysisDetail", resultStrTwo);
// 发送MQ // 发送MQ
log.info("corpusFailTask 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()
.aiAnalysisRequestId(oldAiAnalysisRequestLogs.getAiAnalysisRequestId()) .aiAnalysisRequestId(oldAiAnalysisRequestLogs.getAiAnalysisRequestId())
.corpusType(corpusReportDTO.getAnalysisScene()) .corpusType(corpusReportDTO.getAnalysisScene())
.corpusTime(DateUtil.parseTime(corpusReportDTO.getCorpusTime())) .corpusTime(DateUtil.parse(corpusReportDTO.getCorpusTime()))
.userId(corpusReportDTO.getUserId()) .userId(corpusReportDTO.getUserId())
.unionId(corpusReportDTO.getUnionId()) .unionId(corpusReportDTO.getUnionId())
.reportTitle(resultStrOne.replace("#", "")) .reportTitle(resultStrOne.replace("#", ""))
@@ -135,6 +135,7 @@ public class CorpusFailJob {
updateAiAnalysisErrors(aiAnalysisErrors,oldAiAnalysisRequestLogs.getAiAnalysisRequestId()); updateAiAnalysisErrors(aiAnalysisErrors,oldAiAnalysisRequestLogs.getAiAnalysisRequestId());
} }
} catch (Exception e) { } catch (Exception e) {
log.info("语料解析失败补偿异常：{}",e);
aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0"); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0");
aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount()+ 1); aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount()+ 1);
updateAiAnalysisErrors(aiAnalysisErrors,aiAnalysisErrors.getAiAnalysisRequestId()); updateAiAnalysisErrors(aiAnalysisErrors,aiAnalysisErrors.getAiAnalysisRequestId());