package com.netsdk.demo.customize;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.structure.NET_TIME_EX;
|
import com.netsdk.lib.utils.Initialization;
|
import com.sun.jna.Pointer;
|
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description ManNumDetection事件
|
* @date 2021/11/30 11:34
|
*/
|
public class ManNumDetectionDemo extends Initialization {
|
|
|
int channel=0;
|
NetSDKLib.LLong attachHandle=new NetSDKLib.LLong(0);
|
/**
|
* 订阅智能任务
|
*/
|
public NetSDKLib.LLong AttachEventRealLoadPic() {
|
// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
if(attachHandle.longValue()!=0){
|
this.DetachEventRealLoadPic();
|
}
|
|
// 需要图片
|
int bNeedPicture = 1;
|
attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, NetSDKLib.EVENT_IVS_MAN_NUM_DETECTION, bNeedPicture,AnalyzerDataCB.getInstance(), null, null);
|
|
|
if (attachHandle.longValue() != 0) {
|
System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n", channel);
|
} else {
|
System.out.printf("Ch[%d] CLIENT_RealLoadPictureEx Failed!LastError = %s\n", channel,
|
ToolKits.getErrorCode());
|
}
|
|
return attachHandle;
|
}
|
/**
|
* 报警事件（智能）回调
|
*/
|
private static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
|
private final File picturePath;
|
private static AnalyzerDataCB instance;
|
|
private AnalyzerDataCB() {
|
picturePath = new File("./AnalyzerPicture/");
|
if (!picturePath.exists()) {
|
picturePath.mkdirs();
|
}
|
}
|
|
public static AnalyzerDataCB getInstance() {
|
if (instance == null) {
|
synchronized (AnalyzerDataCB.class) {
|
if (instance == null) {
|
instance = new AnalyzerDataCB();
|
}
|
}
|
}
|
return instance;
|
}
|
|
public int invoke(NetSDKLib.LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
|
Pointer dwUser, int nSequence, Pointer reserved) {
|
if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
|
return -1;
|
}
|
|
|
switch (dwAlarmType) {
|
case NetSDKLib.EVENT_IVS_MAN_NUM_DETECTION: // 立体视觉区域内人数统计事件(对应DEV_EVENT_MANNUM_DETECTION_INFO)
|
|
NetSDKLib.DEV_EVENT_MANNUM_DETECTION_INFO msg = new NetSDKLib.DEV_EVENT_MANNUM_DETECTION_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
int nChannelID= msg.nChannelID;
|
System.out.println("通道号："+nChannelID);
|
|
|
try {
|
// System.out.println("事件名称UTF："+new String(msg.szName,"UTF-8"));
|
System.out.println("事件名称GBK："+new String(msg.szName,"GBK"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
double pts = msg.PTS;
|
System.out.println("时间戳:"+pts);
|
NET_TIME_EX utc = msg.UTC;
|
System.out.println("事件发生的时间:"+utc);
|
int nEventID = msg.nEventID;
|
System.out.println("事件ID:"+nEventID);
|
|
int nAction = msg.nAction;
|
System.out.println("0:脉冲 1:开始 2:停止:"+nAction);
|
int nManListCount = msg.nManListCount;
|
System.out.println("区域人员列表数量:"+nManListCount);
|
|
NetSDKLib.MAN_NUM_LIST_INFO[] stuManList = msg.stuManList;
|
|
for(int i=0;i<nManListCount;i++){
|
NetSDKLib.MAN_NUM_LIST_INFO list_info= stuManList[i];
|
int nStature = list_info.nStature;
|
System.out.println("人员身高，单位cm:"+nStature);
|
|
NetSDKLib.DH_RECT stuBoudingBox = list_info.stuBoudingBox;
|
System.out.println("人员包围盒,8192坐标系:"+stuBoudingBox.right+","+stuBoudingBox.left+","+stuBoudingBox.bottom+","+stuBoudingBox.top);
|
|
}
|
|
NetSDKLib.EVENT_INTELLI_COMM_INFO stuIntelliCommInfo = msg.stuIntelliCommInfo;
|
System.out.println("智能事件所属大类:"+stuIntelliCommInfo.emClassType);
|
System.out.println("该事件触发的预置点:"+stuIntelliCommInfo.nPresetID);
|
|
int nAreaID = msg.nAreaID;
|
System.out.println("区域ID(一个预置点可以对应多个区域ID):"+nAreaID);
|
|
int nPrevNumber = msg.nPrevNumber;
|
System.out.println("变化前人数:"+nPrevNumber);
|
|
int nCurrentNumber = msg.nCurrentNumber;
|
System.out.println("当前人数:"+nCurrentNumber);
|
|
byte[] szSourceID = msg.szSourceID;
|
System.out.println("事件关联ID:"+new String(szSourceID));
|
|
byte[] szRuleName = msg.szRuleName;
|
try {
|
System.out.println("规则名称:"+new String(szRuleName,"GBK"));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
|
int emDetectType = msg.emDetectType; //检测模式 EM_EVENT_DETECT_TYPE
|
System.out.println("检测模式:"+emDetectType);
|
|
int nAlertNum = msg.nAlertNum;
|
System.out.println("实际触发报警的人数:"+nAlertNum);
|
//报警类型. 0:未知, 1:从人数正常到人数异常, 2:从人数异常到人数正常
|
int nAlarmType = msg.nAlarmType;
|
System.out.println("报警类型:"+nAlarmType);
|
|
|
break;
|
default:
|
System.out.println("其他事件--------------------"+ dwAlarmType);
|
break;
|
}
|
|
return 0;
|
}
|
}
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic() {
|
if (this.attachHandle.longValue() != 0) {
|
netSdk.CLIENT_StopLoadPic(this.attachHandle);
|
}
|
}
|
|
|
/**
|
* 加载测试内容
|
*/
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this, "订阅智能事件", "AttachEventRealLoadPic"));
|
menu.addItem(new CaseMenu.Item(this, "停止侦听智能事件", "DetachEventRealLoadPic"));
|
menu.run();
|
}
|
|
|
|
public static void main(String[] args) {
|
ManNumDetectionDemo manNumDetectionDemo=new ManNumDetectionDemo();
|
InitTest("172.29.2.132",37777,"admin","admin123");
|
manNumDetectionDemo.RunTest();
|
LoginOut();
|
|
}
|
|
|
}
|
