From c8f5e604019bdbc4bd67113ffc0b2dbb1a79017a Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期五, 20 九月 2024 15:25:36 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/MainServiceImpl.java |   13 +++++++++----
 1 files changed, 9 insertions(+), 4 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 149dbc5..e0f0670 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
@@ -161,13 +161,18 @@
                     ) {
 
                         // 鑾峰彇鏉$爜鎵弿浠俊鎭�
-                        BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, basConveyorSta.getBarcodeId().intValue());
+                        DeviceBarcode deviceBarcode = deviceBarcodeService.getById(basConveyorSta.getBarcodeId());
+                        if(deviceBarcode == null) {
+                            continue;
+                        }
+                        BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, Integer.parseInt(deviceBarcode.getDeviceId()));
                         if (barcodeThread == null) {
                             continue;
                         }
                         String barcode = barcodeThread.getBarcode();
                         if (!Cools.isEmpty(barcode)) {
-                            News.info("{}鍙锋潯鐮佹壂鎻忓櫒妫�娴嬫潯鐮佷俊鎭細{}", inSta.getBarcode(), barcode);
+                            News.info("{}鍙锋潯鐮佹壂鎻忓櫒妫�娴嬫潯鐮佷俊鎭細{}", deviceBarcode.getId(), barcode);
+
                             if ("NG".endsWith(barcode) || "NoRead".equals(barcode) || "empty".equals(barcode) || "00000000".equals(barcode)) {
                                 staProtocol.setWorkNo((short) 32002);
                                 staProtocol.setStaNo(inSta.getBackSta().shortValue());
@@ -213,7 +218,7 @@
                             param.setBarcode(barcode);
                             param.setIoType(1);
                             param.setSourceStaNo(inSta.getStaNo());
-                            param.setLocType1(staProtocol.getLocType1().shortValue());
+                            param.setLocType1((short)1);
                             String response = new HttpHandler.Builder()
                                     .setUri(wmsUrl)
                                     .setPath("/rpc/pakin/loc/v1")
@@ -458,7 +463,7 @@
             if (Cools.isEmpty(basConveyorSta.getTaskNo())){
                 continue;
             }
-            if (!basConveyorSta.getTaskNo().toString().equals(task.getTaskNo())){
+            if (!basConveyorSta.getTaskNo().toString().equals(task.getWmsTaskNo())){
                 continue;
             }
             DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Conveyor, basConveyor.getDeviceId().intValue());

--
Gitblit v1.9.1