From 40ada0315f79eaaa30dce2f246878b3ea0d7493b Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期六, 20 十二月 2025 12:49:48 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java |  197 ++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 193 insertions(+), 4 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 c9c1985..7ae931d 100644
--- a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
@@ -344,9 +344,9 @@
 
             // 鑾峰彇璺緞
             StaDesc staDesc = staDescService.queryCrnStn(ioType, locMast.getCrnNo(), outSta);
-            if(ioType.equals(107)){
-                staDesc = staDescService.queryCrnStnCheck(ioType, locMast.getCrnNo(), outSta);
-            }
+//            if(ioType.equals(107)){
+//                staDesc = staDescService.queryCrnStnCheck(ioType, locMast.getCrnNo(), outSta);
+//            }
 
             // 鐢熸垚宸ヤ綔鍙�
             int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(ioType));
@@ -361,6 +361,7 @@
             wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯
             wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔�
             wrkMast.setSourceLocNo(dto.getLocNo()); // 婧愬簱浣�
+            wrkMast.setBarcode(locMast.getBarcode());
             wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
             wrkMast.setPicking("N"); // 鎷f枡
             wrkMast.setExitMk("N"); // 閫�鍑�
@@ -486,7 +487,194 @@
             }catch (Exception e){}
         }
     }
+    @Override
+    @Transactional
+    public void stockOut(BasDevp staNo,Integer outStaArea, List<LocDetlDto> locDetlDtos, IoWorkType ioWorkType, Long userId) {
+        Date now = new Date();
+        // 鍚堝苟鍚岀被椤�
+        Set<String> locNos = new HashSet<>();
+        List<OutLocDto> dtos = new ArrayList<>();
+        for (LocDetlDto locDetlDto : locDetlDtos) {
+            String locNo = locDetlDto.getLocDetl().getLocNo();
+            if (locNos.contains(locNo)) {
+                for (OutLocDto dto : dtos) {
+                    if (dto.getLocNo().equals(locNo)) {
+                        dto.getLocDetlDtos().add(locDetlDto);
+                        break;
+                    }
+                }
+            } else {
+                locNos.add(locNo);
+                dtos.add(new OutLocDto(locNo, locDetlDto));
+            }
+        }
+        Config configAutoMPArea = configService.selectConfigByCode("AutoMPArea");
 
+        Integer ioType = null;
+        // 鐢熸垚宸ヤ綔妗�
+        for (OutLocDto dto : dtos) {
+            // 鍒ゆ柇鍏ュ嚭搴撶被鍨嬶細101.鍏ㄦ澘鍑哄簱 or 103.鎷f枡鍑哄簱
+            if (ioWorkType == null) {
+                ioType = dto.isAll() ? 101 : 103;
+            } else if (ioWorkType.equals(IoWorkType.CHECK_OUT)) {
+                ioType = 107;
+            }
+            assert ioType != null;
+            // 鑾峰彇搴撲綅
+            LocMast locMast = locMastService.selectById(dto.getLocNo());
+
+            Integer outSta = staNo.getDevNo();
+//            //2鍙峰爢鍨涙満鍏ㄦ澘鍑哄簱绔欐寚瀹氫负204绔欙紝鎷f枡绔欐寚瀹氫负202
+//            if(locMast.getCrnNo()==2){
+//                outSta = ioType == 101 ? 204 : 202;
+//            }
+
+            // 鑾峰彇璺緞
+            StaDesc staDesc = staDescService.queryCrnStn(ioType, locMast.getCrnNo(), outSta);
+//            if(ioType.equals(107)){
+//                staDesc = staDescService.queryCrnStnCheck(ioType, locMast.getCrnNo(), outSta);
+//            }
+
+            // 鐢熸垚宸ヤ綔鍙�
+            int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(ioType));
+            // 鐢熸垚宸ヤ綔妗�
+            WrkMast wrkMast = new WrkMast();
+            wrkMast.setWrkNo(workNo);
+            wrkMast.setIoTime(now);
+            wrkMast.setWrkSts(11L); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID
+            wrkMast.setIoType(ioType); // 鍏ュ嚭搴撶姸鎬�
+            wrkMast.setIoPri(13D); // 浼樺厛绾э細13
+            wrkMast.setCrnNo(locMast.getCrnNo());
+            wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯
+            wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔�
+            wrkMast.setSourceLocNo(dto.getLocNo()); // 婧愬簱浣�
+            wrkMast.setBarcode(locMast.getBarcode());
+            wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+            wrkMast.setPicking("N"); // 鎷f枡
+            wrkMast.setExitMk("N"); // 閫�鍑�
+            wrkMast.setEmptyMk("N"); // 绌烘澘
+            wrkMast.setCtnKind(outStaArea);//
+            wrkMast.setLinkMis("N");
+            wrkMast.setBarcode(locMast.getBarcode());
+            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);
+            wrkMast.setModiTime(now);
+            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;}
+                WrkDetl wrkDetl = new WrkDetl();
+                wrkDetl.sync(detlDto.getLocDetl());
+                wrkDetl.setOrderNo(""); // 鎵嬪姩鍑哄簱涓嶉渶瑕佸甫鍑哄簱瀛樹腑鐨勫崟鎹紪鍙�
+                wrkDetl.setWrkNo(workNo);
+                wrkDetl.setIoTime(now);
+                Double anfme = ioType==101?detlDto.getLocDetl().getAnfme():detlDto.getCount();
+                wrkDetl.setAnfme(anfme); // 鏁伴噺
+                wrkDetl.setAppeTime(now);
+                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槑缁嗗け璐�");
+                }
+            }
+//            if(locMastRgv !=null){
+//                if (Boolean.parseBoolean(config.getValue()) && locMastRgv.getLocNo() != null && ioType != 107) {  //鑻ユ湁绌哄簱浣嶄笖閰嶇疆鍏佽鍒欑粦瀹氬叾澶囨枡搴撲綅鍙�
+//                    //淇敼agv澶囨枡鍖虹姸鎬�
+//                    if(locMastRgv.getLocSts().equals("O") && ioType != 107){
+//                        locMastRgv.setLocSts("S");
+//                        locMastRgv.setModiUser(userId);
+//                        locMastRgv.setModiTime(now);
+//                        if (!locMastService.updateById(locMastRgv)) {
+//                            throw new CoolException("棰勭害agv澶囨枡鍖哄簱浣嶇姸鎬佸け璐ワ紝搴撲綅鍙凤細"+locMastRgv.getLocNo());
+//                        }
+//                    }
+//                }
+//            }
+
+            // 淇敼搴撲綅鐘舵��:   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);
+                if (!locMastService.updateById(locMast)) {
+                    throw new CoolException("棰勭害搴撲綅鐘舵�佸け璐ワ紝搴撲綅鍙凤細"+dto.getLocNo());
+                }
+            } else {
+                log.error(dto.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
+                throw new CoolException(dto.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
+            }
+
+            try{
+                // 澧炲姞AGV搴撳瓨涓浆鏁伴噺
+                if (basAgvLocDetls != null){
+                    for (BasAgvLocDetl basAgvLocDetl : basAgvLocDetls) {
+                        try{
+                            basAgvLocDetlService.insert(basAgvLocDetl);
+                        } catch (Exception e){
+                            log.error("澧炲姞AGV搴撳瓨涓浆鏁伴噺澶辫触");
+                        }
+                    }
+                }
+                if (basAgvWrkDetls != null){
+                    for (BasAgvWrkDetl basAgvWrkDetl : basAgvWrkDetls) {
+                        try{
+                            basAgvWrkDetlService.insert(basAgvWrkDetl);
+                        } catch (Exception e){
+                            log.error("澧炲姞AGV搴撳瓨涓浆鏁伴噺澶辫触");
+                        }
+                    }
+                }
+
+            }catch (Exception e){}
+        }
+    }
     @Override
     @Transactional
     public void stockOut(BasDevp staNo, TaskDto taskDto, Long userId) {
@@ -526,6 +714,7 @@
         wrkMast.setIoType(ioType); // 鍏ュ嚭搴撶姸鎬�
         wrkMast.setIoPri(13D); // 浼樺厛绾э細13
         wrkMast.setCrnNo(locMast.getCrnNo());
+        wrkMast.setBarcode(locMast.getBarcode());
         wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯
         wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔�
         wrkMast.setSourceLocNo(taskDto.getLocNo()); // 婧愬簱浣�
@@ -882,7 +1071,7 @@
             LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", locDetlDtos.get(0).getLocDetl().getLocNo()));
             if (locMast.getLocSts().equals("F")){
                 // 鍚姩鍑哄簱寮�濮� 107.鐩樼偣鍑哄簱
-                stockOut(staNo, locDetlDtos, IoWorkType.CHECK_OUT, userId);
+                stockOut(staNo,param.getOutStaArea(), locDetlDtos, IoWorkType.CHECK_OUT, userId);
             }else {
                 throw new CoolException("鎵�閫夊簱浣嶅瓨鍦ㄧ姸鎬佷笉涓篎鐨勫簱浣嶏紝搴撲綅鍙凤細"+locMast.getLocNo()+" 銆佸綋鍓嶇姸鎬侊細"+locMast.getLocSts()+"-"+locMast.getLocSts$());
             }

--
Gitblit v1.9.1