From 0eb4bcffe0c6e017f9a9967576f12818c9b05db7 Mon Sep 17 00:00:00 2001
From: 18516761980 <4761516tqsxp>
Date: 星期六, 11 九月 2021 13:36:44 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/service/CommonService.java |  328 +++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 282 insertions(+), 46 deletions(-)

diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java
index b647bae..6df78ab 100644
--- a/src/main/java/com/zy/common/service/CommonService.java
+++ b/src/main/java/com/zy/common/service/CommonService.java
@@ -1,5 +1,6 @@
 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;
@@ -7,8 +8,12 @@
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.*;
 import com.zy.asrs.service.*;
+import com.zy.asrs.utils.Utils;
+import com.zy.asrs.utils.VersionUtils;
+import com.zy.common.model.LocTypeDto;
 import com.zy.common.model.Shelves;
 import com.zy.common.model.StartupDto;
+import com.zy.common.properties.SlaveProperties;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -39,6 +44,8 @@
     private LocMastService locMastService;
     @Autowired
     private LocDetlService locDetlService;
+    @Autowired
+    private SlaveProperties slaveProperties;
 
     /**
      * 鐢熸垚宸ヤ綔鍙�
@@ -82,71 +89,132 @@
         return workNo;
     }
 
+    public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, boolean emptyMk, List<String> matNos, LocTypeDto locTypeDto, int times) {
+        LocTypeDto oldLocType = locTypeDto.clone();
+        return getLocNo(whsType, staDescId, sourceStaNo, emptyMk, matNos, locTypeDto, oldLocType, times);
+    }
+
     /**
      * 妫�绱㈠簱浣嶅彿
      * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋�
      * @param staDescId 璺緞ID
      * @param sourceStaNo 婧愮珯
-     * @param matNos 浜у搧鍙烽泦鍚�
+     * @param matNos 鐗╂枡鍙烽泦鍚�
      * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿
      */
-    public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, int times) {
-//        if (sourceStaNo == 3) {
-//            whsType = 1;
-//        } else if (sourceStaNo == 7) {
-//            whsType = 2;
-//        } else if (sourceStaNo == 19) {
-//            whsType = 3;
-//        } else {
-//            throw new CoolException("鏃犳晥鍏ュ簱绔�");
-//        }
+    public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, boolean emptyMk, List<String> matNos, LocTypeDto locTypeDto, LocTypeDto oldLocType, int times) {
         StartupDto startupDto = new StartupDto();
+        // 鐢熸垚宸ヤ綔鍙�
+        int workNo = getWorkNo(0);
+//        if (locTypeDto.getLocType3() == 1) { // 杞昏揣淇″彿
+//            whsType = 2;    // 5 - 12 杞讳粨
+//        } else if (locTypeDto.getLocType3() == 2) { // 閲嶈揣淇″彿
+//            whsType = 1;    // 1 - 4 閲嶄粨
+//        }
         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 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 (whsType == 1 || whsType == 2) {
-            if (curRow == sRow) {
-                curRow = eRow;
-            } else {
-                curRow = sRow;
+        // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂�
+        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 (locMastService.checkEmptyCount(shallowLoc)) {
+                            // 娴呭簱浣嶅搴斿爢鍨涙満蹇呴』鍙敤涓旀棤寮傚父
+                            if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
+                                locMast = shallowLoc;
+                                crnNo = locMast.getCrnNo();
+                                break;
+                            }
+                        }
+                    }
+                }
             }
