From 700059de6ffbe956e6546e74aac9a1f0cd6f2663 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期一, 27 三月 2023 11:15:14 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/common/service/CommonService.java |  196 +++++++++++++++++-------------------------------
 1 files changed, 70 insertions(+), 126 deletions(-)

diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java
index fcadb9d..3f4744f 100644
--- a/src/main/java/com/zy/common/service/CommonService.java
+++ b/src/main/java/com/zy/common/service/CommonService.java
@@ -10,7 +10,6 @@
 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;
@@ -29,13 +28,18 @@
 public class CommonService {
 
     public static final List<Integer> FIRST_GROUP_ROW_LIST = new ArrayList<Integer>() {{
-        add(2);add(3);add(4);add(5);add(6);add(7);add(8);add(9);add(10);
-        add(11);add(12);add(13);add(14);add(15);add(16);add(17);
+        add(1);add(2);add(3);add(4);add(5);add(6);add(7);add(8);add(9);add(10);
+    }};
+    public static final List<Integer> FIRST_GROUP_ROW_LIST_SHORT = new ArrayList<Integer>() {{
+        add(8);add(9);add(10);
     }};
     public static final List<Integer> SECOND_GROUP_ROW_LIST = new ArrayList<Integer>() {{
-        add(18);add(19);add(20);
-        add(21);add(22);add(23);add(24);add(25);add(26);add(27);add(28);add(29);add(30);
+        add(12);add(13);add(14);add(15);add(16);add(17);add(18);
     }};
+    public static final List<Integer> THIRD_GROUP_ROW_LIST = new ArrayList<Integer>() {{
+        add(20);add(21);add(22);add(23);
+    }};
+
 
     @Autowired
     private WrkMastService wrkMastService;
@@ -97,62 +101,45 @@
     }
 
     public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto, int times) {
-        LocTypeDto oldLocType = locTypeDto.clone();
-        return getLocNo(whsType, staDescId, sourceStaNo, matNos, locTypeDto, oldLocType, times);
+        return getLocNo(staDescId, sourceStaNo, matNos, locTypeDto, times);
     }
 
     /**
      * 妫�绱㈠簱浣嶅彿
-     * @param whsType 绫诲瀷 1:鍙屾繁寮忚揣鏋�
      * @param staDescId 璺緞ID
      * @param sourceStaNo 婧愮珯
      * @param matNos 鐗╂枡鍙烽泦鍚�
      * @return locNo 妫�绱㈠埌鐨勫簱浣嶅彿
      */
