| | |
| | | |
| | | if (CJRecordFromTaskLists.size() > 0) { |
| | | log.info("【双重预防】排查任务记录CJ:数据处理..."); |
| | | log.info("【双重预防】排查任务记录CJ:数据处理开始taskIds..." + JSONObject.toJSONString(taskIds)); |
| | | |
| | | |
| | | //设置原始数据状态 |
| | | int taskUpdateResult = preventRiskDangerCheckLogService.updateTaskReportStatusByList(taskIds); |
| | | if (taskUpdateResult < taskIds.size()) { |
| | | log.error("【双重预防】排查任务记录CJ:数据处理开始taskIds...排查任务记录原始数据更新失败, 取消操作"); |
| | | throw new AusinessException(E.ADD_FAIL.getCode(), "排查任务记录原始数据更新失败, 取消操作"); |
| | | } |
| | | |
| | | log.info("【双重预防】排查任务记录CJ:数据处理开始CJRecordFromTaskLists..." + JSONObject.toJSONString(CJRecordFromTaskLists)); |
| | | int result = CJTaskRecordService.insertRecordList(CJRecordFromTaskLists); |
| | | if (result < CJRecordFromTaskLists.size()) { |
| | | log.error("【双重预防】排查任务记录CJ:数据处理开始taskIds...排查任务记录插入失败, 取消操作"); |
| | |
| | | CJDangerInfo.setDataSource((byte) 1); |
| | | CJDangerInfo.setDangerName(hiddenDanger.getDangerName()); |
| | | CJDangerInfo.setDangerLevel(hiddenDanger.getDangerLevel()); |
| | | CJDangerInfo.setDangerSrc(dangerManage.getDangerSrc().toString()); |
| | | if (ObjectUtils.isNotEmpty(hiddenDanger.getDangerSrc())){ |
| | | CJDangerInfo.setDangerSrc(dangerManage.getDangerSrc().toString()); |
| | | }else { |
| | | CJDangerInfo.setDangerSrc("1"); |
| | | } |
| | | |
| | | if (hiddenDanger.getRectifyType().equals("1")) { |
| | | CJDangerInfo.setDangerManageType("0"); |
| | | } else { |