From 70a46cd5e65b1ee16fb4bb4954a01129e6898b6d Mon Sep 17 00:00:00 2001
From: sfd <sun.sunshine@163.com>
Date: 星期一, 12 五月 2025 18:29:37 +0800
Subject: [PATCH] Merge branch 'dev' of http://192.168.50.149:8085/r/aps-backend into dev

---
 aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlateStandardRequireServiceImpl.java |   77 ++++++++++++++++++++++++--------------
 1 files changed, 49 insertions(+), 28 deletions(-)

diff --git a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlateStandardRequireServiceImpl.java b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlateStandardRequireServiceImpl.java
index 24e079a..f0c7cc8 100644
--- a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlateStandardRequireServiceImpl.java
+++ b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlateStandardRequireServiceImpl.java
@@ -72,6 +72,8 @@
 
     @Resource
     IApsPlateStandardRequireBatchService requireBatchService;
+    @Autowired
+    private IApsMaterialStorageManagementService storageManagementService;
 
     /**
      * 鏌ヨ閽i噾宸ュ崟鏍囧噯闇�姹�
@@ -166,7 +168,7 @@
         /*瀹氫箟宸ュ巶涓哄崡閫� */
         String plantCode="FORTUNA";
         /*瀹氫箟涓诲崟绫诲瀷涓洪挘閲戜富鍗�*/
-        String mainOrderType = "0";
+        String mainOrderType = "main";
         /*鐢熸垚鏂版壒娆″彿*/
         String batchNum= requireBatchService.getNewBatchNumber();
         /*鑾峰彇閽i噾涓诲崟淇℃伅*/
@@ -177,8 +179,11 @@
             /*褰撳墠Bom鑺傜偣澶勭悊瀹屾垚鍚庯紝澶勭悊涓嬬骇BOM*/
 
             List<ApsPlateStandardRequire> requiresList=new ArrayList<>();
+            List<ApsPlateStandardRequireBomStockDetail> stockDetailsList=new ArrayList<>();
+            List<ApsPlateStandardRequireBomOrderDetail> orderDetailsList=new ArrayList<>();
 
-            getBomRequires(plantCode, "0","0",itemNumber,BigDecimal.ONE, batchNum, null, mainPlan, requiresList, 0L);
+
+            getBomRequires(plantCode, "0","0",itemNumber,BigDecimal.ONE, batchNum, null, mainPlan, requiresList, 0L,stockDetailsList,orderDetailsList);
 
             // 鎵归噺鎻掑叆浠ユ彁楂樻�ц兘
             if (!requiresList.isEmpty()) {
@@ -187,6 +192,24 @@
                     int end = Math.min(i + batchSize, requiresList.size());
                     List<ApsPlateStandardRequire> batch = requiresList.subList(i, end);
                     apsPlateStandardRequireMapper.batchInsert(batch);
+                }
+            }
+
+            if(!stockDetailsList.isEmpty()){
+                int batchSize = 1000;
+                for (int i = 0; i < stockDetailsList.size(); i += batchSize) {
+                    int end = Math.min(i + batchSize, stockDetailsList.size());
+                    List<ApsPlateStandardRequireBomStockDetail> batch = stockDetailsList.subList(i, end);
+                    plateBomStockDetailMapper.batchInsert(batch);
+                }
+            }
+
+            if(!orderDetailsList.isEmpty()){
+                int batchSize = 1000;
+                for (int i = 0; i < orderDetailsList.size(); i += batchSize) {
+                    int end = Math.min(i + batchSize, orderDetailsList.size());
+                    List<ApsPlateStandardRequireBomOrderDetail> batch = orderDetailsList.subList(i, end);
+                    plateBomOrderDetailMapper.batchInsert(batch);
                 }
             }
         }
@@ -205,8 +228,15 @@
      * @param plan 璁″垝瀵硅薄
      * @param allRequires 鎵�鏈夐渶姹傜殑鍒楄〃
      * @param level 灞傜骇
+     * @param stockDetailsList 搴撳瓨鍖归厤璁板綍
+     * @param orderDetailsList 瀛愪欢宸ュ崟鍖归厤璁板綍
      */
