package com.ruoyi.alarm.global.service.impl; import com.alibaba.fastjson2.JSONObject; import com.ruoyi.alarm.access.domain.ArdAlarmAccess; import com.ruoyi.alarm.access.mapper.ArdAlarmAccessMapper; import com.ruoyi.alarm.apponekey.domain.ArdAlarmApponekey; import com.ruoyi.alarm.apponekey.mapper.ArdAlarmApponekeyMapper; import com.ruoyi.alarm.camera.domain.ArdAlarmCamera; import com.ruoyi.alarm.camera.mapper.ArdAlarmCameraMapper; import com.ruoyi.alarm.external.domain.ArdAlarmExternal; import com.ruoyi.alarm.external.mapper.ArdAlarmExternalMapper; import com.ruoyi.alarm.global.domain.GlobalAlarmCondition; import com.ruoyi.alarm.global.domain.GlobalAlarmData; import com.ruoyi.alarm.global.domain.GuidePriorityQueue; import com.ruoyi.alarm.global.domain.GuideTask; import com.ruoyi.alarm.global.service.IGlobalAlarmService; import com.ruoyi.alarm.radar.domain.ArdAlarmRadar; import com.ruoyi.alarm.radar.domain.RadarAlarmData; import com.ruoyi.alarm.radar.mapper.ArdAlarmRadarMapper; import com.ruoyi.alarm.steal.domain.ArdAlarmStealelec; import com.ruoyi.alarm.steal.mapper.ArdAlarmStealelecMapper; import com.ruoyi.alarm.tube.domain.ArdAlarmTube; import com.ruoyi.alarm.tube.mapper.ArdAlarmTubeMapper; import com.ruoyi.alarmpoints.tube.domain.ArdTubes; import com.ruoyi.alarmpoints.tube.domain.ArdTubesDetails; import com.ruoyi.alarmpoints.tube.mapper.ArdTubesDetailsMapper; import com.ruoyi.alarmpoints.tube.mapper.ArdTubesMapper; import com.ruoyi.alarmpoints.well.domain.ArdAlarmpointsWell; import com.ruoyi.alarmpoints.well.mapper.ArdAlarmpointsWellMapper; import com.ruoyi.common.constant.CacheConstants; import com.ruoyi.common.core.redis.RedisCache; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.constant.CamPriority; import com.ruoyi.device.external.domain.ArdEquipExternal; import com.ruoyi.device.external.mapper.ArdEquipExternalMapper; import com.ruoyi.utils.tools.ArdTool; import com.ruoyi.utils.tools.GisTool; import com.ruoyi.common.utils.uuid.IdUtils; import com.ruoyi.device.camera.domain.ArdCameras; import com.ruoyi.device.camera.mapper.ArdCamerasMapper; import com.ruoyi.system.service.ISysConfigService; import com.ruoyi.utils.tube.GeoPoint; import com.ruoyi.utils.tube.TubeTools; import lombok.AllArgsConstructor; import lombok.Data; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.PriorityBlockingQueue; import java.util.stream.Collectors; /** * @Description: 全局报警业务 * @ClassName: globalAlarmServiceImpl * @Author: Administrator * @Date: 2023年03月10日 11:03 * @Version: 1.0 **/ @Service @Slf4j(topic = "mqtt") public class GlobalAlarmServiceImpl implements IGlobalAlarmService { //region 依赖注入 @Resource private ArdAlarmApponekeyMapper ardAlarmApponekeyMapper; @Resource private ArdEquipExternalMapper ardEquipExternalMapper; @Resource private ArdAlarmAccessMapper ardAlarmAccessMapper; @Resource private ArdAlarmExternalMapper ardAlarmExternalMapper; @Resource private ArdAlarmRadarMapper ardAlarmRadarMapper; @Resource private ArdAlarmStealelecMapper ardAlarmStealelecMapper; @Resource private ArdAlarmTubeMapper ardAlarmTubeMapper; @Resource private ArdAlarmCameraMapper ardAlarmCameraMapper; @Resource private ArdTubesMapper ardTubesMapper; @Resource private ArdAlarmpointsWellMapper ardAlarmpointsWellMapper; @Resource private ArdTubesDetailsMapper ardTubesDetailsMapper; @Resource private ISysConfigService configService; @Resource private ArdCamerasMapper ardCamerasMapper; @Resource private RedisCache redisCache; @Resource private QueueManager queueManager; //endregion /** * @描述 查询所有报警的当前数量 * @参数 [] * @返回值 java.util.Map * @创建人 刘苏义 * @创建时间 2023/6/13 16:30 * @修改人和其它信息 */ @Override public Map selectAlarmLogsCount() { Map map = new HashMap<>(); Map countMap = new HashMap<>(); String refreshTime = configService.selectConfigByKey("refreshTime"); int count1001 = ardAlarmStealelecMapper.selectCountByStartTime(refreshTime); countMap.put("1001", count1001); int count1002 = ardAlarmCameraMapper.selectCountByAlarmTime(refreshTime); countMap.put("1002", count1002); int count1003 = ardAlarmRadarMapper.selectCountByAlarmTime(refreshTime, "运动目标检测"); countMap.put("1003", count1003); int count1004 = ardAlarmRadarMapper.selectCountByAlarmTime(refreshTime, "热源检测"); countMap.put("1004", count1004); int count1007 = ardAlarmRadarMapper.selectCountByAlarmTime(refreshTime, "雷达抽油机停机"); countMap.put("1007", count1007); int count1005 = ardAlarmExternalMapper.selectCountByAlarmTime(refreshTime, "防区报警"); countMap.put("1005", count1005); int count1006 = ardAlarmAccessMapper.selectCountByAlarmTime(refreshTime); countMap.put("1006", count1006); int count1009 = ardAlarmApponekeyMapper.selectCountByAlarmTime(refreshTime); countMap.put("1009", count1009); int count1014 = ardAlarmTubeMapper.selectCountByAlarmTime(refreshTime); countMap.put("1014", count1014); map.put("20000", countMap); return map; } /** * @描述 按条件查询报警 * @参数 [condition] * @返回值 java.util.List * @创建人 刘苏义 * @创建时间 2023/6/15 15:48 * @修改人和其它信息 */ @Override public List selectAlarmLogs(GlobalAlarmCondition condition) { String refreshTime = configService.selectConfigByKey("refreshTime"); switch (condition.getCommand()) { case 1001: List ardAlarmStealelecs = ardAlarmStealelecMapper.selectListAllByCommand(refreshTime); return ardAlarmStealelecs.stream() .map(ardAlarmStealelec -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmStealelec.getId()) .setName(ardAlarmStealelec.getDescribe()) .setAlarmTime(ardAlarmStealelec.getStartTime()) .setLongitude(ardAlarmStealelec.getLongitude()) .setLatitude(ardAlarmStealelec.getLatitude()) .setAltitude(ardAlarmStealelec.getAltitude()) .setCount(ardAlarmStealelec.getCount()) .setTotal(ardAlarmStealelec.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1002: List ardAlarmCameras = ardAlarmCameraMapper.selectListAllByCommand(refreshTime); return ardAlarmCameras.stream() .map(ardAlarmCamera -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmCamera.getId()) .setName(ardAlarmCamera.getCameraName()) .setAlarmTime(ardAlarmCamera.getAlarmTime()) .setLongitude(ardAlarmCamera.getLongitude()) .setLatitude(ardAlarmCamera.getLatitude()) .setCount(ardAlarmCamera.getCount()) .setTotal(ardAlarmCamera.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1003: List ardAlarmRadars = ardAlarmRadarMapper.selectListAllByCommand(refreshTime, "运动目标检测"); return ardAlarmRadars.stream() .map(ardAlarmRadar -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadar.getId()) .setName(ardAlarmRadar.getName()) .setAlarmTime(ardAlarmRadar.getAlarmTime()) .setLongitude(ardAlarmRadar.getLongitude()) .setLatitude(ardAlarmRadar.getLatitude()) .setCount(ardAlarmRadar.getCount()) .setTotal(ardAlarmRadar.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1004: ardAlarmRadars = ardAlarmRadarMapper.selectListAllByCommand(refreshTime, "热源检测"); return ardAlarmRadars.stream() .map(ardAlarmRadar -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadar.getId()) .setName(ardAlarmRadar.getName()) .setAlarmTime(ardAlarmRadar.getAlarmTime()) .setLongitude(ardAlarmRadar.getLongitude()) .setLatitude(ardAlarmRadar.getLatitude()) .setCount(ardAlarmRadar.getCount()) .setTotal(ardAlarmRadar.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1005: List ardAlarmExternals = ardAlarmExternalMapper.selectListAllByCommand(refreshTime, "防区报警"); return ardAlarmExternals.stream() .map(ardAlarmExternal -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmExternal.getId()) .setName(ardAlarmExternal.getAlarmName()) .setAlarmTime(ardAlarmExternal.getAlarmTime()) .setLongitude(ardAlarmExternal.getLongitude()) .setLatitude(ardAlarmExternal.getLatitude()) .setCount(ardAlarmExternal.getCount()) .setTotal(ardAlarmExternal.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1006: List ardAlarmAccesses = ardAlarmAccessMapper.selectListAllByCommand(refreshTime); return ardAlarmAccesses.stream() .map(ardAlarmAccess -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmAccess.getId()) .setName(ardAlarmAccess.getAcsName()) .setAlarmTime(ardAlarmAccess.getAlarmTime()) .setLongitude(ardAlarmAccess.getLongitude()) .setLatitude(ardAlarmAccess.getLatitude()) .setCount(ardAlarmAccess.getCount()) .setTotal(ardAlarmAccess.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1007: ardAlarmRadars = ardAlarmRadarMapper.selectListAllByCommand(refreshTime, "雷达抽油机停机"); return ardAlarmRadars.stream() .map(ardAlarmRadar -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadar.getId()) .setName(ardAlarmRadar.getName()) .setAlarmTime(ardAlarmRadar.getAlarmTime()) .setLongitude(ardAlarmRadar.getLongitude()) .setLatitude(ardAlarmRadar.getLatitude()) .setCount(ardAlarmRadar.getCount()) .setTotal(ardAlarmRadar.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1009: List ardAlarmApponekeys = ardAlarmApponekeyMapper.selectListAllByCommand(refreshTime); return ardAlarmApponekeys.stream() .map(ardAlarmApponekey -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmApponekey.getId()) .setName(ardAlarmApponekey.getName()) .setAlarmTime(ardAlarmApponekey.getCreateTime()) .setLongitude(ardAlarmApponekey.getLongitude()) .setLatitude(ardAlarmApponekey.getLatitude()) .setCount(ardAlarmApponekey.getCount()) .setTotal(ardAlarmApponekey.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1014: List ardAlarmTubes = ardAlarmTubeMapper.selectListAllByCommand(refreshTime); return ardAlarmTubes.stream() .map(ardAlarmTube -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmTube.getId()) .setName(ardAlarmTube.getTubeName()) .setAlarmTime(ardAlarmTube.getAlarmTime()) .setLongitude(ardAlarmTube.getLongitude()) .setLatitude(ardAlarmTube.getLatitude()) .setAltitude(ardAlarmTube.getAltitude()) .setCount(ardAlarmTube.getCount()) .setTotal(ardAlarmTube.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); default: return null; } } /** * @描述 历史报警查询 * @参数 [command, beginTime, endTime, pageNum, pageSize] * @返回值 java.lang.Object * @创建人 刘苏义 * @创建时间 2023/6/28 13:30 * @修改人和其它信息 */ @Override public Object selectAlarmList(Integer command, String beginTime, String endTime, Integer pageNum, Integer pageSize) { Map params = new HashMap<>(); params.put("beginTime", beginTime); params.put("endTime", endTime); switch (command) { case 1001: ArdAlarmStealelec aas = new ArdAlarmStealelec(); aas.setParams(params); aas.setPageNum(pageNum); aas.setPageSize(pageSize); return ardAlarmStealelecMapper.selectArdAlarmStealelecList(aas); case 1002: ArdAlarmCamera aac = new ArdAlarmCamera(); aac.setParams(params); aac.setPageNum(pageNum); aac.setPageSize(pageSize); return ardAlarmCameraMapper.selectArdAlarmCameraList(aac); case 1003: ArdAlarmRadar aar = new ArdAlarmRadar(); aar.setParams(params); aar.setPageNum(pageNum); aar.setPageSize(pageSize); aar.setAlarmType("运动目标检测"); return ardAlarmRadarMapper.selectArdAlarmRadarList(aar); case 1004: ArdAlarmRadar aarr = new ArdAlarmRadar(); aarr.setParams(params); aarr.setPageNum(pageNum); aarr.setPageSize(pageSize); aarr.setAlarmType("热源检测"); return ardAlarmRadarMapper.selectArdAlarmRadarList(aarr); case 1007: ArdAlarmRadar aarrr = new ArdAlarmRadar(); aarrr.setParams(params); aarrr.setPageNum(pageNum); aarrr.setPageSize(pageSize); aarrr.setAlarmType("雷达抽油机停机"); return ardAlarmRadarMapper.selectArdAlarmRadarList(aarrr); case 1005: ArdAlarmExternal aae = new ArdAlarmExternal(); aae.setParams(params); aae.setPageNum(pageNum); aae.setPageSize(pageSize); aae.setAlarmType("防区报警"); return ardAlarmExternalMapper.selectArdAlarmExternalList(aae); case 1006: ArdAlarmAccess aaa = new ArdAlarmAccess(); aaa.setParams(params); aaa.setPageNum(pageNum); aaa.setPageSize(pageSize); aaa.setAlarmType("防区报警"); return ardAlarmAccessMapper.selectArdAlarmAccessList(aaa); case 1009: ArdAlarmApponekey aaak = new ArdAlarmApponekey(); aaak.setParams(params); aaak.setPageNum(pageNum); aaak.setPageSize(pageSize); return ardAlarmApponekeyMapper.selectArdAlarmApponekeyList(aaak); case 1014: ArdAlarmTube aat = new ArdAlarmTube(); aat.setParams(params); aat.setPageNum(pageNum); aat.setPageSize(pageSize); return ardAlarmTubeMapper.selectArdAlarmTubeList(aat); } return null; } /** * @描述 按条件更新查看时间 * @参数 [condition] * @返回值 java.lang.Object * @创建人 刘苏义 * @创建时间 2023/6/15 15:48 * @修改人和其它信息 */ @Override public Object updateAlarmViewTime(GlobalAlarmCondition condition) { SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); switch (condition.getCommand()) { case 1001: ArdAlarmStealelec ardAlarmStealelec = ardAlarmStealelecMapper.selectByPrimaryKey(condition.getId()); if (StringUtils.isNotNull(ardAlarmStealelec)) { String describe = ardAlarmStealelec.getDescribe(); String startTime = fmt.format(ardAlarmStealelec.getStartTime()); ardAlarmStealelecMapper.updateViewTimeByDescribe(describe, startTime, DateUtils.getTime()); return ardAlarmStealelec; } case 1002: ArdAlarmCamera ardAlarmCamera = ardAlarmCameraMapper.selectArdAlarmCameraById(condition.getId()); if (StringUtils.isNotNull(ardAlarmCamera)) { String cameraName = ardAlarmCamera.getCameraName(); String alarmTime = fmt.format(ardAlarmCamera.getAlarmTime()); ardAlarmCameraMapper.updateViewTimeByCameraName(cameraName, alarmTime, DateUtils.getTime()); return ardAlarmCamera; } case 1003: case 1004: case 1007: ArdAlarmRadar ardAlarmRadar = ardAlarmRadarMapper.selectArdAlarmRadarById(condition.getId()); if (StringUtils.isNotNull(ardAlarmRadar)) { String name = ardAlarmRadar.getName(); String alarmType = ardAlarmRadar.getAlarmType(); String alarmTime = fmt.format(ardAlarmRadar.getAlarmTime()); ardAlarmRadarMapper.updateViewTimeByCondition(name, alarmType, alarmTime, DateUtils.getTime()); return ardAlarmRadar; } case 1005: ArdAlarmExternal ardAlarmExternal = ardAlarmExternalMapper.selectArdAlarmExternalById(condition.getId()); if (StringUtils.isNotNull(ardAlarmExternal)) { String defenseName = ardAlarmExternal.getDefenseName(); String alarmType = ardAlarmExternal.getAlarmType(); String alarmTime = fmt.format(ardAlarmExternal.getAlarmTime()); ardAlarmExternalMapper.updateViewTimeByCondition(defenseName, alarmType, alarmTime, DateUtils.getTime()); return ardAlarmExternal; } case 1006: ArdAlarmAccess ardAlarmAccess = ardAlarmAccessMapper.selectArdAlarmAccessById(condition.getId()); if (StringUtils.isNotNull(ardAlarmAccess)) { String acsId = ardAlarmAccess.getAcsId(); String alarmTime = fmt.format(ardAlarmAccess.getAlarmTime()); ardAlarmAccessMapper.updateViewTimeByAcsId(acsId, alarmTime, DateUtils.getTime()); return ardAlarmAccess; } case 1009: ArdAlarmApponekey ardAlarmApponekey = ardAlarmApponekeyMapper.selectArdAlarmApponekeyById(condition.getId()); if (StringUtils.isNotNull(ardAlarmApponekey)) { String userId = ardAlarmApponekey.getUserId(); String alarmTime = fmt.format(ardAlarmApponekey.getCreateTime()); ardAlarmApponekeyMapper.updateViewTimeByUserId(userId, alarmTime, DateUtils.getTime()); return ardAlarmApponekey; } case 1014: ArdAlarmTube ardAlarmTube = ardAlarmTubeMapper.selectArdAlarmTubeById(condition.getId()); if (StringUtils.isNotNull(ardAlarmTube)) { String tubeId = ardAlarmTube.getTubeId(); String alarmTime = fmt.format(ardAlarmTube.getAlarmTime()); ardAlarmTubeMapper.updateViewTimeByTubeId(tubeId, alarmTime, DateUtils.getTime()); return ardAlarmTube; } default: return null; } } /** * @描述 异步处理接收的报警 * @参数 [topic, message] * @返回值 void * @创建人 刘苏义 * @创建时间 2023/6/15 15:46 * @修改人和其它信息 */ @Override @Async("alarmExecutor") public void receiveAlarm(String topic, String message) { try { switch (topic) { case "stealelec": //region 处理盗电报警 ArdAlarmStealelec ardAlarmStealelec = JSONObject.parseObject(message, ArdAlarmStealelec.class); ArdAlarmStealelec isExiste = ardAlarmStealelecMapper.selectByPrimaryKey(ardAlarmStealelec.getId()); if (StringUtils.isNull(isExiste)) { int aas = ardAlarmStealelecMapper.insertArdAlarmStealelec(ardAlarmStealelec); if (aas > 0) { log.info("stealelec入库成功：" + ardAlarmStealelec); } } //endregion break; case "tube": //region 处理管线泄露报警 ArdAlarmTube ardAlarmTube = JSONObject.parseObject(message, ArdAlarmTube.class); ardAlarmTube.setId(IdUtils.simpleUUID()); ArdTubesDetails atd = new ArdTubesDetails(); atd.setReelNumber(ardAlarmTube.getTubeId()); List ardTubesDetails = ardTubesDetailsMapper.selectArdTubesDetailsList(atd); if (ardTubesDetails.size() > 0) { String tubeId = ardTubesDetails.get(0).getTubeId(); ArdTubes ardTubes = ardTubesMapper.selectArdTubesById(tubeId); ardAlarmTube.setTubeName(ardTubes.getName()); ardAlarmTube.setColor(ardTubes.getColor()); ardAlarmTube.setPipeDiameter(ardTubes.getPipeDiameter()); ardAlarmTube.setTubeType(ardTubes.getType()); ardAlarmTube.setCreateTime(new Date()); GeoPoint geoPoint = TubeTools.CalculateCoordinates(ardTubesDetails, ardAlarmTube.getPosition()); if (StringUtils.isNotNull(geoPoint)) { ardAlarmTube.setLongitude(geoPoint.getLongitude()); ardAlarmTube.setLatitude(geoPoint.getLatitude()); ardAlarmTube.setAltitude(geoPoint.getAltitude()); } } int aat = ardAlarmTubeMapper.insertArdAlarmTube(ardAlarmTube); if (aat > 0) { log.debug("tube入库成功：" + ardAlarmTube); //region 引导录像 Double longitude = ardAlarmTube.getLongitude(); Double latitude = ardAlarmTube.getLatitude(); if (StringUtils.isNull(longitude) || StringUtils.isNull(latitude)) { return; } double[] coordinate = new double[]{longitude, latitude}; String nearbyCameraId = getNearbyCamera(new double[]{ardAlarmTube.getLongitude(), ardAlarmTube.getLatitude()}); if (StringUtils.isNotEmpty(nearbyCameraId)) { messagesEnqueued(nearbyCameraId, ardAlarmTube.getId(), "sys_tube_leak", ardAlarmTube.getCreateTime(), 1, 1, coordinate); } //endregion } //endregion break; case "camera": //region 处理通用光电报警 ArdAlarmCamera ardAlarmCamera = JSONObject.parseObject(message, ArdAlarmCamera.class); ardAlarmCamera.setId(IdUtils.simpleUUID()); int aac = ardAlarmCameraMapper.insertArdAlarmCamera(ardAlarmCamera); if (aac > 0) { log.debug("camera入库成功：" + ardAlarmCamera); } //endregion break; case "radar": //region 处理雷达报警 // 开始时间 long stime = System.currentTimeMillis(); RadarAlarmData radarAlarmData = JSONObject.parseObject(message, RadarAlarmData.class); List ardAlarmRadars = radarAlarmData.getArdAlarmRadars(); for (ArdAlarmRadar ardAlarmRadar : ardAlarmRadars) { String uuid = IdUtils.simpleUUID(); ardAlarmRadar.setId(uuid);//报警ID ardAlarmRadar.setAlarmTime(radarAlarmData.getAlarmTime());//报警时间 String alarmpointName = ardAlarmRadar.getName();//兴趣点名称 ardAlarmRadar.setName(ardAlarmRadar.getName() + "(" + radarAlarmData.getRadarName() + ")");//报警点名称 ardAlarmRadar.setCreateTime(new Date());//接收时间 String alarmType = ""; switch (ardAlarmRadar.getAlarmType()) { case "运动目标检测": alarmType = "sys_radar_move"; break; case "热源检测": alarmType = "sys_radar_fire"; break; case "雷达抽油机停机": alarmType = "sys_radar_pumpshutdown"; ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); if (StringUtils.isNotNull(ardAlarmpointsWell)) { ardAlarmRadar.setLongitude(ardAlarmpointsWell.getLongitude()); ardAlarmRadar.setLatitude(ardAlarmpointsWell.getLatitude()); } break; } if (StringUtils.isNull(ardAlarmRadar.getLongitude()) || StringUtils.isNull(ardAlarmRadar.getLatitude())) { continue; } double[] coordinate = new double[]{ardAlarmRadar.getLongitude(), ardAlarmRadar.getLatitude()};//报警坐标 //判断当前报警点5分钟内是否已引导 ardAlarmRadar.setGuideFlag(1); // ArdAlarmRadar AlarmRadar = ardAlarmRadarMapper.getArdAlarmRadarWithGuide(ardAlarmRadar); ArdAlarmRadar AlarmRadar = redisCache.getCacheObject("global_alarm:guideNew");//从redis中取出最新引导的报警数据 if (StringUtils.isNull(AlarmRadar)) { //5分钟内未引导直接入库 ardAlarmRadarMapper.insertArdAlarmRadar(ardAlarmRadar); redisCache.setCacheObject("global_alarm:guideNew",ardAlarmRadar);//引导数据写入redis //获取雷达所在塔上的大光电 String cameraIdWithTower = ardAlarmRadarMapper.getCameraByRadar(radarAlarmData.getRadarId()); if (StringUtils.isNotNull(cameraIdWithTower) && StringUtils.isNotEmpty(cameraIdWithTower)) { log.info("获取到雷达塔上的光电:" + cameraIdWithTower); //如果雷达塔上有光电 messagesEnqueued(cameraIdWithTower, uuid, alarmType, ardAlarmRadar.getCreateTime(), 1, 1, coordinate); } //获取报警点关联的大光电 ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); if (StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId())) { String cameraId = ardAlarmpointsWell.getCameraId(); if (cameraId.equals(cameraIdWithTower)) { return; } log.info("获取到报警点关联的光电:" + cameraId); //如果报警点关联了光电 messagesEnqueued(cameraId, uuid, alarmType, ardAlarmRadar.getCreateTime(), 1, 2, coordinate); } } else { //5分钟内有引导 ardAlarmRadar.setGuideFlag(0); int count = ardAlarmRadarMapper.getArdAlarmRadarWithNotGuide(ardAlarmRadar, AlarmRadar.getCreateTime()); //未引导超过3次，直接入库入队 if (count >= 3) { ardAlarmRadar.setGuideFlag(1); ardAlarmRadarMapper.insertArdAlarmRadar(ardAlarmRadar); redisCache.setCacheObject("global_alarm:guideNew",ardAlarmRadar);//引导数据写入redis //获取雷达所在塔上的大光电 String cameraIdWithTower = ardAlarmRadarMapper.getCameraByRadar(radarAlarmData.getRadarId()); if (StringUtils.isNotNull(cameraIdWithTower) && StringUtils.isNotEmpty(cameraIdWithTower)) { log.info("获取到雷达塔上的光电:" + cameraIdWithTower); //如果雷达塔上有光电 messagesEnqueued(cameraIdWithTower, uuid, alarmType, ardAlarmRadar.getCreateTime(), count, 1, coordinate); } //获取报警点关联的大光电 ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); if (StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId())) { String cameraId = ardAlarmpointsWell.getCameraId(); if (cameraId.equals(cameraIdWithTower)) { return; } log.info("获取到报警点关联的光电:" + cameraId); //如果报警点关联了光电 messagesEnqueued(cameraId, uuid, alarmType, ardAlarmRadar.getCreateTime(), count, 2, coordinate); } } else { //未引导未超过3次，直接入库 ardAlarmRadarMapper.insertArdAlarmRadar(ardAlarmRadar); } } // 结束时间 long etime = System.currentTimeMillis(); // 计算执行时间 log.info("查询API执行时长："+(etime-stime)+"毫秒"); } //endregion break; case "external": //region 处理外联报警 ArdAlarmExternal ardAlarmExternal = JSONObject.parseObject(message, ArdAlarmExternal.class); ardAlarmExternal.setId(IdUtils.simpleUUID()); ardAlarmExternal.setCreateTime(new Date());//接收时间 //外联防区名称就是兴趣点，查兴趣点坐标 String defenseName = ardAlarmExternal.getDefenseName(); ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(defenseName); if (StringUtils.isNotNull(ardAlarmpointsWell)) { ardAlarmExternal.setLongitude(ardAlarmpointsWell.getLongitude()); ardAlarmExternal.setLatitude(ardAlarmpointsWell.getLatitude()); } int aae = ardAlarmExternalMapper.insertArdAlarmExternal(ardAlarmExternal); if (aae > 0) { log.debug("external入库成功：" + ardAlarmExternal); //region 引导录像 if (StringUtils.isNull(ardAlarmExternal.getLongitude()) || StringUtils.isNull(ardAlarmExternal.getLatitude())) { return; } double[] guideCoordinate = new double[]{ardAlarmExternal.getLongitude(), ardAlarmExternal.getLatitude()};//引导坐标 String nearbyCameraId = getNearbyCamera(guideCoordinate);//最近相机ID if (StringUtils.isNotEmpty(nearbyCameraId)) { messagesEnqueued(nearbyCameraId, ardAlarmExternal.getId(), "sys_external", ardAlarmExternal.getCreateTime(), 1, 1, guideCoordinate); } //endregion } //endregion break; case "accessControl": //region 处理门禁报警 ArdAlarmAccess ardAlarmAccess = JSONObject.parseObject(message, ArdAlarmAccess.class); ardAlarmAccess.setId(IdUtils.simpleUUID()); ardAlarmAccess.setCreateTime(new Date());//接收时间 //查管理的门禁主机信息 String acsId = ardAlarmAccess.getAcsId(); ArdEquipExternal ardEquipExternal = ardEquipExternalMapper.selectArdEquipExternalById(acsId); if (StringUtils.isNotNull(ardEquipExternal)) { ardAlarmAccess.setLongitude(ardEquipExternal.getLongitude()); ardAlarmAccess.setLatitude(ardEquipExternal.getLatitude()); ardAlarmAccess.setAltitude(ardEquipExternal.getAltitude()); ardAlarmAccess.setAcsId(ardEquipExternal.getId()); ardAlarmAccess.setAcsName(ardEquipExternal.getName()); } int aaa = ardAlarmAccessMapper.insertArdAlarmAccess(ardAlarmAccess); if (aaa > 0) { log.debug("external入库成功：" + ardAlarmAccess); //region 引导录像 if (StringUtils.isNull(ardAlarmAccess.getLongitude()) || StringUtils.isNull(ardAlarmAccess.getLatitude())) { return; } double[] guideCoordinate = new double[]{ardAlarmAccess.getLongitude(), ardAlarmAccess.getLatitude()};//引导坐标 String nearbyCameraId = getNearbyCamera(guideCoordinate);//最近相机ID if (StringUtils.isNotEmpty(nearbyCameraId)) { messagesEnqueued(nearbyCameraId, ardAlarmAccess.getId(), "sys_access_control", ardAlarmAccess.getCreateTime(), 1, 1, guideCoordinate); } //endregion } //endregion break; case "apponekey": //region app一键报警 ArdAlarmApponekey ardAlarmApponekey = JSONObject.parseObject(message, ArdAlarmApponekey.class); int aaak = ardAlarmApponekeyMapper.insertArdAlarmApponekey(ardAlarmApponekey); if (aaak > 0) { log.debug("apponekey入库成功：" + ardAlarmApponekey); } //endregion break; } } catch (Exception ex) { log.error("接收报警异常:" + ex.getMessage()); } } /** * 消息入队 *

* cameraId 相机ID * alarmId 报警ID * alarmType 报警类型 * num 报警次数 * recordSn 录像存储位置 1-recordUrl1 2-recordUrl2 * targetPosition 报警点位置坐标 */ private void messagesEnqueued(String cameraId, String alarmId, String alarmType, Date receiveTime, Integer num, Integer recordSn, double[] targetPosition) { try { if (!IsEnableGuide(cameraId)) { log.info("相机:" + cameraId + "未开启报警引导功能"); return; } SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); GuideTask guideTask = new GuideTask(); //相机ID guideTask.setCameraId(cameraId); //报警类型 guideTask.setAlarmType(alarmType); //通道(通过日夜时间研判) String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime"); Integer channel = ArdTool.getChannelBydayNightTime(dayNightTime); guideTask.setChanNum(channel); //报警ID guideTask.setAlarmId(alarmId); //接收时间 guideTask.setReceiveTime(fmt.format(receiveTime)); //报警优先级(通过优先级字典) Integer priority = CamPriority.priorityMap.get(alarmType); guideTask.setPriority(priority); //报警次数 guideTask.setNum(num); //录像存储位置 guideTask.setRecordSn(recordSn); //目标经纬度 guideTask.setTargetPosition(targetPosition); //消息入队 queueManager.addTaskToQueue(cameraId, guideTask); //打印队列 GuidePriorityQueue.printPriorityQueue(); } catch (Exception ex) { log.error("报警入队异常:" + ex.getMessage()); } } /** * 光电是否开启报警引导功能 * 刘苏义 * 2023/7/7 14:03 */ private Boolean IsEnableGuide(String cameraId) { boolean enabled = false; ArdCameras ardCameras = redisCache.getCacheObject(CacheConstants.CAMERA_LIST_KEY + cameraId); if(ardCameras!=null) { if (ardCameras.getCamAlarmGuideEnable().equals(1)) { enabled = true; } } return enabled; } /** * 获取附近开启报警引导功能光电 */ private String getNearbyCamera(double[] targetPosition) { String minDistanceCameraId = ""; //获取所有大光电 List ardCamerasList = ardCamerasMapper.selectArdCamerasList(new ArdCameras("1")); //统计所有大光电可视范围内与报警点的距离 Map distanceMap = new HashMap<>(); Map guideMap = new HashMap<>(); for (ArdCameras camera : ardCamerasList) { double[] camPosition = new double[]{camera.getLongitude(), camera.getLatitude()}; double distance = GisTool.getDistance(targetPosition, camPosition); if (distance != 0.0 && distance <= camera.getCamMaxVisibleDistance()) { distanceMap.put(camera.getId(), distance); if (StringUtils.isNull(camera.getCamAlarmGuideEnable())) { camera.setCamAlarmGuideEnable(0); } guideMap.put(camera.getId(), camera.getCamAlarmGuideEnable()); } } if (distanceMap.size() > 0) { log.debug("尝试查找最近光电"); //获取距离字典中最近的一个相机ID minDistanceCameraId = ArdTool.getKeyByMinValue(distanceMap); log.debug("查找到最近光电:" + minDistanceCameraId); if (guideMap.get(minDistanceCameraId).equals(0)) { log.debug("该光电未开启报警引导"); return " "; } } return minDistanceCameraId; } public static void main(String[] args) { Comparator PriorityDescCom = Comparator.comparingInt(Obj::getPriority).reversed(); Comparator NumDescCom = Comparator.comparingInt(Obj::getNum).reversed(); Comparator receiveTimeAscCom = Comparator.comparing(Obj::getAlarmTime); Comparator comparator = PriorityDescCom.thenComparing(NumDescCom).thenComparing(receiveTimeAscCom); PriorityBlockingQueue priorityQueue = new PriorityBlockingQueue<>(1000, comparator); priorityQueue.add(new Obj(999, 1, "2023-07-01 16:00:01")); priorityQueue.add(new Obj(999, 2, "2023-07-01 16:00:01")); priorityQueue.add(new Obj(999, 3, "2023-07-01 16:00:01")); List elements = new ArrayList<>(priorityQueue); elements.sort(priorityQueue.comparator()); // 使用队列的比较器进行排序 for (Obj task : elements) { log.info("正在排队【priority】" + task.getPriority() + "【num】" + task.getNum() + "【alarmTime】" + task.getAlarmTime()); } log.info("==================================================================="); priorityQueue.add(new Obj(999, 5, "2023-07-01 16:00:01")); PriorityBlockingQueue queue = new PriorityBlockingQueue<>(priorityQueue); while (queue.size() > 0) { Obj task = (Obj) queue.poll(); log.info("正在排队【priority】" + task.getPriority() + "【num】" + task.getNum() + "【alarmTime】" + task.getAlarmTime()); } } @Data @AllArgsConstructor static class Obj { Integer priority; Integer num; String alarmTime; } }