From 4070ab454a009c2d4e65d4e40bccefbdbb60a1cf Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期三, 21 二月 2024 15:31:12 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/service/CommonService.java |  180 +++++++++++++++++++++++++++++++++++++----------------------
 1 files changed, 112 insertions(+), 68 deletions(-)

diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java
index 38fc00d..fa0d583 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;
@@ -12,6 +13,7 @@
 import com.zy.common.model.LocTypeDto;
 import com.zy.common.model.Shelves;
 import com.zy.common.model.StartupDto;
+import com.zy.common.utils.News;
 import com.zy.core.properties.SlaveProperties;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -110,10 +112,15 @@
             case 126:
                 whsType = 3;
                 break;
+            case 110:
+                whsType = 4;
+                break;
+            case 301:
+                whsType = 5;
+                break;
             default:
                 throw new CoolException("搴撲綅鎺掑彿鍒嗛厤閿欒, 婧愮珯鍙凤細" + sourceStaNo);
         }
-        startupDto.setWorkNo(workNo);
         RowLastno rowLastno = rowLastnoService.selectById(whsType);
         if (Cools.isEmpty(rowLastno)) {
             throw new CoolException("鏁版嵁寮傚父锛岃鑱旂郴绠$悊鍛�");
@@ -141,10 +148,12 @@
                 // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣�
                 LocMast shallowLoc = locMastService.selectById(shallowLocNo);
                 if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) {
-                    if (VersionUtils.locMoveCheckLocType(shallowLoc, locTypeDto)) {
-                        locMast = shallowLoc;
-                        crnNo = locMast.getCrnNo();
-                        break;
+                    if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
+                        if (VersionUtils.locMoveCheckLocType(shallowLoc, locTypeDto)) {
+                            locMast = shallowLoc;
+                            crnNo = locMast.getCrnNo();
+                            break;
+                        }
                     }
                 }
             }
@@ -162,9 +171,12 @@
                     // 妫�娴嬬洰鏍囧簱浣嶆槸鍚︿负绌哄簱浣�
                     LocMast shallowLoc = locMastService.selectById(shallowLocNo);
                     if (shallowLoc != null && shallowLoc.getLocSts().equals("O")) {
-                        locMast = shallowLoc;
-                        crnNo = locMast.getCrnNo();
-                        break;
+                        if (basCrnpService.checkSiteError(shallowLoc.getCrnNo(), true)) {
+                            locMast = shallowLoc;
+                            crnNo = locMast.getCrnNo();
+                            break;
+                        }
+
                     }
                 }
             }
