From 16171041fc0e2e86a5e56504e00a3d4742ad60a9 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期三, 19 六月 2024 15:53:43 +0800
Subject: [PATCH] #
---
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/action/LiftAction.java | 45 ++++++++++++++++++++++++++++++++-------------
1 files changed, 32 insertions(+), 13 deletions(-)
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/action/LiftAction.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/action/LiftAction.java
index 53e0ad3..c8c57b0 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/action/LiftAction.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/action/LiftAction.java
@@ -8,7 +8,7 @@
import com.zy.asrs.wcs.rcs.cache.SlaveConnection;
import com.zy.asrs.wcs.rcs.constant.DeviceRedisConstant;
import com.zy.asrs.wcs.rcs.entity.Device;
-import com.zy.asrs.wcs.rcs.model.enums.ShuttleProtocolStatusType;
+import com.zy.asrs.wcs.rcs.model.enums.LiftProtocolStatusType;
import com.zy.asrs.wcs.rcs.model.enums.SlaveType;
import com.zy.asrs.wcs.rcs.model.protocol.LiftProtocol;
import com.zy.asrs.wcs.rcs.thread.LiftThread;
@@ -41,7 +41,7 @@
redisCommand.setAssignCommand(assignCommand);//鍛戒护
//浠诲姟鏁版嵁淇濆瓨鍒皉edis
if (redisUtil.set(DeviceRedisConstant.LIFT_WORK_FLAG + assignCommand.getTaskNo(), JSON.toJSONString(redisCommand))) {
- liftProtocol.setTaskNo(assignCommand.getTaskNo());
+ liftThread.setSyncTaskNo(assignCommand.getTaskNo());
return true;
}
return false;
@@ -68,11 +68,8 @@
return false;
}
- //鎻愬崌鏈哄浜庤嚜鍔ㄣ�佸氨缁�佺┖闂�
- if (!(liftProtocol.getModel()
- && liftProtocol.getReady()
- && !liftProtocol.getRun())
- ) {
+ //鍒ゆ柇鎻愬崌鏈烘槸鍚︾┖闂�
+ if (!liftThread.isDeviceIdle()) {
return false;
}
@@ -86,22 +83,39 @@
if (commandStep != 0) {
LiftCommand command = commands.get(commandStep - 1);
-
- //鐩墠娌℃湁鍒ゆ柇锛岀洿鎺ュ垽瀹氫笂涓�鏉℃寚浠ゅ畬鎴�
- command.setComplete(true);
+ if (command.getMode() == LiftCommandModeType.MOVE.id) {
+ //鎻愬崌鏈哄崌闄�
+ if (liftProtocol.getLev() == command.getTargetLev()) {
+ command.setComplete(true);
+ }
+ } else if (command.getMode() == LiftCommandModeType.MOVE_CAR.id) {
+ //鎻愬崌鏈哄崌闄嶅皬杞�
+ if (liftProtocol.getLev() == command.getTargetLev()) {
+ command.setComplete(true);
+ }
+ } else if (command.getMode() == LiftCommandModeType.PALLET_INOUT.id) {
+ //鎵樼洏鍑哄叆
+ if (liftProtocol.getLev() == command.getTargetLev()) {
+ command.setComplete(true);
+ }
+ }
// 鏇存柊redis鏁版嵁
- redisUtil.set(DeviceRedisConstant.LIFT_WORK_FLAG + redisCommand.getWrkNo(), JSON.toJSONString(redisCommand));
+ redisUtil.set(DeviceRedisConstant.LIFT_WORK_FLAG + taskNo, JSON.toJSONString(redisCommand));
if (!command.getComplete()) {
return false;
}
-
//鍒ゆ柇鏄惁涓烘渶鍚庝竴鏉″懡浠や笖鍛戒护鎵ц瀹屾垚锛屾姏鍑虹瓑寰呯‘璁ょ姸鎬�
LiftCommand endCommand = commands.get(commands.size() - 1);
if (endCommand.getComplete()) {
News.info("鎻愬崌鏈轰换鍔℃墽琛屼笅鍙戝畬鎴愮瓑寰呮墽琛岀粨鏉燂紝鎻愬崌鏈哄彿={}锛屼换鍔℃暟鎹�={}", liftProtocol.getLiftNo(), JSON.toJSON(commands));
+
+ //瀵逛富绾跨▼鎶涘嚭绛夊緟纭鐘舵�亀aiting
+ liftThread.setProtocolStatus(LiftProtocolStatusType.WAITING);
+ liftThread.commandFinished(taskNo);//璋冪敤瀹屾垚鍚庣画鎸囦护(閮ㄥ垎鎻愬崌鏈烘湁鍚庣画鎸囦护锛屽疄闄呮儏鍐电湅鏄惁鏈夌湡姝ｅ疄鐜版柟娉�)
+ redisUtil.del(DeviceRedisConstant.LIFT_WORK_FLAG + taskNo);
return false;//绂佹鍐嶄笅鍙戝懡浠�
}
}
@@ -117,7 +131,12 @@
News.info("鎻愬崌鏈哄懡浠や笅鍙戞垚鍔燂紝鎻愬崌鏈哄彿={}锛屼换鍔℃暟鎹�={}", command.getLiftNo(), JSON.toJSON(command));
}
- redisUtil.del(DeviceRedisConstant.LIFT_WORK_FLAG + command.getTaskNo());
+ liftThread.setProtocolStatus(LiftProtocolStatusType.WORKING);
+ commandStep++;
+ //鏇存柊redis鏁版嵁
+ redisCommand.setCommandStep(commandStep);
+ // 鏇存柊redis鏁版嵁
+ redisUtil.set(DeviceRedisConstant.LIFT_WORK_FLAG + taskNo, JSON.toJSONString(redisCommand));
return true;
}
--
Gitblit v1.9.1