#map latest test

Junjie

2023-12-19 5c6978b62f16d7f947b07e287ca9c611ad849ce4

 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;
@@ -27,6 +29,7 @@
import com.zy.core.cache.OutputQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.CrnModeType;
import com.zy.core.enums.RedisKeyType;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.CrnSlave;
import com.zy.core.model.DevpSlave;
@@ -39,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;
@@ -68,6 +73,8 @@
    private LocMastMapper locMastMapper;
    @Autowired
    private RedisUtil redisUtil;
    @Value("${super.pwd}")
    private String superPwd;

    @PostMapping("/system/running/status")
    @ManagerAuth(memo = "系统运行状态")
@@ -312,7 +319,7 @@
    @GetMapping("/map/{lev}/auth")
    @ManagerAuth
    public R getMapFromRedis(@PathVariable Integer lev) {
        Object data = redisUtil.get("realtimeBasMap_" + lev);
        Object data = redisUtil.get(RedisKeyType.MAP.key + lev);
        if (data == null) {
            return R.error();
        }
@@ -401,7 +408,7 @@
            }

            //将数据库地图数据存入redis
            redisUtil.set("realtimeBasMap_" + i, JSON.toJSONString(basMap));
            redisUtil.set(RedisKeyType.MAP.key + i, JSON.toJSONString(basMap));
        }
        return R.ok();
    }
@@ -410,7 +417,21 @@
     * 重置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);
@@ -427,7 +448,7 @@
            if (!basMapService.insert(basMap)) {
                log.info("地图数据存储失败");
            }
        }else {
        } else {
            basMap.setData(JSON.toJSONString(lists));
            basMap.setUpdateTime(new Date());
            if (!basMapService.updateById(basMap)) {
@@ -436,7 +457,7 @@
        }

        //将数据库地图数据存入redis
        redisUtil.set("realtimeBasMap_" + lev, JSON.toJSONString(basMap));
        redisUtil.set(RedisKeyType.MAP.key + lev, JSON.toJSONString(basMap));
        return R.ok();
    }