查看在线单兵端及车辆提交

zhangnaisong

2024-02-21 ca8c7b4e9c4762acb2fc2c793d79ae58e05dcf36

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

@@ -1,20 +1,32 @@
package com.ruoyi.app.position.service.impl;

import com.ruoyi.alarm.wall.domain.ArdAlarmWall;
import com.ruoyi.alarm.wall.service.IArdAlarmWallService;
import com.ruoyi.alarmpoints.wall.domain.ArdWall;
import com.ruoyi.alarmpoints.wall.mapper.ArdWallMapper;
import com.ruoyi.app.position.appcontainer.AppContainer;
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.entity.SysUser;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.system.mapper.SysDeptMapper;
import com.ruoyi.system.mapper.SysUserMapper;
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.utils.gis.GisUtil;
import com.ruoyi.utils.gis.Point;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import java.util.stream.Collectors;

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


/**
@@ -24,11 +36,24 @@
 * @date 2023-07-18
 */
@Service
@Slf4j
public class ArdAppPositionServiceImpl implements IArdAppPositionService {
    @Resource
    private ArdAppPositionMapper ardAppPositionMapper;
    @Resource
    private ISysUserService iSysUserService;
    @Resource
    RedisCache redisCache;
    @Resource
    ArdWallMapper ardWallMapper;
    @Resource
    IArdAlarmWallService ardAlarmWallService;
    @Resource
    private SysUserMapper sysUserMapper;
    @Resource
    private SysDeptMapper sysDeptMapper;


    Map<String, String> firstAlarmMap = new HashMap<>();//首次报警缓存key:用户id_围栏id value: 报警id
    /**
     * 查询app位置
     *
@@ -39,6 +64,7 @@
    public ArdAppPosition selectArdAppPositionById(String id) {
        return ardAppPositionMapper.selectArdAppPositionById(id);
    }

    /**
     * 按用户id查询最后的位置信息
     *
@@ -46,9 +72,10 @@
     * @return app位置
     */
    @Override
    public ArdAppPosition selectLastArdAppPositionByUserId(String userId){
    public ArdAppPosition selectLastArdAppPositionByUserId(String userId) {
        return ardAppPositionMapper.selectLastArdAppPositionByUserId(userId);
    }

    /**
     * 查询app位置列表
     *
@@ -67,10 +94,16 @@
     * @return 结果
     */
    @Override
    public int insertArdAppPosition(ArdAppPosition ardAppPosition) {
    public List<ArdAlarmWall> insertArdAppPosition(ArdAppPosition ardAppPosition) {
        ardAppPosition.setId(IdUtils.simpleUUID());
        ardAppPosition.setCreateTime(DateUtils.getNowDate());
        return ardAppPositionMapper.insertArdAppPosition(ardAppPosition);
        ardAppPositionMapper.insertArdAppPosition(ardAppPosition);
        try{
            return DetectionWallAlarm(ardAppPosition);
        }finally {
            AppContainer.getArdAppPositionMap().put(ardAppPosition.getUserId(),ardAppPosition);//实时位置存入容器
        }

    }

    /**
@@ -106,5 +139,397 @@
        return ardAppPositionMapper.deleteArdAppPositionById(id);
    }

    /**
     * 获取封控圈内所有在线app用户
     * 刘苏义
     * 2023/8/17 13:56:36
     */
    @Override
    public List<SysUser> getNearAppUsers(SchedulingParam param) {
        List<SysUser> filteredList = new ArrayList<>();
        try {
            Long deptId = SecurityUtils.getLoginUser().getUser().getDeptId();
            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();
            user.setDeptId(deptId);
            List<SysUser> appUserList = iSysUserService.selectAllAppUserList(user);
            //过滤在线和单兵端
            List<SysUser> onLineList = appUserList.stream()
                    .filter(sysUser -> (sysUser.getAppOnlineState().equals("1")))
                    .filter(sysUser -> (sysUser.getAppUserType().equals("1")))
                    .collect(Collectors.toList());
            //过滤范围
            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 = GisUtil.getDistance(new double[]{longitude, latitude}, new double[]{lon, lat});
                    if (distance <= radius) {
                        Map<String, Object> params = new HashMap<>();
                        params.put("longitude", lon);
                        params.put("latitude", lat);
                        sysUser.setParams(params);
                        filteredList.add(sysUser); // 将满足条件的用户添加到筛选列表中
                    }
                }
            }
        } catch (Exception ex) {
            log.error("获取封控圈内所有在线app用户异常" + ex.getMessage());
        }
        return filteredList;
    }

