提交代码

.gitignore

@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store

README.md

@@ -0,0 +1,4 @@
+该工程用于项目引入访问硬件设备
+支持硬件厂商：
+1.大华
+2.海康

pom.xml

@@ -0,0 +1,39 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.yzx.hardware-access</groupId>
+    <artifactId>hardware-access</artifactId>
+    <version>1.0.0</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>com.sun.jna</groupId>
+            <artifactId>examples</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>net.java.dev.jna</groupId>
+            <artifactId>jna</artifactId>
+            <version>5.4.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.22</version>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.7</version>
+        </dependency>
+    </dependencies>
+</project>

src/main/java/com/common/CommonUtil.java

@@ -0,0 +1,29 @@
+
+
+package com.common;
+
+/**
+ * @author
+ * @create 2022-03-22-11:13
+ */
+public class CommonUtil {
+
+    //SDK时间解析
+    public static String parseTime(int time)
+    {
+        int year=(time>>26)+2000;
+        int month=(time>>22)&15;
+        int day=(time>>17)&31;
+        int hour=(time>>12)&31;
+        int min=(time>>6)&63;
+        int second=(time>>0)&63;
+        String sTime=year+"-"+month+"-"+day+"-"+hour+":"+min+":"+second;
+//        System.out.println(sTime);
+        return sTime;
+
+
+
+    }
+
+
+}

src/main/java/com/common/osSelect.java

@@ -0,0 +1,16 @@
+package com.common;
+
+/**
+ * @author
+ * @create 2022-01-19-16:40
+ */
+public class osSelect {
+
+    public static boolean isLinux() {
+        return System.getProperty("os.name").toLowerCase().contains("linux");
+    }
+
+    public static boolean isWindows() {
+        return System.getProperty("os.name").toLowerCase().contains("windows");
+    }
+}

src/main/java/com/hkversion/FMSGCallBack.java

@@ -0,0 +1,16 @@
+package com.hkversion;
+
+import com.sun.jna.Pointer;
+
+
+/**
+ * @author jiangxin
+ * @create 2022-08-15-17:26
+ */
+public class FMSGCallBack implements HCNetSDK.FMSGCallBack {
+    //报警信息回调函数
+    public void invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
+        AlarmDataParse.alarmDataHandle(lCommand, pAlarmer, pAlarmInfo, dwBufLen, pUser);
+        return;
+    }
+}

src/main/java/com/hkversion/FMSGCallBack_V31.java

@@ -0,0 +1,20 @@
+
+package com.hkversion;
+
+import com.sun.jna.Pointer;
+
+
+public class FMSGCallBack_V31 implements HCNetSDK.FMSGCallBack_V31 {
+    //报警信息回调函数
+    public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) {
+        AlarmDataParse.alarmDataHandle(lCommand, pAlarmer, pAlarmInfo, dwBufLen, pUser);
+        return true;
+    }
+}
+
+
+
+
+
+
+

src/main/java/com/yzx/IHardwareEquipment.java

@@ -0,0 +1,10 @@
+package com.yzx;
+
+public interface IHardwareEquipment {
+
+    /**
+     * 释放sdk资源
+     */
+    void cleanup();
+
+}

src/main/java/com/yzx/Main.java

@@ -0,0 +1,22 @@
+package com.yzx;
+
+import com.yzx.callback.AlarmCallback;
+import com.yzx.impl.HKVersion;
+import com.yzx.impl.HardwareEquipmentInfo;
+
+public class Main {
+    public static void main(String[] args) {
+
+        AlarmCallback alarmCallback = new AlarmCallback() {
+            @Override
+            public void process(String json) {
+                System.out.println(" 告警回调触发......");
+                System.out.println("json = " + json);
+            }
+        };
+
+        HardwareEquipmentInfo info = new HardwareEquipmentInfo("192.168.69.128",(short) 8000,"admin","yzx123456",alarmCallback);
+        IHardwareEquipment hardwareEquipment = new HKVersion(info);
+
+    }
+}

src/main/java/com/yzx/callback/AlarmCallback.java

@@ -0,0 +1,8 @@
+package com.yzx.callback;
+
+public interface AlarmCallback {
+    /**
+     * 告警回调函数，调用方必须实现该函数方可收到硬件设备的告警数据
+     */
+    void process(String json);
+}

src/main/java/com/yzx/impl/HKVersion.java

