项目总结25：海康威视SDK-Java二次开发-客流量分析

前言html

　　原本一个很简单的SDK接口对接，折腾了很久；总结下缘由有：java

海康的SDK底层使用C++写的，我不熟悉C++；
海康Java源码示例写的是一个Swing桌面应用，我须要的是嵌入到web项目；
海康《设备网络SDK使用手册》中的示例是用C++写的；而且会出现使用手册和Java源码示例版本不匹配的状况（用手册版本高于Java源码示例版）

个人需求web

统计一个出入口的实时进出客流量；即将摄像头产生的数据抓取出来保存到业务数据库
SDK版本：6.0.2.35

准备工做spring

海康摄像头iDS-2CD681XYZUV-ABD/C；并已经现场安装成功；
海康的SDK，下载地址(win64)：https://www.hikvision.com/cn/download_more_570.html；后面用到的所有文档和参考源码所有在SDK文档中

代码处理sql

将SDK开发包【库文件】里的HCNetSDK.dll、HCCore.dll、PlayCtrl.dll、SuperRender.dll、AudioRender.dll、HCNetSDKCom文件夹、ssleay32.dll、libeay32.dll文件均要加载到程序里面，【HCNetSDKCom文件夹】（包含里面的功能组件dll库文件）须要和HCNetSDK.dll、HCCore.dll一块儿加载，放在同一个目录下(个人事springboot项目，放在resources目录下)，且HCNetSDKCom文件夹名不能修改。
将路径：Demo示例\4- Java 开发示例\2-报警布防监听\AlarmJavaDemo\src\alarmjavademo下的HCNetSDK类植入到项目中；

修改HCNetSDK类中的HCNetSDK加载的路径，不然会报没法加载HCNetSDK.dll错误；

HCNetSDK INSTANCE = (HCNetSDK) Native.loadLibrary("HCNetSDK", HCNetSDK.class); 改为 String path=(HCNetSDK.class.getResource("/").getPath()).replaceAll("%20", " ").substring(1).replace("/", "\\")+"HCNetSDK.dll"; HCNetSDK INSTANCE = (HCNetSDK) Native.loadLibrary(path, HCNetSDK.class);

写MemberFlowUploadService类，实现数据的抓取(见业务源码1);代码逻辑说明，可参考《设备网络SDK使用手册》-编程导引-客流量功模块的示例说明
写MemberFlowUPloadCallBackImpl类，即回调函数(见业务源码2)；回调函数的实现，我参考书hideSDK中的Demo示例\4- Java 开发示例\2-报警布防监听\AlarmJavaDemo\src\alarmjavademo下的AlarmJavaDemoView类
控制台结果输出

进入回调了
sAlarmType---》lCommand=4355：客流量统计，进入人数：78，离开人数：83, byMode:0, dwRelativeTime:1298991096, dwAbsTime:1298991096
进入回调了
sAlarmType---》lCommand=4355：客流量统计，进入人数：0，离开人数：1, byMode:1, tmStart:20190522163123,tmEnd :20190522163200
进入回调了
sAlarmType---》lCommand=4355：客流量统计，进入人数：79，离开人数：83, byMode:0, dwRelativeTime:1298991115, dwAbsTime:1298991115

源码分析数据库

源码1：MemberFlowUploadService类编程

package com.hs.api.service.haikang.meberflow; import org.springframework.stereotype.Service; import java.util.Timer; import java.util.TimerTask; @Service public class MemberFlowUploadService{ static HCNetSDK hCNetSDK = HCNetSDK.INSTANCE; static HCNetSDK.NET_DVR_USER_LOGIN_INFO m_strLoginInfo = new HCNetSDK.NET_DVR_USER_LOGIN_INFO();//设备登陆信息
    static HCNetSDK.NET_DVR_DEVICEINFO_V40 m_strDeviceInfo = new HCNetSDK.NET_DVR_DEVICEINFO_V40();//设备信息
    static String m_sDeviceIP = "192.168.1.X";//已登陆设备的IP地址
    static String m_sUsername = "XXX";//设备用户名
    static String m_sPassword = "XXXXXX";//设备密码
    static short m_sPort = 8000;//端口号

    public  void initMemberFlowUpload(int remainMinuteTime){ // 初始化
 hCNetSDK.NET_DVR_Init(); //设置链接时间与重连时间
        hCNetSDK.NET_DVR_SetConnectTime(2000, 1); hCNetSDK.NET_DVR_SetReconnect(10000, true); // 注册设备-登陆参数，包括设备地址、登陆用户、密码等
        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.bUseAsynLogin = false; //是否异步登陆：0- 否，1- 是
 m_strLoginInfo.write(); //设备信息, 输出参数
        int lUserID = hCNetSDK.NET_DVR_Login_V40(m_strLoginInfo,m_strDeviceInfo); System.out.println("lUserID.size-->" + lUserID); if(lUserID< 0){ System.out.println("hCNetSDK.NET_DVR_Login_V30()"+"\n" +hCNetSDK.NET_DVR_GetErrorMsg(null)); hCNetSDK.NET_DVR_Cleanup(); return; } //设置报警回调函数
        hCNetSDK.NET_DVR_SetDVRMessageCallBack_V31(new MemberFlowUPloadCallBackImpl(),null ); //启用布防-其余报警布防参数不须要设置，不支持
        HCNetSDK.NET_DVR_SETUPALARM_PARAM lpSetupParam = new HCNetSDK.NET_DVR_SETUPALARM_PARAM(); lpSetupParam.dwSize = 0; int lAlarmHandle = hCNetSDK.NET_DVR_SetupAlarmChan_V41(lUserID,lpSetupParam); if (lAlarmHandle< 0) { System.out.println("NET_DVR_SetupAlarmChan_V41 error, %d\n"+hCNetSDK.NET_DVR_GetLastError()); hCNetSDK.NET_DVR_Logout(lUserID); hCNetSDK.NET_DVR_Cleanup(); return; } //等待过程当中，若是设备上传报警信息，在报警回调函数里面接收和处理报警信息
        Timer timer = new Timer();// 实例化Timer类
        timer.schedule(new TimerTask() { public void run() { //撤销布防上传通道
                if (! hCNetSDK.NET_DVR_CloseAlarmChan_V30(lAlarmHandle)) { System.out.println("! hCNetSDK.NET_DVR_CloseAlarmChan_V31(lAlarmHandle)\n"+ hCNetSDK.NET_DVR_GetLastError() +"\n" +hCNetSDK.NET_DVR_GetErrorMsg(null) ); hCNetSDK.NET_DVR_Logout(lUserID); hCNetSDK. NET_DVR_Cleanup(); return; } //注销用户
 hCNetSDK.NET_DVR_Logout(lUserID); //释放SDK资源
 hCNetSDK.NET_DVR_Cleanup(); this.cancel(); System.gc();//主动回收垃圾
 } }, remainMinuteTime * 60 * 1000 );// 这里毫秒
 } }

