From c2053d7017625f270577bc0f6c523d04f52db6ea Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期五, 24 七月 2026 14:20:29 +0800
Subject: [PATCH] refactor(crm): 重构文件上传功能,替换原有的fileUrls字段为统一的StorageAttachmentApi

---
 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkOrderProcessServiceImpl.java |   39 ++++++++++++++++++++++++++++++++++++++-
 1 files changed, 38 insertions(+), 1 deletions(-)

diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkOrderProcessServiceImpl.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkOrderProcessServiceImpl.java
index 0883d5d..9ee4e74 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkOrderProcessServiceImpl.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/service/pro/workorder/MesProWorkOrderProcessServiceImpl.java
@@ -5,8 +5,11 @@
 import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.process.MesProWorkOrderProcessPageReqVO;
 import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.process.MesProWorkOrderProcessSaveReqVO;
+import cn.iocoder.yudao.module.mes.controller.admin.pro.workorder.vo.process.MesProWorkOrderProcessSaveReqVO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.route.MesProRouteProcessDO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderBomDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.pro.workorder.MesProWorkOrderProcessDO;
+import cn.iocoder.yudao.module.mes.dal.mysql.pro.workorder.MesProWorkOrderBomMapper;
 import cn.iocoder.yudao.module.mes.dal.mysql.pro.workorder.MesProWorkOrderProcessMapper;
 import cn.iocoder.yudao.module.mes.service.pro.process.MesProProcessService;
 import cn.iocoder.yudao.module.mes.service.pro.route.MesProRouteProcessService;
@@ -44,6 +47,11 @@
     private MesProProcessService processService;
     @Resource
     private MesProRouteProcessService routeProcessService;
+    @Resource
+    @Lazy
+    private MesProWorkOrderBomService workOrderBomService;
+    @Resource
+    private MesProWorkOrderBomMapper workOrderBomMapper;
 
     @Override
     public Long createWorkOrderProcess(MesProWorkOrderProcessSaveReqVO createReqVO) {
@@ -175,10 +183,39 @@
             }
         }
 
-        // 4. 閲嶅缓宸ュ簭閾�
+        // 4. 淇濆瓨宸ュ崟 BOM 鎶曟枡锛堝悎骞舵墍鏈夊伐搴忕殑 bomItems锛屾寜 itemId 鍘婚噸锛�
+        saveWorkOrderBomFromProcesses(workOrderId, list);
+
+        // 5. 閲嶅缓宸ュ簭閾�
         rebuildProcessChain(workOrderId);
     }
 
+    /**
+     * 浠庡伐搴忓垪琛ㄤ腑鎻愬彇 BOM 鎶曟枡锛屾寜宸ュ簭鍒嗗埆淇濆瓨鍒板伐鍗� BOM 琛�
+     */
+    private void saveWorkOrderBomFromProcesses(Long workOrderId, List<MesProWorkOrderProcessSaveReqVO> list) {
+        workOrderBomService.deleteWorkOrderBomByWorkOrderId(workOrderId);
+        List<MesProWorkOrderBomDO> bomList = new ArrayList<>();
+        for (MesProWorkOrderProcessSaveReqVO item : list) {
+            if (CollUtil.isNotEmpty(item.getBomItems())) {
+                for (MesProWorkOrderProcessSaveReqVO.BomItem bomItem : item.getBomItems()) {
+                    if (bomItem.getItemId() != null) {
+                        bomList.add(MesProWorkOrderBomDO.builder()
+                                .workOrderId(workOrderId)
+                                .processId(item.getProcessId())
+                                .itemId(bomItem.getItemId())
+                                .quantity(bomItem.getQuantity())
+                                .remark(bomItem.getRemark())
+                                .build());
+                    }
+                }
+            }
+        }
+        if (CollUtil.isNotEmpty(bomList)) {
+            workOrderBomMapper.insertBatch(bomList);
+        }
+    }
+
     // ==================== 绉佹湁鏂规硶 ====================
 
     private MesProWorkOrderProcessDO validateWorkOrderProcessExists(Long id) {

--
Gitblit v1.9.3