| | |
| | | judgeDataBlean = Boolean.FALSE; |
| | | errorMessage += |
| | | StringUtils.isEmpty(errorMessage)? |
| | | "第" + (i + 1) + "行,该[基础清单名称]不能为空" :"<br/> 第" + (i + 1) + "行,该[基础清单名称]不能为空"; |
| | | "第" + (i + 2) + "行,该[基础清单名称]不能为空" :"<br/> 第" + (i + 1) + "行,该[基础清单名称]不能为空"; |
| | | } |
| | | if (StringUtil.isEmpty(importData.getCheckType())) { |
| | | judgeDataBlean = Boolean.FALSE; |
| | | errorMessage += |
| | | StringUtils.isEmpty(errorMessage)? |
| | | "第" + (i + 1) + "行,该[检查类别]不能为空" :"<br/> 第" + (i + 1) + "行,该[检查类别]不能为空"; |
| | | "第" + (i + 2) + "行,该[检查类别]不能为空" :"<br/> 第" + (i + 1) + "行,该[检查类别]不能为空"; |
| | | } |
| | | if (StringUtil.isEmpty(importData.getCheckContent())) { |
| | | judgeDataBlean = Boolean.FALSE; |
| | | errorMessage += |
| | | StringUtils.isEmpty(errorMessage)? |
| | | "第" + (i + 1) + "行,该[检查内容]不能为空" :"<br/> 第" + (i + 1) + "行,该[检查内容]不能为空"; |
| | | "第" + (i + 2) + "行,该[检查内容]不能为空" :"<br/> 第" + (i + 1) + "行,该[检查内容]不能为空"; |
| | | } |
| | | if (StringUtil.isEmpty(importData.getControlMeasureCode())) { |
| | | judgeDataBlean = Boolean.FALSE; |
| | | errorMessage += |
| | | StringUtils.isEmpty(errorMessage)? |
| | | "第" + (i + 1) + "行,该[管控措施编号]不能为空" :"<br/> 第" + (i + 1) + "行,该[管控措施编号]不能为空"; |
| | | "第" + (i + 2) + "行,该[管控措施编号]不能为空" :"<br/> 第" + (i + 1) + "行,该[管控措施编号]不能为空"; |
| | | } |
| | | |
| | | } |
| | |
| | | riskList.setCompanyId(getSysUser().getCompanyId()); |
| | | int resultRiskList = riskListService.insertRiskList(riskList); |
| | | if (resultRiskList < 1){ //todo 需要检查是否收到标题行影响 |
| | | return AjaxResult.error("第" + i + "行基础清单插入错误,导入失败"); |
| | | throw new RuntimeException("第" + (i+2) + "行基础清单插入错误,导入失败"); |
| | | } |
| | | }else { |
| | | riskList.setRiskListId(infoByRiskListName.getRiskListId()); |
| | |
| | | } |
| | | int resultBaseCheckPoint = baseCheckPointService.insertBaseCheckPoint(baseCheckPoint); |
| | | if (resultBaseCheckPoint < 1){ |
| | | return AjaxResult.error("第" + i + "行风险点插入错误,导入失败"); |
| | | throw new RuntimeException("第" + (i+2) + "行风险点插入错误,导入失败"); |
| | | } |
| | | //3.preventRiskCheckUnit |
| | | PreventRiskControlMeasure controlMeasure = |
| | | riskControlMeasureService.getPreventRiskControlMeasureByControlMeasureCode(importData.getControlMeasureCode()); |
| | | if (ObjectUtils.isEmpty(controlMeasure)){ |
| | | return AjaxResult.error("第" + i + "行管控措施不存在,导入失败"); |
| | | throw new RuntimeException("第" + (i+2) + "行管控措施不存在,导入失败"); |
| | | } |
| | | preventPointAndMeasureParams.setRiskId(riskList.getRiskListId()); |
| | | preventPointAndMeasureParams.setBaseCheckPointId(baseCheckPoint.getCheckPointId()); |
| | | preventPointAndMeasureParams.setControlMeasureId(controlMeasure.getId()); |
| | | int result = riskService.insertPointAndMeasure(preventPointAndMeasureParams); |
| | | if (ObjectUtils.isEmpty(controlMeasure)){ |
| | | return AjaxResult.error("第" + i + "行风险点与管控措施关联关系保持出错,导入失败"); |
| | | if (result < 1){ |
| | | throw new RuntimeException("第" + (i+2) + "行风险点与管控措施关联关系保持出错,导入失败"); |
| | | } |
| | | |
| | | } |