| | |
| | | |
| | | import cn.hutool.core.collection.CollUtil; |
| | | import cn.hutool.core.date.DateUtil; |
| | | import cn.hutool.core.util.StrUtil; |
| | | import cn.iocoder.yudao.framework.common.exception.ServiceException; |
| | | import cn.iocoder.yudao.framework.common.pojo.PageResult; |
| | | import cn.iocoder.yudao.framework.common.util.object.BeanUtils; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.pro.alternativeplan.vo.MesProAlternativePlanImportExcelVO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.pro.alternativeplan.vo.MesProAlternativePlanImportRespVO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.pro.alternativeplan.vo.MesProAlternativePlanPageReqVO; |
| | | import cn.iocoder.yudao.module.mes.controller.admin.pro.alternativeplan.vo.MesProAlternativePlanSaveReqVO; |
| | | import cn.iocoder.yudao.module.mes.dal.dataobject.pro.alternativeplan.MesProAlternativePlanDO; |
| | | import cn.iocoder.yudao.module.mes.dal.dataobject.pro.process.MesProProcessDO; |
| | | import cn.iocoder.yudao.module.mes.dal.mysql.pro.alternativeplan.MesProAlternativePlanMapper; |
| | | import cn.iocoder.yudao.module.mes.service.pro.process.MesProProcessService; |
| | | import jakarta.annotation.Resource; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.springframework.validation.annotation.Validated; |
| | | |
| | | import java.time.LocalDateTime; |
| | | import java.util.ArrayList; |
| | | import java.util.Collection; |
| | | import java.util.LinkedHashMap; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | import java.util.concurrent.atomic.AtomicInteger; |
| | | |
| | | import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; |
| | | import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_PRO_ALTERNATIVE_PLAN_IMPORT_LIST_IS_EMPTY; |
| | | import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_PRO_ALTERNATIVE_PLAN_NOT_EXISTS; |
| | | import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MES_PRO_ALTERNATIVE_PLAN_NOT_PREPARE; |
| | | |
| | |
| | | |
| | | @Resource |
| | | private MesProAlternativePlanMapper planMapper; |
| | | |
| | | @Resource |
| | | private MesProProcessService processService; |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | |
| | | planMapper.updateById(new MesProAlternativePlanDO().setId(id).setStatus(STATUS_PUBLISHED)); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public MesProAlternativePlanImportRespVO importPlanList(List<MesProAlternativePlanImportExcelVO> importList, |
| | | boolean updateSupport) { |
| | | if (CollUtil.isEmpty(importList)) { |
| | | throw exception(MES_PRO_ALTERNATIVE_PLAN_IMPORT_LIST_IS_EMPTY); |
| | | } |
| | | MesProAlternativePlanImportRespVO respVO = MesProAlternativePlanImportRespVO.builder() |
| | | .createNames(new ArrayList<>()).updateNames(new ArrayList<>()) |
| | | .failureNames(new LinkedHashMap<>()).build(); |
| | | AtomicInteger index = new AtomicInteger(1); |
| | | importList.forEach(importItem -> { |
| | | int currentIndex = index.getAndIncrement(); |
| | | String key = StrUtil.blankToDefault(importItem.getName(), "第 " + currentIndex + " 行"); |
| | | if (StrUtil.isBlank(importItem.getName())) { |
| | | respVO.getFailureNames().put(key, "方案名称不能为空"); |
| | | return; |
| | | } |
| | | Long mainProcessId = null; |
| | | if (StrUtil.isNotBlank(importItem.getMainProcessName())) { |
| | | MesProProcessDO process = processService.getProcessByName(importItem.getMainProcessName().trim()); |
| | | if (process == null) { |
| | | respVO.getFailureNames().put(key, "主工序名称[" + importItem.getMainProcessName() + "]不存在"); |
| | | return; |
| | | } |
| | | mainProcessId = process.getId(); |
| | | } |
| | | Long altProcessId = null; |
| | | if (StrUtil.isNotBlank(importItem.getAltProcessName())) { |
| | | MesProProcessDO process = processService.getProcessByName(importItem.getAltProcessName().trim()); |
| | | if (process == null) { |
| | | respVO.getFailureNames().put(key, "替代工序名称[" + importItem.getAltProcessName() + "]不存在"); |
| | | return; |
| | | } |
| | | altProcessId = process.getId(); |
| | | } |
| | | MesProAlternativePlanSaveReqVO reqVO = BeanUtils.toBean(importItem, MesProAlternativePlanSaveReqVO.class); |
| | | reqVO.setMainProcessId(mainProcessId); |
| | | reqVO.setAltProcessId(altProcessId); |
| | | MesProAlternativePlanDO existPlan = planMapper.selectByName(importItem.getName()); |
| | | try { |
| | | if (existPlan == null) { |
| | | reqVO.setId(null); |
| | | createPlan(reqVO); |
| | | respVO.getCreateNames().add(importItem.getName()); |
| | | } else if (updateSupport) { |
| | | reqVO.setId(existPlan.getId()); |
| | | updatePlan(reqVO); |
| | | respVO.getUpdateNames().add(importItem.getName()); |
| | | } else { |
| | | respVO.getFailureNames().put(key, "方案名称已存在"); |
| | | } |
| | | } catch (ServiceException e) { |
| | | respVO.getFailureNames().put(key, e.getMessage()); |
| | | } |
| | | }); |
| | | return respVO; |
| | | } |
| | | |
| | | private String generateCode() { |
| | | return "TD" + DateUtil.format(LocalDateTime.now(), "yyyyMMddHHmmss") |
| | | + String.format("%03d", (int) (Math.random() * 1000)); |