|  |  |  | 
|---|
|  |  |  | 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); | 
|---|
|  |  |  | } | 
|---|