三一车辆追踪加入预推送位置提交

zhangnaisong

2024-02-05 748ab31dc10c24dd4cdfffdcbc39527d1f79ae12

 ard-work/src/main/java/com/ruoyi/sy/service/impl/ArdSyCarServiceImpl.java

@@ -328,59 +328,26 @@

    @Override
    public List<Map<String, String>> getAllCarModel() {
        boolean exsit = MinioUtil.exitsBucket("sycar");
        boolean exsit = MinioUtil.exitsBucket("system");
        if (exsit) {
            List<Map<String, String>> listObjetcName = new ArrayList<>();
            try {
               // ListObjectsArgs listObjectsArgs = ListObjectsArgs.builder().prefix("carmodel/").bucket("sycar").build();
                Iterable<Result<Item>> myObjects = MinioUtil.getObjectsByBucket("sycar","carmodel");
                //Iterable<Result<Item>> myObjects = MinioUtil.getObjectsByBucket("sycar","carmodel");
                Iterable<Result<Item>> myObjects = MinioUtil.getObjectsByBucket("system","model/car");
                for (Result<Item> result : myObjects) {
                    Item item = result.get();
                    Map<String, String> map = new HashMap();
                    String[] strArr = item.objectName().split("/");
                    map.put("carType", strArr[1]);
                    map.put("carModel", "sycar/" + item.objectName());
                    /*switch (item.objectName()) {
                        case "carmodel/aodi.glb":
                            map.put("carType", "奥迪");
                            break;
                        case "carmodel/baolai.glb":
                            map.put("carType", "宝来");
                            break;
                        case "carmodel/bieke.glb":
                            map.put("carType", "别克");
                            break;
                        case "carmodel/bus1.glb":
                            map.put("carType", "大客车");
                            break;
                        case "carmodel/car.glb":
                            map.put("carType", "小型车");
                            break;
                        case "carmodel/fire(1).glb":
                            map.put("carType", "消防车");
                            break;
                        case "carmodel/fute.glb":
                            map.put("carType", "福特");
                            break;
                        case "carmodel/jingche_a.glb":
                            map.put("carType", "警车");
                            break;
                        case "carmodel/jiuhu.glb":
                            map.put("carType", "救护车");
                            break;
                        case "carmodel/oil.glb":
                            map.put("carType", "油罐车");
                            break;
                        case "carmodel/truck.glb":
                            map.put("carType", "工程用车");
                            break;
                        case "carmodel/van1.glb":
                            map.put("carType", "大货车");
                            break;
                        default:
                            break;
                    }*/
                    listObjetcName.add(map);
                    try{
                        String carType = strArr[2];
                        if(!carType.contains(".")){
                            map.put("carType", carType);
                            map.put("carModel", "system/" + item.objectName());
                            listObjetcName.add(map);
                        }
                    }catch(Exception e){

                    }
                }
                return listObjetcName;
            } catch (Exception ex) {
@@ -934,15 +901,22 @@

    @Override
    public Results chaseCarByCarId(String usersId, String carId, String cycle) {
        String sessionId = "";
        for(String key : ONLINE_USER_SESSIONS.keySet()){
            if(key.startsWith(usersId + "_")){
                sessionId = key;
            }
        }
        if(sessionId.equals("")){//没有session就返回失败
            return Results.error("追踪失败");
        }
        try {
            /*Map<String,Map<String,Object>> map = new HashMap();
            map.put(carId,new HashMap());
            PositionContainer.getUserPositionMap().put(usersId,map);*/
            if (cycle.equals("0")) {
                if (userCarTimerMap.get(usersId) != null) {
                    userCarTimerMap.get(usersId).cancel();
                    userCarTimerMap.remove(usersId);
                    PositionContainer.getUserPositionMap().remove(usersId);
                    System.out.println("停止追踪");
                }
                return Results.succeed("停止追踪");
            } else {
@@ -953,8 +927,19 @@
                    Map<String, Map<String, Object>> map = new HashMap();
                    map.put(carId, new HashMap());
                    PositionContainer.getUserPositionMap().put(usersId, map);
                    Map<String, Object> position = PositionContainer.getCarPositionMap().get(carId);//查询当前车辆位置
                    if (position != null) {
                        if (position.size() != 0) {
                            position.put("elng",position.get("lng"));
                            position.put("elat",position.get("lat"));
                            Map<String, Map<String, Object>> data = new HashMap();
                            data.put("31000", position);
                            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));
                        }
                    }

                    Date date = new Date();
                    Timer carPositionTimer = new Timer();//定时推送实时位置
                    Timer carPositionTimer = new Timer(sessionId);//定时推送实时位置
                    TimerTask carPositionTask = new TimerTask() {
                        @Override
                        public void run() {
@@ -963,11 +948,13 @@
                                if (position.size() != 0) {
                                    Map<String, Map<String, Object>> data = new HashMap();
                                    data.put("31000", position);
                                    //WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
                                    String sessionId = "";
                                    for(String key : ONLINE_USER_SESSIONS.keySet()){
                                        if(key.startsWith(usersId + "_")){
                                            sessionId = key;
                                    String sessionId = Thread.currentThread().getName();
                                    if(ONLINE_USER_SESSIONS.get(sessionId) == null){//用户离线释放资源
                                        if (userCarTimerMap.get(usersId) != null) {
                                            userCarTimerMap.get(usersId).cancel();
                                            userCarTimerMap.remove(usersId);
                                            PositionContainer.getUserPositionMap().remove(usersId);
                                            System.out.println("用户离线，停止追踪");
                                        }
                                    }
                                    WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));
@@ -982,8 +969,19 @@
                    Map<String, Map<String, Object>> map = new HashMap();
                    map.put(carId, new HashMap());
                    PositionContainer.getUserPositionMap().put(usersId, map);
                    Map<String, Object> position = PositionContainer.getCarPositionMap().get(carId);//查询当前车辆位置
                    if (position != null) {
                        if (position.size() != 0) {
                            position.put("elng",position.get("lng"));
                            position.put("elat",position.get("lat"));
                            Map<String, Map<String, Object>> data = new HashMap();
                            data.put("31000", position);
                            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));
                        }
                    }

                    Date date = new Date();
                    Timer carPositionTimer = new Timer();//定时推送实时位置
                    Timer carPositionTimer = new Timer(sessionId);//定时推送实时位置
                    TimerTask carPositionTask = new TimerTask() {
                        @Override
                        public void run() {
@@ -992,11 +990,13 @@
                                if (position.size() != 0) {
                                    Map<String, Map<String, Object>> data = new HashMap();
                                    data.put("31000", position);
                                    //WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
                                    String sessionId = "";
                                    for(String key : ONLINE_USER_SESSIONS.keySet()){
                                        if(key.startsWith(usersId + "_")){
                                            sessionId = key;
                                    String sessionId = Thread.currentThread().getName();
                                    if(ONLINE_USER_SESSIONS.get(sessionId) == null){//用户离线释放资源
                                        if (userCarTimerMap.get(usersId) != null) {
                                            userCarTimerMap.get(usersId).cancel();
                                            userCarTimerMap.remove(usersId);
                                            PositionContainer.getUserPositionMap().remove(usersId);
                                            System.out.println("用户离线，停止追踪");
                                        }
                                    }
                                    WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sessionId), JSON.toJSONString(data));