From 08b4403ec8d6b69528d161cfcad80b5d64dea76c Mon Sep 17 00:00:00 2001
From: Administrator <876263681@qq.com>
Date: 星期三, 02 七月 2025 15:12:43 +0800
Subject: [PATCH] #优化库位检索

---
 src/main/java/com/zy/common/service/CommonService.java |  404 +++++++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 304 insertions(+), 100 deletions(-)

diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java
index fc3ddf7..19af71d 100644
--- a/src/main/java/com/zy/common/service/CommonService.java
+++ b/src/main/java/com/zy/common/service/CommonService.java
@@ -92,16 +92,312 @@
      * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋�
      * @param staDescId 璺緞宸ヤ綔绫诲瀷
      * @param sourceStaNo 婧愮珯
-     * @param matNos 鍟嗗搧缂栧彿闆嗗悎
+     * @param matNos 鍝佸彿闆嗗悎
      * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿
      */
     @Transactional
     public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto, int times) {
-//        whsType = getWhsType(sourceStaNo, times);
+        //whsType = getWhsType(sourceStaNo, times);
+
         StartupDto startupDto = new StartupDto();
 
 
 
+        RowLastno rowLastno = rowLastnoService.selectById(whsType);
+        if (Cools.isEmpty(rowLastno)) {
+            throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
+        }
+
+        // ===============>>>> 寮�濮嬫墽琛�
+        // ===============>>>> 寮�濮嬫墽琛�
+        int curRow = rowLastno.getCurrentRow();
+        int sRow = rowLastno.getsRow();
+        int eRow = rowLastno.geteRow();
+        int crn_qty = rowLastno.getCrnQty();
+        int rowCount = eRow - sRow + 1;
+        // 鐩爣鍫嗗灈鏈哄彿
+        int crnNo = 0;
+        // 鐩爣搴撲綅
+        LocMast locMast = null;
+
+        // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
+        if (null == locMast) {
+            curRow = curRow + 1;
+            if (curRow == 4) {
+                curRow = 1;
+            }
+            if (basCrnpService.checkSiteError(1, true)) {
+                crnNo = 1;
+            }
+        }
+        if (crnNo == 0) {
+            throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満");
+        }
+
+        // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂�
+        if (!Cools.isEmpty(matNos)) {
+            List<String> locNos = locDetlService.getSameDetlToday(matNos.get(0), sRow, eRow);
+            for (String locNo : locNos) {
+                // 鏄祬搴撲綅 鐨勮烦璧�
+                //if (Utils.isShallowLoc(slaveProperties, locNo)) {
+                //    continue;
+                //}
+                int row = Integer.parseInt(locNo.substring(0, 2));
+                if (row == 2) continue;
+                String shallowLocNo = "";
+                if (row == 1) {
+                    shallowLocNo = locNo;
+                } else {
+                    shallowLocNo = zerofill(String.valueOf(2), 2) + locNo.substring(2);
+                }
+                // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣�
+                LocMast shallowLoc = locMastService.selectById(shallowLocNo);
+                if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) {
+                    if (VersionUtils.locMoveCheckLocType(shallowLoc, locTypeDto)) {
+                        if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
+                            locMast = shallowLoc;
+                            crnNo = locMast.getCrnNo();
+                            break;
+                        }
+                    }
+                }
+            }
+        }
+
+        // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭
+        if (staDescId == 10) {
+            List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow));
+            if (locMasts.size() > 0) {
+                for (LocMast loc : locMasts) {
+
+                    int row = Integer.parseInt(loc.getLocNo().substring(0, 2));
+                    String shallowLocNo = "";
+                    if (row == 1 || row == 2) {
+                        continue;
+                    }
+                    LocMast trgerLoc = locMastService.selectById(zerofill(String.valueOf(2), 2) + loc.getLocNo().substring(2));
+                    if (!trgerLoc.getLocSts().equals("O")) {
+                        continue;
+                    }
+                    shallowLocNo = trgerLoc.getLocNo();
+
+                    // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣�
+                    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();
+                            break;
+                        }
+                    }
+                }
+            }
+        }
+
+
+        // 鑾峰彇鐩爣绔�
+        Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()
+                .eq("type_no", staDescId)
+                .eq("stn_no", sourceStaNo)
+                .eq("crn_no", crnNo);
+        StaDesc staDesc = staDescService.selectOne(wrapper);
+        if (Cools.isEmpty(staDesc)) {
+            log.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo);
+            throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�");
+        }
+        BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn());
+        if (!staNo.getAutoing().equals("Y")) {
+            throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�");
+        }
+
+        // 鏇存柊搴撲綅鎺掑彿
+        rowLastno.setCurrentRow(curRow);
+             rowLastnoService.updateById(rowLastno);
+
+        // 寮�濮嬫煡鎵惧簱浣� ==============================>>
+
+        // 1.褰撴绱㈠簱鎺掍负娴呭簱浣嶆帓鏃讹紝浼樺厛瀵绘壘褰撳墠搴撴帓鐨勬繁搴撲綅鎺�
+        if (locMast == null) {
+            if (curRow == 2) {
+                Integer deepRow = 3;
+                locMast = locMastService.queryFreeLocMast(deepRow, locTypeDto.getLocType1());
+                if (!locMastService.checkEmptyCount(locMast)) {
+                    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;
+            //    }
+            //}
+            if (Cools.isEmpty(locMast)) {
+                locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1());
+                List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>()
+                        .eq("row1", curRow)
+                        .eq("loc_sts", "O")
+                        .orderBy("lev1", true).orderBy("bay1", true));
+                for(LocMast locMast1 :locMasts){
+                    // 鐩爣搴撲綅 ===>> 娴呭簱浣嶏紝 鍒欐牎楠屽叾娣卞簱浣嶆槸鍚︿负 F D X
+                    if (null != locMast1 && Integer.parseInt(locMast1.getLocNo().substring(0, 2)) == 2) {
+                        LocMast deepLoc = locMastService.selectById(zerofill(String.valueOf(3), 2) + locMast1.getLocNo().substring(2));
+                        if (!deepLoc.getLocSts().equals("F") && !deepLoc.getLocSts().equals("D") && !deepLoc.getLocSts().equals("X") && !deepLoc.getLocSts().equals("P")) {
+                            locMast = null;
+                        }else {
+                            if (!Cools.isEmpty(locMast1)) {
+                                locMast = locMast1;
+                                break;
+                            }
+                        }
+                    }
+
+                    // 鐩爣搴撲綅 ===>> 娣卞簱浣嶏紝 鍒欐牎楠屽叾娴呭簱浣嶆槸鍚︿负 O
+                    if (null != locMast1 && Integer.parseInt(locMast1.getLocNo().substring(0, 2)) == 3) {
+                        LocMast shallowLoc = locMastService.selectById(zerofill(String.valueOf(2), 2) + locMast1.getLocNo().substring(2));
+                        if (!Cools.isEmpty(shallowLoc)) {
+                            if (!shallowLoc.getLocSts().equals("O")) {
+                                locMast = null;
+                            }else {
+                                if (!Cools.isEmpty(locMast1)) {
+                                    locMast = locMast1;
+                                    break;
+                                }
+                            }
+                        }
+                    }
+                }
+                // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣�
+                if (!locMastService.checkEmptyCount(locMast)) {
+                    locMast = null;
+                }
+//                // 鐩爣搴撲綅 ===>> 娴呭簱浣嶏紝 鍒欐牎楠屽叾娣卞簱浣嶆槸鍚︿负 F D X
+//                if (null != locMast && Integer.parseInt(locMast.getLocNo().substring(0, 2)) == 2) {
+//                    LocMast deepLoc = locMastService.selectById(zerofill(String.valueOf(3), 2) + locMast.getLocNo().substring(2));
+//                    if (!deepLoc.getLocSts().equals("F") && !deepLoc.getLocSts().equals("D") && !deepLoc.getLocSts().equals("X") && !deepLoc.getLocSts().equals("P")) {
+//                        locMast = null;
+//                    }
+//                }
+//
+//                // 鐩爣搴撲綅 ===>> 娣卞簱浣嶏紝 鍒欐牎楠屽叾娴呭簱浣嶆槸鍚︿负 O
+//                if (null != locMast && Integer.parseInt(locMast.getLocNo().substring(0, 2)) == 3) {
+//                    LocMast shallowLoc = locMastService.selectById(zerofill(String.valueOf(2), 2) + locMast.getLocNo().substring(2));
+//                    if (!Cools.isEmpty(shallowLoc)) {
+//                        if (!shallowLoc.getLocSts().equals("O")) {
+//                            locMast = null;
+//                        }
+//                    }
+//                }
+
+            }
+        }
+
+        // 2.搴撲綅褰撳墠鎵�灞炲昂瀵告棤绌哄簱浣嶆椂锛岃皟鏁村昂瀵稿弬鏁帮紝鍚戜笂鍏煎妫�绱㈠簱浣�
+        if (Cools.isEmpty(locMast)) {
+            // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊
+            if (times < 4) {
+                times = times + 1;
+                if(locTypeDto.getLocType1() == 1 && times == 2){
+                    locTypeDto.setLocType1((short) 2);
+                }
+                return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times);
+            }
+
+            // 杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠�
+//            if (locTypeDto.getLocType1() == 1) {
+//                locTypeDto.setLocType1((short) 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);
+        startupDto.setSourceStaNo(sourceStaNo);
+        startupDto.setStaNo(staNo.getDevNo());
+        startupDto.setLocNo(locNo);
+        return startupDto;
+    }
+
+
+    public static String zerofill(String msg, Integer count) {
+        if (msg.length() == count) {
+            return msg;
+        } else if (msg.length() > count) {
+            return msg.substring(0, 16);
+        } else {
+            StringBuilder msgBuilder = new StringBuilder(msg);
+            for(int i = 0; i < count - msg.length(); ++i) {
+                msgBuilder.insert(0, "0");
+            }
+            return msgBuilder.toString();
+        }
+    }
+
+    /**
+     * 鏍规嵁鍏ュ簱绔欒幏鍙栧簱浣嶆帓鍙峰垎閰�
+     */
+    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);
+        }
+    }
+    /**
+     * 妫�绱㈠簱浣嶅彿
+     * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋�
+     * @param staDescId 璺緞宸ヤ綔绫诲瀷
+     * @param sourceStaNo 婧愮珯
+     * @param matnr 鍝佸彿闆嗗悎
+     * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿
+     */
+    @Transactional
+    public StartupDto getLocNoRun(Integer whsType, Integer staDescId, Integer sourceStaNo, String matnr, String batch, String grade, Integer moveCrnNo, LocTypeDto locTypeDto, int times) {
+        if (Cools.isEmpty(matnr)) {  //鍝佸彿
+            matnr = "";
+        }
+        if (Cools.isEmpty(batch)) {  //绠卞彿
+            batch = "";
+        }
+        if (Cools.isEmpty(grade)) {  //澶囩敤
+            grade = "";
+        }
+
+        StartupDto startupDto = new StartupDto();
         RowLastno rowLastno = rowLastnoService.selectById(whsType);
         if (Cools.isEmpty(rowLastno)) {
             throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
@@ -118,49 +414,6 @@
         // 鐩爣搴撲綅
         LocMast locMast = null;
 
-//        // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂�
-//        if (!Cools.isEmpty(matNos)) {
-//            List<String> locNos = locDetlService.getSameDetlToday(matNos.get(0), sRow, eRow);
-//            for (String locNo : locNos) {
-//                if (Utils.isShallowLoc(slaveProperties, locNo)) {
-//                    continue;
-//                }
-//                String shallowLocNo = Utils.getShallowLoc(slaveProperties, locNo);
-//                // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣�
-//                LocMast shallowLoc = locMastService.selectById(shallowLocNo);
-//                if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) {
-//                    if (VersionUtils.locMoveCheckLocType(shallowLoc, locTypeDto)) {
-//                        if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
-//                            locMast = shallowLoc;
-//                            crnNo = locMast.getCrnNo();
-//                            break;
-//                        }
-//                    }
-//                }
-//            }
-//        }
-//
-//        // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭
-//        if (staDescId == 10) {
-//            List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow));
-//            if (locMasts.size() > 0) {
-//                for (LocMast loc : locMasts) {
-//                    if (Utils.isShallowLoc(slaveProperties, loc.getLocNo())) {
-//                        continue;
-//                    }
-//                    String shallowLocNo = Utils.getShallowLoc(slaveProperties,  loc.getLocNo());
-//                    // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣�
-//                    LocMast shallowLoc = locMastService.selectById(shallowLocNo);
-//                    if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) {
-//                        if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
-//                            locMast = shallowLoc;
-//                            crnNo = locMast.getCrnNo();
-//                            break;
-//                        }
-//                    }
-//                }
-//            }
-//        }
 
         // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
         if (null == locMast) {
@@ -248,14 +501,14 @@
             // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊
             if (times < rowCount) {
                 times = times + 1;
-                return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times);
+                return getLocNoRun(1, staDescId, sourceStaNo, matnr, batch, grade,moveCrnNo, locTypeDto, times);
             }
 
-            // 杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠�
-            if (locTypeDto.getLocType1() == 1) {
-                locTypeDto.setLocType1((short) 2);
-                return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, times);
-            }
+////             杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠�
+//            if (locTypeDto.getLocType1() == 1) {
+//                locTypeDto.setLocType1((short) 2);
+//                return getLocNoRun(1, staDescId, sourceStaNo, matnr, batch, grade,moveCrnNo, locTypeDto, times);
+//            }
             log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒 灏哄瑙勬牸锛� {}锛� 杞娆℃暟锛歿}", JSON.toJSONString(locTypeDto), times);
             throw new CoolException("娌℃湁绌哄簱浣�");
         }
@@ -270,55 +523,6 @@
         startupDto.setStaNo(staNo.getDevNo());
         startupDto.setLocNo(locNo);
         return startupDto;
-    }
-
-
-    public static String zerofill(String msg, Integer count) {
-        if (msg.length() == count) {
-            return msg;
-        } else if (msg.length() > count) {
-            return msg.substring(0, 16);
-        } else {
-            StringBuilder msgBuilder = new StringBuilder(msg);
-            for(int i = 0; i < count - msg.length(); ++i) {
-                msgBuilder.insert(0, "0");
-            }
-            return msgBuilder.toString();
-        }
-    }
-
-    /**
-     * 鏍规嵁鍏ュ簱绔欒幏鍙栧簱浣嶆帓鍙峰垎閰�
-     */
-    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