@@ -0,0 +1,161 @@
+package com.yzx.impl;
+
+import com.common.osSelect;
+import com.hkversion.FMSGCallBack;
+import com.hkversion.FMSGCallBack_V31;
+import com.hkversion.HCNetSDK;
+import com.sun.jna.Native;
+import com.sun.jna.Pointer;
+import com.yzx.IHardwareEquipment;
+
+public class HKVersion implements IHardwareEquipment {
+
+    //海康SDK
+    private static HCNetSDK hCNetSDK;
+    private int[] lUserID = new int[]{0, 0, 0, 0, 0};//用户句柄 实现对设备登录
+    private int[] lAlarmHandle = new int[]{-1, -1, -1, -1, -1};//报警布防句柄
+    private int[] lAlarmHandle_V50 = new int[]{-1, -1, -1, -1, -1}; //v50报警布防句柄
+    private int lListenHandle = -1;//报警监听句柄
+    private FMSGCallBack_V31 fMSFCallBack_V31 = null;
+    private FMSGCallBack fMSFCallBack=null;
+
+    static{
+        if (hCNetSDK == null) {
+            if (!CreateSDKInstance()) {
+                System.out.println("Load SDK fail");
+            }
+        }
+        /**初始化*/
+        hCNetSDK.NET_DVR_Init();
+        /**加载日志*/
+        hCNetSDK.NET_DVR_SetLogToFile(3, "../sdklog", false);
+    }
+    private HardwareEquipmentInfo info;
+    public HKVersion(HardwareEquipmentInfo info){
+        this.info = info;
+        this.alarm();
+
+    }
+
+    private void alarm(){
+        //设置报警回调函数
+        if (fMSFCallBack_V31 == null) {
+            fMSFCallBack_V31 = new FMSGCallBack_V31();
+            Pointer pUser = null;
+            if (!hCNetSDK.NET_DVR_SetDVRMessageCallBack_V31(fMSFCallBack_V31, pUser)) {
+                System.out.println("设置回调函数失败!");
+                return;
+            } else {
+                System.out.println("设置回调函数成功!");
+            }
+        }
+
+        /** 设备上传的报警信息是COMM_VCA_ALARM(0x4993)类型，
+         在SDK初始化之后增加调用NET_DVR_SetSDKLocalCfg(enumType为NET_DVR_LOCAL_CFG_TYPE_GENERAL)设置通用参数NET_DVR_LOCAL_GENERAL_CFG的byAlarmJsonPictureSeparate为1，
+         将Json数据和图片数据分离上传，这样设置之后，报警布防回调函数里面接收到的报警信息类型为COMM_ISAPI_ALARM(0x6009)，
+         报警信息结构体为NET_DVR_ALARM_ISAPI_INFO（与设备无关，SDK封装的数据结构），更便于解析。*/
+        HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG struNET_DVR_LOCAL_GENERAL_CFG = new HCNetSDK.NET_DVR_LOCAL_GENERAL_CFG();
+        struNET_DVR_LOCAL_GENERAL_CFG.byAlarmJsonPictureSeparate = 1;   //设置JSON透传报警数据和图片分离
+        struNET_DVR_LOCAL_GENERAL_CFG.write();
+        Pointer pStrNET_DVR_LOCAL_GENERAL_CFG = struNET_DVR_LOCAL_GENERAL_CFG.getPointer();
+        hCNetSDK.NET_DVR_SetSDKLocalCfg(17, pStrNET_DVR_LOCAL_GENERAL_CFG);
+        this.Login_V40(0, info.getIp(), info.getPort(), info.getUsername(), info.getPassword());  //登录设备
+
+        this.SetAlarm(0);//报警布防，和报警监听二选一即可
+    }
+
+    private void SetAlarm(int i) {
+        if (lAlarmHandle[i] < 0)//尚未布防,需要布防
+        {
+            //报警布防参数设置
+            HCNetSDK.NET_DVR_SETUPALARM_PARAM m_strAlarmInfo = new HCNetSDK.NET_DVR_SETUPALARM_PARAM();
+            m_strAlarmInfo.dwSize = m_strAlarmInfo.size();
+            m_strAlarmInfo.byLevel = 0;  //布防等级
+            m_strAlarmInfo.byAlarmInfoType = 1;   // 智能交通报警信息上传类型：0- 老报警信息（NET_DVR_PLATE_RESULT），1- 新报警信息(NET_ITS_PLATE_RESULT)
+            m_strAlarmInfo.byDeployType = 0;   //布防类型：0-客户端布防，1-实时布防
+            m_strAlarmInfo.write();
+            lAlarmHandle[i] = hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID[i], m_strAlarmInfo);
+            System.out.println("lAlarmHandle: " + lAlarmHandle[i]);
+            if (lAlarmHandle[i] == -1) {
+                System.out.println("布防失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+                return;
+            } else {
+                System.out.println("布防成功");
+
+            }
+        } else {
+
+            System.out.println("设备已经布防，请先撤防！");
+        }
+    }
+
+    /**
+     * 设备登录V40 与V30功能一致
+     *
+     * @param i    登录设备编号
+     * @param ip   设备IP
+     * @param port SDK端口，默认设备的8000端口
+     * @param user 设备用户名
+     * @param psw  设备密码
+     */
+    private void Login_V40(int i, String ip, short port, String user, String psw) {
+        //注册
+        HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登录信息
+        HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
+
+        String m_sDeviceIP = ip;//设备ip地址
+        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());
+
+        String m_sUsername = user;//设备用户名
+        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());
+
+        String m_sPassword = psw;//设备密码
+        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 = port;
+        m_strLoginInfo.bUseAsynLogin = false; //是否异步登录：0- 否，1- 是
+//        m_strLoginInfo.byLoginMode=1;  //ISAPI登录
+        m_strLoginInfo.write();
+
+        lUserID[i] = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo, m_strDeviceInfo);
+        if (lUserID[i] == -1) {
+            System.out.println("登录失败，错误码为" + hCNetSDK.NET_DVR_GetLastError());
+        } else {
+            System.out.println(ip + ":设备登录成功！");
+        }
+    }
+
+    @Override
+    public void cleanup() {
+        hCNetSDK.NET_DVR_Cleanup();
+    }
+
+    /**
+     * 动态库加载
+     *
+     * @return
+     */
+    private static boolean CreateSDKInstance() {
+        if (hCNetSDK == null) {
+            synchronized (HCNetSDK.class) {
+                String strDllPath = "";
+                try {
+                    if (osSelect.isWindows())
+                        //win系统加载库路径
+                        strDllPath = System.getProperty("user.dir") + "\\lib\\HCNetSDK.dll";
+                    else if (osSelect.isLinux())
+                        //Linux系统加载库路径
+                        strDllPath = "/home/LinuxSDK/libhcnetsdk.so";
+                    hCNetSDK = (HCNetSDK) Native.loadLibrary(strDllPath, HCNetSDK.class);
+                } catch (Exception ex) {
+                    System.out.println("loadLibrary: " + strDllPath + " Error: " + ex.getMessage());
+                    return false;
+                }
+            }
+        }
+        return true;
+    }
+}

