package com.netsdk.demo.customize;
|
|
import java.io.File;
|
import java.util.Arrays;
|
import java.util.Scanner;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.structure.NET_LEFTDETECTION_RULE_INFO;
|
import com.netsdk.lib.structure.NET_PARKINGDETECTION_RULE_INFO;
|
import com.netsdk.lib.structure.NET_RIOTERDETECTION_RULE_INFO;
|
import com.netsdk.lib.structure.NET_WANDERDETECTION_RULE_INFO;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.enumeration.EM_EVENT_IVS;
|
import com.netsdk.lib.NetSDKLib.*;
|
|
import static com.netsdk.lib.NetSDKLib.EM_ANALYSE_EVENT_TYPE.EM_ANALYSE_EVENT_IVS_WANDERDETECTION;
|
|
public class SmartDetection {
|
|
public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
|
// 登陆句柄
|
private LLong loginHandle = new LLong(0);
|
|
private LLong lAttachHandle = new LLong(0);
|
|
private LLong AttachHandle = new LLong(0);
|
|
// 任务ID
|
private int nTaskID = 0;
|
|
// 设备信息扩展
|
private NET_DEVICEINFO_Ex deviceInfo = new NET_DEVICEINFO_Ex();
|
|
public void InitTest() {
|
// 初始化SDK库
|
netSdk.CLIENT_Init(DisConnectCallBack.getInstance(), null);
|
|
// 设置断线重连成功回调函数
|
netSdk.CLIENT_SetAutoReconnect(new HaveReConnectCallBack(), null);
|
|
// 打开日志，可选
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
String logPath = new File(".").getAbsoluteFile().getParent() + File.separator + "sdk_log" + File.separator
|
+ "sdk.log";
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
if (!netSdk.CLIENT_LogOpen(setLog)) {
|
System.err.println("Open SDK Log Failed!!!");
|
}
|
|
Login();
|
}
|
|
public void Login() {
|
// 登陆设备
|
int nSpecCap = NetSDKLib.EM_LOGIN_SPAC_CAP_TYPE.EM_LOGIN_SPEC_CAP_TCP; // TCP登入
|
IntByReference nError = new IntByReference(0);
|
loginHandle = netSdk.CLIENT_LoginEx2(m_strIp, m_nPort, m_strUser, m_strPassword, nSpecCap, null, deviceInfo,
|
nError);
|
if (loginHandle.longValue() != 0) {
|
System.out.printf("Login Device[%s] Success!\n", m_strIp);
|
} else {
|
System.err.printf("Login Device[%s] Fail.Error[%s]\n", m_strIp, ToolKits.getErrorCode());
|
LoginOut();
|
}
|
}
|
|
public void LoginOut() {
|
System.out.println("End Test");
|
if (loginHandle.longValue() != 0) {
|
netSdk.CLIENT_Logout(loginHandle);
|
}
|
System.out.println("See You...");
|
|
netSdk.CLIENT_Cleanup();
|
System.exit(0);
|
}
|
|
/*
|
* 添加睿厨监测任务
|
*/
|
@SuppressWarnings("resource")
|
public void AddAnalyseTaskKITCHEN() {
|
Scanner scan = new Scanner(System.in);
|
System.out.println("请输入emDataSourceType值:");
|
int emDataSourceType = scan.nextInt();
|
if (emDataSourceType == 1) {
|
// 入参
|
NET_REMOTE_REALTIME_STREAM_INFO msg = new NET_REMOTE_REALTIME_STREAM_INFO();
|
msg.stuRuleInfo.nRuleCount = 1;
|
msg.emStartRule = 0;
|
msg.emStreamProtocolType = 3;
|
byte[] path = "rtsp://admin:admin@10.33.9.184:554/cam/realmonitor?channel=1&subtype=0".getBytes();
|
System.arraycopy(path, 0, msg.szPath, 0, path.length);
|
msg.nChannelID = 0;
|
msg.nStreamType = 0;
|
int[] emTpye = new int[2];
|
emTpye[0] = 1;
|
emTpye[1] = 11;
|
msg.stuRuleInfo.stuRuleInfos[0].emClassType = NetSDKLib.EM_SCENE_CLASS_TYPE.EM_SCENE_CLASS_OPERATEMONITOR;
|
msg.stuRuleInfo.stuRuleInfos[0].dwRuleType = NetSDKLib.EVENT_IVS_SMART_KITCHEN_CLOTHES_DETECTION; // 智慧厨房穿着检测事件
|
msg.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum = 2;
|
msg.stuRuleInfo.stuRuleInfos[0].emObjectTypes = emTpye;
|
NET_SMART_KITCHEN_CLOTHES_DETECTION_RULE_INFO SRuleInfo = new NET_SMART_KITCHEN_CLOTHES_DETECTION_RULE_INFO();
|
SRuleInfo.bChefClothesEnable = 1;
|
SRuleInfo.bMaskEnable = 1;
|
SRuleInfo.bChefHatEnable = 1;
|
SRuleInfo.nChefClothesColorNum = 1;
|
int[] Colors = new int[8];
|
Colors[0] = 1;
|
SRuleInfo.emChefClothesColors = Colors;
|
SRuleInfo.nReportInterval = 30;
|
Pointer pReserv1 = new Memory(SRuleInfo.size());
|
msg.stuRuleInfo.stuRuleInfos[0].pReserved = pReserv1;
|
ToolKits.SetStructDataToPointer(SRuleInfo, msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
Pointer pInParam = new Memory(msg.size());
|
ToolKits.SetStructDataToPointer(msg, pInParam, 0);
|
// 出参
|
NET_OUT_ADD_ANALYSE_TASK pOutParam = new NET_OUT_ADD_ANALYSE_TASK();
|
|
// if(netSdk.(loginHandle, emDataSourceType, pInParam, pOutParam, 5000)){
|
// nTaskID=pOutParam.nTaskID;
|
// System.out.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID + "任务对应的虚拟通道号" + pOutParam.nVirtualChannel);
|
// }else{
|
// System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
//
|
// }
|
}
|
}
|
|
/**
|
* 添加物品遗留任务
|
*/
|
public void AddAnalyseTaskLEFTDETECTION() {
|
Scanner scanner = new Scanner(System.in);
|
System.out.println("请输入智能分析数据源类型,1:远程实时流;2:主动推送图片文件");
|
int emDataSourceType = scanner.nextInt();
|
/**
|
* 主动推送暂无操作
|
*/
|
if (emDataSourceType != 1) {
|
// TODO
|
System.out.println("主动推送暂无事件安排");
|
return;
|
}
|
// 入参结构体
|
NET_REMOTE_REALTIME_STREAM_INFO msg = new NET_REMOTE_REALTIME_STREAM_INFO();
|
// 设置分析规则的条数
|
msg.stuRuleInfo.nRuleCount = 1;
|
// 设置智能任务启动规则
|
msg.emStartRule = 0;
|
/**
|
* 设置视频流协议类型 EM_STREAM_PROTOCOL_TYPE,枚举值为 EM_STREAM_PROTOCOL_UNKNOWN=0; // 未知
|
* EM_STREAM_PROTOCOL_PRIVATE_V2=1; // 私有二代 EM_STREAM_PROTOCOL_PRIVATE_V3=2; //
|
* 私有三代 EM_STREAM_PROTOCOL_RTSP=3; // rtsp EM_STREAM_PROTOCOL_ONVIF=4; // Onvif
|
* EM_STREAM_PROTOCOL_GB28181=5; // GB28181
|
*/
|
msg.emStreamProtocolType = NetSDKLib.EM_STREAM_PROTOCOL_TYPE.EM_STREAM_PROTOCOL_RTSP;
|
/**
|
* 视频流地址
|
*/
|
byte[] path = "rtsp://admin:admin@10.33.12.138:554/cam/realmonitor?channel=1&subtype=0 ".getBytes();
|
System.arraycopy(path, 0, msg.szPath, 0, path.length);
|
/**
|
* 通道号
|
*/
|
msg.nChannelID = 6;
|
|
/**
|
* 配置智能分析规则
|
*/
|
|
// 设置分析大类
|
msg.stuRuleInfo.stuRuleInfos[0].emClassType = NetSDKLib.EM_SCENE_CLASS_TYPE.EM_SCENE_CLASS_NORMAL;
|
// 设置规则类型
|
msg.stuRuleInfo.stuRuleInfos[0].dwRuleType = EM_EVENT_IVS.EVENT_IVS_LEFTDETECTION.getId();
|
/**
|
* 设置检测物体类型个数
|
*/
|
msg.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum = 2;
|
/**
|
* 设置检测物体类型列表
|
*/
|
int[] emType = new int[2];
|
emType[0] = NetSDKLib.EM_ANALYSE_OBJECT_TYPE.EM_ANALYSE_OBJECT_TYPE_ENTITY;
|
emType[1] = NetSDKLib.EM_ANALYSE_OBJECT_TYPE.EM_ANALYSE_OBJECT_TYPE_CONTAINER;
|
msg.stuRuleInfo.stuRuleInfos[0].emObjectTypes = emType;
|
// 设置规则配置
|
// 1.new 一个结构体对象
|
NET_LEFTDETECTION_RULE_INFO sRuleInfo = new NET_LEFTDETECTION_RULE_INFO();
|
|
// 2.对结构体对象赋值
|
sRuleInfo.nDetectRegionPoint = 4;
|
for (int i = 0; i < 4; i++) {
|
POINTCOORDINATE region = new POINTCOORDINATE();
|
sRuleInfo.stuDetectRegion[i] = region;
|
}
|
// 设置检测区域
|
sRuleInfo.stuDetectRegion[0].nX = 0;
|
sRuleInfo.stuDetectRegion[0].nY = 0;
|
sRuleInfo.stuDetectRegion[1].nX = 0;
|
sRuleInfo.stuDetectRegion[1].nY = 8191;
|
sRuleInfo.stuDetectRegion[2].nX = 8191;
|
sRuleInfo.stuDetectRegion[2].nY = 8191;
|
sRuleInfo.stuDetectRegion[3].nX = 8191;
|
sRuleInfo.stuDetectRegion[3].nY = 0;
|
// 设置触发报警位置
|
sRuleInfo.nTriggerPosition = 1;
|
byte[] position = new byte[1];
|
position[0] = 0;
|
sRuleInfo.bTriggerPosition = position;
|
// 最短持续时间
|
sRuleInfo.nMinDuration = 10;
|
// 跟踪持续时间
|
sRuleInfo.nTrackDuration = 20;
|
// 尺寸过滤器是否有效
|
sRuleInfo.bSizeFileter = false;
|
// 3.分配内存
|
Pointer pReserv = new Memory(sRuleInfo.size());
|
// 设置到msg.stuRuleInfo.stuRuleInfos[0].pReserved
|
msg.stuRuleInfo.stuRuleInfos[0].pReserved = pReserv;
|
// 使用ToolKits.SetStructDataToPointer进行内存对齐
|
ToolKits.SetStructDataToPointer(sRuleInfo, msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
// ToolKits.SetStructDataToPointer(sRuleInfo,msg.stuRuleInfo.stuRuleInfos[0].pReserved,0);
|
// pInParam分配内存
|
Pointer pInParam = new Memory(msg.size());
|
ToolKits.SetStructDataToPointer(msg, pInParam, 0);
|
// 出参
|
NET_OUT_ADD_ANALYSE_TASK pOutParam = new NET_OUT_ADD_ANALYSE_TASK();
|
|
if (netSdk.CLIENT_AddAnalyseTask(loginHandle, emDataSourceType, pInParam, pOutParam, 5000)) {
|
nTaskID = pOutParam.nTaskID;
|
System.out
|
.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID + "任务对应的虚拟通道号" + pOutParam.nVirtualChannel);
|
} else {
|
System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
/**
|
* 添加人员徘徊任务
|
*/
|
public void AddAnalyseTaskWANDERDETECTION() {
|
Scanner scanner = new Scanner(System.in);
|
System.out.println("请输入智能分析数据源类型,1:远程实时流;2:主动推送图片文件");
|
int emDataSourceType = scanner.nextInt();
|
/**
|
* 主动推送暂无操作
|
*/
|
if (emDataSourceType != 1) {
|
// TODO
|
System.out.println("主动推送暂无事件安排");
|
return;
|
}
|
// 入参结构体
|
NET_REMOTE_REALTIME_STREAM_INFO msg = new NET_REMOTE_REALTIME_STREAM_INFO();
|
// 设置分析规则的条数
|
msg.stuRuleInfo.nRuleCount = 1;
|
// 设置智能任务启动规则
|
msg.emStartRule = 0;
|
/**
|
* 设置视频流协议类型 EM_STREAM_PROTOCOL_TYPE,枚举值为 EM_STREAM_PROTOCOL_UNKNOWN=0; // 未知
|
* EM_STREAM_PROTOCOL_PRIVATE_V2=1; // 私有二代 EM_STREAM_PROTOCOL_PRIVATE_V3=2; //
|
* 私有三代 EM_STREAM_PROTOCOL_RTSP=3; // rtsp EM_STREAM_PROTOCOL_ONVIF=4; // Onvif
|
* EM_STREAM_PROTOCOL_GB28181=5; // GB28181
|
*/
|
msg.emStreamProtocolType = NetSDKLib.EM_STREAM_PROTOCOL_TYPE.EM_STREAM_PROTOCOL_RTSP;
|
/**
|
* 视频流地址
|
*/
|
byte[] path = "rtsp://admin:admin@10.33.12.138:554/cam/realmonitor?channel=1&subtype=0".getBytes();
|
System.arraycopy(path, 0, msg.szPath, 0, path.length);
|
/**
|
* 通道号
|
*/
|
msg.nChannelID = 7;
|
|
/**
|
* 配置智能分析规则
|
*/
|
|
// 设置分析大类
|
msg.stuRuleInfo.stuRuleInfos[0].emClassType = NetSDKLib.EM_SCENE_CLASS_TYPE.EM_SCENE_CLASS_NORMAL;
|
// 设置规则类型
|
msg.stuRuleInfo.stuRuleInfos[0].dwRuleType = EM_EVENT_IVS.EVENT_IVS_PARKINGDETECTION.getId();
|
/**
|
* 设置检测物体类型个数
|
*/
|
msg.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum = 2;
|
/**
|
* 设置检测物体类型列表
|
*/
|
int[] emType = new int[1];
|
emType[0] = NetSDKLib.EM_ANALYSE_OBJECT_TYPE.EM_ANALYSE_OBJECT_TYPE_HUMAN;
|
msg.stuRuleInfo.stuRuleInfos[0].emObjectTypes = emType;
|
// 设置规则配置
|
// 1.new 一个结构体对象
|
NET_WANDERDETECTION_RULE_INFO sRuleInfo = new NET_WANDERDETECTION_RULE_INFO();
|
|
// 2.对结构体对象赋值
|
sRuleInfo.nDetectRegionPoint = 4;
|
for (int i = 0; i < 4; i++) {
|
POINTCOORDINATE region = new POINTCOORDINATE();
|
sRuleInfo.stuDetectRegion[i] = region;
|
}
|
// 设置检测区域
|
sRuleInfo.stuDetectRegion[0].nX = 0;
|
sRuleInfo.stuDetectRegion[0].nY = 0;
|
sRuleInfo.stuDetectRegion[1].nX = 0;
|
sRuleInfo.stuDetectRegion[1].nY = 8191;
|
sRuleInfo.stuDetectRegion[2].nX = 8191;
|
sRuleInfo.stuDetectRegion[2].nY = 8191;
|
sRuleInfo.stuDetectRegion[3].nX = 8191;
|
sRuleInfo.stuDetectRegion[3].nY = 0;
|
// 设置触发报警位置
|
sRuleInfo.nTriggerPosition = 1;
|
byte[] position = new byte[1];
|
position[0] = 0;
|
sRuleInfo.bTriggerPosition = position;
|
// 触发报警的徘徊或滞留人数
|
sRuleInfo.nTriggerTargetsNumber = 5;
|
// 最短持续时间
|
sRuleInfo.nMinDuration = 10;
|
// 报告时间间隔,0表示不重复报警,默认30，单位秒0-600
|
sRuleInfo.nReportInterval = 30;
|
// 跟踪持续时间
|
sRuleInfo.nTrackDuration = 20;
|
// 规则特定的尺寸过滤器是否有效
|
sRuleInfo.bSizeFileter = false;
|
// 规则特定的尺寸过滤器
|
// sRuleInfo.stuSizeFileter=new NET_CFG_SIZEFILTER_INFO
|
|
// 3.分配内存
|
Pointer pReserv = new Memory(sRuleInfo.size());
|
// 设置到msg.stuRuleInfo.stuRuleInfos[0].pReserved
|
msg.stuRuleInfo.stuRuleInfos[0].pReserved = pReserv;
|
// 使用ToolKits.SetStructDataToPointer进行内存对齐
|
ToolKits.SetStructDataToPointer(sRuleInfo, msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
// pInParam分配内存
|
Pointer pInParam = new Memory(msg.size());
|
ToolKits.SetStructDataToPointer(msg, pInParam, 0);
|
// 出参
|
NET_OUT_ADD_ANALYSE_TASK pOutParam = new NET_OUT_ADD_ANALYSE_TASK();
|
|
if (netSdk.CLIENT_AddAnalyseTask(loginHandle, emDataSourceType, pInParam, pOutParam, 5000)) {
|
nTaskID = pOutParam.nTaskID;
|
System.out
|
.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID + "任务对应的虚拟通道号" + pOutParam.nVirtualChannel);
|
} else {
|
System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
/**
|
* 添加车辆违停任务
|
*/
|
public void AddAnalyseTaskPARKINGDETECTION() {
|
Scanner scanner = new Scanner(System.in);
|
System.out.println("请输入智能分析数据源类型,1:远程实时流;2:主动推送图片文件");
|
int emDataSourceType = scanner.nextInt();
|
/**
|
* 主动推送暂无操作
|
*/
|
if (emDataSourceType != 1) {
|
// TODO
|
System.out.println("主动推送暂无事件安排");
|
return;
|
}
|
// 入参结构体
|
NET_REMOTE_REALTIME_STREAM_INFO msg = new NET_REMOTE_REALTIME_STREAM_INFO();
|
// 设置分析规则的条数
|
msg.stuRuleInfo.nRuleCount = 1;
|
// 设置智能任务启动规则
|
msg.emStartRule = 0;
|
/**
|
* 设置视频流协议类型 EM_STREAM_PROTOCOL_TYPE,枚举值为 EM_STREAM_PROTOCOL_UNKNOWN=0; // 未知
|
* EM_STREAM_PROTOCOL_PRIVATE_V2=1; // 私有二代 EM_STREAM_PROTOCOL_PRIVATE_V3=2; //
|
* 私有三代 EM_STREAM_PROTOCOL_RTSP=3; // rtsp EM_STREAM_PROTOCOL_ONVIF=4; // Onvif
|
* EM_STREAM_PROTOCOL_GB28181=5; // GB28181
|
*/
|
msg.emStreamProtocolType = NetSDKLib.EM_STREAM_PROTOCOL_TYPE.EM_STREAM_PROTOCOL_RTSP;
|
/**
|
* 视频流地址
|
*/
|
byte[] path = "rtsp://admin:admin@10.33.12.138:554/cam/realmonitor?channel=1&subtype=0 ".getBytes();
|
System.arraycopy(path, 0, msg.szPath, 0, path.length);
|
/**
|
* 通道号
|
*/
|
msg.nChannelID = 5;
|
|
/**
|
* 配置智能分析规则
|
*/
|
|
// 设置分析大类
|
msg.stuRuleInfo.stuRuleInfos[0].emClassType = NetSDKLib.EM_SCENE_CLASS_TYPE.EM_SCENE_CLASS_NORMAL;
|
// 设置规则类型
|
msg.stuRuleInfo.stuRuleInfos[0].dwRuleType = EM_EVENT_IVS.EVENT_IVS_PARKINGDETECTION.getId();
|
/**
|
* 设置检测物体类型个数
|
*/
|
msg.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum = 2;
|
/**
|
* 设置检测物体类型列表
|
*/
|
int[] emType = new int[1];
|
emType[0] = NetSDKLib.EM_ANALYSE_OBJECT_TYPE.EM_ANALYSE_OBJECT_TYPE_VEHICLE;
|
msg.stuRuleInfo.stuRuleInfos[0].emObjectTypes = emType;
|
// 设置规则配置
|
// 1.new 一个结构体对象
|
NET_PARKINGDETECTION_RULE_INFO sRuleInfo = new NET_PARKINGDETECTION_RULE_INFO();
|
|
// 2.对结构体对象赋值
|
sRuleInfo.nDetectRegionPoint = 4;
|
for (int i = 0; i < 4; i++) {
|
POINTCOORDINATE region = new POINTCOORDINATE();
|
sRuleInfo.stuDetectRegion[i] = region;
|
}
|
// 设置检测区域
|
sRuleInfo.stuDetectRegion[0].nX = 0;
|
sRuleInfo.stuDetectRegion[0].nY = 0;
|
sRuleInfo.stuDetectRegion[1].nX = 0;
|
sRuleInfo.stuDetectRegion[1].nY = 8191;
|
sRuleInfo.stuDetectRegion[2].nX = 8191;
|
sRuleInfo.stuDetectRegion[2].nY = 8191;
|
sRuleInfo.stuDetectRegion[3].nX = 8191;
|
sRuleInfo.stuDetectRegion[3].nY = 0;
|
// 设置触发报警位置
|
sRuleInfo.nTriggerPosition = 1;
|
byte[] position = new byte[1];
|
position[0] = 0;
|
sRuleInfo.bTriggerPosition = position;
|
// 最短持续时间
|
sRuleInfo.nMinDuration = 10;
|
// 跟踪持续时间
|
sRuleInfo.nTrackDuration = 20;
|
// 尺寸过滤器是否有效
|
sRuleInfo.bSizeFileter = false;
|
|
// 3.分配内存
|
Pointer pReserv = new Memory(sRuleInfo.size());
|
// 设置到msg.stuRuleInfo.stuRuleInfos[0].pReserved
|
msg.stuRuleInfo.stuRuleInfos[0].pReserved = pReserv;
|
// 使用ToolKits.SetStructDataToPointer进行内存对齐
|
ToolKits.SetStructDataToPointer(sRuleInfo, msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
// pInParam分配内存
|
Pointer pInParam = new Memory(msg.size());
|
ToolKits.SetStructDataToPointer(msg, pInParam, 0);
|
// 出参
|
NET_OUT_ADD_ANALYSE_TASK pOutParam = new NET_OUT_ADD_ANALYSE_TASK();
|
|
if (netSdk.CLIENT_AddAnalyseTask(loginHandle, emDataSourceType, pInParam, pOutParam, 5000)) {
|
nTaskID = pOutParam.nTaskID;
|
System.out
|
.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID + "任务对应的虚拟通道号" + pOutParam.nVirtualChannel);
|
} else {
|
System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
/**
|
* 添加人群聚集任务
|
*/
|
public void AddAnalyseTaskRIOTERDETECTION() {
|
Scanner scanner = new Scanner(System.in);
|
System.out.println("请输入智能分析数据源类型,1:远程实时流;2:主动推送图片文件");
|
int emDataSourceType = scanner.nextInt();
|
/**
|
* 主动推送暂无操作
|
*/
|
if (emDataSourceType != 1) {
|
// TODO
|
System.out.println("主动推送暂无事件安排");
|
return;
|
}
|
// 入参结构体
|
NET_REMOTE_REALTIME_STREAM_INFO msg = new NET_REMOTE_REALTIME_STREAM_INFO();
|
// 设置分析规则的条数
|
msg.stuRuleInfo.nRuleCount = 1;
|
// 设置智能任务启动规则
|
msg.emStartRule = 0;
|
/**
|
* 设置视频流协议类型 EM_STREAM_PROTOCOL_TYPE,枚举值为 EM_STREAM_PROTOCOL_UNKNOWN=0; // 未知
|
* EM_STREAM_PROTOCOL_PRIVATE_V2=1; // 私有二代 EM_STREAM_PROTOCOL_PRIVATE_V3=2; //
|
* 私有三代 EM_STREAM_PROTOCOL_RTSP=3; // rtsp EM_STREAM_PROTOCOL_ONVIF=4; // Onvif
|
* EM_STREAM_PROTOCOL_GB28181=5; // GB28181
|
*/
|
msg.emStreamProtocolType = NetSDKLib.EM_STREAM_PROTOCOL_TYPE.EM_STREAM_PROTOCOL_RTSP;
|
/**
|
* 视频流地址
|
*/
|
byte[] path = "rtsp://admin:admin@10.33.12.138:554/cam/realmonitor?channel=1&subtype=0".getBytes();
|
System.arraycopy(path, 0, msg.szPath, 0, path.length);
|
/**
|
* 通道号
|
*/
|
msg.nChannelID = 8;
|
|
/**
|
* 配置智能分析规则
|
*/
|
|
// 设置分析大类
|
msg.stuRuleInfo.stuRuleInfos[0].emClassType = NetSDKLib.EM_SCENE_CLASS_TYPE.EM_SCENE_CLASS_NORMAL;
|
// 设置规则类型
|
msg.stuRuleInfo.stuRuleInfos[0].dwRuleType = EM_EVENT_IVS.EVENT_IVS_RIOTERDETECTION.getId();
|
/**
|
* 设置检测物体类型个数
|
*/
|
msg.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum = 2;
|
/**
|
* 设置检测物体类型列表
|
*/
|
int[] emType = new int[1];
|
emType[0] = NetSDKLib.EM_ANALYSE_OBJECT_TYPE.EM_ANALYSE_OBJECT_TYPE_HUMAN;
|
msg.stuRuleInfo.stuRuleInfos[0].emObjectTypes = emType;
|
// 设置规则配置
|
// 1.new 一个结构体对象
|
NET_RIOTERDETECTION_RULE_INFO sRuleInfo = new NET_RIOTERDETECTION_RULE_INFO();
|
|
// 2.对结构体对象赋值
|
sRuleInfo.nDetectRegionPoint = 4;
|
for (int i = 0; i < 4; i++) {
|
POINTCOORDINATE region = new POINTCOORDINATE();
|
sRuleInfo.stuDetectRegion[i] = region;
|
}
|
// 设置检测区域
|
sRuleInfo.stuDetectRegion[0].nX = 0;
|
sRuleInfo.stuDetectRegion[0].nY = 0;
|
sRuleInfo.stuDetectRegion[1].nX = 0;
|
sRuleInfo.stuDetectRegion[1].nY = 8191;
|
sRuleInfo.stuDetectRegion[2].nX = 8191;
|
sRuleInfo.stuDetectRegion[2].nY = 8191;
|
sRuleInfo.stuDetectRegion[3].nX = 8191;
|
sRuleInfo.stuDetectRegion[3].nY = 0;
|
// 设置检测模式个数
|
sRuleInfo.nModeNum = 1;
|
byte[] mode = new byte[1];
|
/**
|
* 0:按最小聚集区域检测 1:按聚集人员数量阈值检测
|
*/
|
mode[0] = 1;
|
sRuleInfo.nModeList = mode;
|
// 最小聚集区域矩形框,矩形框的左上和右下点
|
/*
|
* POINTCOORDINATE[] coordinate=new POINTCOORDINATE[2]; for (int i = 0; i < 2;
|
* i++) { coordinate[i]=new POINTCOORDINATE(); } coordinate[0].nX=0;
|
* coordinate[0].nY=400; coordinate[1].nX=400; coordinate[1].nY=0;
|
*
|
* sRuleInfo.stuMinDetectRect=coordinate;
|
*/
|
// 聚集人数阈值,0不报警
|
sRuleInfo.nRioterThreshold = 5;
|
// 最短持续时间
|
sRuleInfo.nMinDuration = 10;
|
// 报告时间间隔
|
sRuleInfo.nReportInterval = 10;
|
// 灵敏度
|
sRuleInfo.nSensitivity = 5;
|
// 跟踪持续时间
|
sRuleInfo.nTrackDuration = 20;
|
// 3.分配内存
|
Pointer pReserv = new Memory(sRuleInfo.size());
|
// 设置到msg.stuRuleInfo.stuRuleInfos[0].pReserved
|
msg.stuRuleInfo.stuRuleInfos[0].pReserved = pReserv;
|
// 使用ToolKits.SetStructDataToPointer进行内存对齐
|
ToolKits.SetStructDataToPointer(sRuleInfo, msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
// pInParam分配内存
|
Pointer pInParam = new Memory(msg.size());
|
ToolKits.SetStructDataToPointer(msg, pInParam, 0);
|
// 出参
|
NET_OUT_ADD_ANALYSE_TASK pOutParam = new NET_OUT_ADD_ANALYSE_TASK();
|
|
if (netSdk.CLIENT_AddAnalyseTask(loginHandle, emDataSourceType, pInParam, pOutParam, 5000)) {
|
nTaskID = pOutParam.nTaskID;
|
System.out
|
.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID + "任务对应的虚拟通道号" + pOutParam.nVirtualChannel);
|
} else {
|
System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
/*
|
* 添加横幅检测任务
|
*
|
* @SuppressWarnings("resource") public void AddAnalyseTaskBANNER(){ Scanner
|
* scan = new Scanner(System.in); System.out.println("请输入emDataSourceType值:");
|
* int emDataSourceType=scan.nextInt(); if(emDataSourceType==1){ //入参
|
* NET_REMOTE_REALTIME_STREAM_INFO msg=new NET_REMOTE_REALTIME_STREAM_INFO();
|
* msg.stuRuleInfo.nRuleCount=1; msg.emStartRule=0; msg.emStreamProtocolType=3;
|
* byte[]
|
* path="rtsp://admin:admin@10.33.9.184:555/cam/realmonitor?channel=1&subtype=0"
|
* .getBytes(); System.arraycopy(path, 0, msg.szPath, 0, path.length);
|
* msg.nChannelID=0; msg.nStreamType=0; int [] emTpye=new int[16]; emTpye[0]=0;
|
* msg.stuRuleInfo.stuRuleInfos[0].dwRuleType=NetSDKLib.
|
* EVENT_IVS_BANNER_DETECTION; //拉横幅事件
|
* msg.stuRuleInfo.stuRuleInfos[0].emClassType=NetSDKLib.EM_SCENE_CLASS_TYPE.
|
* EM_SCENE_CLASS_CROWD_ABNORMAL;
|
* msg.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum=1;
|
* msg.stuRuleInfo.stuRuleInfos[0].emObjectTypes=emTpye;
|
* NET_BANNER_DETECTION_RULE_INFO BRuleInfo=new
|
* NET_BANNER_DETECTION_RULE_INFO(); BRuleInfo.nDetectRegionPoint=4;
|
* POINTCOORDINATE[] piont=new POINTCOORDINATE[4]; for(int j=0
|
* ;j<BRuleInfo.nDetectRegionPoint; j++){ piont[j]=new POINTCOORDINATE();
|
* BRuleInfo.stuDetectRegion[j]=piont[j]; } BRuleInfo.stuDetectRegion[0].nX=0;
|
* BRuleInfo.stuDetectRegion[0].nY=0; BRuleInfo.stuDetectRegion[1].nX=0;
|
* BRuleInfo.stuDetectRegion[1].nY=8191; BRuleInfo.stuDetectRegion[2].nX=8191;
|
* BRuleInfo.stuDetectRegion[2].nY=8191; BRuleInfo.stuDetectRegion[3].nX=8191;
|
* BRuleInfo.stuDetectRegion[3].nY=0; //BRuleInfo.bSizeFileter=1;
|
* BRuleInfo.nBannerPercent=80; BRuleInfo.nSensitivity=5;
|
* BRuleInfo.nMinDuration=30; BRuleInfo.nReportInterval=10; Pointer pReserv=new
|
* Memory(BRuleInfo.size()); msg.stuRuleInfo.stuRuleInfos[0].pReserved=pReserv;
|
* ToolKits.SetStructDataToPointer(BRuleInfo,
|
* msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0); Pointer pInParam=new
|
* Memory(msg.size()); ToolKits.SetStructDataToPointer(msg, pInParam, 0); //出参
|
* NET_OUT_ADD_ANALYSE_TASK pOutParam=new NET_OUT_ADD_ANALYSE_TASK();
|
* if(netSdk.CLIENT_AddAnalyseTask(loginHandle, emDataSourceType, pInParam,
|
* pOutParam, 5000)){ nTaskID=pOutParam.nTaskID;
|
* System.out.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID +
|
* "任务对应的虚拟通道号" + pOutParam.nVirtualChannel); }else{
|
* System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n",
|
* netSdk.CLIENT_GetLastError()); return; } } }
|
*
|
*
|
* 添加水位监测任务
|
*
|
* public void AddAnalyseTaskWaterLevel(){ int emDataSourceType=2;
|
* NET_PUSH_PICFILE_INFO msg=new NET_PUSH_PICFILE_INFO(); msg.emStartRule=0;
|
* msg.stuRuleInfo.nRuleCount=1;
|
* msg.stuRuleInfo.stuRuleInfos[0].dwRuleType=NetSDKLib.
|
* EVENT_IVS_WATER_STAGE_MONITOR; //水位监测事件
|
* msg.stuRuleInfo.stuRuleInfos[0].emClassType=NetSDKLib.EM_SCENE_CLASS_TYPE.
|
* EM_SCENE_CLASS_WATERMONITOR; NET_WATER_STAGE_MONITOR_RULE_INFO WaterRule=new
|
* NET_WATER_STAGE_MONITOR_RULE_INFO(); WaterRule.dwSceneMask=1;
|
* WaterRule.nDetectRegionPoint=4; POINTCOORDINATE[] piont=new
|
* POINTCOORDINATE[4]; for(int j=0 ;j<WaterRule.nDetectRegionPoint; j++){
|
* piont[j]=new POINTCOORDINATE(); WaterRule.stuDetectRegion[j]=piont[j]; }
|
* WaterRule.stuDetectRegion[0].nX=0; WaterRule.stuDetectRegion[0].nY=0;
|
* WaterRule.stuDetectRegion[1].nX=0; WaterRule.stuDetectRegion[1].nY=8191;
|
* WaterRule.stuDetectRegion[2].nX=8191; WaterRule.stuDetectRegion[2].nY=8191;
|
* WaterRule.stuDetectRegion[3].nX=8191; WaterRule.stuDetectRegion[3].nY=0;
|
* WaterRule.stuCalibrateLine.stuStartPoint.nx=0;
|
* WaterRule.stuCalibrateLine.stuStartPoint.ny=0;
|
* WaterRule.stuCalibrateLine.stuEndPoint.nx=1000;
|
* WaterRule.stuCalibrateLine.stuEndPoint.ny=1000;
|
* msg.stuRuleInfo.stuRuleInfos[0].pReserved=new Memory(WaterRule.size());
|
* ToolKits.SetStructDataToPointer(WaterRule,
|
* msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0); Pointer pInParam=new
|
* Memory(msg.size()); ToolKits.SetStructDataToPointer(msg, pInParam, 0); //出参
|
* NET_OUT_ADD_ANALYSE_TASK pOutParam=new NET_OUT_ADD_ANALYSE_TASK();
|
* if(netSdk.CLIENT_AddAnalyseTask(loginHandle, emDataSourceType, pInParam,
|
* pOutParam, 5000)){ nTaskID=pOutParam.nTaskID;
|
* System.out.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID +
|
* "任务对应的虚拟通道号" + pOutParam.nVirtualChannel); }else{
|
* System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n",
|
* netSdk.CLIENT_GetLastError()); return; } }
|
*/
|
|
/*
|
* 添加漂浮物检测任务
|
*/
|
public void AddAnalyseTaskFloating() {
|
int emDataSourceType = 2;
|
NET_PUSH_PICFILE_INFO msg = new NET_PUSH_PICFILE_INFO();
|
msg.emStartRule = 0;
|
msg.stuRuleInfo.nRuleCount = 1;
|
msg.stuRuleInfo.stuRuleInfos[0].dwRuleType = NetSDKLib.EVENT_IVS_FLOATINGOBJECT_DETECTION; // 漂浮物监测事件
|
msg.stuRuleInfo.stuRuleInfos[0].emClassType = NetSDKLib.EM_SCENE_CLASS_TYPE.EM_SCENE_CLASS_WATERMONITOR;
|
NET_FLOATINGOBJECT_DETECTION_RULE_INFO FloatingRule = new NET_FLOATINGOBJECT_DETECTION_RULE_INFO();
|
FloatingRule.nDetectRegionPoint = 4;
|
FloatingRule.stuDetectRegion[0].nX = 0;
|
FloatingRule.stuDetectRegion[0].nY = 0;
|
FloatingRule.stuDetectRegion[1].nX = 0;
|
FloatingRule.stuDetectRegion[1].nY = 8191;
|
FloatingRule.stuDetectRegion[2].nX = 8191;
|
FloatingRule.stuDetectRegion[2].nY = 8191;
|
FloatingRule.stuDetectRegion[3].nX = 8191;
|
FloatingRule.stuDetectRegion[3].nY = 0;
|
FloatingRule.fAlarmThreshold = 60;
|
FloatingRule.nAlarmInterval = 60;
|
FloatingRule.nUpdateInterval = 60;
|
FloatingRule.bDataUpload = 10;
|
msg.stuRuleInfo.stuRuleInfos[0].pReserved = new Memory(FloatingRule.size());
|
ToolKits.SetStructDataToPointer(FloatingRule, msg.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
Pointer pInParam = new Memory(msg.size());
|
ToolKits.SetStructDataToPointer(msg, pInParam, 0);
|
// 出参
|
NET_OUT_ADD_ANALYSE_TASK pOutParam = new NET_OUT_ADD_ANALYSE_TASK();
|
if (netSdk.CLIENT_AddAnalyseTask(loginHandle, emDataSourceType, pInParam, pOutParam, 5000)) {
|
nTaskID = pOutParam.nTaskID;
|
System.out
|
.println("AddAnalyseTask Succeed! " + "任务ID" + nTaskID + "任务对应的虚拟通道号" + pOutParam.nVirtualChannel);
|
} else {
|
System.err.printf("AddAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void StartAnalyseTask() {
|
// 入参
|
NET_IN_START_ANALYSE_TASK pInParam = new NET_IN_START_ANALYSE_TASK();
|
pInParam.nTaskID = nTaskID;
|
|
// 出参
|
NET_OUT_START_ANALYSE_TASK pOutParam = new NET_OUT_START_ANALYSE_TASK();
|
|
if (netSdk.CLIENT_StartAnalyseTask(loginHandle, pInParam, pOutParam, 5000)) {
|
System.out.println("StartAnalyseTask Succeed! ");
|
} else {
|
System.err.printf("StartAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void RemoveAnalyseTask() {
|
// 入参
|
NET_IN_REMOVE_ANALYSE_TASK pInParam = new NET_IN_REMOVE_ANALYSE_TASK();
|
pInParam.nTaskID = nTaskID;
|
|
// 出参
|
NET_OUT_REMOVE_ANALYSE_TASK pOutParam = new NET_OUT_REMOVE_ANALYSE_TASK();
|
|
if (netSdk.CLIENT_RemoveAnalyseTask(loginHandle, pInParam, pOutParam, 5000)) {
|
System.out.println("RemoveAnalyseTask Succeed! ");
|
} else {
|
System.err.printf("RemoveAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void FindAnalyseTask() {
|
// 入参
|
NET_IN_FIND_ANALYSE_TASK pInParam = new NET_IN_FIND_ANALYSE_TASK();
|
|
// 出参
|
NET_OUT_FIND_ANALYSE_TASK pOutParam = new NET_OUT_FIND_ANALYSE_TASK();
|
|
if (netSdk.CLIENT_FindAnalyseTask(loginHandle, pInParam, pOutParam, 5000)) {
|
System.out.println(
|
"FindAnalyseTask Succeed!" + "智能分析任务个数" + pOutParam.nTaskNum + pOutParam.stuTaskInfos[0].nTaskID);
|
} else {
|
System.err.printf("FindAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void PushAnalysePictureFile() {
|
// 入参
|
NET_IN_PUSH_ANALYSE_PICTURE_FILE pInParam = new NET_IN_PUSH_ANALYSE_PICTURE_FILE();
|
pInParam.nTaskID = nTaskID;
|
pInParam.nPicNum = 1;
|
// 文件id
|
pInParam.stuPushPicInfos[0].szFileID = "file-1234".getBytes();
|
// ftp://用户名:密码@hostname:端口号/文件路径
|
pInParam.stuPushPicInfos[0].szUrl = "ftp://username:password@hostname:port/filepath".getBytes();
|
pInParam.stuPushPicInfos[1].szFileID = "".getBytes();
|
pInParam.stuPushPicInfos[1].szUrl = "".getBytes();
|
// 出参
|
NET_OUT_PUSH_ANALYSE_PICTURE_FILE pOutParam = new NET_OUT_PUSH_ANALYSE_PICTURE_FILE();
|
|
if (netSdk.CLIENT_PushAnalysePictureFile(loginHandle, pInParam, pOutParam, 5000)) {
|
System.out.println("PushAnalysePictureFile Succeed!");
|
} else {
|
System.err.printf("PushAnalysePictureFile Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void AttachAnalyseTaskState() {
|
// 入参
|
NET_IN_ATTACH_ANALYSE_TASK_STATE pInParam = new NET_IN_ATTACH_ANALYSE_TASK_STATE();
|
pInParam.cbAnalyseTaskState = CbfAnalyseTaskStateCallBack.getInstance();
|
pInParam.nTaskIdNum = 1;
|
pInParam.nTaskIDs[0] = 100004;
|
lAttachHandle = netSdk.CLIENT_AttachAnalyseTaskState(loginHandle, pInParam, 5000);
|
if (lAttachHandle.longValue() != 0) {
|
System.out.println("AttachAnalyseTaskState Succeed!");
|
} else {
|
System.err.printf("AttachAnalyseTaskState Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void DetachAnalyseTaskState() {
|
|
if (netSdk.CLIENT_DetachAnalyseTaskState(lAttachHandle)) {
|
System.out.println("DetachAnalyseTaskState Succeed!");
|
} else {
|
System.err.printf("DetachAnalyseTaskState Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void AttachAnalyseTaskResult() {
|
// 入参
|
NET_IN_ATTACH_ANALYSE_RESULT pInParam = new NET_IN_ATTACH_ANALYSE_RESULT();
|
pInParam.cbAnalyseTaskResult = CbfAnalyseTaskResultCallBack.getInstance();
|
|
pInParam.nTaskIdNum = 1;
|
pInParam.nTaskIDs[0] = 100004;
|
|
/*
|
* pInParam.nTaskIdNum = 1; pInParam.nTaskIDs[0] = nTaskID;
|
*
|
* pInParam.nTaskIdNum = 0;
|
*/
|
// pInParam.nTaskIDs[0]=nTaskID;
|
|
/*
|
* pInParam.stuFilter.nEventNum=2;
|
* pInParam.stuFilter.dwAlarmTypes[0]=NetSDKLib.EVENT_IVS_BANNER_DETECTION;
|
* pInParam.stuFilter.dwAlarmTypes[1]=NetSDKLib.
|
* EVENT_IVS_SMART_KITCHEN_CLOTHES_DETECTION;
|
*/
|
|
AttachHandle = netSdk.CLIENT_AttachAnalyseTaskResult(loginHandle, pInParam, 5000);
|
if (AttachHandle.longValue() != 0) {
|
System.out.println("AttachAnalyseTaskResult Succeed!");
|
} else {
|
System.err.printf("AttachAnalyseTaskResult Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
public void DetachAnalyseTaskResult() {
|
|
if (netSdk.CLIENT_DetachAnalyseTaskState(AttachHandle)) {
|
System.out.println("DetachAnalyseTaskResult Succeed!");
|
} else {
|
System.err.printf("DetachAnalyseTaskResult Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
}
|
|
// 添加轮询检测任务
|
public void AddPollingAnalyseTask() {
|
// 入参
|
NET_IN_ADD_POLLING_ANALYSE_TASK pIn = new NET_IN_ADD_POLLING_ANALYSE_TASK();
|
|
// 赋值
|
pIn.nIntervalTime = 60;
|
pIn.nLoopCount = 0;
|
pIn.nInfoCount = 1;
|
|
NET_POLLING_INFO[] msg = new NET_POLLING_INFO[pIn.nInfoCount];
|
for (int i = 0; i < pIn.nInfoCount; i++) {
|
msg[i] = new NET_POLLING_INFO();
|
msg[i].emSourceType = 1;
|
System.arraycopy("aojfoasfad654".getBytes(), 0, msg[0].szUserData, 0, "aojfoasfad654".getBytes().length);
|
System.arraycopy("qwerewr".getBytes(), 0, msg[0].szUserData, 0, "cxzvdf".getBytes().length);
|
NET_REMOTE_REALTIME_STREAM_INFO info = new NET_REMOTE_REALTIME_STREAM_INFO();
|
|
info.szIp = "10.80.56.129".getBytes();
|
info.wPort = (short) 31111;
|
// info.szUser="admin".getBytes();
|
System.arraycopy("admin".getBytes(), 0, info.szUser, 0, "admin".getBytes().length);
|
// info.szPwd="admin123".getBytes();
|
System.arraycopy("admin123".getBytes(), 0, info.szPwd, 0, "admin".getBytes().length);
|
info.emStreamProtocolType = 3;
|
// info.szPath="rtsp://10.11.16.86:554/cam/realmonitor?channel=1&subtype=00".getBytes();
|
System.arraycopy("rtsp://admin:admin123@10.11.16.86:554/cam/realmonitor?channel=1&subtype=00".getBytes(), 0,
|
info.szPath, 0,
|
"rtsp://admin:admin123@10.11.16.86:554/cam/realmonitor?channel=1&subtype=00".getBytes().length);
|
info.nChannelID = 1;
|
info.nStreamType = 0;
|
info.stuRuleInfo.nRuleCount = 1;
|
info.stuRuleInfo.stuRuleInfos[0].emClassType = 11;
|
info.stuRuleInfo.stuRuleInfos[0].dwRuleType = NetSDKLib.EVENT_IVS_VIDEOABNORMALDETECTION;
|
info.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum = 2;
|
info.stuRuleInfo.stuRuleInfos[0].emObjectTypes[0] = 1;
|
info.stuRuleInfo.stuRuleInfos[0].emObjectTypes[1] = 2;
|
|
NET_VIDEOABNORMALDETECTION_RULE_INFO rule = new NET_VIDEOABNORMALDETECTION_RULE_INFO();
|
rule.nDetectType = 7;
|
for (int m = 0; m < 7; m++) {
|
rule.bDetectType[m] = (byte) m;
|
rule.nThreshold[m] = 1;
|
}
|
// System.arraycopy("3".getBytes(), 0, rule.bDetectType, 0,
|
// "3".getBytes().length);
|
rule.nMinDuration = 30;
|
rule.nSensitivity = 2;
|
info.stuRuleInfo.stuRuleInfos[0].pReserved = new Memory(rule.size());
|
System.out.println(rule.size());
|
ToolKits.SetStructDataToPointer(rule, info.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
msg[i].pSourceData = new Memory(info.size());
|
ToolKits.SetStructDataToPointer(info, msg[i].pSourceData, 0);
|
}
|
|
pIn.pInfoList = new Memory(msg[0].size() * pIn.nInfoCount);
|
ToolKits.SetStructArrToPointerData(msg, pIn.pInfoList);
|
|
Pointer pInParam = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInParam, 0);
|
// 出参
|
NET_OUT_ADD_POLLING_ANALYSE_TASK pOut = new NET_OUT_ADD_POLLING_ANALYSE_TASK();
|
|
Pointer pOutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutParam, 0);
|
boolean ret = netSdk.CLIENT_AddPollingAnalyseTask(loginHandle, pInParam, pOutParam, 3000);
|
if (!ret) {
|
System.err.printf("AddPollingAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
} else {
|
ToolKits.GetPointerDataToStruct(pOutParam, 0, pOut);
|
nTaskID = pOut.nTaskID;
|
System.out.println("AddPollingAnalyseTask Succeed!" + nTaskID);
|
}
|
}
|
|
// 更新轮询检测任务规则
|
public void UpdatePollingAnalyseTask() {
|
// 入參
|
NET_IN_UPDATE_POLLING_ANALYSE_TASK pIn = new NET_IN_UPDATE_POLLING_ANALYSE_TASK();
|
pIn.nTaskID = 100004;
|
|
// 赋值
|
pIn.nIntervalTime = 30;
|
pIn.nLoopCount = 3;
|
pIn.nInfoCount = 2;
|
|
NET_POLLING_INFO[] msg = new NET_POLLING_INFO[pIn.nInfoCount];
|
for (int i = 0; i < pIn.nInfoCount; i++) {
|
msg[i] = new NET_POLLING_INFO();
|
msg[i].emSourceType = 1;
|
System.arraycopy("aojfoasfad654".getBytes(), 0, msg[i].szUserData, 0, "aojfoasfad654".getBytes().length);
|
// System.arraycopy("qwerewr".getBytes(), 0, msg[1].szUserData, 0,
|
// "cxzvdf".getBytes().length);
|
NET_REMOTE_REALTIME_STREAM_INFO info = new NET_REMOTE_REALTIME_STREAM_INFO();
|
|
info.szIp = "192.168.100.251".getBytes();
|
info.wPort = (short) 37777;
|
// info.szUser="admin".getBytes();
|
System.arraycopy("admin".getBytes(), 0, info.szUser, 0, "admin".getBytes().length);
|
// info.szPwd="admin".getBytes();
|
System.arraycopy("admin123".getBytes(), 0, info.szPwd, 0, "admin".getBytes().length);
|
info.emStreamProtocolType = 3;
|
System.arraycopy("rtsp://admin:admin123@10.11.16.86:554/cam/realmonitor?channel=1&subtype=00".getBytes(), 0,
|
info.szPath, 0,
|
"rtsp://admin:admin123@10.11.16.86:554/cam/realmonitor?channel=1&subtype=00".getBytes().length);
|
info.nChannelID = 0;
|
info.nStreamType = 0;
|
info.stuRuleInfo.nRuleCount = 1;
|
info.stuRuleInfo.stuRuleInfos[0].emClassType = 11;
|
info.stuRuleInfo.stuRuleInfos[0].dwRuleType = NetSDKLib.EVENT_IVS_VIDEOABNORMALDETECTION;
|
info.stuRuleInfo.stuRuleInfos[0].nObjectTypeNum = 2;
|
info.stuRuleInfo.stuRuleInfos[0].emObjectTypes[0] = 1;
|
info.stuRuleInfo.stuRuleInfos[0].emObjectTypes[1] = 2;
|
|
NET_VIDEOABNORMALDETECTION_RULE_INFO rule = new NET_VIDEOABNORMALDETECTION_RULE_INFO();
|
System.out.println(rule.size());
|
rule.nDetectType = 7;
|
for (int m = 0; m < 7; m++) {
|
rule.bDetectType[m] = (byte) m;
|
rule.nThreshold[m] = 1;
|
}
|
// System.arraycopy("3".getBytes(), 0, rule.bDetectType, 0,
|
// "3".getBytes().length);
|
rule.nMinDuration = 30;
|
rule.nSensitivity = 2;
|
|
info.stuRuleInfo.stuRuleInfos[0].pReserved = new Memory(rule.size());
|
System.out.println(rule.size());
|
ToolKits.SetStructDataToPointer(rule, info.stuRuleInfo.stuRuleInfos[0].pReserved, 0);
|
msg[i].pSourceData = new Memory(info.size());
|
ToolKits.SetStructDataToPointer(info, msg[i].pSourceData, 0);
|
}
|
|
pIn.pInfoList = new Memory(msg[0].size() * pIn.nInfoCount);
|
ToolKits.SetStructArrToPointerData(msg, pIn.pInfoList);
|
|
Pointer pInParam = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInParam, 0);
|
|
// 出參
|
NET_OUT_UPDATE_POLLING_ANALYSE_TASK pOut = new NET_OUT_UPDATE_POLLING_ANALYSE_TASK();
|
|
Pointer pOutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutParam, 0);
|
|
boolean ret = netSdk.CLIENT_UpdatePollingAnalyseTask(loginHandle, pInParam, pOutParam, 3000);
|
if (!ret) {
|
System.err.printf("UpdatePollingAnalyseTask Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
} else {
|
System.out.println("UpdatePollingAnalyseTask Succeed!" + nTaskID);
|
}
|
}
|
|
// 获取剩余智能分析资源
|
public void GetRemainAnalyseResource() {
|
// 入参
|
NET_IN_REMAIN_ANAYLSE_RESOURCE pIn = new NET_IN_REMAIN_ANAYLSE_RESOURCE();
|
Pointer pInParam = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInParam, 0);
|
|
// 出参
|
NET_OUT_REMAIN_ANAYLSE_RESOURCE pOut = new NET_OUT_REMAIN_ANAYLSE_RESOURCE();
|
// pOut.nRetRemainCapNum=1;
|
Pointer pOutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutParam, 0);
|
|
boolean ret = netSdk.CLIENT_GetRemainAnalyseResource(loginHandle, pInParam, pOutParam, 3000);
|
if (!ret) {
|
System.err.printf("GetRemainAnalyseResource Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
|
ToolKits.GetPointerDataToStruct(pOutParam, 0, pOut);
|
|
// 获取剩余智能分析资源
|
System.out.println("能力格式" + pOut.nRetRemainCapNum + "剩余能分析的视频流数目" + pOut.stuRemainCapacities[0].nMaxStreamNum
|
+ "大类业务方案" + pOut.stuRemainCapacities[0].emClassType);
|
}
|
|
// 获取远程设备管理能力集
|
public void QueryDevInfo() {
|
int nQueryType = NetSDKLib.NET_QUERY_REMOTE_DEVICE_CAPS;
|
|
// 入参
|
NET_IN_REMOTEDEVICE_CAPS pIn = new NET_IN_REMOTEDEVICE_CAPS();
|
|
Pointer pInBuf = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInBuf, 0);
|
// 出参
|
NET_OUT_REMOTEDEVICE_CAP pOut = new NET_OUT_REMOTEDEVICE_CAP();
|
|
Pointer pOutBuf = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutBuf, 0);
|
boolean ret = netSdk.CLIENT_QueryDevInfo(loginHandle, nQueryType, pInBuf, pOutBuf, null, 3000);
|
|
if (!ret) {
|
System.err.printf("QueryDevInfo Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
|
ToolKits.GetPointerDataToStruct(pOutBuf, 0, pOut);
|
for (int i = 0; i < pOut.nRetCount; i++) {
|
System.out.println("协议类型值" + pOut.snProtocal[i]);
|
}
|
|
}
|
|
// 获取视频分析服务智能能力集
|
public void GetAnalyseCaps() {
|
int emCapsType = 1;
|
NET_ANALYSE_CAPS_ALGORITHM pOut = new NET_ANALYSE_CAPS_ALGORITHM();
|
Pointer pOutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutParam, 0);
|
|
boolean ret = netSdk.CLIENT_GetAnalyseCaps(loginHandle, emCapsType, pOutParam, 3000);
|
if (!ret) {
|
System.err.printf("GetAnalyseCaps Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}
|
|
ToolKits.GetPointerData(pOutParam, pOut);
|
|
System.out.println("算法个数" + pOut.nAlgorithmNum + "业务大类" + pOut.stuAlgorithmInfos[0].emClassType + "算法版本"
|
+ new String(pOut.stuAlgorithmInfos[0].szVersion).trim() + "算法商"
|
+ pOut.stuAlgorithmInfos[0].emAlgorithmVendor + "算法库文件版本"
|
+ pOut.stuAlgorithmInfos[0].szAlgorithmLibVersion);
|
}
|
|
// 设置任务的自定义数据
|
public void SetAnalyseTaskCustomData() {
|
// 入参
|
NET_IN_SET_ANALYSE_TASK_CUSTOM_DATA pIn = new NET_IN_SET_ANALYSE_TASK_CUSTOM_DATA();
|
pIn.nTaskID = nTaskID;
|
pIn.stuTaskCustomData.szClientIP = "10.34.3.60".getBytes();
|
pIn.stuTaskCustomData.szDeviceID = "37777".getBytes();
|
Pointer pInParam = new Memory(pIn.size());
|
ToolKits.SetStructDataToPointer(pIn, pInParam, 0);
|
// 出参
|
NET_OUT_SET_ANALYSE_TASK_CUSTOM_DATA pOut = new NET_OUT_SET_ANALYSE_TASK_CUSTOM_DATA();
|
|
Pointer pOutParam = new Memory(pOut.size());
|
ToolKits.SetStructDataToPointer(pOut, pOutParam, 0);
|
boolean ret = netSdk.CLIENT_SetAnalyseTaskCustomData(loginHandle, pInParam, pOutParam, 3000);
|
|
if (!ret) {
|
System.err.printf("SetAnalyseTaskCustomData Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
} else {
|
System.out.println("SetAnalyseTaskCustomData Succeed!");
|
}
|
}
|
|
public void transmitInfoForWebEX() {
|
NET_IN_TRANSMIT_INFO pIn =new NET_IN_TRANSMIT_INFO();
|
pIn.emType = 0;
|
pIn.emEncryptType = 0;
|
String json = "{ \"id\" : 110799659, \"method\" : \"analyseTaskManager.updatePollingTask\", \"params\" : { \"Task\" : { \"InfoList\" : [ { \"RemoteStream\" : { \"Channel\" : 0, \"IP\" : \"10.172.160.195\", \"Password\" : \"admin123\", \"Path\" : \"rtsp:\\/\\/admin:admin123@10.11.16.86:554\\/cam\\/realmonitor?channel=1&subtype=00\", \"Port\" : 37777, \"Protocol\" : \"Private\", \"Subtype\" : 0, \"UserName\" : \"admin\" }, \"Rules\" : [ { \"Class\" : \"VideoDiagnosis\", \"Config\" : { \"DetectType\" : [ \"Loss\", \"Cover\", \"Frozen\", \"Dark\", \"SceneChange\", \"Striation\", \"Noise\", \"Unbalance\", \"Contrast\", \"DramaticChange\", \"Motion\", \"UnFocus\", \"OverExposure\" ], \"MinDuration\" : 30, \"Sensitivity\" : 2, \"Threshold\" : [ 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1 ] }, \"ObjectTypes\" : [ \"Human\", \"Vehicle\" ], \"Type\" : \"VideoAbnormalDetection\" } ], \"SourceType\" : \"RemoteStream\", \"UserData\" : \"aojfoasfad654\" }, { \"RemoteStream\" : { \"Channel\" : 0, \"IP\" : \"10.172.160.195\", \"Password\" : \"admin123\", \"Path\" : \"rtsp:\\/\\/admin:admin123@10.11.16.86:554\\/cam\\/realmonitor?channel=1&subtype=00\", \"Port\" : 37777, \"Protocol\" : \"Private\", \"Subtype\" : 0, \"UserName\" : \"admin\" }, \"Rules\" : [ { \"Class\" : \"VideoDiagnosis\", \"Config\" : { \"DetectType\" : [ \"Loss\", \"Cover\", \"Frozen\", \"Dark\", \"SceneChange\", \"Striation\", \"Noise\", \"Unbalance\", \"Contrast\", \"DramaticChange\", \"Motion\", \"UnFocus\", \"OverExposure\" ], \"MinDuration\" : 30, \"Sensitivity\" : 2, \"Threshold\" : [ 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1 ] }, \"ObjectTypes\" : [ \"Human\", \"Vehicle\" ], \"Type\" : \"VideoAbnormalDetection\" } ], \"SourceType\" : \"RemoteStream\", \"UserData\" : \"aojfoasfad654\" }, { \"RemoteStream\" : { \"Channel\" : 0, \"IP\" : \"10.172.160.195\", \"Password\" : \"admin123\", \"Path\" : \"rtsp:\\/\\/admin:admin123@10.11.16.86:554\\/cam\\/realmonitor?channel=1&subtype=00\", \"Port\" : 37777, \"Protocol\" : \"Private\", \"Subtype\" : 0, \"UserName\" : \"admin\" }, \"Rules\" : [ { \"Class\" : \"VideoDiagnosis\", \"Config\" : { \"DetectType\" : [ \"Loss\", \"Cover\", \"Frozen\", \"Dark\", \"SceneChange\", \"Striation\", \"Noise\", \"Unbalance\", \"Contrast\", \"DramaticChange\", \"Motion\", \"UnFocus\", \"OverExposure\" ], \"MinDuration\" : 30, \"Sensitivity\" : 2, \"Threshold\" : [ 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1 ] }, \"ObjectTypes\" : [ \"Human\", \"Vehicle\" ], \"Type\" : \"VideoAbnormalDetection\" } ], \"SourceType\" : \"RemoteStream\", \"UserData\" : \"aojfoasfad654\" } ], \"Interval\" : 30, \"LoopCount\" : 3 }, \"TaskID\" : 100001 }, \"session\" : 1667653350 }";
|
|
pIn.dwInJsonBufferSize = json.getBytes().length;
|
pIn.szInJsonBuffer=json;
|
NET_OUT_TRANSMIT_INFO pOut =new NET_OUT_TRANSMIT_INFO();
|
pOut.szOutBuffer =new Memory(1024*10);
|
pOut.dwOutBufferSize = 1024*10;
|
|
pIn.write();
|
pOut.write();
|
boolean ret = netSdk.CLIENT_TransmitInfoForWebEx(loginHandle, pIn.getPointer(), pOut.getPointer(), 3000);
|
|
if (!ret) {
|
System.err.printf("transmitInfoForWebEX Failed!Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
} else {
|
System.out.println("transmitInfoForWebEX Succeed!");
|
}
|
}
|
|
public void RunTest() {
|
/*
|
* CaseMenu menu = new CaseMenu(); menu.addItem(new CaseMenu.Item(this,
|
* "UpdatePollingAnalyseTask", "UpdatePollingAnalyseTask")); menu.addItem(new
|
* CaseMenu.Item(this, "添加人员徘徊任务", "AddAnalyseTaskWANDERDETECTION"));
|
* menu.addItem(new CaseMenu.Item(this, "添加车辆违停任务",
|
* "AddAnalyseTaskPARKINGDETECTION")); menu.addItem(new CaseMenu.Item(this,
|
* "添加人群聚集任务", "AddAnalyseTaskRIOTERDETECTION")); menu.addItem((new
|
* CaseMenu.Item(this, "AttachAnalyseTaskState", "AttachAnalyseTaskState")));
|
* menu.addItem((new CaseMenu.Item(this, "AttachAnalyseTaskResult",
|
* "AttachAnalyseTaskResult"))); menu.addItem((new CaseMenu.Item(this,
|
* "AddAnalyseTaskWaterLevel", "AddAnalyseTaskWaterLevel"))); menu.addItem((new
|
* CaseMenu.Item(this, "AddAnalyseTaskFloating", "AddAnalyseTaskFloating")));
|
* menu.addItem((new CaseMenu.Item(this, "StartAnalyseTask",
|
* "StartAnalyseTask"))); menu.addItem((new CaseMenu.Item(this,
|
* "RemoveAnalyseTask", "RemoveAnalyseTask"))); menu.addItem((new
|
* CaseMenu.Item(this, "FindAnalyseTask", "FindAnalyseTask")));
|
* menu.addItem((new CaseMenu.Item(this, "PushAnalysePictureFile",
|
* "PushAnalysePictureFile"))); menu.addItem((new CaseMenu.Item(this,
|
* "DetachAnalyseTaskResult", "DetachAnalyseTaskResult"))); menu.addItem((new
|
* CaseMenu.Item(this, "DetachAnalyseTaskState", "DetachAnalyseTaskState")));
|
* menu.run();
|
*/
|
transmitInfoForWebEX();
|
}
|
|
////////////////////////////////////////////////////////////////
|
private String m_strIp = "10.172.160.195";
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
private String m_strPassword = "admin123";
|
////////////////////////////////////////////////////////////////
|
|
/**
|
* 设备断线回调
|
*/
|
private static class DisConnectCallBack implements NetSDKLib.fDisConnect {
|
|
private DisConnectCallBack() {
|
}
|
|
private static class CallBackHolder {
|
private static DisConnectCallBack instance = new DisConnectCallBack();
|
}
|
|
public static DisConnectCallBack getInstance() {
|
return CallBackHolder.instance;
|
}
|
|
@Override
|
public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("Device[%s] Port[%d] DisConnect!\n", pchDVRIP, nDVRPort);
|
}
|
}
|
|
/**
|
* 设备重连回调
|
*/
|
private class HaveReConnectCallBack implements NetSDKLib.fHaveReConnect {
|
/*
|
* private HaveReConnectCallBack() { }
|
*
|
* private class CallBackHolder { private HaveReConnectCallBack instance = new
|
* HaveReConnectCallBack(); }
|
*
|
* public HaveReConnectCallBack getInstance() { return CallBackHolder.instance;
|
* }
|
*/
|
|
public void invoke(NetSDKLib.LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
|
new Thread(new Runnable() {
|
|
@Override
|
public void run() {
|
// TODO Auto-generated method stub
|
FindAnalyseTask();
|
}
|
}).start();
|
}
|
}
|
|
/**
|
* 智能分析状态订阅函数原型
|
*/
|
private static class CbfAnalyseTaskStateCallBack implements NetSDKLib.fAnalyseTaskStateCallBack {
|
private CbfAnalyseTaskStateCallBack() {
|
}
|
|
private static class CallBackHolder {
|
private static CbfAnalyseTaskStateCallBack instance = new CbfAnalyseTaskStateCallBack();
|
}
|
|
public static CbfAnalyseTaskStateCallBack getInstance() {
|
return CallBackHolder.instance;
|
}
|
|
@Override
|
public int invoke(LLong lAttachHandle, Pointer pstAnalyseTaskStateInfo, Pointer dwUser) {
|
NetSDKLib.NET_CB_ANALYSE_TASK_STATE_INFO task = new NetSDKLib.NET_CB_ANALYSE_TASK_STATE_INFO();
|
ToolKits.GetPointerData(pstAnalyseTaskStateInfo, task);
|
// NetSDKLib.NET_ANALYSE_TASKS_INFO[] taskInfo=new
|
// NetSDKLib.NET_ANALYSE_TASKS_INFO[task.nTaskNum];
|
for (int i = 0; i < task.nTaskNum; i++) {
|
// taskInfo[i]=new NetSDKLib.NET_ANALYSE_TASKS_INFO();
|
System.out.println(task.stuTaskInfos[i].nTaskID);
|
System.out.println(task.stuTaskInfos[i].emAnalyseState);
|
}
|
return 0;
|
}
|
|
}
|
|
/**
|
* 智能分析结果订阅函数原型
|
*/
|
private static class CbfAnalyseTaskResultCallBack implements NetSDKLib.fAnalyseTaskResultCallBack {
|
private CbfAnalyseTaskResultCallBack() {
|
}
|
|
private static class CallBackHolder {
|
private static CbfAnalyseTaskResultCallBack instance = new CbfAnalyseTaskResultCallBack();
|
}
|
|
public static CbfAnalyseTaskResultCallBack getInstance() {
|
return CallBackHolder.instance;
|
}
|
|
@Override
|
public int invoke(LLong lAttachHandle, Pointer pstAnalyseTaskResult, Pointer pBuf, int dwBufSize,
|
Pointer dwUser) {
|
NetSDKLib.NET_CB_ANALYSE_TASK_RESULT_INFO task = new NetSDKLib.NET_CB_ANALYSE_TASK_RESULT_INFO();
|
ToolKits.GetPointerData(pstAnalyseTaskResult, task);
|
|
System.out.println(System.currentTimeMillis() + "进入回调-----------------------------------");
|
for (int i = 0; i < task.nTaskResultNum; i++) {
|
for (int j = 0; j < task.stuTaskResultInfos[0].nEventCount; j++) {
|
switch (task.stuTaskResultInfos[i].stuEventInfos[i].emEventType) {
|
case NetSDKLib.EM_ANALYSE_EVENT_TYPE.EM_ANALYSE_EVENT_IVS_VIDEOABNORMALDETECTION:
|
DEV_EVENT_VIDEOABNORMALDETECTION_INFO msg = new DEV_EVENT_VIDEOABNORMALDETECTION_INFO();
|
ToolKits.GetPointerData(task.stuTaskResultInfos[0].stuEventInfos[j].pstEventInfo, msg);
|
System.out.println("异常类型" + msg.bType);
|
/*
|
* for(int m=0 ;m<pBuf.getByteArray(0, dwBufSize).length ;m++){
|
* System.out.println(Arrays.toString(getBooleanArray(pBuf.getByteArray(0,
|
* dwBufSize)[m]))); } ToolKits.savePicture(pBuf,
|
* WaterStructure.stuObjectMaskInfo.nOffset, "./chiken.jpg");
|
*/
|
break;
|
}
|
}
|
}
|
for (int i = 0; i < task.nTaskResultNum; i++) {
|
System.out.println(task.stuTaskResultInfos[i].nTaskID);
|
System.out.println(new String(task.stuTaskResultInfos[i].szFileID).trim());
|
/*
|
* switch(task.stuTaskResultInfos[i].stuEventInfos[i].emEventType){ case
|
* NetSDKLib.EM_ANALYSE_EVENT_TYPE.EM_ANALYSE_EVENT_WATER_STAGE_MONITOR:
|
* DEV_EVENT_WATER_STAGE_MONITOR_INFO WaterStructure=new
|
* DEV_EVENT_WATER_STAGE_MONITOR_INFO();
|
* System.out.println(WaterStructure.dbMark); break; }
|
*/
|
}
|
ToolKits.savePicture(pBuf, dwBufSize, "./chiken.jpg");
|
for (int i = 0; i < task.nTaskResultNum; i++) {
|
System.out.println(task.stuTaskResultInfos[i].nTaskID);
|
for (int j = 0; j < task.stuTaskResultInfos[i].nEventCount; j++) {
|
NET_SECONDARY_ANALYSE_EVENT_INFO info = task.stuTaskResultInfos[i].stuEventInfos[j];
|
System.out.println("type:" + info.emEventType);
|
switch (info.emEventType) {
|
case EM_ANALYSE_EVENT_TYPE.EM_ANALYSE_EVENT_WATER_STAGE_MONITOR: {
|
DEV_EVENT_WATER_STAGE_MONITOR_INFO WaterStructure = new DEV_EVENT_WATER_STAGE_MONITOR_INFO();
|
System.out.println(WaterStructure.dbMark);
|
break;
|
}
|
// 物品遗留
|
case EM_ANALYSE_EVENT_TYPE.EM_ANALYSE_EVENT_IVS_LEFTDETECTION: {
|
NetSDKLib.DEV_EVENT_LEFT_INFO leftStructure = new NetSDKLib.DEV_EVENT_LEFT_INFO();
|
ToolKits.GetPointerDataToStruct(task.stuTaskResultInfos[i].stuEventInfos[i].pstEventInfo, 0,
|
leftStructure);
|
System.out.println("物品遗留: 时间:" + leftStructure.UTC.toString() + ",name:"
|
+ new String(leftStructure.szName) + ",channelID:" + leftStructure.nChannelID
|
+ ",objectID:" + leftStructure.stuObject.nObjectID);
|
break;
|
}
|
// 人员徘徊
|
case EM_ANALYSE_EVENT_IVS_WANDERDETECTION: {
|
NetSDKLib.DEV_EVENT_WANDER_INFO wanderStructure = new NetSDKLib.DEV_EVENT_WANDER_INFO();
|
ToolKits.GetPointerDataToStruct(task.stuTaskResultInfos[i].stuEventInfos[j].pstEventInfo, 0,
|
wanderStructure);
|
System.out.println("人员徘徊: 时间:" + wanderStructure.UTC.toString() + ",name:"
|
+ new String(wanderStructure.szName) + ",channelID:" + wanderStructure.nChannelID
|
+ ",objectNum:" + wanderStructure.nObjectNum + ",object[0].id:"
|
+ wanderStructure.stuObjectIDs[0].nObjectID + ",count: "
|
+ wanderStructure.nOccurrenceCount);
|
break;
|
}
|
// 车辆违停
|
case EM_ANALYSE_EVENT_TYPE.EM_ANALYSE_EVENT_IVS_PARKINGDETECTION: {
|
NetSDKLib.DEV_EVENT_PARKINGDETECTION_INFO parkingStructure = new NetSDKLib.DEV_EVENT_PARKINGDETECTION_INFO();
|
ToolKits.GetPointerDataToStruct(task.stuTaskResultInfos[i].stuEventInfos[j].pstEventInfo, 0,
|
parkingStructure);
|
System.out.println("车辆违停:" + new String(parkingStructure.szName) + ","
|
/*+ new String(parkingStructure.szCustomParkNo)*/);
|
break;
|
}
|
// 人群聚集
|
case EM_ANALYSE_EVENT_TYPE.EM_ANALYSE_EVENT_IVS_RIOTERDETECTION: {
|
NetSDKLib.DEV_EVENT_RIOTERL_INFO rioterlStructure = new NetSDKLib.DEV_EVENT_RIOTERL_INFO();
|
ToolKits.GetPointerDataToStruct(task.stuTaskResultInfos[i].stuEventInfos[j].pstEventInfo, 0,
|
rioterlStructure);
|
System.out.println("人群聚集: count: " + rioterlStructure.nObjectNum + "sourceId: "
|
/*+ new String(rioterlStructure.szSourceID)*/);
|
break;
|
}
|
default: {
|
System.out.println("default");
|
break;
|
}
|
}
|
;
|
}
|
System.out.println(new String(task.stuTaskResultInfos[i].szFileID).trim());
|
}
|
ToolKits.savePicture(pBuf, dwBufSize, "./chiken.jpg");
|
return 0;
|
}
|
}
|
|
public static byte[] getBooleanArray(byte b) {
|
byte[] array = new byte[8];
|
for (int i = 7; i >= 0; i--) {
|
array[i] = (byte) (b & 1);
|
b = (byte) (b >> 1);
|
}
|
return array;
|
}
|
|
public static void main(String[] args) {
|
SmartDetection XM = new SmartDetection();
|
XM.InitTest();
|
XM.RunTest();
|
XM.LoginOut();
|
}
|
|
}
|
