| | |
| | | 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.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.domain.*; |
| | | import com.ruoyi.alarm.global.service.IGlobalAlarmService; |
| | | import com.ruoyi.alarm.radar.domain.*; |
| | | import com.ruoyi.alarm.radar.mapper.ArdAlarmRadarFireMapper; |
| | |
| | | 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.domain.entity.SysConfig; |
| | | 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.camera.domain.CameraCmd; |
| | | 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.tube.GeoPoint; |
| | | import com.ruoyi.utils.tube.TubeTools; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.gavaghan.geodesy.GlobalCoordinates; |
| | | 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.TimeUnit; |
| | | import java.util.stream.Collectors; |
| | | |
| | | |
| | |
| | | * @Version: 1.0 |
| | | **/ |
| | | @Service |
| | | @Slf4j(topic = "mqtt") |
| | | @Slf4j(topic = "alarm") |
| | | public class GlobalAlarmServiceImpl implements IGlobalAlarmService { |
| | | //region 依赖注入 |
| | | @Resource |
| | |
| | | @Resource |
| | | private RedisCache redisCache; |
| | | @Resource |
| | | private QueueManager queueManager; |
| | | private QueueHandler queueHandler; |
| | | @Resource |
| | | private ArdEquipRadarMapper ardEquipRadarMapper; |
| | | //endregion |
| | |
| | | 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); |
| | | 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 |
| | | } |
| | |
| | | case "radar": |
| | | //region 处理雷达报警 |
| | | String mergeTime = ConfigUtils.getConfigValue("radarMergeTime"); |
| | | Integer radarMergeTime= mergeTime==null||"".equals(mergeTime)?10:Integer.valueOf(mergeTime); |
| | | Integer radarMergeTime = mergeTime == null || "".equals(mergeTime) ? 10 : Integer.valueOf(mergeTime); |
| | | RadarAlarmData radarAlarmData = JSONObject.parseObject(message, RadarAlarmData.class); |
| | | List<ArdAlarmRadar> ardAlarmRadars = radarAlarmData.getArdAlarmRadars(); |
| | | for (ArdAlarmRadar ardAlarmRadar : ardAlarmRadars) { |
| | |
| | | String radarId = radarAlarmData.getRadarId(); |
| | | String alarmpointName = ardAlarmRadar.getName();//兴趣点名称 |
| | | ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); |
| | | if(well==null) |
| | | { |
| | | if (well == null) { |
| | | return; |
| | | } |
| | | |
| | | Double longitude = well.getLongitude(); |
| | | Double latitude = well.getLatitude(); |
| | | String targetId = ardAlarmRadar.getTargetId(); |
| | | GuidePTZ guidePTZ = new GuidePTZ(); |
| | | guidePTZ.setP1(well.getGuideP1()); |
| | | guidePTZ.setT1(well.getGuideT1()); |
| | | guidePTZ.setZ1(well.getGuideZ1()); |
| | | guidePTZ.setP2(well.getGuideP2()); |
| | | guidePTZ.setT2(well.getGuideT2()); |
| | | guidePTZ.setZ2(well.getGuideZ2()); |
| | | switch (ardAlarmRadar.getAlarmType()) { |
| | | case "运动目标检测": |
| | | ArdAlarmRadarMove ardAlarmRadarMove = new ArdAlarmRadarMove(); |
| | |
| | | ardAlarmRadarMove.setLatitude(latitude); |
| | | ardAlarmRadarMove.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | ardAlarmRadarMove.setRadarId(radarId); |
| | | ardAlarmRadarMove.setGuidePTZ(guidePTZ); |
| | | Date alarmTime = ardAlarmRadarMove.getAlarmTime(); |
| | | //获取当前兴趣点当前雷达的上一条数据 |
| | | ArdAlarmRadarMove lastMoveData = ardAlarmRadarMoveMapper.selectArdAlarmRadarLastData(ardAlarmRadarMove.getName()); |
| | |
| | | //否则比对更新时间 |
| | | Date lastUpdateTime = lastMoveData.getUpdateTime(); |
| | | Date lastGuideTime = lastMoveData.getGuideTime(); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime,lastUpdateTime); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime, lastUpdateTime); |
| | | if (secDatePoor <= radarMergeTime) { |
| | | //小于10秒的新数据,更新上一条 |
| | | ArdAlarmRadarMove updateData = new ArdAlarmRadarMove(); |
| | |
| | | updateData.setUpdateTime(alarmTime); |
| | | |
| | | //判断引导时间超过5分钟再次引导 |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime,lastGuideTime); |
| | | if(secDatePoorGuide>=300) |
| | | { |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime, lastGuideTime); |
| | | if (secDatePoorGuide >= 300) { |
| | | updateData.setGuideTime(alarmTime); |
| | | radarMoveGuide(ardAlarmRadarMove);//引导 |
| | | } |
| | |
| | | ardAlarmRadarFire.setAlarmType("热源检测"); |
| | | ardAlarmRadarFire.setLongitude(longitude); |
| | | ardAlarmRadarFire.setLatitude(latitude); |
| | | ardAlarmRadarFire.setGuidePTZ(guidePTZ); |
| | | ardAlarmRadarFire.setRadarId(radarId); |
| | | ardAlarmRadarFire.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | // |
| | |
| | | } else { |
| | | //否则比对更新时间 |
| | | Date lastUpdateTime = lastFireData.getUpdateTime(); |
| | | |
| | | Date lastGuideTime = lastFireData.getGuideTime(); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime,lastUpdateTime); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime, lastUpdateTime); |
| | | if (secDatePoor <= radarMergeTime) { |
| | | //小于10秒的新数据,更新上一条 |
| | | ArdAlarmRadarFire updateData = new ArdAlarmRadarFire(); |
| | |
| | | updateData.setUpdateTime(alarmTime); |
| | | |
| | | //判断引导时间超过5分钟再次引导 |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime,lastGuideTime); |
| | | if(secDatePoorGuide>=300) |
| | | { |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime, lastGuideTime); |
| | | if (secDatePoorGuide >= 300) { |
| | | updateData.setGuideTime(alarmTime); |
| | | radarFireGuide(ardAlarmRadarFire);//引导 |
| | | } |
| | |
| | | ardAlarmRadarPump.setAlarmType("雷达抽油机停机"); |
| | | ardAlarmRadarPump.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | alarmTime = ardAlarmRadarPump.getAlarmTime(); |
| | | ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); |
| | | if (StringUtils.isNotNull(ardAlarmpointsWell)) { |
| | | ardAlarmRadarPump.setLongitude(ardAlarmpointsWell.getLongitude()); |
| | | ardAlarmRadarPump.setLatitude(ardAlarmpointsWell.getLatitude()); |
| | | } |
| | | ardAlarmRadarPump.setLongitude(well.getLongitude()); |
| | | ardAlarmRadarPump.setLatitude(well.getLatitude()); |
| | | ardAlarmRadarPump.setGuidePTZ(guidePTZ); |
| | | // |
| | | ArdAlarmRadarPump lastPumpData = ardAlarmRadarPumpMapper.selectArdAlarmRadarLastData(ardAlarmRadarPump.getName()); |
| | | if (lastPumpData == null) { |
| | |
| | | //否则比对更新时间 |
| | | Date lastUpdateTime = lastPumpData.getUpdateTime(); |
| | | Date lastGuideTime = lastPumpData.getGuideTime(); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime,lastUpdateTime); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime, lastUpdateTime); |
| | | if (secDatePoor <= radarMergeTime) { |
| | | //小于10秒的新数据,更新上一条 |
| | | ArdAlarmRadarPump updateData = new ArdAlarmRadarPump(); |
| | | updateData.setId(lastPumpData.getId()); |
| | | updateData.setUpdateTime(alarmTime); |
| | | //判断引导时间超过5分钟再次引导 |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime,lastGuideTime); |
| | | if(secDatePoorGuide>=300) |
| | | { |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime, lastGuideTime); |
| | | if (secDatePoorGuide >= 300) { |
| | | radarPumpGuide(ardAlarmRadarPump);//引导 |
| | | updateData.setGuideTime(alarmTime); |
| | | } |
| | |
| | | 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()); |
| | | ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(defenseName); |
| | | GuidePTZ guidePTZ = new GuidePTZ(); |
| | | if (StringUtils.isNotNull(well)) { |
| | | ardAlarmExternal.setLongitude(well.getLongitude()); |
| | | ardAlarmExternal.setLatitude(well.getLatitude()); |
| | | guidePTZ.setP1(well.getGuideP1()); |
| | | guidePTZ.setT1(well.getGuideT1()); |
| | | guidePTZ.setZ1(well.getGuideZ1()); |
| | | guidePTZ.setP2(well.getGuideP2()); |
| | | guidePTZ.setT2(well.getGuideT2()); |
| | | guidePTZ.setZ2(well.getGuideZ2()); |
| | | } |
| | | int aae = ardAlarmExternalMapper.insertArdAlarmExternal(ardAlarmExternal); |
| | | if (aae > 0) { |
| | |
| | | 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); |
| | | 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) |
| | | .setGuidePTZ(guidePTZ); |
| | | messagesEnqueued(guideDataDto); |
| | | } |
| | | //endregion |
| | | } |
| | |
| | | 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); |
| | | 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 |
| | | } |
| | |
| | | * recordSn 录像存储位置 1-recordUrl1 2-recordUrl2 |
| | | * targetPosition 报警点位置坐标 |
| | | */ |
| | | private void messagesEnqueued(String cameraId, String alarmId, String alarmType, Date receiveTime, Integer num, Integer recordSn, double[] targetPosition) { |
| | | private void messagesEnqueued(GuideDataDto guideDataDto) { |
| | | try { |
| | | String cameraId = guideDataDto.getCameraId(); |
| | | 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); |
| | | //报警类型 |
| | | String aType = ""; |
| | | guideTask.setCameraId(cameraId);//相机ID |
| | | String alarmType = guideDataDto.getAlarmType(); |
| | | switch (alarmType) { |
| | | case "运动目标检测": |
| | | aType = "sys_radar_move"; |
| | | alarmType = "sys_radar_move"; |
| | | break; |
| | | case "热源检测": |
| | | aType = "sys_radar_fire"; |
| | | alarmType = "sys_radar_fire"; |
| | | break; |
| | | case "雷达抽油机停机": |
| | | aType = "sys_radar_pump"; |
| | | break; |
| | | default: |
| | | aType = alarmType; |
| | | alarmType = "sys_radar_pump"; |
| | | break; |
| | | } |
| | | guideTask.setAlarmType(aType); |
| | | //通道(通过日夜时间研判) |
| | | String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime"); |
| | | Integer channel = ArdTool.getChannelBydayNightTime(dayNightTime); |
| | | guideTask.setChanNum(channel); |
| | | //报警ID |
| | | guideTask.setAlarmId(alarmId); |
| | | //接收时间 |
| | | guideTask.setReceiveTime(fmt.format(receiveTime)); |
| | | 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", aType); |
| | | String priority = DictUtils.getDictValue("cameras_priority", alarmType); |
| | | if (StringUtils.isEmpty(priority)) { |
| | | log.debug("未匹配到优先级,请检查优先级字典配置"); |
| | | return; |
| | | } |
| | | guideTask.setPriority(Integer.valueOf(priority)); |
| | | //报警次数 |
| | | guideTask.setNum(num); |
| | | //录像存储位置 |
| | | guideTask.setRecordSn(recordSn); |
| | | //目标经纬度 |
| | | guideTask.setTargetPosition(targetPosition); |
| | | guideTask.setTargetPosition(guideDataDto.getTargetPosition());//目标经纬度 |
| | | if (guideDataDto.getGuidePTZ() != null) { |
| | | guideTask.setGuidePTZ(guideDataDto.getGuidePTZ());//目标PTZ |
| | | } |
| | | //消息入队 |
| | | queueManager.addTaskToQueue(cameraId, guideTask); |
| | | queueHandler.addTaskToQueue(cameraId, guideTask); |
| | | //打印队列 |
| | | GuidePriorityQueue.printPriorityQueue(); |
| | | } catch (Exception ex) { |
| | |
| | | /** |
| | | * 获取附近开启报警引导功能光电 |
| | | */ |
| | | private String getNearbyCamera(double[] targetPosition) { |
| | | private String getCameraByNear(double[] targetPosition) { |
| | | String minDistanceCameraId = ""; |
| | | try { |
| | | //获取所有大光电 |
| | |
| | | return minDistanceCameraId; |
| | | } |
| | | |
| | | //雷达获取相机引导入队 |
| | | private void radarGuideToQueue(String alarmId, String radarId, String name, String alarmType, Date createTime, double[] coordinate) { |
| | | int index = name.indexOf("("); |
| | | String alarmpointName = name.substring(0, index); |
| | | //获取相机引导入队 |
| | | private void getCameraGuideToQueue(GuideDataDto guideDataDto) { |
| | | |
| | | //获取雷达所在塔上的大光电 |
| | | ArdCameras cameraWithTower = ardEquipRadarMapper.getCameraByRadar(radarId); |
| | | ArdCameras cameraWithTower = ardEquipRadarMapper.getCameraByRadar(guideDataDto.getRadarId()); |
| | | if (StringUtils.isNotNull(cameraWithTower)) { |
| | | log.debug("获取到雷达塔上的光电:" + cameraWithTower.getId()); |
| | | //如果雷达塔上有光电 |
| | | messagesEnqueued(cameraWithTower.getId(), alarmId, alarmType, createTime, 1, 1, coordinate); |
| | | guideDataDto.setCameraId(cameraWithTower.getId()); |
| | | messagesEnqueued(guideDataDto); |
| | | } else { |
| | | log.debug("未获取到雷达塔上的光电,无法引导"); |
| | | } |
| | | //获取报警点关联的大光电 |
| | | ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName); |
| | | if (StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId())) { |
| | | String cameraId = ardAlarmpointsWell.getCameraId(); |
| | | if (cameraId.equals(cameraWithTower.getId())) { |
| | | return; |
| | | } |
| | | log.info("获取到报警点关联的光电:" + cameraId); |
| | | //如果报警点关联了光电 |
| | | messagesEnqueued(cameraId, alarmId, alarmType, createTime, 1, 2, coordinate); |
| | | } else { |
| | | log.debug("未获取到报警点关联的光电,无法引导"); |
| | | } |
| | | } |
| | | |
| | | //雷达移动引导 |
| | | private void radarMoveGuide(ArdAlarmRadarMove ardAlarmRadarMove) { |
| | | log.debug("雷达移动开始引导"); |
| | |
| | | } |
| | | double[] coordinate = new double[]{ardAlarmRadarMove.getLongitude(), ardAlarmRadarMove.getLatitude()};//报警坐标 |
| | | //引导入队 |
| | | radarGuideToQueue(ardAlarmRadarMove.getId(), ardAlarmRadarMove.getRadarId(), ardAlarmRadarMove.getName(), ardAlarmRadarMove.getAlarmType(), ardAlarmRadarMove.getCreateTime(), coordinate);//更新 |
| | | GuideDataDto guideDataDto = new GuideDataDto() |
| | | .setRadarId( ardAlarmRadarMove.getRadarId()) |
| | | .setName(ardAlarmRadarMove.getName()) |
| | | .setAlarmId(ardAlarmRadarMove.getId()) |
| | | .setAlarmType(ardAlarmRadarMove.getAlarmType()) |
| | | .setReceiveTime(ardAlarmRadarMove.getCreateTime()) |
| | | .setTargetPosition(coordinate) |
| | | .setGuidePTZ(ardAlarmRadarMove.getGuidePTZ()); |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |
| | | |
| | | //雷达防火引导 |
| | | private void radarFireGuide(ArdAlarmRadarFire ardAlarmRadarFire) { |
| | | log.debug("雷达防火开始引导"); |
| | |
| | | } |
| | | double[] coordinate = new double[]{ardAlarmRadarFire.getLongitude(), ardAlarmRadarFire.getLatitude()};//报警坐标 |
| | | //引导入队 |
| | | radarGuideToQueue(ardAlarmRadarFire.getId(), ardAlarmRadarFire.getRadarId(), ardAlarmRadarFire.getName(), ardAlarmRadarFire.getAlarmType(), ardAlarmRadarFire.getCreateTime(), coordinate);//更新 |
| | | GuideDataDto guideDataDto = new GuideDataDto() |
| | | .setRadarId( ardAlarmRadarFire.getRadarId()) |
| | | .setName(ardAlarmRadarFire.getName()) |
| | | .setAlarmId(ardAlarmRadarFire.getId()) |
| | | .setAlarmType(ardAlarmRadarFire.getAlarmType()) |
| | | .setReceiveTime(ardAlarmRadarFire.getCreateTime()) |
| | | .setTargetPosition(coordinate) |
| | | .setGuidePTZ(ardAlarmRadarFire.getGuidePTZ()); |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |
| | | |
| | | //雷达抽油机停机引导 |
| | | private void radarPumpGuide(ArdAlarmRadarPump ardAlarmRadarPump) { |
| | | log.debug("雷达抽油机停机开始引导"); |
| | |
| | | } |
| | | double[] coordinate = new double[]{ardAlarmRadarPump.getLongitude(), ardAlarmRadarPump.getLatitude()};//报警坐标 |
| | | //引导入队 |
| | | radarGuideToQueue(ardAlarmRadarPump.getId(), ardAlarmRadarPump.getRadarId(), ardAlarmRadarPump.getName(), ardAlarmRadarPump.getAlarmType(), ardAlarmRadarPump.getCreateTime(), coordinate);//更新 |
| | | GuideDataDto guideDataDto = new GuideDataDto() |
| | | .setRadarId( ardAlarmRadarPump.getRadarId()) |
| | | .setName(ardAlarmRadarPump.getName()) |
| | | .setAlarmId(ardAlarmRadarPump.getId()) |
| | | .setAlarmType(ardAlarmRadarPump.getAlarmType()) |
| | | .setReceiveTime(ardAlarmRadarPump.getCreateTime()) |
| | | .setTargetPosition(coordinate) |
| | | .setGuidePTZ(ardAlarmRadarPump.getGuidePTZ()); |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |
| | | |
| | | } |