From c41fce4524aaf930da42d2b86a41f0ec8570c0a0 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 30 八月 2023 11:26:11 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/NyShuttleThread.java | 173 +++++++++++++++++++++++++++++++++++++--------------------
1 files changed, 112 insertions(+), 61 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/NyShuttleThread.java b/src/main/java/com/zy/core/thread/NyShuttleThread.java
index 73dd3ae..ed9db90 100644
--- a/src/main/java/com/zy/core/thread/NyShuttleThread.java
+++ b/src/main/java/com/zy/core/thread/NyShuttleThread.java
@@ -10,6 +10,7 @@
import com.zy.asrs.utils.Utils;
import com.zy.common.model.NavigateNode;
+import com.zy.common.model.NyShuttleOperaResult;
import com.zy.common.utils.*;
import com.zy.core.News;
import com.zy.core.ThreadHandler;
@@ -27,6 +28,8 @@
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
+import java.io.IOException;
+import java.net.Socket;
import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Date;
@@ -42,6 +45,7 @@
private ShuttleSlave slave;
private NyShuttleProtocol shuttleProtocol;
private RedisUtil redisUtil;
+ private Socket socket;
public NyShuttleThread(ShuttleSlave slave,RedisUtil redisUtil) {
this.slave = slave;
@@ -83,6 +87,10 @@
private void read() {
try {
+ if (this.socket == null || !this.socket.isConnected()) {
+ //閾炬帴鏂紑閲嶆柊閾炬帴
+ this.connect();
+ }
readStatus();
//鍥涘悜绌挎杞︾┖闂层�佹湁浠诲姟銆佹爣璁颁负true銆佸瓨鍦ㄤ换鍔℃寚浠わ紝闇�瑕佹墽琛屼换鍔＄殑涓嬩竴鏉℃寚浠�
if (shuttleProtocol.getFree() == ShuttleStatusType.IDLE.id
@@ -107,7 +115,7 @@
//----------璇诲彇鍥涘悜绌挎杞︾姸鎬�-----------
NyShuttleHttpCommand readStatusCommand = NyHttpUtils.getReadStatusCommand(slave.getId());
- JSONObject jsonObject = NyHttpUtils.requestCommand(readStatusCommand);
+ JSONObject jsonObject = NyHttpUtils.requestCommand(socket, readStatusCommand);
if (jsonObject == null) {
OutputQueue.SHUTTLE.offer(MessageFormat.format("銆恵0}銆戝洓鍚戠┛姊溅plc鐘舵�佷俊鎭け璐� ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
}else {
@@ -158,7 +166,7 @@
errCode.add(Integer.parseInt(o.toString()));
}
//鏁呴殰鐮�
- shuttleProtocol.setErrCode(errCode);
+ shuttleProtocol.setErrCode(errCode.get(0));
//鎬婚噷绋嬫暟
shuttleProtocol.setStatusSum(jsonObject.getObject("statusSum", NyShuttleProtocol.StatusSumClass.class));
//闈炶嚜鍔ㄧ姸鎬佹椂闂磋鏃�
@@ -241,6 +249,13 @@
@Override
public boolean connect() {
+ try {
+ Socket socket = new Socket(slave.getIp(),slave.getPort());
+ socket.setSoTimeout(60000);
+ this.socket = socket;
+ } catch (IOException e) {
+ OutputQueue.SHUTTLE.offer(MessageFormat.format("銆恵0}銆戝洓鍚戠┛姊溅Socket閾炬帴澶辫触 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));
+ }
return true;
}
@@ -267,7 +282,7 @@
}
//鍙戝嚭璇锋眰
- JSONObject result = NyHttpUtils.requestCommand(command);
+ JSONObject result = NyHttpUtils.requestCommand(socket, command);
if (result == null) {
return false;//璇锋眰澶辫触
}
@@ -306,8 +321,8 @@
}
ShuttleRedisCommand redisCommand = JSON.parseObject(o.toString(), ShuttleRedisCommand.class);
- List<NyShuttleHttpCommand> commands = redisCommand.getAssignCommand().getCommands();
ShuttleAssignCommand assignCommand = redisCommand.getAssignCommand();
+ List<NyShuttleHttpCommand> commands = redisCommand.getAssignCommand().getCommands();
//褰撳墠姝ュ簭
int commandStep = redisCommand.getCommandStep();
if (commands.size() == 0) {
@@ -317,62 +332,62 @@
NavigateMapData navigateMapData = new NavigateMapData(Utils.getLev(shuttleProtocol.getCurrentLocNo()));
//鍙栧嚭鍛戒护
NyShuttleHttpCommand command = commands.get(commandStep);//褰撳墠鍛戒护
- if (commandStep != 0) {
- //鍒ゆ柇涓婁竴鏉℃寚浠ゆ槸鍚﹀畬鎴�
- NyShuttleHttpCommand lastCommand = commands.get(commandStep - 1);
- String requestType = lastCommand.getRequest().getBody().get("requestType").toString();
- if (requestType.equals("move") || requestType.equals("intoLift") || requestType.equals("outLift")) {
- //绉诲姩鍛戒护銆佸嚭鍏ユ彁鍗囨満鍛戒护
- NyShuttleProtocol.NyShuttlePointClass target = JSON.parseObject(lastCommand.getRequest().getBody().get("target").toString(), NyShuttleProtocol.NyShuttlePointClass.class);
- if (shuttleProtocol.getPoint().equals(target)) {
- //涓婁竴鏉℃寚浠ょ殑鐩爣浣嶇疆鍜屽綋鍓嶅皬杞︿綅缃浉鍚岋紝鍒欒瀹氫笂涓�鏉′换鍔″畬鎴�
- lastCommand.setComplete(true);
- //瑙ｉ攣閿佸畾璺緞锛屼笂涓�鏉¤矾寰勫拰褰撳墠璺緞
- List<NavigateNode> nodes = lastCommand.getNodes();
- nodes.addAll(command.getNodes());
- navigateMapData.writeNavigateNodeToRedisMap(nodes, false);//瑙ｉ攣璺緞
- }
- }else {
- lastCommand.setComplete(true);//鍏朵粬鍛戒护榛樿璁や负瀹屾垚
- }
- //浠诲姟鏁版嵁淇濆瓨鍒皉edis
- redisUtil.set("shuttle_wrk_no_" + redisCommand.getWrkNo(), JSON.toJSONString(redisCommand));
-
- if (!lastCommand.getComplete()) {
- //涓婁竴鏉′换鍔℃湭瀹屾垚锛岀姝笅鍙戝懡浠�
- return false;
- }
- }
-
- List<NavigateNode> nextNodes = null;//涓嬩竴姝ュ懡浠よ璧拌矾寰�
- if (commandStep + 1 < commands.size()) {
- NyShuttleHttpCommand nextCommand = commands.get(commandStep + 1);//涓嬩竴姝ュ懡浠�
- nextNodes = nextCommand.getNodes();//涓嬩竴姝ュ懡浠よ璧拌矾寰�
- }
-
- if (shuttleProtocol.getFree() == ShuttleStatusType.BUSY.id) {
- return false;//灏忚溅鐘舵�佸繖锛岀姝㈡墽琛屽懡浠�
- }
-
- //妫�娴嬪皬杞︽槸鍚﹁杩涙彁鍗囨満锛屽闇�瑕佽繘鎻愬崌鏈哄垯璋冨害鎻愬崌鏈�
- if (!checkLiftStation(wrkNo)) {
- return false;
- }
-
- //妫�娴嬬┛姊溅鏄惁鍦ㄦ彁鍗囨満鍐�
- if (!checkShuttleInTheLift(wrkNo)) {
- return false;
- }
-
- //妫�娴嬭矾寰勬槸鍚﹀彲琛岃蛋
- if (!checkPath(command.getNodes(), nextNodes)) {
- return false;
- }
-
- //閿佸畾璺緞锛岄攣瀹氬綋鍓嶈矾寰勫拰涓嬩竴姝ヨ矾寰�
- List<NavigateNode> nodes = command.getNodes();
- nodes.addAll(nextNodes);
- navigateMapData.writeNavigateNodeToRedisMap(nodes, true);//鎵�浣跨敤鐨勮矾寰勮繘琛岄攣瀹氱鐢�
+// if (commandStep != 0) {
+// //鍒ゆ柇涓婁竴鏉℃寚浠ゆ槸鍚﹀畬鎴�
+// NyShuttleHttpCommand lastCommand = commands.get(commandStep - 1);
+// String requestType = lastCommand.getRequest().getBody().get("requestType").toString();
+// if (requestType.equals("move") || requestType.equals("intoLift") || requestType.equals("outLift")) {
+// //绉诲姩鍛戒护銆佸嚭鍏ユ彁鍗囨満鍛戒护
+// NyShuttleProtocol.NyShuttlePointClass target = JSON.parseObject(lastCommand.getRequest().getBody().get("target").toString(), NyShuttleProtocol.NyShuttlePointClass.class);
+// if (shuttleProtocol.getPoint().equals(target)) {
+// //涓婁竴鏉℃寚浠ょ殑鐩爣浣嶇疆鍜屽綋鍓嶅皬杞︿綅缃浉鍚岋紝鍒欒瀹氫笂涓�鏉′换鍔″畬鎴�
+// lastCommand.setComplete(true);
+// //瑙ｉ攣閿佸畾璺緞锛屼笂涓�鏉¤矾寰勫拰褰撳墠璺緞
+// List<NavigateNode> nodes = lastCommand.getNodes();
+// nodes.addAll(command.getNodes());
+// navigateMapData.writeNavigateNodeToRedisMap(nodes, false);//瑙ｉ攣璺緞
+// }
+// }else {
+// lastCommand.setComplete(true);//鍏朵粬鍛戒护榛樿璁や负瀹屾垚
+// }
+// //浠诲姟鏁版嵁淇濆瓨鍒皉edis
+// redisUtil.set("shuttle_wrk_no_" + redisCommand.getWrkNo(), JSON.toJSONString(redisCommand));
+//
+// if (!lastCommand.getComplete()) {
+// //涓婁竴鏉′换鍔℃湭瀹屾垚锛岀姝笅鍙戝懡浠�
+// return false;
+// }
+// }
+//
+// List<NavigateNode> nextNodes = null;//涓嬩竴姝ュ懡浠よ璧拌矾寰�
+// if (commandStep + 1 < commands.size()) {
+// NyShuttleHttpCommand nextCommand = commands.get(commandStep + 1);//涓嬩竴姝ュ懡浠�
+// nextNodes = nextCommand.getNodes();//涓嬩竴姝ュ懡浠よ璧拌矾寰�
+// }
+//
+// if (shuttleProtocol.getFree() == ShuttleStatusType.BUSY.id) {
+// return false;//灏忚溅鐘舵�佸繖锛岀姝㈡墽琛屽懡浠�
+// }
+//
+// //妫�娴嬪皬杞︽槸鍚﹁杩涙彁鍗囨満锛屽闇�瑕佽繘鎻愬崌鏈哄垯璋冨害鎻愬崌鏈�
+// if (!checkLiftStation(wrkNo)) {
+// return false;
+// }
+//
+// //妫�娴嬬┛姊溅鏄惁鍦ㄦ彁鍗囨満鍐�
+// if (!checkShuttleInTheLift(wrkNo)) {
+// return false;
+// }
+//
+// //妫�娴嬭矾寰勬槸鍚﹀彲琛岃蛋
+// if (!checkPath(command.getNodes(), nextNodes, redisCommand)) {
+// return false;
+// }
+//
+// //閿佸畾璺緞锛岄攣瀹氬綋鍓嶈矾寰勫拰涓嬩竴姝ヨ矾寰�
+// List<NavigateNode> nodes = command.getNodes();
+// nodes.addAll(nextNodes);
+// navigateMapData.writeNavigateNodeToRedisMap(nodes, true);//鎵�浣跨敤鐨勮矾寰勮繘琛岄攣瀹氱鐢�
//鍙墽琛屽懡浠�
if (!write(command)) {
@@ -554,8 +569,9 @@
/**
* 妫�娴嬭矾寰勬槸鍚﹀彲琛岃蛋
+ * 濡傛灉璺緞涓虹洰鏍囧簱浣嶏紝浣嗕笉鍙璧帮紝绯荤粺灏嗗皾璇曢噸鏂拌绠楄矾寰�
*/
- private boolean checkPath(List<NavigateNode> currentNodes, List<NavigateNode> nextNodes) {
+ private boolean checkPath(List<NavigateNode> currentNodes, List<NavigateNode> nextNodes, ShuttleRedisCommand redisCommand) {
//妫�娴嬭矾寰勬槸鍚﹀彲琛岃蛋(妫�鏌ヨ矾寰勯攣瀹氱姸鎬侊紝妫�娴嬭矾寰勬槸鍚︽湁鍏朵粬灏忚溅)
//妫�娴嬪綋鍓嶈璧拌矾寰勶紝鍜屼笅涓�姝ヨ矾寰�
boolean checkPathIsAvailable = NavigateUtils.checkPathIsAvailable(currentNodes, shuttleProtocol.getShuttleNo().intValue(), Utils.getLev(shuttleProtocol.getCurrentLocNo()));
@@ -563,6 +579,41 @@
if (checkPathIsAvailable && checkPathIsAvailable2) {
return true;//鍙璧�
}
+
+ ShuttleAssignCommand assignCommand = redisCommand.getAssignCommand();
+ NavigateNode currentTarget = currentNodes.get(currentNodes.size() - 1);
+ String currentLocNo = NavigatePositionConvert.nodeToLocNo(currentTarget);
+ NavigateNode nextTarget = nextNodes.get(nextNodes.size() - 1);
+ String nextLocNo = NavigatePositionConvert.nodeToLocNo(nextTarget);
+ if (assignCommand.getLocNo().equals(currentLocNo) || assignCommand.getLocNo().equals(nextLocNo)) {
+ //褰撳墠璺緞鏈�鍚庝竴涓妭鐐规槸鐩爣搴撲綅锛岃繘琛岃矾寰勬娴嬶紝濡傛灉涓嶅彲琛岃蛋锛岄噸鏂拌绠楄矾寰�
+ //涓嶅彲琛岃蛋锛岄噸鏂拌绠楄矾寰�
+ NyShuttleOperaResult result = NyShuttleOperaUtils.getStartToTargetCommands(shuttleProtocol.getShuttleNo().intValue(), shuttleProtocol.getTaskNo(), shuttleProtocol.getCurrentLocNo(), assignCommand.getLocNo());
+ if (result == null) {
+ return false;//璺緞璁＄畻澶辫触锛屼笉鍙璧�
+ }
+
+ List<NyShuttleHttpCommand> newCommands = result.getCommands();//鏂拌矾寰�
+
+ //褰撳墠姝ュ簭
+ int commandStep = redisCommand.getCommandStep();
+ List<NyShuttleHttpCommand> commands = assignCommand.getCommands();
+
+ commands.remove(commandStep);//绉婚櫎褰撳墠姝ュ簭鎸囦护
+ if (assignCommand.getLocNo().equals(currentLocNo)) {
+ //褰撳墠璺緞锛岄渶瑕佸啀澶氱Щ闄や笅涓�姝ユ寚浠�
+ commands.remove(commandStep + 1);
+ }
+
+ //灏嗘柊璺緞娣诲姞杩涙寚浠ら泦鍚�
+ commands.addAll(commandStep, newCommands);
+ assignCommand.setCommands(commands);
+ redisCommand.setAssignCommand(assignCommand);
+ //浠诲姟鏁版嵁淇濆瓨鍒皉edis
+ redisUtil.set("shuttle_wrk_no_" + redisCommand.getWrkNo(), JSON.toJSONString(redisCommand));
+ return false;//褰撳墠涓嶅彲琛岃蛋锛岀瓑寰呬笅涓�娆℃墽琛岃蛋鏂拌矾寰�
+ }
+
return false;//涓嶅彲琛岃蛋
}
--
Gitblit v1.9.1