~liusuyi/ruoyi-api.git

			@@ -13,17 +13,21 @@
			import com.ruoyi.device.dhsdk.common.Res;
			import com.ruoyi.device.dhsdk.lib.NetSDKLib;
			import com.ruoyi.device.dhsdk.lib.NetSDKLib.LLong;
			import com.ruoyi.device.dhsdk.lib.enumeration.EM_FOCUS_LIMIT_SELECT_MODE;
			import com.ruoyi.device.dhsdk.lib.enumeration.EM_NEW_CONFIG;
			import com.ruoyi.device.dhsdk.lib.structure.CFG_VIDEO_IN_FOCUS;
			import com.ruoyi.device.dhsdk.lib.structure.CFG_VIDEO_IN_FOCUS_UNIT;
			import com.ruoyi.device.dhsdk.module.CapturePictureModule;
			import com.ruoyi.device.dhsdk.module.ConfigModule;
			import com.ruoyi.device.dhsdk.module.LoginModule;
			import com.ruoyi.device.dhsdk.module.RealPlayModule;
			import com.ruoyi.device.dhsdk.lib.structure.NET_ENCODE_VIDEO_INFO;
			import com.ruoyi.device.dhsdk.module.*;
			import com.ruoyi.device.dhsdk.service.IDhClientService;
			import com.ruoyi.device.hiksdk.common.GlobalVariable;
			import com.ruoyi.device.hiksdk.sdk.HCNetSDK;
			import com.ruoyi.media.domain.Vtdu;
			import com.ruoyi.media.service.IVtduService;
			import com.ruoyi.media.service.impl.VtduServiceImpl;
			import com.ruoyi.utils.gis.GisUtil;
			import com.ruoyi.utils.minio.MinioUtil;
			import com.ruoyi.utils.tools.ArdTool;
			import com.sun.jna.Pointer;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.beans.factory.annotation.Value;
			@@ -31,20 +35,15 @@
			import org.springframework.stereotype.Service;

			import javax.annotation.Resource;
			import java.io.ByteArrayInputStream;
			import java.io.FileInputStream;
			import java.io.IOException;
			import java.io.InputStream;
			import java.io.*;
			import java.text.DecimalFormat;
			import java.util.*;

			import static com.ruoyi.device.dhsdk.lib.NetSDKLib.NET_DEVSTATE_ONLINE;
			import static com.ruoyi.device.dhsdk.lib.NetSDKLib.NET_DEVSTATE_PTZ_LOCATION;
			import static com.ruoyi.device.dhsdk.lib.NetSDKLib.*;
			import static com.ruoyi.device.dhsdk.lib.NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_MOVE_CONTROL;
			import static com.ruoyi.device.dhsdk.lib.NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_SET_CONTROL;
			import static com.ruoyi.device.dhsdk.lib.ToolKits.getErrorCodePrint;
			import static com.ruoyi.device.dhsdk.module.LoginModule.netsdk;
			import static com.ruoyi.device.hiksdk.sdk.HCNetSDK.NET_DVR_SET_PTZPOS;


			/**
			@@ -61,10 +60,11 @@
			private IArdCamerasService ardCamerasService;
			@Resource
			private IArdChannelService ardChannelService;
			@Resource
			private IVtduService vtduService;
			@Value("${minio.endpoint}")
			private String minioEndPoint;

			private Vector<String> chnlist = new Vector<String>();
			// 设备断线通知回调
			private static DisConnect disConnect = new DisConnect();
			// 网络连接恢复
			@@ -125,13 +125,39 @@
			GlobalVariable.loginMap.put(camera.getId(), loginId);
			//获取最新通道
			for (int i = 1; i < LoginModule.m_stDeviceInfo.byChanNum + 1; i++) {
			chnlist.add(Res.string().getChannel() + " " + String.valueOf(i));
			ArdChannel channel = new ArdChannel();
			channel.setDeviceId(camera.getId());
			AV_CFG_ChannelName av_cfg_channelName = new AV_CFG_ChannelName();
			boolean b = ConfigModule.GetNewDevConfig(loginId, i - 1, CFG_CMD_CHANNELTITLE, av_cfg_channelName);
			if (b) {
			String chanName = null;
			try {
			chanName = new String(av_cfg_channelName.szName, "GBK").trim();
			} catch (UnsupportedEncodingException e) {
			e.printStackTrace();
			}
			channel.setName(chanName);
			} else {
			channel.setName("通道" + i);
			channel.setId(IdUtils.simpleUUID());
			}
			channel.setDeviceId(camera.getId());
			channel.setChanNo(i);
			ardChannelService.insertArdChannel(channel);

			//配置到流媒体
			String name = camera.getId() + "_" + channel.getChanNo();
			String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/cam/realmonitor?channel=" + channel.getChanNo() + "&subtype=0";
			Vtdu vtdu = vtduService.selectVtduByName(name);
			if (vtdu != null) {
			vtduService.deleteVtduByName(name);
			}
			//添加到流媒体
			vtdu = new Vtdu();
			vtdu.setRtspSource(rtspSource);
			vtdu.setName(camera.getId() + "_" + channel.getChanNo());
			vtdu.setIsCode("0");//默认不转码
			vtdu.setMode("1");//默认CPU软解码
			vtdu.setCameraId(camera.getId());
			vtduService.insertVtdu(vtdu);
			}
			} else {
			//log.debug(camera.getIp() + ":" + camera.getPort() + "登录失败");
			@@ -210,58 +236,58 @@
			switch (code) {
			/方向/
			case 1:
			dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTTOP;
			dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTTOP;
			break;
			case 2:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_UP_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_UP_CONTROL;
			break;
			case 3:
			dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTTOP;
			dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTTOP;
			break;
			case 4:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_LEFT_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_LEFT_CONTROL;
			break;
			case 5:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_POINT_LOOP_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_POINT_LOOP_CONTROL;
			break;
			case 6:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_RIGHT_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_RIGHT_CONTROL;
			break;
			case 7:
			dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTDOWN;
			dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_LEFTDOWN;
			break;
			case 8:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_DOWN_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_DOWN_CONTROL;
			break;
			case 9:
			dwPTZCommand = NetSDKLib.NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTDOWN;
			dwPTZCommand = NET_EXTPTZ_ControlType.NET_EXTPTZ_RIGHTDOWN;
			break;
			/焦距/
			case 10:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_ZOOM_ADD_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_ZOOM_ADD_CONTROL;
			break;
			case 11:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_ZOOM_DEC_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_ZOOM_DEC_CONTROL;
			break;
			/焦点/
			case 12:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_FOCUS_ADD_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_FOCUS_ADD_CONTROL;
			break;
			case 13:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_FOCUS_DEC_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_FOCUS_DEC_CONTROL;
			break;
			/光圈/
			case 14:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_APERTURE_ADD_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_APERTURE_ADD_CONTROL;
			break;
			case 15:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_APERTURE_DEC_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_APERTURE_DEC_CONTROL;
			break;
			case 16:
			dwPTZCommand = NetSDKLib.NET_PTZ_ControlType.NET_PTZ_LAMP_CONTROL;
			dwPTZCommand = NET_PTZ_ControlType.NET_PTZ_LAMP_CONTROL;
			break;
			}
			boolean bool = netsdk.CLIENT_DHPTZControlEx(loginId, chanNo - 1, dwPTZCommand, speed, speed, 0, dwStop);
			boolean bool = PtzControlModule.ptzControl(loginId, chanNo - 1, dwPTZCommand, speed, speed, 0, dwStop);
			if (!bool) {
			log.error("控制失败,请稍后重试" + getErrorCodePrint());
			}
			@@ -409,7 +435,7 @@
			if (enable) {
			LLong lRealHandle = new LLong(0);
			if (!GlobalVariable.previewMap.containsKey(cameraId)) {
			lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo, 0);
			lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
			if (lRealHandle.longValue() <= 0) {
			log.error("取流失败" + getErrorCodePrint());
			return "";
			@@ -417,15 +443,11 @@
			log.debug("取流成功");
			GlobalVariable.previewMap.put(cameraId, lRealHandle.intValue());
			}
			if (!netsdk.CLIENT_SaveRealData(lRealHandle, path)) {
			log.error("保存视频文件到临时文件夹失败错误码为: " + getErrorCodePrint());
			return "";
			}
			log.debug("录像开始");
			} else {
			if (GlobalVariable.previewMap.containsKey(cameraId)) {
			LLong lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
			boolean b = netsdk.CLIENT_StopSaveRealData(lRealHandle);
			RealPlayModule.stopRealPlay(lRealHandle);
			GlobalVariable.previewMap.remove(cameraId);
			}
			log.debug("录像停止");
			@@ -450,11 +472,11 @@
			LLong lRealHandle;
			if (GlobalVariable.previewMap.containsKey(cameraId)) {
			lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
			netsdk.CLIENT_StopRealPlayEx(lRealHandle);
			RealPlayModule.stopRealPlay(lRealHandle);
			GlobalVariable.previewMap.remove(cameraId);
			log.debug("停止当前录像");
			}
			lRealHandle = RealPlayModule.startRealPlay1(loginId, chanNo - 1, path);
			lRealHandle = RealPlayModule.startRealPlay(loginId, chanNo - 1, path);
			if (lRealHandle.longValue() <= 0) {
			log.error("取流失败" + getErrorCodePrint());
			}
			@@ -485,7 +507,7 @@
			LLong lRealHandle;
			if (GlobalVariable.previewMap.containsKey(cameraId)) {
			lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
			netsdk.CLIENT_StopRealPlayEx(lRealHandle);
			RealPlayModule.stopRealPlay(lRealHandle);
			GlobalVariable.previewMap.remove(cameraId);
			log.debug("停止当前录像");
			}
			@@ -503,6 +525,29 @@
			log.error("录像异常" + ex.getMessage());
			return "";
			}
			}

			@Override
			public boolean recordStopNotToMinio(CameraCmd cmd) {
			boolean result = false;
			try {
			String cameraId = cmd.getCameraId();
			if (!GlobalVariable.loginMap.containsKey(cameraId)) {
			return false;
			}
			LLong lRealHandle;
			if (GlobalVariable.previewMap.containsKey(cameraId)) {
			lRealHandle = new LLong(GlobalVariable.previewMap.get(cameraId));
			RealPlayModule.stopRealPlay(lRealHandle);
			GlobalVariable.previewMap.remove(cameraId);
			log.debug("停止当前录像");
			}

			result = true;
			} catch (Exception ex) {
			log.error("录像异常" + ex.getMessage());
			}
			return result;
			}

			/**
			@@ -595,14 +640,21 @@
			LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
			try {
			CFG_VIDEO_IN_FOCUS cfg_video_in_focus = new CFG_VIDEO_IN_FOCUS();
			CFG_VIDEO_IN_FOCUS_UNIT[] stVideoInFocusUnit = new CFG_VIDEO_IN_FOCUS_UNIT[32];
			if (enable) {
			stVideoInFocusUnit[0].nMode = 4;//手动聚焦
			cfg_video_in_focus.nVideoInFocusRealNum = 3;//配置使用个数
			for (int i = 0; i < 3; i++) {
			cfg_video_in_focus.stVideoInFocusUnit[i].nSensitivity = 1;//聚焦灵敏度, 0-高, 1-默认, 2-低

			cfg_video_in_focus.stVideoInFocusUnit[i].nIRCorrection = 2;//红外光聚焦修正, 0-不修正, 1-修正, 2-自动修正
			cfg_video_in_focus.stVideoInFocusUnit[i].nFocusLimit = 10000;//聚焦极限值, 单位毫米
			if (enable) {//聚焦模式, 0-关闭, 1-辅助聚焦, 2-自动聚焦, 3-半自动聚焦, 4-手动聚焦
			cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 4;//手动聚焦
			cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 1;//聚焦极限Manual
			} else {
			stVideoInFocusUnit[0].nMode = 2;//手动聚焦
			cfg_video_in_focus.stVideoInFocusUnit[i].nMode = 2;//自动聚焦
			cfg_video_in_focus.stVideoInFocusUnit[i].emFocusMode = 0;//聚焦极限Auto
			}
			}
			cfg_video_in_focus.nChannelIndex = chanNo - 1;
			cfg_video_in_focus.stVideoInFocusUnit = stVideoInFocusUnit;
			boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, NetSDKLib.CFG_CMD_VIDEOIN_FOCUS, cfg_video_in_focus);
			if (!bool) {
			log.error("控制失败,请稍后重试" + getErrorCodePrint());
			@@ -614,6 +666,176 @@
			}
			}

			//透雾
			@Override
			public boolean controlDefogcfg(CameraCmd cmd) {
			String cameraId = cmd.getCameraId();
			Integer chanNo = cmd.getChanNo();
			boolean enable = cmd.isEnable();
			if (!GlobalVariable.loginMap.containsKey(cameraId)) {
			return false;
			}
			LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
			try {
			EM_NEW_CONFIG config = EM_NEW_CONFIG.CFG_CMD_VIDEOINDEFOG;
			//CFG_VIDEOINDEFOG_LIST cfg_videoindefog_list=new CFG_VIDEOINDEFOG_LIST();
			boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, config.getValue(), null);
			if (!bool) {
			log.error("控制失败,请稍后重试" + getErrorCodePrint());
			}
			return bool;
			} catch (Exception ex) {
			log.error("切换透雾异常:" + ex.getMessage());
			return false;
			}
			}

			//红外
			@Override
			public boolean controlInfrarecfg(CameraCmd cmd) {
			String cameraId = cmd.getCameraId();
			Integer chanNo = cmd.getChanNo();
			boolean enable = cmd.isEnable();
			if (!GlobalVariable.loginMap.containsKey(cameraId)) {
			return false;
			}
			LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
			try {
			CFG_LIGHTING_INFO cfg_lighting_info = new CFG_LIGHTING_INFO();
			cfg_lighting_info.nLightingDetailNum = 1;
			if (enable) {
			cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_MANUAL;
			} else {
			cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_OFF;
			}
			boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);
			if (!bool) {
			log.error("控制失败,请稍后重试" + getErrorCodePrint());
			}
			return bool;
			} catch (Exception ex) {
			log.error("切换红外异常:" + ex.getMessage());
			return false;
			}
			}

			//获取聚焦值
			@Override
			public int getFocusPos(CameraCmd cmd) {
			int result = 0;
			try {
			String cameraId = cmd.getCameraId();
			Integer chanNo = cmd.getChanNo();
			if (!GlobalVariable.loginMap.containsKey(cameraId)) {
			return result;
			}
			LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
			NET_PTZ_LOCATION_INFO net_ptz_location_info = new NET_PTZ_LOCATION_INFO();
			net_ptz_location_info.nChannelID = chanNo - 1;
			boolean bool = ConfigModule.queryDevState(loginId, NET_DEVSTATE_PTZ_LOCATION, net_ptz_location_info);
			if (!bool) {
			log.error("控制失败,请稍后重试" + getErrorCodePrint());
			}
			result = net_ptz_location_info.nFocusMapValue;
			} catch (Exception ex) {
			log.error("获取聚焦值异常:" + ex.getMessage());
			}
			return result;
			}

			//设置聚焦值
			@Override
			public boolean setFocusPos(CameraCmd cmd) {
			String cameraId = cmd.getCameraId();
			Integer chanNo = cmd.getChanNo();
			boolean enable = cmd.isEnable();
			if (!GlobalVariable.loginMap.containsKey(cameraId)) {
			return false;
			}
			LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
			try {
			CFG_LIGHTING_INFO cfg_lighting_info = new CFG_LIGHTING_INFO();
			cfg_lighting_info.nLightingDetailNum = 1;
			if (enable) {
			cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_MANUAL;
			} else {
			cfg_lighting_info.stuLightingDetail[0].emMode = EM_CFG_LIGHTING_MODE.EM_CFG_LIGHTING_MODE_OFF;
			}
			boolean bool = ConfigModule.SetDevConfig(loginId, chanNo - 1, CFG_CMD_LIGHTING, cfg_lighting_info);
			if (!bool) {
			log.error("控制失败,请稍后重试" + getErrorCodePrint());
			}
			return bool;
			} catch (Exception ex) {
			log.error("设置聚焦值异常:" + ex.getMessage());
			return false;
			}
			}

			//获取码流压缩参数
			@Override
			public Map<String, Object> getVideoCompressionCfg(CameraCmd cmd) {
			Map<String, Object> map = new HashMap<>();
			String cameraId = cmd.getCameraId();
			Integer chanNo = cmd.getChanNo();
			if (!GlobalVariable.loginMap.containsKey(cameraId)) {
			return null;
			}
			LLong loginId = (LLong) GlobalVariable.loginMap.get(cameraId);
			CFG_ENCODE_INFO cfg_encode_info = new CFG_ENCODE_INFO();
			cfg_encode_info.nChannelID = chanNo - 1;
			boolean b = ConfigModule.GetNewDevConfig(loginId, chanNo - 1, CFG_CMD_ENCODE, cfg_encode_info);
			if (b) {
			int emCompression = cfg_encode_info.stuMainStream[0].stuVideoFormat.emCompression;//视频格式
			String videoEncType = "";
			switch (emCompression) {
			case 0:
			videoEncType = "MPEG4";
			break;
			case 1:
			videoEncType = "MS-MPEG4";
			break;
			case 2:
			videoEncType = "MPEG2";
			break;
			case 3:
			videoEncType = "MPEG1";
			break;
			case 4:
			videoEncType = "H.263";
			break;
			case 5:
			videoEncType = "MJPG";
			break;
			case 6:
			videoEncType = "FCC-MPEG4";
			break;
			case 7:
			videoEncType = "标准h264";
			break;
			case 8:
			videoEncType = "标准h265";
			break;
			case 9:
			videoEncType = "SVAC";
			break;
			default:
			videoEncType = "未知";
			break;
			}
			int nBitRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nBitRate;
			int nWidth = cfg_encode_info.stuMainStream[0].stuVideoFormat.nWidth;
			int nHeight = cfg_encode_info.stuMainStream[0].stuVideoFormat.nHeight;
			String resolution = nWidth + "*" + nHeight;
			float nFrameRate = cfg_encode_info.stuMainStream[0].stuVideoFormat.nFrameRate;
			map.put("resolution", resolution);//分辨率
			map.put("videoBitrate", String.valueOf(nBitRate));//比特率
			map.put("videoEncType", videoEncType);//编码
			map.put("nFrameRate", String.valueOf(nFrameRate));//帧率
			}
			return map;
			}

			// 设备断线回调: 当设备出现断线时，SDK会调用该函数
			private static class DisConnect implements NetSDKLib.fDisConnect {
			public void invoke(LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {