From 82bcd0328dddbaad65933e2fada22bc68e82b3d5 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期六, 26 八月 2023 10:07:46 +0800
Subject: [PATCH] # 导入订单增加单据类型

---
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java |  604 ++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 552 insertions(+), 52 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 3f02ed6..239acd3 100644
--- a/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java
@@ -1,6 +1,7 @@
 package com.zy.asrs.service.impl;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.mapper.Wrapper;
 import com.core.common.BaseRes;
@@ -73,6 +74,8 @@
     private OrderDetlService orderDetlService;
     @Autowired
     private WcsController wcsController;
+    @Autowired
+    private WaitPakinService waitPakinService;
     @Autowired
     private RowLastnoService rowLastnoService;
     @Autowired
@@ -159,21 +162,142 @@
     @Override
     @Transactional
     public void startupFullTakeStore(StockOutParam param, Long userId) {
-        ArrayList<String> locNos = new ArrayList<>();
-        for (StockOutParam.LocDetl locDetl:param.getLocDetls()){
-            if (!locNos.contains(locDetl.getLocNo())){
-                locNos.add(locDetl.getLocNo());
-            }
+        List<StockOutParam.LocDetl> locDetls = new ArrayList<>();
+        List<String> locs = new ArrayList<>();
+        for(StockOutParam.LocDetl one : param.getLocDetls()){
+            locs.add(one.getLocNo());
         }
+        for (StockOutParam.LocDetl locDetl : param.getLocDetls()) {
+            //鑾峰彇鍚屼竴搴撲綅缁勭殑澶栦晶搴撲綅鍙�
+            List<String> groupOuterSingleLoc = Utils.getGroupOuterSingleLoc(locDetl.getLocNo());
+            if (Utils.getBay(locDetl.getLocNo())>=21){
+                groupOuterSingleLoc = Utils.getGroupOuterSingleLocLowFrequency(locDetl.getLocNo());
+            }
 
-        //妫�娴嬫彁浜ょ殑鍑哄簱搴撲綅鏄惁鍚堟硶(娴呭簱浣嶆湁闈炵┖搴撲綅)
-        Utils.checkStockOutLocNo(locNos);
+            for (String locNo : groupOuterSingleLoc) {
+                //姣忎釜搴撲綅鐨勫簱浣嶆槑缁�
+                if(locs.contains(locNo)) continue;
+                for (LocDetl detl : locDetlService.selectByLocNo(locNo)) {
+                    if (!detl.getMatnr().equals(locDetl.getMatnr())) {
+                        //涓嶆槸鐩稿悓鐗╂枡
+                        if (Utils.getBay(locDetl.getLocNo())>=21){
+                            locDetls.add(new StockOutParam.LocDetl(detl.getLocNo(), detl.getMatnr(), detl.getBatch(), detl.getAnfme()));
+                        }
+                        continue;
+                    }
+                    locDetls.add(new StockOutParam.LocDetl(detl.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), detl.getAnfme()));
+                }
+
+            }
+            locDetls.add(locDetl);
+        }
+        //鍑哄簱鏃讹紝濡傛灉褰撳墠搴撲綅缁勬湁鐩稿悓鐨勭墿鏂欙紝鍒欏厛鍑哄渚х墿鏂� 6.30鏃� 娉ㄩ噴
+        //for (StockOutParam.LocDetl locDetl : param.getLocDetls()) {
+        //    List<String> outerSingleLoc = Utils.getGroupOuterSingleLoc(locDetl.getLocNo());
+        //    boolean flag = false;
+        //    Double useCount = 0D;
+        //    for (String locNo : outerSingleLoc) {
+        //        if(locs.contains(locNo)) continue;
+        //        for (LocDetl locDetl0 : locDetlService.selectByLocNo(locNo)) {
+        //            if (!locDetl0.getMatnr().equals(locDetl.getMatnr())) {
+        //                //涓嶆槸鐩稿悓鐗╂枡
+        //                continue;
+        //            }
+        //            double lastCount = locDetl.getCount() - useCount;//鍓╀綑鎵�闇�鏁伴噺
+        //            double realCount = 0;//瀹為檯鎻愪緵鏁伴噺
+        //            if (lastCount==0){
+        //                continue;
+        //            }
+        //            if (locDetl0.getAnfme() >= lastCount) {//瀹為檯鏁伴噺澶т簬鎵�闇�鏁伴噺锛屾寜鎵�闇�鏁伴噺鎻愪緵
+        //                realCount = lastCount;
+        //            } else {
+        //                //瀹為檯灏忎簬鎵�闇�鏁伴噺锛屾寜瀹為檯鏁伴噺鎻愪緵
+        //                realCount = locDetl0.getAnfme();
+        //            }
+        //            useCount += realCount;//宸蹭娇鐢ㄧ殑鏁伴噺
+        //
+        //            locDetls.add(new StockOutParam.LocDetl(locDetl0.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), realCount));
+        //            flag = true;
+        //            if (useCount >= locDetl.getCount()) {
+        //                //鎵惧埌鐨勫簱瀛� >= 鎵�闇�搴撳瓨锛屾弧瓒虫潯浠�
+        //                break;
+        //            }
+        //        }
+        //    }
+        //
+        //    if (!flag) {
+        //        locDetls.add(locDetl);
+        //    }
+        //
+        //}
+
+        // TODO: 2023/6/28 绛夋潕钖囩‘璁ゆ槸鍚︿娇鐢�
+        // ----------------------------------------------
+        //for(StockOutParam.LocDetl one : param.getLocDetls()){
+        //    List<String> outerSingleLoc = Utils.getGroupOuterSingleLoc(one.getLocNo());
+        //    for (String s : outerSingleLoc) {
+        //        if (!locs.contains(s)) {
+        //            throw new CoolException("娴呭簱浣嶆湁鐩稿悓鐗╂枡涓嶆敮鎸佸嚭搴�");
+        //        }
+        //    }
+        //}
+        // ----------------------------------------------
+
+//        ArrayList<String> locNos = new ArrayList<>();
+//        for (StockOutParam.LocDetl locDetl:param.getLocDetls()){
+//            if (!locNos.contains(locDetl.getLocNo())){
+//                locNos.add(locDetl.getLocNo());
+//            }
+//        }
+//        List<StockOutParam.LocDetl> locDetls = param.getLocDetls();
+
+
+
+//        ArrayList<String> locNos = new ArrayList<>();
+//        List<StockOutParam.LocDetl> locDetls = new ArrayList<>();
+//        ArrayList<String> matnrs = new ArrayList<>();//鐩殑鍋氭暟鎹幓閲�
+//        for (StockOutParam.LocDetl locDetl : param.getLocDetls()) {
+//            if (!matnrs.contains(locDetl.getMatnr())) {
+//                matnrs.add(locDetl.getMatnr());
+//
+//                //1.鏍规嵁鐗╂枡鍙峰厛鎼滅储楂橀鍖哄煙鏄惁鏈夊簱瀛�
+//                List<StockOutParam.LocDetl> locNoStep1 = this.findLocNoStep1(locDetl);
+//                if (locNoStep1 != null) {
+//                    locDetls.addAll(locNoStep1);
+//                    continue;
+//                }
+//
+//                //楂橀娣锋斁鍖哄煙娌℃湁婊¤冻鐨勫簱浣嶏紝鍦ㄥ崟鍝佸尯鍩熻繘琛屾悳绱�
+//                List<StockOutParam.LocDetl> locNoStep2 = this.findLocNoStep2(locDetl);
+//                if (locNoStep2 != null) {
+//                    locDetls.addAll(locNoStep2);
+//                    continue;
+//                }
+//
+//                //浣庨娣锋斁鍖哄煙杩涜鎼滅储
+//                List<StockOutParam.LocDetl> locNoStep3 = this.findLocNoStep3(locDetl);
+//                if (locNoStep3 != null) {
+//                    locDetls.addAll(locNoStep3);
+//                    continue;
+//                }
+//
+//            }
+//        }
+//
+//        for (StockOutParam.LocDetl locDetl : locDetls) {
+//            if (!locNos.contains(locDetl.getLocNo())) {
+//                locNos.add(locDetl.getLocNo());
+//            }
+//        }
+
+//        //妫�娴嬫彁浜ょ殑鍑哄簱搴撲綅鏄惁鍚堟硶(娴呭簱浣嶆湁闈炵┖搴撲綅)
+//        Utils.checkStockOutLocNo(locNos);
 
         // 鐩爣绔欑偣鐘舵�佹娴�
         BasDevp staNo = basDevpService.checkSiteStatus(param.getOutSite());
         // 鑾峰彇搴撲綅鏄庣粏
         List<LocDetlDto> locDetlDtos = new ArrayList<>();
-        for (StockOutParam.LocDetl paramLocDetl : param.getLocDetls()) {
+        for (StockOutParam.LocDetl paramLocDetl : locDetls) {
             if (!Cools.isEmpty(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getCount())) {
                 LocDetl one = locDetlService.selectItem(paramLocDetl.getLocNo(), paramLocDetl.getMatnr(), paramLocDetl.getBatch());
                 if (null != one) locDetlDtos.add(new LocDetlDto(one, paramLocDetl.getCount()));
@@ -192,9 +316,146 @@
         }
     }
 
+    //1.鏍规嵁鐗╂枡鍙峰厛鎼滅储楂橀鍖哄煙鏄惁鏈夊簱瀛�
+    private List<StockOutParam.LocDetl> findLocNoStep1(StockOutParam.LocDetl locDetl) {
+        List<StockOutParam.LocDetl> locDetlList = new ArrayList<>();
+        //1.鏍规嵁鐗╂枡鍙峰厛鎼滅储楂橀鍖哄煙鏄惁鏈夊簱瀛�
+        List<LocDetl> locDetls = locDetlService.findHighAreaByMatnr(locDetl.getMatnr());
+        if (locDetls.size() > 0) {
+            for (LocDetl locDetl0 : locDetls) {
+                if (locDetl0.getAnfme() >= locDetl.getCount()) {
+                    //鎵惧埌鐨勫簱瀛� >= 鎵�闇�搴撳瓨锛屾弧瓒虫潯浠�
+                    locDetlList.add(new StockOutParam.LocDetl(locDetl0.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), locDetl.getCount()));
+                    return locDetlList;
+                } else {
+                    //涓嶆弧瓒冲簱瀛樻潯浠�
+                    //鍒ゆ柇鏈�澶栦晶搴撲綅鐨勬繁澶勬槸鍚︽湁鐩稿悓鐗╂枡
+                    Double useCount = locDetl0.getAnfme();//宸蹭娇鐢ㄧ殑鏁伴噺
+                    List<StockOutParam.LocDetl> tmpLocDetlList = new ArrayList<>();//璁板綍缁忚繃鐨勫簱浣�
+                    tmpLocDetlList.add(new StockOutParam.LocDetl(locDetl0.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), locDetl0.getAnfme()));
+
+                    List<String> insideLoc = Utils.getGroupInsideLoc(locDetl0.getLocNo());
+                    List<LocDetl> locDetls1 = locDetlService.selectByLocNosAndMatnr(insideLoc, locDetl.getMatnr());
+                    if (locDetls1.size() == 0) {//鍐呬晶搴撲綅娌℃湁鐩稿悓鐨勭墿鏂欙紝璺宠繃
+                        continue;
+                    }
+                    int locRow = Utils.getRow(locDetl0.getLocNo());
+                    switch (locRow) {
+                        case 3:
+                        case 11:
+                        case 18:
+                            Collections.reverse(locDetls1);
+                            break;
+                    }
+                    for (LocDetl detl : locDetls1) {
+                        double lastCount = locDetl.getCount() - useCount;//鍓╀綑鎵�闇�鏁伴噺
+                        double realCount = 0;//瀹為檯鎻愪緵鏁伴噺
+                        if (detl.getAnfme() >= lastCount) {//瀹為檯鏁伴噺澶т簬鎵�闇�鏁伴噺锛屾寜鎵�闇�鏁伴噺鎻愪緵
+                            realCount = lastCount;
+                        }else {
+                            //瀹為檯灏忎簬鎵�闇�鏁伴噺锛屾寜瀹為檯鏁伴噺鎻愪緵
+                            realCount = detl.getAnfme();
+                        }
+                        useCount += realCount;
+                        tmpLocDetlList.add(new StockOutParam.LocDetl(detl.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), realCount));
+                        if (useCount >= locDetl.getCount()) {
+                            //鎵惧埌鐨勫簱瀛� >= 鎵�闇�搴撳瓨锛屾弧瓒虫潯浠�
+                            locDetlList.addAll(tmpLocDetlList);
+                            return locDetlList;
+                        }
+                    }
+
+                }
+            }
+
+            //鏈�澶栦晶鍖呮嫭鍐呬晶閮芥棤婊¤冻搴撲綅锛屽垯鍒ゆ柇鎼滅储鍑烘潵鐨勫叏閮ㄦ渶澶栦晶搴撲綅鍔犺捣鏉ユ槸鍚︽弧瓒冲嚭搴撴暟閲忚姹�
+            Double useCount = 0D;
+            for (LocDetl locDetl0 : locDetls) {
+                double lastCount = locDetl.getCount() - useCount;//鍓╀綑鎵�闇�鏁伴噺
+                double realCount = 0;//瀹為檯鎻愪緵鏁伴噺
+                if (locDetl0.getAnfme() >= lastCount) {//瀹為檯鏁伴噺澶т簬鎵�闇�鏁伴噺锛屾寜鎵�闇�鏁伴噺鎻愪緵
+                    realCount = lastCount;
+                }else {
+                    //瀹為檯灏忎簬鎵�闇�鏁伴噺锛屾寜瀹為檯鏁伴噺鎻愪緵
+                    realCount = locDetl0.getAnfme();
+                }
+                useCount += realCount;//宸蹭娇鐢ㄧ殑鏁伴噺
+                locDetlList.add(new StockOutParam.LocDetl(locDetl0.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), realCount));
+                if (useCount >= locDetl.getCount()) {
+                    //鎵惧埌鐨勫簱瀛� >= 鎵�闇�搴撳瓨锛屾弧瓒虫潯浠�
+                    return locDetlList;
+                }
+            }
+        }
+
+        return null;
+    }
+
+    //楂橀娣锋斁鍖哄煙娌℃湁婊¤冻鐨勫簱浣嶏紝鍦ㄥ崟鍝佸尯鍩熻繘琛屾悳绱�
+    private List<StockOutParam.LocDetl> findLocNoStep2(StockOutParam.LocDetl locDetl) {
+        List<StockOutParam.LocDetl> locDetlList = new ArrayList<>();
+        //鍦ㄥ崟鍝佸尯鍩熻繘琛屾悳绱�
+        List<LocDetl> locDetls = locDetlService.findSingleAreaByMatnr(locDetl.getMatnr());
+        if (locDetls.size() > 0) {
+            Double useCount = 0D;
+            for (LocDetl locDetl0 : locDetls) {
+                double lastCount = locDetl.getCount() - useCount;//鍓╀綑鎵�闇�鏁伴噺
+                double realCount = 0;//瀹為檯鎻愪緵鏁伴噺
+                if (locDetl0.getAnfme() >= lastCount) {//瀹為檯鏁伴噺澶т簬鎵�闇�鏁伴噺锛屾寜鎵�闇�鏁伴噺鎻愪緵
+                    realCount = lastCount;
+                } else {
+                    //瀹為檯灏忎簬鎵�闇�鏁伴噺锛屾寜瀹為檯鏁伴噺鎻愪緵
+                    realCount = locDetl0.getAnfme();
+                }
+                useCount += realCount;//宸蹭娇鐢ㄧ殑鏁伴噺
+
+                locDetlList.add(new StockOutParam.LocDetl(locDetl0.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), realCount));
+                if (useCount >= locDetl.getCount()) {
+                    //鎵惧埌鐨勫簱瀛� >= 鎵�闇�搴撳瓨锛屾弧瓒虫潯浠�
+                    return locDetlList;
+                }
+            }
+
+            //搴撳瓨鏁伴噺涓嶆弧瓒�
+            throw new CoolException("鍗曞搧鍖哄煙鍙湁" + useCount + "涓揣鐗�");
+        }
+
+        return null;
+    }
+
+    //浣庨娣锋斁鍖哄煙杩涜鎼滅储
+    private List<StockOutParam.LocDetl> findLocNoStep3(StockOutParam.LocDetl locDetl) {
+        List<StockOutParam.LocDetl> locDetlList = new ArrayList<>();
+        //鍦ㄥ崟鍝佸尯鍩熻繘琛屾悳绱�
+        List<LocDetl> locDetls = locDetlService.findLowAreaByMatnr(locDetl.getMatnr());
+        if (locDetls.size() > 0) {
+            Double useCount = 0D;
+            for (LocDetl locDetl0 : locDetls) {
+                double lastCount = locDetl.getCount() - useCount;//鍓╀綑鎵�闇�鏁伴噺
+                double realCount = 0;//瀹為檯鎻愪緵鏁伴噺
+                if (locDetl0.getAnfme() >= lastCount) {//瀹為檯鏁伴噺澶т簬鎵�闇�鏁伴噺锛屾寜鎵�闇�鏁伴噺鎻愪緵
+                    realCount = lastCount;
+                }else {
+                    //瀹為檯灏忎簬鎵�闇�鏁伴噺锛屾寜瀹為檯鏁伴噺鎻愪緵
+                    realCount = locDetl0.getAnfme();
+                }
+                useCount += realCount;//宸蹭娇鐢ㄧ殑鏁伴噺
+
+                locDetlList.add(new StockOutParam.LocDetl(locDetl0.getLocNo(), locDetl.getMatnr(), locDetl.getBatch(), realCount));
+                if (useCount >= locDetl.getCount()) {
+                    //鎵惧埌鐨勫簱瀛� >= 鎵�闇�搴撳瓨锛屾弧瓒虫潯浠�
+                    return locDetlList;
+                }
+            }
+        }
+
+        return null;
+    }
+
     @Override
     @Transactional
     public void stockOut(BasDevp staNo, List<LocDetlDto> locDetlDtos, IoWorkType ioWorkType, Long userId) {
+        Integer basDevp = staNo.getDevNo();
         Date now = new Date();
         // 鍚堝苟鍚岀被椤�
         Set<String> locNos = new HashSet<>();
@@ -225,6 +486,141 @@
                 }
             }
 
