From a43356828c7b02f355fd32ff1adb2b1e1bbe8b5c Mon Sep 17 00:00:00 2001 From: zren25 Date: Fri, 14 Mar 2025 18:05:48 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=A4=B1=E8=B4=A5=E8=A1=A5?= =?UTF-8?q?=E5=81=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/analytic/center/job/CorpusFailJob.java | 44 +++++++++---------- 1 file changed, 20 insertions(+), 24 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java index 9792387..7f07b1b 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/job/CorpusFailJob.java @@ -108,35 +108,31 @@ public class CorpusFailJob { // 发送MQ log.info("send mq {}", ltoMap); tmTelephoneCorpusService.sendMq(tag, JSONObject.toJSONString(ltoMap)); - try { - // 保存报告 - tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder() - .aiAnalysisRequestId(oldAiAnalysisRequestLogs.getAiAnalysisRequestId()) - .corpusType(corpusReportDTO.getAnalysisScene()) - .corpusTime(DateUtil.parseTime(corpusReportDTO.getCorpusTime())) - .userId(corpusReportDTO.getUserId()) - .unionId(corpusReportDTO.getUnionId()) - .reportTitle(resultStrOne.replace("#", "")) - .reportInfo(resultStrTwo) - .isLike(0) - .isDeleted(0) - .version(0) - .createBy("system") - .updateBy("") - .createSqlby("") - .updateSqlby("") - .createTime(new Date()) - .build()); - } catch (Exception e) { - log.info(" 企业语料处理保存报告异常processItem：{} ", e); - } + // 保存报告 + tmCorpusReportService.saveTmCorpusReport(TmCorpusReport.builder() + .aiAnalysisRequestId(oldAiAnalysisRequestLogs.getAiAnalysisRequestId()) + .corpusType(corpusReportDTO.getAnalysisScene()) + .corpusTime(DateUtil.parseTime(corpusReportDTO.getCorpusTime())) + .userId(corpusReportDTO.getUserId()) + .unionId(corpusReportDTO.getUnionId()) + .reportTitle(resultStrOne.replace("#", "")) + .reportInfo(resultStrTwo) + .isLike(0) + .isDeleted(0) + .version(0) + .createBy("system") + .updateBy("") + .createSqlby("") + .updateSqlby("") + .createTime(new Date()) + .build()); } oldAiAnalysisRequestLogs.setDifyResponse(JSON.toJSONString(execDifyFlow)); - aiAnalysisRequestLogsService.save(oldAiAnalysisRequestLogs); + aiAnalysisRequestLogsService.saveAiAnalysisRequestLogs(oldAiAnalysisRequestLogs); aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1); aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("1"); - aiAnalysisErrorsService.save(aiAnalysisErrors); + aiAnalysisErrorsService.saveAiAnalysisErrors(aiAnalysisErrors); } } catch (Exception e) { aiAnalysisErrors.setAiAnalysisErrorHandlingStatus("0");