From a2d6371396f74e4fb30a4c79e91c6b371a77d0b5 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期五, 22 十一月 2024 20:54:07 +0800
Subject: [PATCH] #读取地图文件优化

---
 src/main/java/com/zy/asrs/controller/ConsoleController.java |   51 ++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 42 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/ConsoleController.java b/src/main/java/com/zy/asrs/controller/ConsoleController.java
index 3c08969..3b9c31b 100644
--- a/src/main/java/com/zy/asrs/controller/ConsoleController.java
+++ b/src/main/java/com/zy/asrs/controller/ConsoleController.java
@@ -3,6 +3,7 @@
 import com.alibaba.fastjson.JSON;
 import com.core.annotations.ManagerAuth;
 import com.core.common.Arith;
+import com.core.common.BaseRes;
 import com.core.common.Cools;
 import com.core.common.R;
 import com.zy.asrs.domain.enums.CrnStatusType;
@@ -19,6 +20,7 @@
 import com.zy.common.CodeRes;
 import com.zy.common.model.MapNode;
 import com.zy.common.model.enums.NavigationMapType;
+import com.zy.common.utils.Http;
 import com.zy.common.utils.NavigateMapData;
 import com.zy.common.utils.RedisUtil;
 import com.zy.core.CrnThread;
@@ -40,8 +42,10 @@
 import com.zy.core.thread.SiemensCrnThread;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletRequest;
 import java.io.BufferedReader;
 import java.io.File;
 import java.io.FileInputStream;
@@ -69,6 +73,10 @@
     private LocMastMapper locMastMapper;
     @Autowired
     private RedisUtil redisUtil;
+    @Value("${super.pwd}")
+    private String superPwd;
+    @Autowired
+    private NavigateMapData navigateMapData;
 
     @PostMapping("/system/running/status")
     @ManagerAuth(memo = "绯荤粺杩愯鐘舵��")
@@ -307,6 +315,19 @@
         return R.ok().add(JSON.toJSONString(new ArrayList<>(OutputQueue.BARCODE)));
     }
 
+    @GetMapping("/barcode/list")
+    public R barcodeList(){
+        ArrayList<HashMap<String, Object>> list = new ArrayList<>();
+        for (Slave slave : slaveProperties.getBarcode()) {
+            HashMap<String, Object> map = new HashMap<>();
+            BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, slave.getId());
+            map.put("id", slave.getId());
+            map.put("barcode", barcodeThread.getBarcode());
+            list.add(map);
+        }
+        return R.ok().add(list);
+    }
+
     /**
      * 鑾峰彇鍦板浘鏁版嵁
      */
@@ -321,7 +342,7 @@
         BasMap basMap = JSON.parseObject(data.toString(), BasMap.class);
         //瑙f瀽json鍦板浘鏁版嵁
         ArrayList arrayList = JSON.parseObject(basMap.getData(), ArrayList.class);
-        NavigateMapData navigateMapData = new NavigateMapData(lev);
+        navigateMapData.setLev(lev);
         List<List<MapNode>> lists = navigateMapData.filterMap(NavigationMapType.NONE.id, arrayList, lev, null, null);//杩囨护鍦板浘鏁版嵁
         return R.ok().add(lists);
     }
@@ -346,8 +367,6 @@
                 }
                 br.close();
             }
-
-            NavigateMapData navigateMapData = new NavigateMapData();
 
             //瑙f瀽json鍦板浘鏁版嵁
             ArrayList arrayList = JSON.parseObject(stringBuffer.toString(), ArrayList.class);
@@ -379,8 +398,8 @@
         for (int i = 1; i <= 10; i++) {//鎬诲叡10灞傛ゼ
             BasMap basMap = basMapService.selectLatestMap(i);
             //杞藉叆鍦板浘
-            NavigateMapData mapData = new NavigateMapData(i);
-            List<List<MapNode>> lists = mapData.getJsonData(-1, null, null);//鑾峰彇瀹屾暣鍦板浘(鍖呮嫭鍏ュ簱鍑哄簱)
+            navigateMapData.setLev(i);
+            List<List<MapNode>> lists = navigateMapData.getJsonData(-1, null, null);//鑾峰彇瀹屾暣鍦板浘(鍖呮嫭鍏ュ簱鍑哄簱)
             if (basMap == null) {
                 //鏁版嵁搴撲腑涔熶笉瀛樺湪鍦板浘鏁版嵁锛屼粠鍦板浘鏂囦欢涓幏鍙�
                 //瀛樺叆鏁版嵁搴�
@@ -411,11 +430,25 @@
      * 閲嶇疆redis涓殑鍦板浘锛屽皢鍗犵敤鐨勫簱浣嶅叏閮ㄨВ闄�
      */
     @GetMapping("/map/resetMap/{lev}")
-    public R resetMapToRedisByLev(@PathVariable Integer lev) {
+    @ManagerAuth(memo = "閲嶇疆Redis鍦板浘")
+    public R resetMapToRedisByLev(@PathVariable Integer lev, HttpServletRequest request) {
+        // super璐﹀彿
+        String token = request.getHeader("token");
+        if (token == null) {
+            return R.error();
+        }
+        String deToken = Cools.deTokn(token, superPwd);
+        if (deToken == null) {
+            return R.error("鏉冮檺涓嶈冻");
+        }
+        if (!"super".equals(deToken.substring(13))) {
+            return R.error("鏉冮檺涓嶈冻");
+        }
+
         BasMap basMap = basMapService.selectLatestMap(lev);
         //杞藉叆鍦板浘
-        NavigateMapData mapData = new NavigateMapData(lev);
-        List<List<MapNode>> lists = mapData.getJsonData(-1, null, null);//鑾峰彇瀹屾暣鍦板浘(鍖呮嫭鍏ュ簱鍑哄簱)
+        navigateMapData.setLev(lev);
+        List<List<MapNode>> lists = navigateMapData.getJsonData(-1, null, null);//鑾峰彇瀹屾暣鍦板浘(鍖呮嫭鍏ュ簱鍑哄簱)
         if (basMap == null) {
             //鏁版嵁搴撲腑涔熶笉瀛樺湪鍦板浘鏁版嵁锛屼粠鍦板浘鏂囦欢涓幏鍙�
             //瀛樺叆鏁版嵁搴�
@@ -428,7 +461,7 @@
             if (!basMapService.insert(basMap)) {
                 log.info("鍦板浘鏁版嵁瀛樺偍澶辫触");
             }
-        }else {
+        } else {
             basMap.setData(JSON.toJSONString(lists));
             basMap.setUpdateTime(new Date());
             if (!basMapService.updateById(basMap)) {

--
Gitblit v1.9.1