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); + } }); }