package com.netsdk.demo.customize;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
import java.io.File;
|
import java.io.UnsupportedEncodingException;
|
import java.util.Objects;
|
import java.util.Scanner;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.*;
|
import com.netsdk.lib.enumeration.EM_EVENT_IVS_TYPE;
|
import com.netsdk.lib.structure.CFG_INTELLI_SHELF_INFO;
|
import com.netsdk.lib.structure.CFG_IVS_MAN_NUM_DETECTION_INFO;
|
import com.netsdk.lib.structure.CFG_NUMBERSTAT_INFO;
|
import com.netsdk.lib.structure.DEV_EVENT_INTELLI_SHELF_INFO;
|
import com.netsdk.lib.ToolKits;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
|
/**
|
* 视频统计摘要信息
|
* 进出数量统计
|
* @author 29779
|
*
|
*/
|
public class VideoStatistic {
|
|
static NetSDKLib netsdkApi = NetSDKLib.NETSDK_INSTANCE;
|
static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;
|
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
// 登录句柄
|
private static LLong loginHandle = new LLong(0);
|
|
public static String encode;
|
|
static {
|
String osPrefix = getOsPrefix();
|
if (osPrefix.toLowerCase().startsWith("win32")) {
|
encode = "GBK";
|
} else if (osPrefix.toLowerCase().startsWith("linux")) {
|
encode = "UTF-8";
|
}
|
}
|
// 智能订阅句柄
|
private LLong attachHandle = new NetSDKLib.LLong(0);
|
|
String address = "172.27.1.173";
|
int port = 37777;
|
String username = "admin";
|
String password = "admin123";
|
//
|
|
private static class DisconnectCallback implements NetSDKLib.fDisConnect {
|
private static DisconnectCallback instance = new DisconnectCallback();
|
private DisconnectCallback() {}
|
public static DisconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser){
|
System.out.printf("Device[%s:%d] Disconnect!\n" , pchDVRIP , nDVRPort);
|
}
|
}
|
|
private static class HaveReconnectCallback implements NetSDKLib.fHaveReConnect {
|
private static HaveReconnectCallback instance = new HaveReconnectCallback();
|
private HaveReconnectCallback() {}
|
public static HaveReconnectCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser){
|
System.out.printf("Device[%s:%d] HaveReconnected!\n" , pchDVRIP , nDVRPort);
|
}
|
}
|
|
|
|
|
public void EndTest() {
|
System.out.println("End Test");
|
if( loginHandle.longValue() != 0) {
|
netsdkApi.CLIENT_Logout(loginHandle);
|
}
|
System.out.println("See You...");
|
|
netsdkApi.CLIENT_Cleanup(); // 进程关闭时调用一次
|
System.exit(0);
|
}
|
|
public void InitTest() {
|
//初始化SDK库
|
netsdkApi.CLIENT_Init(DisconnectCallback.getInstance(), null); // 进程启动时调用一次
|
|
//设置断线自动重练功能
|
netsdkApi.CLIENT_SetAutoReconnect(HaveReconnectCallback.getInstance(), null);
|
|
// 向设备登入
|
final int nSpecCap = 0; /// login device by TCP
|
final IntByReference error = new IntByReference();
|
|
loginHandle = netsdkApi.CLIENT_LoginEx2(address, (short)port, username,
|
password, nSpecCap, null, deviceInfo, error);
|
|
if(loginHandle.longValue() == 0) {
|
System.err.printf("Login Device [%s:%d] Failed ! Last Error[%x]\n", address, port, netsdkApi.CLIENT_GetLastError());
|
return;
|
}
|
|
System.out.printf("Login Device [%s:%d] Success. \n", address, port);
|
}
|
|
private static class VideoStatSumCallback implements NetSDKLib.fVideoStatSumCallBack {
|
private static VideoStatSumCallback instance = new VideoStatSumCallback();
|
private VideoStatSumCallback() {}
|
public static VideoStatSumCallback getInstance() {
|
return instance;
|
}
|
|
public void invoke(LLong lAttachHandle, NET_VIDEOSTAT_SUMMARY stVideoState, int dwBufLen, Pointer dwUser){
|
/**
|
* 回调函数使用注意（防止卡回调）
|
* 1.不能再回调进行耗时操作，建议将数据、图片流、视频流等通过中间件和多线程抛出处理
|
* 2.不能再回调调用netsdk的其他接口
|
*/
|
System.out.printf("Channel[%d] GetTime[%s]\n" +
|
"People In Information[Total[%d] Hour[%d] Today[%d]]\n" +
|
"People Out Information[Total[%d] Hour[%d] Today[%d]]\n",
|
stVideoState.nChannelID , stVideoState.stuTime.toStringTime() ,
|
stVideoState.stuEnteredSubtotal.nToday ,
|
stVideoState.stuEnteredSubtotal.nHour ,
|
stVideoState.stuEnteredSubtotal.nTotal ,
|
stVideoState.stuExitedSubtotal.nToday ,
|
stVideoState.stuExitedSubtotal.nHour ,
|
stVideoState.stuExitedSubtotal.nTotal );
|
|
try {
|
/**
|
* 方案:通过上报的规则类型名称 和区域ID值 去智能规则配置关系获取自定义的规则名称
|
* 一.规则类型名称
|
* 输出字符串
|
* 1."ManNumDetection" 对应 智能规则配置枚举 EVENT_IVS_MAN_NUM_DETECTION(立体视觉区域内人数统计事件)
|
* 2."NumberStat" 对应 智能规则配置枚举 EVENT_IVS_NUMBERSTAT(数量统计事件)对应的规则配置
|
*
|
* 二、区域ID
|
* 输出区域ID值 对应智能规则字段nAreaID的值
|
*/
|
System.out.println("规则类型名称:"+new String(stVideoState.szRuleName,encode));
|
System.out.println("区域ID:"+stVideoState.nAreaID);
|
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
|
|
/**
|
* 查询智能规则配置信息
|
*/
|
public void getCongigRuleInfo() {
|
int channel = 0; // 通道号
|
String command = NetSDKLib.CFG_CMD_ANALYSERULE;
|
|
int ruleCount = 10; // 事件规则个数
|
CFG_RULE_INFO[] ruleInfo = new CFG_RULE_INFO[ruleCount];
|
for (int i = 0; i < ruleCount; i++) {
|
ruleInfo[i] = new CFG_RULE_INFO();
|
}
|
|
CFG_ANALYSERULES_INFO analyse = new CFG_ANALYSERULES_INFO();
|
analyse.nRuleLen = 1024 * 1024 * 40;
|
analyse.pRuleBuf = new Memory(1024 * 1024 * 40); // 申请内存
|
analyse.pRuleBuf.clear(1024 * 1024 * 40);
|
|
// 查询
|
if (ToolKits.GetDevConfig(loginHandle, channel, command, analyse)) {
|
int offset = 0;
|
System.out.println("设备返回的事件规则个数:" + analyse.nRuleCount);
|
int count = analyse.nRuleCount < ruleCount ? analyse.nRuleCount : ruleCount;
|
for (int i = 0; i < count; i++) {
|
// 每个视频输入通道对应的所有事件规则：缓冲区pRuleBuf填充多个事件规则信息，每个事件规则信息内容为 CFG_RULE_INFO + 事件类型对应的规则配置结构体。
|
ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, ruleInfo[i]);
|
|
offset += ruleInfo[0].size(); // 智能规则偏移量
|
|
switch (ruleInfo[i].dwRuleType) {
|
case NetSDKLib.EVENT_IVS_CROSSLINEDETECTION: { //事件类型 EVENT_IVS_CROSSLINEDETECTION (警戒线事件)对应的规则配置CFG_CROSSLINE_INFO
|
//System.out.println("警戒线配置----------------------------");
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_CROSSREGIONDETECTION: {//事件类型EVENT_IVS_CROSSREGIONDETECTION(警戒区事件)对应的规则配置CFG_CROSSREGION_INFO
|
//System.out.println("警戒区配置-----------------------------");
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_NUMBERSTAT: { //事件类型EVENT_IVS_NUMBERSTAT(数量统计事件)对应的规则配置 CFG_NUMBERSTAT_INFO
|
// #define EVENT_IVS_NUMBERSTAT = 0x00000010
|
System.out.println("数量统计-----------------------------");
|
System.out.println("数量统计的枚举值："+NetSDKLib.EVENT_IVS_NUMBERSTAT+" 对应规则类型名称字符串'NumberStat'");
|
CFG_NUMBERSTAT_INFO msg = new CFG_NUMBERSTAT_INFO();
|
ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, msg);
|
try {
|
System.out.println("自定义规则名称:"+ new String(msg.szRuleName,encode)); // 用户需要的名称
|
System.out.println("区域ID:"+ msg.nAreaID);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_MAN_NUM_DETECTION: { //事件类型EVENT_IVS_MAN_NUM_DETECTION(立体视觉区域内人数统计事件)对应的规则配置 CFG_IVS_MAN_NUM_DETECTION_INFO
|
//#define EVENT_IVS_MAN_NUM_DETECTION = 0x0000020E
|
System.out.println("区域内人数统计-----------------------------");
|
System.out.println("区域内人数统计的枚举值："+NetSDKLib.EVENT_IVS_MAN_NUM_DETECTION+" 对应规则类型名称字符串'ManNumDetection'");
|
CFG_IVS_MAN_NUM_DETECTION_INFO msg = new CFG_IVS_MAN_NUM_DETECTION_INFO();
|
ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, msg);
|
try {
|
System.out.println("自定义规则名称:"+ new String(msg.szRuleName,encode)); // 用户需要的名称
|
System.out.println("区域ID:"+ msg.nAreaID);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
break;
|
}
|
case NetSDKLib.EVENT_IVS_INTELLI_SHELF: { //事件类型EVENT_IVS_INTELLI_SHELF(智能补货事件)对应的规则配置 CFG_INTELLI_SHELF_INFO
|
//#define EVENT_IVS_INTELLI_SHELF = 0x00000277
|
System.out.println("智能补货事件-----------------------------");
|
System.out.println("智能补货事件的枚举值："+NetSDKLib.EVENT_IVS_INTELLI_SHELF+" 对应规则类型名称字符串'IntelliShelf'");
|
CFG_INTELLI_SHELF_INFO msg = new CFG_INTELLI_SHELF_INFO();
|
ToolKits.GetPointerDataToStruct(analyse.pRuleBuf, offset, msg);
|
try {
|
System.out.println("自定义规则名称:"+ new String(msg.szRuleName,encode)); // 用户需要的名称
|
System.out.println("区域ID:"+ msg.nAreaID);
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
break;
|
}
|
default:
|
break;
|
}
|
offset += ruleInfo[i].nRuleSize; // 智能事件偏移量
|
}
|
} else {
|
System.err.println("查询智能事件规则信息失败!" + ToolKits.getErrorCode());
|
}
|
}
|
|
|
|
/** 订阅视频统计 句柄*/
|
private LLong videoStatHandle = new LLong(0);
|
|
/**
|
* 订阅
|
*/
|
public void attachVideoStatSummary() {
|
if (loginHandle.longValue() == 0) {
|
return;
|
}
|
|
NET_IN_ATTACH_VIDEOSTAT_SUM videoStatIn = new NET_IN_ATTACH_VIDEOSTAT_SUM();
|
videoStatIn.nChannel = 0;
|
videoStatIn.cbVideoStatSum = VideoStatSumCallback.getInstance();
|
|
NET_OUT_ATTACH_VIDEOSTAT_SUM videoStatOut = new NET_OUT_ATTACH_VIDEOSTAT_SUM();
|
|
videoStatHandle = netsdkApi.CLIENT_AttachVideoStatSummary(loginHandle, videoStatIn, videoStatOut, 5000);
|
if( videoStatHandle.longValue() == 0 ) {
|
System.err.printf("Attach Failed!LastError = %x\n", netsdkApi.CLIENT_GetLastError());
|
return;
|
}
|
|
System.out.printf("Attach Success!Wait Device Notify Information\n");
|
}
|
|
/**
|
* 退订
|
*/
|
public void detachVideoStatSummary() {
|
if (videoStatHandle.longValue() != 0) {
|
netsdkApi.CLIENT_DetachVideoStatSummary(videoStatHandle);
|
videoStatHandle.setValue(0);
|
}
|
}
|
|
private LLong findHandle = new LLong(0); // 查询句柄
|
|
public void startFindNumberStat() {
|
NetSDKLib.NET_IN_FINDNUMBERSTAT inParam = new NetSDKLib.NET_IN_FINDNUMBERSTAT();
|
inParam.nChannelID = 0; // 通道号
|
|
inParam.stStartTime.dwYear = 2016;// 开始时间
|
inParam.stStartTime.dwMonth = 6;
|
inParam.stStartTime.dwDay = 20;
|
inParam.stStartTime.dwHour = 0;
|
|
inParam.stEndTime.dwYear = 2016;// 结束时间
|
inParam.stEndTime.dwMonth = 6;
|
inParam.stEndTime.dwDay = 21;
|
inParam.stEndTime.dwHour = 23;
|
|
inParam.nGranularityType = 1;// 颗粒度
|
inParam.nWaittime = 5000; // 接口超时时间5s
|
|
NetSDKLib.NET_OUT_FINDNUMBERSTAT outParam = new NetSDKLib.NET_OUT_FINDNUMBERSTAT();
|
|
/// 获取查询句柄
|
findHandle = netsdkApi.CLIENT_StartFindNumberStat(loginHandle, inParam, outParam);
|
if (findHandle.longValue() == 0) {
|
System.err.printf("StartFindNumberStat Failed! LastError = 0x%x\n", netsdkApi.CLIENT_GetLastError() );
|
return;
|
}
|
|
System.out.println("dwTotalCount: " + outParam.dwTotalCount);
|
/// 查询
|
NetSDKLib.NET_IN_DOFINDNUMBERSTAT inDoFind = new NetSDKLib.NET_IN_DOFINDNUMBERSTAT();
|
inDoFind.nBeginNumber = 0; // 从0开始查询
|
inDoFind.nCount = 10; // 每次查询10条
|
inDoFind.nWaittime = 5000; //接口超时时间 5s
|
|
NetSDKLib.NET_OUT_DOFINDNUMBERSTAT outDofind = new NetSDKLib.NET_OUT_DOFINDNUMBERSTAT();
|
NetSDKLib.NET_NUMBERSTAT[] numberstat = (NetSDKLib.NET_NUMBERSTAT[])new NetSDKLib.NET_NUMBERSTAT().toArray(inDoFind.nCount);
|
|
for (int i = 0 ;i < numberstat.length; i ++) {
|
numberstat[i].dwSize = numberstat[0].dwSize;
|
}
|
|
outDofind.nBufferLen = inDoFind.nCount * numberstat[0].dwSize;
|
outDofind.pstuNumberStat = new Memory(outDofind.nBufferLen);
|
outDofind.pstuNumberStat.clear(outDofind.nBufferLen);
|
// Note： 初始化内存中 dwSize 字段的值，否则查询的结果为空
|
ToolKits.SetStructArrToPointerData(numberstat, outDofind.pstuNumberStat);
|
|
int bFound = 0;
|
int index = 1;
|
do {
|
bFound = netsdkApi.CLIENT_DoFindNumberStat(findHandle, inDoFind, outDofind);
|
if (0 == bFound) {
|
System.err.printf("DoFindNumberStat Failed! LastError = 0x%x\n", netsdkApi.CLIENT_GetLastError() );
|
return;
|
}
|
|
// 查询结果
|
ToolKits.GetPointerDataToStructArr(outDofind.pstuNumberStat, numberstat);
|
for(int i = 0; i < outDofind.nCount; i++, index ++) {
|
System.out.println("Index = " + index +
|
" Start Time: " + numberstat[i].stuStartTime.toStringTime() +
|
" Stop Time: " + numberstat[i].stuEndTime.toStringTime() +
|
" Enter Total: " + numberstat[i].nEnteredSubTotal +
|
" Exit Total: " + numberstat[i].nExitedSubtotal + "\n"
|
);
|
}
|
|
// 查询下一次
|
inDoFind.nBeginNumber += inDoFind.nCount; // 从上一次结束地方开始查询
|
}while(outDofind.nCount >= inDoFind.nCount);
|
}
|
|
public void stopFindNumberStat() {
|
if (findHandle.longValue() != 0 ) {
|
netsdkApi.CLIENT_StopFindNumberStat(findHandle);
|
System.out.println("stop Find Number Stat Success. ");
|
findHandle.setValue(0);
|
}
|
}
|
|
|
|
/**
|
* 选择通道
|
*/
|
private int channel = 0;
|
|
public void setChannelID() {
|
System.out.println("请输入通道，从0开始计数，-1表示全部");
|
Scanner sc = new Scanner(System.in);
|
this.channel = sc.nextInt();
|
}
|
|
/**
|
* 订阅智能事件
|
*/
|
public void AttachEventRealLoadPic() {
|
// 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
|
this.DetachEventRealLoadPic();
|
// 需要图片
|
int bNeedPicture = 1;
|
attachHandle = netsdkApi.CLIENT_RealLoadPictureEx(loginHandle, channel, NetSDKLib.EVENT_IVS_ALL, 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());
|
}
|
}
|
|
/**
|
* 智能事件回调
|
*/
|
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(LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
|
Pointer dwUser, int nSequence, Pointer reserved) {
|
if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
|
return -1;
|
}
|
System.out.println("dwAlarmType:"+dwAlarmType);
|
switch (Objects.requireNonNull(EM_EVENT_IVS_TYPE.getEventType(dwAlarmType))) {
|
case EVENT_IVS_INTELLI_SHELF: {// 智能补货事件(对应 DEV_EVENT_INTELLI_SHELF_INFO)
|
DEV_EVENT_INTELLI_SHELF_INFO msg = new DEV_EVENT_INTELLI_SHELF_INFO();
|
ToolKits.GetPointerData(pAlarmInfo, msg);
|
System.out.println(" 智能补货事件 时间(UTC)：" + msg.UTC
|
+ " 通道号:" + msg.nChannelID
|
+" 事件ID:" + msg.nEventID
|
+" 事件名称:" +new String(msg.szName).trim() // 规则类型名称
|
+" 区域ID（从1开始）, 0为单区域:" +msg.nAreaID // 区域ID
|
+" 事件触发的预置点号，从1开始:" +msg.nPresetID
|
+" 表示货架上剩余货物的百分比:" +msg.nPercent
|
);
|
/**
|
* 回调函数使用注意（防止卡回调）
|
* 1.不能再回调进行耗时操作，建议将数据、图片流、视频流等通过中间件和多线程抛出处理
|
* 2.不能再回调调用netsdk的其他接口
|
*/
|
// 全图
|
String Picture = picturePath + "\\" + "EVENT_IVS_INTELLI_SHELF" + System.currentTimeMillis()
|
+ ".jpg";
|
if (dwBufSize > 0) {
|
ToolKits.savePicture(pBuffer, 0, dwBufSize, Picture);
|
}
|
// 全景大图
|
if (msg.stuSceneImage != null && msg.stuSceneImage.nLength > 0) {
|
String bigPicture = picturePath + "\\" + "big" + System.currentTimeMillis()
|
+ ".jpg";
|
ToolKits.savePicture(pBuffer, msg.stuSceneImage.nOffSet, msg.stuSceneImage.nLength, bigPicture);
|
}
|
|
break;
|
}
|
default:
|
System.out.println("其他事件--------------------" + dwAlarmType);
|
break;
|
}
|
return 0;
|
}
|
|
}
|
|
/**
|
* 停止侦听智能事件
|
*/
|
public void DetachEventRealLoadPic() {
|
if (attachHandle.longValue() != 0) {
|
netsdkApi.CLIENT_StopLoadPic(attachHandle);
|
}
|
}
|
|
|
public void RunTest() {
|
System.out.println("Run Test");
|
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this, "查询智能规则配置信息", "getCongigRuleInfo"));
|
menu.addItem(new CaseMenu.Item(this, "订阅", "attachVideoStatSummary"));
|
menu.addItem(new CaseMenu.Item(this, "退订", "detachVideoStatSummary"));
|
|
//menu.addItem(new CaseMenu.Item(this, "开始查询", "startFindNumberStat"));
|
//menu.addItem(new CaseMenu.Item(this, "停止查询", "stopFindNumberStat"));
|
|
menu.addItem(new CaseMenu.Item(this, "选择通道", "setChannelID"));
|
menu.addItem(new CaseMenu.Item(this, "订阅智能事件", "AttachEventRealLoadPic"));
|
menu.addItem(new CaseMenu.Item(this, "停止侦听智能事件", "DetachEventRealLoadPic"));
|
|
menu.run();
|
}
|
|
public static void main(String[]args)
|
{
|
VideoStatistic demo = new VideoStatistic();
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
}
|
