From 77ba9a8e95927efc361268c005ae907e709da2c4 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期三, 12 六月 2024 16:55:35 +0800
Subject: [PATCH] #
---
zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/NyShuttleThread.java | 24 ++++++++++++++++++------
1 files changed, 18 insertions(+), 6 deletions(-)
diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/NyShuttleThread.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/NyShuttleThread.java
index 697f489..a8f70d1 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/NyShuttleThread.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/rcs/thread/impl/NyShuttleThread.java
@@ -24,6 +24,7 @@
import com.zy.asrs.wcs.core.utils.NavigateMapData;
import com.zy.asrs.wcs.core.utils.NavigatePositionConvert;
import com.zy.asrs.wcs.core.utils.RedisUtil;
+import com.zy.asrs.wcs.core.utils.Utils;
import com.zy.asrs.wcs.rcs.News;
import com.zy.asrs.wcs.rcs.cache.OutputQueue;
import com.zy.asrs.wcs.rcs.constant.DeviceRedisConstant;
@@ -99,17 +100,15 @@
BufferedReader reader = new BufferedReader(new InputStreamReader(this.socket.getInputStream()));
// 璇诲彇鏈嶅姟鍣ㄧ殑鍝嶅簲
StringBuffer sb = new StringBuffer();
- String response = null;
char[] chars = new char[2048];//缂撳啿鍖�
- do {
+ while (true) {
reader.read(chars);
- String trim = new String(chars).trim();
+ String trim = new String(chars);
sb.append(trim);
- if (sb.lastIndexOf("\r\n") != -1) {
+ if (trim.lastIndexOf("\r\n") != -1) {
break;
}
- } while (response != null);
-// System.out.println("Received response from server: " + sb);
+ }
JSONObject result = JSON.parseObject(sb.toString());//寰楀埌鍝嶅簲缁撴灉闆�
if (!socketResults.isEmpty() && socketResults.size() >= 5) {
@@ -614,6 +613,7 @@
@Override
public List<NavigateNode> getMoveAdvancePath() {
ObjectMapper objectMapper = SpringUtils.getBean(ObjectMapper.class);
+ NavigateMapData navigateMapData = SpringUtils.getBean(NavigateMapData.class);
ArrayList<NavigateNode> path = new ArrayList<>();
if (shuttleProtocol.getTaskNo() != 0) {
//瀛樺湪浠诲姟锛岃幏鍙栨寚浠�
@@ -632,6 +632,18 @@
if (!nodes.isEmpty()) {
path.addAll(nodes);
}
+
+ //灏嗚矾寰勯攣涓庡皬杞﹁矾寰勮繘琛屽尮閰�
+ ArrayList<NavigateNode> tmp = new ArrayList<>();
+ //妫�娴嬭矾寰勬槸鍚﹁閿佸畾
+ int[][] map = navigateMapData.getDataFromRedis(NavigationMapType.DFX.id, null, null);
+ for (NavigateNode node : path) {
+ if(map[node.getX()][node.getY()] == -999) {
+ tmp.add(node);
+ }
+ }
+
+ path = tmp;
}
}
return path;
--
Gitblit v1.9.1