    /**
     * 获取封控圈内所有在线app用户(多边形)
     * 刘苏义
     * 2023/8/17 13:56:36
     */
    @Override
    public List<SysUser> getNearAppUsersWithPolygon(SchedulingParam param) {
        List<SysUser> filteredList = new ArrayList<>();
        try {
            Long deptId = SecurityUtils.getLoginUser().getUser().getDeptId();
            List<Point> partitionLocation = param.getPartitionLocation();

            SysUser user = new SysUser();
            user.setDeptId(deptId);
            List<SysUser> appUserList = iSysUserService.selectAllAppUserList(user);
            //过滤在线
            List<SysUser> onLineList = appUserList.stream()
                    .filter(sysUser -> (sysUser.getAppOnlineState().equals("1")))
                    .filter(sysUser -> (sysUser.getAppUserType().equals("1")))
                    .collect(Collectors.toList());
            //过滤范围
            for (SysUser sysUser : onLineList) {
                ArdAppPosition ardAppPosition = ardAppPositionMapper.selectLastArdAppPositionByUserId(sysUser.getUserId());
                if (ardAppPosition != null) {
                    Double lon = ardAppPosition.getLongitude();
                    Double lat = ardAppPosition.getLatitude();
                    if (lon == null || lat == null) {
                        continue;
                    }
                    Point point2D = new Point(lon, lat);
                    boolean inPolygon = GisUtil.isInPolygon(point2D, partitionLocation);
                    if (inPolygon) {
                        Map<String, Object> params = new HashMap<>();
                        params.put("longitude", lon);
                        params.put("latitude", lat);
                        sysUser.setParams(params);
                        filteredList.add(sysUser); // 将满足条件的用户添加到筛选列表中
                    }
                }
            }
        } catch (Exception ex) {
            log.error("获取封控圈内所有在线app用户异常" + ex.getMessage());
        }
        return filteredList;
    }

