增加一件调度获取附近车人相机

‘liusuyi’

2023-08-17 fb85b1053475a90d902f1dcfd1f1c24b368eabac

增加一件调度获取附近车人相机

 ard-work/src/main/java/com/ruoyi/app/position/controller/ArdAppPositionController.java

@@ -46,8 +46,7 @@
    private IArdAppPositionService ardAppPositionService;
    @Autowired
    private ISysUserService sysUserService;
    @Autowired
    private RongCloudService rongCloudService;


    /**
     * æŸ¥è¯¢app位置列表

 ard-work/src/main/java/com/ruoyi/app/position/service/IArdAppPositionService.java

@@ -2,6 +2,8 @@

import java.util.List;
import com.ruoyi.app.position.domain.ArdAppPosition;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.scheduling.domian.SchedulingParam;


/**
@@ -65,4 +67,10 @@
     * @return ç»“æžœ
     */
    public int deleteArdAppPositionById(String id);
    /**
     * èŽ·å–封控圈内所有在线app用户
     * åˆ˜è‹ä¹‰
     * 2023/8/17 13:56:36
     */
    public List<SysUser>getNearAppUsers(SchedulingParam param);
}

 ard-work/src/main/java/com/ruoyi/app/position/service/impl/ArdAppPositionServiceImpl.java

@@ -3,12 +3,17 @@
import com.ruoyi.app.position.domain.ArdAppPosition;
import com.ruoyi.app.position.mapper.ArdAppPositionMapper;
import com.ruoyi.app.position.service.IArdAppPositionService;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.spring.SpringUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.utils.tools.GisTool;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
@@ -17,6 +22,7 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;


/**
@@ -26,10 +32,12 @@
 * @date 2023-07-18
 */
@Service
@Slf4j
public class ArdAppPositionServiceImpl implements IArdAppPositionService {
    @Resource
    private ArdAppPositionMapper ardAppPositionMapper;

    @Resource
    private ISysUserService iSysUserService;

    /**
     * æŸ¥è¯¢app位置
@@ -41,6 +49,7 @@
    public ArdAppPosition selectArdAppPositionById(String id) {
        return ardAppPositionMapper.selectArdAppPositionById(id);
    }

    /**
     * æŒ‰ç”¨æˆ·id查询最后的位置信息
     *
@@ -48,9 +57,10 @@
     * @return app位置
     */
    @Override
    public ArdAppPosition selectLastArdAppPositionByUserId(String userId){
    public ArdAppPosition selectLastArdAppPositionByUserId(String userId) {
        return ardAppPositionMapper.selectLastArdAppPositionByUserId(userId);
    }

    /**
     * æŸ¥è¯¢app位置列表
     *
@@ -108,4 +118,50 @@
        return ardAppPositionMapper.deleteArdAppPositionById(id);
    }

    /**
     * èŽ·å–封控圈内所有在线app用户
     * åˆ˜è‹ä¹‰
     * 2023/8/17 13:56:36
     */
    @Override
    public List<SysUser> getNearAppUsers(SchedulingParam param) {
        Double longitude = param.getLongitude();
        Double latitude = param.getLatitude();
        if (longitude == null && latitude == null) {
            log.debug("原点坐标为空");
            return null;
        }
        Integer radius = param.getSealingRadius();

        if (radius == null) {
            log.debug("半径距离为空");
            return null;
        }

        SysUser user = new SysUser();
        List<SysUser> appUserList = iSysUserService.selectAllAppUserList(user);
        //过滤在线
        List<SysUser> onLineList = appUserList.stream()
                .filter(sysUser -> (sysUser.getAppOnlineState().equals("0")))
                .collect(Collectors.toList());
        //过滤范围
        List<SysUser> filteredList = new ArrayList<>();
        for(SysUser sysUser:onLineList) {
            ArdAppPosition ardAppPosition = ardAppPositionMapper.selectLastArdAppPositionByUserId(sysUser.getUserId());
            if (ardAppPosition != null) {
                Double lon = ardAppPosition.getLongitude();
                Double lat = ardAppPosition.getLatitude();
                if(longitude==null||latitude==null)
                {
                    continue;
                }
                double distance = GisTool.getDistance(new double[]{ longitude, latitude}, new double[]{ lon, lat});
                if (distance <= radius) {
                    filteredList.add(sysUser); // å°†æ»¡è¶³æ¡ä»¶çš„用户添加到筛选列表中
                }
            }
        }
        return filteredList;
    }

}

 ard-work/src/main/java/com/ruoyi/device/camera/service/IArdCamerasService.java

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

import com.ruoyi.device.camera.domain.ArdCameras;
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.scheduling.domian.SchedulingParam;

/**
 * ç›¸æœºè®¾å¤‡Service接口
@@ -83,4 +84,11 @@


    public TreeMap getNearCamerasBycoordinate(CameraCmd cmd);

    /**
     * èŽ·å–监控圈内所有在线光电
     * åˆ˜è‹ä¹‰
     * 2023/8/17 13:56:36
     */
    List<ArdCameras> getNearCameras(SchedulingParam param);
}

 ard-work/src/main/java/com/ruoyi/device/camera/service/impl/ArdCamerasServiceImpl.java

@@ -2,6 +2,7 @@

import java.time.LocalTime;
import java.util.*;
import java.util.stream.Collectors;

