进入回调了
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　　

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 );// 这里毫秒
    }
}

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 {@Autowiredprivate StatisticsMemberInOutService statisticsMemberInOutService;@Overridepublic 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;}}
}