From 3b64c807f60e5d6b71deca3f79c9be4be19abfaa Mon Sep 17 00:00:00 2001 From: Junjie <540245094@qq.com> Date: 星期五, 23 二月 2024 10:47:58 +0800 Subject: [PATCH] #显示器更新 --- src/main/java/com/zy/common/utils/NavigateMapData.java | 81 ++++++++++++++++++++++++++++++++++++++-- 1 files changed, 76 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/zy/common/utils/NavigateMapData.java b/src/main/java/com/zy/common/utils/NavigateMapData.java index 6b706e1..f0065b4 100644 --- a/src/main/java/com/zy/common/utils/NavigateMapData.java +++ b/src/main/java/com/zy/common/utils/NavigateMapData.java @@ -9,7 +9,9 @@ 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 com.zy.core.enums.ShuttleTaskModeType; +import org.springframework.core.io.ClassPathResource; import org.springframework.stereotype.Component; import java.io.*; @@ -40,9 +42,15 @@ public int[][] getData(Integer mapType, List<int[]> whitePoints, List<int[]> shuttlePoints) { try { String mapFilename = "map_" + lev + ".json"; + ClassPathResource classPathResource = new ClassPathResource(mapFilename); + InputStream inputStream = classPathResource.getInputStream(); + byte[] buffer = new byte[inputStream.available()]; + inputStream.read(buffer); + File file = File.createTempFile("prefix","suffix"); + try (OutputStream outStream = new FileOutputStream(file)) { + outStream.write(buffer); + } - String fileName = this.getClass().getClassLoader().getResource(mapFilename).getPath();//鑾峰彇鏂囦欢璺緞 - File file = new File(fileName); StringBuffer stringBuffer = new StringBuffer(); if (file.isFile() && file.exists()) { InputStreamReader isr = new InputStreamReader(new FileInputStream(file), "GBK"); @@ -84,7 +92,7 @@ */ public int[][] getDataFromRedis(Integer mapType, List<int[]> whitePoints, List<int[]> shuttlePoints) { RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); - Object o = redisUtil.get("realtimeBasMap_" + lev); + Object o = redisUtil.get(RedisKeyType.MAP.key + lev); if (o == null) { return null; } @@ -119,9 +127,52 @@ public List<List<MapNode>> getJsonData(Integer mapType, List<int[]> whitePoints, List<int[]> shuttlePoints) { try { String mapFilename = "map_" + lev + ".json"; + ClassPathResource classPathResource = new ClassPathResource(mapFilename); + InputStream inputStream = classPathResource.getInputStream(); + byte[] buffer = new byte[inputStream.available()]; + inputStream.read(buffer); + File file = File.createTempFile("prefix","suffix"); + try (OutputStream outStream = new FileOutputStream(file)) { + outStream.write(buffer); + } - String fileName = this.getClass().getClassLoader().getResource(mapFilename).getPath();//鑾峰彇鏂囦欢璺緞 - File file = new File(fileName); + StringBuffer stringBuffer = new StringBuffer(); + if (file.isFile() && file.exists()) { + InputStreamReader isr = new InputStreamReader(new FileInputStream(file), "GBK"); + BufferedReader br = new BufferedReader(isr); + String lineTxt = null; + while ((lineTxt = br.readLine()) != null) { + stringBuffer.append(lineTxt); + } + br.close(); + + //瑙f瀽json鍦板浘鏁版嵁 + ArrayList arrayList = JSON.parseObject(stringBuffer.toString(), ArrayList.class); + List<List<MapNode>> lists = filterMap(mapType, arrayList, lev, whitePoints, shuttlePoints);//杩囨护鍦板浘鏁版嵁 + + return lists; + } else { + System.out.println("鏂囦欢涓嶅瓨鍦�!"); + } + } catch (IOException ioException) { + ioException.printStackTrace(); + } + return null; + } + + //鑾峰彇JSON鏍煎紡鏁版嵁 + public List<List<MapNode>> getJsonData(Integer lev, Integer mapType, List<int[]> whitePoints, List<int[]> shuttlePoints) { + try { + String mapFilename = "map_" + lev + ".json"; + ClassPathResource classPathResource = new ClassPathResource(mapFilename); + InputStream inputStream = classPathResource.getInputStream(); + byte[] buffer = new byte[inputStream.available()]; + inputStream.read(buffer); + File file = File.createTempFile("prefix","suffix"); + try (OutputStream outStream = new FileOutputStream(file)) { + outStream.write(buffer); + } + StringBuffer stringBuffer = new StringBuffer(); if (file.isFile() && file.exists()) { InputStreamReader isr = new InputStreamReader(new FileInputStream(file), "GBK"); @@ -232,6 +283,26 @@ } } + //鍔犺浇鐧藉悕鍗曡妭鐐� + if (whitePoints != null) { + List<List<MapNode>> realMap = getJsonData(lev, -1, null, null);//鑾峰彇瀹屾暣鍦板浘 + for (int[] points : whitePoints) { + //鑾峰彇鍘熷鑺傜偣鏁版嵁 + int x = points[0]; + int y = points[1]; + List<MapNode> rows = realMap.get(x); + MapNode col = rows.get(y); + + List<MapNode> list = lists.get(x); + MapNode mapNode = list.get(y); + mapNode.setValue(col.getValue());//鎭㈠鍘熷鑺傜偣 + + //鏇存柊list + list.set(y, mapNode); + lists.set(x, list); + } + } + return lists; } -- Gitblit v1.9.1