From 78a59eda850857e1bfeb48541f0c64d442877a4d Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期二, 08 四月 2025 11:17:10 +0800
Subject: [PATCH] #实现pda简单入库出库操作

---
 src/main/java/com/zy/common/service/CommonService.java |  150 ++++++++++++++++++++++++++++---------------------
 1 files changed, 85 insertions(+), 65 deletions(-)

diff --git a/src/main/java/com/zy/common/service/CommonService.java b/src/main/java/com/zy/common/service/CommonService.java
index 0989bf9..11f1840 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,12 +28,16 @@
 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);
     }};
     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(5);add(6);add(7);add(8);add(9);add(10);add(11);
+    }};
+    public static final List<Integer> FIRST_GROUP_ROW_LIST2 = new ArrayList<Integer>() {{
+        add(2);add(3);add(4);
+    }};
+    public static final List<Integer> SECOND_GROUP_ROW_LIST10 = new ArrayList<Integer>() {{
+        add(5);add(6);add(7);add(8);add(9);add(10);
     }};
 
     @Autowired
@@ -68,25 +71,23 @@
         }
         int workNo = 0;
         // 鍏ュ嚭搴撶被鍨�
-        if (wrkLastno.getWrkMk() == 0) {
-            workNo = wrkLastno.getWrkNo();
-            int sNo = wrkLastno.getSNo();
-            int eNo = wrkLastno.getENo();
+        workNo = wrkLastno.getWrkNo();
+        int sNo = wrkLastno.getSNo();
+        int eNo = wrkLastno.getENo();
 
-            workNo = workNo>=eNo ? sNo : workNo+1;
+        workNo = workNo>=eNo ? sNo : workNo+1;
 
-            while (true) {
-                WrkMast wrkMast = wrkMastService.selectById(workNo);
-                if (null != wrkMast) {
-                    workNo = workNo>=eNo ? sNo : workNo+1;
-                } else {
-                    break;
-                }
+        while (true) {
+            WrkMast wrkMast = wrkMastService.selectById(workNo);
+            if (null != wrkMast) {
+                workNo = workNo>=eNo ? sNo : workNo+1;
+            } else {
+                break;
             }
-            if (workNo > 0){
-                wrkLastno.setWrkNo(workNo);
-                wrkLastnoService.updateById(wrkLastno);
-            }
+        }
+        if (workNo > 0){
+            wrkLastno.setWrkNo(workNo);
+            wrkLastnoService.updateById(wrkLastno);
         }
         if (workNo == 0) {
             throw new CoolException("鐢熸垚宸ヤ綔鍙峰け璐ワ紝璇疯仈绯荤鐞嗗憳");
@@ -131,17 +132,17 @@
         LocMast locMast = null;
 
         // 闈犺繎鎽嗘斁瑙勫垯 --- 鍚屽ぉ鍚岃鏍肩墿鏂�
-        if (!Cools.isEmpty(matNos)) {
+        if (!Cools.isEmpty(matNos) && matNos.size() == 1) {
             List<String> locNos = locDetlService.getSameDetl(matNos.get(0), sRow, eRow);
             for (String locNo : locNos) {
-                List<String> groupLoc = Utils.getGroupLoc(locNo);
-                locMast = locMastService.findOutMost(groupLoc);
-                if (null != locMast) {
+                LocMast locMast0 = locMastService.findOutMost(locNo);
+                if (null != locMast0) {
                     // 娴呭簱浣嶇鍚堝昂瀵告娴�
-                    if (VersionUtils.locMoveCheckLocType(locMast, locTypeDto)) {
+                    if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) {
                         // 娴呭簱浣嶅搴斿爢鍨涙満蹇呴』鍙敤涓旀棤寮傚父
-                        if (basCrnpService.checkSiteError(locMast.getCrnNo(), true)) {
-                            crnNo = locMast.getCrnNo();
+                        if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) {
+                            crnNo = locMast0.getCrnNo();
+                            locMast = locMast0;
                             break;
                         }
                     }
@@ -151,17 +152,18 @@
 
         // 闈犺繎鎽嗘斁瑙勫垯 --- 绌烘墭
         if (staDescId == 10) {
-            List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts", "D").ge("row1", sRow).le("row1", eRow));
+            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) {
-                    List<String> groupLoc = Utils.getGroupLoc(loc.getLocNo());
-                    locMast = locMastService.findOutMost(groupLoc);
-                    if (null != locMast) {
+                    LocMast locMast0 = locMastService.findOutMost(loc.getLocNo());
+                    if (null != locMast0) {
                         // 娴呭簱浣嶇鍚堝昂瀵告娴�
-                        if (VersionUtils.locMoveCheckLocType(locMast, locTypeDto)) {
+                        if (VersionUtils.locMoveCheckLocType(locMast0, locTypeDto)) {
                             // 娴呭簱浣嶅搴斿爢鍨涙満蹇呴』鍙敤涓旀棤寮傚父
-                            if (basCrnpService.checkSiteError(locMast.getCrnNo(), true)) {
-                                crnNo = locMast.getCrnNo();
+                            if (basCrnpService.checkSiteError(locMast0.getCrnNo(), true)) {
+                                crnNo = locMast0.getCrnNo();
+                                locMast = locMast0;
                                 break;
                             }
                         }
@@ -172,23 +174,20 @@
 
         // 濡傛灉娌℃湁鐩歌繎鐗╂枡锛屽垯鎸夎鍒欒疆璇㈣揣鏋�
         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);
-                if (basCrnpService.checkSiteError(crnNo1, true)) {
-                    crnNo = crnNo1;
-                    break;
-                }
+            if (curRow == 1) {
+                curRow = 11;
+            } else {
+                curRow = 1;
+            }
+            if (basCrnpService.checkSiteError(1, true)) {
+                crnNo = 1;
             }
         }
 
         if (crnNo == 0) {
             throw new CoolException("娌℃湁鍙敤鐨勫爢鍨涙満");
         }
+
         // 鑾峰彇鐩爣绔�
         Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()
                 .eq("type_no", staDescId)
@@ -214,23 +213,44 @@
 
         // 1.褰撴绱㈠簱鎺掍负娴呭簱浣嶆帓鏃讹紝浼樺厛瀵绘壘褰撳墠搴撴帓鐨勬繁搴撲綅鎺�
         if (locMast == null) {
-            List<Integer> rows;
-            switch (curRow) {
-                case 1:
-                    rows = FIRST_GROUP_ROW_LIST;
-                    break;
-                case 2:
-                    rows = SECOND_GROUP_ROW_LIST;
-                    break;
-                default:
-                    throw new CoolException("鍏ュ簱閫昏緫鏁呴殰銆�" + curRow + "銆�");
-            }
+            List<Integer> rows = Utils.getGroupLoc(curRow);
 
-            locMast = locMastService.queryFreeLocMast(curRow, rows, locTypeDto.getLocType1());
+            List<LocMast> locMasts = locMastService.queryFreeLocMast(rows, rows.size(), locTypeDto.getLocType1());
+            if (!Cools.isEmpty(locMasts)) {
+                Integer innermostRow = Utils.getInnermostRow(locMasts.get(0).getLocNo());
+                for (LocMast one : locMasts) {
+                    if (one.getRow1().equals(innermostRow)) {
+                        locMast = one;
+                        break;
+                    }
+                }
+            }
+            if (Cools.isEmpty(locMast)){
+                if (rows.equals(FIRST_GROUP_ROW_LIST)){
+                    rows=FIRST_GROUP_ROW_LIST2;
+                }else if (rows.equals(SECOND_GROUP_ROW_LIST)){
+                    rows=SECOND_GROUP_ROW_LIST10;
+                }
+                List<LocMast> locMasts1 = locMastService.queryFreeLocMast2(rows, rows.size(), locTypeDto.getLocType1());
+                if (!Cools.isEmpty(locMasts1)) {
+                    Integer innermostRow = Utils.getInnermostRow(locMasts1.get(0).getLocNo());
+                    if (rows.equals(FIRST_GROUP_ROW_LIST2)){
+                        innermostRow=innermostRow+1;
+                    }else if (rows.equals(SECOND_GROUP_ROW_LIST10)){
+                        innermostRow=innermostRow-1;
+                    }
+                    for (LocMast one : locMasts1) {
+                        if (one.getRow1().equals(innermostRow)) {
+                            locMast = one;
+                            break;
+                        }
+                    }
+                }
+            }
             // 鍥犲簱浣嶇Щ杞�侀渶棰勭暀绌哄簱浣�
-//            if (!locMastService.checkEmptyCount(locMast)) {
-//                locMast = null;
-//            }
+            if (!locMastService.checkEmptyCount(locMast, 10)) {
+                locMast = null;
+            }
         }
 
         // 2.搴撲綅褰撳墠鎵�灞炲昂瀵告棤绌哄簱浣嶆椂锛岃皟鏁村昂瀵稿弬鏁帮紝鍚戜笂鍏煎妫�绱㈠簱浣�
@@ -243,10 +263,10 @@
                 times = 0;
             }
             // 璐х墿妫�绱綆搴撲綅浠撳け璐ワ紝鍏煎楂樺簱浣嶄粨鍚庣户缁墽琛�
-            if (locTypeDto.getLocType1() == 1) {
-                locTypeDto.setLocType1((short) 2);
-                return getLocNo(1, staDescId, sourceStaNo, matNos, locTypeDto, oldLocType, times);
-            }
+//            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("娌℃湁绌哄簱浣�");
         }

--
Gitblit v1.9.1