app单兵端发起查看指挥端位置及车辆位置提交

zhangnaisong

2024-01-22 97f4a9b9621eca21da79df727121f5fac12cc42a

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

@@ -1,5 +1,6 @@
package com.ruoyi.app.position.service.impl;

import com.alibaba.fastjson2.JSON;
import com.ruoyi.alarm.wall.domain.ArdAlarmWall;
import com.ruoyi.alarm.wall.mapper.ArdAlarmWallMapper;
import com.ruoyi.alarm.wall.service.IArdAlarmWallService;
@@ -14,6 +15,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;
@@ -24,6 +26,8 @@
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

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


/**
@@ -45,6 +49,8 @@
    ArdWallMapper ardWallMapper;
    @Resource
    IArdAlarmWallService ardAlarmWallService;
    @Resource
    private SysUserMapper sysUserMapper;

    Map<String, String> firstAlarmMap = new HashMap<>();//首次报警缓存key:用户id_围栏id value: 报警id
    /**
@@ -238,12 +244,8 @@
        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) {
@@ -325,4 +327,53 @@
        }
        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 void sendCheckCommandersPosition(String usersId,Map<String, Object> para) {
        String reason = (String) para.get("reason");
        List<String> usersIdList = (List<String>) para.get("usersIdList");
        for(String commanderId : usersIdList){
            //设置key为checkCommanderPosition_指挥端主键_单兵端主键
            String key = "checkCommanderPosition_" + commanderId + "_" + usersId;
            Map<String,Object> value = new HashMap();
            value.put("reason",reason);
            value.put("state","0");
            value.put("begin","");
            redisCache.setCacheObject(key, JSON.toJSONString(value));
        }
    }

    @Override
    public void sendCheckSYCarsPosition(String usersId, Map<String, Object> para) {
        String reason = (String) para.get("reason");
        List<String> usersIdList = (List<String>) para.get("usersIdList");
        for(String commanderId : usersIdList){
            //设置key为checkCommanderPosition_指挥端主键/PC端主键_单兵端主键
            String key = "checkSYCarsPosition_" + commanderId + "_" + usersId;
            Map<String,Object> value = new HashMap();
            value.put("reason",reason);
            value.put("state","0");
            value.put("begin","");
            redisCache.setCacheObject(key, JSON.toJSONString(value));
        }
    }
}