| | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.core.common.SpringUtils; |
| | | import com.zy.asrs.entity.BasMap; |
| | | import com.zy.asrs.utils.Utils; |
| | | import com.zy.common.model.MapNode; |
| | | import com.zy.common.model.NavigateNode; |
| | | import com.zy.common.model.enums.NavigationMapType; |
| | | import com.zy.core.enums.RedisKeyType; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.ArrayList; |
| | |
| | | * 写入路径节点数据到redis地图中 |
| | | * lock为true 禁用库位,lock为false恢复库位 |
| | | */ |
| | | public synchronized boolean writeNavigateNodeToRedisMap(Integer lev, List<NavigateNode> nodes, boolean lock) { |
| | | public synchronized boolean writeNavigateNodeToRedisMap(Integer lev, Integer shuttleNo, List<NavigateNode> nodes, boolean lock) { |
| | | RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); |
| | | NavigateMapData navigateMapData = SpringUtils.getBean(NavigateMapData.class); |
| | | try { |
| | | NavigateMapData navigateMapData = new NavigateMapData(lev); |
| | | if (nodes.isEmpty()) { |
| | | return true; |
| | | } |
| | | |
| | | // if (!redisUtil.tryLock("realtimeBasMap_" + lev)) { |
| | | // return false;//加锁失败 |
| | | // } |
| | | |
| | | Object o = redisUtil.get("realtimeBasMap_" + lev); |
| | | navigateMapData.setLev(lev); |
| | | Object o = redisUtil.get(RedisKeyType.MAP.key + lev); |
| | | if (o == null) { |
| | | return false; |
| | | } |
| | | |
| | | //获取小车节点 |
| | | List<int[]> shuttlePoints = Utils.getShuttlePoints(shuttleNo, lev); |
| | | |
| | | BasMap basMap = JSON.parseObject(o.toString(), BasMap.class); |
| | | ArrayList arrayList = JSON.parseObject(basMap.getData(), ArrayList.class); |
| | | //带小车地图 |
| | | List<List<MapNode>> listsHasShuttle = navigateMapData.filterMap(NavigationMapType.NONE.id, arrayList, lev, null, shuttlePoints);//获取带小车地图数据 |
| | | List<List<MapNode>> lists = navigateMapData.filterMap(NavigationMapType.NONE.id, arrayList, lev, null, null);//获取全部地图数据 |
| | | |
| | | NavigateMapData mapData = new NavigateMapData(nodes.get(0).getZ()); |
| | | List<List<MapNode>> realMap = mapData.getJsonData(-1, null, null);//获取完整地图(包括入库出库) |
| | | //检测路径是否被锁定 |
| | | if (lock) { |
| | | for (NavigateNode node : nodes) { |
| | | List<MapNode> listX = listsHasShuttle.get(node.getX()); |
| | | MapNode mapNode = listX.get(node.getY()); |
| | | if (mapNode.getValue() == -999) { |
| | | return false;//路径被锁定过,禁止再次锁定 |
| | | } |
| | | if (mapNode.getValue() == 66) { |
| | | return false;//路径存在小车,禁止锁定 |
| | | } |
| | | } |
| | | } |
| | | |
| | | //尝试锁定/解锁路径 |
| | | navigateMapData.setLev(nodes.get(0).getZ()); |
| | | List<List<MapNode>> realMap = navigateMapData.getJsonData(-1, null, null);//获取完整地图(包括入库出库) |
| | | for (NavigateNode node : nodes) { |
| | | if (node.getZ() != lev) { |
| | | continue; |
| | |
| | | basMap.setData(JSON.toJSONString(lists)); |
| | | basMap.setUpdateTime(new Date()); |
| | | //将数据库地图数据存入redis |
| | | redisUtil.set("realtimeBasMap_" + lev, JSON.toJSONString(basMap)); |
| | | // //解锁 |
| | | // redisUtil.unlock("realtimeBasMap_" + lev); |
| | | redisUtil.set(RedisKeyType.MAP.key + lev, JSON.toJSONString(basMap)); |
| | | return true; |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |