| | |
| | | break; |
| | | case "radar": |
| | | //region 处理雷达报警 |
| | | String mergeTime = ConfigUtils.getConfigValue("radarMergeTime"); |
| | | 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) { |
| | |
| | | ardAlarmRadarMove.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | ardAlarmRadarMove.setRadarId(radarId); |
| | | ardAlarmRadarMove.setGuidePTZ(guidePTZ); |
| | | Date alarmTime = ardAlarmRadarMove.getAlarmTime(); |
| | | //获取当前兴趣点当前雷达的上一条数据 |
| | | ArdAlarmRadarMove lastMoveData = ardAlarmRadarMoveMapper.selectArdAlarmRadarLastData(ardAlarmRadarMove.getName()); |
| | | if (lastMoveData == null) { |
| | | //入库 |
| | | ardAlarmRadarMove.setGuideTime(alarmTime); |
| | | ardAlarmRadarMoveMapper.insertArdAlarmRadarMove(ardAlarmRadarMove); |
| | | radarMoveGuide(ardAlarmRadarMove);//引导 |
| | | } else { |
| | | //否则比对更新时间 |
| | | Date lastUpdateTime = lastMoveData.getUpdateTime(); |
| | | Date lastGuideTime = lastMoveData.getGuideTime(); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime, lastUpdateTime); |
| | | if (secDatePoor <= radarMergeTime) { |
| | | //小于10秒的新数据,更新上一条 |
| | | ArdAlarmRadarMove updateData = new ArdAlarmRadarMove(); |
| | | updateData.setId(lastMoveData.getId()); |
| | | updateData.setUpdateTime(alarmTime); |
| | | |
| | | //判断引导时间超过5分钟再次引导 |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime, lastGuideTime); |
| | | if (secDatePoorGuide >= 300) { |
| | | updateData.setGuideTime(alarmTime); |
| | | radarMoveGuide(ardAlarmRadarMove);//引导 |
| | | } |
| | | ardAlarmRadarMoveMapper.updateArdAlarmRadarMove(updateData); |
| | | } else { |
| | | //超过10秒的数据,入库 |
| | | ardAlarmRadarMove.setGuideTime(alarmTime); |
| | | ardAlarmRadarMoveMapper.insertArdAlarmRadarMove(ardAlarmRadarMove); |
| | | radarMoveGuide(ardAlarmRadarMove);//引导 |
| | | } |
| | | } |
| | | //入缓存 |
| | | //String key = "radar_alarm:" + DateUtils.getDate(); |
| | | //if (redisCache.hasKey(key)) { |
| | | // redisCache.setCacheList(key, ardAlarmRadarMove, -1, TimeUnit.HOURS); |
| | | //} else { |
| | | // Integer expiryTimeInSeconds = DateUtils.getDayRemainingTime(ardAlarmRadarMove.getCreateTime()); |
| | | // redisCache.setCacheList(key, ardAlarmRadarMove, expiryTimeInSeconds, TimeUnit.SECONDS); |
| | | //} |
| | | // |
| | | ardAlarmRadarMoveHandler(ardAlarmRadarMove); |
| | | break; |
| | | case "热源检测": |
| | | ArdAlarmRadarFire ardAlarmRadarFire = new ArdAlarmRadarFire(); |
| | |
| | | ardAlarmRadarFire.setRadarId(radarId); |
| | | ardAlarmRadarFire.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | // |
| | | ArdAlarmRadarFire lastFireData = ardAlarmRadarFireMapper.selectArdAlarmRadarLastData(ardAlarmRadarFire.getName()); |
| | | alarmTime = ardAlarmRadarFire.getAlarmTime(); |
| | | if (lastFireData == null) { |
| | | //入库 |
| | | ardAlarmRadarFire.setGuideTime(alarmTime); |
| | | ardAlarmRadarFireMapper.insertArdAlarmRadarFire(ardAlarmRadarFire); |
| | | radarFireGuide(ardAlarmRadarFire);//引导 |
| | | } else { |
| | | //否则比对更新时间 |
| | | Date lastUpdateTime = lastFireData.getUpdateTime(); |
| | | Date lastGuideTime = lastFireData.getGuideTime(); |
| | | long secDatePoor = DateUtils.getSecDatePoor(alarmTime, lastUpdateTime); |
| | | if (secDatePoor <= radarMergeTime) { |
| | | //小于10秒的新数据,更新上一条 |
| | | ArdAlarmRadarFire updateData = new ArdAlarmRadarFire(); |
| | | updateData.setId(lastFireData.getId()); |
| | | updateData.setUpdateTime(alarmTime); |
| | | |
| | | //判断引导时间超过5分钟再次引导 |
| | | long secDatePoorGuide = DateUtils.getSecDatePoor(alarmTime, lastGuideTime); |
| | | if (secDatePoorGuide >= 300) { |
| | | updateData.setGuideTime(alarmTime); |
| | | radarFireGuide(ardAlarmRadarFire);//引导 |
| | | } |
| | | ardAlarmRadarFireMapper.updateArdAlarmRadarFire(updateData); |
| | | } else { |
| | | //超过10秒的数据,入库 |
| | | ardAlarmRadarFire.setGuideTime(alarmTime); |
| | | ardAlarmRadarFireMapper.insertArdAlarmRadarFire(ardAlarmRadarFire); |
| | | radarFireGuide(ardAlarmRadarFire);//引导 |
| | | } |
| | | } |
| | | ardAlarmRadarFireHandler(ardAlarmRadarFire); |
| | | break; |
| | | case "雷达抽油机停机": |
| | | ArdAlarmRadarPump ardAlarmRadarPump = new ArdAlarmRadarPump(); |
| | |
| | | ardAlarmRadarPump.setName(ardAlarmRadar.getName() + "(" + radarAlarmData.getRadarName() + ")"); |
| | | ardAlarmRadarPump.setAlarmType("雷达抽油机停机"); |
| | | ardAlarmRadarPump.setUpdateTime(radarAlarmData.getAlarmTime()); |
| | | alarmTime = ardAlarmRadarPump.getAlarmTime(); |
| | | ardAlarmRadarPump.setLongitude(well.getLongitude()); |
| | | ardAlarmRadarPump.setLatitude(well.getLatitude()); |
| | | ardAlarmRadarPump.setGuidePTZ(guidePTZ); |
| | | // |
| | | ArdAlarmRadarPump lastPumpData = ardAlarmRadarPumpMapper.selectArdAlarmRadarLastData(ardAlarmRadarPump.getName()); |
| | | if (lastPumpData == null) { |
| | | //入库 |
| | | ardAlarmRadarPump.setGuideTime(alarmTime); |
| | | ardAlarmRadarPumpMapper.insertArdAlarmRadarPump(ardAlarmRadarPump); |
| | | radarPumpGuide(ardAlarmRadarPump);//引导 |
| | | } else { |
| | | //否则比对更新时间 |
| | | Date lastUpdateTime = lastPumpData.getUpdateTime(); |
| | | Date lastGuideTime = lastPumpData.getGuideTime(); |
| | | 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) { |
| | | radarPumpGuide(ardAlarmRadarPump);//引导 |
| | | updateData.setGuideTime(alarmTime); |
| | | } |
| | | ardAlarmRadarPumpMapper.updateArdAlarmRadarPump(updateData); |
| | | } else { |
| | | //超过10秒的数据,入库 |
| | | ardAlarmRadarPump.setGuideTime(alarmTime); |
| | | ardAlarmRadarPumpMapper.insertArdAlarmRadarPump(ardAlarmRadarPump); |
| | | radarPumpGuide(ardAlarmRadarPump);//引导 |
| | | } |
| | | } |
| | | ardAlarmRadarPumpHandler(ardAlarmRadarPump); |
| | | break; |
| | | } |
| | | } |
| | |
| | | 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()));//接收时间 |
| | | 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)) { |
| | |
| | | } |
| | | } |
| | | |
| | | //雷达移动引导 |
| | | /** |
| | | * 雷达移动引导 |
| | | * 刘苏义 |
| | | * 2023/12/14 15:04:24 |
| | | */ |
| | | private void radarMoveGuide(ArdAlarmRadarMove ardAlarmRadarMove) { |
| | | log.debug("雷达移动开始引导"); |
| | | if (StringUtils.isNull(ardAlarmRadarMove.getLongitude()) || StringUtils.isNull(ardAlarmRadarMove.getLatitude())) { |
| | |
| | | double[] coordinate = new double[]{ardAlarmRadarMove.getLongitude(), ardAlarmRadarMove.getLatitude()};//报警坐标 |
| | | //引导入队 |
| | | GuideDataDto guideDataDto = new GuideDataDto() |
| | | .setRadarId( ardAlarmRadarMove.getRadarId()) |
| | | .setRadarId(ardAlarmRadarMove.getRadarId()) |
| | | .setName(ardAlarmRadarMove.getName()) |
| | | .setAlarmId(ardAlarmRadarMove.getId()) |
| | | .setAlarmType(ardAlarmRadarMove.getAlarmType()) |
| | |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |
| | | |
| | | //雷达防火引导 |
| | | /** |
| | | * 雷达防火引导 |
| | | * 刘苏义 |
| | | * 2023/12/14 15:04:32 |
| | | */ |
| | | private void radarFireGuide(ArdAlarmRadarFire ardAlarmRadarFire) { |
| | | log.debug("雷达防火开始引导"); |
| | | if (StringUtils.isNull(ardAlarmRadarFire.getLongitude()) || StringUtils.isNull(ardAlarmRadarFire.getLatitude())) { |
| | |
| | | double[] coordinate = new double[]{ardAlarmRadarFire.getLongitude(), ardAlarmRadarFire.getLatitude()};//报警坐标 |
| | | //引导入队 |
| | | GuideDataDto guideDataDto = new GuideDataDto() |
| | | .setRadarId( ardAlarmRadarFire.getRadarId()) |
| | | .setRadarId(ardAlarmRadarFire.getRadarId()) |
| | | .setName(ardAlarmRadarFire.getName()) |
| | | .setAlarmId(ardAlarmRadarFire.getId()) |
| | | .setAlarmType(ardAlarmRadarFire.getAlarmType()) |
| | |
| | | getCameraGuideToQueue(guideDataDto);//获取相机入队 |
| | | } |
| | | |
| | | //雷达抽油机停机引导 |
| | | /** |
| | | * 雷达抽油机停机引导 |
| | | * 刘苏义 |
| | | * 2023/12/14 15:04:40 |
| | | */ |
| | | private void radarPumpGuide(ArdAlarmRadarPump ardAlarmRadarPump) { |
| | | log.debug("雷达抽油机停机开始引导"); |
| | | if (StringUtils.isNull(ardAlarmRadarPump.getLongitude()) || StringUtils.isNull(ardAlarmRadarPump.getLatitude())) { |
| | |
| | | double[] coordinate = new double[]{ardAlarmRadarPump.getLongitude(), ardAlarmRadarPump.getLatitude()};//报警坐标 |
| | | //引导入队 |
| | | GuideDataDto guideDataDto = new GuideDataDto() |
| | | .setRadarId( ardAlarmRadarPump.getRadarId()) |
| | | .setRadarId(ardAlarmRadarPump.getRadarId()) |
| | | .setName(ardAlarmRadarPump.getName()) |
| | | .setAlarmId(ardAlarmRadarPump.getId()) |
| | | .setAlarmType(ardAlarmRadarPump.getAlarmType()) |
| | |
| | | .setGuidePTZ(ardAlarmRadarPump.getGuidePTZ()); |
| | | 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);//引导 |
| | | } |
| | | } |
| | | } |
| | | } |