+            //-----------------2023.5.31涓婃灦鍖哄煙鐗堟湰鍏煎浠g爜-----------------------
+            //鍒ゆ柇褰撳墠搴撲綅缁勬槸鍚﹀潎涓哄悓涓�绉嶇墿鏂欙紝濡備笉鏄紝鍒欒瀹氶渶瑕佹墽琛屽吋瀹逛唬鐮�
+            //闇�瑕佸皢寰呭嚭搴撳簱浣嶅墠渚у簱浣�(涓嶅寘鍚渶澶栦晶楂橀搴撲綅)鎵ц101鍏ㄦ澘鍑哄簱
+            String locNo = dto.getLocNo();
+            String matnr = null;
+            for (LocDetlDto locDetlDto : dto.getLocDetlDtos()) {
+                LocDetl locDetl = locDetlDto.getLocDetl();
+                if (locDetl.getLocNo().equals(locNo)) {
+                    matnr = locDetl.getMatnr();
+                }
+            }
+
+            List<String> outerLocs = Utils.getGroupOuterSingleLoc(locNo);
+            Double wrkPri = 15D;
+            for (String outerLoc : outerLocs) {
+                LocMast locMast = locMastService.selectById(outerLoc);
+                if (locMast == null) {
+                    continue;
+                }
+
+                if (!locMast.getLocSts().equals("F")) {
+                    continue;
+                }
+                //if (locMast.getLocSts().equals("F")) {
+                //    throw new CoolException("娴呭簱浣嶅湪搴撲笉鏀寔姝や换鍔�");
+                //}
+                boolean flag = false;
+                for (LocDetl locDetl : locDetlService.selectByLocNo(locMast.getLocNo())) {
+                    if (!locDetl.getMatnr().equals(matnr)) {
+                        flag = true;
+                        break;
+                    }else if (!Cools.isEmpty(ioWorkType) && ioWorkType.equals(IoWorkType.CHECK_OUT)){
+                        flag = true;
+                        break;
+                    }
+                }
+
+                if (flag) {
+                    //褰撳墠宸烽亾瀛樺湪涓嶅悓瑙勬牸鐨勭墿鏂欙紝闇�瑕佽繘琛�101鍏ㄦ澘鍑哄簱
+                    // 鑾峰彇璺緞
+                    StaDesc staDesc = staDescService.queryCrnStn(101, locMast.getCrnNo(), locMast.getCrnNo()==1? 100:200 , locMast.getRow1());
+                    if(staDesc == null){
+                        throw new CoolException("鍑哄簱璺緞涓嶅瓨鍦�");
+                    }
+
+                    // 鐢熸垚宸ヤ綔鍙�
+                    int workNo = commonService.getWorkNo(WorkNoType.getWorkNoType(101));
+                    // 鐢熸垚宸ヤ綔妗�
+                    WrkMast wrkMast = new WrkMast();
+                    wrkMast.setWrkNo(workNo);
+                    wrkMast.setIoTime(now);
+                    wrkMast.setWrkSts(11L); // 宸ヤ綔鐘舵�侊細11.鐢熸垚鍑哄簱ID
+                    wrkMast.setIoType(101); // 鍏ュ嚭搴撶姸鎬�101鍏ㄦ澘鍑哄簱
+                    wrkPri += 2D;
+                    wrkMast.setIoPri(wrkPri); // 浼樺厛绾�
+                    wrkMast.setOutMost(0);
+                    wrkMast.setCrnNo(locMast.getCrnNo());
+                    wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯
+                    wrkMast.setStaNo(locMast.getCrnNo()==1? 100:200); // 鐩爣绔�
+                    wrkMast.setSourceLocNo(locMast.getLocNo()); // 婧愬簱浣�
+                    wrkMast.setFullPlt("Y"); // 婊℃澘锛歒
+                    wrkMast.setPicking("N"); // 鎷f枡
+                    wrkMast.setExitMk("N"); // 閫�鍑�
+                    wrkMast.setEmptyMk("N"); // 绌烘澘
+                    wrkMast.setLinkMis("N");
+                    wrkMast.setBarcode(locMast.getBarcode());
+                    wrkMast.setAppeUser(userId); // 鎿嶄綔浜哄憳鏁版嵁
+                    wrkMast.setAppeTime(now);
+                    wrkMast.setModiUser(userId);
+                    wrkMast.setModiTime(now);
+                    if (!wrkMastService.insert(wrkMast)) {
+                        throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鍑哄簱搴撲綅鍙凤細" + dto.getLocNo());
+                    }
+                    // 鐢熸垚宸ヤ綔妗f槑缁�
+                    for (LocDetl locDetl : locDetlService.selectByLocNo(locMast.getLocNo())) {
+                        WrkDetl wrkDetl = new WrkDetl();
+                        wrkDetl.sync(locDetl);
+                        wrkDetl.setOrderNo(""); // 鎵嬪姩鍑哄簱涓嶉渶瑕佸甫鍑哄簱瀛樹腑鐨勫崟鎹紪鍙�
+                        wrkDetl.setWrkNo(workNo);
+                        wrkDetl.setIoTime(now);
+                        wrkDetl.setAnfme(locDetl.getAnfme()); // 鏁伴噺
+                        wrkDetl.setAppeTime(now);
+                        wrkDetl.setAppeUser(userId);
+                        wrkDetl.setModiTime(now);
+                        wrkDetl.setModiUser(userId);
+                        wrkDetl.setSpecs(locDetl.getSpecs());
+                        wrkDetl.setMatType(locDetl.getMatType());
+                        wrkDetl.setZpallet(locMast.getBarcode());
+                        if (!wrkDetlService.insert(wrkDetl)) {
+                            throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
+                        }
+
+                        Mat mat = matService.selectByMatnr(locDetl.getMatnr());
+                        if (Cools.isEmpty(mat)) {
+                            throw new CoolException(locDetl.getMatnr() + "鍟嗗搧妗f涓嶅瓨鍦�");
+                        }
+                        int zpallet = waitPakinService.selectCount(new EntityWrapper<WaitPakin>().eq("zpallet", locDetl.getZpallet()).ne("loc_no",locDetl.getLocNo()));
+                        if (zpallet>0) {
+                            throw new CoolException(locDetl.getZpallet() + "鍏ュ簱閫氱煡妗d腑宸插瓨鍦�");
+                        }
+                        WaitPakin waitPakin = new WaitPakin();
+                        waitPakin.sync(mat);
+                        waitPakin.setBatch("");
+                        waitPakin.setZpallet(locMast.getBarcode());   // 鎵樼洏鐮�
+                        waitPakin.setIoStatus("N");     // 鍏ュ嚭鐘舵��
+                        waitPakin.setAnfme(locDetl.getAnfme());  // 鏁伴噺
+                        waitPakin.setStatus("Y");    // 鐘舵��
+                        waitPakin.setAppeUser(userId);
+                        waitPakin.setAppeTime(now);
+                        waitPakin.setModiUser(userId);
+                        waitPakin.setModiTime(now);
+                        waitPakin.setMemo(locDetl.getMemo());
+                        waitPakin.setFrozen(0); // 鏄惁鍐荤粨
+                        waitPakin.setManu(locDetl.getManu());
+                        waitPakin.setMatType(mat.getMatType());//鐗╂枡绫诲瀷
+                        if (!waitPakinService.insert(waitPakin)) {
+                            throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�");
+                        }
+                    }
+                    // 淇敼搴撲綅鐘舵��:   F.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害
+                    if (locMast.getLocSts().equals("F")) {
+                        locMast.setLocSts("R");
+                        locMast.setModiUser(userId);
+                        locMast.setModiTime(now);
+                        if (!locMastService.updateById(locMast)) {
+                            throw new CoolException("棰勭害搴撲綅鐘舵�佸け璐ワ紝搴撲綅鍙凤細" + dto.getLocNo());
+                        }
+                    } else {
+                        throw new CoolException(dto.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
+                    }
+                }
+
+            }
+            //-----------------2023.5.31涓婃灦鍖哄煙鐗堟湰鍏煎浠g爜end-----------------------
+
             // 鍒ゆ柇鍏ュ嚭搴撶被鍨嬶細101.鍏ㄦ澘鍑哄簱 or 103.鎷f枡鍑哄簱
             if (ioWorkType == null) {
                 ioType = dto.isAll() ? 101 : 103;
@@ -237,6 +633,34 @@
             assert ioType != null;
             // 鑾峰彇搴撲綅
             LocMast locMast = locMastService.selectById(dto.getLocNo());
+
+            //-----------------2023.6.2鍑哄簱鍏煎浠g爜-----------------------
+            if (ioType!=107){
+                List<LocDetl> locDetls = locDetlService.selectByLocNo(locMast.getLocNo());
+                //if (locMast.getLocType2() == 1 && locDetls.size() > 1) {
+                //    //鍗曞搧鍖哄煙鍑哄簱鐗╂枡澶т簬1绉嶏紝寮哄埗鍙樻垚101鍏ㄦ澘鍑哄簱
+                //    ioType = 101;
+                //    if (staNo.getDevNo()==300){
+                //        staNo.setDevNo(200);
+                //    }
+                //}
+                if (ioType == 101) {
+                    if (staNo.getDevNo()==300){
+                        if(locMast.getCrnNo() == 1) {
+                            staNo.setDevNo(100);
+                        } else {
+                            staNo.setDevNo(200);
+                        }
+
+                    }
+                } else {
+                    staNo.setDevNo(basDevp);
+                }
+
+
+            }
+            //-----------------2023.6.2鍑哄簱鍏煎浠g爜end-----------------------
+
             // 鑾峰彇璺緞
             StaDesc staDesc = staDescService.queryCrnStn(ioType, locMast.getCrnNo(), staNo.getDevNo(), locMast.getRow1());
             if(staDesc == null){
@@ -288,6 +712,8 @@
                 wrkDetl.setModiTime(now);
                 wrkDetl.setModiUser(userId);
                 wrkDetl.setSpecs(detlDto.getLocDetl().getSpecs());
+                wrkDetl.setMatType(detlDto.getLocDetl().getMatType());
+                wrkDetl.setZpallet(locMast.getBarcode());
                 if (!wrkDetlService.insert(wrkDetl)) {
                     throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
                 }
@@ -312,6 +738,54 @@
     @Transactional
     public void stockOut(BasDevp staNo, TaskDto taskDto, Long userId) {
         Date now = new Date();
+        if (Cools.isEmpty(taskDto.getLocDtos()) || taskDto.getLocDtos().size()==0){
+            // 鑾峰彇搴撲綅
+            LocMast locMast = locMastService.selectById(taskDto.getLocNo());
+            // 鑾峰彇璺緞
+            int ioType = locMast.getLocSts().equals("D") ? 110 : 101;
+            StaDesc staDesc = staDescService.queryCrnStnAuto(ioType, locMast.getCrnNo(), staNo.getDevNo());
+            // 鐢熸垚宸ヤ綔鍙�
+            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); // 鍏ュ嚭搴撶姸鎬�
+            Double ioPri = wrkMastService.getIoPri(ioType, taskDto.getLocNo());
+            wrkMast.setIoPri(ioPri); // 浼樺厛绾э細13
+            wrkMast.setOutMost(locMastService.isOutMost(taskDto.getLocNo(), false) ? 1 : 0);
+            wrkMast.setCrnNo(locMast.getCrnNo());
+            wrkMast.setSourceStaNo(staDesc.getCrnStn()); // 婧愮珯
+            wrkMast.setStaNo(staDesc.getStnNo()); // 鐩爣绔�
+            wrkMast.setSourceLocNo(taskDto.getLocNo()); // 婧愬簱浣�
+            wrkMast.setFullPlt(ioType==110? "N":"Y"); // 婊℃澘锛歒
+            wrkMast.setPicking("N"); // 鎷f枡
+            wrkMast.setExitMk("N"); // 閫�鍑�
+            wrkMast.setEmptyMk(ioType==110? "Y":"N"); // 绌烘澘
+            wrkMast.setLinkMis("N");
+            wrkMast.setBarcode(locMast.getBarcode());
+            wrkMast.setAppeUser(userId); // 鎿嶄綔浜哄憳鏁版嵁
+            wrkMast.setAppeTime(now);
+            wrkMast.setModiUser(userId);
+            wrkMast.setModiTime(now);
+            if (!wrkMastService.insert(wrkMast)) {
+                throw new CoolException("淇濆瓨宸ヤ綔妗eけ璐ワ紝鍑哄簱搴撲綅鍙凤細" + taskDto.getLocNo());
+            }
+            // 淇敼搴撲綅鐘舵��:   F銆丏.鍦ㄥ簱 ====>>> R.鍑哄簱棰勭害/P.鎷f枡/鐩樼偣/骞舵澘鍑哄簱涓�
+            locMast = locMastService.selectById(taskDto.getLocNo());
+            if (locMast.getLocSts().equals("F") || locMast.getLocSts().equals("D") ) {
+                locMast.setLocSts("R");
+                locMast.setModiUser(userId);
+                locMast.setModiTime(now);
+                if (!locMastService.updateById(locMast)) {
+                    throw new CoolException("棰勭害搴撲綅鐘舵�佸け璐ワ紝搴撲綅鍙凤細" + taskDto.getLocNo());
+                }
+            } else {
+                throw new CoolException(taskDto.getLocNo() + "搴撲綅涓嶆槸鍦ㄥ簱鐘舵��");
+            }
+            return;
+        }
         List<LocDto> locDtos = taskDto.getLocDtos();
         for (LocDto locDto : locDtos) {
             if (!taskDto.getLocNo().equals(locDto.getLocNo()) && !taskDto.getStaNo().equals(locDto.getStaNo())) {
@@ -374,54 +848,76 @@
             wrkDetl.setAppeUser(userId);
             wrkDetl.setModiTime(now);
             wrkDetl.setModiUser(userId);
+            wrkDetl.setMatType(locDetl.getMatType());
             if (!wrkDetlService.insert(wrkDetl)) {
                 throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
             }
-            // 淇敼璁㈠崟鏄庣粏
-            if (!BaseController.isJSON(locDto.getOrderNo())) {
-                String[] orderNos = GetOrderNo(locDto.getOrderNo());
-                if (!Cools.isEmpty(orderNos)){
-                    Double anfme = locDto.getAnfme();
-                    for (String orderNo : orderNos) {
-                        OrderDetl orderDetl = orderDetlService.selectItem(orderNo, locDto.getMatnr(), locDto.getBatch());
-                        if (orderDetl == null) {
-                            orderDetl = orderDetlService.selectItem(orderNo, locDto.getMatnr(), null);
+            if (!wrkDetl.getOrderNo().equals("浼寸敓鍑哄簱")){
+                // 淇敼璁㈠崟鏄庣粏
+                if (!BaseController.isJSON(locDto.getOrderNo())) {
+                    String[] orderNos = GetOrderNo(locDto.getOrderNo());
+                    if (!Cools.isEmpty(orderNos) && orderNos.length!=0){
+                        Double anfme = locDto.getAnfme();
+                        for (String orderNo : orderNos) {
+                            OrderDetl orderDetl = orderDetlService.selectItem(orderNo, locDto.getMatnr(), locDto.getBatch());
+                            if (orderDetl == null) {
+                                orderDetl = orderDetlService.selectItem(orderNo, locDto.getMatnr(), null);
+                            }
+                            if (orderDetl.getAnfme() <= anfme) {
+                                if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getAnfme())) {
+                                    throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
+                                }
+                                anfme = anfme - orderDetl.getAnfme();
+                            } else {
+                                if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), anfme)) {
+                                    throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
+                                }
+                            }
+                            orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);
                         }
-                        if (orderDetl.getAnfme() <= anfme) {
-                            if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDetl.getAnfme())) {
-                                throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
-                            }
-                            anfme = anfme - orderDetl.getAnfme();
-                        } else {
-                            if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), anfme)) {
-                                throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
-                            }
+                    }else {
+                        OrderDetl orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());
+                        if (orderDetl == null) {
+                            orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null);
+                        }
+                        if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme())) {
+                            throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
                         }
                         orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);
                     }
