From 3066a8f5c1f475997bfe23857ba4bae9395900c4 Mon Sep 17 00:00:00 2001
From: yuan <123@>
Date: 星期四, 13 八月 2026 10:19:24 +0800
Subject: [PATCH] fix: 领料功能修改,移除订单领料,添加工序领料功能,支持按工序查询物料与已领料记录

---
 src/main/java/com/ruoyi/technology/service/impl/TechnologyRoutingServiceImpl.java |   69 +++++++++++++++++-----------------
 1 files changed, 35 insertions(+), 34 deletions(-)

diff --git a/src/main/java/com/ruoyi/technology/service/impl/TechnologyRoutingServiceImpl.java b/src/main/java/com/ruoyi/technology/service/impl/TechnologyRoutingServiceImpl.java
index d225f7c..bbc1aff 100644
--- a/src/main/java/com/ruoyi/technology/service/impl/TechnologyRoutingServiceImpl.java
+++ b/src/main/java/com/ruoyi/technology/service/impl/TechnologyRoutingServiceImpl.java
@@ -1,7 +1,6 @@
 package com.ruoyi.technology.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -10,20 +9,10 @@
 import com.ruoyi.common.utils.OrderUtils;
 import com.ruoyi.technology.bean.dto.TechnologyRoutingDto;
 import com.ruoyi.technology.bean.vo.TechnologyRoutingVo;
-import com.ruoyi.technology.mapper.TechnologyBomStructureMapper;
-import com.ruoyi.technology.mapper.TechnologyOperationMapper;
-import com.ruoyi.technology.mapper.TechnologyOperationParamMapper;
-import com.ruoyi.technology.mapper.TechnologyParamMapper;
-import com.ruoyi.technology.mapper.TechnologyRoutingMapper;
-import com.ruoyi.technology.mapper.TechnologyRoutingOperationMapper;
-import com.ruoyi.technology.mapper.TechnologyRoutingOperationParamMapper;
-import com.ruoyi.technology.pojo.TechnologyBomStructure;
-import com.ruoyi.technology.pojo.TechnologyOperation;
-import com.ruoyi.technology.pojo.TechnologyOperationParam;
-import com.ruoyi.technology.pojo.TechnologyParam;
-import com.ruoyi.technology.pojo.TechnologyRouting;
-import com.ruoyi.technology.pojo.TechnologyRoutingOperation;
-import com.ruoyi.technology.pojo.TechnologyRoutingOperationParam;
+import com.ruoyi.production.mapper.ProductionOrderRoutingMapper;
+import com.ruoyi.production.pojo.ProductionOrderRouting;
+import com.ruoyi.technology.mapper.*;
+import com.ruoyi.technology.pojo.*;
 import com.ruoyi.technology.service.TechnologyRoutingService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
@@ -31,9 +20,9 @@
 
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
-import java.util.LinkedHashMap;
+import java.util.LinkedHashSet;
 import java.util.List;
-import java.util.Map;
+import java.util.Set;
 import java.util.stream.Collectors;
 
 @Service
@@ -51,6 +40,8 @@
     private final TechnologyOperationParamMapper technologyOperationParamMapper;
     private final TechnologyParamMapper technologyParamMapper;
     private final TechnologyRoutingOperationParamMapper technologyRoutingOperationParamMapper;
