From d2d40f1b4e2b740043f09b70efd8d5c9742ccc2e Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期日, 30 十一月 2025 10:19:19 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   53 ++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 50 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 0dbe861..3e22f86 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -186,9 +186,6 @@
                     log.error("鐗╂枡鐮佹壂鐮佸け璐�");
                     back = true;
                 }
-                if(barcode.equals("0")){
-                    continue;
-                }
                 // 閫�鍥�
                 if (back) {
                     News.warn("鎵爜鍏ュ簱澶辫触锛寋}鍏ュ簱绔欏洜{}寮傚父锛屾墭鐩樺凡琚��鍥�", inSta.getStaNo(), errMsg);
@@ -225,6 +222,7 @@
                         && staProtocol.isPakMk()
                         && staProtocol.getWorkNo() == 0
                 ) {
+
                     if(Cools.isEmpty(barcode) || "NG".endsWith(barcode) || "NoRead".equals(barcode)) {
 //                        News.error(JSON.toJSONString(staProtocol));
                         News.info("{}鍙锋潯鐮佹壂鎻忓櫒妫�娴嬫潯鐮佷俊鎭細{}", inSta.getBarcode(), barcode);
@@ -242,6 +240,9 @@
                         devpThread.setPakMk(staProtocol.getSiteId(), false);
                         MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                         log.error("杈撻�佺嚎涓嬪彂1锛�"+wrkNo+","+inSta.getBackSta());
+                        continue;
+                    }
+                    if(barcode.equals("0")){
                         continue;
                     }
 //                    if (staProtocol.getSiteId()!= 159){
@@ -4404,6 +4405,52 @@
             log.error("鏈烘鑷傛姄鍙栦换鍔″畬鎴愮粍鎵樺け璐�"+e.getMessage());
         }
     }
+
+    /*
+     * arm浠诲姟瀹屾垚鑷姩缁勬墭
+     * */
+    public synchronized void  armMissionAccomplished2() {
+        try{
+            List<BasArm> basArmList = basArmService.selectList(new EntityWrapper<BasArm>().gt("arm_no",4));
+            for (BasArm basArm : basArmList) {
+                if (basArm.getStatus()!=1){
+                    continue;
+                }
+                LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", basArm.getStaNoSou()));
+                if (Cools.isEmpty(locMast)){
+                    continue;
+                }
+                try{
+                    List<BasArmMast> basArmMastList = basArmMastService.selectList(
+                            new EntityWrapper<BasArmMast>()
+                                    .eq("arm_no", basArm.getArmNo())
+                                    .eq("sorting_line", basArm.getSortingLineSou())
+                                    .eq("status", 3)
+                    );
+                    if (basArmMastList.isEmpty()){
+                        continue;
+                    }
+                    CombParam combParam = new CombParam(basArmMastList);
+                    //arm浠诲姟瀹屾垚鑷姩缁勬墭
+                    ReturnT<String> result = new PostMesDataUtils().postMesData("arm浠诲姟瀹屾垚鑷姩缁勬墭",wmsUrl, wmsComb, combParam);
+                    if (result.getCode()==200){
+                        basArmMastService.updateArmMastStatus(basArm.getArmNo(),basArm.getSortingLineSou(),3,5);
+                        locMast.setLocSts("R");
+                        locMastService.updateById(locMast);
+                    } else {
+                        armTaskAssignmentCallApiLogSave(locMast, "鑷姩缁勬墭澶辫触", basArm.getStaNoSou()+"鐮佸灈浣嶇疆锛�===銆嬭嚜鍔ㄧ粍鎵樺け璐ワ紝绛夊緟閲嶈瘯", false);
+//                                log.error("鏈烘鑷傛姄鍙栦换鍔″畬鎴愶細"+JSON.toJSON(basArmMastList)+"===銆嬭嚜鍔ㄧ粍鎵樺け璐ワ紝绛夊緟閲嶈瘯");
+                    }
+                }  catch (Exception e){
+                    armTaskAssignmentCallApiLogSave(locMast, "鑷姩缁勬墭澶辫触", basArm.getStaNoSou()+"鐮佸灈浣嶇疆锛�===銆嬭嚜鍔ㄧ粍鎵樺け璐ワ紝绛夊緟閲嶈瘯", false);
+//                            log.error("arm缂栧彿锛�"+basArm.getArmNo()+"====銆嬫満姊拌噦鎶撳彇浠诲姟瀹屾垚"+e.getMessage());
+                }
+                break;
+            }
+        } catch (Exception e){
+            log.error("鏈烘鑷傛姄鍙栦换鍔″畬鎴愮粍鎵樺け璐�"+e.getMessage());
+        }
+    }
     public synchronized void armMissionAccomplishedScanToCheckIn() {
         try{
             for (DevpSlave devp : slaveProperties.getDevp()) {

--
Gitblit v1.9.1