| | |
| | | if(result != null){ |
| | | alarmMap.putAll(result); |
| | | } |
| | | Map<Integer,Object> data = new HashMap(); |
| | | data.put(40000, alarmMap); |
| | | Map<String,Object> data = new HashMap(); |
| | | data.put("40000", alarmMap); |
| | | ((ArdSyCarServiceImpl) SpringUtils.getBean("ardSyCarServiceImpl")).sendArdSyCarAlarmByCarId(carId,data);//查询车辆及部门 |
| | | }else if("0401".equals(pushMsg.getCmd())) {//透传消息 |
| | | Map<String,Object> dataMap = pushMsg.getJsonMap(); |
| | |
| | | /** |
| | | * 根据部门发送车辆实时报警 |
| | | */ |
| | | public void sendArdSyCarAlarmByCarId(String carId, Map<Integer,Object> data); |
| | | public void sendArdSyCarAlarmByCarId(String carId, Map<String,Object> data); |
| | | // List<ArdSyCar> getArdSyCarWithRightByCarIdList(List<String> carIdList); |
| | | |
| | | /** |
| | |
| | | String deptId = String.valueOf(sysUser.getDeptId()); |
| | | Map<String,Map<String,Object>> map = PositionContainer.getDeptPositionMap().get(deptId); |
| | | if(map != null){ |
| | | Map<Integer,Object> data = new HashMap(); |
| | | data.put(30000, map.values()); |
| | | Map<String,Object> data = new HashMap(); |
| | | data.put("30000", map.values()); |
| | | WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(key), JSON.toJSONString(data)); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | public void sendArdSyCarAlarmByCarId(String carId, Map<Integer,Object> data) { |
| | | public void sendArdSyCarAlarmByCarId(String carId, Map<String,Object> data) { |
| | | List<SysUser> result = userMapper.getSysUserByCarId(carId); |
| | | for(SysUser sysUser : result){ |
| | | WebSocketUtils.sendMessage(ONLINE_USER_SESSIONS.get(sysUser.getUserId()), JSON.toJSONString(data)); |