devbox
繁依Fanyi0
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Java-Spring Boot 集成海康威视明眸门禁 布防|报警|回调|获取事件|查询用户信息_明眸门禁设备代码

作者：繁依Fanyi0 | 2024-07-19 09:18:56

赞

踩

明眸门禁设备代码

最近做门禁的集成，突然感觉海康这个东西挺有意思的，于是记录一下。

好了废话不多说，开始上环境、代码

本集成是海康-设备网络集成（以人为中心）

环境：windows

开发工具：IDEA

JDK版本：JDK-11.0.12

海康jar包：怎么引入都行（本地引入、maven上传到私服）

                链接：https://pan.baidu.com/s/12limkwExPqn9q-vUc6zA6g?pwd=xr0s 
                提取码：xr0s 

海康库：

        windows环境：链接：https://pan.baidu.com/s/10iADLziw-jdxWd9Awmuu4Q?pwd=o26k 
                                提取码：o26k 

        linux环境：     链接：https://pan.baidu.com/s/10iADLziw-jdxWd9Awmuu4Q?pwd=o26k 
                                提取码：o26k 

布防整体流程：

我们就以此流程开始：

1、初始化SDK：
  1.     /**
  2.      * 海康设备提前操作方法（第一步）
  3.      */
  4.     private Integer preparation(String ip, String user, String password, Integer port, Boolean isLogin) {
  5.         // 创建操作类
  6.         createHkSdkInstance();
  7.         // 加载组件库
  8.         loadLinuxSystem(SystemHkSelect.isLinux());
  9.         // 初始话操作类
  10.         HK_NET_SDK.NET_DVR_Init();
  11.  
  12.         log.info("海康设备初始化成功！");
  13.         // 操作完成，首先登录设备
  14.         return loginAccessHk(ip, user, password, ObjectUtils.isNotEmpty(port) ? Short.parseShort(port.toString()) : (short) 8000;
  15.     }

参数解释：

ip：门禁设备的IP地址

user：门禁设备的管理员

password：管理员密码

port：端口   默认8000

isLogin：暂时无用

  1.  
  2.     /**
  3.      * 创建海康SDK操作类（第二步）
  4.      */
  5.     private void createHkSdkInstance() {
  6.         try {
  7.             // 海康SDK操作类
  8.             if (HK_NET_SDK == null) {
  9.                 log.info("海康SDK操作类为空，开始创建海康SDK操作类");
  10.                 HK_NET_SDK = (HCNetSDK) Native.loadLibrary(stringDllPath,         
  11.                 HCNetSDK.class);
  12.                 log.info("海康SDK操作类创建成功");
  13.             } else {
  14.                 log.info("海康SDK操作类不为空，无需创建");
  15.             }
  16.         } catch (Exception e) {
  17.             throw exception(UNKNOWN_OPERATING_SYSTEM);
  18.         }
  19.     }
  20.  
  21.  
  22.  
  23.

参数解释：

 stringDllPath：海康库的加载地址（配置成海康库里HCNetSDK.dll这个文件的路径）

        windows环境：C:\\Users\\PinRu\\Desktop\\CH-HCNetSDKV6.1.9.48_build20230410_win64\\lib\\HCNetSDK.dll

        linux环境：C:\\Users\\PinRu\\Desktop\\CH-HCNetSDKV6.1.9.48_build20230410_linux64\\lib\\libhcnetsdk.so

  1.  
  2. /**
  3.  * linux系统建议调用以下接口加载组件库（win下不需要操作）（第三步）
  4.  */
  5. private void loadLinuxSystem(Boolean isLinux) {
  6.         // linux系统建议调用以下接口加载组件库（win下不需要操作）
  7.         if (isLinux) {
  8.             log.info("加载海康组件库" + isLinux);
  9.             HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
  10.             HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
  11.             //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
  12.             // cry组件库
  13.             System.arraycopy(stringCryPath.getBytes(), 0, ptrByteArray1.byValue, 0,
  14.                     stringCryPath.length());
  15.             ptrByteArray1.write();
  16.             HK_NET_SDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
  17.             System.arraycopy(stringSslPath.getBytes(), 0, ptrByteArray2.byValue, 0,
  18.                     stringSslPath.length());
  19.             ptrByteArray2.write();
  20.             // ssl组件库
  21.             HK_NET_SDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
  22.             HCNetSDK.NET_DVR_LOCAL_SDK_PATH strComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
  23.             // lib组件库
  24.             System.arraycopy(stringLibPath.getBytes(), 0, strComPath.sPath, 0,
  25.                     stringLibPath.length());
  26.             strComPath.write();
  27.             HK_NET_SDK.NET_DVR_SetSDKInitCfg(2, strComPath.getPointer());
  28.         }
  29.     }

参数解释： 

 isLinusx：是否是linux环境（win开发环境下，直接写成false）

stringCryPath：cry路径         默认路径：/lib/libcrypto.so.1.1

stringSslPath：ssl路径          默认路径：/lib/libssl.so.1.1

stringLibPath：lib库路径       默认路径：/lib/

2、用户注册
  1.     public static Integer loginAccessHk(String deviceIp, String userName, String password,
  2.             short port) {
  3.         //注册（登录海康设备）
  4.         //设备登录信息
  5.         HCNetSDK.NET_DVR_USER_LOGIN_INFO strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();
  6.         //设备ip地址
  7.         strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
  8.         System.arraycopy(deviceIp.getBytes(), 0, strLoginInfo.sDeviceAddress, 0, deviceIp.length());
  9.  
  10.         //设备用户名
  11.         strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
  12.         System.arraycopy(userName.getBytes(), 0, strLoginInfo.sUserName, 0, userName.length());
  13.  
  14.         //设备密码
  15.         strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
  16.         System.arraycopy(password.getBytes(), 0, strLoginInfo.sPassword, 0, password.length());
  17.  
  18.         //sdk端口
  19.         strLoginInfo.wPort = port;
  20.         //是否异步登录：0- 否，1- 是
  21.         strLoginInfo.bUseAsynLogin = false;
  22.         strLoginInfo.write();
  23.         //设备信息
  24.         HCNetSDK.NET_DVR_DEVICEINFO_V40 strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();
  25.         AtomicInteger userId = new AtomicInteger(-1);
  26.         userId.set(HK_NET_SDK.NET_DVR_Login_V40(strLoginInfo, strDeviceInfo));
  27.         if (userId.get() == -1) {
  28.             return HK_NET_SDK.NET_DVR_GetLastError();
  29.         } else {
  30.             log.info("设备登录成功，用户ID：" + userId);
  31.             strDeviceInfo.read();
  32.             CHAR_ENCODE_TYPE = strDeviceInfo.byCharEncodeType;
  33.         }
  34.         return userId.get();
  35.     }

参数解释：

deviceIp：门禁设备的IP地址

userName：门禁设备的管理员

password：管理员密码

port：端口   默认8000

3、门禁设备布防
  1.     public Boolean equipmentRegistration() {
  2.         // 设备准备工作（必须调用）
  3.         try {
  4.             Integer userId = preparation("", "", "", null, null);
  5.             // 回调函数
  6.             if (callBack == null) {
  7.                 callBack = new HkEquipmentCallBack();
  8.             }
  9.             // 设置回调
  10.             HK_NET_SDK.NET_DVR_SetDVRMessageCallBack_V50(0, callBack, null);
  11.             //布防参数
  12.             HCNetSDK.NET_DVR_SETUPALARM_PARAM_V50 param =
  13.                     new HCNetSDK.NET_DVR_SETUPALARM_PARAM_V50();
  14.             param.dwSize = param.size();
  15.             //布防等级
  16.             param.byLevel = 0;
  17.             // 智能交通报警信息上传类型：0- 老报警信息（NET_DVR_PLATE_RESULT），1- 新报警信息(NET_ITS_PLATE_RESULT)
  18.             param.byAlarmInfoType = 1;
  19.             //布防类型：0-客户端布防，1-实时布防
  20.             param.byDeployType = 1;
  21.             param.write();
  22.             // 设备布防
  23.             int v41 = HK_NET_SDK.NET_DVR_SetupAlarmChan_V50(userId, param, null, 0);
  24.  
  25.             if (v41 < 0) {
  26.                 log.info("设备布防失败，布防结果：" + v41);
  27.                 // 布防失败
  28.                 logout(userId);
  29.             }
  30.         } catch (Exception e) {
  31.             log.error("门禁设备设置门禁布防失败！错误信息：", e);
  32.             return Boolean.FALSE;
  33.         }
  34.         log.info("布防成功");
  35.         return Boolean.TRUE;
  36.     }

HkEquipmentCallBack 布防回调：

  1. import cn.hutool.extra.spring.SpringUtil;
  2. import com.sun.jna.Pointer;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.stereotype.Component;
  5.  
  6. /**
  7.  * 布防回调的入口
  8.  */
  9. @Component
  10. @Slf4j
  11. public class HkEquipmentCallBack implements HCNetSDK.FMSGCallBack_V31 {
  12.  
  13.     @Override
  14.     public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlar, Pointer pAlarmInfo,
  15.             int dwBufLen, Pointer pUser) {
  16.         log.info("hk alarm call back，type：{}", lCommand);
  17.         // 轮询处理事件回调
  18.         switch (lCommand) {
  19.             case HCNetSDK.COMM_ALARM:
  20.                 saveEquipmentLog(pAlar);
  21.                 break;
  22.             case HCNetSDK.COMM_TRADEINFO:
  23.                 saveEquipmentLog(pAlar);
  24.                 break;
  25.             case HCNetSDK.COMM_ALARM_V30:
  26.                 break;
  27.             case HCNetSDK.COMM_ALARM_V40:
  28.                 saveEquipmentLog(pAlar);
  29.                 break;
  30.             case HCNetSDK.COMM_ALARM_RULE:
  31.                 saveEquipmentLog(pAlar);
  32.                 break;
  33.             case HCNetSDK.COMM_IPCCFG:
  34.                 saveEquipmentLog(pAlar);
  35.                 break;
  36.             case HCNetSDK.COMM_UPLOAD_FACESNAP_RESULT:
  37.                 saveEquipmentLog(pAlar);
  38.                 break;
  39.             case HCNetSDK.COMM_SNAP_MATCH_ALARM:
  40.                 saveEquipmentLog(pAlar);
  41.                 break;
  42.             case HCNetSDK.COMM_ALARM_ACS:
  43.                 // 门禁设备主机报警
  44.                 EquipmentHandle handle = SpringUtil.getBean(EquipmentHandle.class);
  45.                 handle.equipmentHandleMethod(pAlar, pAlarmInfo);
  46.                 break;
  47.             case HCNetSDK.COMM_ID_INFO_ALARM:
  48.                 saveEquipmentLog(pAlar);
  49.                 break;
  50.             case HCNetSDK.COMM_VCA_ALARM:
  51.                 saveEquipmentLog(pAlar);
  52.                 break;
  53.             case HCNetSDK.COMM_ISAPI_ALARM:
  54.                 saveEquipmentLog(pAlar);
  55.                 break;
  56.             case HCNetSDK.COMM_ALARMHOST_CID_ALARM:
  57.                 saveEquipmentLog(pAlar);
  58.                 break;
  59.             case HCNetSDK.COMM_SWITCH_ALARM:
  60.                 saveEquipmentLog(pAlar);
  61.                 break;
  62.             case HCNetSDK.COMM_ALARMHOST_EXCEPTION:
  63.                 saveEquipmentLog(pAlar);
  64.                 break;
  65.             case HCNetSDK.COMM_ALARMHOST_OPERATEEVENT_ALARM:
  66.                 saveEquipmentLog(pAlar);
  67.                 break;
  68.             case HCNetSDK.COMM_ALARMHOST_ALARMOUTSTATUS:
  69.                 saveEquipmentLog(pAlar);
  70.                 break;
  71.             case HCNetSDK.COMM_UPLOAD_VIDEO_INTERCOM_EVENT:
  72.                 saveEquipmentLog(pAlar);
  73.                 break;
  74.             case HCNetSDK.COMM_ALARM_VIDEO_INTERCOM:
  75.                 saveEquipmentLog(pAlar);
  76.                 break;
  77.             case HCNetSDK.COMM_THERMOMETRY_ALARM:
  78.                 saveEquipmentLog(pAlar);
  79.                 break;
  80.             case HCNetSDK.COMM_FIREDETECTION_ALARM:
  81.                 saveEquipmentLog(pAlar);
  82.                 break;
  83.             case HCNetSDK.COMM_THERMOMETRY_DIFF_ALARM:
  84.                 saveEquipmentLog(pAlar);
  85.                 break;
  86.             case HCNetSDK.COMM_UPLOAD_AIOP_VIDEO:
  87.                 saveEquipmentLog(pAlar);
  88.                 break;
  89.             case HCNetSDK.COMM_UPLOAD_AIOP_POLLING_SNAP:
  90.                 saveEquipmentLog(pAlar);
  91.                 break;
  92.             case HCNetSDK.COMM_UPLOAD_AIOP_POLLING_VIDEO:
  93.                 saveEquipmentLog(pAlar);
  94.                 break;
  95.             case HCNetSDK.COMM_IPC_AUXALARM_RESULT:
  96.                 saveEquipmentLog(pAlar);
  97.                 break;
  98.             default:
  99.                 break;
  100.         }
  101.         return false;
  102.     }
  103.  
  104.     private void saveEquipmentLog(HCNetSDK.NET_DVR_ALARMER pAlar) {
  105.         // 给个回调，嗨嗨嗨
  106.         log.info("此报警暂时不需要做何处理，休息一下吧~~~~");
  107.     }
  108. }