-            crnNo = whsType;
-            basCrnpService.checkSiteStatus(crnNo, true);
-        } else {
+        }
+        // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭
+        if (emptyMk) {
+            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 (locMastService.checkEmptyCount(shallowLoc)) {
+                            // 娴呭簱浣嶅搴斿爢鍨涙満蹇呴』鍙敤涓旀棤寮傚父
+                            if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
+                                locMast = shallowLoc;
+                                crnNo = locMast.getCrnNo();
+                                break;
+                            }
+                        }
+                    }
+                }
+            }
+        }
+
+        // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
+        if (null == locMast) {
             Shelves shelves = new Shelves(rowCount, crn_qty);
-            curRow = curRow - 4;
-            for (int i = 0; i < shelves.group; i ++) {
-                curRow = shelves.start(curRow);
-                if (curRow < 0) {
-                    throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
+            // 閲嶅簱浣� 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.getCrnNo(curRow);
+                    if (basCrnpService.checkSiteError(crnNo1, true)) {
+                        crnNo = crnNo1;
+                        break;
+                    }
                 }
-                Integer crnNo1 = shelves.getCrnNo(curRow);
-                if (basCrnpService.checkSiteError(crnNo1 + 2, true)) {
-                    // 鍋忕Щ閲忚ˉ鍋�
-                    curRow = curRow + 4;
-                    crnNo = crnNo1 + 2;
-                    break;
-                }
+//                // 杞诲簱浣� 5 - 12鎺�
+//            } else {
+//                curRow = curRow - 4;
+//                for (int i = 0; i < shelves.group; i ++) {
+//                    curRow = shelves.start(curRow);
+//                    if (curRow < 0) {
+//                        throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
+//                    }
+//                    Integer crnNo1 = shelves.getCrnNo(curRow);
+//                    if (basCrnpService.checkSiteError(crnNo1 + 1, true)) {
+//                        // 鍋忕Щ閲忚ˉ鍋�
+//                        curRow = curRow + 4;
+//                        crnNo = crnNo1 + 1;
+//                        break;
+//                    }
+//                }
             }
         }
 
         if (crnNo == 0) {
             throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満");
         }
-
         // 鑾峰彇鐩爣绔�
         Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()
                 .eq("type_no", staDescId)
@@ -157,6 +225,7 @@
             log.error("鍏ュ簱璺緞涓嶅瓨鍦�, staDescId={}, sourceStaNo={}, crnNo={}", staDescId, sourceStaNo, crnNo);
             throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�");
         }
+
         // 妫�娴嬬洰鏍囩珯
         BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn());
         if (!staNo.getAutoing().equals("Y")) {
@@ -169,21 +238,79 @@
 
         // 寮�濮嬫煡鎵惧簱浣� ==============================>>
 
-        // 鏌ユ壘搴撲綅
-        locMast = locMastService.queryFreeLocMast(curRow);
+        // 1.褰撴绱㈠簱鎺掍负娴呭簱浣嶆帓鏃讹紝浼樺厛瀵绘壘褰撳墠搴撴帓鐨勬繁搴撲綅鎺�
+        if (locMast == null) {
+            if (Utils.isShallowLoc(slaveProperties, curRow)) {
+                Integer deepRow = Utils.getDeepRow(slaveProperties, curRow);
+                locMast = locMastService.queryFreeLocMast(deepRow, locTypeDto.getLocType1(), locTypeDto.getLocType2(), locTypeDto.getLocType3());
+                // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣�
+                if (!locMastService.checkEmptyCount(locMast)) {
+                    locMast = null;
+                }
+            }
+            if (Cools.isEmpty(locMast)) {
+                locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1(), locTypeDto.getLocType2(), locTypeDto.getLocType3());
+                // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣�
+                if (!locMastService.checkEmptyCount(locMast)) {
+                    locMast = null;
+                }
+                // 鐩爣搴撲綅 ===>> 娴呭簱浣嶏紝 鍒欐牎楠屽叾娣卞簱浣嶆槸鍚︿负 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) {
-                log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒");
-                throw new CoolException("娌℃湁绌哄簱浣�");
+            if (times < rowCount) {
+                times = times + 1;
+                return getLocNo(1, staDescId, sourceStaNo, emptyMk, matNos, locTypeDto, oldLocType, times);
+            } else {
+                times = 0;
             }
-            times = times + 1;
-            return getLocNo(1, staDescId, sourceStaNo, matNos, times);
+            // 璐х墿妫�绱綆搴撲綅浠撳け璐ワ紝鍏煎楂樺簱浣嶄粨鍚庣户缁墽琛�
+            if (locTypeDto.getLocType1() == 1) {
+                locTypeDto.setLocType1((short) 2);
+                return getLocNo(1, staDescId, sourceStaNo, emptyMk, matNos, locTypeDto, oldLocType, times);
+            }
+//            // 璐х墿妫�绱㈢獎搴撲綅浠撳け璐ワ紝鍏煎瀹藉簱浣嶄粨鍚庣户缁墽琛�
+//            if (locTypeDto.getLocType2() == 1) {
+//                locTypeDto.setLocType2((short) 2);
+//                if (oldLocType.getLocType1() == 1) {
+//                    locTypeDto.setLocType1((short) 1);
+//                }
+//                return getLocNo(null, staDescId, sourceStaNo, emptyMk, matNos, locTypeDto, oldLocType, times);
+//            }
+//            // 璐х墿妫�绱㈣交搴撲綅浠撳け璐ワ紝鍏煎閲嶅簱浣嶄粨鍚庣户缁墽琛�
+//            if (locTypeDto.getLocType3() == 1) {
+//                locTypeDto.setLocType3((short) 2);
+//                if (oldLocType.getLocType1() == 1) {
+//                    locTypeDto.setLocType1((short) 1);
+//                }
+//                if (oldLocType.getLocType2() == 1) {
+//                    locTypeDto.setLocType2((short) 1);
+//                }
+//                return getLocNo(null, staDescId, sourceStaNo, emptyMk, matNos, locTypeDto, oldLocType, times);
+//            }
+            log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒 灏哄瑙勬牸锛� {}锛� 杞娆℃暟锛歿}", JSON.toJSONString(locTypeDto), times);
+            throw new CoolException("娌℃湁绌哄簱浣�");
         }
         String locNo = locMast.getLocNo();
 
         // 杩斿洖dto
