From 8f1d32397b1b30f51d641513898d3f36cb0e515d Mon Sep 17 00:00:00 2001
From: gtsxc <3272660260@qq.com>
Date: 星期一, 18 十一月 2024 13:53:47 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java |   41 ++++++++++++++++++++++++++++++++++++++---
 1 files changed, 38 insertions(+), 3 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
index 94221bf..e941845 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java
@@ -165,6 +165,7 @@
                     if (staProtocol.isAutoing() && staProtocol.isLoading()
                             && staProtocol.isInEnable()
                             && !staProtocol.isEmptyMk() && (workNo == 0 || (workNo >= 9990 && workNo <= 9999))
+                            && staProtocol.isPakMk()
                     ) {
 
                         // 鑾峰彇鏉$爜鎵弿浠俊鎭�
@@ -224,7 +225,7 @@
                             param.setBarcode(barcode);
                             param.setIoType(1);
                             param.setSourceStaNo(inSta.getStaNo());
-                            param.setLocType1((short) 1);
+                            param.setLocType1(staProtocol.getLocType1().shortValue());
                             String response = new HttpHandler.Builder()
                                     .setUri(wmsUrl)
                                     .setPath("/rpc/pakin/loc/v1")
@@ -253,8 +254,33 @@
                                 createInTaskParam.setBarcode(barcode);
 
                                 R result = openUtils.createInTask(createInTaskParam);
-                                News.info("鍒涘缓鍏ュ簱浠诲姟锛屼换鍔℃暟鎹�={}锛岃姹傚搷搴�={}", JSON.toJSON(param), JSON.toJSON(result));
+                                News.info("鍒涘缓鍏ュ簱浠诲姟锛屼换鍔℃暟鎹�={}锛學MS鍝嶅簲={}锛岃姹傚搷搴�={}", JSON.toJSON(param), JSON.toJSON(jsonObject), JSON.toJSON(result));
+                                try{
+                                    String msg = "";
+                                    HashMap<String, String> hashMap = new HashMap<>();
+                                    hashMap.put("msg", msg);
+                                    hashMap.put("sta", "31001");
+                                    new HttpHandler.Builder()
+                                            .setUri(wmsUrl)
+                                            .setPath("/rpc/led/getError")
+                                            .setJson(JSON.toJSONString(hashMap))
+                                            .build()
+                                            .doPost();
+                                }catch (Exception e){
+
+                                }
+
                             }else {
+                                String msg = jsonObject.getString("msg");
+                                HashMap<String, String> hashMap = new HashMap<>();
+                                hashMap.put("msg", msg);
+                                hashMap.put("sta", "31001");
+                                new HttpHandler.Builder()
+                                        .setUri(wmsUrl)
+                                        .setPath("/rpc/led/getError")
+                                        .setJson(JSON.toJSONString(hashMap))
+                                        .build()
+                                        .doPost();
                                 News.error("鍏ュ簱鐢宠澶辫触锛屼换鍔℃暟鎹�={}锛岃姹傚搷搴�={}", JSON.toJSON(param), JSON.toJSON(jsonObject));
                             }
                         } catch (Exception e) {
@@ -484,6 +510,14 @@
                 continue;
             }
 
+            //瑙f瀽鍓嶅垽鏂唴閮ㄧ洰鏍囧�兼槸鍚︽湁鐗� 鏈夊伐浣滃彿
+            StaProtocol staProtocolInside = devpThread.getStation().get(Utils.getStaByLev(Utils.getLev(task.getDestLoc())));
+            if (staProtocolInside == null) {
+                continue;
+            }
+            if (staProtocolInside.isLoading() || staProtocolInside.getWorkNo() !=0) {
+                continue;
+            }
 
             if (Cools.isEmpty(task.getShuttleNo())) {
                 //鍒嗛厤灏忚溅
@@ -896,7 +930,8 @@
                     .eq(BasLed::getDeviceId, ledDevice.getId()));
             List<Integer> staArr = JSON.parseArray(led.getSta(), Integer.class);
 
-            BasConveyor basConveyor = basConveyorService.getById(led.getConveyorId().intValue());
+            BasConveyor basConveyor = basConveyorService.getById(new LambdaQueryWrapper<BasConveyor>()
+                    .eq(BasConveyor::getDeviceId, led.getConveyorId().intValue()));
             if (basConveyor == null) {
                 continue;
             }

--
Gitblit v1.9.1