From ad79ba405b2d1ac96423f88f4e8a76c584b9d38a Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期一, 09 二月 2026 15:57:06 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/impl/ZyStationThread.java |    9 ++++++---
 1 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/impl/ZyStationThread.java b/src/main/java/com/zy/core/thread/impl/ZyStationThread.java
index df9af2a..544fb8b 100644
--- a/src/main/java/com/zy/core/thread/impl/ZyStationThread.java
+++ b/src/main/java/com/zy/core/thread/impl/ZyStationThread.java
@@ -20,6 +20,7 @@
 import com.zy.core.cache.OutputQueue;
 import com.zy.core.enums.RedisKeyType;
 import com.zy.core.enums.SlaveType;
+import com.zy.core.enums.StationCommandType;
 import com.zy.core.model.CommandResponse;
 import com.zy.core.model.Task;
 import com.zy.core.model.command.StationCommand;
@@ -28,7 +29,6 @@
 
 import java.text.MessageFormat;
 import java.util.*;
-import java.util.concurrent.ScheduledExecutorService;
 
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
@@ -82,7 +82,6 @@
                     if (step == 2) {
                         sendCommand((StationCommand) task.getData());
                     }
-
                     Thread.sleep(100);
                 } catch (Exception e) {
                     log.error("StationProcess Fail", e);
@@ -136,8 +135,11 @@
                     stationProtocol.setFullPlt(statusEntity.isFullPlt());
                     stationProtocol.setPalletHeight(statusEntity.getPalletHeight());
                     stationProtocol.setError(statusEntity.getError());
+                    stationProtocol.setErrorMsg(statusEntity.getErrorMsg());
                     stationProtocol.setBarcode(statusEntity.getBarcode());
                     stationProtocol.setRunBlock(statusEntity.isRunBlock());
+                    stationProtocol.setEnableIn(statusEntity.isEnableIn());
+                    stationProtocol.setWeight(statusEntity.getWeight());
                 }
             }
         }
@@ -180,12 +182,13 @@
     }
 
     @Override
-    public StationCommand getMoveCommand(Integer taskNo, Integer stationId, Integer targetStationId, Integer palletSize) {
+    public StationCommand getCommand(StationCommandType commandType, Integer taskNo, Integer stationId, Integer targetStationId, Integer palletSize) {
         StationCommand stationCommand = new StationCommand();
         stationCommand.setTaskNo(taskNo);
         stationCommand.setStationId(stationId);
         stationCommand.setTargetStaNo(targetStationId);
         stationCommand.setPalletSize(palletSize);
+        stationCommand.setCommandType(commandType);
         return stationCommand;
     }
 

--
Gitblit v1.9.1