~liusuyi/ruoyi-api.git

			@@ -1,6 +1,7 @@
			package com.ruoyi.alarm.globalAlarm.service.impl;

			import com.ruoyi.alarm.globalAlarm.domain.GuidePriorityQueue;
			import com.ruoyi.alarm.externalAlarm.domain.ArdAlarmExternal;
			import com.ruoyi.alarm.externalAlarm.service.IArdAlarmExternalService;
			import com.ruoyi.alarm.globalAlarm.domain.GuideTask;
			import com.ruoyi.alarm.radarAlarm.domain.ArdAlarmRadar;
			import com.ruoyi.alarm.radarAlarm.service.IArdAlarmRadarService;
			@@ -31,6 +32,8 @@
			IArdAlarmTubeService ardAlarmTubeService;
			@Resource
			IArdAlarmRadarService ardAlarmRadarService;
			@Resource
			IArdAlarmExternalService ardAlarmExternalService;

			public void processTask(GuideTask guideTask) {
			try {
			@@ -41,7 +44,7 @@
			cmd.setOperator(guideTask.getAlarmType());
			cmd.setExpired(30);
			cmd.setRecordBucketName("record");
			cmd.setRecordObjectName("alarm_"+guideTask.getAlarmId());
			cmd.setRecordObjectName("alarm_" + guideTask.getAlarmId());
			log.debug("开始引导");
			boolean guideRes = hikClientService.guideTargetPosition(cmd);
			if (guideRes) {
			@@ -51,7 +54,7 @@
			try {
			Thread.sleep(30000);
			} catch (InterruptedException e) {
			log.info("当前任务ID"+guideTask.getAlarmId()+"线程被终止");
			log.info("当前任务ID" + guideTask.getAlarmId() + "线程被终止");
			}
			String url = hikClientService.recordStopToMinio(cmd);//停止录像返回url
			if (StringUtils.isNotEmpty(url)) {
			@@ -63,6 +66,8 @@
			ardAlarmTubeService.updateArdAlarmTube(ardAlarmTube);
			break;
			case "sys_radar_move":
			case "sys_radar_fire":
			case "sys_radar_pumpshutdown":
			ArdAlarmRadar ardAlarmRadar = new ArdAlarmRadar();
			ardAlarmRadar.setId(guideTask.getAlarmId());
			if (guideTask.getRecordSn().equals(1)) {
			@@ -72,15 +77,11 @@
			}
			ardAlarmRadarService.updateArdAlarmRadar(ardAlarmRadar);
			break;
			case "sys_radar_fire":
			ardAlarmRadar = new ArdAlarmRadar();
			ardAlarmRadar.setId(guideTask.getAlarmId());
			if (guideTask.getRecordSn().equals(1)) {
			ardAlarmRadar.setRecordUrl1(url);
			} else {
			ardAlarmRadar.setRecordUrl2(url);
			}
			ardAlarmRadarService.updateArdAlarmRadar(ardAlarmRadar);
			case "sys_external":
			ArdAlarmExternal ardAlarmExternal = new ArdAlarmExternal();
			ardAlarmExternal.setId(guideTask.getAlarmId());
			ardAlarmExternal.setRecordUrl(url);
			ardAlarmExternalService.updateArdAlarmExternal(ardAlarmExternal);
			break;
			}
			}