源码2：MemberFlowUPloadCallBackImpl类windows

package com.hs.api.service.haikang.meberflow; import com.hs.dao.entity.saichang.statistics.StatisticsMemberInOut; import com.hs.dao.service.impl.saichang.statistics.StatisticsMemberInOutService; import com.sun.jna.Pointer; import org.springframework.beans.factory.annotation.Autowired; import java.sql.Timestamp; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; import java.util.logging.Level; import java.util.logging.Logger; public class MemberFlowUPloadCallBackImpl implements HCNetSDK.FMSGCallBack_V31 { @Autowired private StatisticsMemberInOutService statisticsMemberInOutService; @Override public boolean invoke(int lCommand, HCNetSDK.NET_DVR_ALARMER pAlarmer, Pointer pAlarmInfo, int dwBufLen, Pointer pUser) { System.out.println("进入回调了"); try { String sAlarmType = new String(); //报警时间
                Date today = new Date(); DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); String[] sIP = new String[2]; sAlarmType = new String("lCommand=") + lCommand; //lCommand是传的报警类型
                HCNetSDK.NET_DVR_PDC_ALRAM_INFO strPDCResult = new HCNetSDK.NET_DVR_PDC_ALRAM_INFO(); strPDCResult.write(); Pointer pPDCInfo = strPDCResult.getPointer(); pPDCInfo.write(0, pAlarmInfo.getByteArray(0, strPDCResult.size()), 0, strPDCResult.size()); strPDCResult.read(); if (strPDCResult.byMode == 0) { strPDCResult.uStatModeParam.setType(HCNetSDK.NET_DVR_STATFRAME.class); sAlarmType = sAlarmType + "：客流量统计，进入人数：" + strPDCResult.dwEnterNum + "，离开人数：" + strPDCResult.dwLeaveNum +
                            ", byMode:" + strPDCResult.byMode + ", dwRelativeTime:" + strPDCResult.uStatModeParam.struStatFrame.dwRelativeTime +
                            ", dwAbsTime:" + strPDCResult.uStatModeParam.struStatFrame.dwAbsTime; } if (strPDCResult.byMode == 1) { strPDCResult.uStatModeParam.setType(HCNetSDK.NET_DVR_STATTIME.class); //在这里实现数据的保存等业务逻辑，下面注释的代码是SDK提供的参考示例

/* String strtmStart = "" + String.format("%04d", strPDCResult.uStatModeParam.struStatTime.tmStart.dwYear) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmStart.dwMonth) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmStart.dwDay) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmStart.dwHour) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmStart.dwMinute) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmStart.dwSecond); String strtmEnd = "" + String.format("%04d", strPDCResult.uStatModeParam.struStatTime.tmEnd.dwYear) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmEnd.dwMonth) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmEnd.dwDay) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmEnd.dwHour) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmEnd.dwMinute) + String.format("%02d", strPDCResult.uStatModeParam.struStatTime.tmEnd.dwSecond); sAlarmType = sAlarmType + "：客流量统计，进入人数：" + strPDCResult.dwEnterNum + "，离开人数：" + strPDCResult.dwLeaveNum + ", byMode:" + strPDCResult.byMode + ", tmStart:" + strtmStart + ",tmEnd :" + strtmEnd;*/ } System.out.println("sAlarmType---》" +sAlarmType); //报警类型 //报警设备IP地址
                sIP = new String(strPDCResult.struDevInfo.struDevIP.sIpV4).split("\0", 2); return true; } catch (Exception ex) { Logger.getLogger(MemberFlowUPloadCallBackImpl.class.getName()).log(Level.SEVERE, null, ex); return false; } } }

其余问题解决api

项目开发没有问题，最后用maven打包项目时，HCNetSDK的加载出了问题，分析错误日志，发现是由于maven打包时进行了test，没法找到HCNetSDK，只要打包时不test就能够了；
windows server 2008 在jdk1.8.0_131下能够加载到HCNetSDK.dll(这里JDK默认在C:\Program Files ); 在更新的JDK版本中就不行(这里JDK默认在C:\Program Files (x86))