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

zhangnaisong

2023-07-28 3d296df1ff6f6c34a68d228f5766ebe44cf169e1

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

@@ -1,19 +1,15 @@
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;

import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.common.websocket.util.WebSocketUtils;
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import com.ruoyi.device.hiksdk.config.MinioClientSingleton;
import com.ruoyi.device.hiksdk.util.minio.MinioUtils;
import com.ruoyi.sy.domain.ArdSyUser;
@@ -23,15 +19,12 @@
import com.ruoyi.system.mapper.SysConfigMapper;
import com.ruoyi.system.mapper.SysUserMapper;
import com.ruoyi.utils.forest.SYClient;
import com.ruoyi.utils.httpclient.SYCarClient;
import com.ruoyi.utils.result.Constants;
import com.ruoyi.utils.result.Results;
import io.minio.GetPresignedObjectUrlArgs;
import io.minio.ListObjectsArgs;
import io.minio.PutObjectArgs;
import io.minio.Result;
import io.minio.http.Method;
import io.minio.messages.Contents;
import io.minio.messages.Item;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.stereotype.Service;
@@ -42,7 +35,7 @@

import javax.annotation.Resource;

import static com.ruoyi.common.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;
import static com.ruoyi.utils.websocket.util.WebSocketUtils.ONLINE_USER_SESSIONS;

