From 6182cc11c3e93610df7fda87611d2ca807c6354c Mon Sep 17 00:00:00 2001
From: qlsxk <qlsxk@qq.com>
Date: 星期四, 16 十月 2025 14:28:30 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/common/utils/NavigateMapUtils.java | 169 ++++++++++++++++++++++++++++++++++++++------------------
1 files changed, 115 insertions(+), 54 deletions(-)
diff --git a/src/main/java/com/zy/common/utils/NavigateMapUtils.java b/src/main/java/com/zy/common/utils/NavigateMapUtils.java
index ad25bb3..49c72a9 100644
--- a/src/main/java/com/zy/common/utils/NavigateMapUtils.java
+++ b/src/main/java/com/zy/common/utils/NavigateMapUtils.java
@@ -1,80 +1,141 @@
package com.zy.common.utils;
-import com.alibaba.fastjson.JSON;
-import com.core.common.SpringUtils;
-import com.zy.asrs.entity.BasMap;
-import com.zy.common.model.MapNode;
+import com.zy.asrs.utils.Utils;
import com.zy.common.model.NavigateNode;
-import com.zy.common.model.enums.NavigationMapType;
+import com.zy.core.cache.SlaveConnection;
+import com.zy.core.enums.RedisKeyType;
+import com.zy.core.enums.SlaveType;
+import com.zy.core.model.protocol.ShuttleProtocol;
+import com.zy.core.thread.ShuttleThread;
+import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
-import java.util.Date;
+import java.util.HashMap;
import java.util.List;
+import java.util.Map;
@Component
public class NavigateMapUtils {
+
+ @Autowired
+ private RedisUtil redisUtil;
+
+ public synchronized boolean clearPath(Integer shuttleNo) {
+ ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttleNo);
+ if (shuttleThread == null) {
+ return false;
+ }
+
+ ShuttleProtocol shuttleProtocol = shuttleThread.getStatus();
+ if (shuttleProtocol == null) {
+ return false;
+ }
+
+ String currentLocNo = shuttleProtocol.getCurrentLocNo();
+ int lev = Utils.getLev(currentLocNo);
+
+ HashMap<String, Object> lockMap = new HashMap<>();
+ Object o = redisUtil.get(RedisKeyType.LOCK_MAP_NODES.key + lev);
+ if (o != null) {
+ lockMap = (HashMap<String, Object>) o;
+ }
+
+ List<NavigateNode> list = new ArrayList<>();
+ for (Map.Entry<String, Object> entry : lockMap.entrySet()) {
+ String locNo = entry.getKey();
+ Integer value = (Integer) entry.getValue();
+ if (value.equals(shuttleNo)) {
+ NavigateNode navigateNode = NavigatePositionConvert.locNoToNode(locNo);
+ list.add(navigateNode);
+ }
+ }
+
+ return writeNavigateNodeToRedisMap(lev, shuttleNo, list, false);
+ }
/**
* 鍐欏叆璺緞鑺傜偣鏁版嵁鍒皉edis鍦板浘涓�
* lock涓簍rue 绂佺敤搴撲綅锛宭ock涓篺alse鎭㈠搴撲綅
*/
- public synchronized boolean writeNavigateNodeToRedisMap(Integer lev, List<NavigateNode> nodes, boolean lock) {
- RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class);
- try {
- NavigateMapData navigateMapData = new NavigateMapData(lev);
+ public synchronized boolean writeNavigateNodeToRedisMap(Integer lev, Integer shuttleNo, List<NavigateNode> nodes, boolean lock) {
+ if (lock) {
+ return lockNodes(lev, shuttleNo, nodes);
+ }else {
+ return unlockNodes(lev, shuttleNo, nodes);
+ }
+ }
- Object o = redisUtil.get("realtimeBasMap_" + lev);
- if (o == null) {
+ public synchronized boolean lockNodes(Integer lev, Integer shuttleNo, List<NavigateNode> nodes) {
+ if (nodes.isEmpty()) {
+ return false;
+ }
+
+ HashMap<String, Object> lockMap = new HashMap<>();
+ Object o = redisUtil.get(RedisKeyType.LOCK_MAP_NODES.key + lev);
+ if (o != null) {
+ lockMap = (HashMap<String, Object>) o;
+ }
+
+ List<String> shuttleList = new ArrayList<>();
+ //鑾峰彇灏忚溅鑺傜偣-鑾峰彇闄ょ櫧鍚嶅崟澶栫殑鎸囧畾妤煎眰鍏ㄩ儴绌挎杞y鍧愭爣鐐�
+ List<int[]> shuttlePoints = Utils.getShuttlePoints(shuttleNo, lev);
+ for (int[] point : shuttlePoints) {
+ String key = Utils.getLocNo(point[0], point[1], lev);
+ shuttleList.add(key);
+ }
+
+ HashMap<String, Object> tmpMap = new HashMap<>();
+ for (NavigateNode node : nodes) {
+ String key = Utils.getLocNo(node.getX(), node.getY(), lev);
+
+ //鍒ゆ柇鑺傜偣鏄惁鏈夊皬杞�
+ if(shuttleList.contains(key)) {
return false;
}
- BasMap basMap = JSON.parseObject(o.toString(), BasMap.class);
- ArrayList arrayList = JSON.parseObject(basMap.getData(), ArrayList.class);
- List<List<MapNode>> lists = navigateMapData.filterMap(NavigationMapType.NONE.id, arrayList, lev, null, null);//鑾峰彇鍏ㄩ儴鍦板浘鏁版嵁
-
- //妫�娴嬭矾寰勬槸鍚﹁閿佸畾
- if (lock) {
- for (NavigateNode node : nodes) {
- List<MapNode> listX = lists.get(node.getX());
- MapNode mapNode = listX.get(node.getY());
- if (mapNode.getValue() == -999) {
- return false;//璺緞琚攣瀹氳繃锛岀姝㈠啀娆￠攣瀹�
- }
+ //鍒ゆ柇鑺傜偣鏄惁琚攣瀹�
+ if(lockMap.containsKey(key)) {
+ Integer deviceNo = (Integer) lockMap.get(key);
+ if (!shuttleNo.equals(deviceNo)) {//绛夊緟閿佸畾鐨勮妭鐐瑰凡琚綋鍓嶅皬杞﹂攣瀹氾紝璁ゅ畾閿佸畾鎴愬姛
+ return false;
}
}
- //灏濊瘯閿佸畾/瑙ｉ攣璺緞
- NavigateMapData mapData = new NavigateMapData(nodes.get(0).getZ());
- List<List<MapNode>> realMap = mapData.getJsonData(-1, null, null);//鑾峰彇瀹屾暣鍦板浘(鍖呮嫭鍏ュ簱鍑哄簱)
- for (NavigateNode node : nodes) {
- if (node.getZ() != lev) {
- continue;
- }
-
- List<MapNode> listX = lists.get(node.getX());
- MapNode mapNode = listX.get(node.getY());
- if (lock) {
- mapNode.setValue(-999);//绂佺敤搴撲綅
- } else {
- //鑾峰彇鍘熷鑺傜偣鏁版嵁
- List<MapNode> rows = realMap.get(node.getX());
- MapNode col = rows.get(node.getY());
- mapNode.setValue(col.getValue());//鎭㈠搴撲綅
- }
-
- listX.set(node.getY(), mapNode);
- lists.set(node.getX(), listX);
- }
- basMap.setData(JSON.toJSONString(lists));
- basMap.setUpdateTime(new Date());
- //灏嗘暟鎹簱鍦板浘鏁版嵁瀛樺叆redis
- redisUtil.set("realtimeBasMap_" + lev, JSON.toJSONString(basMap));
- return true;
- } catch (Exception e) {
- e.printStackTrace();
+ tmpMap.put(key, shuttleNo);
}
- return false;
+
+ lockMap.putAll(tmpMap);
+
+ redisUtil.set(RedisKeyType.LOCK_MAP_NODES.key + lev, lockMap);
+ return true;
+ }
+
+ public synchronized boolean unlockNodes(Integer lev, Integer shuttleNo, List<NavigateNode> nodes) {
+ if (nodes.isEmpty()) {
+ return false;
+ }
+
+ HashMap<String, Object> lockMap = new HashMap<>();
+ Object o = redisUtil.get(RedisKeyType.LOCK_MAP_NODES.key + lev);
+ if (o != null) {
+ lockMap = (HashMap<String, Object>) o;
+ }
+
+ for (NavigateNode node : nodes) {
+ String key = Utils.getLocNo(node.getX(), node.getY(), lev);
+
+ if(!lockMap.containsKey(key)) {
+ continue;
+ }
+
+ Integer deviceNo = (Integer) lockMap.get(key);
+ if(deviceNo.equals(shuttleNo)) {
+ lockMap.remove(key);
+ }
+ }
+ redisUtil.set(RedisKeyType.LOCK_MAP_NODES.key + lev, lockMap);
+ return true;
}
}
--
Gitblit v1.9.1