-                }else {
-                    OrderDetl orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());
-                    if (orderDetl == null) {
-                        orderDetl = orderDetlService.selectItem(locDto.getOrderNo(), locDto.getMatnr(), null);
-                    }
-                    if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), locDto.getAnfme())) {
-                        throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
-                    }
-                    orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);
-                }
-            } else {
-                // 璁㈠崟鍚堝苟鍑哄簱
-                List<OrderDto> orderDtoList = JSON.parseArray(locDto.getOrderNo(), OrderDto.class);
+                } else {
+                    // 璁㈠崟鍚堝苟鍑哄簱
+                    List<OrderDto> orderDtoList = JSON.parseArray(locDto.getOrderNo(), OrderDto.class);
 
-                for (OrderDto orderDto : orderDtoList) {
-                    OrderDetl orderDetl = orderDetlService.selectItem(orderDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());
-                    if (orderDetl == null) {
-                        orderDetl = orderDetlService.selectItem(orderDto.getOrderNo(), locDto.getMatnr(), null);
+                    for (OrderDto orderDto : orderDtoList) {
+                        OrderDetl orderDetl = orderDetlService.selectItem(orderDto.getOrderNo(), locDto.getMatnr(), locDto.getBatch());
+                        if (orderDetl == null) {
+                            orderDetl = orderDetlService.selectItem(orderDto.getOrderNo(), locDto.getMatnr(), null);
+                        }
+                        if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDto.getAnfme())) {
+                            throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
+                        }
+                        orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);
                     }
