From ec5c9eaddfac58ec5dde1fb67c1c5ac8b3073043 Mon Sep 17 00:00:00 2001 From: zren25 Date: Fri, 13 Jun 2025 10:45:40 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/volvo/ai/analytic/center/job/CorpusFailJob.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 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 8282711..2088e7d 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 @@ -287,12 +287,12 @@ public class CorpusFailJob { .collect(Collectors.toMap( AiAnalysisRequestLogs::getAiAnalysisRequestId,logs -> logs )); aiAnalysisErrorsListlist.forEach(aiAnalysisErrors -> { + try { AiAnalysisRequestLogs oldAiAnalysisRequestLogs = requestLogsMap.get(aiAnalysisErrors.getAiAnalysisRequestId()); if (null != oldAiAnalysisRequestLogs && StringUtils.isBlank(oldAiAnalysisRequestLogs.getBusinessResponse())) { DiFyReq diFyReq = JSONObject.parseObject(oldAiAnalysisRequestLogs.getDifyRequest(), DiFyReq.class); - CorpusReportDTO corpusReportDTO = JSONObject.parseObject(oldAiAnalysisRequestLogs.getBusinessRequest(), CorpusReportDTO.class); - + log.info(" corpusFailTask runDify req {}", JSON.toJSONString(diFyReq)); JSONObject execDifyFlow = diFyService.executeDifyFlow(diFyReq); log.info(" corpusFailTask runDify execDifyFlow {}", execDifyFlow); if (null != execDifyFlow && execDifyFlow.get("status").equals("succeeded")) { @@ -311,6 +311,9 @@ public class CorpusFailJob { aiAnalysisErrors.setRetryCount(aiAnalysisErrors.getRetryCount() + 1); updateAiAnalysisErrors(aiAnalysisErrors, oldAiAnalysisRequestLogs.getAiAnalysisRequestId()); } + } catch (Exception e) { + log.info("画像重试异常：{}，{}",aiAnalysisErrors.getAiAnalysisRequestId() , e); + } }); }