-    private void getBomRequires(String plant, String bomHeaderCode, String bomLineId,String itemCode,BigDecimal itemNum, String batchNum, Date upLevelStartDate, ApsPlatePlan plan, List<ApsPlateStandardRequire> allRequires, Long level) {
+    private void getBomRequires(String plant, String bomHeaderCode, String bomLineId,String itemCode,BigDecimal itemNum,
+                                String batchNum, Date upLevelStartDate, ApsPlatePlan plan,
+                                List<ApsPlateStandardRequire> allRequires,
+                                Long level,List<ApsPlateStandardRequireBomStockDetail> stockDetailsList
+                                ,List<ApsPlateStandardRequireBomOrderDetail> orderDetailsList
+    ) {
         /*鏋勫缓闇�姹備俊鎭�*/
         ApsPlateStandardRequire require = new ApsPlateStandardRequire();
         require.setId(IdUtil.getSnowflakeNextId());
@@ -226,8 +256,6 @@
         /*璁$畻闇�姹傛暟閲�*/
         if (level == 0) {
             require.setBomUseAmount(BigDecimal.ONE);
-            require.setCompleteDate(plan.getPlanEndDay());
-            require.setDemandDate(plan.getPlanEndDay());
         } else {
             require.setBomUseAmount(itemNum.multiply(plan.getProductionQuantity()));
         }
@@ -235,7 +263,7 @@
         BigDecimal remainderStock = BigDecimal.ZERO;
         /*榛樿鍑�闇�姹備负BOM鐢ㄩ噺*/
         require.setNetRequirement(require.getBomUseAmount());
-        Optional<ApsMaterialStorageManagement> itemStorage = getItemStorage(plant, itemCode);
+        Optional<ApsMaterialStorageManagement> itemStorage = Optional.of(storageManagementService.getRdsStorage( plant,  itemCode));
         if (itemStorage.isPresent()) {
             ApsMaterialStorageManagement storage = itemStorage.get();
             /*鍓╀綑搴撳瓨*/
@@ -258,13 +286,15 @@
                     require.setNetRequirement(BigDecimal.ZERO);
                 }
                 /*璁板綍搴撳瓨鍓╀綑鏁伴噺锛岃褰曞簱瀛樹娇鐢ㄨ褰�*/
-                bomStockDetailService.saveStorageAndDetail(storage, plan, bomLineId,itemCode, batchNum, deductionAmount, afterStockAmount,require.getId());
+                bomStockDetailService.saveStorageAndDetail(storage, plan, bomLineId,itemCode, batchNum, deductionAmount
+                        , afterStockAmount,require.getId(),stockDetailsList
+                );
             }
         }
         /*鏈尮閰嶆暟閲忥紝榛樿涓哄噣闇�姹�*/
         require.setUnmatchedDemandAmount(require.getNetRequirement());
         /*宸ヨ壓璺嚎鎬婚渶姹�*/
-        ApsStandardProcessRouteLine routeHeader = routeLineService.getRouteLineTotalTime(require);
+        ApsStandardProcessRouteLine routeHeader = routeLineService.getRouteHeaderRouteTime(require);
         String routeId = routeHeader.getRouteId();
         BigDecimal totalRouteTime = routeHeader.getRouteTime();
         long millisecond = 60 * 60 * 1000L;
@@ -311,30 +341,24 @@
             require.setMatchState("寰呭尮閰�");
             require.setMatchMode("宸ュ崟鍖归厤");
             /*浣跨敤瀛愪欢宸ュ崟杩涜闇�姹傚尮閰�*/
-            matchRequireAndSubPlan(require);
+            matchRequireAndSubPlan(require,orderDetailsList);
         }
         allRequires.add(require);
         if (require.getNetRequirement().compareTo(BigDecimal.ZERO) > 0) {
             /*褰撳墠Bom鑺傜偣澶勭悊瀹屾垚鍚庯紝澶勭悊涓嬬骇BOM*/
             long nextLevel=level+1;
-            List<ApsBom> bomLineList = bomLineService.selectApsBomLineList(plant, itemCode);
+            List<ApsBom> bomLineList = bomLineService.selectRdsBomLineList(plant, itemCode);
             if (!bomLineList.isEmpty()) {
                 bomLineList.forEach(line -> {
-                    getBomRequires(plant, itemCode, line.getBomLineId(),line.getItemCode() ,line.getNum() , batchNum, require.getStartDate(), plan, allRequires, nextLevel);
+                    getBomRequires(plant, itemCode, line.getBomLineId(),line.getItemCode() ,line.getNum() , batchNum
+                            , require.getStartDate(), plan, allRequires, nextLevel,stockDetailsList
+                            ,orderDetailsList
+                    );
                 });
             }
         }
     }
