1. 案件一键分析 添加异常捕获,防止案件状态一直停留在正在分析中

master
xueqingkun 4 months ago
parent 5997fef737
commit dcedd984dc

@ -58,6 +58,7 @@ public class MroServiceImpl implements MroService {
log.info("开始异步分析案件...."); log.info("开始异步分析案件....");
List<String> caseIdList = new ArrayList<>(); List<String> caseIdList = new ArrayList<>();
for (ModelCase modelCase : modelCases) { for (ModelCase modelCase : modelCases) {
try {
int caseAnalysisStatus = modelCase.getCaseAnalysisStatus(); int caseAnalysisStatus = modelCase.getCaseAnalysisStatus();
if (1 == caseAnalysisStatus) { if (1 == caseAnalysisStatus) {
log.info("案件【{}】正在分析中,跳过", modelCase.getCaseName()); log.info("案件【{}】正在分析中,跳过", modelCase.getCaseName());
@ -65,11 +66,18 @@ public class MroServiceImpl implements MroService {
} }
caseStatusManageService.whenAnalyseCaseStart(modelCase.getId()); caseStatusManageService.whenAnalyseCaseStart(modelCase.getId());
caseIdList.add(modelCase.getId()); caseIdList.add(modelCase.getId());
} catch (Exception e) {
log.error("案件【{}】添加开始标识失败!", modelCase.getCaseName(), e);
}
} }
for (String caseId : caseIdList) { for (String caseId : caseIdList) {
try {
AnalyseCaseDTO analyseCaseDTO = new AnalyseCaseDTO(); AnalyseCaseDTO analyseCaseDTO = new AnalyseCaseDTO();
analyseCaseDTO.setCaseId(caseId); analyseCaseDTO.setCaseId(caseId);
modelService.analyseCaseWrapper(analyseCaseDTO); modelService.analyseCaseWrapper(analyseCaseDTO);
} catch (Exception e) {
log.error("案件【{}】分析失败", caseId, e);
}
} }
log.info("案件分析完成!"); log.info("案件分析完成!");
}).start(); }).start();

Loading…
Cancel
Save