From 608fb6f9529ce51291ef682638a5efc7dd51ac63 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期二, 18 十一月 2025 08:21:08 +0800
Subject: [PATCH] 1.完善找库位 2.新增erp订单删除后,wms订单跟着删除功能 3.新增订单完成后,上报erp,erp报错后显现在出货单中 4.新增一键查询到异常完成订单 5.对销售单据和其他单据进行区分出库 6.对中间表订单状态进行完善 7.新增锁单功能 8.新增任务查询维护加上订单号

---
 src/main/java/com/zy/common/service/CommonService.java |  246 ++++++++++++++++++++++++++++++++----------------
 1 files changed, 162 insertions(+), 84 deletions(-)

diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java
index a4df5c5..4d70aee 100644
--- a/src/main/java/com/zy/common/service/CommonService.java
+++ b/src/main/java/com/zy/common/service/CommonService.java
@@ -1,7 +1,9 @@
 package com.zy.common.service;
 
+import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.core.common.Arith;
 import com.core.common.Cools;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
@@ -95,32 +97,36 @@
      */
     @Transactional
     public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto, int times) {
+//        whsType = getWhsType(sourceStaNo, times);
         StartupDto startupDto = new StartupDto();
-        // 鐢熸垚宸ヤ綔鍙�
-        int workNo = getWorkNo(0);
 
-        switch (sourceStaNo) {
-            case 202:
-                whsType = 2;
-                break;
-            case 205:
-                whsType = 1;
-                break;
-            case 126:
-                whsType = 3;
-                break;
-            case 110:
-                whsType = 4;
-                break;
-            case 301:
-                whsType = 5;
-                break;
-            default:
-                throw new CoolException("搴撲綅鎺掑彿鍒嗛厤閿欒, 婧愮珯鍙凤細" + sourceStaNo);
-        }
+//        if (sourceStaNo < 200){
+//            whsType = 1;
+//        } else if (sourceStaNo > 199 && sourceStaNo < 300){
+//            whsType = 2;
+//        } else if (sourceStaNo > 299 && sourceStaNo < 400){
+//            whsType = 3;
+//        } else if (sourceStaNo > 399){
+//            whsType = 4;
+//        }
+        // 鐩爣鍫嗗灈鏈哄彿
+        int crnNo = 0;
+        if (sourceStaNo ==102) {
+            whsType = 3;
+            crnNo = 3;
+        }else if (sourceStaNo ==104) {
+            whsType = 2;
+            crnNo = 2;
+        }else if(sourceStaNo ==106) {
+            whsType = 1;
+            crnNo = 1;
+        }else
+            throw new CoolException("绔欑偣鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
+
+
         RowLastno rowLastno = rowLastnoService.selectById(whsType);
         if (Cools.isEmpty(rowLastno)) {
-            throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
+            throw new CoolException("1鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
         }
 
         // ===============>>>> 寮�濮嬫墽琛�
@@ -129,8 +135,7 @@
         int eRow = rowLastno.geteRow();
         int crn_qty = rowLastno.getCrnQty();
         int rowCount = eRow - sRow + 1;
-        // 鐩爣鍫嗗灈鏈哄彿
-        int crnNo = 0;
+
         // 鐩爣搴撲綅
         LocMast locMast = null;
 
@@ -168,6 +173,9 @@
                     // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣�
                     LocMast shallowLoc = locMastService.selectById(shallowLocNo);
                     if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) {
+                        if (shallowLoc.getLocType1()<locTypeDto.getLocType1()){
+                            continue;
+                        }
                         if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
                             locMast = shallowLoc;
                             crnNo = locMast.getCrnNo();
@@ -178,58 +186,35 @@
             }
         }
 
-        // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
-        if (null == locMast) {
-            Shelves shelves = new Shelves(rowCount, crn_qty);
-            // 1-4鎺�
-            if (whsType == 1) {
-                for (int i = 0; i < shelves.group; i ++) {
-                    curRow = shelves.start(curRow);
-                    if (curRow < 0) {
-                        throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
-                    }
-                    Integer crnNo1 = shelves.get(curRow);
-                    if (basCrnpService.checkSiteError(crnNo1, true)) {
-                        crnNo = crnNo1;
-                        break;
-                    }
-                }
-            // 5-8鎺�
-            } else if (whsType == 2) {
-                curRow = curRow - 4;
-                for (int i = 0; i < shelves.group; i ++) {
-                    curRow = shelves.start(curRow);
-                    if (curRow < 0) {
-                        throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
-                    }
-                    Integer crnNo1 = shelves.get(curRow);
-                    if (basCrnpService.checkSiteError(crnNo1 + 1, true)) {
-                        // 鍋忕Щ閲忚ˉ鍋�
-                        curRow = curRow + 4;
-                        crnNo = crnNo1 + 1;
-                        break;
-                    }
-
-                }
-            // 126绌烘澘鍏� 1-8鎺�
-            } else {
-                for (int i = 0; i < shelves.group; i ++) {
-                    curRow = shelves.start(curRow);
-                    if (curRow < 0) {
-                        throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
-                    }
-                    Integer crnNo1 = shelves.get(curRow);
-                    if (basCrnpService.checkSiteError(crnNo1, true)) {
-                        crnNo = crnNo1;
-                        break;
-                    }
-                }
-            }
-        }
-
-        if (crnNo == 0) {
-            throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満");
-        }
+//        // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
+//        if (null == locMast) {
+//            if(crnNo>1) {
+//                curRow = curRow -2;
+//            }
+//            Shelves shelves = new Shelves(rowCount, crn_qty);
+//            int divides = (int) Arith.divides(1, curRow - 1, 4);
+//            curRow = (int) Arith.remainder(curRow, 4);
+//            if (curRow == 0) {
+//                curRow = 4;
+//            }
+//            for (int i = 0; i < shelves.group; i ++) {
+//                curRow = shelves.start(curRow);
+//                if (curRow < 0) {
+//                    throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
+//                }
+//                if (basCrnpService.checkSiteError(crnNo, true)) {
+//                    curRow = curRow + divides*4;
+//                    break;
+//                }
+//            }
+//            if(crnNo>1) {
+//                curRow = curRow +2;
+//            }
+//        }
+//
+//        if (crnNo == 0) {
+//            throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満");
+//        }
         // 鑾峰彇鐩爣绔�
         Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()
                 .eq("type_no", staDescId)
@@ -244,14 +229,39 @@
         if (!staNo.getAutoing().equals("Y")) {
             throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�");
         }
+        if(curRow==1){
+            curRow=2;
+        }else if(curRow==2){
+            curRow=1;
+        }else if(curRow==3){
+            curRow=6;
+        }else if(curRow==6){
+            curRow=3;
+        }else if(curRow==7){
+            curRow=10;
+        }else if(curRow==10){
+            curRow=7;
+        }else if(curRow==4){
+            curRow=5;
+        }else if(curRow==5){
+            curRow=4;
+        }else if(curRow==8){
+            curRow=9;
+        }else if(curRow==9){
+            curRow=8;
+        }
         // 鏇存柊搴撲綅鎺掑彿
         rowLastno.setCurrentRow(curRow);
         rowLastnoService.updateById(rowLastno);
-        // 鏌ユ壘搴撲綅
+
+        // 寮�濮嬫煡鎵惧簱浣� ==============================>>
+
+        // 1.褰撴绱㈠簱鎺掍负娴呭簱浣嶆帓鏃讹紝浼樺厛瀵绘壘褰撳墠搴撴帓鐨勬繁搴撲綅鎺�
         if (locMast == null) {
             if (Utils.isShallowLoc(slaveProperties, curRow)) {
                 Integer deepRow = Utils.getDeepRow(slaveProperties, curRow);
                 locMast = locMastService.queryFreeLocMast(deepRow, locTypeDto.getLocType1());
+                // todo:luxiaotao 濡傛灉鐢ㄦ祬鎺掓壘鍒扮殑娣卞簱浣嶏紝閭d箞鍒欓渶瑕佸垽鏂繖涓繁搴撲綅瀵瑰簲鐨勬祬搴撲綅鏄惁鏈夎揣锛團銆乆銆丏锛�
                 // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣�
                 if (!locMastService.checkEmptyCount(locMast)) {
                     locMast = null;
@@ -263,23 +273,57 @@
                 if (!locMastService.checkEmptyCount(locMast)) {
                     locMast = null;
                 }
+                if(curRow >2){
+                    // 鐩爣搴撲綅 ===>> 娴呭簱浣嶏紝 鍒欐牎楠屽叾娣卞簱浣嶆槸鍚︿负 F D X
+                    if (null != locMast && Utils.isShallowLoc(slaveProperties, locMast.getLocNo())) {
+                        LocMast deepLoc = locMastService.selectById(Utils.getDeepLoc(slaveProperties, locMast.getLocNo()));
+                        if (!deepLoc.getLocSts().equals("F") && !deepLoc.getLocSts().equals("D") && !deepLoc.getLocSts().equals("X")) {
+                            locMast = null;
+                        }
+                    }
+                    // 鐩爣搴撲綅 ===>> 娣卞簱浣嶏紝 鍒欐牎楠屽叾娴呭簱浣嶆槸鍚︿负 O
+                    if (null != locMast && Utils.isDeepLoc(slaveProperties, locMast.getLocNo())) {
+                        LocMast shallowLoc = locMastService.selectById(Utils.getShallowLoc(slaveProperties, locMast.getLocNo()));
+                        if (!shallowLoc.getLocSts().equals("O")) {
+                            locMast = null;
+                        }
+                    }
+                }
             }
         }
+
+        // 2.搴撲綅褰撳墠鎵�灞炲昂瀵告棤绌哄簱浣嶆椂锛岃皟鏁村昂瀵稿弬鏁帮紝鍚戜笂鍏煎妫�绱㈠簱浣�
         if (Cools.isEmpty(locMast)) {
+            // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊
+            if (times < rowCount) {
+                times = times + 1;
+                return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times);
+            }else if (times == rowCount) {
+
+                LocMast locMast1 = locMastService.selectOne(new EntityWrapper<LocMast>()
+                        .eq("crn_no", crnNo)
+                        .eq("loc_sts", "O")
+                        .orderBy("lev1"));
+                if(Cools.isEmpty(locMast1)){
+                    throw new CoolException("鍫嗗灈鏈�="+crnNo+"娌℃湁绌哄簱浣�");
+                }
+                if(!locMastService.checkEmptyCount(locMast1)){
+                    throw new CoolException("鍫嗗灈鏈�="+crnNo+"娌℃湁绌哄簱浣�");
+                }
+            }
+
             // 杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠�
             if (locTypeDto.getLocType1() == 1) {
                 locTypeDto.setLocType1((short) 2);
-                return getLocNo(null, staDescId, sourceStaNo, matNos, locTypeDto, times);
+                return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times);
             }
-            if (times >= rowCount) {
-                log.error("娌℃湁绌哄簱浣�");
-                throw new CoolException("娌℃湁绌哄簱浣�");
-            }
-            times = times + 1;
-            return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times);
+            log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒 灏哄瑙勬牸锛� {}锛� 杞娆℃暟锛歿}", JSON.toJSONString(locTypeDto), times);
+            throw new CoolException("娌℃湁绌哄簱浣�");
         }
         String locNo = locMast.getLocNo();
 
+        // 鐢熸垚宸ヤ綔鍙�
+        int workNo = getWorkNo(0);
         // 杩斿洖dto
         startupDto.setWorkNo(workNo);
         startupDto.setCrnNo(crnNo);
@@ -304,4 +348,38 @@
         }
     }
 
+    /**
+     * 鏍规嵁鍏ュ簱绔欒幏鍙栧簱浣嶆帓鍙峰垎閰�
+     */
+    private Integer getWhsType(Integer sourceStaNo, int times) {
+        if (times >= 16) {
+            return 4;
+        }
+        switch (sourceStaNo) {
+            case 173:
+            case 176:
+            case 180:
+            case 185:
+                return 1;
+            case 189:
+            case 194:
+            case 198:
+            case 202:
+                return 2;
+            case 206:
+//            case 211:
+//            case 215:
+//            case 219:
+//            case 223:
+            case 227:
+                return 3;
+            case 305:
+            case 303:
+            case 301:
+                return 4;
+            default:
+                throw new CoolException("鏍规嵁鍏ュ簱绔欒幏鍙栧簱浣嶆帓鍙峰垎閰嶅け璐ワ紝鍏ュ簱绔欙細" + sourceStaNo);
+        }
+    }
+
 }

--
Gitblit v1.9.1