+
+    private final ProductionOrderRoutingMapper productionOrderRoutingMapper;
 
     @Override
     public IPage<TechnologyRoutingVo> pageTechnologyRouting(Page<TechnologyRoutingDto> page, TechnologyRoutingDto technologyRoutingDto) {
@@ -91,6 +82,13 @@
         if (ids == null || ids.isEmpty()) {
             return false;
         }
+        // 鍒ゆ柇鏄惁鏈夌敓浜ц鍗曠粦瀹氳宸ヨ壓璺嚎
+        Long count = productionOrderRoutingMapper.selectCount(
+                Wrappers.<ProductionOrderRouting>lambdaQuery()
+                        .in(ProductionOrderRouting::getTechnologyRoutingId, ids));
+        if (count > 0) {
+            throw new ServiceException("璇ュ伐鑹鸿矾绾垮凡缁戝畾鐢熶骇璁㈠崟锛屾棤娉曞垹闄わ紒");
+        }
         List<TechnologyRoutingOperation> routingOperationList = technologyRoutingOperationMapper.selectList(
                 Wrappers.<TechnologyRoutingOperation>lambdaQuery()
                         .in(TechnologyRoutingOperation::getTechnologyRoutingId, ids));
@@ -106,9 +104,10 @@
 
     /**
      * 鎸夊綋鍓嶉�夋嫨鐨� BOM 閲嶅缓宸ヨ壓璺嚎宸ュ簭锛�
-     * 1. 鍏堝垹闄よ宸ヨ壓璺嚎涓嬪凡鏈夊伐搴�
-     * 2. 璇诲彇 BOM 缁撴瀯涓殑 operation_id
-     * 3. 鎸� BOM 鍑虹幇椤哄簭鍘婚噸鍚庨噸鏂板啓鍏ュ伐鑹鸿矾绾垮伐搴忚〃
+     * 1. 鍏堝垹闄よ宸ヨ壓璺嚎涓嬪凡鏈夊伐搴忓強鍙傛暟蹇収
+     * 2. 璇诲彇鎵佸钩 BOM 鏄庣粏涓殑 operation_id
+     * 3. 鎸� BOM 涓娆″嚭鐜扮殑椤哄簭瀵瑰伐搴忓幓閲嶏紝姣忛亾宸ュ簭鐢熸垚涓�鏉¤矾绾垮伐搴�
+     * 4. 姣忔潯璺嚎宸ュ簭鐨勪骇鍑鸿鏍煎浐瀹氫负宸ヨ壓璺嚎鐨勬垚鍝佽鏍�
      */
     private void syncRoutingOperationsByBom(TechnologyRouting technologyRouting) {
         List<TechnologyRoutingOperation> oldRoutingOperationList = technologyRoutingOperationMapper.selectList(
@@ -126,7 +125,7 @@
         }
         List<TechnologyBomStructure> bomStructures = technologyBomStructureMapper.selectList(
                 Wrappers.<TechnologyBomStructure>lambdaQuery()
-                        .eq(TechnologyBomStructure::getBomId, Long.valueOf(technologyRouting.getBomId()))
+                        .eq(TechnologyBomStructure::getBomId, technologyRouting.getBomId())
                         .isNotNull(TechnologyBomStructure::getOperationId)
                         .orderByAsc(TechnologyBomStructure::getId)
         );
@@ -134,22 +133,25 @@
             throw new ServiceException("bom浜у搧缁撴瀯涓虹┖锛�");
         }
 
-        // 鍚屼竴涓� BOM 涓彲鑳介噸澶嶅紩鐢ㄧ浉鍚屽伐搴忥紝杩欓噷鎸夐娆″嚭鐜伴『搴忓幓閲嶃��
-        Map<Long, TechnologyBomStructure> uniqueOperationMap = new LinkedHashMap<>();
+        // 鎵佸钩 BOM 涓涓墿鏂欏彲浠ユ寚鍚戝悓涓�閬撳伐搴忥紝杩欓噷鍙寜宸ュ簭鍘婚噸
+        Set<Long> uniqueOperationIdList = new LinkedHashSet<>();
         for (TechnologyBomStructure bomStructure : bomStructures) {
-            uniqueOperationMap.putIfAbsent(bomStructure.getOperationId(), bomStructure);
+            uniqueOperationIdList.add(bomStructure.getOperationId());
         }
 
         int dragSort = 1;
-        for (TechnologyBomStructure bomStructure : uniqueOperationMap.values()) {
+        for (Long operationId : uniqueOperationIdList) {
             TechnologyRoutingOperation routingOperation = new TechnologyRoutingOperation();
             routingOperation.setTechnologyRoutingId(technologyRouting.getId());
             routingOperation.setProductModelId(technologyRouting.getProductModelId());
-            routingOperation.setTechnologyOperationId(bomStructure.getOperationId());
+            routingOperation.setTechnologyOperationId(operationId);
             routingOperation.setDragSort(dragSort++);
-            routingOperation.setIsQuality(getOperationQuality(bomStructure.getOperationId()));
+            TechnologyOperation technologyOperation = getOperation(operationId);
+            routingOperation.setIsQuality(technologyOperation != null ? technologyOperation.getIsQuality() : null);
+            routingOperation.setIsProduction(technologyOperation != null ? technologyOperation.getIsProduction() : null);
+            routingOperation.setType(technologyOperation != null ? technologyOperation.getType() : null);
             technologyRoutingOperationMapper.insert(routingOperation);
-            syncRoutingOperationParams(routingOperation.getId(), bomStructure.getOperationId());
+            syncRoutingOperationParams(routingOperation.getId(), operationId);
         }
     }
 
@@ -183,12 +185,11 @@
         }
     }
 
-    /**
-     * 璐ㄦ鏍囪瘑浠ュ伐搴忓熀纭�琛ㄥ畾涔変负鍑嗐��
-     */
-    private Boolean getOperationQuality(Long operationId) {
-        TechnologyOperation technologyOperation = technologyOperationMapper.selectById(operationId);
-        return technologyOperation != null ? technologyOperation.getIsQuality() : null;
+    private TechnologyOperation getOperation(Long operationId) {
+        if (operationId == null) {
+            return null;
+        }
+        return technologyOperationMapper.selectById(operationId);
     }
 
     private String buildProcessRouteCode(Long id) {

--
Gitblit v1.9.3