From bd8cdb3244d058ad062610c8dc914374b52dd1e6 Mon Sep 17 00:00:00 2001 From: liusuyi <13324259@qq.com> Date: 星期一, 23 十月 2023 20:33:37 +0800 Subject: [PATCH] 增加redis和流媒体服务外部程序 增加流媒体日志 --- ard-work/src/main/java/com/ruoyi/device/hiksdk/service/impl/HikClientServiceImpl.java | 3086 +++++++++++++++++++++++++++++++++-------------------------- 1 files changed, 1,717 insertions(+), 1,369 deletions(-) diff --git a/ard-work/src/main/java/com/ruoyi/device/hiksdk/service/impl/HikClientServiceImpl.java b/ard-work/src/main/java/com/ruoyi/device/hiksdk/service/impl/HikClientServiceImpl.java index a714686..9ebe065 100644 --- a/ard-work/src/main/java/com/ruoyi/device/hiksdk/service/impl/HikClientServiceImpl.java +++ b/ard-work/src/main/java/com/ruoyi/device/hiksdk/service/impl/HikClientServiceImpl.java @@ -1,1370 +1,1718 @@ -package com.ruoyi.device.hiksdk.service.impl; - -import com.ruoyi.common.annotation.SdkOperate; -import com.ruoyi.common.core.domain.entity.SysUser; -import com.ruoyi.common.core.domain.model.LoginUser; -import com.ruoyi.common.utils.SecurityUtils; -import com.ruoyi.common.utils.StringUtils; -import com.ruoyi.constant.sdkPriority; -import com.ruoyi.device.camera.domain.CameraCmd; -import com.ruoyi.device.camera.mapper.ArdCamerasMapper; -import com.ruoyi.device.hiksdk.common.global.globalVariable; -import com.ruoyi.device.camera.domain.ArdCameras; -import com.ruoyi.device.hiksdk.domain.recordInfo; -import com.ruoyi.device.hiksdk.util.hikSdkUtil.GisUtil; -import com.ruoyi.device.hiksdk.util.hikSdkUtil.HCNetSDK; -import com.ruoyi.device.hiksdk.service.IHikClientService; -import com.ruoyi.device.hiksdk.util.minio.MinioUtils; -import com.ruoyi.system.mapper.SysUserMapper; -import com.sun.jna.Native; -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 sun.misc.BASE64Encoder; - -import javax.annotation.Resource; -import java.io.*; -import java.math.BigDecimal; -import java.nio.ByteBuffer; -import java.text.DecimalFormat; -import java.text.SimpleDateFormat; -import java.util.*; - -import static com.ruoyi.device.hiksdk.util.hikSdkUtil.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 - ArdCamerasMapper ardCamerasMapper; - - @Resource - SysUserMapper sysUserMapper; - - private static HCNetSDK hCNetSDK; - private static Map<Integer, recordInfo> user_real_Map = new HashMap<>(); - - @Override - public void loadHCNetSDKLib() { - try { - log.debug("寮�濮嬪姞杞絪dk搴撴枃浠惰矾寰�"); - if (Platform.isWindows()) { - String WIN_PATH = System.getProperty("user.dir") + File.separator + "lib" + File.separator + "HCNetSDK.dll"; - log.debug("褰撳墠Windows骞冲彴鐨剆dk搴撹矾寰勶細" + WIN_PATH); - hCNetSDK = (HCNetSDK) Native.loadLibrary(WIN_PATH, HCNetSDK.class); - } else { - log.debug("Linux骞冲彴"); - String LINUX_PATH = System.getProperty("user.dir") + File.separator + "hiklib" + File.separator + "libhcnetsdk.so"; - log.debug("褰撳墠Linux骞冲彴鐨剆dk搴撹矾寰勶細" + LINUX_PATH); - hCNetSDK = (HCNetSDK) Native.loadLibrary(LINUX_PATH, HCNetSDK.class); - - //璁剧疆HCNetSDKCom缁勪欢搴撴墍鍦ㄨ矾寰� - //libhcnetsdk.so - String strPathCom = "/home/hiklib"; - NET_DVR_LOCAL_SDK_PATH struComPath = new NET_DVR_LOCAL_SDK_PATH(); - System.arraycopy(strPathCom.getBytes(), 0, struComPath.sPath, 0, strPathCom.length()); - struComPath.write(); - hCNetSDK.NET_DVR_SetSDKInitCfg(2, struComPath.getPointer()); - - //璁剧疆libcrypto.so鎵�鍦ㄨ矾寰� - BYTE_ARRAY ptrByteArrayCrypto = new BYTE_ARRAY(256); - String strPathCrypto = "/home/hiklib/libcrypto.so.1.1"; - System.arraycopy(strPathCrypto.getBytes(), 0, ptrByteArrayCrypto.byValue, 0, strPathCrypto.length()); - ptrByteArrayCrypto.write(); - hCNetSDK.NET_DVR_SetSDKInitCfg(3, ptrByteArrayCrypto.getPointer()); - - //璁剧疆libssl.so鎵�鍦ㄨ矾寰� - BYTE_ARRAY ptrByteArraySsl = new BYTE_ARRAY(256); - String strPathSsl = "/home/hiklib/libssl.so.1.1"; - System.arraycopy(strPathSsl.getBytes(), 0, ptrByteArraySsl.byValue, 0, strPathSsl.length()); - ptrByteArraySsl.write(); - hCNetSDK.NET_DVR_SetSDKInitCfg(4, ptrByteArraySsl.getPointer()); - } - } catch (Exception ex) { - log.error("鍔犺浇搴撴枃浠跺紓甯革細" + ex.getMessage()); - } - } - - /** - * @鎻忚堪 娉ㄥ唽鐧诲綍 - * @鍙傛暟 [dvrLogin] - * @杩斿洖鍊� java.lang.Integer - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/17 16:12 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - public ArdCameras 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, false); - } else { - hCNetSDK.NET_DVR_SetLogToFile(3, "/home/ardLog/hiklog", false); - } - 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); - //璁惧淇℃伅, 杈撳嚭鍙傛暟 - NET_DVR_DEVICEINFO_V30 m_strDeviceInfo = new NET_DVR_DEVICEINFO_V30(); - int lUserID = hCNetSDK.NET_DVR_Login_V30(m_sDeviceIP, m_sPort, m_sUsername, m_sPassword, m_strDeviceInfo); - if (lUserID < 0) { - //閲婃斁SDK璧勬簮 - hCNetSDK.NET_DVR_Cleanup(); - camera.setLoginId(-1); - } - if (globalVariable.loginMap.containsKey(camera.getId())) { - globalVariable.loginMap.remove(camera.getId()); - } - globalVariable.loginMap.put(camera.getId(), lUserID); - - camera.setLoginId(lUserID); - camera.setChannel((int) m_strDeviceInfo.byStartChan); - return camera; - } - - /** - * @鎻忚堪 鐧诲綍鎵�鏈夌浉鏈� - * @鍙傛暟 [] - * @杩斿洖鍊� void - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/2/3 10:10 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - @Async("loginExecutor") - public void loginAll() { - try { - log.debug("鍔犺浇lib瀹屾垚锛�"); - List<ArdCameras> ardCameras = ardCamerasMapper.selectArdCamerasList(new ArdCameras()); - for (ArdCameras camera : ardCameras) { - camera = login(camera); - if (camera.getLoginId() >= 0) { - log.info("鐩告満" + camera.getIp() + ":" + camera.getPort() + "鐧诲綍鎴愬姛锛�" + camera.getLoginId()); - ardCamerasMapper.updateArdCameras(camera); - } else { - log.info("鐩告満" + camera.getIp() + ":" + camera.getPort() + "鐧诲綍澶辫触锛�" + camera.getLoginId()); - } -// if (!globalVariable.loginMap.containsKey(camera.getId())) { -// camera = login(camera); -// if (camera.getLoginId() >= 0) { -// log.info("鐩告満" + camera.getIp() + ":" + camera.getPort() + "鐧诲綍鎴愬姛锛�" + camera.getLoginId()); -// globalVariable.loginMap.put(camera.getId(), camera.getLoginId()); -// ardCamerasService.updateArdCameras(camera); -// } else { -// log.info("鐩告満" + camera.getIp() + ":" + camera.getPort() + "鐧诲綍澶辫触锛�" + camera.getLoginId()); -// } -// } else { -// Integer userid = globalVariable.loginMap.get(camera.getId()); -// log.info("褰撳墠鐩告満:" + camera.getId() + "宸茬櫥褰�,ID:" + userid); -// } - } - } catch (Exception ex) { - log.error("鍒濆鍖栫櫥褰曠浉鏈哄紓甯革細" + ex.getMessage()); - } - } - - /** - * @鎻忚堪 娉ㄩ攢鐧诲綍 - * @鍙傛暟 [dvrLogin] - * @杩斿洖鍊� java.lang.Integer - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/17 16:12 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - public boolean loginOut(String cameraId) { - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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) { - String cameraId = cmd.getCameraId(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = globalVariable.loginMap.get(cameraId); - boolean isOnLine = hCNetSDK.NET_DVR_RemoteControl(userId, HCNetSDK.NET_DVR_CHECK_USER_STATUS, null, 0); - return isOnLine; - } - - /** - * @鎻忚堪 甯﹂�熷害鐨勪簯鍙版帶鍒舵搷浣� - * 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 - @SdkOperate - public boolean PTZControlWithSpeed(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - boolean enable = cmd.isEnable(); - Integer channelNum = cmd.getChannelNum(); - Integer speed = cmd.getSpeed(); - Integer code = cmd.getCode(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = globalVariable.loginMap.get(cameraId); - Integer dwStop; - if (enable) { - dwStop = 0;//寮�鍚� - } else { - dwStop = 1;//鍏抽棴 - } - Integer 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.info("鎺у埗澶辫触,璇风◢鍚庨噸璇�" + errorCode); - } - return bool; - } - - /** - * 璁剧疆鑱氱劍鍊� - * - * @param cmd - */ - @Override - @SdkOperate - public boolean setFocusPos(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - Integer dwFocusPos = cmd.getDwFocusPos(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = globalVariable.loginMap.get(cameraId); - - NET_DVR_FOCUSMODE_CFG focusmodeCfg = new NET_DVR_FOCUSMODE_CFG(); - Pointer point = focusmodeCfg.getPointer(); - IntByReference ibrBytesReturned = new IntByReference(0); - focusmodeCfg.dwFocusPos = dwFocusPos; - boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_FOCUSMODECFG, channelNum, point, focusmodeCfg.size(), ibrBytesReturned); - if (!bool) { - int code = hCNetSDK.NET_DVR_GetLastError(); - log.info("璁剧疆鑱氱劍鍊煎け璐�,璇风◢鍚庨噸璇�" + code); - } - return bool; - } - - /** - * 鑾峰彇鑱氱劍鍊� - * - * @param cmd - */ - @Override - public Map<String, Object> getFocusPos(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - - if (!globalVariable.loginMap.containsKey(cameraId)) { - return new HashMap<>(); - } - Integer userId = globalVariable.loginMap.get(cameraId); - - NET_DVR_FOCUSMODE_CFG focusmodeCfg = new NET_DVR_FOCUSMODE_CFG(); - Pointer point = focusmodeCfg.getPointer(); - IntByReference ibrBytesReturned = new IntByReference(0); - boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, NET_DVR_GET_FOCUSMODECFG, channelNum, point, focusmodeCfg.size(), ibrBytesReturned); - if (bool) { - focusmodeCfg.read(); - Map<String, Object> map = new HashMap<>(); - map.put("dwFocusPos", focusmodeCfg.dwFocusPos); - map.put("byFocusDefinitionDisplay ", focusmodeCfg.byFocusDefinitionDisplay); - map.put("dwRelativeFocusPos", focusmodeCfg.dwRelativeFocusPos); - return map; - } else { - int code = hCNetSDK.NET_DVR_GetLastError(); - log.info("鑾峰彇鑱氱劍鍊煎け璐�,璇风◢鍚庨噸璇�" + code); - return new HashMap<>(); - } - } - - /** - * 璁剧疆棰勭疆鐐� - * - * @param cmd - */ - @Override - @SdkOperate - public boolean setPreset(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - Integer PresetIndex = cmd.getPresetIndex(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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.info("棰勭疆鐐硅缃け璐�,璇风◢鍚庨噸璇�" + code); - } - return bool; - } - - /** - * 杞埌棰勭疆鐐� - * - * @param cmd - */ - @Override - @SdkOperate - public boolean gotoPreset(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - Integer PresetIndex = cmd.getPresetIndex(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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.info("棰勭疆鐐硅缃け璐�,璇风◢鍚庨噸璇�" + code); - } - return bool; - } - - /** - * @鎻忚堪 鑾峰彇鍒嗚鲸鐜� - * @鍙傛暟 [cameraId, channelNum] - * @杩斿洖鍊� java.lang.String - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/2/3 8:36 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - public String getVideoResolution(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return " "; - } - Integer userId = globalVariable.loginMap.get(cameraId); - - String ResResolution = ""; - NET_DVR_COMPRESSIONCFG_V30 resolution = new NET_DVR_COMPRESSIONCFG_V30(); - resolution.write(); - Pointer pioint = resolution.getPointer(); - IntByReference ibrBytesReturned = new IntByReference(0); - try { - boolean bool = hCNetSDK.NET_DVR_GetDVRConfig(userId, HCNetSDK.NET_DVR_GET_COMPRESSCFG_V30, channelNum, pioint, resolution.size(), ibrBytesReturned); - if (bool) { - resolution.read(); - //瑙嗛杈撳嚭鍙e垎杈ㄧ巼锛�0- 1024x768锛�1- 1280x720锛�2-1280x1024锛�3- 1680x1050锛�4- 1920x1080锛�5- 3840*2160 - byte byStreamType = resolution.struNormHighRecordPara.byStreamType; - int dwVideoBitrate = resolution.struNormHighRecordPara.dwVideoBitrate; - int byResolution = resolution.struNormHighRecordPara.byResolution; - switch (byResolution) { - case 0: - ResResolution = "DCIF(528*384/528*320)"; - break; - case 1: - ResResolution = "CIF(352*288/352*240)"; - break; - case 2: - ResResolution = "QCIF(176*144/176*120)"; - break; - case 3: - ResResolution = "4CIF(704*576/704*480)"; - break; - case 4: - ResResolution = "2CIF(704*288/704*240)"; - break; - case 6: - ResResolution = "QVGA(320*240)"; - break; - case 7: - ResResolution = "QQVGA(160*120)"; - break; - case 16: - ResResolution = "VGA(640*480)"; - break; - case 17: - ResResolution = "UXGA(1600*1200)"; - break; - case 18: - ResResolution = "SVGA(800*600)"; - break; - case 19: - ResResolution = "HD720P(1280*720)"; - break; - case 20: - ResResolution = "XVGA(1280*960)"; - break; - case 21: - ResResolution = "HD900P(1600*900)"; - break; - case 22: - ResResolution = "1360*1024"; - break; - case 23: - ResResolution = "1536*1536"; - break; - case 24: - ResResolution = "1920*1920"; - break; - case 27: - ResResolution = "1920*1080p"; - break; - case 28: - ResResolution = "2560*1920"; - break; - case 29: - ResResolution = "1600*304"; - break; - case 30: - ResResolution = "2048*1536"; - break; - default: - ResResolution = "涓嶅湪褰撳墠鍒嗚鲸鐜囩储寮曪紝璇疯仈绯荤鐞嗗憳娣诲姞"; - break; - } - } else { - int code = hCNetSDK.NET_DVR_GetLastError(); - System.out.println("鎺у埗澶辫触,璇风◢鍚庨噸璇�" + code); - } - } catch (Exception ex) { - log.error(ex.getMessage()); - } - return ResResolution; - } - - /** - * @return - * @鎻忚堪 鑾峰彇ptz淇℃伅 - * @鍙傛暟 [userId, channelNum] - * @杩斿洖鍊� boolean - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/17 16:36 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - public Map<String, Object> getPtz(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return null; - } - Integer userId = 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杩涘埗杞琁nteger鍚庨櫎10锛屼繚鐣欏皬鏁扮偣1浣� - //瀹為檯鏄剧ず鐨凱TZ鍊兼槸鑾峰彇鍒扮殑鍗佸叚杩涘埗鍊肩殑鍗佸垎涔嬩竴锛� - //濡傝幏鍙栫殑姘村钩鍙傛暟P鐨勫�兼槸0x1750锛屽疄闄呮樉绀虹殑P鍊间负175搴︼紱 - //鑾峰彇鍒扮殑鍨傜洿鍙傛暟T鐨勫�兼槸0x0789锛屽疄闄呮樉绀虹殑T鍊间负78.9搴︼紱 - //鑾峰彇鍒扮殑鍙樺�嶅弬鏁癦鐨勫�兼槸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 { - int code = hCNetSDK.NET_DVR_GetLastError(); - log.info("鎺у埗澶辫触,璇风◢鍚庨噸璇�" + code); - return null; - } - - } - - /** - * @鎻忚堪 璁剧疆ptz淇℃伅 - * @鍙傛暟 [userId, channelNum] - * @杩斿洖鍊� boolean - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/17 16:36 - * @淇敼浜哄拰鍏跺畠淇℃伅 娉ㄦ剰淇话瑙掑害璐熷�奸渶瑕佸姞涓�360寰楀埌鐨勬鍊艰繘琛岃缃� - */ - @Override - @SdkOperate - public boolean setPtz(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - Map<String, Double> ptz = cmd.getPtzMap(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = globalVariable.loginMap.get(cameraId); - NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS(); - m_ptzPosCurrent.wAction = 1; - try { - String p = String.valueOf((int) ((double) ptz.get("p") * 10)); - String t = String.valueOf((int) ((double) ptz.get("t") * 10)); - String z = String.valueOf((int) ((double) 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.info("璁剧疆ptz澶辫触,璇风◢鍚庨噸璇�" + code); - } - return bool; - } catch (Exception ex) { - log.error(ex.getMessage()); - return false; - } - } - - @Override - @SdkOperate - public boolean setTargetPosition(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = globalVariable.loginMap.get(cameraId); - NET_DVR_PTZPOS m_ptzPosCurrent = new NET_DVR_PTZPOS(); - m_ptzPosCurrent.wAction = 1; - try { - double[] cameraPositon = cmd.getCamPosition(); - 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.info("璁剧疆ptz澶辫触,璇风◢鍚庨噸璇�" + code); - } - return bool; - } catch (Exception ex) { - log.error(ex.getMessage()); - return false; - } - } - - /** - * @鎻忚堪 鎿嶆帶閿佸畾 - * @鍙傛暟 [userId, channelNum] - * @杩斿洖鍊� boolean - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/17 16:36 - * @淇敼浜哄拰鍏跺畠淇℃伅 0-瑙i攣 1-閿佸畾 - */ - @Override - public boolean controlLock(CameraCmd cmd) { - String cameraId = cmd.getCameraId();//鐢宠閿佺殑鐩告満 - ArdCameras ardCameras = ardCamerasMapper.selectArdCamerasById(cameraId); - if (StringUtils.isNull(ardCameras)) { - return false;//鎵句笉鍒扮浉鏈烘嫆缁濇搷鎺� - } - Integer expired = cmd.getExpired();//鐢宠鎺у埗鏃堕暱 - String operator = cmd.getOperator();//鐢宠鑰� - String currentOperator = ardCameras.getOperatorId();//鐩告満褰撳墠鎺у埗鑰� - Date currentExpired = ardCameras.getOperatorExpired();//鐩告満褰撳墠杩囨湡鏃堕棿 - if (currentExpired == null) { - //璁剧疆褰撳墠鎿嶄綔鐢ㄦ埛ID - ardCameras.setOperatorId(operator); - //璁剧疆褰撳墠杩囨湡鏃堕棿 - Date now = new Date(); - now.setTime(now.getTime() + expired * 1000 * 60); - ardCameras.setOperatorExpired(now); - ardCamerasMapper.updateArdCameras(ardCameras); - } else { - //濡傛灉杩囨湡鏃堕棿鏈夊�� - //濡傛灉鏄湰浜虹洿鎺ヤ慨鏀� - if (currentOperator.equals(operator)) { - //璁剧疆褰撳墠杩囨湡鏃堕棿 - Date now = new Date(); - now.setTime(now.getTime() + expired * 1000 * 60); - ardCameras.setOperatorExpired(now); - ardCamerasMapper.updateArdCameras(ardCameras); - } else { - //濡傛灉闈炴湰浜烘瘮杈冧紭鍏堢骇 - Integer currentLevel = 0;//褰撳墠鎿嶄綔鑰呯殑浼樺厛绾� - if (sdkPriority.priorityMap.containsKey(currentOperator)) { - /*褰撳墠鎺у埗鑰呬负绯荤粺鎶ヨ鐢ㄦ埛*/ - currentLevel = (Integer) sdkPriority.priorityMap.get(currentOperator); - } else { - /*褰撳墠鎺у埗鑰呬负鏅�氱敤鎴�*/ - SysUser sysUser = sysUserMapper.selectUserById(currentOperator); - currentLevel = sysUser.getCameraPriority(); - } - Integer operatorLevel = 0;//鑾峰彇鐢宠鑰呯殑浼樺厛绾� - if (sdkPriority.priorityMap.containsKey(operator)) { - /*鍖呭惈璇存槑褰撳墠鐢宠鎺у埗鑰呬负绯荤粺鎶ヨ鐢ㄦ埛*/ - operatorLevel = (Integer) sdkPriority.priorityMap.get(operator); - } else { - /*鍚﹀垯鐢宠鎺у埗鑰呬负褰撳墠鐧诲綍鐢ㄦ埛*/ - LoginUser loginUser = SecurityUtils.getLoginUser(); - SysUser user = loginUser.getUser();//鑾峰彇鐧诲綍鐢ㄦ埛鐨勪俊鎭� - operatorLevel = user.getCameraPriority(); - } - //鍒ゆ柇浼樺厛绾� - if (operatorLevel > currentLevel) { - Date now = new Date(); - now.setTime(now.getTime() + expired * 60 * 1000); - ardCameras.setOperatorExpired(now);//璁剧疆褰撳墠杩囨湡鏃堕棿 - ardCameras.setOperatorId(operator);//璁剧疆褰撳墠鐢ㄦ埛 - ardCamerasMapper.updateArdCameras(ardCameras); - } else { - return false;//浼樺厛绾т綆鏃犳硶涓婇攣 - } - } - } - return true; - } - - /** - * @鎻忚堪 鑾峰彇ptz閿佸畾淇℃伅 - * @鍙傛暟 [userId, channelNum] - * @杩斿洖鍊� boolean - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/17 16:36 - * @淇敼浜哄拰鍏跺畠淇℃伅 0-瑙i攣 1-閿佸畾 - */ - @Override - public int getPTZLockInfo(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return -1; - } - Integer userId = 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.info("鑾峰彇ptz閿佸畾淇℃伅澶辫触,璇风◢鍚庨噸璇�" + code); - return -1; - } else { - netDvrPtzLockcfg.read(); - int byWorkMode = netDvrPtzLockcfg.byWorkMode; - return byWorkMode; - } - } - - /** - * @鎻忚堪 璁剧疆闆舵柟浣嶈 - * @鍙傛暟 [userId, channelNum] - * @杩斿洖鍊� boolean - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/17 16:36 - * @淇敼浜哄拰鍏跺畠淇℃伅 娉ㄦ剰淇话瑙掑害璐熷�奸渶瑕佸姞涓�360寰楀埌鐨勬鍊艰繘琛岃缃� - */ - @Override - @SdkOperate - public boolean setZeroPtz(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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<java.lang.String, java.lang.Object> - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/2/8 10:58 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - public Map<String, Object> getPtzScope(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return new HashMap<>(); - } - Integer userId = 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.info("璁剧疆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<String, Object> 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.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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.info("鏄惁寮�鍚�忛浘锛�" + 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.info("璁剧疆閫忛浘澶辫触,璇风◢鍚庨噸璇�" + code); - return false; - } - log.info("璁剧疆閫忛浘鎴愬姛"); - 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.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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.info("鏄惁寮�鍚瑙嗭細" + 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.info("璁剧疆澶滆澶辫触,璇风◢鍚庨噸璇�" + code); - return false; - } - log.info("璁剧疆澶滆鎴愬姛"); - 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.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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) { - System.out.println("鑾峰彇鍓嶇鍙傛暟澶辫触锛岄敊璇爜锛�" + hCNetSDK.NET_DVR_GetLastError()); - } - struFocusMode.read(); - log.info("褰撳墠鑱氱劍妯″紡锛�" + 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.info("璁剧疆鑱氱劍妯″紡澶辫触,璇风◢鍚庨噸璇�" + code); - return false; - } - log.info("璁剧疆鑱氱劍妯″紡鎴愬姛"); - return bool; - } - - /** - * @鎻忚堪 浜戝彴鍔犵儹寮�鍏� - * @鍙傛暟 [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.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = globalVariable.loginMap.get(cameraId); - Integer 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.info("璁剧疆浜戝彴鍔犵儹澶辫触,璇风◢鍚庨噸璇�" + code); - return false; - } - log.info("璁剧疆浜戝彴鍔犵儹鎴愬姛"); - 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.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return false; - } - Integer userId = 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.info("鏄惁寮�鍚櫎鍐帮細" + 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.info("璁剧疆闀滃ご闄ゅ啺澶辫触,璇风◢鍚庨噸璇�" + code); - return false; - } - log.info("璁剧疆闀滃ご闄ゅ啺鎴愬姛"); - return bool; - } - - /** - * 鎴浘 杩旂粰鍓嶇 - * - * @param cmd - */ - public String captureJPEGPicture(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return ""; - } - Integer userId = 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.info("-----------杩欓噷寮�濮嬪浘鐗囧瓨鍏ュ唴瀛�----------" + is); - - - BASE64Encoder encoder = new BASE64Encoder(); - String png_base64 = encoder.encodeBuffer(jpegBuffer);//杞崲鎴恇ase64涓� - png_base64 = png_base64.replaceAll("\n", "").replaceAll("\r", "");//鍒犻櫎 \r\n - log.info("-----------澶勭悊瀹屾垚鎴浘鏁版嵁----------"); - return png_base64; - -// ByteArrayInputStream in = new ByteArrayInputStream(jpegBuffer.array(), 0, a.getValue()); -// OutputStream outputStream = null; -// try { -// //1銆佽缃畆esponse 鍝嶅簲澶� //璁剧疆椤甸潰涓嶇紦瀛�,娓呯┖buffer -// response.reset(); -// //瀛楃缂栫爜 -// response.setCharacterEncoding("UTF-8"); -// //浜岃繘鍒朵紶杈撴暟鎹� -// response.setContentType("multipart/form-data"); -// //璁剧疆鍝嶅簲澶� -// response.setHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()) + ".jpeg", "UTF-8")); -// -// outputStream = response.getOutputStream(); -// // LoginUser loginUser = LoginContext.me().getLoginUser(); -// waterMarkUtil.markImageByIO("", in, outputStream, null, "jpeg"); -// outputStream.flush(); -// } catch (Exception e) { -// e.printStackTrace(); -// log.error("鎶撳浘澶辫触锛岃绋嶅悗閲嶈瘯"); -// } finally { -// try { -// outputStream.close(); -// } catch (IOException e) { -// log.error("鎶撳浘澶辫触锛岃绋嶅悗閲嶈瘯"); -// } -// } - - - } - - /** - * @鎻忚堪 鎴浘 瀛樻湇鍔″櫒 - * @鍙傛暟 [cameraId, channelNum] - * @杩斿洖鍊� java.lang.String - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/2/2 14:59 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - @SdkOperate - public String picCutCate(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return ""; - } - Integer userId = 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)鎴朌1(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.info("-----------杩欓噷寮�濮嬪皝瑁� NET_DVR_CaptureJPEGPicture_NEW---------"); - boolean is = hCNetSDK.NET_DVR_CaptureJPEGPicture_NEW(userId, channelNum, jpeg, jpegBuffer, 1024 * 1024, a); - log.info("-----------杩欓噷寮�濮嬪浘鐗囧瓨鍏ュ唴瀛�----------" + is); - if (is) { - log.info("hksdk(鎶撳浘)-缁撴灉鐘舵�佸��(0琛ㄧず鎴愬姛):" + hCNetSDK.NET_DVR_GetLastError()); - byte[] array = jpegBuffer.array(); - //瀛樺偍鍒癿inio - String BucketName = "pic"; - String uuid = UUID.randomUUID().toString().replace("-", ""); - String time = new SimpleDateFormat("yyyyMMdd").format(new Date()); - String ObjectName = time + "/" + uuid + ".jpeg"; - String ContentType = "image/JPEG"; - InputStream input = new ByteArrayInputStream(array); - String url = ""; - try { - boolean b = MinioUtils.uploadObject(BucketName, ObjectName, input, input.available(), ContentType); - if (b) { - url = MinioUtils.getBucketObjectUrl(BucketName, ObjectName); - log.info("涓婁紶鏂囦欢鎴愬姛!" + url); - } - } catch (IOException ex) { - log.error("涓婁紶鏂囦欢寮傚父锛�" + ex.getMessage()); - } - return url; - } else { - int code = hCNetSDK.NET_DVR_GetLastError(); - log.info("鎶撳浘澶辫触,璇风◢鍚庨噸璇�" + code); - return ""; - } - } - - /** - * @鎻忚堪 鐭椂褰曞儚 - * @鍙傛暟 [userId, channelNum, enable] - * @杩斿洖鍊� void - * @鍒涘缓浜� 鍒樿嫃涔� - * @鍒涘缓鏃堕棿 2023/1/20 11:18 - * @淇敼浜哄拰鍏跺畠淇℃伅 - */ - @Override - @SdkOperate - public String record(CameraCmd cmd) { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - boolean enable = cmd.isEnable(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return ""; - } - Integer userId = globalVariable.loginMap.get(cameraId); - String path = ""; - //棰勮鍙傛暟 - 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;//鎾斁绐楀彛鐨勫彞鏌勶紝涓篘ULL琛ㄧず涓嶈В鐮佹樉绀恒�� - previewinfo.bBlocked = 0;//0- 闈為樆濉炲彇娴侊紝1-闃诲鍙栨祦 - previewinfo.byNPQMode = 0;//NPQ妯″紡锛�0-鐩磋繛妯″紡锛�1-杩囨祦濯掍綋妯″紡 - previewinfo.write(); - int lRealHandle; - if (enable) { - if (!user_real_Map.containsKey(userId)) { - lRealHandle = hCNetSDK.NET_DVR_RealPlay_V40(userId, previewinfo, null, null); - if (lRealHandle == -1) { - int iErr = hCNetSDK.NET_DVR_GetLastError(); - log.error("鍙栨祦澶辫触" + iErr); - return ""; - } - log.info("鍙栨祦鎴愬姛"); - - File file = new File("D:/record/temp.mp4"); - if (!file.exists()) { - try { - File fileParent = file.getParentFile(); - if (!fileParent.exists()) { - fileParent.mkdirs(); - } - file.createNewFile(); - } catch (Exception e) { - e.printStackTrace(); - } - } - try { - path = file.getCanonicalPath(); - } catch (IOException e) { - e.printStackTrace(); - } - recordInfo info = new recordInfo(); - info.setLRealHandle(lRealHandle); - info.setRecordPath(path); - user_real_Map.put(userId, info); - } - recordInfo info = user_real_Map.get(userId); - if (!hCNetSDK.NET_DVR_SaveRealData_V30(info.getLRealHandle(), 1, info.getRecordPath())) { - log.error("淇濆瓨瑙嗛鏂囦欢鍒颁复鏃舵枃浠跺す澶辫触 閿欒鐮佷负: " + hCNetSDK.NET_DVR_GetLastError()); - return "淇濆瓨瑙嗛鏂囦欢鍒颁复鏃舵枃浠跺す澶辫触 閿欒鐮佷负:" + hCNetSDK.NET_DVR_GetLastError(); - } - log.info("褰曞儚寮�濮�"); - //return info.getRecordPath(); - return ""; - } else { - recordInfo info = user_real_Map.get(userId); - if (StringUtils.isNull(info)) { - return ""; - } - hCNetSDK.NET_DVR_StopRealPlay(info.getLRealHandle()); - log.info("褰曞儚鍋滄"); - //瀛樺叆minio - String BucketName = "record"; - String uuid = UUID.randomUUID().toString().replace("-", ""); - String time = new SimpleDateFormat("yyyyMMdd").format(new Date()); - String ObjectName = cameraId + "/" + time + "/" + uuid + ".mp4"; - String ContentType = "video/MP4"; - FileInputStream stream = null; - try { - stream = new FileInputStream(info.getRecordPath()); - } catch (FileNotFoundException e) { - e.printStackTrace(); - } - String url = ""; - try { - boolean b = MinioUtils.uploadObject(BucketName, ObjectName, stream, stream.available(), ContentType); - if (b) { - url = MinioUtils.getBucketObjectUrl(BucketName, ObjectName); - log.info("涓婁紶鏂囦欢鎴愬姛!" + url); - } - } catch (IOException ex) { - log.error("涓婁紶鏂囦欢寮傚父锛�" + ex.getMessage()); - } - user_real_Map.remove(userId); - return url; - } - } - - @Override - @SdkOperate - public void recordToMinio(CameraCmd cmd) { - try { - String cameraId = cmd.getCameraId(); - Integer channelNum = cmd.getChannelNum(); - boolean enable = cmd.isEnable(); - if (!globalVariable.loginMap.containsKey(cameraId)) { - return; - } - Integer userId = globalVariable.loginMap.get(cameraId); - String path = ""; - //棰勮鍙傛暟 - 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;//鎾斁绐楀彛鐨勫彞鏌勶紝涓篘ULL琛ㄧず涓嶈В鐮佹樉绀恒�� - previewinfo.bBlocked = 0;//0- 闈為樆濉炲彇娴侊紝1-闃诲鍙栨祦 - previewinfo.byNPQMode = 0;//NPQ妯″紡锛�0-鐩磋繛妯″紡锛�1-杩囨祦濯掍綋妯″紡 - previewinfo.write(); - int lRealHandle; - if (enable) { - if (!user_real_Map.containsKey(userId)) { - lRealHandle = hCNetSDK.NET_DVR_RealPlay_V40(userId, previewinfo, null, null); - if (lRealHandle == -1) { - int iErr = hCNetSDK.NET_DVR_GetLastError(); - log.error("鍙栨祦澶辫触" + iErr); - return; - } - log.info("鍙栨祦鎴愬姛"); - File file = new File("D:/recordTemp/" + cameraId + ".mp4"); - if (!file.exists()) { - File fileParent = file.getParentFile(); - if (!fileParent.exists()) { - fileParent.mkdirs(); - } - file.createNewFile(); - } - path = file.getCanonicalPath(); - recordInfo info = new recordInfo(); - info.setLRealHandle(lRealHandle); - info.setRecordPath(path); - user_real_Map.put(userId, info); - } - recordInfo info = user_real_Map.get(userId); - if (!hCNetSDK.NET_DVR_SaveRealData_V30(info.getLRealHandle(), 1, info.getRecordPath())) { - log.error("淇濆瓨瑙嗛鏂囦欢鍒颁复鏃舵枃浠跺す澶辫触 閿欒鐮佷负: " + hCNetSDK.NET_DVR_GetLastError()); - return; - } - log.info("褰曞儚寮�濮�"); - } else { - recordInfo info = user_real_Map.get(userId); - if (StringUtils.isNull(info)) { - return; - } - hCNetSDK.NET_DVR_StopRealPlay(info.getLRealHandle()); - log.info("褰曞儚鍋滄"); - //瀛樺叆minio - String BucketName = cmd.getRecordBucketName(); - String ObjectName = cmd.getRecordObjectName(); - String ContentType = "video/MP4"; - FileInputStream stream = new FileInputStream(info.getRecordPath()); - String url = ""; - boolean b = MinioUtils.uploadObject(BucketName, ObjectName, stream, stream.available(), ContentType); - if (b) { - log.info("涓婁紶鏂囦欢鎴愬姛!" + BucketName + "/" + ObjectName); - user_real_Map.remove(userId); - } - } - } catch (Exception ex) { - log.error("褰曞儚寮傚父" + ex.getMessage()); - } - } +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) { + try { + // 鍒濆鍖� + 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鍜宖alse + 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<ArdChannel> 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<String, Object> 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<GuideTask> comparator = GuidePriorityQueue.getComparator(); + PriorityBlockingQueue<GuideTask> priorityQueue = new PriorityBlockingQueue<>(1000, comparator); + GuidePriorityQueue.cameraQueueMap.put(camera.getId(), priorityQueue); + } + ardCamerasService.updateArdCameras(camera); + } + } catch (Exception ex) { + log.error("娉ㄥ唽璁惧寮傚父", ex); + } + } + + /** + * @鎻忚堪 娉ㄥ唽鐧诲綍 闆嗘垚浜嶯ET_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鍜宖alse + 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> 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<String, Object> 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<String, Object> 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; + } + //瑙嗛杈撳嚭鍙e垎杈ㄧ巼锛�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<String, Object> 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杩涘埗杞琁nteger鍚庨櫎10锛屼繚鐣欏皬鏁扮偣1浣� + //瀹為檯鏄剧ず鐨凱TZ鍊兼槸鑾峰彇鍒扮殑鍗佸叚杩涘埗鍊肩殑鍗佸垎涔嬩竴锛� + //濡傝幏鍙栫殑姘村钩鍙傛暟P鐨勫�兼槸0x1750锛屽疄闄呮樉绀虹殑P鍊间负175搴︼紱 + //鑾峰彇鍒扮殑鍨傜洿鍙傛暟T鐨勫�兼槸0x0789锛屽疄闄呮樉绀虹殑T鍊间负78.9搴︼紱 + //鑾峰彇鍒扮殑鍙樺�嶅弬鏁癦鐨勫�兼槸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 { + 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<String, Double> 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-瑙i攣 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<java.lang.String, java.lang.Object> + * @鍒涘缓浜� 鍒樿嫃涔� + * @鍒涘缓鏃堕棿 2023/2/8 10:58 + * @淇敼浜哄拰鍏跺畠淇℃伅 + */ + @Override + public Map<String, Object> 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<String, Object> 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());//杞崲鎴恇ase64涓� + 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)鎴朌1(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(); + //瀛樺偍鍒癿inio + 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;//鍥犱负涓婃枃浠g爜涓缃簡閫氶亾鍙凤紝鎸夌収涓婃枃涓殑璁剧疆 + 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;//鎾斁绐楀彛鐨勫彞鏌勶紝涓篘ULL琛ㄧず涓嶈В鐮佹樉绀恒�� + 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;//鍥犱负涓婃枃浠g爜涓缃簡閫氶亾鍙凤紝鎸夌収涓婃枃涓殑璁剧疆 + 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;//鎾斁绐楀彛鐨勫彞鏌勶紝涓篘ULL琛ㄧず涓嶈В鐮佹樉绀恒�� + 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;//鍥犱负涓婃枃浠g爜涓缃簡閫氶亾鍙凤紝鎸夌収涓婃枃涓殑璁剧疆 + 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;//鎾斁绐楀彛鐨勫彞鏌勶紝涓篘ULL琛ㄧず涓嶈В鐮佹樉绀恒�� + 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;//鍥犱负涓婃枃浠g爜涓缃簡閫氶亾鍙凤紝鎸夌収涓婃枃涓殑璁剧疆 + 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;//鎾斁绐楀彛鐨勫彞鏌勶紝涓篘ULL琛ㄧず涓嶈В鐮佹樉绀恒�� + 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<ArdChannel> getCameraChannelList(ArdCameras camera) { + /*鑾峰彇閫氶亾*/ + List<ArdChannel> 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-瑙i攣 1-閿佸畾 + */ + @Override + public Map<String, Object> 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<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; + } + } } \ No newline at end of file -- Gitblit v1.9.3