From 1dacf2305187f5c2fb44f03b6b754c46cb73ba25 Mon Sep 17 00:00:00 2001
From: L <L@132>
Date: 星期四, 19 三月 2026 08:53:59 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |   19 +++++++++++++++++--
 1 files changed, 17 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 075ff8b..2d43235 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -76,6 +76,12 @@
             List<WcsRgvListParam> wcsRgvListParamList = new ArrayList<>();
             List<WrkMast> wrkMastList = wrkMastService.selectList(new EntityWrapper<>());
             List<BasDevpPosition> basDevpPositions = basDevpPositionService.selectList(new EntityWrapper<BasDevpPosition>().orderBy("plc_position",true));
+            if (wrkMastList == null) {
+                wrkMastList = new ArrayList<>();
+            }
+            if (basDevpPositions == null) {
+                basDevpPositions = new ArrayList<>();
+            }
 
             for (WrkMast wrkMast : wrkMastList){
                 WcsTaskListParam wcsTaskListParam = new WcsTaskListParam(wrkMast);
@@ -94,11 +100,19 @@
                 WcsRgvListParam wcsRgvListParam = new WcsRgvListParam();
                 wcsRgvListParam.setRgvNo(rgv.getId().toString());
                 wcsRgvListParam.setTaskNo(Cools.isEmpty(rgvProtocol.getTaskNo1()) ? null:rgvProtocol.getTaskNo1().toString());
+                if (rgvProtocol.getStatusType() == null || rgvProtocol.getStatusType().id == null) {
+                    continue;
+                }
                 wcsRgvListParam.setStatus(rgvProtocol.statusType.id);
                 wcsRgvListParam.setCurrPos(rgvProtocol.RgvPos);
-                wcsRgvListParam.setCurrSta(SortTheExecutionOfTheCarUtil.LatelyAndLessThanWcs(basDevpPositions,rgvProtocol.getRgvPos(),perimeter).toString());
+                if (rgvProtocol.getRgvPos() != null && !basDevpPositions.isEmpty()) {
+                    Integer currSta = SortTheExecutionOfTheCarUtil.LatelyAndLessThanWcs(basDevpPositions, rgvProtocol.getRgvPos(), perimeter);
+                    wcsRgvListParam.setCurrSta(currSta == null ? null : currSta.toString());
+                } else {
+                    wcsRgvListParam.setCurrSta(null);
+                }
                 List<String> arrayList = new ArrayList<>();
-                if (rgvProtocol.getAlarm()!=0){
+                if (rgvProtocol.getAlarm() != null && rgvProtocol.getAlarm()!=0){
                     arrayList.add(rgvProtocol.getAlarm$());
                 }
                 wcsRgvListParam.setError(arrayList);
@@ -109,6 +123,7 @@
             wcsDataSynchronizationParam.setTimestamp(timestamp);
             return R.ok().add(wcsDataSynchronizationParam);
         } catch (Exception e){
+            log.error("wcsTaskStatus鎺ュ彛寮傚父, timestamp={}", timestamp, e);
             return R.error("寮傚父").add("寮傚父淇℃伅锛�"+e);
         }
     }

--
Gitblit v1.9.1