From 5b017324148ea92d96f9f16ade215463d6c712e5 Mon Sep 17 00:00:00 2001
From: liusuyi <1951119284@qq.com>
Date: 星期六, 10 八月 2024 14:15:02 +0800
Subject: [PATCH] 优化：海康大华sdk断线重连机制
---
ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/module/ConfigModule.java | 70 +++++++++++++++++++++++++++++++++-
1 files changed, 67 insertions(+), 3 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/module/ConfigModule.java b/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/module/ConfigModule.java
index c874eaa..7075434 100644
--- a/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/module/ConfigModule.java
+++ b/ard-work/src/main/java/com/ruoyi/utils/sdk/dhsdk/module/ConfigModule.java
@@ -2,6 +2,8 @@
import com.ruoyi.utils.sdk.dhsdk.lib.NetSDKLib;
import com.ruoyi.utils.sdk.dhsdk.lib.ToolKits;
+import com.sun.jna.Memory;
+import com.sun.jna.Pointer;
import com.sun.jna.Structure;
import com.sun.jna.ptr.IntByReference;
import lombok.extern.slf4j.Slf4j;
@@ -63,7 +65,7 @@
int nBufferLen = 2 * 1024 * 1024;
byte[] strBuffer = new byte[nBufferLen];
- if (netsdk.CLIENT_GetNewDevConfig(hLoginHandle, strCmd, nChn, strBuffer, nBufferLen, error, 3000)) {
+ if (netsdk.CLIENT_GetNewDevConfig(hLoginHandle, strCmd, nChn, strBuffer, nBufferLen, error, 6000)) {
cmdObject.write();
if (configsdk.CLIENT_ParseData(strCmd, strBuffer, cmdObject.getPointer(), cmdObject.size(), null)) {
cmdObject.read();
@@ -80,6 +82,22 @@
return result;
}
+ //鏌ヨ閫氶亾鍚嶇О
+ public static String getChannelName(NetSDKLib.LLong hLoginHandle, Integer channel) {
+ String channelName = "";
+ NetSDKLib.AV_CFG_ChannelName channelTitleName = new NetSDKLib.AV_CFG_ChannelName();
+ if (ToolKits.GetDevConfig(hLoginHandle, channel - 1, NetSDKLib.CFG_CMD_CHANNELTITLE, channelTitleName)) {
+ try {
+ channelName = new String(channelTitleName.szName, "GBK");
+ } catch (Exception e) {
+ log.error("getChannelName Failed!");
+ }
+ } else {
+ log.error("Get Channel Name Failed." + ToolKits.getErrorCodePrint());
+ }
+ return channelName;
+ }
+
public static boolean GetDevConfig(NetSDKLib.LLong hLoginHandle, int nChn, String strCmd, Structure cmdObject) {
boolean result = true;
IntByReference error = new IntByReference(0);
@@ -90,10 +108,57 @@
if (bRet) {
cmdObject.read();
} else {
- log.error("Get ["+strCmd+"] Config Failed!Last Error = " + getErrorCodePrint());
+ log.error("Get [" + strCmd + "] Config Failed!Last Error = " + getErrorCodePrint());
result = false;
}
return result;
+ }
+
+ //鏌ヨ鐩告満鐘舵��
+ public static boolean queryCameraState(NetSDKLib.LLong hLoginHandle, Integer chanNum, Integer chanNo) {
+ boolean bRet = false;
+ try {
+ NetSDKLib.NET_CAMERA_STATE_INFO[] arrCameraStatus = new NetSDKLib.NET_CAMERA_STATE_INFO[chanNum];
+ for (int i = 0; i < arrCameraStatus.length; i++) {
+ arrCameraStatus[i] = new NetSDKLib.NET_CAMERA_STATE_INFO();
+ }
+
+ // 鍏ュ弬
+ NetSDKLib.NET_IN_GET_CAMERA_STATEINFO stIn = new NetSDKLib.NET_IN_GET_CAMERA_STATEINFO();
+ stIn.bGetAllFlag = 0; // 鍏ㄩ儴
+ stIn.nValidNum = chanNum;
+ stIn.nChannels[chanNo - 1] = chanNo - 1;
+
+ // 鍑哄弬
+ NetSDKLib.NET_OUT_GET_CAMERA_STATEINFO stOut = new NetSDKLib.NET_OUT_GET_CAMERA_STATEINFO();
+ stOut.nMaxNum = chanNum;
+ stOut.pCameraStateInfo = new Memory(arrCameraStatus[0].size() * chanNum);
+ stOut.pCameraStateInfo.clear(arrCameraStatus[0].size() * chanNum);
+ ToolKits.SetStructArrToPointerData(arrCameraStatus, stOut.pCameraStateInfo); // 灏嗘暟缁勫唴瀛樻嫹璐濆埌Pointer
+
+ stIn.write();
+ stOut.write();
+
+ bRet = netsdk.CLIENT_QueryDevInfo(hLoginHandle, NetSDKLib.NET_QUERY_GET_CAMERA_STATE,
+ stIn.getPointer(), stOut.getPointer(), null, 3000);
+ if (bRet) {
+ stOut.read();
+ ToolKits.GetPointerDataToStructArr(stOut.pCameraStateInfo, arrCameraStatus); // 灏哖ointer鎷疯礉鍒版暟缁勫唴瀛�
+ final String[] connectionState = {"鏈煡", "姝ｅ湪杩炴帴", "宸茶繛鎺�", "鏈繛鎺�", "閫氶亾鏈厤缃�,鏃犱俊鎭�", "閫氶亾鏈夐厤缃�,浣嗚绂佺敤"};
+
+ if (connectionState[arrCameraStatus[chanNo - 1].emConnectionState].equals("宸茶繛鎺�")) {
+ //log.debug("閫氶亾锛�" + arrCameraStatus[chanNo - 1].nChannel + "鐘舵�侊細" + connectionState[arrCameraStatus[chanNo - 1].emConnectionState]);
+ bRet = true;
+ } else {
+ bRet = false;
+ }
+ } else {
+ log.error("Query Camera State Failed!" + getErrorCodePrint());
+ }
+ } catch (Exception ex) {
+ log.error("Query Camera State Failed!" + ex.getMessage());
+ }
+ return bRet;
}
// 鑾峰彇閰嶇疆
@@ -144,6 +209,5 @@
return result;
}
-
}
--
Gitblit v1.9.3