/**
 * 三一车辆Service业务层处理
@@ -68,6 +61,8 @@
    private SYClient sYClient;

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

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

    /**
     * 查询三一车辆
@@ -368,19 +363,42 @@
    @Override
    public void sendArdSyCarPosition() {
        for(String key : ONLINE_USER_SESSIONS.keySet()){
            SysUser sysUser = userMapper.selectUserById(key);
            String deptId = String.valueOf(sysUser.getDeptId());
            Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
            System.out.println("/////////////");
            System.out.println(PositionContainer.getDeptPositionMap());
            Map<Integer,Object> data = new HashMap();
            data.put(30000, map.values());
            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
            if(PositionContainer.getUserPositionMap().keySet().contains(key)){//当追踪的车辆容器包含此用户Id，则实时位置推送需要剔除该车辆
                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);
                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);
                if(map != null){
                    Map<String,Object> data = new HashMap();
                    data.put("30000", map.values());
                    WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data));
                }
            }
        }
    }

    @Override
    public void sendArdSyCarAlarmByCarId(String carId, Map<Integer,Object> data) {
    public void sendArdSyCarAlarmByCarId(String carId, Map<String,Object> data) {
        List<SysUser> result = userMapper.getSysUserByCarId(carId);
        for(SysUser sysUser : result){
            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sysUser.getUserId()), JSON.toJSONString(data));
@@ -455,49 +473,53 @@
        carList31 = sYClient.getCarList1(syURL,teamId, result.get("userId"),result.get("sessionId"));
        //拿到车辆数据
        list= (List) carList31.get("list");
        List<String> carIdList = new ArrayList();
        //所有carId
        for(Map<String,String> m : list){
            carIdList.add(m.get("carId"));
        }
        if(carIdList.size() == 0){
            Map<String,String> map0 = new HashMap();
            map0.put("list", "{}");
            map0.put("rspCode", "1");
            list.add(map0);
        if(list.isEmpty()){
            return list;
        }
        //添加车辆属性
        for(Map<String,String> m : list){
            switch (m.get("state")) {
                case "1":
                    m.put("carState", "离线-从未报定位");break;
                case "2":
                    m.put("carState", "离线-欠费");break;
                case "3":
                    m.put("carState", "离线");break;
                case "4":
                    m.put("carState", "离线-报警");break;
                case "5":
                    m.put("carState", "在线-从未报定位");break;
                case "6":
                    m.put("carState", "在线-欠费");break;
                case "7":
                    m.put("carState", "在线-行驶");break;
                case "8":
                    m.put("carState", "在线-行驶-报警");break;
                case "9":
                    m.put("carState", "在线-停车-ACC关");break;
                case "10":
                    m.put("carState", "在线-停车-ACC开");break;
                case "11":
                    m.put("carState", "在线-停车-ACC关-报警");break;
                case "12":
                    m.put("carState", "在线-停车-ACC开-报警");break;
                case "13":
                    m.put("carState", "在线-无效定位");break;
                default:
                    break;
        }else {
            List<String> carIdList = new ArrayList();
            //所有carId
            for(Map<String,String> m : list){
                carIdList.add(m.get("carId"));
            }
            if(carIdList.size() == 0){
                Map<String,String> map0 = new HashMap();
                map0.put("list", "{}");
                map0.put("rspCode", "1");
                list.add(map0);
                return list;
            }
            //添加车辆属性
            for(Map<String,String> m : list){
                switch (m.get("state")) {
                    case "1":
                        m.put("carState", "离线-从未报定位");break;
                    case "2":
                        m.put("carState", "离线-欠费");break;
                    case "3":
                        m.put("carState", "离线");break;
                    case "4":
                        m.put("carState", "离线-报警");break;
                    case "5":
                        m.put("carState", "在线-从未报定位");break;
                    case "6":
                        m.put("carState", "在线-欠费");break;
                    case "7":
                        m.put("carState", "在线-行驶");break;
                    case "8":
                        m.put("carState", "在线-行驶-报警");break;
                    case "9":
                        m.put("carState", "在线-停车-ACC关");break;
                    case "10":
                        m.put("carState", "在线-停车-ACC开");break;
                    case "11":
                        m.put("carState", "在线-停车-ACC关-报警");break;
                    case "12":
                        m.put("carState", "在线-停车-ACC开-报警");break;
                    case "13":
                        m.put("carState", "在线-无效定位");break;
                    default:
                        break;
                }
            }
        }
        return list;
@@ -528,4 +550,211 @@
        }
        return list;
    }

    @Override
    public Results getCarGPSTrack(Map<String,String> map,String syURL, ArdSyUser ardSyUser){
        String carId = map.get("carId");
        String startTime = map.get("startTime").replace(" ", "").replace("-", "").replace(":", "");
        String endTime = map.get("endTime").replace(" ", "").replace("-", "").replace(":", "");
        String maxSpeed = map.get("maxSpeed");
        //31用户名密码
        String username31 = ardSyUser.getUserId();
        String password31 = ardSyUser.getPassword();
        String passwordMd5 = DigestUtils.md5Hex(password31);
        Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
        Map<String,Object> result0 = new HashMap();
        result0 = sYClient.getCarGPSTrack(syURL,carId,startTime,endTime,maxSpeed,(String) result1.get("sessionId"));
        List<Map<String,Object>> list = (List<Map<String, Object>>) result0.get("list");
        if(list.isEmpty()){
            return Results.succeed();
        }else {
            for(Map<String,Object> m : list) {
                String alarmStts = (String) m.get("alarmStts");
                Map<String, List<String>> alarmMap = getInfo("alarm", alarmStts);
                m.putAll(alarmMap);
                String carStts = (String) m.get("carStts");
                Map<String, List<String>> carMap = getInfo("car", carStts);
                m.putAll(carMap);
                String sgnStts = (String) m.get("sgnStts");
                Map<String, List<String>> sgnMap = getInfo("sgn", sgnStts);
                m.putAll(sgnMap);
            }
            return Results.succeed(list);
        }
    }


    public Map<String,List<String>> getInfo(String type,String stts){
        if(stts.isEmpty()){
            return new HashMap<>();
        }
        String[] alarmTypes = {"紧急报警","超速报警","疲劳驾驶","危险预警","GNSS 模块发生故障","GNSS 天线未接或被剪断","GNSS 天线短路",
                "终端主电源欠压","终端主电源掉电","终端LCD 或显示器故障","TTS 模块故障","摄像头故障","道路运输证IC 卡模块故障","超速预警",
                "疲劳驾驶预警","违规行驶报警","胎压预警","右转盲区异常报警","当天累计驾驶超时","超时停车","进出区域","进出路线","路段行驶时间不足/过长",
                "路线偏离报警","车辆VSS 故障","车辆油量异常","车辆被盗","车辆非法点火","车辆非法位移","碰撞预警","侧翻预警","非法开门报警"};

        String[] carTypes89 = {"空车","半载","保留","满载"};

        Object[] carTypes = {"ACC开","定位","南纬","西经","停运状态","经纬度已经保密插件加密","保留","保留",carTypes89,"车辆油路断开","车门加锁",
                "车辆电路断开","门1开（前门）","门2开（中门）","门3开（后门","门4开（驾驶席门","门5开","使用GPS 卫星进行定位","使用北斗卫星进行定位",
                "使用GLONASS卫星进行定位","使用Galileo卫星进行定位","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留"};

        String[] sgnTypes = {"近光灯信号","远光灯信号","右转向灯信号","左转向灯信号","制动信号","倒档信号","雾灯信号","示廓灯","喇叭信号","空调状态",
                "空挡信号","缓速器工作","ABS 工作","加热器工作","离合器状态","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留",
                "保留","保留","保留","保留","保留","保留"};
        Integer sttsHex = Integer.parseInt(stts, 16);
        String sttsBin = Integer.toBinaryString(sttsHex);
        if(sttsBin.length() < 32){
            while(sttsBin.length() < 32){
                sttsBin = "0" + sttsBin;
            }
        }
        String[] sttsBinArray = sttsBin.split("");
        switch (type) {
            case "alarm":
                List<String> alarmTypeArray = new ArrayList();
                for (int i = 0; i < sttsBinArray.length; i++) {
                    if(sttsBinArray[i].equals("1")){
                        alarmTypeArray.add(alarmTypes[i]);
                    }
                }
                Map<String,List<String>> alarmMap = new HashMap();
                alarmMap.put(type, alarmTypeArray);
                return alarmMap;
            case "car":
                List<String> carTypeArray = new ArrayList();
                for (int i = 0; i < sttsBinArray.length; i++) {
                    if(i <= 7 || i >= 10){
                        if(sttsBinArray[i].equals("1")){
                            carTypeArray.add(alarmTypes[i]);
                        }
                    }else if(i == 8){
                        switch (sttsBinArray[8]+sttsBinArray[9]) {
                            case "00":
                                carTypeArray.add(carTypes89[0]);
                                break;
                            case "01":
                                carTypeArray.add(carTypes89[1]);
                                break;
                            case "10":
                                carTypeArray.add(carTypes89[2]);
                                break;
                            case "11":
                                carTypeArray.add(carTypes89[3]);
                                break;
                            default:
                                break;
                        }
                    }else if(i == 9){
                        continue;
                    }else{
                        break;
                    }
                }
                Map<String,List<String>> carMap = new HashMap();
                List<String> carTypeArray0 = new ArrayList();
                for(String str : carTypeArray){
                    if(!str.equals("保留")){
                        carTypeArray0.add(str);
                    }
                }
                carMap.put(type, carTypeArray0);
                return carMap;
            case "sgn":
                List<String> sgnTypeArray = new ArrayList();
                for (int i = 0; i < sttsBinArray.length; i++) {
                    if(sttsBinArray[i].equals("1")){
                        sgnTypeArray.add(alarmTypes[i]);
                    }
                }
                Map<String,List<String>> sgnMap = new HashMap();
                List<String> sgnTypeArray0 = new ArrayList();
                for(String str : sgnTypeArray){
                    if(!str.equals("保留")){
                        sgnTypeArray0.add(str);
                    }
                }
                sgnMap.put(type, sgnTypeArray0);
                return sgnMap;
            default:
                return new HashMap<String,List<String>>();
        }
    }

    @Override
    public Results getCarGPSBycarId(String usersId,String carId,String syURL,ArdSyUser ardSyUser){
        Map<String, String> result = logInMap.get(Integer.parseInt(usersId));
        //31用户名密码
        String username31 = ardSyUser.getUserId();
        String password31 = ardSyUser.getPassword();
        String passwordMd5 = DigestUtils.md5Hex(password31);
        Map<String, Object> result1 = sYClient.logIn(syURL,passwordMd5, username31);
        result = new HashMap();
        result.put("userId", username31);
        result.put("sessionId", (String) result1.get("sessionId"));
        Map<String,Object> result0 = new HashMap();
        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("追踪失败");
        }
    }
}