import com.ruoyi.common.constant.CacheConstants;
import com.ruoyi.common.core.domain.entity.SysDept;
@@ -11,6 +12,7 @@
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.device.camera.domain.CameraCmd;
import com.ruoyi.device.hiksdk.common.GlobalVariable;
import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.system.domain.SysConfig;
import com.ruoyi.utils.tools.ArdTool;
import com.ruoyi.device.camera.domain.ArdCameras;
@@ -19,6 +21,7 @@
import com.ruoyi.common.annotation.DataScope;
import com.ruoyi.system.mapper.SysDeptMapper;
import com.ruoyi.utils.tools.GisTool;
import com.sun.org.apache.bcel.internal.generic.NEW;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@@ -137,10 +140,8 @@
    @Override
    public int deleteArdCamerasByIds(String[] ids) {
        int res = ardCamerasMapper.deleteArdCamerasByIds(ids);
        if(res>0)
        {
            for(String id:ids)
            {
        if (res > 0) {
            for (String id : ids) {
                redisCache.deleteObject(getCacheKey(id));
            }
        }
@@ -260,5 +261,50 @@
        return null;
    }

    /**
     * èŽ·å–监控圈内所有在线光电
     * åˆ˜è‹ä¹‰
     * 2023/8/17 13:57:21
     */
    @Override
    public List<ArdCameras> getNearCameras(SchedulingParam param) {
        try {
            Double longitude = param.getLongitude();
            Double latitude = param.getLatitude();
            if (longitude == null && latitude == null) {
                log.debug("原点坐标为空");
                return null;
            }
            Integer radius = param.getMonitoringRadius();
            if (radius == null) {
                log.debug("监控圈半径距离为空");
                return null;
            }
            String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime");
            //获取所有光电
            List<ArdCameras> ardCamerasList = ardCamerasMapper.selectArdCamerasList(new ArdCameras());
            //统计所有光电可视范围内与报警点的距离
            List<ArdCameras> ardCameras = new ArrayList<>();
            for (ArdCameras camera : ardCamerasList) {
                if (camera.getLongitude() == null && camera.getLatitude() == null) {
                    continue;
                }
                double[] camPosition = new double[]{camera.getLongitude(), camera.getLatitude()};
                double distance = GisTool.getDistance(new double[]{longitude, latitude}, camPosition);
                if (distance <= radius) {
                    camera.setChannel(ArdTool.getChannelBydayNightTime(dayNightTime));
                    ardCameras.add(camera);
                }
            }
            //过滤在线相机
            List<ArdCameras> onlineList = ardCameras.stream()
                    .filter(ardCamera -> (!ardCamera.getLoginId().equals(-1)))
                    .collect(Collectors.toList());
            return onlineList;
        } catch (Exception ex) {
            log.error("获取附近相机异常:" + ex.getMessage());
        }
        return null;
    }

}

 ard-work/src/main/java/com/ruoyi/scheduling/controller/SchedulingController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,54 @@
package com.ruoyi.scheduling.controller;

import com.ruoyi.app.position.service.IArdAppPositionService;
import com.ruoyi.common.annotation.Anonymous;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.device.camera.domain.ArdCameras;
import com.ruoyi.device.camera.service.IArdCamerasService;
import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.sy.service.IArdSyCarService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * @Description:
 * @ClassName: SchedulingController
 * @Author: åˆ˜è‹ä¹‰
 * @Date: 2023å¹´08月17日11:05:59
 * @Version: 1.0
 **/
@RestController
@RequestMapping("/scheduling")
@Api(tags = "一键调度")
public class SchedulingController {
    @Resource
    IArdSyCarService iArdSyCarService;
    @Resource
    IArdCamerasService iArdCamerasService;
    @Resource
    IArdAppPositionService iArdAppPositionService;

    @GetMapping("/getNearVehiPersonCam")
    @ApiOperation("获取附近的车人相机")
    AjaxResult getNearVehiPersonCam(SchedulingParam param) {
        Map<String, Object> nearMap = new HashMap<>();

        List<Map<String, Object>> Cars = iArdSyCarService.getNearCar(param);
        nearMap.put("car", Cars);
        List<ArdCameras> Cameras = iArdCamerasService.getNearCameras(param);
        nearMap.put("camera", Cameras);
        List<SysUser> AppUsers = iArdAppPositionService.getNearAppUsers(param);
        nearMap.put("users", AppUsers);

        return AjaxResult.success(nearMap);
    }
}

 ard-work/src/main/java/com/ruoyi/scheduling/domian/SchedulingParam.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,21 @@
package com.ruoyi.scheduling.domian;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

/**
 * @Description:
 * @ClassName: RequestParam
 * @Author: åˆ˜è‹ä¹‰
 * @Date: 2023å¹´08月17日13:16:25
 * @Version: 1.0
 **/
@Data
public class SchedulingParam {

    Integer sealingRadius;
    Integer monitoringRadius;
    Double longitude;
    Double latitude;
}

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

@@ -3,6 +3,7 @@
import java.util.List;
import java.util.Map;

import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.sy.domain.ArdSyCar;
import com.ruoyi.sy.domain.ArdSyUser;
import com.ruoyi.utils.result.Results;
@@ -134,5 +135,8 @@
     * æ ¹æ®æ—¶é—´åŠè½¦è¾†ä¸»é”®æŸ¥è¯¢è¯¥æœˆæ¯å¤©æ˜¯å¦æœ‰è½¨è¿¹
     */
    public Results getExistTraceByCarIdAndMonth(String userId,String carId,String time);

    /**
     * èŽ·å–附近范围内的车辆信息
     * */
    List<Map<String, Object>> getNearCar(SchedulingParam param);
}

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

@@ -13,9 +13,13 @@
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.core.redis.RedisCache;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.sy.domain.ArdSyCarDay;
import com.ruoyi.sy.mapper.ArdSyCarDayMapper;
import com.ruoyi.utils.tools.GisTool;
import com.ruoyi.utils.websocket.util.WebSocketUtils;
import com.ruoyi.device.hiksdk.config.MinioClientSingleton;
import com.ruoyi.storage.minio.utils.MinioUtils;
@@ -33,6 +37,7 @@
import io.minio.Result;
import io.minio.http.Method;
import io.minio.messages.Item;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
@@ -55,6 +60,7 @@
 * @date 2023-06-26
 */
@Service
@Slf4j(topic = "sy")
public class ArdSyCarServiceImpl implements IArdSyCarService {
    @Resource
    private ArdSyCarMapper ardSyCarMapper;
@@ -70,13 +76,14 @@

    @Resource
    private SYClient sYClient;

    @Resource
    RedisCache redisCache;
    @Resource
    private ArdSyCarDayMapper ardSyCarDayMapper;

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

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

    /**
     * æŸ¥è¯¢ä¸‰ä¸€è½¦è¾†
@@ -108,7 +115,7 @@
     */
    @Override
    public int insertArdSyCar(ArdSyCar ardSyCar) {
            return ardSyCarMapper.insertArdSyCar(ardSyCar);
        return ardSyCarMapper.insertArdSyCar(ardSyCar);
    }