    /**
     * 实时位置检测围栏报警
     * 刘苏义
     * 2023/8/31 8:54:06
     */
    /*public List<ArdAlarmWall> DetectionWallAlarm(ArdAppPosition ardAppPosition) {
        List<ArdAlarmWall> ardAlarmWalls = new ArrayList<>();
        //获取当前用户的部门
        String userId = ardAppPosition.getUserId();
        //获取用户关联的所有电子围栏
        List<ArdWall> ardWalls = ardWallMapper.selectArdWallListByUserId(userId);
        if (ardWalls.size() > 0) {
            //遍历所有电子围栏
            for (ArdWall wall : ardWalls) {
                String wallId = wall.getId();//围栏ID
                String wallType = wall.getType();//围栏类型
                String wallPoi = wall.getWallPoi();//围栏坐标集合
                //处理多边形的每个点的经纬度
                String[] parts = wallPoi.split(",");
                List<Point> pointList = new ArrayList<>();
                for (int i = 0; i < parts.length; i += 3) {
                    Point point = new Point();
                    point.setLongitude(Double.valueOf(parts[i]));
                    point.setLatitude(Double.valueOf(parts[i + 1]));
                    pointList.add(point);
                }
                //当前用户的位置
                Point userPoint = new Point(ardAppPosition.getLongitude(), ardAppPosition.getLatitude());
                boolean inPolygon = GisUtil.isInPolygon(userPoint, pointList);//判断是否在围栏内
                //创建围栏报警实体对象
                ArdAlarmWall ardAlarmWall = new ArdAlarmWall();
                ardAlarmWall.setWallId(wall.getId());
                ardAlarmWall.setWallName(wall.getWallName());
                ardAlarmWall.setUserId(userId);
                ardAlarmWall.setAlarmTime(DateUtils.getNowDate());
                ardAlarmWall.setAlarmType(wall.getType());
                ardAlarmWall.setLongitude(ardAppPosition.getLongitude());
                ardAlarmWall.setLatitude(ardAppPosition.getLatitude());
                ardAlarmWall.setAltitude(ardAppPosition.getAltitude());
                String key = userId + "_" + wallId;//最后一次报警缓存key
                //按类型区分围栏禁入或者禁出
                if ("1".equals(wallType)) {
                    if (inPolygon) {
                        //禁入围栏则若在围栏内,获取首次进入围栏报警ID
                        String lastInAlarmId = firstAlarmMap.get(key);
                        //判断当前用户是否首次进入围栏内
                        if (lastInAlarmId == null) {
                            //当前用户首次进入生成报警
                            String uuid = IdUtils.simpleUUID();
                            ardAlarmWall.setId(uuid);
                            ardAlarmWallService.insertArdAlarmWall(ardAlarmWall);
                            //记录首次报警id
                            firstAlarmMap.put(key, uuid);
                        } else {
                            //用户已进入更新最后报警
                            ardAlarmWall.setId(lastInAlarmId);
                            ardAlarmWallService.updateArdAlarmWall(ardAlarmWall);
                        }
                        ardAlarmWalls.add(ardAlarmWall);
                    } else {
                        //禁入围栏则若在围栏外则移除报警缓存
                        firstAlarmMap.remove(key);
                    }
                } else//禁出
                {
                    //判断当前用户位置是否在围栏外
                    if (!inPolygon) {
                        //禁出围栏则若在围栏外,获取首次走出围栏报警ID
                        String lastAlarmId = firstAlarmMap.get(key);
                        //判断当前用户是否首次在围栏外
                        if (lastAlarmId == null) {
                            String uuid = IdUtils.simpleUUID();
                            //当前用户首次出围栏生成报警
                            ardAlarmWall.setId(uuid);
                            ardAlarmWallService.insertArdAlarmWall(ardAlarmWall);
                            //记录首次报警id
                            firstAlarmMap.put(key, uuid);
                        } else {
                            //用户已经在围栏外更新报警
                            ardAlarmWall.setId(lastAlarmId);
                            ardAlarmWallService.updateArdAlarmWall(ardAlarmWall);
                        }
                        ardAlarmWalls.add(ardAlarmWall);
                    } else {
                        //移除首次报警缓存
                        firstAlarmMap.remove(key);
                    }
                }
            }
        }
        return ardAlarmWalls;
    }*/