-    public StartupDto getLocNo(Integer whsType, Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto, LocTypeDto oldLocType, int times) {
+    public StartupDto getLocNo(Integer staDescId, Integer sourceStaNo, List<String> matNos, LocTypeDto locTypeDto,int times) {
+
         StartupDto startupDto = new StartupDto();
-        int start = 2;
-        int end = 30;
-        switch (sourceStaNo) {
-            case 107:
-                whsType = 2;
-                end = 17;
-                break;
-            case 118:
-                whsType = 3;
-                start = 18;
-                break;
-            default:
-                whsType = 1;
-                break;
-        }
-        // 鐢熸垚宸ヤ綔鍙�
-        int workNo = getWorkNo(0);
-        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 (!Cools.isEmpty(matNos) && matNos.size() == 1) {
-            List<String> locNos = locDetlService.getSameDetl(matNos.get(0), start, end);
-            for (String locNo : locNos) {
-                LocMast locMast0 = locMastService.findOutMost(locNo);
+        // 闈犺繎鎽嗘斁瑙勫垯 --- 鐩稿悓璁㈠崟鍙�, 鍚屽ぉ鍚岃鏍肩墿鏂�
+        if (!Cools.isEmpty(matNos) && matNos.size() == 1 && staDescId == 1) {
+            //鍏堝垽鏂伐浣滄。锛屾煡鎵句富妗OType=1锛� wrkSts < 10鐨勫伐浣滄槑缁嗭紝鏂欏彿鐩稿悓鐨勬槑缁嗗簱浣�
+            List<WrkMast> wrkMasts = wrkMastService.selectSameMatnrs(matNos.get(0));
+            for (WrkMast wrkMast : wrkMasts) {
+                LocMast locMast0 = locMastService.findNearloc(wrkMast.getLocNo());
                 if (null != locMast0) {
                     // 娴呭簱浣嶇鍚堝昂瀵告娴�
                     if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) {
-                        // 娴呭簱浣嶅搴斿爢鍨涙満蹇呴』鍙敤涓旀棤寮傚父
-                        if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) {
-                            crnNo = locMast0.getCrnNo();
+                        locMast = locMast0;
+                        break;
+                    }
+                }
+            }
+            if (Cools.isEmpty(locMast)) {
+                //鍐嶅垽鏂簱瀛樻槑缁嗘。锛屾枡鍙风浉鍚岀殑鏄庣粏搴撲綅
+                List<String> locNos = locDetlService.getSameDetl(matNos.get(0));
+                for (String locNo : locNos) {
+                    LocMast locMast0 = locMastService.findNearloc(locNo);
+                    if (null != locMast0) {
+                        // 娴呭簱浣嶇鍚堝昂瀵告娴�
+                        if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) {
                             locMast = locMast0;
                             break;
                         }
@@ -161,21 +148,33 @@
             }
         }
 
+
         // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭
         if (staDescId == 10) {
-            List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>()
-                    .eq("loc_sts", "D").ge("row1", start).le("row1", end));
-            if (locMasts.size() > 0) {
-                for (LocMast loc : locMasts) {
-                    LocMast locMast0 = locMastService.findOutMost(loc.getLocNo());
-                    if (null != locMast0) {
-                        // 娴呭簱浣嶇鍚堝昂瀵告娴�
-                        if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) {
-                            // 娴呭簱浣嶅搴斿爢鍨涙満蹇呴』鍙敤涓旀棤寮傚父
-                            if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) {
-                                crnNo = locMast0.getCrnNo();
+            //鍏堝垽鏂伐浣滄。锛屾煡鎵句富妗OType=1锛� wrkSts < 10鐨勫伐浣滄槑缁嗭紝鏂欏彿鐩稿悓鐨勬槑缁嗗簱浣�
+            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("io_type",10));
+            for (WrkMast wrkMast : wrkMasts) {
+                LocMast locMast0 = locMastService.findNearloc(wrkMast.getLocNo());
+                if (null != locMast0) {
+                    // 娴呭簱浣嶇鍚堝昂瀵告娴�
+                    if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) {
+                        locMast = locMast0;
+                        break;
+                    }
+                }
+            }
+            if (Cools.isEmpty(locMast)){
+                List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>()
+                        .eq("loc_sts", "D"));
+                if (locMasts.size() > 0) {
+                    for (LocMast loc : locMasts) {
+                        LocMast locMast0 = locMastService.findNearloc(loc.getLocNo());
+                        if (null != locMast0) {
+                            // 娴呭簱浣嶇鍚堝昂瀵告娴�
+                            if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) {
                                 locMast = locMast0;
                                 break;
+
                             }
                         }
                     }
@@ -184,110 +183,55 @@
         }
 
         // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
-        if (null == locMast) {
-            Shelves shelves = new Shelves(rowCount, crn_qty);
-            for (int i = 0; i < shelves.group; i ++) {
-                curRow = shelves.start(curRow);
-                if (curRow < 0) {
-                    throw new CoolException("妫�绱㈠簱浣嶅け璐ワ紝璇疯仈绯荤鐞嗗憳");
-                }
-                Integer crnNo1 = shelves.get(curRow) + 1;
-                if (whsType != 1) {
-                    crnNo1 = whsType;
-                }
-                if (basCrnpService.checkSiteError(crnNo1, true)) {
-                    crnNo = crnNo1;
-                    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);
+                .eq("stn_no", sourceStaNo);
         StaDesc staDesc = staDescService.selectOne(wrapper);
         if (Cools.isEmpty(staDesc)) {
-            log.error("鍏ュ簱璺緞涓嶅瓨鍦�, staDescId={}, sourceStaNo={}, crnNo={}", staDescId, sourceStaNo, crnNo);
+            log.error("鍏ュ簱璺緞涓嶅瓨鍦�, staDescId={}, sourceStaNo={}", staDescId, sourceStaNo);
             throw new CoolException("鍏ュ簱璺緞涓嶅瓨鍦�");
         }
 
         // 妫�娴嬬洰鏍囩珯
         BasDevp staNo = basDevpService.selectById(staDesc.getCrnStn());
         if (!staNo.getAutoing().equals("Y")) {
-            throw new CoolException("鐩爣绔�"+staDesc.getCrnStn()+"涓嶅彲鐢�");
+            throw new CoolException("鐩爣绔�" + staDesc.getCrnStn() + "涓嶅彲鐢�");
         }
-
-        // 鏇存柊搴撲綅鎺掑彿
-        rowLastno.setCurrentRow(curRow);
-        rowLastnoService.updateById(rowLastno);
 
         // 寮�濮嬫煡鎵惧簱浣� ==============================>>
 
         // 1.褰撴绱㈠簱鎺掍负娴呭簱浣嶆帓鏃讹紝浼樺厛瀵绘壘褰撳墠搴撴帓鐨勬繁搴撲綅鎺�
         if (locMast == null) {
-            List<Integer> rows = Utils.getGroupLoc(curRow);
-
-            List<LocMast> locMasts = locMastService.queryFreeLocMast(rows, rows.size(), locTypeDto.getLocType1());
-            if (!Cools.isEmpty(locMasts)) {
-                Integer innermostRow = Utils.getOutLayerRow(locMasts.get(0).getLocNo(), false);
-                for (LocMast one : locMasts) {
-                    if (one.getRow1().equals(innermostRow)) {
-                        locMast = one;
-                        break;
-                    }
+            List<LocMast> peakLocs = locMastService.selectAllPeakLoc();
+            for (LocMast peakLoc : peakLocs) {
+                List<String> groupInsideLoc = Utils.getGroupInsideLoc(peakLoc.getLocNo());
+                if (!Cools.isEmpty(groupInsideLoc)){
+                    if (!locMastService.checkAllLocEmpty(groupInsideLoc)) continue;
+                    locMast = peakLoc;
+                    break;
+                }else {
+                    locMast=peakLoc;
+                    break;
                 }
             }
-            // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣� todo:luxiaotao
-//            if (!locMastService.checkEmptyCount(locMast)) {
-//                locMast = null;
-//            }
         }
 
         // 2.搴撲綅褰撳墠鎵�灞炲昂瀵告棤绌哄簱浣嶆椂锛岃皟鏁村昂瀵稿弬鏁帮紝鍚戜笂鍏煎妫�绱㈠簱浣�
         if (Cools.isEmpty(locMast)) {
-            // 褰撳墠宸烽亾鏃犵┖搴撲綅鏃讹紝閫掑綊璋冩暣鑷充笅涓�宸烽亾锛屾绱㈠叏閮ㄥ贩閬撴棤鏋滃悗锛岃烦鍑洪�掑綊
-            if (times < rowCount) {
-                times = times + 1;
-                return getLocNo(whsType, staDescId, sourceStaNo, matNos, locTypeDto, oldLocType, times);
-            } else {
-                times = 0;
-            }
-            // 璐х墿妫�绱綆搴撲綅浠撳け璐ワ紝鍏煎楂樺簱浣嶄粨鍚庣户缁墽琛�
-            if (locTypeDto.getLocType1() == 1) {
-                locTypeDto.setLocType1((short) 2);
-                return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, oldLocType, 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();
-        }
     }
 
 }

--
Gitblit v1.9.1