-                    if (!orderDetlService.increase(orderDetl.getOrderId(), orderDetl.getMatnr(), orderDetl.getBatch(), orderDto.getAnfme())) {
-                        throw new CoolException("淇敼璁㈠崟鏄庣粏鏁伴噺澶辫触");
-                    }
-                    orderService.updateSettle(orderDetl.getOrderId(), 2L, userId);
+                }
+            }else {//鑷姩缁勬墭
+                WaitPakin waitPakin = new WaitPakin();
+                waitPakin.sync(mat);
+                waitPakin.setBatch(wrkDetl.getBatch());
+                waitPakin.setZpallet(wrkDetl.getZpallet());   // 鎵樼洏鐮�
+                waitPakin.setIoStatus("N");     // 鍏ュ嚭鐘舵��
+                waitPakin.setAnfme(wrkDetl.getAnfme());  // 鏁伴噺
+                waitPakin.setStatus("Y");    // 鐘舵��
+                waitPakin.setAppeUser(userId);
+                waitPakin.setAppeTime(now);
+                waitPakin.setModiUser(userId);
+                waitPakin.setModiTime(now);
+                waitPakin.setMemo(wrkDetl.getMemo());
+                waitPakin.setFrozen(wrkDetl.getFrozen()); // 鏄惁鍐荤粨
+                waitPakin.setManu(wrkDetl.getManu());
+                waitPakin.setMatType(mat.getMatType());//鐗╂枡绫诲瀷
+                if (!waitPakinService.insert(waitPakin)) {
+                    throw new CoolException("淇濆瓨鍏ュ簱閫氱煡妗eけ璐�");
                 }
             }
         }
