✨ feat(mes): 添加生产任务状态校验和反馈数据验证逻辑

新增对生产任务状态的校验，确保任务未完成时才能进行报工操作。同时，优化报工数据的验证逻辑，确保输入的数量符合业务要求，提升系统的健壮性和用户体验。

✨ feat(mes): 添加生产任务状态校验和反馈数据验证逻辑
新增对生产任务状态的校验，确保任务未完成时才能进行报工操作。同时，优化报工数据的验证逻辑，确保输入的数量符合业务要求，提升系统的健壮性和用户体验。
YunaiV
1 parent 5c60fab8
Showing 5 changed files with 82 additions and 13 deletions
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/pro/feedback/MesProFeedbackController.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/enums/ErrorCodeConstants.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/feedback/MesProFeedbackServiceImpl.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/task/MesProTaskService.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/task/MesProTaskServiceImpl.java
@@ -55,25 +55,18 @@ public class MesProFeedbackController {
     @Resource
     private MesProFeedbackService feedbackService;
-
     @Resource
     private MesMdWorkstationService workstationService;
-
     @Resource
     private MesProRouteService routeService;
-
     @Resource
     private MesProProcessService processService;
-
     @Resource
     private MesProWorkOrderService workOrderService;
-
     @Resource
     private MesMdItemService itemService;
-
     @Resource
     private MesMdUnitMeasureService unitMeasureService;
-
     @Resource
     private MesProRouteProcessService routeProcessService;
@@ -226,6 +219,7 @@ public class MesProFeedbackController {
             findAndThen(workOrderMap, vo.getWorkOrderId(), wo ->
                     vo.setWorkOrderCode(wo.getCode()).setWorkOrderName(wo.getName()));
             // TODO @芋艿：task code 待 pro_task 服务迁移后补充
+            // TODO @AI：貌似已经支持，可以跟进下
             // 物料、计量单位
             findAndThen(itemMap, vo.getItemId(), item ->
                     vo.setItemCode(item.getCode()).setItemName(item.getName()).setItemSpec(item.getSpecification()));
@@ -226,6 +226,7 @@ public interface ErrorCodeConstants {
     // ========== MES 生产管理-生产任务（1-040-503-000） ==========
     ErrorCode PRO_TASK_NOT_EXISTS = new ErrorCode(1_040_503_000, "生产任务不存在");
+    ErrorCode PRO_TASK_ALREADY_FINISHED = new ErrorCode(1_040_503_001, "生产任务已完成或已取消，不能继续操作");
     // ========== MES 生产管理-安灯呼叫配置（1-040-504-000） ==========
     ErrorCode PRO_ANDON_CONFIG_NOT_EXISTS = new ErrorCode(1_040_504_000, "安灯呼叫配置不存在");
@@ -245,6 +246,10 @@ public interface ErrorCodeConstants {
     ErrorCode PRO_FEEDBACK_STATUS_ERROR = new ErrorCode(1_040_506_005, "报工单状态不正确，无法执行此操作");
     ErrorCode PRO_FEEDBACK_WORK_ORDER_NOT_CONFIRMED = new ErrorCode(1_040_506_006, "关联的工单未确认，无法创建报工");
     ErrorCode PRO_FEEDBACK_QUALIFIED_UNQUALIFIED_MISMATCH = new ErrorCode(1_040_506_007, "合格品数量与不良品数量之和必须等于报工数量");
+    ErrorCode PRO_FEEDBACK_ROUTE_PROCESS_INVALID = new ErrorCode(1_040_506_008, "未找到对应的工艺工序配置，请检查工艺路线与工序");
+    ErrorCode PRO_FEEDBACK_TASK_OR_ORDER_FINISHED = new ErrorCode(1_040_506_009, "当前生产任务或工单已完成，不能继续报工");
+    ErrorCode PRO_FEEDBACK_QUANTITY_MUST_POSITIVE = new ErrorCode(1_040_506_010, "报工数量必须大于 0");
+    ErrorCode PRO_FEEDBACK_QUALIFIED_UNQUALIFIED_REQUIRED = new ErrorCode(1_040_506_011, "请输入合格品和不良品数量，且合计须大于 0");
     // ========== MES 生产管理-生产流转卡（1-040-507-000） ==========
     ErrorCode PRO_CARD_NOT_EXISTS = new ErrorCode(1_040_507_000, "生产流转卡不存在");
@@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.mes.service.pro.feedback;
 import cn.hutool.core.util.BooleanUtil;
 import cn.hutool.core.util.ObjUtil;
+import cn.hutool.core.util.ObjectUtil;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;
@@ -11,13 +12,17 @@ import cn.iocoder.yudao.module.mes.dal.dataobject.pro.feedback.MesProFeedbackDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteProcessDO;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.feedback.MesProFeedbackMapper;
 import cn.iocoder.yudao.module.mes.enums.pro.MesProFeedbackStatusEnum;
+import cn.iocoder.yudao.module.mes.service.md.workstation.MesMdWorkstationService;
 import cn.iocoder.yudao.module.mes.service.pro.route.MesProRouteProcessService;
+import cn.iocoder.yudao.module.mes.service.pro.task.MesProTaskService;
 import cn.iocoder.yudao.module.mes.service.pro.workorder.MesProWorkOrderService;
 import jakarta.annotation.Resource;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
+import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
@@ -42,23 +47,31 @@ public class MesProFeedbackServiceImpl implements MesProFeedbackService {
     @Resource
     private MesProRouteProcessService routeProcessService;
+    @Resource
+    private MesMdWorkstationService workstationService;
+
+    @Resource
+    @Lazy // 避免循环依赖
+    private MesProTaskService taskService;
+
     @Override
     public Long createFeedback(MesProFeedbackSaveReqVO createReqVO) {
-        // 1. 校验工单已确认
-        workOrderService.validateWorkOrderConfirmed(createReqVO.getWorkOrderId());
-        // TODO @芋艿：校验 pro_task 存在且未完成（待 pro_task 服务迁移）
+        // 1. 校验
+        validateFeedbackData(createReqVO);
         // 2. 插入
-        MesProFeedbackDO feedback = BeanUtils.toBean(createReqVO, MesProFeedbackDO.class);
-        feedback.setStatus(MesProFeedbackStatusEnum.PREPARE.getStatus());
+        MesProFeedbackDO feedback = BeanUtils.toBean(createReqVO, MesProFeedbackDO.class)
+                .setStatus(MesProFeedbackStatusEnum.PREPARE.getStatus());
         feedbackMapper.insert(feedback);
         return feedback.getId();
     }
     @Override
     public void updateFeedback(MesProFeedbackSaveReqVO updateReqVO) {
-        // 1. 校验存在 + 草稿状态
+        // 1.1 校验存在 + 草稿状态
         validateFeedbackStatusPrepare(updateReqVO.getId());
+        // 1.2 校验业务数据
+        validateFeedbackData(updateReqVO);
         // 2. 更新
         MesProFeedbackDO updateObj = BeanUtils.toBean(updateReqVO, MesProFeedbackDO.class);
@@ -173,6 +186,45 @@ public class MesProFeedbackServiceImpl implements MesProFeedbackService {
     }
     /**
+     * 校验报工单的业务数据（创建 & 修改共用）
+     *
+     * @param reqVO 报工请求
+     */
+    private void validateFeedbackData(MesProFeedbackSaveReqVO reqVO) {
+        // 1. 校验工作站存在
+        workstationService.validateWorkstationExists(reqVO.getWorkstationId());
+
+        // 2.1 校验工艺路线 + 工序配置有效
+        MesProRouteProcessDO routeProcess = routeProcessService.getRouteProcessByRouteIdAndProcessId(
+                reqVO.getRouteId(), reqVO.getProcessId());
+        if (routeProcess == null) {
+            throw exception(PRO_FEEDBACK_ROUTE_PROCESS_INVALID);
+        }
+        // 2.2 校验数量
+        boolean checkFlag = Boolean.TRUE.equals(routeProcess.getCheckFlag());
+        if (checkFlag) {
+            // 需要检验：只需填报工数量，且必须 > 0
+            if (reqVO.getFeedbackQuantity() == null
+                    || reqVO.getFeedbackQuantity().compareTo(BigDecimal.ZERO) <= 0) {
+                throw exception(PRO_FEEDBACK_QUANTITY_MUST_POSITIVE);
+            }
+        } else {
+            // 不需检验：需填合格品 + 不良品数量，合计 > 0
+            BigDecimal qualified = ObjectUtil.defaultIfNull(reqVO.getQualifiedQuantity(), BigDecimal.ZERO);
+            BigDecimal unqualified = ObjectUtil.defaultIfNull(reqVO.getUnqualifiedQuantity(), BigDecimal.ZERO);
+            if (qualified.add(unqualified).compareTo(BigDecimal.ZERO) <= 0) {
+                throw exception(PRO_FEEDBACK_QUALIFIED_UNQUALIFIED_REQUIRED);
+            }
+        }
+
+        // 3. 校验工单已确认
+        workOrderService.validateWorkOrderConfirmed(reqVO.getWorkOrderId());
+
+        // 4. 校验任务存在且未终态（已完成/已取消）
+        taskService.validateTaskNotFinished(reqVO.getTaskId());
+    }
+
+    /**
      * 获取指定工艺路线中指定工序的 checkFlag
      *
      * @param routeId   工艺路线编号
@@ -82,6 +82,14 @@ public interface MesProTaskService {
     MesProTaskDO validateTaskExists(Long id);
     /**
+     * 校验任务存在且未完成（非终态）
+     *
+     * @param id 编号
+     * @return 生产任务
+     */
+    MesProTaskDO validateTaskNotFinished(Long id);
+
+    /**
      * 获得生产任务列表
      *
      * @param ids 编号列表
@@ -29,6 +29,7 @@ import java.util.List;
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
 import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertList;
+import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.PRO_TASK_ALREADY_FINISHED;
 import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.PRO_TASK_NOT_EXISTS;
 /**
@@ -152,6 +153,15 @@ public class MesProTaskServiceImpl implements MesProTaskService {
     }
     @Override
+    public MesProTaskDO validateTaskNotFinished(Long id) {
+        MesProTaskDO task = validateTaskExists(id);
+        if (MesProTaskStatusEnum.isEndStatus(task.getStatus())) {
+            throw exception(PRO_TASK_ALREADY_FINISHED);
+        }
+        return task;
+    }
+
+    @Override
     public List<MesProTaskDO> getTaskList(Collection<Long> ids) {
         return taskMapper.selectByIds(ids);
     }