~liusuyi/ruoyi-api.git

			@@ -3,6 +3,8 @@
			import com.alibaba.fastjson2.JSONObject;
			import com.ruoyi.alarm.cameraAlarm.domain.ArdAlarmCamera;
			import com.ruoyi.alarm.cameraAlarm.mapper.ArdAlarmCameraMapper;
			import com.ruoyi.alarm.externalAlarm.domain.ArdAlarmExternal;
			import com.ruoyi.alarm.externalAlarm.mapper.ArdAlarmExternalMapper;
			import com.ruoyi.alarm.globalAlarm.domain.GlobalAlarmCondition;
			import com.ruoyi.alarm.globalAlarm.domain.GlobalAlarmData;
			import com.ruoyi.alarm.globalAlarm.domain.GuidePriorityQueue;
			@@ -21,6 +23,7 @@
			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.DateUtils;
			import com.ruoyi.common.utils.StringUtils;
			@@ -38,6 +41,7 @@
			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.*;
			@@ -55,6 +59,8 @@
			@Slf4j(topic = "mqtt")
			public class GlobalAlarmServiceImpl implements IGlobalAlarmService {
			//region 依赖注入
			@Resource
			private ArdAlarmExternalMapper ardAlarmExternalMapper;
			@Resource
			private ArdAlarmRadarMapper ardAlarmRadarMapper;
			@Resource
			@@ -102,6 +108,8 @@
			countMap.put("1004", count1004);
			int count1007 = ardAlarmRadarMapper.selectCountByAlarmTime(refreshTime, "雷达抽油机停机");
			countMap.put("1007", count1007);
			int count1005 = ardAlarmExternalMapper.selectCountByAlarmTime(refreshTime, "防区报警");
			countMap.put("1005", count1005);
			int count1014 = ardAlarmTubeMapper.selectCountByAlarmTime(refreshTime);
			countMap.put("1014", count1014);
			map.put("20000", countMap);
			@@ -175,6 +183,20 @@
			.setLatitude(ardAlarmRadar.getLatitude())
			.setCount(ardAlarmRadar.getCount())
			.setTotal(ardAlarmRadar.getTotal());
			return globalAlarmData;
			}).collect(Collectors.toList());
			case 1005:
			List<ArdAlarmExternal> 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 1007:
			@@ -258,6 +280,13 @@
			aarrr.setPageSize(pageSize);
			aarrr.setAlarmType("雷达抽油机停机");
			return ardAlarmRadarMapper.selectArdAlarmRadarList(aarrr);
			case 1005:
			ArdAlarmExternal aae = new ArdAlarmExternal();
			aae.setParams(params);
			aae.setPageNum(pageNum);
			aae.setPageSize(pageSize);
			aae.setAlarmType("防区报警");
			return ardAlarmExternalMapper.selectArdAlarmExternalList(aae);
			case 1014:
			ArdAlarmTube aat = new ArdAlarmTube();
			aat.setParams(params);
			@@ -298,6 +327,15 @@
			String alarmTime=fmt.format(ardAlarmRadar.getAlarmTime());
			ardAlarmRadarMapper.updateViewTimeByCondition(name,alarmType, alarmTime,DateUtils.getTime());
			return ardAlarmRadar;
			}
			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());
			ardAlarmRadarMapper.updateViewTimeByCondition(defenseName, alarmType, alarmTime, DateUtils.getTime());
			return ardAlarmExternal;
			}
			case 1014:
			ArdAlarmTube ardAlarmTube = ardAlarmTubeMapper.selectArdAlarmTubeById(condition.getId());
			@@ -362,10 +400,10 @@
			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))
			{
			if (StringUtils.isNull(longitude) \|\| StringUtils.isNull(latitude)) {
			return;
			}
			double[] coordinate=new double[]{longitude,latitude};
			@@ -373,6 +411,7 @@
			if (StringUtils.isNotEmpty(nearbyCameraId)) {
			messagesEnqueued(nearbyCameraId, ardAlarmTube.getId(), "sys_tube_leak",ardAlarmTube.getCreateTime(), 1,1,coordinate);
			}
			//endregion
			}
			//endregion
			break;
			@@ -380,7 +419,6 @@
			//region 处理通用光电报警
			ArdAlarmCamera ardAlarmCamera = JSONObject.parseObject(message, ArdAlarmCamera.class);
			ardAlarmCamera.setId(IdUtils.simpleUUID());

			int aac = ardAlarmCameraMapper.insertArdAlarmCamera(ardAlarmCamera);
			if (aac > 0) {
			log.debug("camera入库成功：" + ardAlarmCamera);
			@@ -416,8 +454,7 @@
			}
			break;
			}
			if(StringUtils.isNull(ardAlarmRadar.getLongitude())\|\|StringUtils.isNull(ardAlarmRadar.getLatitude()))
			{
			if (StringUtils.isNull(ardAlarmRadar.getLongitude()) \|\| StringUtils.isNull(ardAlarmRadar.getLatitude())) {
			continue;
			}
			double[] coordinate=new double[]{ardAlarmRadar.getLongitude(),ardAlarmRadar.getLatitude()};//报警坐标
			@@ -436,11 +473,9 @@
			}
			//获取报警点关联的大光电
			ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName);
			if(StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId()))
			{
			if (StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId())) {
			String cameraId = ardAlarmpointsWell.getCameraId();
			if(cameraIdWithTower.equals(cameraId))
			{
			if (cameraIdWithTower.equals(cameraId)) {
			return;
			}
			log.info("获取到报警点关联的光电:"+cameraId);
			@@ -464,11 +499,9 @@
			}
			//获取报警点关联的大光电
			ArdAlarmpointsWell ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(alarmpointName);
			if(StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId()))
			{
			if (StringUtils.isNotNull(ardAlarmpointsWell) && StringUtils.isNotEmpty(ardAlarmpointsWell.getCameraId())) {
			String cameraId = ardAlarmpointsWell.getCameraId();
			if(cameraIdWithTower.equals(cameraId))
			{
			if (cameraIdWithTower.equals(cameraId)) {
			return;
			}
			log.info("获取到报警点关联的光电:"+cameraId);
			@@ -483,6 +516,37 @@
			}
			//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 ardAlarmpointsWell = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(defenseName);
			if (StringUtils.isNotNull(ardAlarmpointsWell)) {
			ardAlarmExternal.setLongitude(ardAlarmpointsWell.getLongitude());
			ardAlarmExternal.setLatitude(ardAlarmpointsWell.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[] guideCoordinate = new double[]{ardAlarmExternal.getLongitude(), ardAlarmExternal.getLatitude()};//引导坐标
			if (StringUtils.isNull(ardAlarmExternal.getLongitude()) \|\| StringUtils.isNull(ardAlarmExternal.getLatitude())) {
			return;
			}
			String nearbyCameraId = getNearbyCamera(new double[]{ardAlarmExternal.getLongitude(), ardAlarmExternal.getLatitude()});//最近相机ID
			if (StringUtils.isNotEmpty(nearbyCameraId)) {
			messagesEnqueued(nearbyCameraId, ardAlarmExternal.getId(), "sys_external", ardAlarmExternal.getCreateTime(), 1, 1, guideCoordinate);
			}
			//endregion
			}
			//endregion
			break;
			}
			} catch (Exception ex) {
			log.error("接收报警异常:" + ex.getMessage());
			@@ -491,7 +555,7 @@

			/**
			* 消息入队
			*
			* <p>
			* cameraId 相机ID
			* alarmId 报警ID
			* alarmType 报警类型
			@@ -500,6 +564,12 @@
			* targetPosition 报警点位置坐标
			*/
			private void messagesEnqueued(String cameraId, String alarmId, String alarmType,Date receiveTime, Integer num, Integer recordSn,double[] targetPosition) {
			try {
			if (!IsEnableGuide(cameraId)) {
			log.info("相机:" + cameraId + "未开启报警引导功能");
			return;
			}

			SimpleDateFormat fmt = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS");
			GuideTask guideTask = new GuideTask();
			//相机ID
			@@ -527,6 +597,23 @@
			queueManager.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.getCamAlarmGuideEnable().equals(1)) {
			enabled = true;
			}
			return enabled;
			}

			/**
			@@ -563,6 +650,7 @@
			return minDistanceCameraId;
			}


			public static void main(String[] args) {
			Comparator<Obj> PriorityDescCom = Comparator.comparingInt(Obj::getPriority).reversed();
			Comparator<Obj> NumDescCom = Comparator.comparingInt(Obj::getNum).reversed();
			@@ -588,10 +676,10 @@
			log.info("正在排队【priority】" + task.getPriority()+"【num】" + task.getNum() + "【alarmTime】" + task.getAlarmTime());
			}
			}

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