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