~liusuyi/ruoyi-api.git

			@@ -29,27 +29,24 @@
			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: 全局报警业务
			* @ClassName: globalAlarmServiceImpl
			* @Description:
			* @Author: Administrator
			* @Date: 2023年03月10日 11:03
			* @Version: 1.0
			@@ -76,8 +73,6 @@
			private ISysConfigService configService;
			@Resource
			private ArdCamerasMapper ardCamerasMapper;
			@Resource
			private IHikClientService hikClientService;
			@Resource
			private RedisCache redisCache;
			@Resource
			@@ -137,8 +132,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 +146,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 +160,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 +174,7 @@
			.setCount(ardAlarmRadar.getCount())
			.setTotal(ardAlarmRadar.getTotal());
			return globalAlarmData;
			})
			.collect(Collectors.toList());
			}).collect(Collectors.toList());
			case 1014:
			List<ArdAlarmTube> ardAlarmTubes = ardAlarmTubeMapper.selectListAllByCommand(refreshTime);
			return ardAlarmTubes.stream()
			@@ -198,8 +189,7 @@
			.setCount(ardAlarmTube.getCount())
			.setTotal(ardAlarmTube.getTotal());
			return globalAlarmData;
			})
			.collect(Collectors.toList());
			}).collect(Collectors.toList());
			default:
			return null;
			}
			@@ -224,38 +214,33 @@
			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 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 +262,33 @@
			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:
			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 1004:
			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:
			@@ -332,6 +335,7 @@
			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());
			@@ -342,9 +346,16 @@
			int aat = ardAlarmTubeMapper.insertArdAlarmTube(ardAlarmTube);
			if (aat > 0) {
			log.debug("tube入库成功：" + ardAlarmTube);
			String nearbyCamera = getNearbyCamera(new double[]{ardAlarmTube.getLongitude(), ardAlarmTube.getLatitude()});
			if (StringUtils.isNotEmpty(nearbyCamera)) {
			messagesEnqueued(nearbyCamera, ardAlarmTube.getId(), "sys_tube_leak", ardAlarmTube.getAlarmTime(), 1);
			Double longitude = ardAlarmTube.getLongitude();
			Double latitude = ardAlarmTube.getLatitude();
			if(StringUtils.isNull(longitude)\|\|StringUtils.isNull(latitude))
			{
			return;
			}
			double[] coordinate=new double[]{longitude,latitude};
			String nearbyCameraId = getNearbyCamera(new double[]{ardAlarmTube.getLongitude(), ardAlarmTube.getLatitude()});
			if (StringUtils.isNotEmpty(nearbyCameraId)) {
			messagesEnqueued(nearbyCameraId, ardAlarmTube.getId(), "sys_tube_leak",ardAlarmTube.getCreateTime(), 1,1,coordinate);
			}
			}
			//endregion
			@@ -357,26 +368,6 @@
			int aac = ardAlarmCameraMapper.insertArdAlarmCamera(ardAlarmCamera);
			if (aac > 0) {
			log.debug("camera入库成功：" + ardAlarmCamera);
			String nearbyCamera = getNearbyCamera(new double[]{ardAlarmCamera.getLongitude(), ardAlarmCamera.getLatitude()});
			if (StringUtils.isNotEmpty(nearbyCamera)) {
			messagesEnqueued(nearbyCamera, ardAlarmCamera.getId(), "sys_camera", ardAlarmCamera.getAlarmTime(), 1);
			}
			//引导录像
			// CameraCmd cmd = new CameraCmd();
			// cmd.setRecordBucketName("record");
			// cmd.setRecordObjectName("camera");
			// cmd.setOperator("sys_camera");
			// cmd.setExpired(30);
			// cmd.setTargetPosition(new double[]{ardAlarmCamera.getLongitude(), ardAlarmCamera.getLatitude()});
			// boolean res = guideCamera(cmd);
			// if (res) {
			// String url = alarmToRecord(cmd);
			// if (StringUtils.isNotEmpty(url)) {
			// //更新录像
			// ardAlarmCamera.setRecordUrl(url);
			// ardAlarmCameraMapper.updateArdAlarmCamera(ardAlarmCamera);
			// }
			// }
			}
			//endregion
			break;
			@@ -386,11 +377,12 @@
			List<ArdAlarmRadar> ardAlarmRadars = radarAlarmData.getArdAlarmRadars();
			for (ArdAlarmRadar ardAlarmRadar : ardAlarmRadars) {
			String uuid = IdUtils.simpleUUID();
			ardAlarmRadar.setId(uuid);
			ardAlarmRadar.setAlarmTime(radarAlarmData.getAlarmTime());
			String name = ardAlarmRadar.getName() + "(" + radarAlarmData.getRadarName() + ")";
			ardAlarmRadar.setName(name);
			ardAlarmRadar.setCreateTime(new Date());
			ardAlarmRadar.setId(uuid);//报警ID
			ardAlarmRadar.setAlarmTime(radarAlarmData.getAlarmTime());//报警时间
			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 "运动目标检测":
			@@ -409,72 +401,107 @@
			//获取雷达所在塔上的大光电
			String cameraIdWithTower = ardAlarmRadarMapper.getCameraByRadar(radarAlarmData.getRadarId());
			if (StringUtils.isNotNull(cameraIdWithTower) && StringUtils.isNotEmpty(cameraIdWithTower)) {
			//入队列待引导
			messagesEnqueued(cameraIdWithTower, uuid, alarmType, ardAlarmRadar.getAlarmTime(), 1);
			log.info("获取到雷达塔上的光电:"+cameraIdWithTower);
			//如果雷达塔上有光电
			messagesEnqueued(cameraIdWithTower, uuid, alarmType, ardAlarmRadar.getCreateTime(),1,1,coordinate);
			}
			//获取报警点关联的大光电
			ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName);
			if(StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId()))
			{
			String cameraId = ardAlarmpointsWell.getCameraId();
			if(cameraIdWithTower.equals(cameraId))
			{
			return;
			}
			log.info("获取到报警点关联的光电:"+cameraId);
			//如果报警点关联了光电
			messagesEnqueued(cameraId, uuid, alarmType,ardAlarmRadar.getCreateTime(), 1,2,coordinate);
			}
			} else {
			//5分钟内有引导
			ardAlarmRadar.setGuideFlag(0);
			int count = ardAlarmRadarMapper.getArdAlarmRadarWithNotGuide(ardAlarmRadar, AlarmRadar.getCreateTime());
			//未引导超过3次，直接入库入队
			if (count >= 3) {
			//未引导超过3次，直接入库入队
			//5分钟内未引导直接入库
			ardAlarmRadar.setGuideFlag(1);
			ardAlarmRadarMapper.insertArdAlarmRadar(ardAlarmRadar);
			//入队列待引导
			//获取雷达所在塔上的大光电
			String cameraIdWithTower = ardAlarmRadarMapper.getCameraByRadar(radarAlarmData.getRadarId());
			if (StringUtils.isNotNull(cameraIdWithTower) && StringUtils.isNotEmpty(cameraIdWithTower)) {
			log.info("获取到雷达塔上的光电:"+cameraIdWithTower);
			//如果雷达塔上有光电
			messagesEnqueued(cameraIdWithTower, uuid, alarmType, ardAlarmRadar.getAlarmTime(), count);
			messagesEnqueued(cameraIdWithTower, uuid, alarmType,ardAlarmRadar.getCreateTime(), count,1,coordinate);
			}
			//获取报警点关联的大光电
			ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName);
			if(StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId()))
			{
			String cameraId = ardAlarmpointsWell.getCameraId();
			if(cameraIdWithTower.equals(cameraId))
			{
			return;
			}
			log.info("获取到报警点关联的光电:"+cameraId);
			//如果报警点关联了光电
			messagesEnqueued(cameraId, uuid, alarmType,ardAlarmRadar.getCreateTime(), count,2,coordinate);
			}
			} else {
			//未引导未超过3次，直接入库
			ardAlarmRadarMapper.insertArdAlarmRadar(ardAlarmRadar);
			}

			}


			//获取兴趣点关联的大光电
			// ArdAlarmpointsWell well=new ArdAlarmpointsWell();
			// well.setWellId(ardAlarmRadar.getName());
			// List<ArdAlarmpointsWell> ardAlarmpointsWells = ardAlarmpointsWellMapper.selectArdAlarmpointsWellList(well);
			// if(ardAlarmpointsWells!=null&&ardAlarmpointsWells.size()>0)
			// {
			// String cameraIdWithWell = ardAlarmpointsWells.get(0).getCameraId();
			// }

			}
			//endregion
			break;
			}
			GuidePriorityQueue.printPriorityQueue();//打印队列
			} catch (Exception ex) {
			log.error("接收报警异常:" + ex.getMessage());
			}
			}


			/**
			* 消息入队
			*
			* cameraId 相机ID
			* alarmId 报警ID
			* alarmType 报警类型
			* num 报警次数
			* recordSn 录像存储位置 1-recordUrl1 2-recordUrl2
			* targetPosition 报警点位置坐标
			*/
			private void messagesEnqueued (String cameraId, String alarmId, String alarmType, Date alarmTime, Integer num) {
			private void messagesEnqueued(String cameraId, String alarmId, String alarmType,Date receiveTime, Integer num, Integer recordSn,double[] targetPosition) {
			SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
			GuideTask guideTask = new GuideTask();
			//相机ID
			guideTask.setCameraId(cameraId);
			//报警类型
			guideTask.setAlarmType(alarmType);
			//通道(通过日夜时间研判)
			String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime");
			Integer channel = ArdTool.getChannelBydayNightTime(dayNightTime);
			guideTask.setChanNum(channel);
			//报警ID
			guideTask.setAlarmId(alarmId);
			SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			guideTask.setAlarmTime(fmt.format(alarmTime));
			//接收时间
			guideTask.setReceiveTime(fmt.format(receiveTime));
			//报警优先级(通过优先级字典)
			Integer priority = CamPriority.priorityMap.get(alarmType);
			guideTask.setPriority(priority);
			//报警次数
			guideTask.setNum(num);
			queueManager.addTaskToQueue(cameraId,guideTask);
			// PriorityBlockingQueue<GuideTask> priorityBlockingQueue = GuidePriorityQueue.cameraQueueMap.get(guideTask.getCameraId());
			// priorityBlockingQueue.add(guideTask);
			//录像存储位置
			guideTask.setRecordSn(recordSn);
			//目标经纬度
			guideTask.setTargetPosition(targetPosition);
			//消息入队
			queueManager.addTaskToQueue(cameraId, guideTask);
			//打印队列
			GuidePriorityQueue.printPriorityQueue();
			}

			/**
			* 查找附近开启报警引导功能光电
			* 获取附近开启报警引导功能光电
			*/
			private String getNearbyCamera(double[] targetPosition) {
			String minDistanceCameraId = "";
			@@ -507,66 +534,37 @@
			return minDistanceCameraId;
			}

			/**
			* @描述引导最近的大光电指向目标
			* @参数 [cmd]
			* @返回值 boolean
			* @创建人刘苏义
			* @创建时间 2023/6/28 16:34
			* @修改人和其它信息
			*/
			private boolean guideCamera(CameraCmd cmd) {
			try {
			String dayNightTime = redisCache.getCacheObject("sys_config:dayNightTime");
			String nearbyCamera = getNearbyCamera(cmd.getTargetPosition());
			if (StringUtils.isNotEmpty(nearbyCamera)) {
			//引导光电
			cmd.setCameraId(nearbyCamera);
			cmd.setChannelNum(ArdTool.getChannelBydayNightTime(dayNightTime));
			boolean guideRes = hikClientService.guideTargetPosition(cmd);
			return guideRes;
			} else {
			log.debug("未查找到最近光电");
			return false;
			}
			} catch (
			Exception ex) {
			log.error("引导异常:" + ex.getMessage());
			return false;
			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());
			}

			}

			/**
			* @描述报警录像
			* @参数 [cmd]
			* @返回值 java.lang.String
			* @创建人刘苏义
			* @创建时间 2023/6/28 16:33
			* @修改人和其它信息
			*/
			private String alarmToRecord(CameraCmd cmd) {
			String url = "";
			try {
			log.debug("引导成功，尝试录像");
			String cameraId = cmd.getCameraId();
			hikClientService.controlLock(cmd);//上锁
			cmd.setEnable(true);//开始录像
			hikClientService.recordToMinio(cmd);//开始录像
			GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName());//将相机id与当前处理线程名称绑定
			Thread.sleep(cmd.getExpired() * 1000);//录像时长
			String thread = GlobalVariable.threadMap.get(cameraId);
			String currentThread = Thread.currentThread().getName();
			//判断相机绑定线程是否是当前线程，如果是，停止录像，如果不是，说明相机被其他线程抢占，不停止录像
			if (thread.equals(currentThread)) {
			cmd.setEnable(false);//停止录像
			cmd.setUploadMinio(true);//上传minio
			url = hikClientService.recordToMinio(cmd);//停止录像返回url
			}
			} catch (Exception ex) {
			log.error("录像异常:" + ex.getMessage());
			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());
			}
			return url;
			}

			@Data
			@AllArgsConstructor
			static class Obj
			{
			Integer priority;
			Integer num;
			String alarmTime;
			}
			}