From 1ca9656140c41165459dfb6f6b7606b3aa6a8747 Mon Sep 17 00:00:00 2001
From: zhangnaisong <2434969829@qq.com>
Date: Wed, 24 Jul 2024 15:05:13 +0800
Subject: [PATCH] 三一车辆查询加入关联后bug修改提交

---
 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);  // 将Pointer拷贝到数组内存
+                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