|  |  | 
 |  |  | import com.ruoyi.common.utils.StringUtils; | 
 |  |  | import com.ruoyi.common.utils.bean.BeanValidators; | 
 |  |  | import com.ruoyi.common.utils.spring.SpringUtils; | 
 |  |  | import com.ruoyi.common.utils.uuid.IdUtils; | 
 |  |  | import org.slf4j.Logger; | 
 |  |  | import org.slf4j.LoggerFactory; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public int insertArdTubesDetails(ArdTubesDetails ardTubesDetails) { | 
 |  |  |         ardTubesDetails.setId(IdUtils.simpleUUID()); | 
 |  |  |         ardTubesDetails.setUserId(SecurityUtils.getUserId()); | 
 |  |  |         ardTubesDetails.setCreateBy(SecurityUtils.getUsername()); | 
 |  |  |         ardTubesDetails.setCreateTime(DateUtils.getNowDate()); | 
 |  |  | 
 |  |  |     @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); | 
 |  |  |             } |