-    /**
-     * 鑾峰彇鐗╂枡搴撳瓨淇℃伅
-     * */
-    private Optional<ApsMaterialStorageManagement> getItemStorage(String plant, String itemNumber) {
-        ApsMaterialStorageManagement storageParam = new ApsMaterialStorageManagement();
-        storageParam.setItemNumber(itemNumber);
-        storageParam.setApplicableFactories(plant);
-        return itemStorageMapper.selectApsMaterialStorageManagementList(storageParam).stream()
-                .findFirst();
-    }
+
 
     /**
      * 鑾峰彇閽i噾璁″垝 棰勭暀澶╂暟
@@ -352,12 +376,9 @@
     * 浣跨敤瀛愪欢宸ュ崟鍖归厤闇�姹備腑鐨勫噣闇�姹�
     * */
 
-    private void matchRequireAndSubPlan(ApsPlateStandardRequire require) {
+    private void matchRequireAndSubPlan(ApsPlateStandardRequire require, List<ApsPlateStandardRequireBomOrderDetail> orderDetailsList) {
         BigDecimal netRequirement = require.getNetRequirement();
         require.setMatchMode("宸ュ崟鍖归厤");
-        if(require.getBomLineCode().equals("W0202-100028")){
-            System.out.println("W0202-100028");
-        }
         if (netRequirement.compareTo(BigDecimal.ZERO) > 0) {
             ApsPlatePlan platePlan = apsPlatePlanMapper.selectUnMatchPlateSubPlan(require.getOrgCode(),  require.getBomLineCode());
             /*瀛愪欢宸ュ崟鐨勬湭鍖归厤鏁伴噺 浣滀负褰撳墠鐨勫簱瀛�*/
@@ -367,7 +388,7 @@
                     /* 搴撳瓨鏁伴噺 澶т簬 鍑�闇�姹傛暟閲�*/
                     /* 鍑�闇�姹傛暟閲�=0 锛屽瓙浠跺伐鍗曟湭鍖归厤鏁伴噺= 搴撳瓨-鍑�闇�姹�*/
                     BigDecimal subtract = stock.subtract(netRequirement);
-                    bomOrderDetailService.savePlastPlanAndBomOrderDetail(require, platePlan, subtract, stock, netRequirement);
+                    bomOrderDetailService.savePlastPlanAndBomOrderDetail(require, platePlan, subtract, stock, netRequirement,orderDetailsList);
                     netRequirement = BigDecimal.ZERO;
                     require.setMatchState("宸插尮閰�");
                     require.setUnmatchedDemandAmount(BigDecimal.ZERO);
@@ -377,7 +398,7 @@
                     /*鍑�闇�姹傛暟閲� == 搴撳瓨鏁伴噺*/
 
                     BigDecimal subtract = BigDecimal.ZERO;
-                    bomOrderDetailService.savePlastPlanAndBomOrderDetail(require, platePlan, subtract, stock, netRequirement);
+                    bomOrderDetailService.savePlastPlanAndBomOrderDetail(require, platePlan, subtract, stock, netRequirement,orderDetailsList);
                     netRequirement = BigDecimal.ZERO;
                     require.setMatchState("宸插尮閰�");
                     require.setUnmatchedDemandAmount(BigDecimal.ZERO);
@@ -389,7 +410,7 @@
                     BigDecimal rest = netRequirement.subtract(stock);
                     require.setMatchState("鍖归厤涓�");
                     /*宸ュ崟 鏈尮閰嶆暟閲忎负0 鍏ㄩ儴鐢ㄤ簬鍖归厤闇�姹�*/
-                    bomOrderDetailService.savePlastPlanAndBomOrderDetail(require, platePlan, BigDecimal.ZERO, stock, netRequirement);
+                    bomOrderDetailService.savePlastPlanAndBomOrderDetail(require, platePlan, BigDecimal.ZERO, stock, netRequirement,orderDetailsList);
                     /*鍑�闇�姹傛湭琚弧瓒筹紝闇�瑕佺户缁尮閰�*/
                     platePlan = apsPlatePlanMapper.selectUnMatchPlateSubPlan(require.getOrgCode(),  require.getBomLineCode());
                     /*鍓╀綑鍑�闇�姹�*/

--
Gitblit v1.9.3