    public List<ArdAlarmWall> DetectionWallAlarm(ArdAppPosition ardAppPosition) {
        List<ArdAlarmWall> ardAlarmWalls = new ArrayList<>();
        //获取当前用户的部门
        String userId = ardAppPosition.getUserId();
        //获取用户关联的所有电子围栏
        List<ArdWall> ardWalls = ardWallMapper.selectArdWallListByUserId(userId);
        List<ArdWall> ardWallsNoIn = new ArrayList();//禁入电子围栏
        List<ArdWall> ardWallsNoOut = new ArrayList();//禁出电子围栏
        ardWallsNoIn = ardWalls.stream().filter(ardWall -> ardWall.getType().equals("1")).collect(Collectors.toList());
        ardWallsNoOut = ardWalls.stream().filter(ardWall -> ardWall.getType().equals("2")).collect(Collectors.toList());
        //当前用户的位置
        Point userPoint = new Point(ardAppPosition.getLongitude(), ardAppPosition.getLatitude());
        if(ardWallsNoIn.size() > 0){//判断禁入
            for(ArdWall wall : ardWallsNoIn){
                String wallId = wall.getId();//围栏ID
                String wallPoi = wall.getWallPoi();//围栏坐标集合
                //处理多边形的每个点的经纬度
                String[] parts = wallPoi.split(",");
                List<Point> pointList = new ArrayList<>();
                for (int i = 0; i < parts.length; i += 3) {
                    Point point = new Point();
                    point.setLongitude(Double.valueOf(parts[i]));
                    point.setLatitude(Double.valueOf(parts[i + 1]));
                    pointList.add(point);
                }
                boolean inPolygon = GisUtil.isInPolygon(userPoint, pointList);//判断是否在围栏内
                //创建围栏报警实体对象
                ArdAlarmWall ardAlarmWall = new ArdAlarmWall();
                ardAlarmWall.setWallId(wall.getId());
                ardAlarmWall.setWallName(wall.getWallName());
                ardAlarmWall.setUserId(userId);
                ardAlarmWall.setAlarmTime(DateUtils.getNowDate());
                ardAlarmWall.setAlarmType(wall.getType());
                ardAlarmWall.setLongitude(ardAppPosition.getLongitude());
                ardAlarmWall.setLatitude(ardAppPosition.getLatitude());
                ardAlarmWall.setAltitude(ardAppPosition.getAltitude());
                String key = userId + "_" + wallId;//最后一次报警缓存key
                if (inPolygon) {
                    //禁入围栏则若在围栏内,获取首次进入围栏报警ID
                    String lastInAlarmId = firstAlarmMap.get(key);
                    //判断当前用户是否首次进入围栏内
                    if (lastInAlarmId == null) {
                        //当前用户首次进入生成报警
                        String uuid = IdUtils.simpleUUID();
                        ardAlarmWall.setId(uuid);
                        ardAlarmWallService.insertArdAlarmWall(ardAlarmWall);
                        //记录首次报警id
                        firstAlarmMap.put(key, uuid);
                    } else {
                        //用户已进入更新最后报警
                        ardAlarmWall.setId(lastInAlarmId);
                        ardAlarmWallService.updateArdAlarmWall(ardAlarmWall);
                    }
                    ardAlarmWalls.add(ardAlarmWall);
                } else {
                    //禁入围栏则若在围栏外则移除报警缓存
                    firstAlarmMap.remove(key);
                }
            }
        }

        Boolean noOutFlag = true;
        if(ardWallsNoOut.size() > 0) {//判断禁出
            for(ArdWall wall : ardWallsNoOut){
                String wallPoi = wall.getWallPoi();//围栏坐标集合
                //处理多边形的每个点的经纬度
                String[] parts = wallPoi.split(",");
                List<Point> pointList = new ArrayList<>();
                for (int i = 0; i < parts.length; i += 3) {
                    Point point = new Point();
                    point.setLongitude(Double.valueOf(parts[i]));
                    point.setLatitude(Double.valueOf(parts[i + 1]));
                    pointList.add(point);
                }
                boolean inPolygon = GisUtil.isInPolygon(userPoint, pointList);//判断是否在围栏内
                if (!inPolygon) {
                    noOutFlag = true;
                } else {
                    noOutFlag = false;
                    break;
                }
            }
        }
        if(noOutFlag){//全部禁出电子围栏都出去了
            for(ArdWall wall : ardWallsNoOut){
                String wallId = wall.getId();//围栏ID
                //创建围栏报警实体对象
                ArdAlarmWall ardAlarmWall = new ArdAlarmWall();
                ardAlarmWall.setWallId(wall.getId());
                ardAlarmWall.setWallName(wall.getWallName());
                ardAlarmWall.setUserId(userId);
                ardAlarmWall.setAlarmTime(DateUtils.getNowDate());
                ardAlarmWall.setAlarmType(wall.getType());
                ardAlarmWall.setLongitude(ardAppPosition.getLongitude());
                ardAlarmWall.setLatitude(ardAppPosition.getLatitude());
                ardAlarmWall.setAltitude(ardAppPosition.getAltitude());
                String key = userId + "_" + wallId;//最后一次报警缓存key
                //禁出围栏则若在围栏外,获取首次走出围栏报警ID
                String lastAlarmId = firstAlarmMap.get(key);
                //判断当前用户是否首次在围栏外
                if (lastAlarmId == null) {
                    String uuid = IdUtils.simpleUUID();
                    //当前用户首次出围栏生成报警
                    ardAlarmWall.setId(uuid);
                    ardAlarmWallService.insertArdAlarmWall(ardAlarmWall);
                    //记录首次报警id
                    firstAlarmMap.put(key, uuid);
                } else {
                    //用户已经在围栏外更新报警
                    ardAlarmWall.setId(lastAlarmId);
                    ardAlarmWallService.updateArdAlarmWall(ardAlarmWall);
                }
                ardAlarmWalls.add(ardAlarmWall);
            }
        }else{
            for(ArdWall wall : ardWallsNoOut){
                String wallId = wall.getId();//围栏ID
                String key = userId + "_" + wallId;//最后一次报警缓存key
                firstAlarmMap.remove(key);
            }
        }
        return ardAlarmWalls;
    }

