diff --git a/src/main/java/com/supervision/police/service/impl/MroServiceImpl.java b/src/main/java/com/supervision/police/service/impl/MroServiceImpl.java index a80b4e9..b7af5ad 100644 --- a/src/main/java/com/supervision/police/service/impl/MroServiceImpl.java +++ b/src/main/java/com/supervision/police/service/impl/MroServiceImpl.java @@ -58,18 +58,26 @@ public class MroServiceImpl implements MroService { log.info("开始异步分析案件...."); List caseIdList = new ArrayList<>(); for (ModelCase modelCase : modelCases) { - int caseAnalysisStatus = modelCase.getCaseAnalysisStatus(); - if (1 == caseAnalysisStatus) { - log.info("案件【{}】正在分析中,跳过", modelCase.getCaseName()); - continue; + try { + int caseAnalysisStatus = modelCase.getCaseAnalysisStatus(); + if (1 == caseAnalysisStatus) { + log.info("案件【{}】正在分析中,跳过", modelCase.getCaseName()); + continue; + } + caseStatusManageService.whenAnalyseCaseStart(modelCase.getId()); + caseIdList.add(modelCase.getId()); + } catch (Exception e) { + log.error("案件【{}】添加开始标识失败!", modelCase.getCaseName(), e); } - caseStatusManageService.whenAnalyseCaseStart(modelCase.getId()); - caseIdList.add(modelCase.getId()); } for (String caseId : caseIdList) { - AnalyseCaseDTO analyseCaseDTO = new AnalyseCaseDTO(); - analyseCaseDTO.setCaseId(caseId); - modelService.analyseCaseWrapper(analyseCaseDTO); + try { + AnalyseCaseDTO analyseCaseDTO = new AnalyseCaseDTO(); + analyseCaseDTO.setCaseId(caseId); + modelService.analyseCaseWrapper(analyseCaseDTO); + } catch (Exception e) { + log.error("案件【{}】分析失败", caseId, e); + } } log.info("案件分析完成!"); }).start();