src/main/java/com/yzx/impl/HardwareEquipmentInfo.java

@@ -0,0 +1,19 @@
+package com.yzx.impl;
+
+import com.yzx.callback.AlarmCallback;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+/**
+ * 设备信息，包含ip，端口，用户名，密码等信息
+ */
+@Data
+@AllArgsConstructor
+public class HardwareEquipmentInfo {
+    private String ip;
+    private short port;
+    private String username;
+    private String password;
+
+    private AlarmCallback alarmCallback;
+}

src/main/libs/linux64/HCNetSDK_Log_Switch.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="GB2312"?>
+<SdkLocal>
+	<SdkLog>
+        <logLevel>3</logLevel><!--req, 1-ERROR, 2-DEBUG, 3-INFO-->
+        <logDirectory>./SDKLOG/</logDirectory><!--the end of the string must be '/'-->
+        <autoDelete>true</autoDelete><!--true: There are less than 10 files in the directory, it will be auto deleted by sdk when the files are more than 10; false: No upper limit to the number of log files-->
+    </SdkLog>
+	<HeartbeatCfg>
+		<Interval>120</Interval> <!-- 心跳时间间隔，单位秒，等于0，使用默认值120s，取值范围为[30, 120] 小于30s，间隔为30s，大于120s，间隔为120s-->
+		<Count>1</Count> 	<!-- 触发异常回调需要心跳交互异常的次数，等于0，使用默认值1次-->
+	</HeartbeatCfg>
+</SdkLocal>