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.digitization3.domain.ArdAlarmDigitization3; import com.ruoyi.alarm.digitization3.mapper.ArdAlarmDigitization3Mapper; import com.ruoyi.alarm.external.domain.ArdAlarmExternal; import com.ruoyi.alarm.external.mapper.ArdAlarmExternalMapper; import com.ruoyi.alarm.global.domain.*; import com.ruoyi.alarm.global.service.IGlobalAlarmService; import com.ruoyi.alarm.radar.domain.*; import com.ruoyi.alarm.radar.mapper.ArdAlarmRadarFireMapper; import com.ruoyi.alarm.radar.mapper.ArdAlarmRadarMoveMapper; import com.ruoyi.alarm.radar.mapper.ArdAlarmRadarPumpMapper; import com.ruoyi.alarm.steal.domain.ArdAlarmStealelec; import com.ruoyi.alarm.steal.mapper.ArdAlarmStealelecMapper; import com.ruoyi.alarm.superbrain.domain.ArdAlarmSuperBrain; import com.ruoyi.alarm.superbrain.mapper.ArdAlarmSuperBrainMapper; import com.ruoyi.alarm.tube.domain.ArdAlarmTube; import com.ruoyi.alarm.tube.mapper.ArdAlarmTubeMapper; import com.ruoyi.alarm.wall.domain.ArdAlarmWall; import com.ruoyi.alarm.wall.mapper.ArdAlarmWallMapper; 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.ConfigUtils; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.DictUtils; import com.ruoyi.common.utils.StringUtils; import com.ruoyi.device.external.domain.ArdEquipExternal; import com.ruoyi.device.external.mapper.ArdEquipExternalMapper; import com.ruoyi.device.radar.mapper.ArdEquipRadarMapper; import com.ruoyi.utils.gis.GisUtil; import com.ruoyi.utils.tools.ArdTool; 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.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.stream.Collectors; /** * @Description: 全局报警业务 * @ClassName: globalAlarmServiceImpl * @Author: Administrator * @Date: 2023年03月10日 11:03 * @Version: 1.0 **/ @Service @Slf4j(topic = "alarm") public class GlobalAlarmServiceImpl implements IGlobalAlarmService { //region 依赖注入 @Resource private ArdAlarmSuperBrainMapper ardAlarmSuperBrainMapper; @Resource private ArdAlarmDigitization3Mapper ardAlarmDigitization3Mapper; @Resource private ArdAlarmWallMapper ardAlarmWallMapper; @Resource private ArdAlarmApponekeyMapper ardAlarmApponekeyMapper; @Resource private ArdEquipExternalMapper ardEquipExternalMapper; @Resource private ArdAlarmAccessMapper ardAlarmAccessMapper; @Resource private ArdAlarmExternalMapper ardAlarmExternalMapper; //@Resource //private ArdAlarmRadarMapper ardAlarmRadarMapper; @Resource private ArdAlarmRadarMoveMapper ardAlarmRadarMoveMapper; @Resource private ArdAlarmRadarFireMapper ardAlarmRadarFireMapper; @Resource private ArdAlarmRadarPumpMapper ardAlarmRadarPumpMapper; @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 QueueHandler queueHandler; @Resource private ArdEquipRadarMapper ardEquipRadarMapper; //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 = ardAlarmRadarMoveMapper.selectCountByAlarmTime(refreshTime); countMap.put("1003", count1003); int count1004 = ardAlarmRadarFireMapper.selectCountByAlarmTime(refreshTime); countMap.put("1004", count1004); int count1007 = ardAlarmRadarPumpMapper.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 count1010 = ardAlarmWallMapper.selectCountByAlarmTime(refreshTime); countMap.put("1010", count1010); int count1014 = ardAlarmTubeMapper.selectCountByAlarmTime(refreshTime); countMap.put("1014", count1014); int count1012 = ardAlarmDigitization3Mapper.selectCountByAlarmTime(refreshTime); countMap.put("1012", count1012); int count1015 = ardAlarmSuperBrainMapper.selectCountByAlarmTime(refreshTime); countMap.put("1015", count1015); 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 ardAlarmRadarMoves = ardAlarmRadarMoveMapper.selectListAllByCommand(refreshTime); return ardAlarmRadarMoves.stream() .map(ardAlarmRadarMove -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarMove.getId()) .setName(ardAlarmRadarMove.getName()) .setAlarmTime(ardAlarmRadarMove.getAlarmTime()) .setLongitude(ardAlarmRadarMove.getLongitude()) .setLatitude(ardAlarmRadarMove.getLatitude()) .setCount(ardAlarmRadarMove.getCount()) .setTotal(ardAlarmRadarMove.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1004: List ardAlarmRadarFires = ardAlarmRadarFireMapper.selectListAllByCommand(refreshTime); return ardAlarmRadarFires.stream() .map(ardAlarmRadarFire -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarFire.getId()) .setName(ardAlarmRadarFire.getName()) .setAlarmTime(ardAlarmRadarFire.getAlarmTime()) .setLongitude(ardAlarmRadarFire.getLongitude()) .setLatitude(ardAlarmRadarFire.getLatitude()) .setCount(ardAlarmRadarFire.getCount()) .setTotal(ardAlarmRadarFire.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: List ardAlarmRadarPumps = ardAlarmRadarPumpMapper.selectListAllByCommand(refreshTime); return ardAlarmRadarPumps.stream() .map(ardAlarmRadarPump -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarPump.getId()) .setName(ardAlarmRadarPump.getName()) .setAlarmTime(ardAlarmRadarPump.getAlarmTime()) .setLongitude(ardAlarmRadarPump.getLongitude()) .setLatitude(ardAlarmRadarPump.getLatitude()) .setCount(ardAlarmRadarPump.getCount()) .setTotal(ardAlarmRadarPump.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 1010: List ardAlarmWalls = ardAlarmWallMapper.selectListAllByCommand(refreshTime); return ardAlarmWalls.stream() .map(ardAlarmWall -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmWall.getId()) .setName(ardAlarmWall.getWallName()) .setAlarmTime(ardAlarmWall.getAlarmTime()) .setLongitude(ardAlarmWall.getLongitude()) .setLatitude(ardAlarmWall.getLatitude()) .setCount(ardAlarmWall.getCount()) .setTotal(ardAlarmWall.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1012: List ardAlarmDigitization3s = ardAlarmDigitization3Mapper.selectListAllByCommand(refreshTime); return ardAlarmDigitization3s.stream() .map(ardAlarmDigitization3 -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmDigitization3.getId()) .setName(ardAlarmDigitization3.getWellNo()) .setAlarmType(ardAlarmDigitization3.getAlarmType()) .setAlarmTime(ardAlarmDigitization3.getAlarmTime()) .setLongitude(ardAlarmDigitization3.getLongitude()) .setLatitude(ardAlarmDigitization3.getLatitude()) .setAltitude(ardAlarmDigitization3.getAltitude()) .setCount(ardAlarmDigitization3.getCount()) .setTotal(ardAlarmDigitization3.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()); case 1015: List ardAlarmSuperBrains = ardAlarmSuperBrainMapper.selectListAllByCommand(refreshTime); return ardAlarmSuperBrains.stream() .map(ardAlarmSuperBrain -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmSuperBrain.getId()) .setName(ardAlarmSuperBrain.getAlarmType()) .setAlarmType(ardAlarmSuperBrain.getAlarmType()) .setAlarmTime(ardAlarmSuperBrain.getAlarmTime()) .setLongitude(ardAlarmSuperBrain.getLongitude()) .setLatitude(ardAlarmSuperBrain.getLatitude()) .setAltitude(ardAlarmSuperBrain.getAltitude()) .setCount(ardAlarmSuperBrain.getCount()) .setTotal(ardAlarmSuperBrain.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); default: return null; } } /** * 获取热力图数据 * 刘苏义 * 2023/9/16 8:38:54 */ @Override public List selectThermalMap(GlobalAlarmCondition condition) { String refreshTime = condition.getRefreshTime(); 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: //从缓存获取数据 //String key = "radar_alarm:" + DateUtils.getDate(); //List ardAlarmRadarMoves = redisCache.getCacheList(key); //Map> groupedData = ardAlarmRadarMoves.stream() // .collect(Collectors.groupingBy(ArdAlarmRadarMove::getName)); //List globalAlarmDataList = new ArrayList<>(); //for (String name : groupedData.keySet()) { // List ardAlarmRadarMove = groupedData.get(name); // GlobalAlarmData globalAlarmData = new GlobalAlarmData() // .setId(ardAlarmRadarMove.get(0).getId()) // .setName(name) // .setAlarmTime(ardAlarmRadarMove.get(0).getAlarmTime()) // .setLongitude(ardAlarmRadarMove.get(0).getLongitude()) // .setLatitude(ardAlarmRadarMove.get(0).getLatitude()) // .setTotal(ardAlarmRadarMove.size()); // globalAlarmDataList.add(globalAlarmData); //} //return globalAlarmDataList; //从数据库获取 List ardAlarmRadarMoves = ardAlarmRadarMoveMapper.selectListAllByCommand(refreshTime); return ardAlarmRadarMoves.stream() .map(ardAlarmRadarMove -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarMove.getId()) .setName(ardAlarmRadarMove.getName()) .setAlarmTime(ardAlarmRadarMove.getAlarmTime()) .setLongitude(ardAlarmRadarMove.getLongitude()) .setLatitude(ardAlarmRadarMove.getLatitude()) .setCount(ardAlarmRadarMove.getCount()) .setTotal(ardAlarmRadarMove.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); case 1004: List ardAlarmRadarFires = ardAlarmRadarFireMapper.selectListAllByCommand(refreshTime); return ardAlarmRadarFires.stream() .map(ardAlarmRadarFire -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarFire.getId()) .setName(ardAlarmRadarFire.getName()) .setAlarmTime(ardAlarmRadarFire.getAlarmTime()) .setLongitude(ardAlarmRadarFire.getLongitude()) .setLatitude(ardAlarmRadarFire.getLatitude()) .setCount(ardAlarmRadarFire.getCount()) .setTotal(ardAlarmRadarFire.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: List ardAlarmRadarPumps = ardAlarmRadarPumpMapper.selectListAllByCommand(refreshTime); return ardAlarmRadarPumps.stream() .map(ardAlarmRadarPump -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarPump.getId()) .setName(ardAlarmRadarPump.getName()) .setAlarmTime(ardAlarmRadarPump.getAlarmTime()) .setLongitude(ardAlarmRadarPump.getLongitude()) .setLatitude(ardAlarmRadarPump.getLatitude()) .setCount(ardAlarmRadarPump.getCount()) .setTotal(ardAlarmRadarPump.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 1010: List ardAlarmWalls = ardAlarmWallMapper.selectListAllByCommand(refreshTime); return ardAlarmWalls.stream() .map(ardAlarmWall -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmWall.getId()) .setName(ardAlarmWall.getWallName()) .setAlarmTime(ardAlarmWall.getAlarmTime()) .setLongitude(ardAlarmWall.getLongitude()) .setLatitude(ardAlarmWall.getLatitude()) .setCount(ardAlarmWall.getCount()) .setTotal(ardAlarmWall.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()); case 1015: List ardAlarmSuperBrains = ardAlarmSuperBrainMapper.selectListAllByCommand(refreshTime); return ardAlarmSuperBrains.stream() .map(ardAlarmSuperBrain -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmSuperBrain.getId()) .setName(ardAlarmSuperBrain.getAlarmType()) .setAlarmType(ardAlarmSuperBrain.getAlarmType()) .setAlarmTime(ardAlarmSuperBrain.getAlarmTime()) .setLongitude(ardAlarmSuperBrain.getLongitude()) .setLatitude(ardAlarmSuperBrain.getLatitude()) .setAltitude(ardAlarmSuperBrain.getAltitude()) .setCount(ardAlarmSuperBrain.getCount()) .setTotal(ardAlarmSuperBrain.getTotal()); return globalAlarmData; }).collect(Collectors.toList()); default: return null; } } @Override public List selectAlarmLogsAll() { List GlobalAlarmDataList = new ArrayList<>(); String refreshTime = configService.selectConfigByKey("refreshTime"); List ardAlarmStealelecs = ardAlarmStealelecMapper.selectListAllByCommand(refreshTime); List alarmData1001 = 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()) .setAlarmType("1001"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1001.size() > 0) { GlobalAlarmDataList.addAll(alarmData1001); } List ardAlarmCameras = ardAlarmCameraMapper.selectListAllByCommand(refreshTime); List alarmData1002 = 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()) .setAlarmType("1002"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1002.size() > 0) { GlobalAlarmDataList.addAll(alarmData1002); } List ardAlarmRadarMoves = ardAlarmRadarMoveMapper.selectListAllByCommand(refreshTime); List alarmData1003 = ardAlarmRadarMoves.stream() .map(ardAlarmRadarMove -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarMove.getId()) .setName(ardAlarmRadarMove.getName()) .setAlarmTime(ardAlarmRadarMove.getAlarmTime()) .setLongitude(ardAlarmRadarMove.getLongitude()) .setLatitude(ardAlarmRadarMove.getLatitude()) .setCount(ardAlarmRadarMove.getCount()) .setTotal(ardAlarmRadarMove.getTotal()) .setAlarmType("1003"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1003.size() > 0) { GlobalAlarmDataList.addAll(alarmData1003); } List ardAlarmRadarFires = ardAlarmRadarFireMapper.selectListAllByCommand(refreshTime); List alarmData1004 = ardAlarmRadarFires.stream() .map(ardAlarmRadarFire -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarFire.getId()) .setName(ardAlarmRadarFire.getName()) .setAlarmTime(ardAlarmRadarFire.getAlarmTime()) .setLongitude(ardAlarmRadarFire.getLongitude()) .setLatitude(ardAlarmRadarFire.getLatitude()) .setCount(ardAlarmRadarFire.getCount()) .setTotal(ardAlarmRadarFire.getTotal()) .setAlarmType("1004"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1004.size() > 0) { GlobalAlarmDataList.addAll(alarmData1004); } List ardAlarmExternals = ardAlarmExternalMapper.selectListAllByCommand(refreshTime, "防区报警"); List alarmData1005 = 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()) .setAlarmType("1005"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1005.size() > 0) { GlobalAlarmDataList.addAll(alarmData1005); } List ardAlarmAccesses = ardAlarmAccessMapper.selectListAllByCommand(refreshTime); List alarmData1006 = 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()) .setAlarmType("1006"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1006.size() > 0) { GlobalAlarmDataList.addAll(alarmData1006); } List ardAlarmRadarPumps = ardAlarmRadarPumpMapper.selectListAllByCommand(refreshTime); List alarmData1007 = ardAlarmRadarPumps.stream() .map(ardAlarmRadarPump -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmRadarPump.getId()) .setName(ardAlarmRadarPump.getName()) .setAlarmTime(ardAlarmRadarPump.getAlarmTime()) .setLongitude(ardAlarmRadarPump.getLongitude()) .setLatitude(ardAlarmRadarPump.getLatitude()) .setCount(ardAlarmRadarPump.getCount()) .setTotal(ardAlarmRadarPump.getTotal()) .setAlarmType("1007"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1007.size() > 0) { GlobalAlarmDataList.addAll(alarmData1007); } List ardAlarmApponekeys = ardAlarmApponekeyMapper.selectListAllByCommand(refreshTime); List alarmData1009 = 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()) .setAlarmType("1009"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1009.size() > 0) { GlobalAlarmDataList.addAll(alarmData1009); } List ardAlarmWalls = ardAlarmWallMapper.selectListAllByCommand(refreshTime); List alarmData1010 = ardAlarmWalls.stream() .map(ardAlarmWall -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmWall.getId()) .setName(ardAlarmWall.getWallName()) .setAlarmTime(ardAlarmWall.getCreateTime()) .setLongitude(ardAlarmWall.getLongitude()) .setLatitude(ardAlarmWall.getLatitude()) .setCount(ardAlarmWall.getCount()) .setTotal(ardAlarmWall.getTotal()) .setAlarmType("1010"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1010.size() > 0) { GlobalAlarmDataList.addAll(alarmData1010); } List ardAlarmDigitization3s = ardAlarmDigitization3Mapper.selectListAllByCommand(refreshTime); List alarmData1012 = ardAlarmDigitization3s.stream() .map(ardAlarmDigitization3 -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmDigitization3.getId()) .setName(ardAlarmDigitization3.getWellNo()) .setAlarmTime(ardAlarmDigitization3.getAlarmTime()) .setLongitude(ardAlarmDigitization3.getLongitude()) .setLatitude(ardAlarmDigitization3.getLatitude()) .setAltitude(ardAlarmDigitization3.getAltitude()) .setCount(ardAlarmDigitization3.getCount()) .setTotal(ardAlarmDigitization3.getTotal()) .setAlarmType("1012"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1012.size() > 0) { GlobalAlarmDataList.addAll(alarmData1012); } List ardAlarmTubes = ardAlarmTubeMapper.selectListAllByCommand(refreshTime); List alarmData1014 = 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()) .setAlarmType("1014"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1014.size() > 0) { GlobalAlarmDataList.addAll(alarmData1014); } List ardAlarmSuperBrains = ardAlarmSuperBrainMapper.selectListAllByCommand(refreshTime); List alarmData1015 = ardAlarmSuperBrains.stream() .map(ardAlarmSuperBrain -> { GlobalAlarmData globalAlarmData = new GlobalAlarmData() .setId(ardAlarmSuperBrain.getId()) .setName(ardAlarmSuperBrain.getAlarmType()) .setAlarmTime(ardAlarmSuperBrain.getAlarmTime()) .setLongitude(ardAlarmSuperBrain.getLongitude()) .setLatitude(ardAlarmSuperBrain.getLatitude()) .setAltitude(ardAlarmSuperBrain.getAltitude()) .setCount(ardAlarmSuperBrain.getCount()) .setTotal(ardAlarmSuperBrain.getTotal()) .setAlarmType("1015"); return globalAlarmData; }).collect(Collectors.toList()); if (alarmData1015.size() > 0) { GlobalAlarmDataList.addAll(alarmData1015); } return GlobalAlarmDataList; } /** * @描述 历史报警查询 * @参数 [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: ArdAlarmRadarMove aarm = new ArdAlarmRadarMove(); aarm.setParams(params); aarm.setPageNum(pageNum); aarm.setPageSize(pageSize); aarm.setAlarmType("运动目标检测"); return ardAlarmRadarMoveMapper.selectArdAlarmRadarMoveList(aarm); case 1004: ArdAlarmRadarFire aarf = new ArdAlarmRadarFire(); aarf.setParams(params); aarf.setPageNum(pageNum); aarf.setPageSize(pageSize); aarf.setAlarmType("热源检测"); return ardAlarmRadarFireMapper.selectArdAlarmRadarFireList(aarf); case 1007: ArdAlarmRadarPump aarp = new ArdAlarmRadarPump(); aarp.setParams(params); aarp.setPageNum(pageNum); aarp.setPageSize(pageSize); aarp.setAlarmType("雷达抽油机停机"); return ardAlarmRadarPumpMapper.selectArdAlarmRadarPumpList(aarp); 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 1010: ArdAlarmWall aaw = new ArdAlarmWall(); aaw.setParams(params); aaw.setPageNum(pageNum); aaw.setPageSize(pageSize); return ardAlarmWallMapper.selectArdAlarmWallList(aaw); case 1012: ArdAlarmDigitization3 aad3 = new ArdAlarmDigitization3(); aad3.setParams(params); aad3.setPageNum(pageNum); aad3.setPageSize(pageSize); return ardAlarmDigitization3Mapper.selectArdAlarmDigitization3List(aad3); case 1014: ArdAlarmTube aat = new ArdAlarmTube(); aat.setParams(params); aat.setPageNum(pageNum); aat.setPageSize(pageSize); return ardAlarmTubeMapper.selectArdAlarmTubeList(aat); case 1015: ArdAlarmSuperBrain aasb = new ArdAlarmSuperBrain(); aasb.setParams(params); aasb.setPageNum(pageNum); aasb.setPageSize(pageSize); return ardAlarmSuperBrainMapper.selectArdAlarmSuperBrainList(aasb); } 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"); SimpleDateFormat fmtms = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); 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: ArdAlarmRadarMove ardAlarmRadarMove = ardAlarmRadarMoveMapper.selectArdAlarmRadarMoveById(condition.getId()); if (StringUtils.isNotNull(ardAlarmRadarMove)) { String name = ardAlarmRadarMove.getName(); String alarmTime = fmt.format(ardAlarmRadarMove.getAlarmTime()); ardAlarmRadarMoveMapper.updateViewTimeByCondition(name, alarmTime, DateUtils.getTime()); return ardAlarmRadarMove; } case 1004: ArdAlarmRadarFire ardAlarmRadarFire = ardAlarmRadarFireMapper.selectArdAlarmRadarFireById(condition.getId()); if (StringUtils.isNotNull(ardAlarmRadarFire)) { String name = ardAlarmRadarFire.getName(); String alarmTime = fmt.format(ardAlarmRadarFire.getAlarmTime()); ardAlarmRadarFireMapper.updateViewTimeByCondition(name, alarmTime, DateUtils.getTime()); return ardAlarmRadarFire; } case 1007: ArdAlarmRadarPump ardAlarmRadarPump = ardAlarmRadarPumpMapper.selectArdAlarmRadarPumpById(condition.getId()); if (StringUtils.isNotNull(ardAlarmRadarPump)) { String name = ardAlarmRadarPump.getName(); String alarmTime = fmt.format(ardAlarmRadarPump.getAlarmTime()); ardAlarmRadarPumpMapper.updateViewTimeByCondition(name, alarmTime, DateUtils.getTime()); return ardAlarmRadarPump; } 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 1010: ArdAlarmWall ardAlarmWall = ardAlarmWallMapper.selectArdAlarmWallById(condition.getId()); if (StringUtils.isNotNull(ardAlarmWall)) { String userId = ardAlarmWall.getUserId(); String alarmTime = fmtms.format(ardAlarmWall.getAlarmTime()); ardAlarmWallMapper.updateViewTimeByUserId(userId, alarmTime, DateUtils.getTime()); return ardAlarmWall; } case 1012: ArdAlarmDigitization3 ardAlarmDigitization3 = ardAlarmDigitization3Mapper.selectArdAlarmDigitization3ById(condition.getId()); if (StringUtils.isNotNull(ardAlarmDigitization3)) { String wellNo = ardAlarmDigitization3.getWellNo(); String alarmTime = fmtms.format(ardAlarmDigitization3.getAlarmTime()); ardAlarmDigitization3Mapper.updateViewTimeByWellNo(wellNo, alarmTime, DateUtils.getTime()); return ardAlarmDigitization3; } 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; } case 1015: ArdAlarmSuperBrain ardAlarmSuperBrain = ardAlarmSuperBrainMapper.selectArdAlarmSuperBrainById(condition.getId()); if (StringUtils.isNotNull(ardAlarmSuperBrain)) { String alarmType = ardAlarmSuperBrain.getAlarmType(); String alarmTime = fmt.format(ardAlarmSuperBrain.getAlarmTime()); ardAlarmSuperBrainMapper.updateViewTimeByAlarmType(alarmType, alarmTime, DateUtils.getTime()); return ardAlarmSuperBrain; } 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 cameraId = getCameraByNear(new double[]{ardAlarmTube.getLongitude(), ardAlarmTube.getLatitude()}); if (StringUtils.isNotEmpty(cameraId)) { GuideDataDto guideDataDto = new GuideDataDto() .setAlarmId(cameraId) .setAlarmId(ardAlarmTube.getId()) .setAlarmType("sys_tube_leak") .setReceiveTime(ardAlarmTube.getCreateTime()) .setTargetPosition(coordinate); messagesEnqueued(guideDataDto); } //endregion } //endregion break; case "camera": //region 处理通用光电报警 ArdAlarmCamera ardAlarmCamera = JSONObject.parseObject(message, ArdAlarmCamera.class); ardAlarmCamera.setId(IdUtils.simpleUUID()); ardAlarmCamera.setCreateTime(new Date()); int aac = ardAlarmCameraMapper.insertArdAlarmCamera(ardAlarmCamera); if (aac > 0) { log.debug("camera入库成功：" + ardAlarmCamera); } //endregion break; case "radar": //region 处理雷达报警 RadarAlarmData radarAlarmData = JSONObject.parseObject(message, RadarAlarmData.class); List ardAlarmRadars = radarAlarmData.getArdAlarmRadars(); for (ArdAlarmRadar ardAlarmRadar : ardAlarmRadars) { String uuid = IdUtils.simpleUUID(); String radarId = radarAlarmData.getRadarId(); String alarmpointName = ardAlarmRadar.getName();//兴趣点名称 ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); if (well == null) { return; } Double longitude = well.getLongitude(); Double latitude = well.getLatitude(); String targetId = ardAlarmRadar.getTargetId(); switch (ardAlarmRadar.getAlarmType()) { case "运动目标检测": ArdAlarmRadarMove ardAlarmRadarMove = new ArdAlarmRadarMove(); ardAlarmRadarMove.setId(uuid); ardAlarmRadarMove.setTargetId(targetId); ardAlarmRadarMove.setAlarmTime(radarAlarmData.getAlarmTime()); ardAlarmRadarMove.setCreateTime(new Date()); ardAlarmRadarMove.setName(alarmpointName + "(" + radarAlarmData.getRadarName() + ")"); ardAlarmRadarMove.setAlarmType("运动目标检测"); ardAlarmRadarMove.setLongitude(longitude); ardAlarmRadarMove.setLatitude(latitude); ardAlarmRadarMove.setUpdateTime(radarAlarmData.getAlarmTime()); ardAlarmRadarMove.setRadarId(radarId); ardAlarmRadarMoveHandler(ardAlarmRadarMove); break; case "热源检测": ArdAlarmRadarFire ardAlarmRadarFire = new ArdAlarmRadarFire(); ardAlarmRadarFire.setId(uuid); ardAlarmRadarFire.setTargetId(targetId); ardAlarmRadarFire.setAlarmTime(radarAlarmData.getAlarmTime()); ardAlarmRadarFire.setCreateTime(new Date()); ardAlarmRadarFire.setName(alarmpointName + "(" + radarAlarmData.getRadarName() + ")"); ardAlarmRadarFire.setAlarmType("热源检测"); ardAlarmRadarFire.setLongitude(longitude); ardAlarmRadarFire.setLatitude(latitude); ardAlarmRadarFire.setRadarId(radarId); ardAlarmRadarFire.setUpdateTime(radarAlarmData.getAlarmTime()); ardAlarmRadarFireHandler(ardAlarmRadarFire); break; case "雷达抽油机停机": ArdAlarmRadarPump ardAlarmRadarPump = new ArdAlarmRadarPump(); ardAlarmRadarPump.setRadarId(radarId); ardAlarmRadarPump.setId(uuid); ardAlarmRadarPump.setTargetId(targetId); ardAlarmRadarPump.setAlarmTime(radarAlarmData.getAlarmTime()); ardAlarmRadarPump.setCreateTime(new Date()); ardAlarmRadarPump.setName(ardAlarmRadar.getName() + "(" + radarAlarmData.getRadarName() + ")"); ardAlarmRadarPump.setAlarmType("雷达抽油机停机"); ardAlarmRadarPump.setUpdateTime(radarAlarmData.getAlarmTime()); ardAlarmRadarPump.setLongitude(well.getLongitude()); ardAlarmRadarPump.setLatitude(well.getLatitude()); ardAlarmRadarPumpHandler(ardAlarmRadarPump); break; } } //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 well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(defenseName); if (StringUtils.isNotNull(well)) { ardAlarmExternal.setLongitude(well.getLongitude()); ardAlarmExternal.setLatitude(well.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[] coordinate = new double[]{ardAlarmExternal.getLongitude(), ardAlarmExternal.getLatitude()};//引导坐标 String cameraId = getCameraByNear(coordinate);//最近相机ID if (StringUtils.isNotEmpty(cameraId)) { GuideDataDto guideDataDto = new GuideDataDto() .setAlarmId(cameraId) .setAlarmId(ardAlarmExternal.getId()) .setAlarmType("sys_external") .setReceiveTime(ardAlarmExternal.getCreateTime()) .setTargetPosition(coordinate) .setWellId(well.getId()); messagesEnqueued(guideDataDto); } //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[] coordinate = new double[]{ardAlarmAccess.getLongitude(), ardAlarmAccess.getLatitude()};//引导坐标 String cameraId = getCameraByNear(coordinate);//最近相机ID if (StringUtils.isNotEmpty(cameraId)) { GuideDataDto guideDataDto = new GuideDataDto() .setAlarmId(cameraId) .setAlarmId(ardAlarmAccess.getId()) .setAlarmType("sys_external") .setReceiveTime(ardAlarmAccess.getCreateTime()) .setTargetPosition(coordinate); messagesEnqueued(guideDataDto); } //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; case "digitization3": //region 三厂数字化报警 ArdAlarmDigitization3 ardAlarmDigitization3 = JSONObject.parseObject(message, ArdAlarmDigitization3.class); //获取经纬度 ArdAlarmpointsWell Well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(ardAlarmDigitization3.getWellNo()); if (Well != null) { ardAlarmDigitization3.setLongitude(Well.getLongitude()); ardAlarmDigitization3.setLatitude(Well.getLatitude()); ardAlarmDigitization3.setAltitude(Well.getAltitude()); } ardAlarmDigitization3.setCreateTime(new Date()); int aad = ardAlarmDigitization3Mapper.insertArdAlarmDigitization3(ardAlarmDigitization3); if (aad > 0) { log.debug("digitization3入库成功：" + ardAlarmDigitization3); } //endregion break; case "superBrain": //region 超脑报警 ArdAlarmSuperBrain ardAlarmSuperBrain = JSONObject.parseObject(message, ArdAlarmSuperBrain.class); ardAlarmSuperBrain.setId(IdUtils.simpleUUID()); ardAlarmSuperBrain.setCreateTime(new Date()); int sbRes = ardAlarmSuperBrainMapper.insertArdAlarmSuperBrain(ardAlarmSuperBrain); if (sbRes > 0) { log.debug("superBrain入库成功：" + ardAlarmSuperBrain); } //endregion break; } } catch (Exception ex) { log.error("接收报警异常:" + ex.getMessage()); } } /** * 消息入队 *

* cameraId 相机ID * alarmId 报警ID * alarmType 报警类型 * num 报警次数 * recordSn 录像存储位置 1-recordUrl1 2-recordUrl2 * targetPosition 报警点位置坐标 */ private void messagesEnqueued(GuideDataDto guideDataDto) { try { String cameraId = guideDataDto.getCameraId(); if (!IsEnableGuide(cameraId)) { log.debug("相机:" + cameraId + "未开启报警引导功能"); return; } GuideTask guideTask = new GuideTask(); guideTask.setCameraId(cameraId);//相机ID String alarmType = guideDataDto.getAlarmType(); switch (alarmType) { case "运动目标检测": alarmType = "sys_radar_move"; break; case "热源检测": alarmType = "sys_radar_fire"; break; case "雷达抽油机停机": alarmType = "sys_radar_pump"; break; } guideTask.setAlarmType(alarmType);//报警类型 Integer chanNo = ArdTool.getChannelBydayNightTime(redisCache.getCacheObject("sys_config:dayNightTime")); guideTask.setChanNo(chanNo);//通道(通过日夜时间研判) guideTask.setAlarmId(guideDataDto.getAlarmId()); //报警ID guideTask.setReceiveTime(DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS_MS, guideDataDto.getReceiveTime()));//接收时间 //报警优先级(通过优先级字典) String priority = DictUtils.getDictValue("cameras_priority", alarmType); if (StringUtils.isEmpty(priority)) { log.debug("未匹配到优先级,请检查优先级字典配置"); return; } guideTask.setPriority(Integer.valueOf(priority)); guideTask.setTargetPosition(guideDataDto.getTargetPosition());//引导井ID //消息入队 queueHandler.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 getCameraByNear(double[] targetPosition) { String minDistanceCameraId = ""; try { //获取所有大光电 List ardCamerasList = ardCamerasMapper.selectArdCamerasList(new ArdCameras("1")); //统计所有大光电可视范围内与报警点的距离 Map distanceMap = new HashMap<>(); Map guideMap = new HashMap<>(); for (ArdCameras camera : ardCamerasList) { if (camera.getCamMaxVisibleDistance() == null) { continue; } double[] camPosition = new double[]{camera.getLongitude(), camera.getLatitude()}; double distance = GisUtil.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 " "; } } } catch (Exception ex) { log.error("获取附近开启报警引导功能光电异常:" + ex.getMessage()); } return minDistanceCameraId; } //获取相机引导入队 private void getCameraGuideToQueue(GuideDataDto guideDataDto) { //获取雷达所在塔上的大光电 ArdCameras cameraWithTower = ardEquipRadarMapper.getCameraByRadar(guideDataDto.getRadarId()); if (StringUtils.isNotNull(cameraWithTower)) { log.debug("获取到雷达塔上的光电:" + cameraWithTower.getId()); //如果雷达塔上有光电 guideDataDto.setCameraId(cameraWithTower.getId()); messagesEnqueued(guideDataDto); } else { log.debug("未获取到雷达塔上的光电,无法引导"); } } /** * 雷达移动引导 * 刘苏义 * 2023/12/14 15:04:24 */ private void radarMoveGuide(ArdAlarmRadarMove ardAlarmRadarMove) { log.debug("雷达移动开始引导"); if (StringUtils.isNull(ardAlarmRadarMove.getLongitude()) || StringUtils.isNull(ardAlarmRadarMove.getLatitude())) { log.debug("坐标为空不引导"); return; } double[] coordinate = new double[]{ardAlarmRadarMove.getLongitude(), ardAlarmRadarMove.getLatitude()};//报警坐标 //引导入队 GuideDataDto guideDataDto = new GuideDataDto() .setRadarId(ardAlarmRadarMove.getRadarId()) .setName(ardAlarmRadarMove.getName()) .setAlarmId(ardAlarmRadarMove.getId()) .setAlarmType(ardAlarmRadarMove.getAlarmType()) .setReceiveTime(ardAlarmRadarMove.getCreateTime()) .setTargetPosition(coordinate); getCameraGuideToQueue(guideDataDto);//获取相机入队 } /** * 雷达防火引导 * 刘苏义 * 2023/12/14 15:04:32 */ private void radarFireGuide(ArdAlarmRadarFire ardAlarmRadarFire) { log.debug("雷达防火开始引导"); if (StringUtils.isNull(ardAlarmRadarFire.getLongitude()) || StringUtils.isNull(ardAlarmRadarFire.getLatitude())) { log.debug("坐标为空不引导"); return; } double[] coordinate = new double[]{ardAlarmRadarFire.getLongitude(), ardAlarmRadarFire.getLatitude()};//报警坐标 //引导入队 GuideDataDto guideDataDto = new GuideDataDto() .setRadarId(ardAlarmRadarFire.getRadarId()) .setName(ardAlarmRadarFire.getName()) .setAlarmId(ardAlarmRadarFire.getId()) .setAlarmType(ardAlarmRadarFire.getAlarmType()) .setReceiveTime(ardAlarmRadarFire.getCreateTime()) .setTargetPosition(coordinate); getCameraGuideToQueue(guideDataDto);//获取相机入队 } /** * 雷达抽油机停机引导 * 刘苏义 * 2023/12/14 15:04:40 */ private void radarPumpGuide(ArdAlarmRadarPump ardAlarmRadarPump) { log.debug("雷达抽油机停机开始引导"); if (StringUtils.isNull(ardAlarmRadarPump.getLongitude()) || StringUtils.isNull(ardAlarmRadarPump.getLatitude())) { //坐标为空不引导 log.debug("坐标为空不引导"); return; } double[] coordinate = new double[]{ardAlarmRadarPump.getLongitude(), ardAlarmRadarPump.getLatitude()};//报警坐标 //引导入队 GuideDataDto guideDataDto = new GuideDataDto() .setRadarId(ardAlarmRadarPump.getRadarId()) .setName(ardAlarmRadarPump.getName()) .setAlarmId(ardAlarmRadarPump.getId()) .setAlarmType(ardAlarmRadarPump.getAlarmType()) .setReceiveTime(ardAlarmRadarPump.getCreateTime()) .setTargetPosition(coordinate); getCameraGuideToQueue(guideDataDto);//获取相机入队 } /** * 雷达目标移动报警处理 * 刘苏义 * 2023/12/14 15:03:32 */ private void ardAlarmRadarMoveHandler(ArdAlarmRadarMove ardAlarmRadarMove) { String mergeTime = ConfigUtils.getConfigValue("radarMergeTime"); Integer radarMergeTime = mergeTime == null || "".equals(mergeTime) ? 10 : Integer.valueOf(mergeTime); ArdAlarmRadarMove lastMoveData = ardAlarmRadarMoveMapper.selectArdAlarmRadarLastData(ardAlarmRadarMove.getName()); if (lastMoveData == null) { //入库 ardAlarmRadarMove.setGuideTime(ardAlarmRadarMove.getAlarmTime()); ardAlarmRadarMoveMapper.insertArdAlarmRadarMove(ardAlarmRadarMove); radarMoveGuide(ardAlarmRadarMove);//引导 } else { //否则比对更新时间 Date lastUpdateTime = lastMoveData.getUpdateTime(); Date lastGuideTime = lastMoveData.getGuideTime(); long secDatePoor = DateUtils.getSecDatePoor(ardAlarmRadarMove.getAlarmTime(), lastUpdateTime); if (secDatePoor <= radarMergeTime) { //小于10秒的新数据，更新上一条 ArdAlarmRadarMove updateData = new ArdAlarmRadarMove(); updateData.setId(lastMoveData.getId()); updateData.setUpdateTime(ardAlarmRadarMove.getAlarmTime()); //判断引导时间超过5分钟再次引导 long secDatePoorGuide = DateUtils.getSecDatePoor(ardAlarmRadarMove.getAlarmTime(), lastGuideTime); if (secDatePoorGuide >= 300) { updateData.setGuideTime(ardAlarmRadarMove.getAlarmTime()); radarMoveGuide(ardAlarmRadarMove);//引导 } ardAlarmRadarMoveMapper.updateArdAlarmRadarMove(updateData); } else { //超过10秒的数据,入库 ardAlarmRadarMove.setGuideTime(ardAlarmRadarMove.getAlarmTime()); ardAlarmRadarMoveMapper.insertArdAlarmRadarMove(ardAlarmRadarMove); radarMoveGuide(ardAlarmRadarMove);//引导 } } } /** * 雷达红外防火报警处理 * 刘苏义 * 2023/12/14 15:03:23 */ private void ardAlarmRadarFireHandler(ArdAlarmRadarFire ardAlarmRadarFire) { String mergeTime = ConfigUtils.getConfigValue("radarMergeTime"); Integer radarMergeTime = mergeTime == null || "".equals(mergeTime) ? 10 : Integer.valueOf(mergeTime); ArdAlarmRadarFire lastFireData = ardAlarmRadarFireMapper.selectArdAlarmRadarLastData(ardAlarmRadarFire.getName()); if (lastFireData == null) { //入库 ardAlarmRadarFire.setGuideTime(ardAlarmRadarFire.getAlarmTime()); ardAlarmRadarFireMapper.insertArdAlarmRadarFire(ardAlarmRadarFire); radarFireGuide(ardAlarmRadarFire);//引导 } else { //否则比对更新时间 Date lastUpdateTime = lastFireData.getUpdateTime(); Date lastGuideTime = lastFireData.getGuideTime(); long secDatePoor = DateUtils.getSecDatePoor(ardAlarmRadarFire.getAlarmTime(), lastUpdateTime); if (secDatePoor <= radarMergeTime) { //小于10秒的新数据，更新上一条 ArdAlarmRadarFire updateData = new ArdAlarmRadarFire(); updateData.setId(lastFireData.getId()); updateData.setUpdateTime(ardAlarmRadarFire.getAlarmTime()); //判断引导时间超过5分钟再次引导 long secDatePoorGuide = DateUtils.getSecDatePoor(ardAlarmRadarFire.getAlarmTime(), lastGuideTime); if (secDatePoorGuide >= 300) { updateData.setGuideTime(ardAlarmRadarFire.getAlarmTime()); radarFireGuide(ardAlarmRadarFire);//引导 } ardAlarmRadarFireMapper.updateArdAlarmRadarFire(updateData); } else { //超过10秒的数据,入库 ardAlarmRadarFire.setGuideTime(ardAlarmRadarFire.getAlarmTime()); ardAlarmRadarFireMapper.insertArdAlarmRadarFire(ardAlarmRadarFire); radarFireGuide(ardAlarmRadarFire);//引导 } } } /** * 雷达抽油机停机报警处理 * 刘苏义 * 2023/12/14 15:03:06 */ private void ardAlarmRadarPumpHandler(ArdAlarmRadarPump ardAlarmRadarPump) { String mergeTime = ConfigUtils.getConfigValue("radarMergeTime"); Integer radarMergeTime = mergeTime == null || "".equals(mergeTime) ? 10 : Integer.valueOf(mergeTime); ArdAlarmRadarPump lastPumpData = ardAlarmRadarPumpMapper.selectArdAlarmRadarLastData(ardAlarmRadarPump.getName()); if (lastPumpData == null) { //入库 ardAlarmRadarPump.setGuideTime(ardAlarmRadarPump.getAlarmTime()); ardAlarmRadarPumpMapper.insertArdAlarmRadarPump(ardAlarmRadarPump); radarPumpGuide(ardAlarmRadarPump);//引导 } else { //否则比对更新时间 Date lastUpdateTime = lastPumpData.getUpdateTime(); Date lastGuideTime = lastPumpData.getGuideTime(); long secDatePoor = DateUtils.getSecDatePoor(ardAlarmRadarPump.getAlarmTime(), lastUpdateTime); if (secDatePoor <= radarMergeTime) { //小于10秒的新数据，更新上一条 ArdAlarmRadarPump updateData = new ArdAlarmRadarPump(); updateData.setId(lastPumpData.getId()); updateData.setUpdateTime(ardAlarmRadarPump.getAlarmTime()); //判断引导时间超过5分钟再次引导 long secDatePoorGuide = DateUtils.getSecDatePoor(ardAlarmRadarPump.getAlarmTime(), lastGuideTime); if (secDatePoorGuide >= 300) { radarPumpGuide(ardAlarmRadarPump);//引导 updateData.setGuideTime(ardAlarmRadarPump.getAlarmTime()); } ardAlarmRadarPumpMapper.updateArdAlarmRadarPump(updateData); } else { //超过10秒的数据,入库 ardAlarmRadarPump.setGuideTime(ardAlarmRadarPump.getAlarmTime()); ardAlarmRadarPumpMapper.insertArdAlarmRadarPump(ardAlarmRadarPump); radarPumpGuide(ardAlarmRadarPump);//引导 } } } }