| | |
| | | import com.ruoyi.alarm.global.domain.GuideTask; |
| | | import com.ruoyi.alarm.global.service.impl.QueueHandler; |
| | | import com.ruoyi.common.annotation.SdkOperate; |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | import com.ruoyi.common.utils.file.FileUtils; |
| | | import com.ruoyi.common.utils.file.MimeTypeUtils; |
| | | import com.ruoyi.common.utils.spring.SpringUtils; |
| | |
| | | import com.ruoyi.utils.gis.GisUtil; |
| | | import com.ruoyi.utils.minio.MinioUtil; |
| | | import com.ruoyi.utils.sdk.common.GlobalVariable; |
| | | import com.ruoyi.utils.sdk.common.SdkErrorCodeEnum; |
| | | import com.ruoyi.utils.sdk.hiksdk.lib.ExceptionCallBack; |
| | | import com.ruoyi.utils.sdk.hiksdk.lib.HCNetSDK; |
| | | import com.sun.jna.NativeLong; |
| | |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.*; |
| | | import java.math.BigDecimal; |
| | | import java.nio.ByteBuffer; |
| | | import java.nio.file.Files; |
| | | import java.nio.file.Paths; |
| | | import java.text.DecimalFormat; |
| | | import java.util.*; |
| | | import java.util.concurrent.PriorityBlockingQueue; |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public boolean login(ArdCameras camera) { |
| | | public AjaxResult login(ArdCameras camera) { |
| | | try { |
| | | // 初始化 |
| | | if (!hCNetSDK.NET_DVR_Init()) { |
| | | log.error("SDK初始化失败"); |
| | | log.debug("SDK初始化失败"); |
| | | } |
| | | //打印海康sdk日志 |
| | | if (Platform.isWindows()) { |
| | |
| | | //同步登录 |
| | | int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo); |
| | | if (lUserID < 0) { |
| | | log.debug("Login Failed [ " + camera.getIp() + ":" + camera.getPort() + " ],错误码:" + hCNetSDK.NET_DVR_GetLastError()); |
| | | int errorCode = hCNetSDK.NET_DVR_GetLastError(); |
| | | camera.setChanNum(0); |
| | | camera.setLoginId(-1); |
| | | camera.setState("0"); |
| | | //删除管理通道 |
| | | ardChannelService.deleteArdChannelByDeviceId(camera.getId()); |
| | | ardCamerasService.updateArdCameras(camera); |
| | | return false; |
| | | log.debug("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")"); |
| | | return AjaxResult.warn("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")"); |
| | | } |
| | | |
| | | log.debug("Login Success [ " + camera.getIp() + ":" + camera.getPort() + " ]"); |
| | |
| | | //设置异常回调函数(可在回调函数中获取设备上下线状态等) |
| | | if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) { |
| | | log.debug("Set fExceptionCallBack function fail"); |
| | | return false; |
| | | } else { |
| | | log.debug("Set fExceptionCallBack function successfully!"); |
| | | } |
| | | } |
| | | |
| | | if (GlobalVariable.loginMap.containsKey(camera.getId())) { |
| | | GlobalVariable.loginMap.remove(camera.getId()); |
| | | } |
| | | |
| | | //删除管理通道 |
| | | ardChannelService.deleteArdChannelByDeviceId(camera.getId()); |
| | | // if (GlobalVariable.loginMap.containsKey(camera.getId())) { |
| | | // GlobalVariable.loginMap.remove(camera.getId()); |
| | | // } |
| | | GlobalVariable.loginMap.put(camera.getId(), lUserID); |
| | | GlobalVariable.loginCameraMap.put(lUserID, camera); |
| | | |
| | | camera.setLoginId(lUserID); |
| | | camera.setState("1"); |
| | | camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum); |
| | | camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan); |
| | | int chanNum = m_strDeviceInfo.struDeviceV30.byChanNum; |
| | | int startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan + 1; |
| | | if (camera.getGdtype().equals("2")) { |
| | | chanNum = m_strDeviceInfo.struDeviceV30.byIPChanNum; |
| | | startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan; |
| | | } |
| | | camera.setChanNum(chanNum); |
| | | camera.setStartDChan(startDchan); |
| | | //获取最新通道 |
| | | List<ArdChannel> cameraChannelList = getIPChannelInfo(camera); |
| | | List<ArdChannel> cameraChannelList = getChannels(camera); |
| | | if (cameraChannelList.size() > 0) { |
| | | camera.setChannelList(cameraChannelList); |
| | | for (ArdChannel channel : cameraChannelList) { |
| | | channel.setId(IdUtils.simpleUUID()); |
| | | ardChannelService.insertArdChannel(channel); |
| | | } |
| | | camera.setChanNum(cameraChannelList.size()); |
| | | ardCamerasService.updateArdCameras(camera); |
| | | //添加到流媒体 |
| | | addVtdu(camera); |
| | | } |
| | | //创建引导队列 |
| | | if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) { |
| | | Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator(); |
| | | PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator); |
| | | GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue); |
| | | } |
| | | ardCamerasService.updateArdCameras(camera); |
| | | createGuideQueue(camera); |
| | | return AjaxResult.success("设备登录成功"); |
| | | } catch (Exception ex) { |
| | | log.error("注册设备异常", ex); |
| | | log.error("设备登录异常", ex); |
| | | return AjaxResult.error("设备登录异常" + ex.getMessage()); |
| | | } |
| | | return true; |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | @Override |
| | | @Async("loginExecutor") |
| | | public void asyncLogin(ArdCameras camera) { |
| | | public AjaxResult asyncLogin(ArdCameras camera) { |
| | | try { |
| | | // 初始化 |
| | | if (!hCNetSDK.NET_DVR_Init()) { |
| | | log.error("SDK初始化失败"); |
| | | return AjaxResult.warn("SDK初始化失败"); |
| | | } |
| | | //打印海康sdk日志 |
| | | if (Platform.isWindows()) { |
| | |
| | | //同步登录 |
| | | int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo); |
| | | if (lUserID < 0) { |
| | | log.debug("Login Failed 【 " + camera.getIp() + ":" + camera.getPort() + " 】,Error Code:" + hCNetSDK.NET_DVR_GetLastError()); |
| | | int errorCode = hCNetSDK.NET_DVR_GetLastError(); |
| | | camera.setChanNum(0); |
| | | camera.setLoginId(-1); |
| | | camera.setState("0"); |
| | | //删除管理通道 |
| | | ardChannelService.deleteArdChannelByDeviceId(camera.getId()); |
| | | ardCamerasService.updateArdCameras(camera); |
| | | return; |
| | | log.error("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")"); |
| | | return AjaxResult.warn("设备[" + camera.getIp() + ":" + camera.getPort() + "]登录失败: " + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")"); |
| | | } |
| | | |
| | | log.debug("Login Success 【 " + camera.getIp() + ":" + camera.getPort() + " 】"); |
| | | synchronized (_lock) { |
| | | if (fExceptionCallBack == null) { |
| | |
| | | //设置异常回调函数(可在回调函数中获取设备上下线状态等) |
| | | if (!hCNetSDK.NET_DVR_SetExceptionCallBack_V30(0, 0, fExceptionCallBack, null)) { |
| | | log.debug("Set fExceptionCallBack function fail"); |
| | | return; |
| | | } else { |
| | | log.debug("Set fExceptionCallBack function successfully!"); |
| | | } |
| | | } |
| | | } |
| | | if (GlobalVariable.loginMap.containsKey(camera.getId())) { |
| | | GlobalVariable.loginMap.remove(camera.getId()); |
| | | } |
| | | |
| | | //删除管理通道 |
| | | ardChannelService.deleteArdChannelByDeviceId(camera.getId()); |
| | | // if (GlobalVariable.loginMap.containsKey(camera.getId())) { |
| | | // GlobalVariable.loginMap.remove(camera.getId()); |
| | | // } |
| | | GlobalVariable.loginMap.put(camera.getId(), lUserID); |
| | | GlobalVariable.loginCameraMap.put(lUserID, camera); |
| | | |
| | | camera.setLoginId(lUserID); |
| | | camera.setState("1"); |
| | | camera.setChanNum((int) m_strDeviceInfo.struDeviceV30.byChanNum); |
| | | camera.setStartDChan((int) m_strDeviceInfo.struDeviceV30.byStartDChan); |
| | | |
| | | int chanNum = m_strDeviceInfo.struDeviceV30.byChanNum; |
| | | int startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan + 1; |
| | | if (camera.getGdtype().equals("2")) { |
| | | chanNum = m_strDeviceInfo.struDeviceV30.byIPChanNum; |
| | | startDchan = m_strDeviceInfo.struDeviceV30.byStartDChan; |
| | | } |
| | | camera.setChanNum(chanNum); |
| | | camera.setStartDChan(startDchan); |
| | | //获取最新通道 |
| | | List<ArdChannel> cameraChannelList = getIPChannelInfo(camera); |
| | | List<ArdChannel> cameraChannelList = getChannels(camera); |
| | | if (cameraChannelList.size() > 0) { |
| | | camera.setChannelList(cameraChannelList); |
| | | camera.setChanNum(cameraChannelList.size()); |
| | | for (ArdChannel channel : cameraChannelList) { |
| | | channel.setId(IdUtils.simpleUUID()); |
| | | ardChannelService.insertArdChannel(channel); |
| | | } |
| | | ardCamerasService.updateArdCameras(camera); |
| | | //添加到流媒体 |
| | | addVtdu(camera); |
| | | } |
| | | ardCamerasService.updateArdCameras(camera); |
| | | //添加到流媒体 |
| | | addVtdu(camera); |
| | | //创建引导队列 |
| | | createGuideQueue(camera); |
| | | return AjaxResult.success("设备登录成功"); |
| | | } catch (Exception ex) { |
| | | log.error("注册设备异常", ex); |
| | | return AjaxResult.error("注册设备异常" + ex.getMessage()); |
| | | } |
| | | } |
| | | |
| | | //创建引导队列 |
| | | private void createGuideQueue(ArdCameras camera) { |
| | | if (camera.getCamAlarmGuideEnable() != null) { |
| | | if (camera.getCamAlarmGuideEnable() == 1) { |
| | | if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) { |
| | | Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator(); |
| | | PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator); |
| | | GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue); |
| | | //启动队列处理器 |
| | | queueHandler.process(camera.getId()); |
| | | } |
| | | if (camera.getGdtype().equals("1")) { |
| | | if (!GuidePriorityQueue.cameraQueueMap.containsKey(camera.getId())) { |
| | | Comparator<GuideTask> comparator = GuidePriorityQueue.getComparator(); |
| | | PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator); |
| | | GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue); |
| | | //启动队列处理器 |
| | | queueHandler.process(camera.getId()); |
| | | } |
| | | } |
| | | } |
| | |
| | | */ |
| | | @Override |
| | | @SdkOperate |
| | | public boolean pTZControl(CameraCmd cmd) { |
| | | public AjaxResult pTZControl(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; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | int dwStop; |
| | |
| | | boolean bool = hCNetSDK.NET_DVR_PTZControlWithSpeed_Other(userId, channelNum, dwPTZCommand, dwStop, speed); |
| | | if (!bool) { |
| | | int errorCode = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("控制失败,请稍后重试" + errorCode); |
| | | log.error("控制失败: errorCode:" + errorCode + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(errorCode)); |
| | | return AjaxResult.warn("控制失败:" + SdkErrorCodeEnum.getDescByCode(errorCode) + "(" + errorCode + ")"); |
| | | } |
| | | return bool; |
| | | return AjaxResult.success("控制成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param cmd 相机命令 |
| | | */ |
| | | @Override |
| | | public boolean setFocusPos(CameraCmd cmd) { |
| | | public AjaxResult setFocusPos(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | Integer dwFocusPos = cmd.getDwFocusPos(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | // 获取参数 |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | |
| | | if (!bool) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置GIS信息数据失败,请稍后重试" + code); |
| | | return false; |
| | | } else { |
| | | return true; |
| | | return AjaxResult.warn("设置GIS信息数据失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return AjaxResult.success("设置GIS信息数据成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param cmd 相机命令 |
| | | */ |
| | | @Override |
| | | public int getFocusPos(CameraCmd cmd) { |
| | | int result = 0; |
| | | public AjaxResult getFocusPos(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return result; |
| | | return AjaxResult.error("设备未登录"); |
| | | } |
| | | // 获取参数 |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | |
| | | 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; |
| | | log.error("获取聚焦值失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取聚焦值失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return result; |
| | | struGisInfo.read(); |
| | | int result = struGisInfo.struPtzPosEx.dwFocus; |
| | | return AjaxResult.success(result); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param cmd 相机命令 |
| | | */ |
| | | @Override |
| | | public boolean setPreset(CameraCmd cmd) { |
| | | public AjaxResult setPreset(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | Integer PresetIndex = cmd.getPresetIndex(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.error("设备未登录"); |
| | | } |
| | | 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); |
| | | log.error("预置点设置失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("预置点设置失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return bool; |
| | | return AjaxResult.success("预置点设置成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param cmd 相机命令 |
| | | */ |
| | | @Override |
| | | public boolean gotoPreset(CameraCmd cmd) { |
| | | public AjaxResult gotoPreset(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | Integer PresetIndex = cmd.getPresetIndex(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.error("设备未登录"); |
| | | } |
| | | 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); |
| | | log.error("调用预置点失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("调用预置点失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return bool; |
| | | return AjaxResult.success("调用预置点成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @创建时间 2023/1/17 16:36 |
| | | * @修改人和其它信息 |
| | | */ |
| | | public Map<String, Object> getPtz1(CameraCmd cmd) { |
| | | public AjaxResult getPtz(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return new HashMap<>(); |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | |
| | |
| | | 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<String, Object> ptzMap = new HashMap<>(); |
| | | ptzMap.put("p", p); |
| | | ptzMap.put("t", t); |
| | | ptzMap.put("z", z); |
| | | return ptzMap; |
| | | } else { |
| | | if (!bool) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("控制失败,请稍后重试" + code); |
| | | return new HashMap<>(); |
| | | log.error("获取ptz失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取ptz失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | 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<String, Object> ptzMap = new HashMap<>(); |
| | | ptzMap.put("p", p); |
| | | ptzMap.put("t", t); |
| | | ptzMap.put("z", z); |
| | | return AjaxResult.success(ptzMap); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public Map<String, Object> getPtz(CameraCmd cmd) { |
| | | public AjaxResult getPtzHigh(CameraCmd cmd) { |
| | | Map<String, Object> ptzMap = new HashMap<>(); |
| | | try { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer chanNo = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return new HashMap<>(); |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | IntByReference pchannel = new IntByReference(chanNo); |
| | | Pointer pChannelNum = pchannel.getPointer(); |
| | |
| | | lpConfigParam6696.write(); |
| | | boolean res = hCNetSDK.NET_DVR_GetSTDConfig(lUserID, HCNetSDK.NET_DVR_GET_PTZABSOLUTEEX, lpConfigParam6696); |
| | | if (!res) { |
| | | log.error("获取高精度PTZ绝对位置配置失败,错误号:" + hCNetSDK.NET_DVR_GetLastError()); |
| | | } else { |
| | | lpPTZAbsoluteEX_cfg.read(); |
| | | //log.debug("P:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.fPan + " T:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.fTilt + " Z:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.fZoom |
| | | // + " 聚焦参数:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.dwFocus + " 聚焦范围:" + lpPTZAbsoluteEX_cfg.dwFocalLen + " 水平转动速度:" + lpPTZAbsoluteEX_cfg.fHorizontalSpeed |
| | | // + " 垂直转动速度:" + lpPTZAbsoluteEX_cfg.fVerticalSpeed + " 镜头变倍配置类型:" + lpPTZAbsoluteEX_cfg.byZoomType); |
| | | float p = lpPTZAbsoluteEX_cfg.struPTZCtrl.fPan; |
| | | float fTilt = lpPTZAbsoluteEX_cfg.struPTZCtrl.fTilt; |
| | | float t = fTilt < 0 ? fTilt + 360 : fTilt; |
| | | float z = lpPTZAbsoluteEX_cfg.struPTZCtrl.fZoom; |
| | | ptzMap.put("p", p); |
| | | ptzMap.put("t", t); |
| | | ptzMap.put("z", z); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("获取高精度PTZ失败: errorCode" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取高精度PTZ失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | lpPTZAbsoluteEX_cfg.read(); |
| | | //log.debug("P:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.fPan + " T:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.fTilt + " Z:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.fZoom |
| | | // + " 聚焦参数:" + lpPTZAbsoluteEX_cfg.struPTZCtrl.dwFocus + " 聚焦范围:" + lpPTZAbsoluteEX_cfg.dwFocalLen + " 水平转动速度:" + lpPTZAbsoluteEX_cfg.fHorizontalSpeed |
| | | // + " 垂直转动速度:" + lpPTZAbsoluteEX_cfg.fVerticalSpeed + " 镜头变倍配置类型:" + lpPTZAbsoluteEX_cfg.byZoomType); |
| | | float p = lpPTZAbsoluteEX_cfg.struPTZCtrl.fPan; |
| | | float fTilt = lpPTZAbsoluteEX_cfg.struPTZCtrl.fTilt; |
| | | float t = fTilt < 0 ? fTilt + 360 : fTilt; |
| | | float z = lpPTZAbsoluteEX_cfg.struPTZCtrl.fZoom; |
| | | ptzMap.put("p", p); |
| | | ptzMap.put("t", t); |
| | | ptzMap.put("z", z); |
| | | return AjaxResult.success(ptzMap); |
| | | } catch (Exception ex) { |
| | | log.error("获取高精度PTZ绝对位置异常:" + ex.getMessage()); |
| | | return AjaxResult.error("获取高精度PTZ绝对位置异常:" + ex.getMessage()); |
| | | } |
| | | return ptzMap; |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | @Override |
| | | @SdkOperate |
| | | public boolean setPtz1(CameraCmd cmd) { |
| | | public AjaxResult setPtz(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | Map<String, Double> ptz = cmd.getPtzMap(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS(); |
| | |
| | | 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); |
| | | log.error("设置PTZ参数失败: errorCode" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("设置PTZ参数失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return bool; |
| | | return AjaxResult.success("设置PTZ参数成功"); |
| | | } catch (Exception ex) { |
| | | log.error(ex.getMessage()); |
| | | return false; |
| | | return AjaxResult.error("设置PTZ参数异常:" + ex.getMessage()); |
| | | } |
| | | } |
| | | |
| | |
| | | */ |
| | | @Override |
| | | @SdkOperate |
| | | public boolean setPtz(CameraCmd cmd) { |
| | | public AjaxResult setPtzHigh(CameraCmd cmd) { |
| | | try { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer chanNo = cmd.getChanNo(); |
| | | Map<String, Double> ptz = cmd.getPtzMap(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer lUserID = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | IntByReference pchannel = new IntByReference(chanNo); |
| | |
| | | boolean bool = hCNetSDK.NET_DVR_SetSTDConfig(lUserID, NET_DVR_SET_PTZABSOLUTEEX, lpConfigParam6697); |
| | | if (!bool) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置高精度PTZ参数失败,请稍后重试:" + code); |
| | | log.error("设置高精度PTZ失败:" + code); |
| | | return AjaxResult.warn("设置高精度PTZ失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return bool; |
| | | return AjaxResult.success("设置高精度PTZ参数成功"); |
| | | |
| | | } catch (Exception ex) { |
| | | log.error("设置高精度PTZ参数异常", ex); |
| | | return false; |
| | | return AjaxResult.error("设置高精度PTZ参数异常:" + ex); |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @SdkOperate |
| | | public boolean guideTargetPosition(CameraCmd cmd) { |
| | | public AjaxResult guideTargetPosition(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer chanNo = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS(); |
| | |
| | | if (!bool) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置ptz失败,请稍后重试" + code); |
| | | return AjaxResult.warn("设置ptz失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return bool; |
| | | return AjaxResult.success("引导坐标成功"); |
| | | } catch (Exception ex) { |
| | | log.error("引导异常:" + ex.getMessage()); |
| | | return false; |
| | | log.error("引导坐标异常:" + ex.getMessage()); |
| | | return AjaxResult.error("引导坐标异常:" + ex.getMessage()); |
| | | } |
| | | } |
| | | |
| | |
| | | * @创建时间 2023/1/17 16:36 |
| | | * @修改人和其它信息 0-解锁 1-锁定 |
| | | */ |
| | | public int getPTZLockInfo(CameraCmd cmd) { |
| | | public AjaxResult getPTZLockInfo(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return -1; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_PTZ_LOCKCFG netDvrPtzLockcfg = new NET_DVR_PTZ_LOCKCFG(); |
| | |
| | | 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; |
| | | log.error("获取ptz锁定失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取ptz锁定失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } else { |
| | | netDvrPtzLockcfg.read(); |
| | | return netDvrPtzLockcfg.byWorkMode; |
| | | int byWorkMode = netDvrPtzLockcfg.byWorkMode; |
| | | return AjaxResult.success(byWorkMode); |
| | | } |
| | | } |
| | | |
| | |
| | | */ |
| | | @Override |
| | | @SdkOperate |
| | | public boolean setZeroPtz(CameraCmd cmd) { |
| | | public AjaxResult setZeroPtz(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.error("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_INITIALPOSITIONCTRL initialpositionctrl = new NET_DVR_INITIALPOSITIONCTRL(); |
| | |
| | | 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); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置零方位角失败:" + code); |
| | | return AjaxResult.warn("设置零方位角失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | return bool; |
| | | return AjaxResult.success(); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public Map<String, Object> getPtzScope(CameraCmd cmd) { |
| | | public AjaxResult getPtzScope(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return new HashMap<>(); |
| | | return AjaxResult.error("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_PTZSCOPE m_ptzPosCurrent = new NET_DVR_PTZSCOPE(); |
| | |
| | | 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<>(); |
| | | log.error("获取ptz范围失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取ptz范围失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } else { |
| | | m_ptzPosCurrent.read(); |
| | | DecimalFormat df = new DecimalFormat("0.0");//设置保留位数 |
| | |
| | | ptzScopeMap.put("tMin", wTiltPosMin); |
| | | ptzScopeMap.put("zMax", wZoomPosMax); |
| | | ptzScopeMap.put("zMin", wZoomPosMin); |
| | | return ptzScopeMap; |
| | | return AjaxResult.success(ptzScopeMap); |
| | | } |
| | | |
| | | } |
| | | |
| | | /** |
| | | * @描述 透雾开关 |
| | | * @描述 切换透雾 |
| | | * @参数 [userId, channelNum, enable] |
| | | * @返回值 boolean |
| | | * @创建人 刘苏义 |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public boolean controlDefogcfg(CameraCmd cmd) { |
| | | public AjaxResult controlDefogcfg(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer chanNo = cmd.getChanNo(); |
| | | boolean enable = cmd.isEnable(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | 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); |
| | | boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG_EX, chanNo, point, struCameraParam.size(), ibrBytesReturned); |
| | | if (!b_GetCameraParam) { |
| | | log.error("获取前端参数失败,错误码:" + hCNetSDK.NET_DVR_GetLastError()); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("获取前端参数失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取前端参数失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | struCameraParam.read(); |
| | | log.debug("是否开启透雾:" + struCameraParam.struDefogCfg.byMode); |
| | |
| | | } |
| | | struCameraParam.struDefogCfg = defogcfg; |
| | | struCameraParam.write(); |
| | | boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, channelNum, point, struCameraParam.size()); |
| | | boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, chanNo, point, struCameraParam.size()); |
| | | if (!bool) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置透雾失败,请稍后重试" + code); |
| | | log.error("切换透雾失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("切换透雾失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | log.debug("设置透雾成功"); |
| | | return bool; |
| | | log.debug("切换透雾成功"); |
| | | return AjaxResult.success("切换透雾成功"); |
| | | } |
| | | |
| | | /** |
| | | * @描述 红外开关 |
| | | * @描述 切换红外 |
| | | * @参数 [userId, channelNum, enable] |
| | | * @返回值 boolean |
| | | * @创建人 刘苏义 |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public boolean controlInfrarecfg(CameraCmd cmd) { |
| | | public AjaxResult controlInfrarecfg(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | boolean enable = cmd.isEnable(); |
| | | Integer chanNo = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | 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, chanNo, point, struDayNigh.size(), ibrBytesReturned); |
| | | boolean b_GetCameraParam = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_CCDPARAMCFG, chanNo, point, struDayNigh.size(), ibrBytesReturned); |
| | | if (!b_GetCameraParam) { |
| | | log.error("获取前端参数失败,错误码:" + hCNetSDK.NET_DVR_GetLastError()); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("获取前端参数失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取前端参数失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | struDayNigh.read(); |
| | | String current = struDayNigh.struDayNight.byDayNightFilterType == 1 ? "开启" : "关闭"; |
| | |
| | | daynight.byDayNightFilterTime = 60; |
| | | struDayNigh.struDayNight = daynight; |
| | | struDayNigh.write(); |
| | | boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG_EX, chanNo, point, struDayNigh.size()); |
| | | boolean bool = hCNetSDK.NET_DVR_SetDVRConfig(userId, NET_DVR_SET_CCDPARAMCFG, chanNo, point, struDayNigh.size()); |
| | | if (!bool) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置夜视失败,请稍后重试" + code); |
| | | } else { |
| | | log.debug("设置夜视成功"); |
| | | log.error("切换红外失败 ErrorCode:{},ErrorInfo:{}", code, SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("切换红外失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | |
| | | return bool; |
| | | log.debug("切换红外成功"); |
| | | return AjaxResult.success("切换红外成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public boolean controlFocusMode(CameraCmd cmd) { |
| | | public AjaxResult controlFocusMode(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | boolean enable = cmd.isEnable(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_FOCUSMODE_CFG struFocusMode = new NET_DVR_FOCUSMODE_CFG(); |
| | |
| | | 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()); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("获取前端参数失败: errorCode" + code + " errorInfo" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取前端参数失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | struFocusMode.read(); |
| | | log.debug("当前聚焦模式:" + struFocusMode.byFocusMode); |
| | |
| | | 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.error("设置聚焦模式失败: errorCode" + code + " errorInfo" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("设置聚焦模式失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | log.debug("设置聚焦模式成功"); |
| | | return bool; |
| | | return AjaxResult.success("设置聚焦模式成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @创建时间 2023/1/18 13:07 |
| | | * @修改人和其它信息 |
| | | */ |
| | | public String getFocusMode(CameraCmd cmd) { |
| | | public AjaxResult getFocusMode(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return ""; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_FOCUSMODE_CFG struFocusMode = new NET_DVR_FOCUSMODE_CFG(); |
| | |
| | | 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()); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("获取聚焦模式失败: errorCode" + code + " errorInfo" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取聚焦模式失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | struFocusMode.read(); |
| | | log.debug("当前聚焦模式:" + struFocusMode.byFocusMode); |
| | | return String.valueOf(struFocusMode.byFocusMode); |
| | | return AjaxResult.success(struFocusMode.byFocusMode); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public boolean controlPTHeateRpwron(CameraCmd cmd) { |
| | | public AjaxResult controlPTHeateRpwron(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | boolean enable = cmd.isEnable(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | int dwStop; |
| | |
| | | boolean bool = hCNetSDK.NET_DVR_PTZControl_Other(userId, channelNum, HEATER_PWRON, dwStop); |
| | | if (!bool) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置云台加热失败,请稍后重试" + code); |
| | | log.error("设置云台加热失败: errorCode" + code + " errorInfo" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("设置云台加热失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | log.debug("设置云台加热成功"); |
| | | return bool; |
| | | return AjaxResult.success("设置云台加热成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @修改人和其它信息 |
| | | */ |
| | | @Override |
| | | public boolean controlCameraDeicing(CameraCmd cmd) { |
| | | public AjaxResult controlCameraDeicing(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | boolean enable = cmd.isEnable(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return false; |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | | NET_DVR_DEVSERVER_CFG struDeicing = new NET_DVR_DEVSERVER_CFG(); |
| | |
| | | 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()); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("获取前端参数失败: errorCode" + code + " errorInfo" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取前端参数失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | struDeicing.read(); |
| | | log.debug("是否开启除冰:" + struDeicing.byEnableDeicing); |
| | |
| | | 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.error("设置镜头除冰失败: errorCode" + code + " errorInfo" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("设置镜头除冰失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | log.debug("设置镜头除冰成功"); |
| | | return bool; |
| | | return AjaxResult.success("设置镜头除冰成功"); |
| | | } |
| | | |
| | | /** |
| | |
| | | * |
| | | * @param cmd 相机命令 |
| | | */ |
| | | public String captureJPEGPicture(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return ""; |
| | | @Override |
| | | public AjaxResult localCapture(CameraCmd cmd) { |
| | | try { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | 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)) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("获取设备工作状态失败: errorCode" + code + " errorInfo" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取设备工作状态失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | //图片质量 |
| | | 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); |
| | | // OutputStream outputStream = response.getOutputStream(); |
| | | //outputStream.write(jpegBuffer.array()); |
| | | //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 AjaxResult.success(jpegBuffer.array()); |
| | | } catch (Exception ex) { |
| | | log.error("-----------截图失败----------"); |
| | | return AjaxResult.error(ex.getMessage()); |
| | | } |
| | | 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; |
| | | } |
| | | |
| | | /** |
| | |
| | | public String record(CameraCmd cmd) { |
| | | try { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | Integer chanNo = cmd.getChanNo(); |
| | | String path = FileUtils.createFile("D:/recordTemp/" + cameraId + ".mp4"); |
| | | boolean enable = cmd.isEnable(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | |
| | | //强制I帧结构体对象 |
| | | HCNetSDK.NET_DVR_I_FRAME netDvrIFrame = new HCNetSDK.NET_DVR_I_FRAME(); //新建结构体对象 |
| | | netDvrIFrame.read(); |
| | | netDvrIFrame.dwChannel = channelNum;//因为上文代码中设置了通道号,按照上文中的设置 |
| | | netDvrIFrame.dwChannel = chanNo;//因为上文代码中设置了通道号,按照上文中的设置 |
| | | netDvrIFrame.byStreamType = 0; |
| | | netDvrIFrame.dwSize = netDvrIFrame.size(); |
| | | netDvrIFrame.write(); |
| | |
| | | //预览参数 |
| | | NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO(); |
| | | previewinfo.read(); |
| | | previewinfo.lChannel = channelNum; |
| | | previewinfo.lChannel = chanNo; |
| | | 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表示不解码显示。 |
| | |
| | | return ""; |
| | | } |
| | | log.debug("录像开始"); |
| | | |
| | | } else { |
| | | if (GlobalVariable.previewMap.containsKey(cameraId)) { |
| | | Integer lRealHandle = GlobalVariable.previewMap.get(cameraId); |
| | |
| | | netDvrIFrame.dwSize = netDvrIFrame.size(); |
| | | netDvrIFrame.write(); |
| | | if (!hCNetSDK.NET_DVR_RemoteControl(userId, 3402, netDvrIFrame.getPointer(), netDvrIFrame.dwSize)) { |
| | | log.error("强制I帧 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("设置强制I帧错误:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | //预览参数 |
| | | NET_DVR_PREVIEWINFO previewinfo = new NET_DVR_PREVIEWINFO(); |
| | |
| | | } |
| | | |
| | | //获取IP通道 |
| | | public List<ArdChannel> getIPChannelInfo(ArdCameras camera) { |
| | | |
| | | public List<ArdChannel> getChannels(ArdCameras camera) { |
| | | //获取通道 |
| | | List<ArdChannel> channelList = new ArrayList<>(); |
| | | try { |
| | | if (camera.getGdtype().equals("3")) { |
| | | camera.setChanNum(64);//超脑获取在线通道数 |
| | | camera.setStartDChan(0);//超脑初始通道为0 |
| | | } |
| | | //删除管理通道 |
| | | ardChannelService.deleteArdChannelByDeviceId(camera.getId()); |
| | | IntByReference ibrBytesReturned = new IntByReference(0);//获取IP接入配置参数 |
| | | HCNetSDK.NET_DVR_IPPARACFG_V40 m_strIpparaCfg = new HCNetSDK.NET_DVR_IPPARACFG_V40(); |
| | | m_strIpparaCfg.write(); |
| | |
| | | m_strIpparaCfg.read(); |
| | | //log.debug("起始数字通道号:" + m_strIpparaCfg.dwStartDChan);//m_strIpparaCfg.dwDChanNum |
| | | for (int iChannum = 0; iChannum < camera.getChanNum(); iChannum++) { |
| | | ArdChannel ardChannel = new ArdChannel(); |
| | | int channum = iChannum + camera.getStartDChan() + 1; |
| | | ArdChannel channel = new ArdChannel(); |
| | | int chanNo = iChannum + camera.getStartDChan(); |
| | | 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); |
| | | NativeLong lChannel = new NativeLong(chanNo); |
| | | 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 (m_strIpparaCfg.struStreamMode[iChannum].byGetStreamType == 0) { |
| | | m_strIpparaCfg.struStreamMode[iChannum].uGetStream.setType(HCNetSDK.NET_DVR_IPCHANINFO.class); |
| | | m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.read(); |
| | | int channel = m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byIPID + m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byIPIDHigh * 256; |
| | | int channelNo = m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byIPID + m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byIPIDHigh * 256; |
| | | String channelName = new String(strPicCfg.sChanName, "GBK").trim(); |
| | | ardChannel.setDeviceId(camera.getId()); |
| | | ardChannel.setName(channelName); |
| | | ardChannel.setChanNo(channum); |
| | | if (camera.getGdtype().equals("3")) { |
| | | //超脑只获取在线通道 |
| | | if (m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byEnable == 1) { |
| | | //log.debug("IP通道" + channum + "在线"); |
| | | channelList.add(ardChannel); |
| | | channelName = channelName.equals("") ? "通道" + chanNo : channelName; |
| | | channel.setDeviceId(camera.getId()); |
| | | channel.setName(channelName); |
| | | channel.setChanNo(chanNo); |
| | | if (camera.getGdtype().equals("3") || camera.getGdtype().equals("2")) { |
| | | //NVR过滤离线通道 |
| | | if (m_strIpparaCfg.struStreamMode[iChannum].uGetStream.struChanInfo.byEnable != 1) { |
| | | continue; |
| | | } |
| | | } else { |
| | | channelList.add(ardChannel); |
| | | } |
| | | channelList.add(channel); |
| | | } |
| | | ardChannelService.insertArdChannel(channel); |
| | | } |
| | | } catch (Exception ex) { |
| | | log.error("获取IP通道异常:" + ex.getMessage()); |
| | |
| | | * @修改人和其它信息 0-解锁 1-锁定 |
| | | */ |
| | | @Override |
| | | public Map<String, Object> getGisInfo(CameraCmd cmd) { |
| | | public AjaxResult getGisInfo(CameraCmd cmd) { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return new HashMap<>(); |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | // 获取参数 |
| | | Integer userId = (Integer) GlobalVariable.loginMap.get(cameraId); |
| | |
| | | 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<String, Object> 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; |
| | | log.error("获取GIS信息数据失败: errorCode:" + code + " errorInfo:" + SdkErrorCodeEnum.getDescByCode(code)); |
| | | return AjaxResult.warn("获取GIS信息数据失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | struGisInfo.read(); |
| | | Map<String, Object> 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 AjaxResult.success(map); |
| | | |
| | | } |
| | | |
| | | //本地录像开始 |
| | | @Override |
| | | public AjaxResult localRecordStart(CameraCmd cmd) { |
| | | try { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | String path = FileUtils.createFile("D:/LocalRecordTemp/" + cameraId + ".mp4"); |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | 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) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("本地录像取流失败" + hCNetSDK.NET_DVR_GetLastError()); |
| | | return AjaxResult.warn("本地录像取流失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | log.debug("本地录像取流成功"); |
| | | //GlobalVariable.threadMap.put(cameraId, Thread.currentThread().getName()); |
| | | //GlobalVariable.previewMap.put(cameraId, lRealHandle); |
| | | if (!hCNetSDK.NET_DVR_SaveRealData_V30(lRealHandle, 2, path)) { |
| | | int code = hCNetSDK.NET_DVR_GetLastError(); |
| | | log.error("保存视频文件到临时文件夹失败 错误码为: " + hCNetSDK.NET_DVR_GetLastError()); |
| | | return AjaxResult.warn("本地录像取流失败:" + SdkErrorCodeEnum.getDescByCode(code) + "(" + code + ")"); |
| | | } |
| | | log.debug("本地录像开始"); |
| | | return AjaxResult.success("录像开始", lRealHandle); |
| | | } catch (Exception ex) { |
| | | log.error("本地录像开始异常" + ex.getMessage()); |
| | | return AjaxResult.error("本地录像开始异常" + ex.getMessage()); |
| | | } |
| | | } |
| | | |
| | | //本地录像停止 |
| | | @Override |
| | | public AjaxResult localRecordStop(CameraCmd cmd) { |
| | | try { |
| | | String cameraId = cmd.getCameraId(); |
| | | Integer channelNum = cmd.getChanNo(); |
| | | Integer lRealHandle = cmd.getRecordId().intValue(); |
| | | |
| | | if (!GlobalVariable.loginMap.containsKey(cameraId)) { |
| | | return AjaxResult.warn("设备未登录"); |
| | | } |
| | | 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); |
| | | //} |
| | | hCNetSDK.NET_DVR_StopRealPlay(lRealHandle); |
| | | log.debug("本地录像停止"); |
| | | String recordPath = FileUtils.createFile("D:/LocalRecordTemp/" + cameraId + ".mp4"); |
| | | byte[] recordBytes = Files.readAllBytes(Paths.get(recordPath)); |
| | | //OutputStream outputStream = response.getOutputStream(); |
| | | //outputStream.write(imageBytes); |
| | | return AjaxResult.success(recordBytes); |
| | | } catch (Exception ex) { |
| | | log.error("本地录像停止异常" + ex.getMessage()); |
| | | return AjaxResult.error("本地录像停止异常" + ex.getMessage()); |
| | | } |
| | | } |
| | | } |