三一车辆实时位置加入用户追踪提交

zhangnaisong

2023-07-28 3d296df1ff6f6c34a68d228f5766ebe44cf169e1

三一车辆实时位置加入用户追踪提交

 ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java

@@ -368,4 +368,14 @@
        String syURL = sysConfigService.getSYURL();
        return ardSyCarService.getCarGPSBycarId(usersId,carId,syURL,ardSyUser);
    }

    @PreAuthorize("@ss.hasPermi('sy:syCar:chaseCarByCarId')")
    @PostMapping("chaseCarByCarId")
    @ApiOperation("根据车辆主键追踪车辆")
    public Results chaseCarByCarId(@RequestBody Map<String,String> map){
        String usersId = SecurityUtils.getUserId();
        String carId = map.get("carId");
        String cycle = map.get("cycle");
        return ardSyCarService.chaseCarByCarId(usersId,carId,cycle);
    }
}

 ard-work/src/main/java/com/ruoyi/sy/gps31/PositionContainer.java

@@ -7,6 +7,8 @@

    private static Map<String, Map<String,Map<String,Object>>> deptPositionMap = new HashMap();//依部门存放实施车辆位置:deptId，carId，车辆位置

    private static Map<String, Map<String,Map<String,Object>>> userPositionMap = new HashMap();//依用户存放实施车辆位置:userId，carId，车辆位置

    public static synchronized Map<String, Map<String, Map<String,Object>>> getDeptPositionMap() {
        return deptPositionMap;
    }
@@ -15,4 +17,11 @@
        PositionContainer.deptPositionMap = deptPositionMap;
    }

    public static synchronized Map<String, Map<String, Map<String, Object>>> getUserPositionMap() {
        return userPositionMap;
    }

    public static synchronized void setUserPositionMap(Map<String, Map<String, Map<String, Object>>> userPositionMap) {
        PositionContainer.userPositionMap = userPositionMap;
    }
}

 ard-work/src/main/java/com/ruoyi/sy/gps31/PushClientImplPosition.java

@@ -113,6 +113,18 @@
                        }
                    }
                }
                //存入用户容器
                if(PositionContainer.getUserPositionMap().size() != 0){
                    for(String userId : PositionContainer.getUserPositionMap().keySet()){
                        Map<String,Map<String,Object>> carIdCarMap =  PositionContainer.getUserPositionMap().get(userId);
                        if(carIdCarMap.keySet().contains(carId)){
                            PositionContainer.getUserPositionMap().get(userId).put(carId,gpsMap);
                        }
                    }
                }



            }
            /**
             *

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

@@ -125,4 +125,9 @@

    Results getCarGPSBycarId(String usersId,String carId,String syURL,ArdSyUser ardSyUser);

    /**
     * 根据用户及车辆主键追踪车辆
     */
    Results chaseCarByCarId(String usersId,String carId,String cycle);

}

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

@@ -1,10 +1,7 @@
package com.ruoyi.sy.service.impl;

import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.function.Predicate;
import java.util.stream.Collectors;

@@ -64,6 +61,8 @@
    private SYClient sYClient;

    private Map<Integer,Map<String,String>> logInMap = new HashMap();

    private  Map<String, Timer> userCarTimerMap = new HashMap();

    /**
     * 查询三一车辆
@@ -364,9 +363,28 @@
    @Override
    public void sendArdSyCarPosition() {
        for(String key : ONLINE_USER_SESSIONS.keySet()){
            if(PositionContainer.getUserPositionMap().keySet().contains(key)){//当追踪的车辆容器包含此用户Id，则实时位置推送需要剔除该车辆
            SysUser sysUser = userMapper.selectUserById(key);
            if(sysUser == null){
                return;
                    //return;
                    continue;
                }
                String deptId = String.valueOf(sysUser.getDeptId());
                Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
                List<String> carIdList = new ArrayList();
                carIdList.addAll(PositionContainer.getUserPositionMap().get(key).keySet());
                String carId = carIdList.get(0);
                map.remove(carId);
                if(map != null){
                    Map<String,Object> data = new HashMap();
                    data.put("30000", map.values());
                    WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
                }
            }else{
                SysUser sysUser = userMapper.selectUserById(key);
                if(sysUser == null){
                    //return;
                    continue;
            }
            String deptId = String.valueOf(sysUser.getDeptId());
            Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
@@ -374,6 +392,7 @@
                Map<String,Object> data = new HashMap();
                data.put("30000", map.values());
                WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
                }
            }
        }
    }
@@ -677,4 +696,65 @@
        result0 = sYClient.getCarNearPositionByCarId(syURL,carId,result.get("userId"),result.get("sessionId"));
        return Results.succeed(result0);
    }

    @Override
    public Results chaseCarByCarId(String usersId, String carId, String cycle) {
        if(ONLINE_USER_SESSIONS.get(usersId) == null){
            userCarTimerMap.get(usersId).cancel();
            userCarTimerMap.remove(usersId);
            PositionContainer.getUserPositionMap().remove(usersId);
            return Results.succeed("停止追踪");
        }
        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);
                }
                return Results.succeed("停止追踪");
            }else{
                if(userCarTimerMap.get(usersId) != null){
                    userCarTimerMap.get(usersId).cancel();
                    userCarTimerMap.remove(usersId);
                    PositionContainer.getUserPositionMap().remove(usersId);
                    Date date = new Date();
                    Timer carPositionTimer = new Timer();//定时推送实时位置
                    TimerTask carPositionTask =new TimerTask(){
                        @Override
                        public void run(){
                            Map<String,Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
                            Map<String,Map<String,Object>> data = new HashMap();
                            data.put("31000",position);
                            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
                        }
                    };
                    carPositionTimer.scheduleAtFixedRate(carPositionTask,date,Integer.parseInt(cycle));//启用
                    this.userCarTimerMap.put(usersId,carPositionTimer);
                    return Results.succeed("开始追踪");
                }else{
                    Date date = new Date();
                    Timer carPositionTimer = new Timer();//定时推送实时位置
                    TimerTask carPositionTask =new TimerTask(){
                        @Override
                        public void run(){
                            Map<String,Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
                            Map<String,Map<String,Object>> data = new HashMap();
                            data.put("31000",position);
                            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(usersId), JSON.toJSONString(data));
                        }
                    };
                    carPositionTimer.scheduleAtFixedRate(carPositionTask,date,Integer.parseInt(cycle));//启用
                    this.userCarTimerMap.put(usersId,carPositionTimer);
                    return Results.succeed("开始追踪");
                }
            }
        }catch(Exception e){
            e.printStackTrace();
            return Results.error("追踪失败");
        }
    }
}