From 49f306cb470a8ee824204b701796d1d8f63ff223 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期一, 27 十月 2025 17:58:05 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java |  140 ++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 122 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
index 50dea3e..a25fd6d 100644
--- a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
@@ -98,6 +98,12 @@
     @Resource
     private OrderPakoutService orderPakOutService;
 
+    @Resource
+    private BasAgvLocDetlService basAgvLocDetlService;
+
+    @Resource
+    private BasAgvWrkDetlService basAgvWrkDetlService;
+
     @Override
     @Transactional
     public String startupFullPutStore(FullStoreParam param, Long userId) {
@@ -311,14 +317,7 @@
                 dtos.add(new OutLocDto(locNo, locDetlDto));
             }
         }
-        Config config = configService.selectConfigByCode("AutoMPArea");
-
-        List<LocMast> list = locMastMapper.selectList(
-                new EntityWrapper<LocMast>()
-                        .eq("whs_type", 5)
-                        .eq("loc_sts", "O")
-        );
-        LocMast locMastRgv = list.isEmpty() ? null : list.get(0);
+        Config configAutoMPArea = configService.selectConfigByCode("AutoMPArea");
 
         Integer ioType = null;
         // 鐢熸垚宸ヤ綔妗�
@@ -364,12 +363,26 @@
             wrkMast.setEmptyMk("N"); // 绌烘澘
             wrkMast.setLinkMis("N");
             wrkMast.setBarcode(locMast.getBarcode());
-//            if(locMastRgv !=null){
-                if (Boolean.parseBoolean(config.getValue()) && locMastRgv.getLocNo() != null && ioType != 107) {  //鑻ユ湁绌哄簱浣嶄笖閰嶇疆鍏佽鍒欑粦瀹氬叾澶囨枡搴撲綅鍙�
-//                    wrkMast.setLocNo(locMastRgv.getLocNo());
-                    wrkMast.setTakeNone("0");  //0rgv鏈彇锛�1rgv宸插彇璐�
+            wrkMast.setTakeNone("0");  //0闈炶嚜鍔�
+
+            List<BasAgvWrkDetl> basAgvWrkDetls = null;
+            List<BasAgvLocDetl> basAgvLocDetls = null;
+            try{
+                if (Boolean.parseBoolean(configAutoMPArea.getValue())){
+                    if (wrkMast.getStaNoAgvSign()){
+                        if (ioType==101){
+                            // 鍏ㄦ澘鍑哄簱
+                            basAgvLocDetls = new ArrayList<>();
+                        } else {
+                            // 鎷f枡鍑哄簱
+                            basAgvWrkDetls = new ArrayList<>();
+                        }
+                        wrkMast.setTakeNone("1"); //绛夊緟涓嬪彂
+                    } else {
+                        wrkMast.setTakeNone("3");  //鏃犻渶AGV鎼繍
+                    }
                 }
-//            }
+            } catch (Exception e) {}  //閰嶇疆椤逛笉瀛樺湪锛屼笉鍋氬鐞�
             wrkMast.setAppeUser(userId); // 鎿嶄綔浜哄憳鏁版嵁
             wrkMast.setAppeTime(now);
             wrkMast.setModiUser(userId);
@@ -377,6 +390,7 @@
             if (!wrkMastService.insert(wrkMast)) {
                 throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鍑哄簱搴撲綅鍙凤細"+dto.getLocNo());
             }
+
             // 鐢熸垚宸ヤ綔妗f槑缁�
             for (LocDetlDto detlDto : dto.getLocDetlDtos()) {
                 if (detlDto.getCount()==null || detlDto.getCount() <= 0.0D) {continue;}
@@ -391,6 +405,15 @@
                 wrkDetl.setAppeUser(userId);
                 wrkDetl.setModiTime(now);
                 wrkDetl.setModiUser(userId);
+
+                try{
+                    if (basAgvWrkDetls != null){
+                        BasAgvWrkDetl basAgvWrkDetl = new BasAgvWrkDetl();
+                        basAgvWrkDetl.sync(wrkDetl);
+                        basAgvWrkDetls.add(basAgvWrkDetl);
+                    }
+                } catch (Exception e) {}  //閰嶇疆椤逛笉瀛樺湪锛屼笉鍋氬鐞�
+
                 if (!wrkDetlService.insert(wrkDetl)) {
                     throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
                 }
@@ -412,6 +435,18 @@
             // 淇敼搴撲綅鐘舵��:   F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓�
             locMast = locMastService.selectById(dto.getLocNo());
             if (locMast.getLocSts().equals("F")) {
+
+                try{
+                    if (basAgvLocDetls != null){
+                        List<LocDetl> locDetlList = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
+                        for (LocDetl locDetl : locDetlList) {
+                            BasAgvLocDetl basAgvLocDetl = new BasAgvLocDetl();
+                            basAgvLocDetl.sync(locDetl);
+                            basAgvLocDetls.add(basAgvLocDetl);
+                        }
+                    }
+                } catch (Exception e) {}  //閰嶇疆椤逛笉瀛樺湪锛屼笉鍋氬鐞�
+
                 locMast.setLocSts(ioType==101?"R":"P");
                 locMast.setModiUser(userId);
                 locMast.setModiTime(now);
@@ -421,6 +456,21 @@
             } else {
                 throw new CoolException(dto.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
             }
+
+            try{
+                // 澧炲姞AGV搴撳瓨涓浆鏁伴噺
+                if (basAgvLocDetls != null){
+                    for (BasAgvLocDetl basAgvLocDetl : basAgvLocDetls) {
+                        basAgvLocDetlService.insert(basAgvLocDetl);
+                    }
+                }
+                if (basAgvWrkDetls != null){
+                    for (BasAgvWrkDetl basAgvWrkDetl : basAgvWrkDetls) {
+                        basAgvWrkDetlService.insert(basAgvWrkDetl);
+                    }
+                }
+
+            }catch (Exception e){}
         }
     }
 
@@ -434,7 +484,7 @@
                 throw new CoolException("璁㈠崟鍑哄簱寮傚父锛岃鑱旂郴绠$悊鍛�");
             }
         }
