| | |
| | | @Override |
| | | public String importArdTubesDetails(List<ArdTubesDetails> ardTubesDetailsList, Boolean isUpdateSupport, String operName, String tubeId) { |
| | | if (StringUtils.isNull(ardTubesDetailsList) || ardTubesDetailsList.size() == 0) { |
| | | throw new ServiceException("导入井数据不能为空!"); |
| | | throw new ServiceException("导入管线数据不能为空!"); |
| | | } |
| | | ArdTubes tubes = ardTubesMapper.selectArdTubesById(tubeId); |
| | | int successNum = 0; |
| | |
| | | String userId = SecurityUtils.getUserId(); |
| | | tubesDetails.setUserId(userId); |
| | | // 验证是否存在这个管线编号详情 |
| | | ArdTubesDetails atd = ardTubesDetailsMapper.selectArdTubesDetailsByReelNumber(tubesDetails.getReelNumber()); |
| | | ArdTubesDetails atd = ardTubesDetailsMapper.selectArdTubesDetailsByReelNumber(tubesDetails.getReelNumber(),tubesDetails.getInflectionPointNumber()); |
| | | if (StringUtils.isNull(atd)) { |
| | | BeanValidators.validateWithException(validator, tubesDetails); |
| | | tubesDetails.setCreateBy(operName); |
| | |
| | | tubesDetails.setDeptId(tubes.getDeptId()); |
| | | this.insertArdTubesDetails(tubesDetails); |
| | | successNum++; |
| | | successMsg.append("<br/>" + successNum + "、管线编号 " + tubesDetails.getReelNumber() + " 导入成功"); |
| | | successMsg.append("<br/>" + successNum + "、管线编号 " + tubesDetails.getReelNumber() +"-"+tubesDetails.getInflectionPointNumber()+ " 导入成功"); |
| | | } else if (isUpdateSupport) { |
| | | BeanValidators.validateWithException(validator, tubesDetails); |
| | | checkTubesDetailAllowed(tubesDetails); |
| | |
| | | tubesDetails.setDeptId(tubes.getDeptId()); |
| | | this.updateArdTubesDetailsByReelNumber(tubesDetails); |
| | | successNum++; |
| | | successMsg.append("<br/>" + successNum + "、管线编号 " + tubesDetails.getReelNumber() + " 更新成功"); |
| | | successMsg.append("<br/>" + successNum + "、管线编号 " + tubesDetails.getReelNumber() +"-"+tubesDetails.getInflectionPointNumber()+ " 更新成功"); |
| | | } else { |
| | | failureNum++; |
| | | failureMsg.append("<br/>" + failureNum + "、管线编号 " + tubesDetails.getReelNumber() + " 已存在"); |
| | | failureMsg.append("<br/>" + failureNum + "、管线编号 " + tubesDetails.getReelNumber()+"-"+tubesDetails.getInflectionPointNumber() + " 已存在"); |
| | | } |
| | | } catch (Exception e) { |
| | | failureNum++; |
| | | String msg = "<br/>" + failureNum + "、管线编号 " + tubesDetails.getReelNumber() + " 导入失败:"; |
| | | String msg = "<br/>" + failureNum + "、管线编号 " + tubesDetails.getReelNumber() +"-"+tubesDetails.getInflectionPointNumber()+ " 导入失败:"; |
| | | failureMsg.append(msg + e.getMessage()); |
| | | log.error(msg, e); |
| | | } |