package com.ruoyi.device.hiksdk.service.impl; import com.ruoyi.alarm.global.domain.GuidePriorityQueue; import com.ruoyi.alarm.global.domain.GuideTask; import com.ruoyi.common.annotation.SdkOperate; import com.ruoyi.common.utils.file.FileUtils; import com.ruoyi.common.utils.file.MimeTypeUtils; import com.ruoyi.common.utils.uuid.IdUtils; import com.ruoyi.device.camera.domain.CameraCmd; import com.ruoyi.device.camera.service.IArdCamerasService; import com.ruoyi.device.channel.domain.ArdChannel; import com.ruoyi.device.channel.service.IArdChannelService; import com.ruoyi.device.dhsdk.lib.LibraryLoad; import com.ruoyi.device.dhsdk.lib.NetSDKLib; import com.ruoyi.device.hiksdk.common.GlobalVariable; import com.ruoyi.device.camera.domain.ArdCameras; import com.ruoyi.device.hiksdk.sdk.ExceptionCallBack; import com.ruoyi.media.domain.Vtdu; import com.ruoyi.media.service.IVtduService; import com.ruoyi.utils.gis.GisUtil; import com.ruoyi.device.hiksdk.sdk.HCNetSDK; import com.ruoyi.device.hiksdk.service.IHikClientService; import com.ruoyi.device.hiksdk.sdk.LoginResultCallBack; import com.ruoyi.utils.minio.MinioUtil; import com.sun.jna.Native; import com.sun.jna.NativeLong; import com.sun.jna.Platform; import com.sun.jna.Pointer; import com.sun.jna.ptr.IntByReference; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import java.util.Base64; import javax.annotation.Resource; import java.io.*; import java.math.BigDecimal; import java.nio.ByteBuffer; import java.text.DecimalFormat; import java.util.*; import java.util.concurrent.PriorityBlockingQueue; import static com.ruoyi.device.hiksdk.common.GlobalVariable.loginCameraMap; import static com.ruoyi.device.hiksdk.sdk.HCNetSDK.*; /** * @ClassName: hikClientServiceImpl * @Description: 海康操作客户端实现类 * @Author: Administrator * @Date: 2023年01月17日 11:25 * @Version: 1.2 **/ @Slf4j(topic = "hikSdk") @Service public class HikClientServiceImpl implements IHikClientService { @Resource private IArdCamerasService ardCamerasService; @Resource private IArdChannelService ardChannelService; @Resource private IVtduService vtduService; public static HCNetSDK hCNetSDK = HCNetSDK.hCNetSDK; private static FExceptionCallBack fExceptionCallBack;//异常回调 /** * @描述 注册登录 只支持同步登陆，且官方不建议直接在此接口下写耗时操作 * @参数 [dvrLogin] * @返回值 java.lang.Integer * @创建人 刘苏义 * @创建时间 2023/1/17 16:12 * @修改人和其它信息 */ @Override public void login(ArdCameras camera) { // 初始化 if (!hCNetSDK.NET_DVR_Init()) { log.error("SDK初始化失败"); } //打印海康sdk日志 if (Platform.isWindows()) { String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator; hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true); } else { hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true); } String m_sDeviceIP = camera.getIp(); String m_sUsername = camera.getUsername(); String m_sPassword = camera.getPassword(); short m_sPort = camera.getPort().shortValue(); //设置连接时间与重连时间 hCNetSDK.NET_DVR_SetConnectTime(2000, 1); hCNetSDK.NET_DVR_SetReconnect(5000, true); //设备信息, 输出参数 HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40(); HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO(); // 注册设备-登录参数，包括设备地址、登录用户、密码等 m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN]; System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length()); m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN]; System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length()); m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN]; System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length()); m_strLoginInfo.wPort = m_sPort; m_strLoginInfo.byVerifyMode = 0; m_strLoginInfo.byLoginMode = 0; //是否异步登录：0- 否，1- 是 windowsSDK里是true和false m_strLoginInfo.bUseAsynLogin = false; m_strLoginInfo.write(); //同步登录 int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo); if (lUserID < 0) { int errorCode = hCNetSDK.NET_DVR_GetLastError(); log.debug(camera.getIp() + ":" + camera.getPort() + "登录失败,错误码："+errorCode); camera.setChanNum(0); camera.setLoginId(-1); camera.setState("0"); } else { if (fExceptionCallBack == null) { fExceptionCallBack = new ExceptionCallBack();//异常回调 //设置异常回调函数(可在回调函数中获取设备上下线状态等) if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) { log.info("Set fExceptionCallBack function fail"); return; } else { log.info("Set fExceptionCallBack function successfully!"); } } if (GlobalVariable.loginMap.containsKey(camera.getId())) { GlobalVariable.loginMap.remove(camera.getId()); } //删除管理通道 ardChannelService.deleteArdChannelByDeviceId(camera.getId()); GlobalVariable.loginMap.put(camera.getId(), lUserID); GlobalVariable.loginCameraMap.put(lUserID,camera); log.debug("Login Success [ " + camera.getIp() + ":" + camera.getPort() + " ]"); camera.setLoginId(lUserID); camera.setState("1"); camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum); camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan); //获取最新通道 List cameraChannelList = getCameraChannelList(camera); if (cameraChannelList.size() > 0) { for (ArdChannel channel : cameraChannelList) { channel.setId(IdUtils.simpleUUID()); ardChannelService.insertArdChannel(channel); } //添加到流媒体 for (ArdChannel channel : cameraChannelList) { String name = camera.getId() + "_" + channel.getChanNo(); String rtspSource = "rtsp://" + camera.getUsername() + ":" + camera.getPassword() + "@" + camera.getIp() + ":" + camera.getRtspPort() + "/h264/ch" + channel.getChanNo() + "/main/av_stream"; Vtdu vtdu = vtduService.selectVtduByName(name); if (vtdu != null) { vtduService.deleteVtduByName(name); } //添加到流媒体 vtdu = new Vtdu(); vtdu.setRtspSource(rtspSource); vtdu.setName(camera.getId() + "_" + channel.getChanNo()); CameraCmd cmd = new CameraCmd(camera.getId(), channel.getChanNo()); Map videoCompressionCfg = getVideoCompressionCfg(cmd); if (videoCompressionCfg.get("videoEncType").equals("标准h264")) { vtdu.setIsCode("0");//默认不转码 } else { vtdu.setIsCode("1");//默认转码 } vtdu.setMode("1");//默认CPU软解码 vtdu.setCameraId(camera.getId()); vtduService.insertVtdu(vtdu); } } //创建引导队列 if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) { Comparator comparator = GuidePriorityQueue.getComparator(); PriorityBlockingQueue priorityQueue = new PriorityBlockingQueue<>(1000, comparator); GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue); } ardCamerasService.updateArdCameras(camera); } } /** * @描述 注册登录 集成于NET_DVR_Login_V30，支持同步和异步登录 * @参数 [dvrLogin] * @返回值 java.lang.Integer * @创建人 刘苏义 * @创建时间 2023/1/17 16:12 * @修改人和其它信息 */ @Override public void asyncLogin(ArdCameras camera) { // 初始化 if (!hCNetSDK.NET_DVR_Init()) { log.error("SDK初始化失败"); } //打印海康sdk日志 if (Platform.isWindows()) { String WIN_PATH = System.getProperty("user.dir") + File.separator + "ardLog" + File.separator + "logs" + File.separator; hCNetSDK.NET_DVR_SetLogToFile(3, WIN_PATH, true); } else { hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", true); } String m_sDeviceIP = camera.getIp(); String m_sUsername = camera.getUsername(); String m_sPassword = camera.getPassword(); short m_sPort = camera.getPort().shortValue(); //设置连接时间与重连时间 hCNetSDK.NET_DVR_SetConnectTime(2000, 1); hCNetSDK.NET_DVR_SetReconnect(100000, true); //设备信息, 输出参数 HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40(); HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO(); // 注册设备-登录参数，包括设备地址、登录用户、密码等 m_strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN]; System.arraycopy(m_sDeviceIP.getBytes(), 0, m_strLoginInfo.sDeviceAddress, 0, m_sDeviceIP.length()); m_strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN]; System.arraycopy(m_sUsername.getBytes(), 0, m_strLoginInfo.sUserName, 0, m_sUsername.length()); m_strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN]; System.arraycopy(m_sPassword.getBytes(), 0, m_strLoginInfo.sPassword, 0, m_sPassword.length()); m_strLoginInfo.wPort = m_sPort; m_strLoginInfo.byVerifyMode = 0; m_strLoginInfo.byLoginMode = 0; //是否异步登录：0- 否，1- 是 windowsSDK里是true和false m_strLoginInfo.bUseAsynLogin = true; //异步登录回调 m_strLoginInfo.cbLoginResult = new LoginResultCallBack(camera); m_strLoginInfo.write(); int i = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo); if (i < 0) { int errorCode = hCNetSDK.NET_DVR_GetLastError(); log.error("登录异常：" + errorCode); } } /** * @描述 登录所有相机 * @参数 [] * @返回值 void * @创建人 刘苏义 * @创建时间 2023/2/3 10:10 * @修改人和其它信息 */ @Override public void loginAll() { try { ArdCameras ardCamera = new ArdCameras(); ardCamera.setFactory("1"); List ardCameras = ardCamerasService.selectArdCamerasListNoDataScope(ardCamera); for (ArdCameras camera : ardCameras) { //登录 login(camera); } } catch (Exception ex) { log.error("初始化登录相机异常：" + ex.getMessage()); } } /** * @描述 注销登录 * @参数 [dvrLogin] * @返回值 java.lang.Integer * @创建人 刘苏义 * @创建时间 2023/1/17 16:12 * @修改人和其它信息 */ @Override public boolean logout(String cameraId) { if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); boolean b = hCNetSDK.NET_DVR_Logout(userId); if (b) { GlobalVariable.loginMap.remove(cameraId); } return b; } /** * 是否在线 * * @param cmd 相机命令 */ @Override public boolean isOnLine(CameraCmd cmd) { try { String cameraId = cmd.getCameraId(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); return hCNetSDK.NET_DVR_RemoteControl(userId, NET_DVR_CHECK_USER_STATUS, null, 0); } catch (Exception ex) { log.error("检测在线异常：" + ex.getMessage()); return false; } } /** * @描述 带速度的云台控制操作 * Code:1-左上 2-上 3-右上 4-左 5-巡航 6-右 7-左下 8-下 9-右下 10-焦距变大 11-焦距变小 * 12-焦点前调 13-焦点后调 14-光圈扩大 15-光圈缩小 16-雨刷开启 * @参数 [userId, channelNum, speed] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/17 16:14 * @修改人和其它信息 */ @Override public boolean pTZControlWithSpeed(CameraCmd cmd) { String cameraId = cmd.getCameraId(); boolean enable = cmd.isEnable(); Integer channelNum = cmd.getChanNo(); Integer speed = cmd.getSpeed(); Integer code = cmd.getCode(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); int dwStop; if (enable) { dwStop = 0;//开启 } else { dwStop = 1;//关闭 } int dwPTZCommand = -1; switch (code) { /*方向*/ case 1: dwPTZCommand = HCNetSDK.UP_LEFT; break; case 2: dwPTZCommand = HCNetSDK.TILT_UP; break; case 3: dwPTZCommand = HCNetSDK.UP_RIGHT; break; case 4: dwPTZCommand = HCNetSDK.PAN_LEFT; break; case 5: dwPTZCommand = HCNetSDK.RUN_SEQ; break; case 6: dwPTZCommand = HCNetSDK.PAN_RIGHT; break; case 7: dwPTZCommand = HCNetSDK.DOWN_LEFT; break; case 8: dwPTZCommand = HCNetSDK.TILT_DOWN; break; case 9: dwPTZCommand = HCNetSDK.DOWN_RIGHT; break; /*焦距*/ case 10: dwPTZCommand = HCNetSDK.ZOOM_IN; break; case 11: dwPTZCommand = HCNetSDK.ZOOM_OUT; break; /*焦点*/ case 12: dwPTZCommand = HCNetSDK.FOCUS_NEAR; break; case 13: dwPTZCommand = HCNetSDK.FOCUS_FAR; break; /*光圈*/ case 14: dwPTZCommand = HCNetSDK.IRIS_OPEN; break; case 15: dwPTZCommand = HCNetSDK.IRIS_CLOSE; break; /*雨刷*/ case 16: dwPTZCommand = HCNetSDK.WIPER_PWRON; break; } boolean bool = hCNetSDK.NET_DVR_PTZControlWithSpeed_Other(userId, channelNum, dwPTZCommand, dwStop, speed); if (!bool) { int errorCode = hCNetSDK.NET_DVR_GetLastError(); log.error("控制失败,请稍后重试" + errorCode); } return bool; } /** * 设置聚焦值 * * @param cmd 相机命令 */ @Override public boolean setFocusPos(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); Integer dwFocusPos = cmd.getDwFocusPos(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } // 获取参数 Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); HCNetSDK.NET_DVR_STD_CONFIG struStdCfg = new HCNetSDK.NET_DVR_STD_CONFIG(); HCNetSDK.NET_DVR_GIS_INFO struGisInfo = new HCNetSDK.NET_DVR_GIS_INFO(); struGisInfo.struPtzPosEx.dwFocus = dwFocusPos; struStdCfg.read(); IntByReference lchannel = new IntByReference(channelNum); struStdCfg.lpInBuffer = struGisInfo.getPointer(); struStdCfg.lpCondBuffer = lchannel.getPointer(); struStdCfg.dwCondSize = 4; struStdCfg.dwInSize = struGisInfo.size(); struStdCfg.write();//设置前之前要write() boolean bool = hCNetSDK.NET_DVR_SetSTDConfig(userId, NET_DVR_GET_GISINFO, struStdCfg); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置GIS信息数据失败,请稍后重试" + code); return false; } else { return true; } } /** * 获取聚焦值 * * @param cmd 相机命令 */ @Override public int getFocusPos(CameraCmd cmd) { int result = 0; String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return result; } // 获取参数 Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); HCNetSDK.NET_DVR_STD_CONFIG struStdCfg = new HCNetSDK.NET_DVR_STD_CONFIG(); HCNetSDK.NET_DVR_GIS_INFO struGisInfo = new HCNetSDK.NET_DVR_GIS_INFO(); struStdCfg.read(); IntByReference lchannel = new IntByReference(channelNum); struStdCfg.lpCondBuffer = lchannel.getPointer(); struStdCfg.dwCondSize = 4; struStdCfg.lpOutBuffer = struGisInfo.getPointer(); struStdCfg.dwOutSize = struGisInfo.size(); struStdCfg.write();//设置前之前要write() boolean bool = hCNetSDK.NET_DVR_GetSTDConfig(userId, NET_DVR_GET_GISINFO, struStdCfg); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("获取GIS信息数据失败,请稍后重试" + code); return result; } else { struGisInfo.read(); result = struGisInfo.struPtzPosEx.dwFocus; } return result; } /** * 设置预置点 * * @param cmd 相机命令 */ @Override public boolean setPreset(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); Integer PresetIndex = cmd.getPresetIndex(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); boolean bool = hCNetSDK.NET_DVR_PTZPreset_Other(userId, channelNum, SET_PRESET, PresetIndex); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("预置点设置失败,请稍后重试" + code); } return bool; } /** * 转到预置点 * * @param cmd 相机命令 */ @Override public boolean gotoPreset(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); Integer PresetIndex = cmd.getPresetIndex(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); boolean bool = hCNetSDK.NET_DVR_PTZPreset_Other(userId, channelNum, GOTO_PRESET, PresetIndex); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("预置点设置失败,请稍后重试" + code); } return bool; } /** * @描述 获取通道压缩参数 * @参数 [cameraId, channelNum] * @返回值 java.lang.String * @创建人 刘苏义 * @创建时间 2023/2/3 8:36 * @修改人和其它信息 */ @Override public Map getVideoCompressionCfg(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer chanNo = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return null; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); Map map = new HashMap<>(); NET_DVR_COMPRESSIONCFG_V30 compressioncfg = new NET_DVR_COMPRESSIONCFG_V30(); compressioncfg.write(); Pointer pioint = compressioncfg.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); try { boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, HCNetSDK.NET_DVR_GET_COMPRESSCFG_V30, chanNo, pioint, compressioncfg.size(), ibrBytesReturned); if (bool) { compressioncfg.read(); //码流类型：0-视频流，1-复合流，0xfe- 自动（和源一致） String streamType = ""; switch (compressioncfg.struNormHighRecordPara.byStreamType) { case 0: streamType = "视频流"; break; case 1: streamType = "复合流"; break; default: streamType = "未知"; break; } //视频编码类型：0-私有264，1-标准h264，2-标准mpeg4，7-M-JPEG，8-MPEG2，9-SVAC，10-标准h265，0xfe- 自动（和源一致），0xff-无效 String videoEncType = ""; switch (compressioncfg.struNormHighRecordPara.byVideoEncType) { case 0: videoEncType = "私有264"; break; case 1: videoEncType = "标准h264"; break; case 2: videoEncType = "标准mpeg4"; break; case 7: videoEncType = "M-JPEG"; break; case 8: videoEncType = "MPEG2"; break; case 9: videoEncType = "SVAC"; break; case 10: videoEncType = "标准h265"; break; default: videoEncType = "未知"; break; } //视频码率 String videoBitrate = ""; switch (compressioncfg.struNormHighRecordPara.dwVideoBitrate) { case 0: videoBitrate = "保留"; break; case 1: videoBitrate = "16(保留)"; break; case 2: videoBitrate = "32"; break; case 3: videoBitrate = "48"; break; case 4: videoBitrate = "64"; break; case 5: videoBitrate = "80"; break; case 6: videoBitrate = "96"; break; case 7: videoBitrate = "128"; break; case 8: videoBitrate = "160"; break; case 9: videoBitrate = "192"; break; case 10: videoBitrate = "224"; break; case 11: videoBitrate = "256"; break; case 12: videoBitrate = "320"; break; case 13: videoBitrate = "384"; break; case 14: videoBitrate = "448"; break; case 15: videoBitrate = "512"; break; case 16: videoBitrate = "640"; break; case 17: videoBitrate = "768"; break; case 18: videoBitrate = "896"; break; case 19: videoBitrate = "1024"; break; case 20: videoBitrate = "1280"; break; case 21: videoBitrate = "1536"; break; case 22: videoBitrate = "1792"; break; case 23: videoBitrate = "2048K"; break; case 24: videoBitrate = "3072"; break; case 25: videoBitrate = "4096"; break; case 26: videoBitrate = "8192"; break; case 27: videoBitrate = "16384"; break; default: videoBitrate = "其他"; break; } //视频输出口分辨率：0- 1024x768，1- 1280x720，2-1280x1024，3- 1680x1050，4- 1920x1080，5- 3840*2160 String resolution = ""; switch (compressioncfg.struNormHighRecordPara.byResolution) { case 0: resolution = "528*384/528*320"; break; case 1: resolution = "352*288/352*240"; break; case 2: resolution = "176*144/176*120"; break; case 3: resolution = "704*576/704*480"; break; case 4: resolution = "704*288/704*240"; break; case 6: resolution = "320*240"; break; case 7: resolution = "160*120"; break; case 16: resolution = "640*480"; break; case 17: resolution = "1600*1200"; break; case 18: resolution = "800*600"; break; case 19: resolution = "1280*720"; break; case 20: resolution = "1280*960"; break; case 21: resolution = "1600*900"; break; case 22: resolution = "1360*1024"; break; case 23: resolution = "1536*1536"; break; case 24: resolution = "1920*1920"; break; case 27: resolution = "1920*1080"; break; case 28: resolution = "2560*1920"; break; case 29: resolution = "1600*304"; break; case 30: resolution = "2048*1536"; break; default: resolution = "不在当前分辨率索引，请联系管理员添加"; break; } //帧率 String nFrameRate = ""; switch (compressioncfg.struNormHighRecordPara.dwVideoFrameRate) { case 0: nFrameRate = "0"; break; case 1: nFrameRate = "1/16"; break; case 2: nFrameRate = "1/8"; break; case 3: nFrameRate = "1/4"; break; case 4: nFrameRate = "1/2"; break; case 5: nFrameRate = "1"; break; case 6: nFrameRate = "2"; break; case 7: nFrameRate = "4"; break; case 8: nFrameRate = "6"; break; case 9: nFrameRate = "8"; break; case 10: nFrameRate = "10"; break; case 11: nFrameRate = "12"; break; case 12: nFrameRate = "16"; break; case 13: nFrameRate = "20"; break; case 14: nFrameRate = "15"; break; case 15: nFrameRate = "18"; break; case 16: nFrameRate = "22"; break; case 17: nFrameRate = "25"; break; case 18: nFrameRate = "30"; break; case 19: nFrameRate = "35"; break; case 20: nFrameRate = "40"; break; default: nFrameRate = "未知"; break; } map.put("resolution", resolution);//分辨率 map.put("videoBitrate", videoBitrate);//比特率 map.put("videoEncType", videoEncType);//编码 map.put("nFrameRate", nFrameRate);//帧率 } else { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("控制失败,请稍后重试" + code); } } catch (Exception ex) { log.error(ex.getMessage()); } return map; } /** * @描述 获取ptz信息 * @参数 [userId, channelNum] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/17 16:36 * @修改人和其它信息 */ @Override public Map getPtz(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return new HashMap<>(); } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS(); Pointer pioint = m_ptzPosCurrent.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); m_ptzPosCurrent.write(); boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, HCNetSDK.NET_DVR_GET_PTZPOS, channelNum, pioint, m_ptzPosCurrent.size(), ibrBytesReturned); if (bool) { m_ptzPosCurrent.read(); // DecimalFormat df = new DecimalFormat("0.0");//设置保留位数 //16进制转Integer后除10，保留小数点1位 //实际显示的PTZ值是获取到的十六进制值的十分之一， //如获取的水平参数P的值是0x1750，实际显示的P值为175度； //获取到的垂直参数T的值是0x0789，实际显示的T值为78.9度； //获取到的变倍参数Z的值是0x1100，实际显示的Z值为110倍。 BigDecimal b = new BigDecimal((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wPanPos)) / 10); BigDecimal c = new BigDecimal((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPos)) / 10); BigDecimal d = new BigDecimal((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wZoomPos)) / 10); double p = b.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue(); double t = c.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue(); double z = d.setScale(1, BigDecimal.ROUND_HALF_UP).doubleValue(); //log.debug("T垂直参数为: " + p + "P水平参数为: " + t + "Z变倍参数为: " + z); Map ptzMap = new HashMap<>(); ptzMap.put("p", p); ptzMap.put("t", t); ptzMap.put("z", z); return ptzMap; } else { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("控制失败,请稍后重试" + code); return new HashMap<>(); } } /** * @描述 设置ptz信息 * @参数 [userId, channelNum] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/17 16:36 * @修改人和其它信息 注意俯仰角度负值需要加上360得到的正值进行设置 */ @Override public boolean setPtz(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); Map ptz = cmd.getPtzMap(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS(); m_ptzPosCurrent.wAction = 1; try { String p = String.valueOf((int) (ptz.get("p") * 10)); String t = String.valueOf((int) (ptz.get("t") * 10)); String z = String.valueOf((int) (ptz.get("z") * 10)); m_ptzPosCurrent.wPanPos = (short) (Integer.parseInt(p, 16)); m_ptzPosCurrent.wTiltPos = (short) (Integer.parseInt(t, 16)); m_ptzPosCurrent.wZoomPos = (short) (Integer.parseInt(z, 16)); Pointer point = m_ptzPosCurrent.getPointer(); m_ptzPosCurrent.write(); boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_PTZPOS, channelNum, point, m_ptzPosCurrent.size()); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置ptz失败,请稍后重试" + code); } return bool; } catch (Exception ex) { log.error(ex.getMessage()); return false; } } @Override public boolean guideTargetPosition(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS(); m_ptzPosCurrent.wAction = 1; try { ArdCameras cameras = ardCamerasService.selectArdCamerasById(cameraId); double[] cameraPositon = new double[]{cameras.getLongitude(), cameras.getLatitude(), cameras.getAltitude()}; double[] targetPositions = cmd.getTargetPosition(); double[] cameraPTZ = GisUtil.getCameraPTZ(cameraPositon, targetPositions, 20, 150); String p = String.valueOf((int) (cameraPTZ[0] * 10)); String t = String.valueOf((int) (cameraPTZ[1] * 10)); String z = String.valueOf((int) (cameraPTZ[2] * 10)); m_ptzPosCurrent.wPanPos = (short) (Integer.parseInt(p, 16)); m_ptzPosCurrent.wTiltPos = (short) (Integer.parseInt(t, 16)); m_ptzPosCurrent.wZoomPos = (short) (Integer.parseInt(z, 16)); Pointer point = m_ptzPosCurrent.getPointer(); m_ptzPosCurrent.write(); boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_PTZPOS, channelNum, point, m_ptzPosCurrent.size()); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置ptz失败,请稍后重试" + code); } return bool; } catch (Exception ex) { log.error("引导异常:" + ex.getMessage()); return false; } } /** * @描述 获取ptz锁定信息 * @参数 [userId, channelNum] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/17 16:36 * @修改人和其它信息 0-解锁 1-锁定 */ @Override public int getPTZLockInfo(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return -1; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_PTZ_LOCKCFG netDvrPtzLockcfg = new NET_DVR_PTZ_LOCKCFG(); Pointer point = netDvrPtzLockcfg.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); netDvrPtzLockcfg.write(); boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_PTZLOCKCFG, channelNum, point, netDvrPtzLockcfg.size(), ibrBytesReturned); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("获取ptz锁定信息失败,请稍后重试" + code); return -1; } else { netDvrPtzLockcfg.read(); return netDvrPtzLockcfg.byWorkMode; } } /** * @描述 设置零方位角 * @参数 [userId, channelNum] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/17 16:36 * @修改人和其它信息 注意俯仰角度负值需要加上360得到的正值进行设置 */ @Override @SdkOperate public boolean setZeroPtz(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_INITIALPOSITIONCTRL initialpositionctrl = new NET_DVR_INITIALPOSITIONCTRL(); initialpositionctrl.dwSize = initialpositionctrl.size(); initialpositionctrl.byWorkMode = 0; initialpositionctrl.dwChan = Short.parseShort(channelNum.toString()); Pointer point = initialpositionctrl.getPointer(); initialpositionctrl.write(); boolean bool = hCNetSDK.NET_DVR_RemoteControl(userId, NET_DVR_PTZ_INITIALPOSITIONCTRL, point, initialpositionctrl.size()); if (!bool) { int i = hCNetSDK.NET_DVR_GetLastError(); log.error("错误码：" + i); } return bool; } /** * @描述 获取球机PTZ参数取值范围 * @参数 [cameraId, channelNum] * @返回值 java.util.Map * @创建人 刘苏义 * @创建时间 2023/2/8 10:58 * @修改人和其它信息 */ @Override public Map getPtzScope(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return new HashMap<>(); } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_PTZSCOPE m_ptzPosCurrent = new NET_DVR_PTZSCOPE(); Pointer point = m_ptzPosCurrent.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); m_ptzPosCurrent.write(); boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_PTZSCOPE, channelNum, point, m_ptzPosCurrent.size(), ibrBytesReturned); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置ptz失败,请稍后重试" + code); return new HashMap<>(); } else { m_ptzPosCurrent.read(); DecimalFormat df = new DecimalFormat("0.0");//设置保留位数 String wPanPosMax = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wPanPosMax)) / 10); String wPanPosMin = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPosMax)) / 10); String wTiltPosMax = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPosMax)) / 10); String wTiltPosMin = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wTiltPosMin)) / 10); String wZoomPosMax = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wZoomPosMax)) / 10); String wZoomPosMin = df.format((float) Integer.parseInt(Integer.toHexString(m_ptzPosCurrent.wZoomPosMin)) / 10); Map ptzScopeMap = new HashMap<>(); ptzScopeMap.put("pMax", wPanPosMax); ptzScopeMap.put("pMin", wPanPosMin); ptzScopeMap.put("tMax", wTiltPosMax); ptzScopeMap.put("tMin", wTiltPosMin); ptzScopeMap.put("zMax", wZoomPosMax); ptzScopeMap.put("zMin", wZoomPosMin); return ptzScopeMap; } } /** * @描述 透雾开关 * @参数 [userId, channelNum, enable] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/18 13:07 * @修改人和其它信息 */ @Override @SdkOperate public boolean controlDefogcfg(CameraCmd cmd) { String cameraId = cmd.getCameraId(); boolean enable = cmd.isEnable(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_CAMERAPARAMCFG_EX struCameraParam = new NET_DVR_CAMERAPARAMCFG_EX(); Pointer point = struCameraParam.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG_EX, channelNum, point, struCameraParam.size(), ibrBytesReturned); if (!b_GetCameraParam) { log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError()); } struCameraParam.read(); log.debug("是否开启透雾：" + struCameraParam.struDefogCfg.byMode); NET_DVR_DEFOGCFG defogcfg = new NET_DVR_DEFOGCFG(); if (enable) { defogcfg.byMode = 2;//0-不启用 1-自动模式 2-常开模式 defogcfg.byLevel = 100;//取值范围0-100 } else { defogcfg.byMode = 0;//0-不启用 1-自动模式 2-常开模式 } struCameraParam.struDefogCfg = defogcfg; struCameraParam.write(); boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, channelNum, point, struCameraParam.size()); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置透雾失败,请稍后重试" + code); } log.debug("设置透雾成功"); return bool; } /** * @描述 红外开关 * @参数 [userId, channelNum, enable] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/18 13:07 * @修改人和其它信息 */ @Override @SdkOperate public boolean controlInfrarecfg(CameraCmd cmd) { String cameraId = cmd.getCameraId(); boolean enable = cmd.isEnable(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_CAMERAPARAMCFG_EX struDayNigh = new NET_DVR_CAMERAPARAMCFG_EX(); Pointer point = struDayNigh.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG_EX, channelNum, point, struDayNigh.size(), ibrBytesReturned); if (!b_GetCameraParam) { log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError()); } struDayNigh.read(); log.debug("是否开启夜视：" + struDayNigh.struDayNight.byDayNightFilterType); NET_DVR_DAYNIGHT daynight = new NET_DVR_DAYNIGHT(); if (enable) { daynight.byDayNightFilterType = 1;//夜晚 } else { daynight.byDayNightFilterType = 0;//白天 } daynight.bySwitchScheduleEnabled = 1; daynight.byDayNightFilterTime = 60; struDayNigh.struDayNight = daynight; struDayNigh.write(); boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, channelNum, point, struDayNigh.size()); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置夜视失败,请稍后重试" + code); } log.debug("设置夜视成功"); return bool; } /** * @描述 聚焦开关 * @参数 [userId, channelNum, enable] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/18 13:07 * @修改人和其它信息 */ @Override @SdkOperate public boolean controlFocusMode(CameraCmd cmd) { String cameraId = cmd.getCameraId(); boolean enable = cmd.isEnable(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_FOCUSMODE_CFG struFocusMode = new NET_DVR_FOCUSMODE_CFG(); Pointer point = struFocusMode.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_FOCUSMODECFG, channelNum, point, struFocusMode.size(), ibrBytesReturned); if (!b_GetCameraParam) { log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError()); } struFocusMode.read(); log.debug("当前聚焦模式：" + struFocusMode.byFocusMode); if (enable) { struFocusMode.byFocusMode = 1;//手动聚焦 } else { struFocusMode.byAutoFocusMode = 1; struFocusMode.byFocusMode = 2;//自动聚焦 } struFocusMode.byFocusDefinitionDisplay = 1; struFocusMode.byFocusSpeedLevel = 3; struFocusMode.write(); boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_FOCUSMODECFG, channelNum, point, struFocusMode.size()); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置聚焦模式失败,请稍后重试" + code); } log.debug("设置聚焦模式成功"); return bool; } /** * @描述 获取聚焦模式 * @参数 [userId, channelNum] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/18 13:07 * @修改人和其它信息 */ public String getFocusMode(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return ""; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_FOCUSMODE_CFG struFocusMode = new NET_DVR_FOCUSMODE_CFG(); Pointer point = struFocusMode.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_FOCUSMODECFG, channelNum, point, struFocusMode.size(), ibrBytesReturned); if (!b_GetCameraParam) { log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError()); } struFocusMode.read(); log.debug("当前聚焦模式：" + struFocusMode.byFocusMode); return String.valueOf(struFocusMode.byFocusMode); } /** * @描述 云台加热开关 * @参数 [userId, channelNum, enable] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/18 13:07 * @修改人和其它信息 */ @Override @SdkOperate public boolean controlPTHeateRpwron(CameraCmd cmd) { String cameraId = cmd.getCameraId(); boolean enable = cmd.isEnable(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); int dwStop; if (enable) { dwStop = 0;//开启 } else { dwStop = 1;//关闭 } boolean bool = hCNetSDK.NET_DVR_PTZControl_Other(userId, channelNum, HEATER_PWRON, dwStop); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置云台加热失败,请稍后重试" + code); } log.debug("设置云台加热成功"); return bool; } /** * @描述 镜头加热开关 * @参数 [userId, channelNum, enable] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/18 13:07 * @修改人和其它信息 */ @Override @SdkOperate public boolean controlCameraDeicing(CameraCmd cmd) { String cameraId = cmd.getCameraId(); boolean enable = cmd.isEnable(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_DEVSERVER_CFG struDeicing = new NET_DVR_DEVSERVER_CFG(); Pointer point = struDeicing.getPointer(); IntByReference ibrBytesReturned = new IntByReference(0); boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_DEVSERVER_CFG, channelNum, point, struDeicing.size(), ibrBytesReturned); if (!b_GetCameraParam) { log.error("获取前端参数失败，错误码：" + hCNetSDK.NET_DVR_GetLastError()); } struDeicing.read(); log.debug("是否开启除冰：" + struDeicing.byEnableDeicing); if (enable) { struDeicing.byEnableDeicing = 1;//开启 } else { struDeicing.byEnableDeicing = 0;//关闭 } struDeicing.write(); boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_DEVSERVER_CFG, channelNum, point, struDeicing.size()); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("设置镜头除冰失败,请稍后重试" + code); } log.debug("设置镜头除冰成功"); return bool; } /** * 截图 返给前端 * * @param cmd 相机命令 */ public String captureJPEGPicture(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return ""; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); NET_DVR_WORKSTATE_V30 devwork = new NET_DVR_WORKSTATE_V30(); if (!hCNetSDK.NET_DVR_GetDVRWorkState_V30(userId, devwork)) { // 返回Boolean值，判断是否获取设备能力 log.error("抓图失败，请稍后重试"); } //图片质量 NET_DVR_JPEGPARA jpeg = new NET_DVR_JPEGPARA(); //设置图片分辨率 jpeg.wPicSize = 0; //设置图片质量 jpeg.wPicQuality = 0; IntByReference a = new IntByReference(); //设置图片大小 ByteBuffer jpegBuffer = ByteBuffer.allocate(1024 * 1024); // 抓图到内存，单帧数据捕获并保存成JPEG存放在指定的内存空间中 boolean is = hCNetSDK.NET_DVR_CaptureJPEGPicture_NEW(userId, channelNum, jpeg, jpegBuffer, 1024 * 1024, a); log.debug("-----------这里开始图片存入内存----------" + is); Base64.Encoder decoder = Base64.getEncoder(); // BASE64Encoder encoder = new BASE64Encoder(); String png_base64 = decoder.encodeToString(jpegBuffer.array());//转换成base64串 png_base64 = png_base64.replaceAll("\n", "").replaceAll("\r", "");//删除 \r\n log.debug("-----------处理完成截图数据----------"); return png_base64; } /** * @描述 截图 存服务器 * @参数 [cameraId, channelNum] * @返回值 java.lang.String * @创建人 刘苏义 * @创建时间 2023/2/2 14:59 * @修改人和其它信息 */ @Override @SdkOperate public String picCutCate(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return ""; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); //图片信息 NET_DVR_JPEGPARA jpeg = new NET_DVR_JPEGPARA(); //设置图片分辨率 //图片尺寸：0-CIF(352*288/352*240)，1-QCIF(176*144/176*120)，2-4CIF(704*576/704*480)或D1(720*576/720*486)，3-UXGA(1600*1200)， // 4-SVGA(800*600)，5-HD720P(1280*720)，6-VGA(640*480)，7-XVGA(1280*960)，8-HD900P(1600*900)，9-HD1080P(1920*1080)，10-2560*1920， // 11-1600*304，12-2048*1536，13-2448*2048，14-2448*1200，15-2448*800，16-XGA(1024*768)，17-SXGA(1280*1024)，18-WD1(960*576/960*480), // 19-1080I(1920*1080)，20-576*576，21-1536*1536，22-1920*1920，23-320*240，24-720*720，25-1024*768，26-1280*1280，27-1600*600， // 28-2048*768，29-160*120，75-336*256，78-384*256，79-384*216，80-320*256，82-320*192，83-512*384，127-480*272，128-512*272， 161-288*320， // 162-144*176，163-480*640，164-240*320，165-120*160，166-576*720，167-720*1280，168-576*960，180-180*240, 181-360*480, 182-540*720, // 183-720*960, 184-960*1280, 185-1080*1440, 500-384*288, 0xff-Auto(使用当前码流分辨率) jpeg.wPicSize = 0; //设置图片质量：0-最好，1-较好，2-一般 jpeg.wPicQuality = 0; IntByReference a = new IntByReference(); //设置图片大小 ByteBuffer jpegBuffer = ByteBuffer.allocate(1024 * 1024); // 抓图到内存，单帧数据捕获并保存成JPEG存放在指定的内存空间中 log.debug("-----------这里开始封装 NET_DVR_CaptureJPEGPicture_NEW---------"); boolean is = hCNetSDK.NET_DVR_CaptureJPEGPicture_NEW(userId, channelNum, jpeg, jpegBuffer, 1024 * 1024, a); log.debug("-----------这里开始图片存入内存----------" + is); if (is) { log.debug("hksdk(抓图)-结果状态值(0表示成功):" + hCNetSDK.NET_DVR_GetLastError()); byte[] array = jpegBuffer.array(); //存储到minio String BucketName = "pic"; String ObjectName = "capture/" + IdUtils.simpleUUID() + ".jpeg"; InputStream input = new ByteArrayInputStream(array); String url = ""; try { boolean b = MinioUtil.uploadObject(BucketName, ObjectName, input, input.available(), MimeTypeUtils.IMAGE_JPEG); if (b) { url = MinioUtil.getBucketObjectUrl(BucketName, ObjectName); log.debug("上传文件成功!" + url); } } catch (IOException ex) { log.error("上传文件异常：" + ex.getMessage()); } return url; } else { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("抓图失败,请稍后重试" + code); return ""; } } /** * @描述 短时录像 * @参数 [userId, channelNum, enable] * @返回值 void * @创建人 刘苏义 * @创建时间 2023/1/20 11:18 * @修改人和其它信息 */ @Override public String record(CameraCmd cmd) { try { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4"); boolean enable = cmd.isEnable(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return ""; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); //强制I帧结构体对象 HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象 netDvrIFrame.read(); netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置 netDvrIFrame.byStreamType = 0; netDvrIFrame.dwSize = netDvrIFrame.size(); netDvrIFrame.write(); if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) { log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); } //预览参数 NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO(); previewinfo.read(); previewinfo.lChannel = channelNum; previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推 previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。 previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流 previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式 previewinfo.write(); String url = ""; if (enable) { if (!GlobalVariable.previewMap.containsKey(cameraId)) { int lRealHandle = hCNetSDK.NET_DVR_RealPlay_V40(userId, previewinfo, null, null); if (lRealHandle == -1) { log.error("取流失败" + hCNetSDK.NET_DVR_GetLastError()); return ""; } log.debug("取流成功"); GlobalVariable.previewMap.put(cameraId, lRealHandle); } if (!hCNetSDK.NET_DVR_SaveRealData_V30(GlobalVariable.previewMap.get(cameraId), 2, path)) { log.error("保存视频文件到临时文件夹失败 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); return ""; } log.debug("录像开始"); } else { if (GlobalVariable.previewMap.containsKey(cameraId)) { Integer lRealHandle = GlobalVariable.previewMap.get(cameraId); hCNetSDK.NET_DVR_StopRealPlay(lRealHandle); GlobalVariable.previewMap.remove(cameraId); } log.debug("录像停止"); //存入minio String BucketName = "record"; String ObjectName = IdUtils.simpleUUID() + ".mp4"; FileInputStream stream = new FileInputStream(path); boolean b = MinioUtil.uploadObject(BucketName, ObjectName, stream, stream.available(), "video/MP4"); if (b) { url = MinioUtil.getBucketObjectUrl(BucketName, ObjectName); log.debug("上传文件成功!" + url); } } return url; } catch (Exception ex) { log.error("录像异常" + ex.getMessage()); return ""; } } @Override public boolean recordStart(CameraCmd cmd) { try { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4"); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); //强制I帧结构体对象 HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象 netDvrIFrame.read(); netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置 netDvrIFrame.byStreamType = 0; netDvrIFrame.dwSize = netDvrIFrame.size(); netDvrIFrame.write(); if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) { log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); } //预览参数 NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO(); previewinfo.read(); previewinfo.lChannel = channelNum; previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推 previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。 previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流 previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式 previewinfo.write(); if (GlobalVariable.previewMap.containsKey(cameraId)) { Integer lRealHandle = GlobalVariable.previewMap.get(cameraId); hCNetSDK.NET_DVR_StopRealPlay(lRealHandle); GlobalVariable.previewMap.remove(cameraId); log.debug("停止当前录像"); } int lRealHandle = hCNetSDK.NET_DVR_RealPlay_V40(userId, previewinfo, null, null); if (lRealHandle == -1) { log.error("取流失败" + hCNetSDK.NET_DVR_GetLastError()); return false; } log.debug("取流成功"); GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName()); GlobalVariable.previewMap.put(cameraId, lRealHandle); if (!hCNetSDK.NET_DVR_SaveRealData_V30(GlobalVariable.previewMap.get(cameraId), 2, path)) { log.error("保存视频文件到临时文件夹失败 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); return false; } log.debug("录像开始"); return true; } catch (Exception ex) { log.error("开始录像异常" + ex.getMessage()); return false; } } @Override public String recordStopToMinio(CameraCmd cmd) { String url = ""; try { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4"); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return ""; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); //region 强制I帧 HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象 netDvrIFrame.read(); netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置 netDvrIFrame.byStreamType = 0; netDvrIFrame.dwSize = netDvrIFrame.size(); netDvrIFrame.write(); if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) { log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); } //endregion //region 预览参数 NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO(); previewinfo.read(); previewinfo.lChannel = channelNum; previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推 previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。 previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流 previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式 previewinfo.write(); //endregion if (GlobalVariable.previewMap.containsKey(cameraId)) { Integer lRealHandle = GlobalVariable.previewMap.get(cameraId); hCNetSDK.NET_DVR_StopRealPlay(lRealHandle); GlobalVariable.previewMap.remove(cameraId); } log.debug("录像停止"); //存入minio String BucketName = cmd.getRecordBucketName(); String ObjectName = cmd.getRecordObjectName() + ".mp4"; FileInputStream stream = new FileInputStream(path); boolean b = MinioUtil.uploadObject(BucketName, ObjectName, stream, stream.available(), "video/MP4"); if (b) { url = MinioUtil.getBucketObjectUrl(BucketName, ObjectName); log.debug("上传文件成功!" + url); } return url; } catch (Exception ex) { log.error("录像异常" + ex.getMessage()); return ""; } } @Override public boolean recordStopNotToMinio(CameraCmd cmd) { boolean result = false; try { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return false; } Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); //强制I帧结构体对象 HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象 netDvrIFrame.read(); netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号，按照上文中的设置 netDvrIFrame.byStreamType = 0; netDvrIFrame.dwSize = netDvrIFrame.size(); netDvrIFrame.write(); if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) { log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); } //预览参数 NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO(); previewinfo.read(); previewinfo.lChannel = channelNum; previewinfo.dwStreamType = 0;//码流类型：0-主码流，1-子码流，2-三码流，3-虚拟码流，以此类推 previewinfo.dwLinkMode = 0;//连接方式：0-TCP方式，1-UDP方式，2-多播方式，3-RTP方式，4-RTP/RTSP，5-RTP/HTTP，6-HRUDP（可靠传输），7-RTSP/HTTPS，8-NPQ previewinfo.hPlayWnd = null;//播放窗口的句柄，为NULL表示不解码显示。 previewinfo.bBlocked = 0;//0- 非阻塞取流，1-阻塞取流 previewinfo.byNPQMode = 0;//NPQ模式：0-直连模式，1-过流媒体模式 previewinfo.write(); if (GlobalVariable.previewMap.containsKey(cameraId)) { Integer lRealHandle = GlobalVariable.previewMap.get(cameraId); hCNetSDK.NET_DVR_StopRealPlay(lRealHandle); GlobalVariable.previewMap.remove(cameraId); } log.debug("录像停止"); result = true; } catch (Exception ex) { log.error("录像停止异常" + ex.getMessage()); result = false; } return result; } //获取IP通道 @Override public List getCameraChannelList(ArdCameras camera) { /*获取通道*/ List channelList = new ArrayList<>(); try { Integer chanNum = camera.getChanNum(); Integer startDChan = camera.getStartDChan(); if (chanNum > 0) { // 获取通道号 for (int iChannum = 0; iChannum < chanNum; iChannum++) { ArdChannel ardChannel = new ArdChannel(); int channum = iChannum + startDChan + 1; HCNetSDK.NET_DVR_PICCFG_V40 strPicCfg = new HCNetSDK.NET_DVR_PICCFG_V40(); strPicCfg.dwSize = strPicCfg.size(); strPicCfg.write(); Pointer pStrPicCfg = strPicCfg.getPointer(); NativeLong lChannel = new NativeLong(channum); IntByReference pInt = new IntByReference(0); boolean b_GetPicCfg = hCNetSDK.NET_DVR_GetDVRConfig(camera.getLoginId(), HCNetSDK.NET_DVR_GET_PICCFG_V40, lChannel.intValue(), pStrPicCfg, strPicCfg.size(), pInt); if (b_GetPicCfg) { strPicCfg.read(); String channelName = new String(strPicCfg.sChanName, "GBK").trim(); ardChannel.setName(channelName); } ardChannel.setDeviceId(camera.getId()); ardChannel.setChanNo(iChannum + 1); channelList.add(ardChannel); } } } catch (Exception ex) { log.error("获取相机通道异常:" + ex.getMessage()); } return channelList; } /** * @描述 获取GIS信息数据 * @参数 [userId, channelNum] * @返回值 boolean * @创建人 刘苏义 * @创建时间 2023/1/17 16:36 * @修改人和其它信息 0-解锁 1-锁定 */ @Override public Map getGisInfo(CameraCmd cmd) { String cameraId = cmd.getCameraId(); Integer channelNum = cmd.getChanNo(); if (!GlobalVariable.loginMap.containsKey(cameraId)) { return new HashMap<>(); } // 获取参数 Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); HCNetSDK.NET_DVR_STD_CONFIG struStdCfg = new HCNetSDK.NET_DVR_STD_CONFIG(); HCNetSDK.NET_DVR_GIS_INFO struGisInfo = new HCNetSDK.NET_DVR_GIS_INFO(); struStdCfg.read(); IntByReference lchannel = new IntByReference(channelNum); struStdCfg.lpCondBuffer = lchannel.getPointer(); struStdCfg.dwCondSize = 4; struStdCfg.lpOutBuffer = struGisInfo.getPointer(); struStdCfg.dwOutSize = struGisInfo.size(); struStdCfg.write();//设置前之前要write() boolean bool = hCNetSDK.NET_DVR_GetSTDConfig(userId, NET_DVR_GET_GISINFO, struStdCfg); if (!bool) { int code = hCNetSDK.NET_DVR_GetLastError(); log.error("获取GIS信息数据失败,请稍后重试" + code); return new HashMap<>(); } else { struGisInfo.read(); Map map = new HashMap<>(); map.put("p", struGisInfo.struPtzPos.fPanPos); map.put("t", struGisInfo.struPtzPos.fTiltPos < 0 ? struGisInfo.struPtzPos.fTiltPos + 360 : struGisInfo.struPtzPos.fTiltPos); map.put("z", struGisInfo.struPtzPos.fZoomPos); map.put("fHorFieldAngle", struGisInfo.fHorizontalValue);// 水平视场角 map.put("fVerFieldAngle", struGisInfo.fVerticalValue);// 垂直视场角 return map; } } }