查询本部门在线PC端通过websocket判断提交

zhangnaisong

2024-01-20 e5c8f327e3735a252610eb167d08ae3773b65184

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

@@ -14,6 +14,7 @@
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.common.utils.uuid.IdUtils;
import com.ruoyi.scheduling.domian.SchedulingParam;
import com.ruoyi.system.mapper.SysUserMapper;
import com.ruoyi.system.service.ISysUserService;
import com.ruoyi.utils.gis.GisUtil;
import com.ruoyi.utils.gis.Point;
@@ -21,8 +22,11 @@
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

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


/**
@@ -38,7 +42,16 @@
    private ArdAppPositionMapper ardAppPositionMapper;
    @Resource
    private ISysUserService iSysUserService;
    @Resource
    RedisCache redisCache;
    @Resource
    ArdWallMapper ardWallMapper;
    @Resource
    IArdAlarmWallService ardAlarmWallService;
    @Resource
    private SysUserMapper sysUserMapper;

    Map<String, String> firstAlarmMap = new HashMap<>();//首次报警缓存key:用户id_围栏id value: 报警id
    /**
     * 查询app位置
     *
@@ -221,33 +234,23 @@
        return filteredList;
    }


    @Resource
    RedisCache redisCache;
    @Resource
    ArdWallMapper ardWallMapper;
    @Resource
    IArdAlarmWallService ardAlarmWallService;
    Map<String, String> userLastAlarm = new HashMap<>();

    /**
     * 实时位置检测围栏报警
     * 刘苏义
     * 2023/8/31 8:54:06
     */
    public List<ArdAlarmWall> DetectionWallAlarm(ArdAppPosition ardAppPosition) {
        List<ArdAlarmWall> ardAlarmWalls=new ArrayList<>();
        List<ArdAlarmWall> ardAlarmWalls = new ArrayList<>();
        //获取当前用户的部门
        String userId = ardAppPosition.getUserId();
        SysUser sysUser = redisCache.getCacheObject("user_list:" + userId);
        Long deptId = sysUser.getDeptId();
        //获取部门下的所有电子围栏
        ArdWall ardWall = new ArdWall();
        ardWall.setDeptId(deptId);
        List<ArdWall> ardWalls = ardWallMapper.selectArdWallList(ardWall);
        //获取用户关联的所有电子围栏
        List<ArdWall> ardWalls = ardWallMapper.selectArdWallListByUserId(userId);
        if (ardWalls.size() > 0) {
            //遍历所有电子围栏
            for (ArdWall wall : ardWalls) {
                String wallPoi = wall.getWallPoi();
                String wallId = wall.getId();//围栏ID
                String wallType = wall.getType();//围栏类型
                String wallPoi = wall.getWallPoi();//围栏坐标集合
                //处理多边形的每个点的经纬度
                String[] parts = wallPoi.split(",");
                List<Point> pointList = new ArrayList<>();
@@ -257,44 +260,89 @@
                    point.setLatitude(Double.valueOf(parts[i + 1]));
                    pointList.add(point);
                }

                //判断当前用户位置是否在围栏内
                Point userPoint=new Point();
                userPoint.setLongitude(ardAppPosition.getLongitude());
                userPoint.setLatitude(ardAppPosition.getLatitude());
                boolean inPolygon = GisUtil.isInPolygon(userPoint, pointList);
                if (inPolygon) {
                    String lastAlarmId = userLastAlarm.get(userId);
                    ArdAlarmWall ardAlarmWall = new ArdAlarmWall();
                    ardAlarmWall.setWallId(wall.getId());
                    ardAlarmWall.setWallName(wall.getWallName());
                    ardAlarmWall.setUserId(userId);
                    ardAlarmWall.setAlarmTime(new Date());
                    ardAlarmWall.setAlarmType(wall.getType());
                    ardAlarmWall.setLongitude(ardAppPosition.getLongitude());
                    ardAlarmWall.setLatitude(ardAppPosition.getLatitude());
                    ardAlarmWall.setAltitude(ardAppPosition.getAltitude());
                    if (lastAlarmId == null) {
                        String uuid = IdUtils.simpleUUID();
                        //    当前用户上一次状态未进入，生成报警
                        ardAlarmWall.setId(uuid);
                        ardAlarmWallService.insertArdAlarmWall(ardAlarmWall);
                        //更新最后报警id
                        userLastAlarm.put(userId, uuid);
                //当前用户的位置
                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 {
                        //    上一次用户状态已进入，更新最后报警
                        ardAlarmWall.setId(lastAlarmId);
                        ardAlarmWallService.updateArdAlarmWall(ardAlarmWall);
                        //禁入围栏则若在围栏外则移除报警缓存
                        firstAlarmMap.remove(key);
                    }
                    ardAlarmWalls.add(ardAlarmWall);
                }
                else
                } else//禁出
                {
                    //移除最后报警id
                    userLastAlarm.remove(userId);
                    //判断当前用户位置是否在围栏外
                    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;
    }

    @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;
    }
}