@@ -612,9 +1108,9 @@
     @Override
     @Transactional
     public void locCheckOut(StockOutParam param, Long userId) {
-        // if (wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 107)) > 0) {
-        //     throw new CoolException("鍙兘瀛樺湪涓�绗旂洏鐐逛换鍔�");
-        // }
+//         if (wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("io_type", 107)) > 0) {
+//             throw new CoolException("鍙兘瀛樺湪涓�绗旂洏鐐逛换鍔�");
+//         }
         // 鐩爣绔欑偣鐘舵�佹娴�
         BasDevp staNo = basDevpService.checkSiteStatus(param.getOutSite());
         // 鑾峰彇搴撲綅鏄庣粏
@@ -696,6 +1192,7 @@
             wrkDetl.setAppeUser(userId);
             wrkDetl.setModiTime(now);
             wrkDetl.setModiUser(userId);
+            wrkDetl.setMatType(locDetl.getMatType());
             if (!wrkDetlService.insert(wrkDetl)) {
                 throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
             }
@@ -899,7 +1396,7 @@
             locSts = "O";
 
             // 搴撲綅杞Щ
-            if (wrkMast.getIoType() == 11) {
+            if (wrkMast.getIoType() == 11 || wrkMast.getIoType() == 111) {
                 // 搴撲綅杞Щ锛氭簮搴撲綅
                 LocMast locMast = locMastService.selectById(wrkMast.getSourceLocNo());
                 if (Cools.isEmpty(locMast)) {
@@ -920,7 +1417,7 @@
             } else if (wrkMast.getIoType() == 110) {
                 locSts = "D";
                 // 搴撲綅杞Щ ===>> D.绌烘《/绌烘爤鏉�
-            } else if (wrkMast.getIoType() == 11) {
+            } else if (wrkMast.getIoType() == 11 || wrkMast.getIoType() == 111) {
                 if (wrkMast.getWrkSts() > 11){
                     throw new CoolException("绉诲簱浠诲姟宸插湪鎵ц涓紝涓嶈兘鍙栨秷");
                 }
@@ -1017,6 +1514,8 @@
         if (!wrkMastRes || !locMastRes) {
             throw new CoolException("淇濆瓨鏁版嵁澶辫触");
         }
+        WaitPakin waitPakin = waitPakinService.selectOne(new EntityWrapper<WaitPakin>().eq("zpallet", wrkMast.getBarcode()));
+        waitPakinService.delete(new EntityWrapper<>(waitPakin));
     }
 
     @Override
@@ -1185,6 +1684,7 @@
                     wrkDetl.setAppeUser(9527L);
                     wrkDetl.setModiTime(now);
                     wrkDetl.setModiUser(9527L);
+                    wrkDetl.setMatType(locDetl.getMatType());
                     if (!wrkDetlService.insert(wrkDetl)) {
                         throw new CoolException("淇濆瓨宸ヤ綔妗f槑缁嗗け璐�");
                     }

--
Gitblit v1.9.1