✨ feat(mes): 添加工单任务状态管理功能

YunaiV
1 parent dc7afd47
Showing 8 changed files with 222 additions and 60 deletions
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/pro/task/MesProTaskDO.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/dal/dataobject/pro/workorder/MesProWorkorderDO.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/enums/pro/MesProTaskStatusEnum.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
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkorderBomService.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkorderBomServiceImpl.java
yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkorderServiceImpl.java
 package cn.iocoder.yudao.module.mes.dal.dataobject.pro.task;
 import cn.iocoder.yudao.framework.mybatis.core.dataobject.BaseDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.md.client.MesMdClientDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.unitmeasure.MesMdUnitMeasureDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.workstation.MesMdWorkstationDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.process.MesProProcessDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderDO;
+import cn.iocoder.yudao.module.mes.enums.pro.MesProTaskStatusEnum;
 import com.baomidou.mybatisplus.annotation.KeySequence;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
@@ -79,6 +81,7 @@ public class MesProTaskDO extends BaseDO {
      * 关联 {@link MesMdUnitMeasureDO#getId()}
      */
     private Long unitMeasureId;
+
     /**
      * 排产数量
      */
@@ -99,8 +102,11 @@ public class MesProTaskDO extends BaseDO {
      * 调整数量
      */
     private BigDecimal changedQuantity;
+
     /**
      * 客户编号
+     *
+     * 关联 {@link MesMdClientDO#getId()}
      */
     private Long clientId;
     /**
@@ -127,8 +133,11 @@ public class MesProTaskDO extends BaseDO {
      * 取消日期
      */
     private LocalDateTime cancelDate;
+
     /**
      * 任务状态
+     *
+     * 枚举 {@link MesProTaskStatusEnum}
      */
     private Integer status;
     /**
@@ -32,6 +32,11 @@ import java.time.LocalDateTime;
 public class MesProWorkOrderDO extends BaseDO {
     /**
+     * 父工单编号，空值
+     */
+    public static final Long PARENT_ID_NULL = 0L;
+
+    /**
      * 编号
      */
     @TableId
+package cn.iocoder.yudao.module.mes.enums.pro;
+
+import cn.iocoder.yudao.framework.common.core.ArrayValuable;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.task.vo.MesProTaskSaveReqVO;
+import cn.iocoder.yudao.module.mes.enums.MesOrderStatusConstants;
+import cn.iocoder.yudao.module.mes.service.pro.task.MesProTaskService;
+import cn.iocoder.yudao.framework.common.util.object.ObjectUtils;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.Arrays;
+
+/**
+ * MES 生产任务状态枚举
+ *
+ * @author 芋道源码
+ */
+@Getter
+@AllArgsConstructor
+public enum MesProTaskStatusEnum implements ArrayValuable<Integer> {
+
+    /**
+     * 草稿
+     *
+     * 对应方法：{@link MesProTaskService#createTask(MesProTaskSaveReqVO)}
+     */
+    PREPARE(MesOrderStatusConstants.PREPARE, "草稿"),
+    /**
+     * 已完成
+     *
+     * 对应方法：{@link MesProTaskService#finishTaskByOrderId(Long)}
+     */
+    FINISHED(MesOrderStatusConstants.FINISHED, "已完成"),
+    /**
+     * 已取消
+     *
+     * 对应方法：{@link MesProTaskService#cancelTaskByOrderId(Long)}
+     */
+    CANCELED(MesOrderStatusConstants.CANCELLED, "已取消");
+
+    public static final Integer[] ARRAYS = Arrays.stream(values()).map(MesProTaskStatusEnum::getStatus).toArray(Integer[]::new);
+
+    /**
+     * 状态值
+     */
+    private final Integer status;
+    /**
+     * 状态名
+     */
+    private final String name;
+
+    @Override
+    public Integer[] array() {
+        return ARRAYS;
+    }
+
+    /**
+     * 判断是否为终态（已完成 或 已取消）
+     *
+     * @param status 状态值
+     * @return 是否为终态
+     */
+    public static boolean isEndStatus(Integer status) {
+        return ObjectUtils.equalsAny(status, FINISHED.status, CANCELED.status);
+    }
+
+}
+
@@ -90,4 +90,18 @@ public interface MesProTaskService {
         return convertMap(getTaskList(ids), MesProTaskDO::getId);
     }
+    /**
+     * 根据工单编号，完成所有关联任务
+     *
+     * @param workOrderId 工单编号
+     */
+    void finishTaskByOrderId(Long workOrderId);
+
+    /**
+     * 根据工单编号，取消所有关联任务
+     *
+     * @param workOrderId 工单编号
+     */
+    void cancelTaskByOrderId(Long workOrderId);
+
 }
 package cn.iocoder.yudao.module.mes.service.pro.task;
+import cn.hutool.core.collection.CollUtil;
 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.task.vo.MesProTaskPageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.task.vo.MesProTaskSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.task.MesProTaskDO;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.task.MesProTaskMapper;
+import cn.iocoder.yudao.module.mes.enums.pro.MesProTaskStatusEnum;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
+import java.time.LocalDateTime;
 import java.util.Collection;
 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_NOT_EXISTS;
 /**
@@ -75,7 +79,38 @@ public class MesProTaskServiceImpl implements MesProTaskService {
     @Override
     public List<MesProTaskDO> getTaskList(Collection<Long> ids) {
-        return taskMapper.selectBatchIds(ids);
+        return taskMapper.selectByIds(ids);
+    }
+
+    @Override
+    public void finishTaskByOrderId(Long workOrderId) {
+        // 1. 读取工单下所有任务，过滤掉已完成/已取消的
+        List<MesProTaskDO> tasks = taskMapper.selectListByWorkOrderId(workOrderId);
+        LocalDateTime now = LocalDateTime.now();
+        // 2. 构建待更新列表，批量更新
+        List<MesProTaskDO> updateList = convertList(tasks,
+                task -> new MesProTaskDO().setId(task.getId())
+                        .setStatus(MesProTaskStatusEnum.FINISHED.getStatus()).setFinishDate(now),
+                task -> !MesProTaskStatusEnum.isEndStatus(task.getStatus()));
+        if (CollUtil.isNotEmpty(updateList)) {
+            taskMapper.updateBatch(updateList);
+        }
+    }
+
+    @Override
+    public void cancelTaskByOrderId(Long workOrderId) {
+        // 1. 读取工单下所有任务，过滤掉已完成/已取消的
+        List<MesProTaskDO> tasks = taskMapper.selectListByWorkOrderId(workOrderId);
+        LocalDateTime now = LocalDateTime.now();
+        // 2. 构建待更新列表，批量更新
+        List<MesProTaskDO> updateList = convertList(tasks,
+                task -> new MesProTaskDO().setId(task.getId())
+                        .setStatus(MesProTaskStatusEnum.CANCELED.getStatus()).setCancelDate(now),
+                task -> !MesProTaskStatusEnum.isEndStatus(task.getStatus()));
+        if (CollUtil.isNotEmpty(updateList)) {
+            taskMapper.updateBatch(updateList);
+        }
     }
 }
+
 package cn.iocoder.yudao.module.mes.service.pro.workorder;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderSaveReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.bom.MesProWorkOrderBomPageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.bom.MesProWorkOrderBomSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderBomDO;
@@ -68,4 +69,15 @@ public interface MesProWorkOrderBomService {
      */
     void deleteWorkOrderBomByWorkOrderId(Long workOrderId);
+    /**
+     * 根据产品 BOM 自动生成工单 BOM 行
+     * <p>
+     * 如果 updated 为 true，会先清理旧的 BOM 数据再重新生成
+     *
+     * @param workOrderId 工单编号
+     * @param reqVO       工单创建/更新请求（取 productId、quantity）
+     * @param updated     是否为更新场景（true 时先删除旧 BOM）
+     */
+    void generateWorkOrderBom(Long workOrderId, MesProWorkOrderSaveReqVO reqVO, boolean updated);
+
 }
 package cn.iocoder.yudao.module.mes.service.pro.workorder;
+import cn.hutool.core.collection.CollUtil;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderSaveReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.bom.MesProWorkOrderBomPageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.bom.MesProWorkOrderBomSaveReqVO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdProductBomDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderBomDO;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.workorder.MesProWorkOrderBomMapper;
+import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemService;
+import cn.iocoder.yudao.module.mes.service.md.item.MesMdProductBomService;
 import jakarta.annotation.Resource;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
-import java.util.List;
+import java.util.*;
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MD_ITEM_NOT_EXISTS;
 import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.PRO_WORK_ORDER_BOM_NOT_EXISTS;
 /**
@@ -31,11 +39,17 @@ public class MesProWorkOrderBomServiceImpl implements MesProWorkOrderBomService 
     @Resource
     @Lazy // 延迟加载，避免循环依赖
     private MesProWorkOrderService workOrderService;
+    @Resource
+    private MesMdItemService itemService;
+    @Resource
+    private MesMdProductBomService productBomService;
     @Override
     public Long createWorkOrderBom(MesProWorkOrderBomSaveReqVO createReqVO) {
         // 校验工单存在
         workOrderService.validateWorkOrderExists(createReqVO.getWorkOrderId());
+
+        // 插入数据
         MesProWorkOrderBomDO workOrderBom = BeanUtils.toBean(createReqVO, MesProWorkOrderBomDO.class);
         workOrderBomMapper.insert(workOrderBom);
         return workOrderBom.getId();
@@ -45,7 +59,8 @@ public class MesProWorkOrderBomServiceImpl implements MesProWorkOrderBomService 
     public void updateWorkOrderBom(MesProWorkOrderBomSaveReqVO updateReqVO) {
         // 校验存在
         validateWorkOrderBomExists(updateReqVO.getId());
-        // 更新
+
+        // 更新数据
         MesProWorkOrderBomDO updateObj = BeanUtils.toBean(updateReqVO, MesProWorkOrderBomDO.class);
         workOrderBomMapper.updateById(updateObj);
     }
@@ -54,6 +69,7 @@ public class MesProWorkOrderBomServiceImpl implements MesProWorkOrderBomService 
     public void deleteWorkOrderBom(Long id) {
         // 校验存在
         validateWorkOrderBomExists(id);
+
         // 删除
         workOrderBomMapper.deleteById(id);
     }
@@ -84,4 +100,35 @@ public class MesProWorkOrderBomServiceImpl implements MesProWorkOrderBomService 
         workOrderBomMapper.deleteByWorkOrderId(workOrderId);
     }
-}
+    @Override
+    public void generateWorkOrderBom(Long workOrderId, MesProWorkOrderSaveReqVO reqVO, boolean updated) {
+        // 1. 如果是更新场景，先清理旧的 BOM 数据
+        if (updated) {
+            workOrderBomMapper.deleteByWorkOrderId(workOrderId);
+        }
+
+        // 2.1 查询产品 BOM
+        List<MesMdProductBomDO> productBomList = productBomService.getProductBomListByItemId(reqVO.getProductId());
+        if (CollUtil.isEmpty(productBomList)) {
+            return;
+        }
+        // 2.2 批量获取并校验 BOM 物料
+        Set<Long> bomItemIds = CollectionUtils.convertSet(productBomList, MesMdProductBomDO::getBomItemId);
+        Map<Long, MesMdItemDO> itemMap = itemService.getItemMap(bomItemIds);
+        bomItemIds.forEach(itemId -> {
+            if (itemMap.get(itemId) == null) {
+                throw exception(MD_ITEM_NOT_EXISTS);
+            }
+        });
+
+        // 3. 构建工单 BOM 列表并批量插入
+        List<MesProWorkOrderBomDO> bomList = new ArrayList<>(productBomList.size());
+        for (MesMdProductBomDO productBom : productBomList) {
+            MesMdItemDO bomItem = itemMap.get(productBom.getBomItemId());
+            bomList.add(new MesProWorkOrderBomDO().setWorkOrderId(workOrderId).setItemId(productBom.getBomItemId())
+                    .setQuantity(reqVO.getQuantity().multiply(productBom.getQuantity())).setUnitMeasureId(bomItem.getUnitMeasureId()));
+        }
+        workOrderBomMapper.insertBatch(bomList);
+    }
+
+}
 \ No newline at end of file
@@ -7,24 +7,19 @@ import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderPageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.MesProWorkOrderSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemBatchConfigDO;
-import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemDO;
-import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdProductBomDO;
-import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderBomDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderDO;
-import cn.iocoder.yudao.module.mes.dal.mysql.pro.workorder.MesProWorkOrderBomMapper;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.workorder.MesProWorkOrderMapper;
 import cn.iocoder.yudao.module.mes.enums.pro.MesProWorkOrderStatusEnum;
 import cn.iocoder.yudao.module.mes.enums.wm.BarcodeBizTypeEnum;
 import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemBatchConfigService;
 import cn.iocoder.yudao.module.mes.service.md.item.MesMdItemService;
-import cn.iocoder.yudao.module.mes.service.md.item.MesMdProductBomService;
+import cn.iocoder.yudao.module.mes.service.pro.task.MesProTaskService;
 import cn.iocoder.yudao.module.mes.service.wm.barcode.MesWmBarcodeService;
 import jakarta.annotation.Resource;
 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 java.util.Collection;
 import java.util.Collections;
@@ -45,21 +40,16 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
     @Resource
     private MesProWorkOrderMapper workOrderMapper;
-    // TODO @AI：不应该直接这么调用，调用对应的 service
     @Resource
-    private MesProWorkOrderBomMapper workOrderBomMapper;
-
+    private MesProWorkOrderBomService workOrderBomService;
     @Resource
     private MesMdItemService itemService;
-
-    @Resource
-    private MesMdProductBomService productBomService;
-
     @Resource
     private MesMdItemBatchConfigService itemBatchConfigService;
-
     @Resource
     private MesWmBarcodeService barcodeService;
+    @Resource
+    private MesProTaskService taskService;
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -68,12 +58,12 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
         validateWorkOrderCodeUnique(null, createReqVO.getCode());
         // 1.2 校验产品存在
         itemService.validateItemExists(createReqVO.getProductId());
-        // 1.3 校验批次配置：如果产品有 clientFlag=true，则 clientId 必填
+        // 1.3 校验批次配置
         validateBatchConfig(createReqVO.getProductId(), createReqVO.getClientId());
         // 2.1 设置默认值
         if (createReqVO.getParentId() == null) {
-            createReqVO.setParentId(0L);
+            createReqVO.setParentId(MesProWorkOrderDO.PARENT_ID_NULL);
         }
         // 2.2 插入工单
         MesProWorkOrderDO workOrder = BeanUtils.toBean(createReqVO, MesProWorkOrderDO.class);
@@ -83,7 +73,7 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
         workOrderMapper.insert(workOrder);
         // 3. 自动生成 BOM：根据产品 BOM 生成工单 BOM
-        generateWorkOrderBom(workOrder.getId(), createReqVO.getProductId(), createReqVO.getQuantity());
+        workOrderBomService.generateWorkOrderBom(workOrder.getId(), createReqVO, false);
         // 4. 自动生成条码
         barcodeService.autoGenerateBarcode(BarcodeBizTypeEnum.WORKORDER.getValue(),
@@ -101,13 +91,11 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
         // 1.3 校验批次配置
         validateBatchConfig(updateReqVO.getProductId(), updateReqVO.getClientId());
-        // 2. 判断产品或数量是否变更，如果变更则重新生成 BOM
+        // 2. 判断产品或数量是否变更，如果变更则重新生成 BOM（updated=true 会先清理旧数据）
         boolean productChanged = ObjUtil.notEqual(oldWorkOrder.getProductId(), updateReqVO.getProductId());
         boolean quantityChanged = oldWorkOrder.getQuantity().compareTo(updateReqVO.getQuantity()) != 0;
         if (productChanged || quantityChanged) {
-            // 删除旧 BOM 并重新生成
-            workOrderBomMapper.deleteByWorkOrderId(updateReqVO.getId());
-            generateWorkOrderBom(updateReqVO.getId(), updateReqVO.getProductId(), updateReqVO.getQuantity());
+            workOrderBomService.generateWorkOrderBom(updateReqVO.getId(), updateReqVO, true);
         }
         // 3. 更新
@@ -127,7 +115,7 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
         // 2. 删除工单 + BOM
         workOrderMapper.deleteById(id);
-        workOrderBomMapper.deleteByWorkOrderId(id);
+        workOrderBomService.deleteWorkOrderBomByWorkOrderId(id);
     }
     @Override
@@ -168,45 +156,52 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
     @Override
     public void confirmWorkOrder(Long id) {
-        // 1. 校验存在
+        // 1.1 校验存在
         MesProWorkOrderDO workOrder = validateWorkOrderExists(id);
-        // 2. 只有草稿状态才能确认
-        if (!ObjUtil.equal(workOrder.getStatus(), MesProWorkOrderStatusEnum.PREPARE.getStatus())) {
+        // 1.2 只有草稿状态才能确认
+        if (ObjUtil.notEqual(workOrder.getStatus(), MesProWorkOrderStatusEnum.PREPARE.getStatus())) {
             throw exception(PRO_WORK_ORDER_NOT_PREPARE);
         }
-        // 3. 更新状态为已确认
+
+        // 2. 更新状态为已确认
         workOrderMapper.updateById(new MesProWorkOrderDO().setId(id)
                 .setStatus(MesProWorkOrderStatusEnum.CONFIRMED.getStatus()));
     }
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void finishWorkOrder(Long id) {
         // 1. 校验存在 + 只有已确认状态才能完成
         MesProWorkOrderDO workOrder = validateWorkOrderExists(id);
-        if (!ObjUtil.equal(workOrder.getStatus(), MesProWorkOrderStatusEnum.CONFIRMED.getStatus())) {
+        if (ObjUtil.notEqual(workOrder.getStatus(), MesProWorkOrderStatusEnum.CONFIRMED.getStatus())) {
             throw exception(PRO_WORK_ORDER_NOT_CONFIRMED);
         }
-        // 2. 更新状态为已完成
+        // 2. 级联完成所有关联任务
+        taskService.finishTaskByOrderId(id);
+
+        // 3. 更新工单状态为已完成
         workOrderMapper.updateById(new MesProWorkOrderDO().setId(id)
                 .setStatus(MesProWorkOrderStatusEnum.FINISHED.getStatus())
                 .setFinishDate(LocalDateTime.now()));
-        // TODO @芋艿：pro_task 未迁移，暂不级联更新任务状态
     }
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void cancelWorkOrder(Long id) {
         // 1. 校验存在 + 只有已确认状态才能取消
         MesProWorkOrderDO workOrder = validateWorkOrderExists(id);
-        if (!ObjUtil.equal(workOrder.getStatus(), MesProWorkOrderStatusEnum.CONFIRMED.getStatus())) {
+        if (ObjUtil.notEqual(workOrder.getStatus(), MesProWorkOrderStatusEnum.CONFIRMED.getStatus())) {
             throw exception(PRO_WORK_ORDER_NOT_CONFIRMED);
         }
-        // 2. 更新状态为已取消
+        // 2. 级联取消所有关联任务
+        taskService.cancelTaskByOrderId(id);
+
+        // 3. 更新工单状态为已取消
         workOrderMapper.updateById(new MesProWorkOrderDO().setId(id)
                 .setStatus(MesProWorkOrderStatusEnum.CANCELED.getStatus())
                 .setCancelDate(LocalDateTime.now()));
-        // TODO @芋艿：pro_task 未迁移，暂不级联更新任务状态
     }
     // ==================== 校验方法 ====================
@@ -225,6 +220,7 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
     }
     private void validateBatchConfig(Long productId, Long clientId) {
+        // 如果产品有 clientFlag=true，则 clientId 必填
         MesMdItemBatchConfigDO batchConfig = itemBatchConfigService.getItemBatchConfigByItemId(productId);
         if (batchConfig != null && Boolean.TRUE.equals(batchConfig.getClientFlag()) && clientId == null) {
             // 产品要求批次管理中必须填写客户
@@ -237,28 +233,4 @@ public class MesProWorkOrderServiceImpl implements MesProWorkOrderService {
         return workOrderMapper.selectList();
     }
-    // ==================== BOM 自动生成 ====================
-
-    /**
-     * 根据产品 BOM 自动生成工单 BOM 行
-     *
-     * @param workOrderId 工单编号
-     * @param productId   产品编号
-     * @param quantity    工单生产数量
-     */
-    private void generateWorkOrderBom(Long workOrderId, Long productId, BigDecimal quantity) {
-        List<MesMdProductBomDO> productBomList = productBomService.getProductBomListByItemId(productId);
-        if (CollUtil.isEmpty(productBomList)) {
-            return;
-        }
-        for (MesMdProductBomDO productBom : productBomList) {
-            MesMdItemDO bomItem = itemService.validateItemExists(productBom.getBomItemId());
-            workOrderBomMapper.insert(new MesProWorkOrderBomDO()
-                    .setWorkOrderId(workOrderId)
-                    .setItemId(productBom.getBomItemId())
-                    .setQuantity(quantity.multiply(productBom.getQuantity()))
-                    .setUnitMeasureId(bomItem.getUnitMeasureId()));
-        }
-    }
-
 }