~liusuyi/ruoyi-api.git

			@@ -29,23 +29,20 @@
			import com.ruoyi.utils.tools.GisTool;
			import com.ruoyi.common.utils.uuid.IdUtils;
			import com.ruoyi.device.camera.domain.ArdCameras;
			import com.ruoyi.device.camera.domain.CameraCmd;
			import com.ruoyi.device.camera.mapper.ArdCamerasMapper;
			import com.ruoyi.device.hiksdk.common.GlobalVariable;
			import com.ruoyi.device.hiksdk.service.IHikClientService;
			import com.ruoyi.system.service.ISysConfigService;
			import com.ruoyi.utils.tube.GeoPoint;
			import com.ruoyi.utils.tube.TubeTools;
			import lombok.AllArgsConstructor;
			import lombok.Data;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.scheduling.annotation.Async;
			import org.springframework.stereotype.Service;

			import javax.annotation.Resource;
			import java.text.SimpleDateFormat;
			import java.util.*;
			import java.util.concurrent.PriorityBlockingQueue;
			import java.util.stream.Collectors;


			/**
			* @Description: 全局报警业务
			@@ -77,8 +74,6 @@
			@Resource
			private ArdCamerasMapper ardCamerasMapper;
			@Resource
			private IHikClientService hikClientService;
			@Resource
			private RedisCache redisCache;
			@Resource
			private QueueManager queueManager;
			@@ -105,6 +100,8 @@
			countMap.put("1003", count1003);
			int count1004 = ardAlarmRadarMapper.selectCountByAlarmTime(refreshTime, "热源检测");
			countMap.put("1004", count1004);
			int count1007 = ardAlarmRadarMapper.selectCountByAlarmTime(refreshTime, "雷达抽油机停机");
			countMap.put("1007", count1007);
			int count1014 = ardAlarmTubeMapper.selectCountByAlarmTime(refreshTime);
			countMap.put("1014", count1014);
			map.put("20000", countMap);
			@@ -137,8 +134,7 @@
			.setCount(ardAlarmStealelec.getCount())
			.setTotal(ardAlarmStealelec.getTotal());
			return globalAlarmData;
			})
			.collect(Collectors.toList());
			}).collect(Collectors.toList());
			case 1002:
			List<ArdAlarmCamera> ardAlarmCameras = ardAlarmCameraMapper.selectListAllByCommand(refreshTime);
			return ardAlarmCameras.stream()
			@@ -152,8 +148,7 @@
			.setCount(ardAlarmCamera.getCount())
			.setTotal(ardAlarmCamera.getTotal());
			return globalAlarmData;
			})
			.collect(Collectors.toList());
			}).collect(Collectors.toList());
			case 1003:
			List<ArdAlarmRadar> ardAlarmRadars = ardAlarmRadarMapper.selectListAllByCommand(refreshTime, "运动目标检测");
			return ardAlarmRadars.stream()
			@@ -167,8 +162,7 @@
			.setCount(ardAlarmRadar.getCount())
			.setTotal(ardAlarmRadar.getTotal());
			return globalAlarmData;
			})
			.collect(Collectors.toList());
			}).collect(Collectors.toList());
			case 1004:
			ardAlarmRadars = ardAlarmRadarMapper.selectListAllByCommand(refreshTime, "热源检测");
			return ardAlarmRadars.stream()
			@@ -182,8 +176,21 @@
			.setCount(ardAlarmRadar.getCount())
			.setTotal(ardAlarmRadar.getTotal());
			return globalAlarmData;
			})
			.collect(Collectors.toList());
			}).collect(Collectors.toList());
			case 1007:
			ardAlarmRadars = ardAlarmRadarMapper.selectListAllByCommand(refreshTime, "雷达抽油机停机");
			return ardAlarmRadars.stream()
			.map(ardAlarmRadar -> {
			GlobalAlarmData globalAlarmData = new GlobalAlarmData()
			.setId(ardAlarmRadar.getId())
			.setName(ardAlarmRadar.getName())
			.setAlarmTime(ardAlarmRadar.getAlarmTime())
			.setLongitude(ardAlarmRadar.getLongitude())
			.setLatitude(ardAlarmRadar.getLatitude())
			.setCount(ardAlarmRadar.getCount())
			.setTotal(ardAlarmRadar.getTotal());
			return globalAlarmData;
			}).collect(Collectors.toList());
			case 1014:
			List<ArdAlarmTube> ardAlarmTubes = ardAlarmTubeMapper.selectListAllByCommand(refreshTime);
			return ardAlarmTubes.stream()
			@@ -198,8 +205,7 @@
			.setCount(ardAlarmTube.getCount())
			.setTotal(ardAlarmTube.getTotal());
			return globalAlarmData;
			})
			.collect(Collectors.toList());
			}).collect(Collectors.toList());
			default:
			return null;
			}
			@@ -224,38 +230,40 @@
			aas.setParams(params);
			aas.setPageNum(pageNum);
			aas.setPageSize(pageSize);
			List<ArdAlarmStealelec> ardAlarmStealelecs = ardAlarmStealelecMapper.selectArdAlarmStealelecList(aas);
			return ardAlarmStealelecs;
			return ardAlarmStealelecMapper.selectArdAlarmStealelecList(aas);
			case 1002:
			ArdAlarmCamera aac = new ArdAlarmCamera();
			aac.setParams(params);
			aac.setPageNum(pageNum);
			aac.setPageSize(pageSize);
			List<ArdAlarmCamera> ardAlarmCameras = ardAlarmCameraMapper.selectArdAlarmCameraList(aac);
			return ardAlarmCameras;
			return ardAlarmCameraMapper.selectArdAlarmCameraList(aac);
			case 1003:
			ArdAlarmRadar aar = new ArdAlarmRadar();
			aar.setParams(params);
			aar.setPageNum(pageNum);
			aar.setPageSize(pageSize);
			aar.setAlarmType("运动目标检测");
			List<ArdAlarmRadar> ardAlarmRadar = ardAlarmRadarMapper.selectArdAlarmRadarList(aar);
			return ardAlarmRadar;
			return ardAlarmRadarMapper.selectArdAlarmRadarList(aar);
			case 1004:
			ArdAlarmRadar aarr = new ArdAlarmRadar();
			aarr.setParams(params);
			aarr.setPageNum(pageNum);
			aarr.setPageSize(pageSize);
			aarr.setAlarmType("热源检测");
			List<ArdAlarmRadar> ardAlarmRadarr = ardAlarmRadarMapper.selectArdAlarmRadarList(aarr);
			return ardAlarmRadarr;
			return ardAlarmRadarMapper.selectArdAlarmRadarList(aarr);
			case 1007:
			ArdAlarmRadar aarrr = new ArdAlarmRadar();
			aarrr.setParams(params);
			aarrr.setPageNum(pageNum);
			aarrr.setPageSize(pageSize);
			aarrr.setAlarmType("雷达抽油机停机");
			return ardAlarmRadarMapper.selectArdAlarmRadarList(aarrr);
			case 1014:
			ArdAlarmTube aat = new ArdAlarmTube();
			aat.setParams(params);
			aat.setPageNum(pageNum);
			aat.setPageSize(pageSize);
			List<ArdAlarmTube> ardAlarmTubes = ardAlarmTubeMapper.selectArdAlarmTubeList(aat);
			return ardAlarmTubes;
			return ardAlarmTubeMapper.selectArdAlarmTubeList(aat);
			}
			return null;
			}
			@@ -277,15 +285,26 @@
			if (StringUtils.isNotNull(ardAlarmStealelec)) {
			String describe = ardAlarmStealelec.getDescribe();
			String startTime = fmt.format(ardAlarmStealelec.getStartTime());
			int i = ardAlarmStealelecMapper.updateViewTimeByDescribe(describe, startTime, DateUtils.getTime());
			ardAlarmStealelecMapper.updateViewTimeByDescribe(describe, startTime, DateUtils.getTime());
			return ardAlarmStealelec;
			}
			case 1003:
			case 1004:
			case 1007:
			ArdAlarmRadar ardAlarmRadar = ardAlarmRadarMapper.selectArdAlarmRadarById(condition.getId());
			if (StringUtils.isNotNull(ardAlarmRadar)) {
			String name = ardAlarmRadar.getName();
			String alarmType=ardAlarmRadar.getAlarmType();
			String alarmTime=fmt.format(ardAlarmRadar.getAlarmTime());
			ardAlarmRadarMapper.updateViewTimeByCondition(name,alarmType, alarmTime,DateUtils.getTime());
			return ardAlarmRadar;
			}
			case 1014:
			ArdAlarmTube ardAlarmTube = ardAlarmTubeMapper.selectArdAlarmTubeById(condition.getId());
			if (StringUtils.isNotNull(ardAlarmTube)) {
			String tubeId = ardAlarmTube.getTubeId();
			String alarmTime = fmt.format(ardAlarmTube.getAlarmTime());
			int i = ardAlarmTubeMapper.updateViewTimeByTubeId(tubeId, alarmTime, DateUtils.getTime());
			ardAlarmTubeMapper.updateViewTimeByTubeId(tubeId, alarmTime, DateUtils.getTime());
			return ardAlarmTube;
			}
			default:
			@@ -379,7 +398,7 @@
			String alarmpointName = ardAlarmRadar.getName();//兴趣点名称
			ardAlarmRadar.setName(ardAlarmRadar.getName() + "(" + radarAlarmData.getRadarName() + ")");//报警点名称
			ardAlarmRadar.setCreateTime(new Date());//接收时间
			double[] coordinate=new double[]{ardAlarmRadar.getLongitude(),ardAlarmRadar.getLatitude()};//报警坐标

			String alarmType = "";
			switch (ardAlarmRadar.getAlarmType()) {
			case "运动目标检测":
			@@ -388,7 +407,20 @@
			case "热源检测":
			alarmType = "sys_radar_fire";
			break;
			case "雷达抽油机停机":
			alarmType = "sys_radar_pumpshutdown";
			ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName);
			if(StringUtils.isNotNull(ardAlarmpointsWell)) {
			ardAlarmRadar.setLongitude(ardAlarmpointsWell.getLongitude());
			ardAlarmRadar.setLatitude(ardAlarmpointsWell.getLatitude());
			}
			break;
			}
			if(StringUtils.isNull(ardAlarmRadar.getLongitude())\|\|StringUtils.isNull(ardAlarmRadar.getLatitude()))
			{
			continue;
			}
			double[] coordinate=new double[]{ardAlarmRadar.getLongitude(),ardAlarmRadar.getLatitude()};//报警坐标
			//判断当前报警点5分钟内是否已引导
			ardAlarmRadar.setGuideFlag(1);
			ArdAlarmRadar AlarmRadar = ardAlarmRadarMapper.getArdAlarmRadarWithGuide(ardAlarmRadar);
			@@ -423,7 +455,6 @@
			if (count >= 3) {
			ardAlarmRadar.setGuideFlag(1);
			ardAlarmRadarMapper.insertArdAlarmRadar(ardAlarmRadar);

			//获取雷达所在塔上的大光电
			String cameraIdWithTower = ardAlarmRadarMapper.getCameraByRadar(radarAlarmData.getRadarId());
			if (StringUtils.isNotNull(cameraIdWithTower) && StringUtils.isNotEmpty(cameraIdWithTower)) {
			@@ -532,4 +563,37 @@
			return minDistanceCameraId;
			}

			public static void main(String[] args) {
			Comparator<Obj> PriorityDescCom = Comparator.comparingInt(Obj::getPriority).reversed();
			Comparator<Obj> NumDescCom = Comparator.comparingInt(Obj::getNum).reversed();
			Comparator<Obj> receiveTimeAscCom = Comparator.comparing(Obj::getAlarmTime);
			Comparator<Obj> comparator = PriorityDescCom.thenComparing(NumDescCom).thenComparing(receiveTimeAscCom);

			PriorityBlockingQueue<Obj> priorityQueue = new PriorityBlockingQueue<>(1000,comparator);

			priorityQueue.add(new Obj(999,1,"2023-07-01 16:00:01"));
			priorityQueue.add(new Obj(999,2,"2023-07-01 16:00:01"));
			priorityQueue.add(new Obj(999,3,"2023-07-01 16:00:01"));

			List<Obj> elements = new ArrayList<>(priorityQueue);
			elements.sort(priorityQueue.comparator()); // 使用队列的比较器进行排序
			for (Obj task : elements) {
			log.info("正在排队【priority】" + task.getPriority()+"【num】" + task.getNum() + "【alarmTime】" + task.getAlarmTime());
			}
			log.info("===================================================================");
			priorityQueue.add(new Obj(999,5,"2023-07-01 16:00:01"));
			PriorityBlockingQueue queue = new PriorityBlockingQueue<>(priorityQueue);
			while (priorityQueue.size() > 0) {
			Obj task = priorityQueue.poll();
			log.info("正在排队【priority】" + task.getPriority()+"【num】" + task.getNum() + "【alarmTime】" + task.getAlarmTime());
			}
			}
			@Data
			@AllArgsConstructor
			static class Obj
			{
			Integer priority;
			Integer num;
			String alarmTime;
			}
			}