From e039dbc9aa07fabb13be9673cbb7dfccfecda870 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期六, 23 十一月 2024 08:14:28 +0800 Subject: [PATCH] #读取地图文件优化 --- src/main/java/com/zy/common/utils/NavigateMapData.java | 247 ++++++++++++++++++++++++++++++++---------------- 1 files changed, 163 insertions(+), 84 deletions(-) diff --git a/src/main/java/com/zy/common/utils/NavigateMapData.java b/src/main/java/com/zy/common/utils/NavigateMapData.java index fcc7422..204f937 100644 --- a/src/main/java/com/zy/common/utils/NavigateMapData.java +++ b/src/main/java/com/zy/common/utils/NavigateMapData.java @@ -5,12 +5,15 @@ import com.core.common.SpringUtils; import com.zy.asrs.entity.BasMap; import com.zy.asrs.entity.LocMast; +import com.zy.asrs.service.BasShuttleService; import com.zy.asrs.service.LocMastService; 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.beans.factory.annotation.Autowired; +import org.springframework.core.io.ClassPathResource; import org.springframework.stereotype.Component; import java.io.*; @@ -26,11 +29,11 @@ private Integer lev;//鍦板浘妤煎眰 - public NavigateMapData() { - this.lev = 1; + public Integer getLev() { + return lev; } - public NavigateMapData(Integer lev) { + public void setLev(Integer lev) { this.lev = lev; } @@ -40,42 +43,75 @@ public int[][] getData(Integer mapType, List<int[]> whitePoints, List<int[]> shuttlePoints) { try { - String mapFilename = "map_" + lev + ".json"; - - 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);//杩囨护鍦板浘鏁版嵁 - int[][] map = new int[lists.size()][]; - int j = 0; - for (List<MapNode> list : lists) { - int[] tmp = new int[list.size()]; - int i = 0; - for (MapNode mapNode : list) { - //灏嗘暟鎹坊鍔犺繘浜岀淮鏁扮粍 - tmp[i++] = mapNode.getValue(); - } - //鏁版嵁娣诲姞杩涗竴缁存暟缁� - map[j++] = tmp; - } - - return map; - } else { - System.out.println("鏂囦欢涓嶅瓨鍦�!"); + RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); + Object object = redisUtil.get(RedisKeyType.BASIC_MAP.key + lev); + if (object == null) { + return null; } - } catch (IOException ioException) { - ioException.printStackTrace(); + + //瑙f瀽json鍦板浘鏁版嵁 + ArrayList arrayList = JSON.parseObject(object.toString(), ArrayList.class); + List<List<MapNode>> lists = filterMap(mapType, arrayList, lev, whitePoints, shuttlePoints);//杩囨护鍦板浘鏁版嵁 + int[][] map = new int[lists.size()][]; + int j = 0; + for (List<MapNode> list : lists) { + int[] tmp = new int[list.size()]; + int i = 0; + for (MapNode mapNode : list) { + //灏嗘暟鎹坊鍔犺繘浜岀淮鏁扮粍 + tmp[i++] = mapNode.getValue(); + } + //鏁版嵁娣诲姞杩涗竴缁存暟缁� + map[j++] = tmp; + } + + return map; + +// 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"); +// 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);//杩囨护鍦板浘鏁版嵁 +// int[][] map = new int[lists.size()][]; +// int j = 0; +// for (List<MapNode> list : lists) { +// int[] tmp = new int[list.size()]; +// int i = 0; +// for (MapNode mapNode : list) { +// //灏嗘暟鎹坊鍔犺繘浜岀淮鏁扮粍 +// tmp[i++] = mapNode.getValue(); +// } +// //鏁版嵁娣诲姞杩涗竴缁存暟缁� +// map[j++] = tmp; +// } +// +// if (!file.delete()) { +// System.out.println("涓存椂鏂囦欢鍒犻櫎澶辫触"); +// } +// return map; +// } else { +// System.out.println("鏂囦欢涓嶅瓨鍦�!"); +// } + } catch (Exception e) { + e.printStackTrace(); } return null; } @@ -119,30 +155,52 @@ //鑾峰彇JSON鏍煎紡鏁版嵁 public List<List<MapNode>> getJsonData(Integer mapType, List<int[]> whitePoints, List<int[]> shuttlePoints) { try { - String mapFilename = "map_" + lev + ".json"; - - 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("鏂囦欢涓嶅瓨鍦�!"); + RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); + Object object = redisUtil.get(RedisKeyType.BASIC_MAP.key + lev); + if (object == null) { + return null; } - } catch (IOException ioException) { - ioException.printStackTrace(); + + //瑙f瀽json鍦板浘鏁版嵁 + ArrayList arrayList = JSON.parseObject(object.toString(), ArrayList.class); + List<List<MapNode>> lists = filterMap(mapType, arrayList, lev, whitePoints, shuttlePoints);//杩囨护鍦板浘鏁版嵁 + return lists; + + +// 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"); +// 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);//杩囨护鍦板浘鏁版嵁 +// +// if (!file.delete()) { +// System.out.println("涓存椂鏂囦欢鍒犻櫎澶辫触"); +// } +// +// return lists; +// } else { +// System.out.println("鏂囦欢涓嶅瓨鍦�!"); +// } + } catch (Exception e) { + e.printStackTrace(); } return null; } @@ -150,30 +208,51 @@ //鑾峰彇JSON鏍煎紡鏁版嵁 public List<List<MapNode>> getJsonData(Integer lev, Integer mapType, List<int[]> whitePoints, List<int[]> shuttlePoints) { try { - String mapFilename = "map_" + lev + ".json"; - - 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("鏂囦欢涓嶅瓨鍦�!"); + RedisUtil redisUtil = SpringUtils.getBean(RedisUtil.class); + Object object = redisUtil.get(RedisKeyType.BASIC_MAP.key + lev); + if (object == null) { + return null; } - } catch (IOException ioException) { - ioException.printStackTrace(); + + //瑙f瀽json鍦板浘鏁版嵁 + ArrayList arrayList = JSON.parseObject(object.toString(), ArrayList.class); + List<List<MapNode>> lists = filterMap(mapType, arrayList, lev, whitePoints, shuttlePoints);//杩囨护鍦板浘鏁版嵁 + return lists; + +// 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"); +// 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);//杩囨护鍦板浘鏁版嵁 +// +// if (!file.delete()) { +// System.out.println("涓存椂鏂囦欢鍒犻櫎澶辫触"); +// } +// +// return lists; +// } else { +// System.out.println("鏂囦欢涓嶅瓨鍦�!"); +// } + } catch (Exception e) { + e.printStackTrace(); } return null; } -- Gitblit v1.9.1