    /**
@@ -132,8 +139,8 @@
    public int deleteArdSyCarByIds(String[] ids) {
        List<ArdSyCar> result = ardSyCarMapper.selectArdSyCarByIds(ids);
        List<String> objectNames = new ArrayList();
        for(ArdSyCar ardSyCar : result){
            if(ardSyCar.getCarPicture() != null && !ardSyCar.getCarPicture().equals("")){
        for (ArdSyCar ardSyCar : result) {
            if (ardSyCar.getCarPicture() != null && !ardSyCar.getCarPicture().equals("")) {
                objectNames.add(ardSyCar.getCarPicture().split("/sycar/")[1]);
            }
        }
@@ -156,54 +163,54 @@
     * èŽ·å–未挂接权限的三一车辆
     */
    @Override
    public Map<String,Object> getArdSyCarNoRight(String userId) {
    public Map<String, Object> getArdSyCarNoRight(String userId) {
        SysConfig config = new SysConfig();
        config.setConfigKey("syCarPT");
        List<SysConfig> sysConfigResult = sysConfigMapper.selectConfigList(config);
        String syURL = "";
        Map<String,Object> result = new HashMap();
        if(sysConfigResult.size() == 0){
            result.put("data","三一车辆url没有录入");
            result.put("code","500");
        Map<String, Object> result = new HashMap();
        if (sysConfigResult.size() == 0) {
            result.put("data", "三一车辆url没有录入");
            result.put("code", "500");
            return result;
        }else{
        } else {
            syURL = sysConfigResult.get(0).getConfigValue();
            ArdSyUser ardSyUserPara = new ArdSyUser();
            ardSyUserPara.setSysUserId(userId);
            List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(ardSyUserPara);
            if(ardSyUserList.size() == 0){
                result.put("data","用户未挂接三一车辆");
                result.put("code","500");
            if (ardSyUserList.size() == 0) {
                result.put("data", "用户未挂接三一车辆");
                result.put("code", "500");
                return result;
            }else{
            } else {
                ArdSyUser ardSyUser = ardSyUserList.get(0);
                //Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
                String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
                Map<String,Object> LogInResult = sYClient.logIn(syURL,passwordMd5,ardSyUser.getUserId());
                Map<String, Object> LogInResult = sYClient.logIn(syURL, passwordMd5, ardSyUser.getUserId());
                String sessionId = (String) LogInResult.get("sessionId");
                //Map<String,Object> carListMap = SYCarClient.getCarList(syURL,sessionId);
                Map<String,Object> carListMap = sYClient.getCarList(syURL,sessionId);
                if(((String)carListMap.get("rspCode")).equals("1")){
                    List<Map<String,Object>> list = (List<Map<String,Object>>) carListMap.get("list");
                Map<String, Object> carListMap = sYClient.getCarList(syURL, sessionId);
                if (((String) carListMap.get("rspCode")).equals("1")) {
                    List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
                    ArdSyCar ardSyCar = new ArdSyCar();
                    List<ArdSyCar> ardSyCarList = ardSyCarMapper.selectArdSyCarList(ardSyCar);
                    List<String> carIdList = new ArrayList();
                    for(ArdSyCar innerArdSyCar : ardSyCarList){
                    for (ArdSyCar innerArdSyCar : ardSyCarList) {
                        carIdList.add(innerArdSyCar.getCarId());
                    }

                    List<Map<String,Object>> carList = list.stream().filter(new Predicate<Map<String,Object>>(){
                    List<Map<String, Object>> carList = list.stream().filter(new Predicate<Map<String, Object>>() {
                        @Override
                        public boolean test(Map<String,Object> map) {
                            return !carIdList.contains((String)map.get("carId"));
                        public boolean test(Map<String, Object> map) {
                            return !carIdList.contains((String) map.get("carId"));
                        }
                    }).collect(Collectors.toList());
                    result.put("data",carList);
                    result.put("code","200");
                    result.put("data", carList);
                    result.put("code", "200");
                    return result;
                }else{
                    result.put("data","三一车辆平台出错");
                    result.put("code","500");
                } else {
                    result.put("data", "三一车辆平台出错");
                    result.put("code", "500");
                    return result;
                }
            }
@@ -216,36 +223,36 @@
        config.setConfigKey("syCarPT");
        List<SysConfig> sysConfigResult = sysConfigMapper.selectConfigList(config);
        String syURL = "";
        Map<String,Object> result = new HashMap();
        if(sysConfigResult.size() == 0){
            result.put("data","三一车辆url没有录入");
            result.put("code","500");
        Map<String, Object> result = new HashMap();
        if (sysConfigResult.size() == 0) {
            result.put("data", "三一车辆url没有录入");
            result.put("code", "500");
            return result;
        }else{
        } else {
            syURL = sysConfigResult.get(0).getConfigValue();
            ArdSyUser ardSyUserPara = new ArdSyUser();
            ardSyUserPara.setSysUserId(userId);
            List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(ardSyUserPara);
            if(ardSyUserList.size() == 0){
                result.put("data","用户未挂接三一车辆");
                result.put("code","500");
            if (ardSyUserList.size() == 0) {
                result.put("data", "用户未挂接三一车辆");
                result.put("code", "500");
                return result;
            }else{
            } else {
                ArdSyUser ardSyUser = ardSyUserList.get(0);
                //Map<String,Object> LogInResult = SYCarClient.logIn(syURL,ardSyUser.getUserId(), ardSyUser.getPassword());
                String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
                Map<String,Object> LogInResult = sYClient.logIn(syURL,passwordMd5,ardSyUser.getUserId());
                Map<String, Object> LogInResult = sYClient.logIn(syURL, passwordMd5, ardSyUser.getUserId());
                String sessionId = (String) LogInResult.get("sessionId");
                //Map<String,Object> carListMap = SYCarClient.getCarList(syURL,sessionId);
                Map<String,Object> carListMap = sYClient.getCarList(syURL,sessionId);
                if(((String)carListMap.get("rspCode")).equals("1")){
                    List<Map<String,Object>> list = (List<Map<String,Object>>) carListMap.get("list");
                    result.put("data",list);
                    result.put("code","200");
                Map<String, Object> carListMap = sYClient.getCarList(syURL, sessionId);
                if (((String) carListMap.get("rspCode")).equals("1")) {
                    List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
                    result.put("data", list);
                    result.put("code", "200");
                    return result;
                }else{
                    result.put("data","三一车辆平台出错");
                    result.put("code","500");
                } else {
                    result.put("data", "三一车辆平台出错");
                    result.put("code", "500");
                    return result;
                }
            }
@@ -253,30 +260,54 @@
    }

    @Override
    public List<Map<String,String>> getAllCarModel() {
    public List<Map<String, String>> getAllCarModel() {
        boolean exsit = MinioUtils.exitsBucket("sycar");
        if (exsit) {
            List<Map<String,String>> listObjetcName = new ArrayList<>();
            List<Map<String, String>> listObjetcName = new ArrayList<>();
            try {
                ListObjectsArgs listObjectsArgs = ListObjectsArgs.builder().prefix("carmodel/").bucket("sycar").build();
                Iterable<Result<Item>> myObjects = MinioClientSingleton.getMinioClient().listObjects(listObjectsArgs);
                for (Result<Item> result : myObjects) {
                    Item item = result.get();
                    Map<String,String> map = new HashMap();
                    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;
                    Map<String, String> map = new HashMap();
                    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;
                    }
@@ -292,10 +323,10 @@

    @Override
    public String uploadCarPicture(String id, MultipartFile carPicture) {
        if(id != null && !id.equals("")){//id为非必要
        if (id != null && !id.equals("")) {//id为非必要
            ArdSyCar ardSyCarr = ardSyCarMapper.selectArdSyCarById(id);
            List<String> objectNames = new ArrayList();
            if(ardSyCarr.getCarPicture() != null || !ardSyCarr.getCarPicture().equals("")){
            if (ardSyCarr.getCarPicture() != null || !ardSyCarr.getCarPicture().equals("")) {
                String objectName = ardSyCarr.getCarPicture().split("/sycar/")[1];
                objectNames.add(objectName);
                MinioUtils.removeObjects("sycar", objectNames);
@@ -312,7 +343,7 @@
        //文件名
        String originalFilename = carPicture.getOriginalFilename();
        //新的文件名
        String fileName = "carpicture/" + IdUtils.fastSimpleUUID()+"_"+ originalFilename;
        String fileName = "carpicture/" + IdUtils.fastSimpleUUID() + "_" + originalFilename;
        try {
            InputStream inputStream = carPicture.getInputStream();
            /*上传对象*/
@@ -333,8 +364,8 @@
                    .method(Method.GET)
                    .build();
            String presignedObjectUrl = MinioClientSingleton.getMinioClient().getPresignedObjectUrl(getPresignedObjectUrlArgs);
            String ObjectUrl  = presignedObjectUrl.substring(0, presignedObjectUrl.indexOf("?"));
            if(id != null && !id.equals("")){//id为非必要
            String ObjectUrl = presignedObjectUrl.substring(0, presignedObjectUrl.indexOf("?"));
            if (id != null && !id.equals("")) {//id为非必要
                ArdSyCar ardSyCar = new ArdSyCar();
                ardSyCar.setId(id);
                ardSyCar.setCarPicture(ObjectUrl);
@@ -357,10 +388,10 @@
    public Results carListById(String id) {
        try {
            List<ArdSyCar> list = ardSyCarMapper.carListById(id);
            if(list.size()>0){
            if (list.size() > 0) {
                ArdSyCar ardSyCar = list.get(0);
                return Results.succeed(ardSyCar);
            }else {
            } else {
                return Results.succeed();
            }
        } catch (Exception e) {
@@ -371,12 +402,12 @@
    @Override
    public Map<String, Object> getArdSyCarAndDeptByCarId(String carId) {
        Map<String, Object> result = ardSyCarMapper.getArdSyCarAndDeptByCarId(carId);
        if(result != null){
            if(result.get("carPicture") != null){
                if(!((String)result.get("carPicture")).equals("")){
                    String url = ((String)result.get("carPicture")).split("sycar")[0];
                    String carModel = url + (String)result.get("carModel");
                    result.put("carModel",carModel);
        if (result != null) {
            if (result.get("carPicture") != null) {
                if (!((String) result.get("carPicture")).equals("")) {
                    String url = ((String) result.get("carPicture")).split("sycar")[0];
                    String carModel = url + (String) result.get("carModel");
                    result.put("carModel", carModel);
                }
            }
        }
@@ -385,41 +416,41 @@

    @Override
    public void sendArdSyCarPosition() {
        for(String key : ONLINE_USER_SESSIONS.keySet()){
            if(PositionContainer.getUserPositionMap().keySet().contains(key)){//当追踪的车辆容器包含此用户Id，则实时位置推送需要剔除该车辆
        for (String key : ONLINE_USER_SESSIONS.keySet()) {
            if (PositionContainer.getUserPositionMap().keySet().contains(key)) {//当追踪的车辆容器包含此用户Id，则实时位置推送需要剔除该车辆
                SysUser sysUser = userMapper.selectUserById(key);
                if(sysUser == null){
                if (sysUser == null) {
                    //return;
                    continue;
                }
                String deptId = String.valueOf(sysUser.getDeptId());
                Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId);
                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();
                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{
            } else {
                SysUser sysUser = userMapper.selectUserById(key);
                if(sysUser == null){
                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();
                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));
                }
            }
        }
        for(String userId : userCarTimerMap.keySet()){//用户离线后将车辆追踪资源释放
            if(!ONLINE_USER_SESSIONS.keySet().contains(userId)){
        for (String userId : userCarTimerMap.keySet()) {//用户离线后将车辆追踪资源释放
            if (!ONLINE_USER_SESSIONS.keySet().contains(userId)) {
                userCarTimerMap.get(userId).cancel();
                userCarTimerMap.remove(userId);
                PositionContainer.getUserPositionMap().remove(userId);
@@ -428,125 +459,139 @@
    }

    @Override
    public void sendArdSyCarAlarmByCarId(String carId, Map<String,Object> data) {
    public void sendArdSyCarAlarmByCarId(String carId, Map<String, Object> data) {
        List<SysUser> result = userMapper.getSysUserByCarId(carId);
        for(SysUser sysUser : result){
        for (SysUser sysUser : result) {
            WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sysUser.getUserId()), JSON.toJSONString(data));
        }
    }

    /**
     * æ ¹æ®ç”¨æˆ·èŽ·å–三一列表
     *
     * @return
     */
    @Override
    public Map<String,Object> allListByUser(ArdSyUser ardSyUser,String syURL,String usersId){
        Map<String,Object> result0 = new HashMap();
    public Map<String, Object> allListByUser(ArdSyUser ardSyUser, String syURL, String usersId) {
        Map<String, Object> result0 = new HashMap();
        //判断关联表是否有数据
        if(ardSyUser!=null){
        if (ardSyUser != null) {
            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);
            Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31);
            result = new HashMap();
            result.put("userId", username31);
            result.put("sessionId", (String) result1.get("sessionId"));
            try {
                result0 = sYClient.getTeamList(syURL,result.get("userId"),result.get("sessionId"));
                result0 = sYClient.getTeamList(syURL, result.get("userId"), result.get("sessionId"));
            } catch (Exception e) {
                Map<String,Object> map = new HashMap();
                Map<String, Object> map = new HashMap();
                map.put("rspCode", 0);
                map.put("list", new ArrayList());
                return map;
            }
            int online = 0;
            for(Map<String,Object> map : (List<Map<String,Object>>) result0.get("list")){
                Map<String,Object> resultMap = sYClient.getTeamCarList(syURL,(String)map.get("teamId"),result.get("sessionId"));
                List<Map<String,Object>> carList = (List<Map<String, Object>>) resultMap.get("carList");
                for(Map<String,Object> m : carList){
                    if(((String) m.get("stateCn")).contains("在线")){
            for (Map<String, Object> map : (List<Map<String, Object>>) result0.get("list")) {
                Map<String, Object> resultMap = sYClient.getTeamCarList(syURL, (String) map.get("teamId"), result.get("sessionId"));
                List<Map<String, Object>> carList = (List<Map<String, Object>>) resultMap.get("carList");
                for (Map<String, Object> m : carList) {
                    if (((String) m.get("stateCn")).contains("在线")) {
                        online = online + 1;
                    }else{
                    } else {
                        continue;
                    }
                }
                for(Map<String,Object> m : (List<Map<String,Object>>) result0.get("list")){
                    if(((String) m.get("teamId")).equals(((String) map.get("teamId")))){
                for (Map<String, Object> m : (List<Map<String, Object>>) result0.get("list")) {
                    if (((String) m.get("teamId")).equals(((String) map.get("teamId")))) {
                        map.put("count", Integer.parseInt((String) m.get("carNum")));
                    }
                }
                map.put("online", online);
                online = 0;
            }
        }else {
            result0.put("列表为空！","无关联账号！");
        } else {
            result0.put("列表为空！", "无关联账号！");
        }
        return result0;
    }

    @Override
    public List<Map<String,String>> getCarList(ArdSyUser ardSyUser, String syURL, String usersId,String teamId){
        List<Map<String,String>> list = new ArrayList<>();
    public List<Map<String, String>> getCarList(ArdSyUser ardSyUser, String syURL, String usersId, String teamId) {
        List<Map<String, String>> list = new ArrayList<>();
        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);
        Map<String, Object> result1 = sYClient.logIn(syURL, passwordMd5, username31);
        result = new HashMap();
        result.put("userId", username31);
        result.put("sessionId", (String) result1.get("sessionId"));
        //查询该teamId下的车辆数据
        Map<String,Object> carList31 = new HashMap();
        carList31 = sYClient.getCarList1(syURL,teamId, result.get("userId"),result.get("sessionId"));
        Map<String, Object> carList31 = new HashMap();
        carList31 = sYClient.getCarList1(syURL, teamId, result.get("userId"), result.get("sessionId"));
        //拿到车辆数据
        list= (List) carList31.get("list");
        if(list.isEmpty()){
        list = (List) carList31.get("list");
        if (list.isEmpty()) {
            return list;
        }else {
        } else {
            List<String> carIdList = new ArrayList();
            //所有carId
            for(Map<String,String> m : list){
            for (Map<String, String> m : list) {
                carIdList.add(m.get("carId"));
            }
            if(carIdList.size() == 0){
                Map<String,String> map0 = new HashMap();
            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){
            for (Map<String, String> m : list) {
                switch (m.get("state")) {
                    case "1":
                        m.put("carState", "离线-从未报定位");break;
                        m.put("carState", "离线-从未报定位");
                        break;
                    case "2":
                        m.put("carState", "离线-欠费");break;
                        m.put("carState", "离线-欠费");
                        break;
                    case "3":
                        m.put("carState", "离线");break;
                        m.put("carState", "离线");
                        break;
                    case "4":
                        m.put("carState", "离线-报警");break;
                        m.put("carState", "离线-报警");
                        break;
                    case "5":
                        m.put("carState", "在线-从未报定位");break;
                        m.put("carState", "在线-从未报定位");
                        break;
                    case "6":
                        m.put("carState", "在线-欠费");break;
                        m.put("carState", "在线-欠费");
                        break;
                    case "7":
                        m.put("carState", "在线-行驶");break;
                        m.put("carState", "在线-行驶");
                        break;
                    case "8":
                        m.put("carState", "在线-行驶-报警");break;
                        m.put("carState", "在线-行驶-报警");
                        break;
                    case "9":
                        m.put("carState", "在线-停车-ACC关");break;
                        m.put("carState", "在线-停车-ACC关");
                        break;
                    case "10":
                        m.put("carState", "在线-停车-ACC开");break;
                        m.put("carState", "在线-停车-ACC开");
                        break;
                    case "11":
                        m.put("carState", "在线-停车-ACC关-报警");break;
                        m.put("carState", "在线-停车-ACC关-报警");
                        break;
                    case "12":
                        m.put("carState", "在线-停车-ACC开-报警");break;
                        m.put("carState", "在线-停车-ACC开-报警");
                        break;
                    case "13":
                        m.put("carState", "在线-无效定位");break;
                        m.put("carState", "在线-无效定位");
                        break;
                    default:
                        break;
                }
@@ -557,31 +602,32 @@

    /**
     * æ ¹æ®dept集合查询出所有对应的carId
     *
     * @param deptList
     * @return
     */
    @Override
    public List<Map<String,String>> carIdByDeptList(List<Long> deptList,List<Map<String,String>> list){
    public List<Map<String, String>> carIdByDeptList(List<Long> deptList, List<Map<String, String>> list) {
        QueryWrapper<ArdSyCar> queryWrapper = new QueryWrapper<>();
        queryWrapper.in("dept_id",deptList);
        queryWrapper.in("dept_id", deptList);
        List<ArdSyCar> carList = ardSyCarMapper.selectList(queryWrapper);
        //对比把匹配到的数据添加到list中
        for(Map<String,String> m : list){
        for (Map<String, String> m : list) {
            String carId = m.get("carId");
            for (int i = 0; i < carList.size(); i++) {
                ArdSyCar ardSyCar = carList.get(i);
                if(carId.equals(ardSyCar.getCarId())){
                if (carId.equals(ardSyCar.getCarId())) {
                    String url = "";
                    if(ardSyCar.getCarPicture() != null){
                        if(!ardSyCar.getCarPicture().equals("")){
                    if (ardSyCar.getCarPicture() != null) {
                        if (!ardSyCar.getCarPicture().equals("")) {
                            url = ardSyCar.getCarPicture().split("sycar")[0];
                        }
                    }
                    m.put("carModel",url + ardSyCar.getCarModel());//zns
                    m.put("carModel", url + ardSyCar.getCarModel());//zns
                    //m.put("carModel",ardSyCar.getCarModel());
                    m.put("carTypeArd",ardSyCar.getCarType());
                    m.put("carBrand",ardSyCar.getCarBrand());
                    m.put("carPicture",ardSyCar.getCarPicture());
                    m.put("carTypeArd", ardSyCar.getCarType());
                    m.put("carBrand", ardSyCar.getCarBrand());
                    m.put("carPicture", ardSyCar.getCarPicture());
                }
            }
        }
@@ -589,27 +635,27 @@
    }

    @Override
    public Results getCarGPSTrack(Map<String,String> map,String syURL, ArdSyUser ardSyUser){
    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 time = map.get("time");
        time = time.replace("-", "");
        String startTime = time + "000000";
        String endTime = time +"235959";
        String endTime = time + "235959";
        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()){
        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) {
        } else {
            for (Map<String, Object> m : list) {
                String alarmStts = (String) m.get("alarmStts");
                Map<String, List<String>> alarmMap = getInfo("alarm", alarmStts);
                m.putAll(alarmMap);
@@ -625,30 +671,30 @@
    }


    public Map<String,List<String>> getInfo(String type,String stts){
        if(stts.isEmpty()){
    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[] alarmTypes = {"紧急报警", "超速报警", "疲劳驾驶", "危险预警", "GNSS æ¨¡å—发生故障", "GNSS å¤©çº¿æœªæŽ¥æˆ–被剪断", "GNSS å¤©çº¿çŸ­è·¯",
                "终端主电源欠压", "终端主电源掉电", "终端LCD æˆ–显示器故障", "TTS æ¨¡å—æ•…éšœ", "摄像头故障", "道路运输证IC å¡æ¨¡å—æ•…éšœ", "超速预警",
                "疲劳驾驶预警", "违规行驶报警", "胎压预警", "右转盲区异常报警", "当天累计驾驶超时", "超时停车", "进出区域", "进出路线", "路段行驶时间不足/过长",
                "路线偏离报警", "车辆VSS æ•…éšœ", "车辆油量异常", "车辆被盗", "车辆非法点火", "车辆非法位移", "碰撞预警", "侧翻预警", "非法开门报警"};

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

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

        String[] sgnTypes = {"近光灯信号","远光灯信号","右转向灯信号","左转向灯信号","制动信号","倒档信号","雾灯信号","示廓灯","喇叭信号","空调状态",
                "空挡信号","缓速器工作","ABS å·¥ä½œ","加热器工作","离合器状态","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留","保留",
                "保留","保留","保留","保留","保留","保留"};
        String[] sgnTypes = {"近光灯信号", "远光灯信号", "右转向灯信号", "左转向灯信号", "制动信号", "倒档信号", "雾灯信号", "示廓灯", "喇叭信号", "空调状态",
                "空挡信号", "缓速器工作", "ABS å·¥ä½œ", "加热器工作", "离合器状态", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留", "保留",
                "保留", "保留", "保留", "保留", "保留", "保留"};
        //Integer sttsHex = Integer.parseInt(stts, 16);
        Long sttsHex = Long.parseLong(stts, 16);
        //String sttsBin = Integer.toBinaryString(sttsHex);
        String sttsBin = Long.toBinaryString(sttsHex);
        if(sttsBin.length() < 32){
            while(sttsBin.length() < 32){
        if (sttsBin.length() < 32) {
            while (sttsBin.length() < 32) {
                sttsBin = "0" + sttsBin;
            }
        }
@@ -657,22 +703,22 @@
            case "alarm":
                List<String> alarmTypeArray = new ArrayList();
                for (int i = 0; i < sttsBinArray.length; i++) {
                    if(sttsBinArray[i].equals("1")){
                    if (sttsBinArray[i].equals("1")) {
                        alarmTypeArray.add(alarmTypes[i]);
                    }
                }
                Map<String,List<String>> alarmMap = new HashMap();
                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")){
                    if (i <= 7 || i >= 10) {
                        if (sttsBinArray[i].equals("1")) {
                            carTypeArray.add(alarmTypes[i]);
                        }
                    }else if(i == 8){
                        switch (sttsBinArray[8]+sttsBinArray[9]) {
                    } else if (i == 8) {
                        switch (sttsBinArray[8] + sttsBinArray[9]) {
                            case "00":
                                carTypeArray.add(carTypes89[0]);
                                break;
@@ -688,16 +734,16 @@
                            default:
                                break;
                        }
                    }else if(i == 9){
                    } else if (i == 9) {
                        continue;
                    }else{
                    } else {
                        break;
                    }
                }
                Map<String,List<String>> carMap = new HashMap();
                Map<String, List<String>> carMap = new HashMap();
                List<String> carTypeArray0 = new ArrayList();
                for(String str : carTypeArray){
                    if(!str.equals("保留")){
                for (String str : carTypeArray) {
                    if (!str.equals("保留")) {
                        carTypeArray0.add(str);
                    }
                }
@@ -706,104 +752,104 @@
            case "sgn":
                List<String> sgnTypeArray = new ArrayList();
                for (int i = 0; i < sttsBinArray.length; i++) {
                    if(sttsBinArray[i].equals("1")){
                    if (sttsBinArray[i].equals("1")) {
                        sgnTypeArray.add(alarmTypes[i]);
                    }
                }
                Map<String,List<String>> sgnMap = new HashMap();
                Map<String, List<String>> sgnMap = new HashMap();
                List<String> sgnTypeArray0 = new ArrayList();
                for(String str : sgnTypeArray){
                    if(!str.equals("保留")){
                for (String str : sgnTypeArray) {
                    if (!str.equals("保留")) {
                        sgnTypeArray0.add(str);
                    }
                }
                sgnMap.put(type, sgnTypeArray0);
                return sgnMap;
            default:
                return new HashMap<String,List<String>>();
                return new HashMap<String, List<String>>();
        }
    }

    @Override
    public Results getCarGPSBycarId(String usersId,String carId,String syURL,ArdSyUser ardSyUser){
    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);
        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"));
        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) {
        try{
        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){
            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){
            } else {
                if (userCarTimerMap.get(usersId) != null) {
                    userCarTimerMap.get(usersId).cancel();
                    userCarTimerMap.remove(usersId);
                    PositionContainer.getUserPositionMap().remove(usersId);
                    Map<String,Map<String,Object>> map = new HashMap();
                    map.put(carId,new HashMap());
                    PositionContainer.getUserPositionMap().put(usersId,map);
                    Map<String, Map<String, Object>> map = new HashMap();
                    map.put(carId, new HashMap());
                    PositionContainer.getUserPositionMap().put(usersId, map);
                    Date date = new Date();
                    Timer carPositionTimer = new Timer();//定时推送实时位置
                    TimerTask carPositionTask =new TimerTask(){
                    TimerTask carPositionTask = new TimerTask() {
                        @Override
                        public void run(){
                            Map<String,Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
                            if(position != null){
                                if(position.size() != 0){
                                    Map<String,Map<String,Object>> data = new HashMap();
                                    data.put("31000",position);
                        public void run() {
                            Map<String, Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
                            if (position != null) {
                                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));
                                }
                            }
                        }
                    };
                    carPositionTimer.scheduleAtFixedRate(carPositionTask,date,Integer.parseInt(cycle));//启用
                    this.userCarTimerMap.put(usersId,carPositionTimer);
                    carPositionTimer.scheduleAtFixedRate(carPositionTask, date, Integer.parseInt(cycle));//启用
                    this.userCarTimerMap.put(usersId, carPositionTimer);
                    return Results.succeed("开始追踪");
                }else{
                    Map<String,Map<String,Object>> map = new HashMap();
                    map.put(carId,new HashMap());
                    PositionContainer.getUserPositionMap().put(usersId,map);
                } else {
                    Map<String, Map<String, Object>> map = new HashMap();
                    map.put(carId, new HashMap());
                    PositionContainer.getUserPositionMap().put(usersId, map);
                    Date date = new Date();
                    Timer carPositionTimer = new Timer();//定时推送实时位置
                    TimerTask carPositionTask =new TimerTask(){
                    TimerTask carPositionTask = new TimerTask() {
                        @Override
                        public void run(){
                            Map<String,Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
                            if(position != null){
                                if(position.size() != 0){
                                    Map<String,Map<String,Object>> data = new HashMap();
                                    data.put("31000",position);
                        public void run() {
                            Map<String, Object> position = PositionContainer.getUserPositionMap().get(usersId).get(carId);
                            if (position != null) {
                                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));
                                }
                            }
                        }
                    };
                    carPositionTimer.scheduleAtFixedRate(carPositionTask,date,Integer.parseInt(cycle));//启用
                    this.userCarTimerMap.put(usersId,carPositionTimer);
                    carPositionTimer.scheduleAtFixedRate(carPositionTask, date, Integer.parseInt(cycle));//启用
                    this.userCarTimerMap.put(usersId, carPositionTimer);
                    return Results.succeed("开始追踪");
                }
            }
        }catch(Exception e){
        } catch (Exception e) {
            e.printStackTrace();
            return Results.error("追踪失败");
        }
@@ -835,17 +881,17 @@

    @Override
    public Results getExistTraceByCarIdAndMonth(String userId, String carId, String time) {
        List<ArdSyCarDay> result = ardSyCarDayMapper.selectArdSyCarDayByCarIdAndDay(carId,time + "%");
        List<ArdSyCarDay> result = ardSyCarDayMapper.selectArdSyCarDayByCarIdAndDay(carId, time + "%");
        List<String> list = new ArrayList();
        for(ArdSyCarDay ardSyCarDay : result){
        for (ArdSyCarDay ardSyCarDay : result) {
//            list.add(ardSyCarDay.getDay().split("-")[2]);
            list.add(ardSyCarDay.getDay());
        }
        return Results.succeed(list);
    }

    public Map<String,Integer> getExistTraceByCarIdAndMonth(String url,String usersId,String password,String carId,String time){
        Map<String,Object> LogInResult = sYClient.logIn(url,password,usersId);
    public Map<String, Integer> getExistTraceByCarIdAndMonth(String url, String usersId, String password, String carId, String time) {
        Map<String, Object> LogInResult = sYClient.logIn(url, password, usersId);
        String sessionId = (String) LogInResult.get("sessionId");

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM");
@@ -858,49 +904,49 @@
        Calendar calendar = Calendar.getInstance();
        calendar.setTime(date);
        int maxDay = calendar.getActualMaximum(Calendar.DAY_OF_MONTH);//获取该月天数
        Map<String,Integer> existTraceMap = new HashMap();
        Map<String, Integer> existTraceMap = new HashMap();
        ExecutorService newCachedThreadPoll = Executors.newCachedThreadPool();
        for (int i = 1; i <= maxDay; i = i + 7) {
            int temp = i;
            String finalTime = time.replace("-","");
            String finalTime = time.replace("-", "");
            String finalsyURL = url;
            newCachedThreadPoll.execute(new Runnable(){
            newCachedThreadPoll.execute(new Runnable() {
                @Override
                public void run() {
                    int temp0 = temp + 6;
                    if(temp0 > maxDay){
                    if (temp0 > maxDay) {
                        temp0 = maxDay;
                    }
                    for (int j = temp; j <= temp0; j++) {
                        if(j <= 9){
                        if (j <= 9) {
                            existTraceMap.put("0" + String.valueOf(j), -1);
                        }else{
                        } else {
                            existTraceMap.put(String.valueOf(j), -1);
                        }
                    }
                    if(temp <= 9){
                        if(temp0 <= 9){
                    if (temp <= 9) {
                        if (temp0 <= 9) {
                            String startTime = finalTime + "0" + temp + "000000";
                            String endTime = finalTime + "0" + temp0 + "235959";
                            Map<String,Object> result = getCarGPSTrack(finalsyURL,carId,startTime,endTime,sessionId);
                            String rspCode = (String)result.get("rspCode");
                            if(rspCode.equals("1")){
                                List<Map<String,Object>> list = (List<Map<String, Object>>) result.get("list");
                                for(Map<String,Object> m : list){
                            Map<String, Object> result = getCarGPSTrack(finalsyURL, carId, startTime, endTime, sessionId);
                            String rspCode = (String) result.get("rspCode");
                            if (rspCode.equals("1")) {
                                List<Map<String, Object>> list = (List<Map<String, Object>>) result.get("list");
                                for (Map<String, Object> m : list) {
                                    String time = (String) m.get("time");
                                    time = time.split(" ")[0];
                                    time = time.split("-")[2];
                                    existTraceMap.put(time, 1);
                                }
                            }
                        }else{
                        } else {
                            String startTime = finalTime + "0" + temp + "000000";
                            String endTime = finalTime + temp0 + "235959";
                            Map<String,Object> result = getCarGPSTrack(finalsyURL,carId,startTime,endTime,sessionId);
                            String rspCode = (String)result.get("rspCode");
                            if(rspCode.equals("1")){
                                List<Map<String,Object>> list = (List<Map<String, Object>>) result.get("list");
                                for(Map<String,Object> m : list){
                            Map<String, Object> result = getCarGPSTrack(finalsyURL, carId, startTime, endTime, sessionId);
                            String rspCode = (String) result.get("rspCode");
                            if (rspCode.equals("1")) {
                                List<Map<String, Object>> list = (List<Map<String, Object>>) result.get("list");
                                for (Map<String, Object> m : list) {
                                    String time = (String) m.get("time");
                                    time = time.split(" ")[0];
                                    time = time.split("-")[2];
@@ -908,14 +954,14 @@
                                }
                            }
                        }
                    }else{
                    } else {
                        String startTime = finalTime + temp + "000000";
                        String endTime = finalTime + temp0 + "235959";
                        Map<String,Object> result = getCarGPSTrack(finalsyURL,carId,startTime,endTime,sessionId);
                        String rspCode = (String)result.get("rspCode");
                        if(rspCode.equals("1")){
                            List<Map<String,Object>> list = (List<Map<String, Object>>) result.get("list");
                            for(Map<String,Object> m : list){
                        Map<String, Object> result = getCarGPSTrack(finalsyURL, carId, startTime, endTime, sessionId);
                        String rspCode = (String) result.get("rspCode");
                        if (rspCode.equals("1")) {
                            List<Map<String, Object>> list = (List<Map<String, Object>>) result.get("list");
                            for (Map<String, Object> m : list) {
                                String time = (String) m.get("time");
                                time = time.split(" ")[0];
                                time = time.split("-")[2];
@@ -923,14 +969,14 @@
                            }
                        }
                    }
                    for(int j = temp; j <= temp0; j++){
                    for (int j = temp; j <= temp0; j++) {
                        String key = "";
                        if(j <= 9){
                        if (j <= 9) {
                            key = "0" + j;
                        }else{
                        } else {
                            key = String.valueOf(j);
                        }
                        if(existTraceMap.get(key) == -1){
                        if (existTraceMap.get(key) == -1) {
                            existTraceMap.put(key, 0);
                        }

@@ -938,9 +984,9 @@
                }
            });
        }
        while(true){
            if(!existTraceMap.values().contains(-1)){
                if(existTraceMap.size() == maxDay){
        while (true) {
            if (!existTraceMap.values().contains(-1)) {
                if (existTraceMap.size() == maxDay) {
                    break;
                }
            }
@@ -952,11 +998,11 @@
        }
    }

    public static Map<String,Object> getCarGPSTrack(String syURL,String carId,String startTime,String endTime,String sessionId){
    public static Map<String, Object> getCarGPSTrack(String syURL, String carId, String startTime, String endTime, String sessionId) {
        OkHttpClient okHttpClient = new OkHttpClient();

        Request request = new Request.Builder()
                .url(syURL + "/gps-web/api/get_gps_h.jsp?carId="+carId+"&startTime="+startTime+"&endTime="+endTime+"&filter0=true&maxSpeed=&stopLong=5&queryAlarm=false&userId=yanshi&loginType=user&loginWay=android&loginLang=zh_CN&appDevId=&sessionId="+sessionId)
                .url(syURL + "/gps-web/api/get_gps_h.jsp?carId=" + carId + "&startTime=" + startTime + "&endTime=" + endTime + "&filter0=true&maxSpeed=&stopLong=5&queryAlarm=false&userId=yanshi&loginType=user&loginWay=android&loginLang=zh_CN&appDevId=&sessionId=" + sessionId)
                .build();

        Response response = null;
@@ -973,7 +1019,7 @@

        try {
            String message = responseBody.string();// å“åº”体
            Map<String,Object> map = (Map<String, Object>) JSON.parse(message);
            Map<String, Object> map = (Map<String, Object>) JSON.parse(message);
            //System.out.println(message);
            return map;
        } catch (IOException e) {
@@ -982,4 +1028,66 @@
            return new HashMap();
        }
    }

    /**
     * èŽ·å–附近范围内的车辆信息
     */

    @Override
    public List<Map<String, Object>> getNearCar(SchedulingParam param) {
        Double longitude = param.getLongitude();
        Double latitude = param.getLatitude();
        Integer radius = param.getSealingRadius();
        if (longitude == null && latitude == null) {
            log.debug("原点坐标为空");
            return null;
        }
        if (radius == null) {
            log.debug("半径距离为空");
            return null;
        }
        String userId = SecurityUtils.getUserId();
        ArdSyUser syUser = new ArdSyUser();
        syUser.setSysUserId(userId);
        List<ArdSyUser> ardSyUserList = ardSyUserMapper.selectArdSyUserList(syUser);
        if (ardSyUserList.size() == 0) {
            log.debug("用户未挂接三一车辆");
            return null;
        }
        ArdSyUser ardSyUser = ardSyUserList.get(0);
        String syUrl = redisCache.getCacheObject("sys_config:syCarPT");
        String passwordMd5 = DigestUtils.md5Hex(ardSyUser.getPassword());
        Map<String, Object> LogInResult = sYClient.logIn(syUrl, passwordMd5, ardSyUser.getUserId());
        String sessionId = (String) LogInResult.get("sessionId");

        Map<String, Object> teamList = sYClient.getTeamList(syUrl, ardSyUser.getUserId(), sessionId);
        List<Map<String, Object>> listMap = (List<Map<String, Object>>) teamList.get("list");
        List<Map<String, Object>> allList = new ArrayList<>();
        for (Map<String, Object> team : listMap) {
            String teamId = (String) team.get("teamId");
            Map<String, Object> carListMap = sYClient.getCarList1(syUrl, teamId, ardSyUser.getUserId(), sessionId);
            if (((String) carListMap.get("rspCode")).equals("1")) {
                List<Map<String, Object>> list = (List<Map<String, Object>>) carListMap.get("list");
                allList.addAll(list);
            }
        }
        //过滤在线车辆
        List<Map<String, Object>> onlineList = allList.stream()
                .filter(map -> !"离线".equals(map.get("stateCn")))
                .collect(Collectors.toList());
        List<Map<String, Object>> filteredList = new ArrayList<>();
        //过滤半径
        for (Map<String, Object> carMap : onlineList) {
            String carId = (String) carMap.get("carId");
            Map<String, Object> carGPSTrack = sYClient.getCarNearPositionByCarId(syUrl, carId, ardSyUser.getUserId(), sessionId);
            List<Map<String, Object>> carGPSMap = (List<Map<String, Object>>) carGPSTrack.get("list");
            Double lng = Double.valueOf((String) carGPSMap.get(0).get("lng"));
            Double lat = Double.valueOf((String) carGPSMap.get(0).get("lat"));
            double distance = GisTool.getDistance( new double[]{longitude,latitude}, new double[]{lng, lat});
            if (distance <= radius) {
                filteredList.add(carMap); // å°†æ»¡è¶³æ¡ä»¶çš„车辆添加到筛选列表中
            }
        }
        return filteredList;
    }
}

 ard-work/src/main/resources/mapper/device/ArdCamerasMapper.xml

@@ -49,6 +49,7 @@
               c.altitude,
               c.user_id,
               c.dept_id,
               c.login_id,
               c.cam_heading,
               c.cam_pitch,
               c.cam_roll,

 ruoyi-admin/src/main/resources/logback.xml

@@ -198,11 +198,25 @@
            <pattern>${log.pattern}</pattern>
        </encoder>
    </appender>
    <!--无人机日志输出-->
    <appender name="uav" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${log.path}/uav.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <!--按天回滚daily-->
            <fileNamePattern>${log.path}/uav.%d{yyyy-MM-dd}.log</fileNamePattern>
            <!--日志最大的历史60天-->
            <maxHistory>60</maxHistory>
        </rollingPolicy>
        <encoder>
            <pattern>${log.pattern}</pattern>
        </encoder>
    </appender>
    <!--三一车辆日志输出-->
    <appender name="sy" class="ch.qos.logback.core.rolling.RollingFileAppender">
        <file>${log.path}/sy.log</file>
        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
            <!--按天回滚daily-->
            <fileNamePattern>${log.path}/sy.%d{yyyy-MM-dd}.log</fileNamePattern>
            <!--日志最大的历史60天-->
            <maxHistory>60</maxHistory>
        </rollingPolicy>
@@ -268,7 +282,12 @@
    <logger name="cmd" level="INFO">
        <appender-ref ref="cmd"/>
    </logger>
    <!--无人机日志打印等级-->
    <logger name="uav" level="INFO">
        <appender-ref ref="uav"/>
    </logger>
    <!--三一车辆日志打印等级-->
    <logger name="sy" level="INFO">
        <appender-ref ref="sy"/>
    </logger>
</configuration>