-        Config config = configService.selectConfigByCode("AutoMPArea");
+        Config configAutoMPArea = configService.selectConfigByCode("AutoMPArea");
 
         // 鑾峰彇搴撲綅
         LocMast locMast = locMastService.selectById(taskDto.getLocNo());
@@ -466,10 +516,27 @@
         wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯
         wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔�
         wrkMast.setSourceLocNo(taskDto.getLocNo()); // 婧愬簱浣�
-        if (Boolean.parseBoolean(config.getValue()) && locMastRgv.getLocNo() != null) {  //鑻ユ湁绌哄簱浣嶄笖閰嶇疆鍏佽鍒欑粦瀹氬叾澶囨枡搴撲綅鍙�
-            wrkMast.setLocNo(locMastRgv.getLocNo());
-            wrkMast.setTakeNone("0");  //0rgv鏈彇锛�1rgv宸插彇璐�
-        }
+        wrkMast.setTakeNone("0");  //0闈炶嚜鍔�
+
+        List<BasAgvWrkDetl> basAgvWrkDetls = null;
+        List<BasAgvLocDetl> basAgvLocDetls = null;
+        try{
+            if (Boolean.parseBoolean(configAutoMPArea.getValue())){
+                if (wrkMast.getStaNoAgvSign()){
+                    if (ioType==101){
+                        // 鍏ㄦ澘鍑哄簱
+                        basAgvLocDetls = new ArrayList<>();
+                    } else {
+                        // 鎷f枡鍑哄簱
+                        basAgvWrkDetls = new ArrayList<>();
+                    }
+                    wrkMast.setTakeNone("1"); //绛夊緟涓嬪彂
+                } else {
+                    wrkMast.setTakeNone("3");  //鏃犻渶AGV鎼繍
+                }
+            }
+        } catch (Exception e) {}  //閰嶇疆椤逛笉瀛樺湪锛屼笉鍋氬鐞�
+
         wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
         wrkMast.setPicking("N"); // 鎷f枡
         wrkMast.setExitMk("N"); // 閫�鍑�
@@ -506,6 +573,15 @@
             wrkDetl.setAppeUser(userId);
             wrkDetl.setModiTime(now);
             wrkDetl.setModiUser(userId);
+
+            try{
+                if (basAgvWrkDetls != null){
+                    BasAgvWrkDetl basAgvWrkDetl = new BasAgvWrkDetl();
+                    basAgvWrkDetl.sync(wrkDetl);
+                    basAgvWrkDetls.add(basAgvWrkDetl);
+                }
+            } catch (Exception e) {}  //閰嶇疆椤逛笉瀛樺湪锛屼笉鍋氬鐞�
+
             if (!wrkDetlService.insert(wrkDetl)) {
                 throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
             }
@@ -535,6 +611,17 @@
         // 淇敼搴撲綅鐘舵��:   F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓�
         locMast = locMastService.selectById(taskDto.getLocNo());
         if (locMast.getLocSts().equals("F")) {
+            try{
+                if (basAgvLocDetls != null){
+                    List<LocDetl> locDetlList = locDetlService.selectList(new EntityWrapper<LocDetl>().eq("loc_no", locMast.getLocNo()));
+                    for (LocDetl locDetl : locDetlList) {
+                        BasAgvLocDetl basAgvLocDetl = new BasAgvLocDetl();
+                        basAgvLocDetl.sync(locDetl);
+                        basAgvLocDetls.add(basAgvLocDetl);
+                    }
+                }
+            } catch (Exception e) {}  //閰嶇疆椤逛笉瀛樺湪锛屼笉鍋氬鐞�
+
             locMast.setLocSts(ioType==101?"R":"P");
             locMast.setModiUser(userId);
             locMast.setModiTime(now);
@@ -544,6 +631,23 @@
         } else {
             throw new CoolException(taskDto.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
         }
+
+
+
+        try{
+            // 澧炲姞AGV搴撳瓨涓浆鏁伴噺
+            if (basAgvLocDetls != null){
+                for (BasAgvLocDetl basAgvLocDetl : basAgvLocDetls) {
+                    basAgvLocDetlService.insert(basAgvLocDetl);
+                }
+            }
+            if (basAgvWrkDetls != null){
+                for (BasAgvWrkDetl basAgvWrkDetl : basAgvWrkDetls) {
+                    basAgvWrkDetlService.insert(basAgvWrkDetl);
+                }
+            }
+
+        }catch (Exception e){}
     }
 
     @Override

--
Gitblit v1.9.1