布防回调目前我这只用到主机报警

报警处理类EquipmentHandle ：

  1. import cn.hutool.core.codec.Base64Encoder;
  2. import cn.hutool.extra.spring.SpringUtil;
  3. import com.sun.jna.Pointer;
  4. import lombok.extern.slf4j.Slf4j;
  5. import org.apache.commons.lang3.ObjectUtils;
  6. import org.apache.commons.lang3.StringUtils;
  7. import org.springframework.stereotype.Component;
  8.  
  9. import java.nio.Buffer;
  10. import java.nio.ByteBuffer;
  11.  
  12. /**
  13.  * 门禁设备布防报警-回调的处理类
  14.  */
  15. @Component
  16. @Slf4j
  17. public class EquipmentHandle {
  18.  
  19.     public void equipmentHandleMethod(HCNetSDK.NET_DVR_ALARMER pAlar, Pointer pAlarmInfo) {
  20.         // 设备主机事件
  21.         HCNetSDK.NET_DVR_ACS_ALARM_INFO strAcsInfo = new HCNetSDK.NET_DVR_ACS_ALARM_INFO();
  22.         strAcsInfo.write();
  23.         Pointer pAcsInfo = strAcsInfo.getPointer();
  24.         pAcsInfo.write(0, pAlarmInfo.getByteArray(0, strAcsInfo.size()), 0, strAcsInfo.size());
  25.         strAcsInfo.read();
  26.         // 门禁事件的详细信息解析，通过主次类型的可以判断当前的具体门禁类型，例如（主类型：0X5 次类型：0x4b 表示人脸认证通过，
  27.         // 主类型：0X5 次类型：0x4c 表示人脸认证失败）
  28.         saveEquipmentLogAcs(pAlar, strAcsInfo);
  29.     }
  30.  
  31.     private void saveEquipmentLogAcs(HCNetSDK.NET_DVR_ALARMER pAlar, HCNetSDK.NET_DVR_ACS_ALARM_INFO strAcsInfo) {
  32.         // 获取事件的类型
  33.         String messageMain = HkEventEnum.getMessageByCode(strAcsInfo.dwMajor);
  34.         String message = HkEventEnum.getMessageByCode(strAcsInfo.dwMinor);
  35.         if (ObjectUtils.isEmpty(messageMain) && ObjectUtils.isEmpty(message)) {
  36.             // 主级事件为null，则不记录
  37.             return;
  38.         }
  39.         if (HkEventEnum.Hk_Event_84.getEventType().equals(strAcsInfo.dwMinor)
  40.                 || HkEventEnum.Hk_Event_85.getEventType().equals(strAcsInfo.dwMinor)
  41.                 || HkEventEnum.Hk_Event_1024.getEventType().equals(strAcsInfo.dwMinor)) {
  42.             // 屏蔽部分非法事件
  43.             return;
  44.         }
  45.         
  46.         // 获取卡号
  47.         String byCardNo = new String(strAcsInfo.struAcsEventInfo.byCardNo).trim();
  48.         log.info("卡号：" + byCardNo);
  49.         // 获取卡类型 人员类型（0：白名单，1：访客，2：黑名单）
  50.         String byCardType = String.valueOf(strAcsInfo.struAcsEventInfo.byCardType);
  51.         // 设备唯一编码
  52.         String byDeviceNo = String.valueOf(strAcsInfo.struAcsEventInfo.byDeviceNo);
  53.         // 通进类型（0：入场，1：离场）
  54.         String dwDoorNo = String.valueOf(strAcsInfo.struAcsEventInfo.dwDoorNo);
  55.  
  56.         // 给个回调，嗨嗨嗨
  57.         HkCallBackBuilderVo builder = new HkCallBackBuilderVo(pAlar);
  58.         log.info("获取到的本机IP地址：{}", builder.sDeviceIpStr);
  59.  
  60.         // 人员工号，需要关联查询
  61.         if (ObjectUtils.isNotEmpty(builder.sDeviceIpStr)) {
  62.             // 获取设备详情
  63.             // 取值类型
  64.             HkAdapter hkAdapter = SpringUtil.getBean(HkAdapter.class);
  65.             log.info("当前回调的事件编号：{}", strAcsInfo.struAcsEventInfo.dwSerialNo);
  66.             String employeeNo = hkAdapter.selectEmployeeNo(strAcsInfo.struAcsEventInfo.dwSerialNo, null);
  67.             log.info("获取到的用户编码：{}", employeeNo);
  68.             // 获取人员名称
  69.             if (ObjectUtils.isNotEmpty(employeeNo)) {
  70.                 String userName = hkAdapter.selectUserName(employeeNo);
  71.                 log.info("获取到的用户名称：{}", userName);
  72.             } else {
  73.  
  74.                 String cardNo = hkAdapter.selectEmployeeNo(strAcsInfo.struAcsEventInfo.dwSerialNo,
  75.                         EnableFlagEnum.ENABLE_STATUS_1.getCode());
  76.                 log.info("获取到的用户卡号：{}", cardNo);
  77.             }
  78.  
  79.             // 人脸图片数据
  80.             String dataBytes = null;
  81.             if (strAcsInfo.dwPicDataLen > 0) {
  82.                 long offset = 0;
  83.                 Buffer buffers = strAcsInfo.pPicData.getByteBuffer(offset, strAcsInfo.dwPicDataLen);
  84.                 // 转换成64单独存储
  85.                 dataBytes = assembleDataBytes(buffers, strAcsInfo.dwPicDataLen);
  86.             }
  87.             log.info("获取到的人脸图片数据：{}", dataBytes);
  88.         }
  89.  
  90.     }
  91.  
  92.     private String assembleDataBytes(Buffer buffers, int dwSnapPicLen) {
  93.         byte[] bytes = new byte[dwSnapPicLen];
  94.         buffers.rewind();
  95.         ((ByteBuffer) buffers).get(bytes);
  96.         // 人脸图片数据
  97.         return (ObjectUtils.isNotEmpty(bytes) ? "data:image/jpg;base64," + Base64Encoder.encode(bytes) : StringUtils.EMPTY);
  98.     }

EquipmentHandle - HkCallBackBuilderVo：

  1.  
  2. import lombok.Data;
  3. import org.apache.commons.lang3.ObjectUtils;
  4. import org.apache.commons.lang3.StringUtils;
  5.  
  6. import java.nio.charset.StandardCharsets;
  7.  
  8. /**
  9.  * description
  10.  */
  11. @Data
  12. public class HkCallBackBuilderVo {
  13.     /**
  14.      * userid是否有效 0-无效，1-有效
  15.      */
  16.     public byte byUserIdValid;
  17.     /**
  18.      * 序列号是否有效 0-无效，1-有效
  19.      */
  20.     public byte bySerialValid;
  21.     /**
  22.      * 版本号是否有效 0-无效，1-有效
  23.      */
  24.     public byte byVersionValid;
  25.     /**
  26.      * 设备名字是否有效 0-无效，1-有效
  27.      */
  28.     public byte byDeviceNameValid;
  29.     /**
  30.      * MAC地址是否有效 0-无效，1-有效
  31.      */
  32.     public byte byMacAddrValid;
  33.     /**
  34.      * login端口是否有效 0-无效，1-有效
  35.      */
  36.     public byte byLinkPortValid;
  37.     /**
  38.      * 设备IP是否有效 0-无效，1-有效
  39.      */
  40.     public byte byDeviceIpValid;
  41.     /**
  42.      * socket ip是否有效 0-无效，1-有效
  43.      */
  44.     public byte bySocketIpValid;
  45.     /**
  46.      * NET_DVR_Login()返回值, 布防时有效
  47.      */
  48.     public int lUserId;
  49.     /**
  50.      * 序列号
  51.      */
  52.     public String sSerialNumberStr;
  53.     /**
  54.      * 版本信息 高16位表示主版本，低16位表示次版本
  55.      */
  56.     public int dwDeviceVersion;
  57.     /**
  58.      * 设备名字
  59.      */
  60.     public String sDeviceNameStr;
  61.     /**
  62.      * MAC地址
  63.      */
  64.     public String byMacAddrStr;
  65.     /**
  66.      * link port
  67.      */
  68.     public short wLinkPort;
  69.     /**
  70.      * IP地址
  71.      */
  72.     public String sDeviceIpStr;
  73.     /**
  74.      * 报警主动上传时的socket IP地址
  75.      */
  76.     public String sSocketIpStr;
  77.     /**
  78.      * Ip协议 0-IPV4, 1-IPV6
  79.      */
  80.     public byte byIpProtocol;
  81.     /**
  82.      * 主动推送
  83.      */
  84.     public String byRes2Str;
  85.  
  86.     public HkCallBackBuilderVo(HCNetSDK.NET_DVR_ALARMER pAlar) {
  87.         byUserIdValid = pAlar.byUserIDValid;
  88.         bySerialValid = pAlar.bySerialValid;
  89.         byVersionValid = pAlar.byVersionValid;
  90.         byDeviceNameValid = pAlar.byDeviceNameValid;
  91.         byMacAddrValid = pAlar.byMacAddrValid;
  92.         byLinkPortValid = pAlar.byLinkPortValid;
  93.         byDeviceIpValid = pAlar.byDeviceIPValid;
  94.         bySocketIpValid = pAlar.bySocketIPValid;
  95.         lUserId = pAlar.lUserID;
  96.         sSerialNumberStr = ObjectUtils.isNotEmpty(pAlar.sSerialNumber) ? StringUtils.toEncodedString(pAlar.sSerialNumber, StandardCharsets.UTF_8) : StringUtils.EMPTY;
  97.         dwDeviceVersion = pAlar.dwDeviceVersion;
  98.         sDeviceNameStr = ObjectUtils.isNotEmpty(pAlar.sDeviceName)? StringUtils.toEncodedString(pAlar.sDeviceName, StandardCharsets.UTF_8) : StringUtils.EMPTY;
  99.         byMacAddrStr = ObjectUtils.isNotEmpty(pAlar.byMacAddr)? StringUtils.toEncodedString(pAlar.byMacAddr, StandardCharsets.UTF_8) : StringUtils.EMPTY;
  100.         wLinkPort = pAlar.wLinkPort;
  101.         sDeviceIpStr = ObjectUtils.isNotEmpty(pAlar.sDeviceIP)? StringUtils.toEncodedString(pAlar.sDeviceIP, StandardCharsets.UTF_8) : StringUtils.EMPTY;
  102.         sSocketIpStr = ObjectUtils.isNotEmpty(pAlar.sSocketIP)? StringUtils.toEncodedString(pAlar.sSocketIP, StandardCharsets.UTF_8) : StringUtils.EMPTY;
  103.         byIpProtocol = pAlar.byIpProtocol;
  104.         byRes2Str = ObjectUtils.isNotEmpty(pAlar.byRes2)? StringUtils.toEncodedString(pAlar.byRes2, StandardCharsets.UTF_8) : StringUtils.EMPTY;
  105.     }

海康适配器（包含设备注册-用户注册-用户登出-布防-查询用户-查询事件）：

  1. /**
  2.  * 海康适配器
  3.  */
  4. @Component
  5. @Slf4j
  6. public class HkAdapter {
  7.     // 1. 海康的门禁 || 后端需要先引入海康操作库，目前不在项目内集成海康操作库，是通过海康开放平台
  8.     // 【https://open.hikvision.com/download/5cda567cf47ae80dd41a54b3?type=10】获取的操作库，
  9.     // 不同的服务器须集成不同的操作库，否则会出现异常
  10.  
  11.     // 2. Windows开发时需要将“库文件”文件夹中的HCNetSDK.dll、HCCore.dll、HCNetSDKCom文件夹、libssl-1_1-x64.dll、
  12.     // libcrypto-1_1-x64.dll、hlog.dll、hpr.dll、zlib1.dll等文件拷贝到lib文件夹下，HCNetSDKCom文件夹（包含里面的功能组件dll库文件）
  13.     // 需要和HCNetSDK.dll、HCCore.dll一起加载，放在同一个目录下，且HCNetSDKCom文件夹名不能修改。如果自行开发软件不能正常实现相应功能，
  14.     // 而且程序没有指定加载的dll库路径，请在程序运行的情况下尝试删除HCNetSDK.dll。如果可以删除，说明程序可能调用到系统盘
  15.     // Windows->System32目录下的dll文件，建议删除或者更新该目录下的相关dll文件；如果不能删除，dll文件右键选择属性确认SDK库版本。
  16.     //
  17.     // 3. Linux开发时需要将“库文件”文件夹中libhcnetsdk.so、libHCCore.so、libcrypto.so.1.1、libssl.so.1.1、libhpr.so、
  18.     // libz.so等文件拷贝到lib文件夹下。HCNetSDKCom文件夹（包含里面的功能组件dll库文件）需要和libhcnetsdk.so、
  19.     // libHCCore.so一起加载，放在同一个目录下，且HCNetSDKCom文件夹名不能修改。如果库文件加载有问题，初始化失败，
  20.     // 也可以尝试将SDK所在路径添加到LD_LIBRARY_PATH环境变量中。
  21.  
  22.     // 4. 具体请参考海康的开发文档以及文件包结构
  23.  
  24.     /**
  25.      * 组件库路径
  26.      */
  27.     private String stringDllPath;
  28.  
  29.     /**
  30.      * cry路径
  31.      */
  32.     private String stringCryPath;
  33.  
  34.     /**
  35.      * ssl路径
  36.      */
  37.     private String stringSslPath;
  38.  
  39.     /**
  40.      * lib路径
  41.      */
  42.     private String stringLibPath;
  43.  
  44.     /**
  45.      * 海康SDK
  46.      */
  47.     static HCNetSDK HK_NET_SDK = null;
  48.  
  49.     /**
  50.      * 海康设备字符集
  51.      */
  52.     static int CHAR_ENCODE_TYPE = 0;
  53.  
  54.     /**
  55.      * 全局回调
  56.      */
  57.     static HkEquipmentCallBack callBack;
  58.  
  59.     /**
  60.      * 海康设备提前操作方法（定时任务登录认证使用）
  61.      *
  62.      * @param equipment 门禁基本信息
  63.      */
  64.     public Integer preparationScheduled(GuardEquipmentRespVO equipment) {
  65.         try {
  66.  
  67.             // 设置回调
  68.             // 当返回值是true时，说明host是可用的，false则不可。
  69.             try {
  70.                 boolean status = InetAddress.getByName(equipment.getAddressIp()).isReachable(3000);
  71.                 if (!status) {
  72.                     return EntranceConstants.NET_DVR_NETWORK_FAIL_CONNECT;
  73.                 }
  74.             } catch (IOException e) {
  75.                 return EntranceConstants.NET_DVR_NETWORK_FAIL_CONNECT;
  76.             }
  77.  
  78.             return EntranceConstants.NET_DVR_NO_ERROR;
  79.         } catch (Exception e) {
  80.             log.error("海康设备加载失败！错误信息：", e);
  81.             // 错误状态默认给离线
  82.             return EntranceConstants.NET_DVR_NETWORK_FAIL_CONNECT;
  83.         }
  84.     }
  85.  
  86.     /**
  87.      * 海康设备提前操作方法（必须提前调用）
  88.      *
  89.      * @param equipment 门禁基本信息
  90.      */
  91.     private Integer preparation(String ip, String user, String password, Integer port, Boolean isLogin) {
  92.         // 创建操作类
  93.         createHkSdkInstance();
  94.         // 加载组件库
  95.         loadLinuxSystem(SystemHkSelect.isLinux());
  96.         // 初始话操作类
  97.         HK_NET_SDK.NET_DVR_Init();
  98.  
  99.         log.info("海康设备初始化成功！");
  100.         // 操作完成，首先登录设备
  101.         return loginAccessHk(ip, user, password, ObjectUtils.isNotEmpty(port) ? Short.parseShort(port.toString())
  102.                         : (short) 8000);
  103.     }
  104.  
  105.     /**
  106.      * 创建海康SDK操作类，调用海康SDK接口
  107.      * 根据不同操作系统选择不同的库文件和库路径
  108.      * 固定方式不可更改
  109.      */
  110.     private void createHkSdkInstance() {
  111.         try {
  112.             // 海康SDK操作类
  113.             if (HK_NET_SDK == null) {
  114.                 log.info("海康SDK操作类为空，开始创建海康SDK操作类");
  115.                 HK_NET_SDK = (HCNetSDK) Native.loadLibrary(stringDllPath, HCNetSDK.class);
  116.                 log.info("海康SDK操作类创建成功");
  117.             } else {
  118.                 log.info("海康SDK操作类不为空，无需创建");
  119.             }
  120.         } catch (Exception e) {
  121.             log.info("海康SDK操作类创建失败");
  122.         }
  123.     }
  124.  
  125.     private void loadLinuxSystem(Boolean isLinux) {
  126.         // linux系统建议调用以下接口加载组件库（win下不需要操作）
  127.         if (isLinux) {
  128.             log.info("加载海康组件库" + isLinux);
  129.             HCNetSDK.BYTE_ARRAY ptrByteArray1 = new HCNetSDK.BYTE_ARRAY(256);
  130.             HCNetSDK.BYTE_ARRAY ptrByteArray2 = new HCNetSDK.BYTE_ARRAY(256);
  131.             //这里是库的绝对路径，请根据实际情况修改，注意改路径必须有访问权限
  132.             // cry组件库
  133.             System.arraycopy(stringCryPath.getBytes(), 0, ptrByteArray1.byValue, 0,
  134.                     stringCryPath.length());
  135.             ptrByteArray1.write();
  136.             HK_NET_SDK.NET_DVR_SetSDKInitCfg(3, ptrByteArray1.getPointer());
  137.             System.arraycopy(stringSslPath.getBytes(), 0, ptrByteArray2.byValue, 0,
  138.                     stringSslPath.length());
  139.             ptrByteArray2.write();
  140.             // ssl组件库
  141.             HK_NET_SDK.NET_DVR_SetSDKInitCfg(4, ptrByteArray2.getPointer());
  142.             HCNetSDK.NET_DVR_LOCAL_SDK_PATH strComPath = new HCNetSDK.NET_DVR_LOCAL_SDK_PATH();
  143.             // lib组件库
  144.             System.arraycopy(stringLibPath.getBytes(), 0, strComPath.sPath, 0,
  145.                     stringLibPath.length());
  146.             strComPath.write();
  147.             HK_NET_SDK.NET_DVR_SetSDKInitCfg(2, strComPath.getPointer());
  148.         }
  149.     }
  150.  
  151.     public static Integer loginAccessHk(String deviceIp, String userName, String password,
  152.             short port) {
  153.         //注册（登录海康设备）
  154.         //设备登录信息
  155.         HCNetSDK.NET_DVR_USER_LOGIN_INFO strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();
  156.         //设备ip地址
  157.         strLoginInfo.sDeviceAddress = new byte[HCNetSDK.NET_DVR_DEV_ADDRESS_MAX_LEN];
  158.         System.arraycopy(deviceIp.getBytes(), 0, strLoginInfo.sDeviceAddress, 0, deviceIp.length());
  159.  
  160.         //设备用户名
  161.         strLoginInfo.sUserName = new byte[HCNetSDK.NET_DVR_LOGIN_USERNAME_MAX_LEN];
  162.         System.arraycopy(userName.getBytes(), 0, strLoginInfo.sUserName, 0, userName.length());
  163.  
  164.         //设备密码
  165.         strLoginInfo.sPassword = new byte[HCNetSDK.NET_DVR_LOGIN_PASSWD_MAX_LEN];
  166.         System.arraycopy(password.getBytes(), 0, strLoginInfo.sPassword, 0, password.length());
  167.  
  168.         //sdk端口
  169.         strLoginInfo.wPort = port;
  170.         //是否异步登录：0- 否，1- 是
  171.         strLoginInfo.bUseAsynLogin = false;
  172.         strLoginInfo.write();
  173.         //设备信息
  174.         HCNetSDK.NET_DVR_DEVICEINFO_V40 strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();
  175.         AtomicInteger userId = new AtomicInteger(-1);
  176.         userId.set(HK_NET_SDK.NET_DVR_Login_V40(strLoginInfo, strDeviceInfo));
  177.         if (userId.get() == -1) {
  178.             return HK_NET_SDK.NET_DVR_GetLastError();
  179.         } else {
  180.             log.info("设备登录成功，用户ID：" + userId);
  181.             strDeviceInfo.read();
  182.             CHAR_ENCODE_TYPE = strDeviceInfo.byCharEncodeType;
  183.         }
  184.         return userId.get();
  185.     }
  186.  
  187.     /**
  188.      * 登出（完成工作指令时，必须调用）
  189.      */
  190.     public static void logout(Integer userId) {
  191.         // 登出和清理设备操作缓存，释放SDK资源
  192.         if (userId >= 0) {
  193.             if (!HK_NET_SDK.NET_DVR_Logout(userId)) {
  194.                 log.info("设备注销失败");
  195.             }
  196.             log.info("设备注销成功，用户ID：" + userId);
  197.         }
  198.  
  199.         // 释放SDK资源，防止一直占用内存
  200.         HK_NET_SDK.NET_DVR_Cleanup();
  201.     }
  202.  
  203.     /**
  204.      * 查询人员信息（预留）
  205.      */
  206.     public String eventUserInfo(Integer userId, String equipmentNo) {
  207.         //数组
  208.         HCNetSDK.BYTE_ARRAY ptrByteArray = new HCNetSDK.BYTE_ARRAY(1024);
  209.         //字符串拷贝到数组中
  210.         System.arraycopy(USER_INFO.getBytes(), 0, ptrByteArray.byValue, 0, USER_INFO.length());
  211.         ptrByteArray.write();
  212.  
  213.         int lHandler = HK_NET_SDK.NET_DVR_StartRemoteConfig(userId, HCNetSDK.NET_DVR_JSON_CONFIG,
  214.                 ptrByteArray.getPointer(), USER_INFO.length(), null, null);
  215.         if (lHandler < 0) {
  216.             log.info("SearchUserInfo失败,错误码为" + HK_NET_SDK.NET_DVR_GetLastError());
  217.         } else {
  218.             //组装查询的JSON报文，这边查询的是所有的人员
  219.             JSONObject jsonObject = new JSONObject();
  220.             JSONObject jsonSearchCond = new JSONObject();
  221.  
  222.             // 查询指定的工号人员信息
  223.             JSONArray jsonArray = new JSONArray();
  224.             if (ObjectUtils.isNotEmpty(equipmentNo)) {
  225.                 jsonArray.put(new JSONObject().set("employeeNo", equipmentNo));
  226.             }
  227.             jsonSearchCond.set("EmployeeNoList", jsonArray);
  228.             jsonSearchCond.set("searchID",
  229.                     DateUtil.format(new Date(), DatePattern.PURE_DATE_PATTERN));
  230.             jsonSearchCond.set("searchResultPosition", 0);
  231.             jsonSearchCond.set("maxResults", 50);
  232.             jsonObject.set("UserInfoSearchCond", jsonSearchCond);
  233.  
  234.             String toString = jsonObject.toString();
  235.             log.info("查询的json报文:" + toString);
  236.  
  237.             //把string传递到Byte数组中，后续用.getPointer()方法传入指针地址中。
  238.             HCNetSDK.BYTE_ARRAY byteArray = new HCNetSDK.BYTE_ARRAY(toString.length());
  239.             System.arraycopy(toString.getBytes(), 0, byteArray.byValue, 0, toString.length());
  240.             byteArray.write();
  241.  
  242.             //定义接收结果的结构体
  243.             HCNetSDK.BYTE_ARRAY ptrOutBuff = new HCNetSDK.BYTE_ARRAY(10 * 1024);
  244.  
  245.             IntByReference pInt = new IntByReference(0);
  246.  
  247.             while (true) {
  248.                 int dwState = HK_NET_SDK.NET_DVR_SendWithRecvRemoteConfig(lHandler,
  249.                         byteArray.getPointer(),
  250.                         toString.length(), ptrOutBuff.getPointer(), 20 * 1024, pInt);
  251.                 if (dwState == -1) {
  252.                     break;
  253.                 } else if (dwState == HCNetSDK.NET_SDK_CONFIG_STATUS_NEED_WAIT) {
  254.                     try {
  255.                         Thread.sleep(10);
  256.                     } catch (InterruptedException e) {
  257.                         e.printStackTrace();
  258.                     }
  259.                 } else if (dwState == HCNetSDK.NET_SDK_CONFIG_STATUS_FAILED) {
  260.                     log.error("查询人员失败");
  261.                     break;
  262.                 } else if (dwState == HCNetSDK.NET_SDK_CONFIG_STATUS_EXCEPTION) {
  263.                     log.error("查询人员异常");
  264.                     break;
  265.                 } else if (dwState == HCNetSDK.NET_SDK_CONFIG_STATUS_SUCCESS) {
  266.                     ptrOutBuff.read();
  267.  
  268.                     String trim = new String(ptrOutBuff.byValue).trim();
  269.                     // 得到的人员信息
  270.                     try {
  271.                         ObjectMapper objectMapper = new ObjectMapper();
  272.                         JsonNode rootNode = objectMapper.readTree(trim);
  273.                         JsonNode userInfoSearch = rootNode.get("UserInfoSearch");
  274.                         JsonNode userInfo = userInfoSearch.get("UserInfo");
  275.                         JsonNode userInfoOne = userInfo.get(0);
  276.                         JsonNode name = userInfoOne.get("name");
  277.                         return name.asText();
  278.                     } catch (JsonProcessingException e) {
  279.                         return StringUtils.EMPTY;
  280.                     }
  281.                 } else if (dwState == HCNetSDK.NET_SDK_CONFIG_STATUS_FINISH) {
  282.                     log.error("获取人员完成");
  283.                     break;
  284.                 }
  285.             }
  286.  
  287.             if (!HK_NET_SDK.NET_DVR_StopRemoteConfig(lHandler)) {
  288.                 log.error("NET_DVR_StopRemoteConfig接口调用失败，错误码：" + HK_NET_SDK.NET_DVR_GetLastError());
  289.             } else {
  290.                 log.info("NET_DVR_StopRemoteConfig接口成功");
  291.             }
  292.         }
  293.         return null;
  294.     }
  295.     
  296.     public String selectEmployeeNo(Integer dwSerialNo,
  297.             Integer isCard) {
  298.         // 设备准备工作（必须调用）
  299.         Integer userId = preparation("", "", "", null, null);
  300.         // 通过事件类型拿到人员工号
  301.         String event = searchAllEvent(userId, dwSerialNo, isCard);
  302.         // 句柄完成，登出设备（必须调用）
  303.         logout(userId);
  304.  
  305.         return event;
  306.     }
  307.  
  308.     public String selectUserName(String employeeNo) {
  309.         // 设备准备工作（必须调用）
  310.         Integer userId = preparation("", "", "", null, null);
  311.         // 通过事件类型拿到人员工号
  312.         String event = eventUserInfo(userId, employeeNo);
  313.         // 句柄完成，登出设备（必须调用）
  314.         logout(userId);
  315.  
  316.         return event;
  317.     }
  318.  
  319.     public static String searchAllEvent(int userId, Integer dwSerialNo, Integer isCard) {
  320.         //事件条数
  321.         int i = 0;
  322.         HCNetSDK.NET_DVR_ACS_EVENT_COND strAcsEventCond = new HCNetSDK.NET_DVR_ACS_EVENT_COND();
  323.         strAcsEventCond.read();
  324.         strAcsEventCond.dwSize = strAcsEventCond.size();
  325.         // 查询全部主次类型的报警
  326.         strAcsEventCond.dwMajor = 0;
  327.         // 查询次事件报警类型
  328.         strAcsEventCond.dwMinor = 0;
  329.         strAcsEventCond.dwBeginSerialNo = dwSerialNo;
  330.         strAcsEventCond.dwEndSerialNo = dwSerialNo;
  331.         strAcsEventCond.write();
  332.         Pointer condPointer = strAcsEventCond.getPointer();
  333.         int remoteConfig = HK_NET_SDK.NET_DVR_StartRemoteConfig(userId,
  334.                 HCNetSDK.NET_DVR_GET_ACS_EVENT,
  335.                 condPointer, strAcsEventCond.size(), null, null);
  336.         if (remoteConfig <= -1) {
  337.             log.info("NET_DVR_StartRemoteConfig调用失败，错误信息：" +HK_NET_SDK.NET_DVR_GetLastError());
  338.         }
  339.         HCNetSDK.NET_DVR_ACS_EVENT_CFG eventCfg = new HCNetSDK.NET_DVR_ACS_EVENT_CFG();
  340.         eventCfg.read();
  341.         eventCfg.dwSize = eventCfg.size();
  342.         eventCfg.write();
  343.         Pointer cfgPointer = eventCfg.getPointer();
  344.         while (true) {
  345.             int dwEventSearch = HK_NET_SDK.NET_DVR_GetNextRemoteConfig(remoteConfig, cfgPointer,
  346.                     eventCfg.size());
  347.             if (dwEventSearch == HCNetSDK.NET_SDK_NEXT_STATUS__FINISH) {
  348.                 break;
  349.             } else if (dwEventSearch == HCNetSDK.NET_SDK_GET_NEXT_STATUS_FAILED) {
  350.                 break;
  351.             } else if (dwEventSearch == HCNetSDK.NET_SDK_GET_NEXT_STATUS_SUCCESS) {
  352.                 eventCfg.read();
  353.                 //获取的事件信息通过eventCfg结构体进行解析
  354.                 if (ObjectUtils.isNotEmpty(isCard)) {
  355.                     return new String(eventCfg.struAcsEventInfo.byCardNo).trim()
  356.                             .replace(new String(new char[]{160}), StringUtils.EMPTY);
  357.                 }
  358.                 return new String(eventCfg.struAcsEventInfo.byEmployeeNo).trim()
  359.                         .replace(new String(new char[]{160}), StringUtils.EMPTY);
  360.             }
  361.             i++;
  362.         }
  363.         return null;
  364.     }
  365. }

好了，这就是海康布防回调、获取用户信息、获取事件类型的所有了，写的比较粗糙，有错误的地方希望大家能指正。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/繁依Fanyi0/article/detail/850637
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号