From 06bd0f3f54ff9d29767d3735f7b0a640433656c0 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@63.com>
Date: 星期二, 08 三月 2022 09:48:45 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/SteThread.java | 54 +++++++++++++-------------
src/main/java/com/zy/core/model/protocol/SteProtocol.java | 15 ++-----
src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 49 ++++++++++++++++++++++--
3 files changed, 76 insertions(+), 42 deletions(-)
diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index e8daaa8..0efa6ec 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -26,17 +26,16 @@
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.*;
-import com.zy.core.model.CrnSlave;
-import com.zy.core.model.DevpSlave;
-import com.zy.core.model.LedSlave;
-import com.zy.core.model.Task;
+import com.zy.core.model.*;
import com.zy.core.model.command.CrnCommand;
import com.zy.core.model.command.LedCommand;
import com.zy.core.model.protocol.CrnProtocol;
import com.zy.core.model.protocol.StaProtocol;
+import com.zy.core.model.protocol.SteProtocol;
import com.zy.core.properties.SlaveProperties;
import com.zy.core.thread.BarcodeThread;
import com.zy.core.thread.LedThread;
+import com.zy.core.thread.SteThread;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
@@ -562,6 +561,9 @@
if (!crnProtocol.getStatusType().equals(CrnStatusType.IDLE) || crnProtocol.getTaskNo() != 0) {
continue;
}
+ // todo锛氬皬杞﹁縼鍏ュ嚭
+ this.carMoveIn(wrkMast);
+
// 宸茬粡瀛樺湪鍚婅溅鎵ц浠诲姟鏃讹紝鍒欒繃婊�
if (wrkMastMapper.selectWorking(slave.getId()) != null) {
@@ -639,6 +641,45 @@
}
/**
+ * 鍏ュ簱 ===>> 鍫嗗灈鏈烘惉鍏ュ皬杞�
+ */
+ public void carMoveIn(WrkMast wrkMast) {
+ for (SteSlave ste : slaveProperties.getSte()) {
+ // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+ SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, ste.getId());
+ SteProtocol steProtocol = steThread.getSteProtocol();
+ if (steProtocol == null) { continue; }
+ if (steProtocol.getStatusType().equals(SteStatusType.IDLE)) {
+
+
+
+ }
+
+
+ }
+ }
+
+ /**
+ * 鍏ュ簱 ===>> 鍫嗗灈鏈烘惉鍑哄皬杞�
+ */
+ public void carMoveOut(WrkMast wrkMast) {
+ for (SteSlave ste : slaveProperties.getSte()) {
+ // 鑾峰彇鍫嗗灈鏈轰俊鎭�
+ SteThread steThread = (SteThread) SlaveConnection.get(SlaveType.Ste, ste.getId());
+ SteProtocol steProtocol = steThread.getSteProtocol();
+ if (steProtocol == null) { continue; }
+ if (steProtocol.getStatusType().equals(SteStatusType.IDLE)) {
+
+
+
+ }
+
+
+ }
+ }
+
+
+ /**
* 鍑哄簱 ===>> 搴撲綅鍒板爢鍨涙満绔�
*/
public void locToCrnStn(CrnSlave slave, CrnProtocol crnProtocol){
diff --git a/src/main/java/com/zy/core/model/protocol/SteProtocol.java b/src/main/java/com/zy/core/model/protocol/SteProtocol.java
index 7bd122b..57efadd 100644
--- a/src/main/java/com/zy/core/model/protocol/SteProtocol.java
+++ b/src/main/java/com/zy/core/model/protocol/SteProtocol.java
@@ -22,17 +22,10 @@
public Short mode;
/**
- * 鍫嗗灈鏈哄綋鍓嶇姸鎬�
- * 0锛氱┖闂诧紝鏃犱换鍔�
- * 1锛氬彇璐у畾浣嶄腑
- * 2锛氬彇璐т腑
- * 3锛氬彇璐у畬鎴愶紝鏀捐揣瀹氫綅涓�
- * 4锛氭斁璐т腑
- * 5锛氬洖鍘熺偣涓�
- * 6锛氬弽鍘熺偣
- * 7锛氬簱浣嶇Щ浣�
- * 90锛氫换鍔″畬鎴愮瓑寰匴CS纭
- * 99锛氭姤璀�
+ IDLE(0, "绌洪棽"),
+ MOVING(1, "浣滀笟涓�"),
+ SOS(2, "鎶ヨ"),
+ WAITING(3, "浠诲姟瀹屾垚绛夊緟WCS纭"),
*/
public Short status;
diff --git a/src/main/java/com/zy/core/thread/SteThread.java b/src/main/java/com/zy/core/thread/SteThread.java
index c44d079..b186098 100644
--- a/src/main/java/com/zy/core/thread/SteThread.java
+++ b/src/main/java/com/zy/core/thread/SteThread.java
@@ -72,16 +72,16 @@
if (null == command) {
command = new SteCommand();
}
- command.setCrnNo(slave.getId()); // 绌挎杞︾紪鍙�
- command.setTaskNo((short) 0); // 宸ヤ綔鍙�
- command.setAckFinish((short) 1); // 浠诲姟瀹屾垚纭浣�
- command.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
- command.setSourcePosX((short)0); // 婧愬簱浣嶆帓
- command.setSourcePosY((short)0); // 婧愬簱浣嶅垪
- command.setSourcePosZ((short)0); // 婧愬簱浣嶅眰
- command.setDestinationPosX((short)0); // 鐩爣搴撲綅鎺�
- command.setDestinationPosY((short)0); // 鐩爣搴撲綅鍒�
- command.setDestinationPosZ((short)0); // 鐩爣搴撲綅灞�
+// command.setSteNo(slave.getId()); // 绌挎杞︾紪鍙�
+// command.setTaskNo((short) 0); // 宸ヤ綔鍙�
+// command.setAckFinish((short) 1); // 浠诲姟瀹屾垚纭浣�
+// command.setTaskMode(CrnTaskModeType.NONE); // 浠诲姟妯″紡
+// command.setSourcePosX((short)0); // 婧愬簱浣嶆帓
+// command.setSourcePosY((short)0); // 婧愬簱浣嶅垪
+// command.setSourcePosZ((short)0); // 婧愬簱浣嶅眰
+// command.setDestinationPosX((short)0); // 鐩爣搴撲綅鎺�
+// command.setDestinationPosY((short)0); // 鐩爣搴撲綅鍒�
+// command.setDestinationPosZ((short)0); // 鐩爣搴撲綅灞�
write(command);
break;
default:
@@ -104,23 +104,23 @@
if (null == steProtocol) {
steProtocol = new SteProtocol();
}
- steProtocol.setMode((short) -1);
-// crnProtocol.setTaskNo((short)0);
- steProtocol.setStatus((short)-1);
- steProtocol.setBay((short)0);
- steProtocol.setLevel((short)0);
- steProtocol.setForkPos((short) -1);
- steProtocol.setLiftPos((short) -1);
- steProtocol.setWalkPos((short)0);
- steProtocol.setLoaded((short)0);
- steProtocol.setAlarm((short)0);
- steProtocol.setXSpeed(0F);
- steProtocol.setYSpeed(0F);
- steProtocol.setZSpeed(0F);
- steProtocol.setXDistance(0F);
- steProtocol.setYDistance(0F);
- steProtocol.setXDuration(0F);
- steProtocol.setYDuration(0F);
+// steProtocol.setMode((short) -1);
+// steProtocol.setTaskNo((short)0);
+// steProtocol.setStatus((short)-1);
+// steProtocol.setBay((short)0);
+// steProtocol.setLevel((short)0);
+// steProtocol.setForkPos((short) -1);
+// steProtocol.setLiftPos((short) -1);
+// steProtocol.setWalkPos((short)0);
+// steProtocol.setLoaded((short)0);
+// steProtocol.setAlarm((short)0);
+// steProtocol.setXSpeed(0F);
+// steProtocol.setYSpeed(0F);
+// steProtocol.setZSpeed(0F);
+// steProtocol.setXDistance(0F);
+// steProtocol.setYDistance(0F);
+// steProtocol.setXDuration(0F);
+// steProtocol.setYDuration(0F);
}
@Override
--
Gitblit v1.9.1