@@ -172,55 +184,56 @@
 
         // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
         if (null == locMast) {
+            Shelves shelves = new Shelves(rowCount, crn_qty);
             // 1-4鎺�
             if (whsType == 1) {
-                // 鑾峰彇鐩爣绔欐墍鍦ㄨ揣鏋舵帓鍙�
-                Shelves shelves = new Shelves(rowCount, crn_qty);
-                curRow = shelves.start(curRow);
-                if (curRow < 0) {
-                    throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
-                }
-                for (List<Integer> node : shelves.nodes){
-                    if (node.contains(curRow)) {
-                        crnNo = shelves.nodes.indexOf(node) + 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) {
-                // 鑾峰彇鐩爣绔欐墍鍦ㄨ揣鏋舵帓鍙�
-                Shelves shelves = new Shelves(rowCount, crn_qty);
-                curRow = shelves.start(curRow - 4);
-                if (curRow < 0) {
-                    throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
-                }
-                for (List<Integer> node : shelves.nodes){
-                    if (node.contains(curRow)) {
-                        crnNo = shelves.nodes.indexOf(node) + 1;
+                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;
                     }
+
                 }
-                // 鍋忕Щ閲忚ˉ鍋�
-                curRow = curRow + 4;
-                crnNo = crnNo + 1;
             // 126绌烘澘鍏� 1-8鎺�
             } else {
-                // 鑾峰彇鐩爣绔欐墍鍦ㄨ揣鏋舵帓鍙�
-                Shelves shelves = new Shelves(rowCount, crn_qty);
-                curRow = shelves.start(curRow);
-                if (curRow < 0) {
-                    throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
-                }
-                for (List<Integer> node : shelves.nodes){
-                    if (node.contains(curRow)) {
-                        crnNo = shelves.nodes.indexOf(node) + 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;
                     }
                 }
             }
         }
 
-        basCrnpService.checkSiteStatus(crnNo);
+        if (crnNo == 0) {
+            throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満");
+        }
         // 鑾峰彇鐩爣绔�
         Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()
                 .eq("type_no", staDescId)
@@ -228,47 +241,78 @@
                 .eq("crn_no", crnNo);
         StaDesc staDesc = staDescService.selectOne(wrapper);
         if (Cools.isEmpty(staDesc)) {
+            News.error("type_no={},stn_no={},crn_no={}", staDescId, sourceStaNo, crnNo);
             throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�");
         }
         BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn());
-        int inQty = staNo.getInQty()==null?0:staNo.getInQty();
-        if (staNo.getAutoing().equals("Y") && inQty<2) {
-            // 鏇存柊搴撲綅鎺掑彿
-            rowLastno.setCurrentRow(curRow);
-            rowLastnoService.updateById(rowLastno);
-            // 鏌ユ壘搴撲綅
-            if (locMast == null) {
-                if (Utils.isShallowLoc(slaveProperties, curRow)) {
-                    Integer deepRow = Utils.getDeepRow(slaveProperties, curRow);
-                    locMast = locMastService.queryFreeLocMast(deepRow, locTypeDto.getLocType1());
-                }
-                if (Cools.isEmpty(locMast)) {
-                    locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1());
+        if (!staNo.getAutoing().equals("Y")) {
+            throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�");
+        }
+        // 鏇存柊搴撲綅鎺掑彿
+        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());
+                // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣�
+                if (!locMastService.checkEmptyCount(locMast)) {
+                    locMast = null;
                 }
             }
             if (Cools.isEmpty(locMast)) {
-                // 杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠�
-                if (locTypeDto.getLocType1() == 1) {
-                    locTypeDto.setLocType1((short) 2);
-                    return getLocNo(null, staDescId, sourceStaNo, matNos, locTypeDto, times);
+                locMast = locMastService.queryFreeLocMast(curRow, locTypeDto.getLocType1());
+                // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣�
+                if (!locMastService.checkEmptyCount(locMast)) {
+                    locMast = null;
                 }
-                if (times >= rowCount) {
-                    log.error("娌℃湁绌哄簱浣�");
-                    throw new CoolException("娌℃湁绌哄簱浣�");
+                // 鐩爣搴撲綅 ===>> 娴呭簱浣嶏紝 鍒欐牎楠屽叾娣卞簱浣嶆槸鍚︿负 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 {
+                times = 0;
             }
-            String locNo = locMast.getLocNo();
 
-            // 杩斿洖dto
-            startupDto.setCrnNo(crnNo);
-            startupDto.setSourceStaNo(sourceStaNo);
-            startupDto.setStaNo(staNo.getDevNo());
-            startupDto.setLocNo(locNo);
-        } else {
-            throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�");
+            // 杞昏揣鐗╂壘杞诲簱浣嶄负绌烘椂锛屽彲浠ュ幓鎵鹃噸搴撲綅浠�
+            if (locTypeDto.getLocType1() == 1) {
+                locTypeDto.setLocType1((short) 2);
+                return getLocNo(null, staDescId, sourceStaNo, matNos, locTypeDto, times);
+            }
+            News.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());
+        startupDto.setLocNo(locNo);
         return startupDto;
     }
 
@@ -306,4 +350,4 @@
         }
     }
 
-}
\ No newline at end of file
+}

--
Gitblit v1.9.1