    @Override
    public Map<String, List<SysUser>> getOnlinePCOrCommander(String usersId) {
        Map<String, List<SysUser>> result = new HashMap();
        List<SysUser> commanderList = sysUserMapper.getOnlineCommander(usersId);
        result.put("commander",commanderList);
        try{
            List<String> onLinePCIdList = new ArrayList();
            //onLinePCIdList.addAll(ONLINE_USER_SESSIONS.keySet());
            for(String id : ONLINE_USER_SESSIONS.keySet()){
                onLinePCIdList.add(id.split("_")[0]);
            }
            List<SysUser> pcList = sysUserMapper.getOnlinePC(usersId,onLinePCIdList);
            result.put("pc",pcList);
        }catch(Exception e){
            result.put("pc",new ArrayList());
        }
        return result;
    }

    @Override
    public List<Map<String,Object>> getOnlineCommanderPosition(String soilderId) {
        List<Map<String,Object>> result = ardAppPositionMapper.getOnlineCommanderPosition(soilderId);
        return result;
    }

    @Override
    public List<ArdAppPosition> getAPPPositionByUserIdAndTime(Map<String, String> para) {
        String userId = para.get("userId");
        String beginTime = para.get("beginTime");
        String endTime = para.get("endTime");
        List<ArdAppPosition> result = ardAppPositionMapper.getAPPPositionByUserIdAndTime(userId,beginTime,endTime);
        return result;
    }

    @Override
    public List<Map<String,Object>> getOnlineAPPSoilderByCommanderId(String userId) {
        SysUser sysUser = sysUserMapper.selectUserById(userId);//获取系统用户
        List<Long> deptIdList = new ArrayList();
        deptIdList.add(sysUser.getDeptId());
        deptIdList = getOwnAndChildrenDeptIdList(deptIdList,new ArrayList());//递归查询下属部门主键
        List<SysUser> result = sysUserMapper.getOwnAndChildrenOnlineSoilderList(deptIdList);
        List<Map<String,Object>> resultList = new ArrayList();
        for(SysUser sysUserIn : result){
            Map<String,Object> map = new HashMap();
            map.put("userId",sysUserIn.getUserId());
            map.put("deptId",sysUserIn.getDeptId());
            map.put("userName",sysUserIn.getUserName());
            map.put("nickName",sysUserIn.getNickName());
            try{
                map.put("longitude",AppContainer.getArdAppPositionMap().get(sysUserIn.getUserId()).getLongitude());
                map.put("latitude",AppContainer.getArdAppPositionMap().get(sysUserIn.getUserId()).getLatitude());
                map.put("altitude",AppContainer.getArdAppPositionMap().get(sysUserIn.getUserId()).getAltitude());
            }catch(Exception e){
                ArdAppPosition ardAppPosition = ardAppPositionMapper.getLastAPPPositionByUserId(sysUserIn.getUserId());
                map.put("longitude",ardAppPosition.getLongitude());
                map.put("latitude",ardAppPosition.getLatitude());
                map.put("altitude",ardAppPosition.getAltitude());
            }
            resultList.add(map);
        }
        return resultList;
    }

    public List<Long> getOwnAndChildrenDeptIdList(List<Long> deptIdList,List<Long> deptIdListr){
        deptIdListr.addAll(deptIdList);
        List<Long> result = sysDeptMapper.getChildrenDeptIdList(deptIdList);
        if(result.size() != 0){
            deptIdListr.addAll(result);
            result = getOwnAndChildrenDeptIdList(result,deptIdListr);
        }
        deptIdListr = deptIdListr.stream().distinct().collect(Collectors.toList());
        return deptIdListr;
    }

}