+        startupDto.setWorkNo(workNo);
         startupDto.setCrnNo(crnNo);
         startupDto.setSourceStaNo(sourceStaNo);
         startupDto.setStaNo(staNo.getDevNo());
@@ -191,6 +318,115 @@
         return startupDto;
     }
 
+//    /**
+//     * 妫�绱㈠簱浣嶅彿
+//     * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋�
+//     * @param staDescId 璺緞ID
+//     * @param sourceStaNo 婧愮珯
+//     * @param matNos 浜у搧鍙烽泦鍚�
+//     * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿
+//     */
+//    public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, int times) {
+////        if (sourceStaNo == 3) {
+////            whsType = 1;
+////        } else if (sourceStaNo == 7) {
+////            whsType = 2;
+////        } else if (sourceStaNo == 19) {
+////            whsType = 3;
+////        } else {
+////            throw new CoolException("鏃犳晥鍏ュ簱绔�");
+////        }
+//        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 (whsType == 1 || whsType == 2) {
+//            if (curRow == sRow) {
+//                curRow = eRow;
+//            } else {
+//                curRow = sRow;
+//            }
+//            crnNo = whsType;
+//            basCrnpService.checkSiteStatus(crnNo, true);
+//        } else {
+//            Shelves shelves = new Shelves(rowCount, crn_qty);
+//            curRow = curRow - 4;
+//            for (int i = 0; i < shelves.group; i ++) {
+//                curRow = shelves.start(curRow);
+//                if (curRow < 0) {
+//                    throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
+//                }
+//                Integer crnNo1 = shelves.getCrnNo(curRow);
+//                if (basCrnpService.checkSiteError(crnNo1 + 2, true)) {
+//                    // 鍋忕Щ閲忚ˉ鍋�
+//                    curRow = curRow + 4;
+//                    crnNo = crnNo1 + 2;
+//                    break;
+//                }
+//            }
+//        }
+//
+//        if (crnNo == 0) {
+//            throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満");
+//        }
+//
+//        // 鑾峰彇鐩爣绔�
+//        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("鍏ュ簱璺緞涓嶅瓨鍦�, staDescId={}, sourceStaNo={}, crnNo={}", 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);
+//
+//        // 寮�濮嬫煡鎵惧簱浣� ==============================>>
+//
+//        // 鏌ユ壘搴撲綅
+//        locMast = locMastService.queryFreeLocMast(curRow);
+//
+//        if (Cools.isEmpty(locMast)) {
+//            // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊
+//            if (times >= rowCount) {
+//                log.error("绯荤粺娌℃湁绌哄簱浣嶏紒锛侊紒");
+//                throw new CoolException("娌℃湁绌哄簱浣�");
+//            }
+//            times = times + 1;
+//            return getLocNo(1, staDescId, sourceStaNo, matNos, times);
+//        }
+//        String locNo = locMast.getLocNo();
+//
+//        // 杩斿洖dto
+//        startupDto.setCrnNo(crnNo);
+//        startupDto.setSourceStaNo(sourceStaNo);
+//        startupDto.setStaNo(staNo.getDevNo());
+//        startupDto.setLocNo(locNo);
+//        return startupDto;
+//    }
+
     public static void main(String[] args) {
         System.out.println(Arith.remainder(1, 4));
         System.out.println("0200201".substring(0, 2));

--
Gitblit v1.9.1