package cn.iocoder.yudao.module.mes.service.pro.alternativeplan; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.date.DateUtil; 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.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.mysql.pro.alternativeplan.MesProAlternativePlanMapper; 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.Collection; import java.util.Objects; import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; 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; /** * MES 作业替代方案 Service 实现类 * * @author xiaoyi */ @Service @Validated public class MesProAlternativePlanServiceImpl implements MesProAlternativePlanService { private static final Integer STATUS_DRAFT = 0; private static final Integer STATUS_PUBLISHED = 10; @Resource private MesProAlternativePlanMapper planMapper; @Override @Transactional(rollbackFor = Exception.class) public Long createPlan(MesProAlternativePlanSaveReqVO createReqVO) { MesProAlternativePlanDO plan = BeanUtils.toBean(createReqVO, MesProAlternativePlanDO.class, req -> req .setCode(generateCode()) .setStatus(STATUS_DRAFT)); planMapper.insert(plan); return plan.getId(); } @Override @Transactional(rollbackFor = Exception.class) public void updatePlan(MesProAlternativePlanSaveReqVO updateReqVO) { MesProAlternativePlanDO oldPlan = validatePlanCanModify(updateReqVO.getId()); MesProAlternativePlanDO updateObj = BeanUtils.toBean(updateReqVO, MesProAlternativePlanDO.class, req -> req .setCode(oldPlan.getCode()) .setStatus(oldPlan.getStatus())); planMapper.updateById(updateObj); } @Override @Transactional(rollbackFor = Exception.class) public void deletePlan(Collection ids) { if (CollUtil.isEmpty(ids)) { return; } for (Long id : ids) { validatePlanCanModify(id); planMapper.deleteById(id); } } @Override public MesProAlternativePlanDO getPlan(Long id) { return planMapper.selectById(id); } @Override public PageResult getPlanPage(MesProAlternativePlanPageReqVO pageReqVO) { return planMapper.selectPage(pageReqVO); } @Override @Transactional(rollbackFor = Exception.class) public void publishPlan(Long id) { MesProAlternativePlanDO plan = validatePlanExists(id); if (!Objects.equals(plan.getStatus(), STATUS_DRAFT)) { throw exception(MES_PRO_ALTERNATIVE_PLAN_NOT_PREPARE); } planMapper.updateById(new MesProAlternativePlanDO().setId(id).setStatus(STATUS_PUBLISHED)); } private String generateCode() { return "TD" + DateUtil.format(LocalDateTime.now(), "yyyyMMddHHmmss") + String.format("%03d", (int) (Math.random() * 1000)); } private MesProAlternativePlanDO validatePlanExists(Long id) { MesProAlternativePlanDO plan = planMapper.selectById(id); if (plan == null) { throw exception(MES_PRO_ALTERNATIVE_PLAN_NOT_EXISTS); } return plan; } private MesProAlternativePlanDO validatePlanCanModify(Long id) { MesProAlternativePlanDO plan = validatePlanExists(id); if (!Objects.equals(plan.getStatus(), STATUS_DRAFT)) { throw exception(MES_PRO_ALTERNATIVE_PLAN_NOT_PREPARE); } return plan; } }