package com.netsdk.demo.customize;
|
|
import static com.netsdk.lib.Utils.getOsPrefix;
|
|
import java.io.File;
|
|
import java.io.UnsupportedEncodingException;
|
import java.text.SimpleDateFormat;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.callback.impl.DefaultDisconnectCallback;
|
import com.netsdk.lib.callback.impl.DefaultHaveReconnectCallBack;
|
import com.netsdk.lib.enumeration.EM_DELETE_BY_SOURCEUID_ERRCODE;
|
import com.netsdk.lib.enumeration.EM_WORKSUIT_APPEND_ERRCODE;
|
import com.netsdk.lib.enumeration.EM_WORKSUIT_GROUP_POLICY;
|
import com.netsdk.lib.enumeration.EM_WORKSUIT_GROUP_TYPE;
|
import com.netsdk.lib.structure.ALARM_WORKSUIT_FEATURE_ABSTRACT_INFO;
|
import com.netsdk.lib.structure.NET_ALARM_REID_CLUSTER_STATE_INFO;
|
import com.netsdk.lib.structure.NET_CB_VIDEOSTAT_STREAM;
|
import com.netsdk.lib.structure.NET_IN_ATTACH_VIDEOSTAT_STREAM;
|
import com.netsdk.lib.structure.NET_IN_CREATE_WORKSUIT_COMPARE_GROUP;
|
import com.netsdk.lib.structure.NET_IN_DELETE_WORKSUIT_BY_SOURCEUID;
|
import com.netsdk.lib.structure.NET_IN_DELETE_WORKSUIT_COMPARE_GROUP;
|
import com.netsdk.lib.structure.NET_IN_DO_FIND_DETAIL_CLUSTER;
|
import com.netsdk.lib.structure.NET_IN_FIND_WORKSUIT_COMPARE_GROUP;
|
import com.netsdk.lib.structure.NET_IN_GET_CLUSTER_STATE_INFO;
|
import com.netsdk.lib.structure.NET_IN_MULTI_APPEND_TO_WORKSUIT_GROUP;
|
import com.netsdk.lib.structure.NET_IN_START_FIND_DETAIL_CLUSTER;
|
import com.netsdk.lib.structure.NET_IN_STOP_FIND_DETAIL_CLUSTER_INFO;
|
import com.netsdk.lib.structure.NET_OUT_ATTACH_VIDEOSTAT_STREAM;
|
import com.netsdk.lib.structure.NET_OUT_CREATE_WORKSUIT_COMPARE_GROUP;
|
import com.netsdk.lib.structure.NET_OUT_DELETE_WORKSUIT_BY_SOURCEUID;
|
import com.netsdk.lib.structure.NET_OUT_DELETE_WORKSUIT_COMPARE_GROUP;
|
import com.netsdk.lib.structure.NET_OUT_DO_FIND_DETAIL_CLUSTER;
|
import com.netsdk.lib.structure.NET_OUT_FIND_WORKSUIT_COMPARE_GROUP;
|
import com.netsdk.lib.structure.NET_OUT_GET_CLUSTER_STATE_INFO;
|
import com.netsdk.lib.structure.NET_OUT_MULTI_APPEND_TO_WORKSUIT_GROUP;
|
import com.netsdk.lib.structure.NET_OUT_START_FIND_DETAIL_CLUSTER;
|
import com.netsdk.lib.structure.NET_OUT_STOP_FIND_DETAIL_CLUSTER_INFO;
|
import com.netsdk.lib.structure.NET_WORKSUIT_ABSTRACT_INFO;
|
import com.netsdk.lib.structure.NET_WORKSUIT_COMPARE_GROUP_INFO;
|
import com.netsdk.lib.structure.NET_WORKSUIT_SAMPLE_INFO;
|
import com.sun.jna.Memory;
|
import com.sun.jna.NativeLong;
|
import com.sun.jna.Pointer;
|
|
public class REIDConfigDemo {
|
// SDk对象初始化
|
public static final NetSDKLib netsdk = NetSDKLib.NETSDK_INSTANCE;
|
public static final NetSDKLib configsdk = NetSDKLib.CONFIG_INSTANCE;
|
|
// 判断是否初始化
|
private static boolean bInit = false;
|
// 判断log是否打开
|
private static boolean bLogOpen = false;
|
// 设备信息
|
private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();
|
// 登录句柄
|
private NetSDKLib.LLong m_hLoginHandle = new NetSDKLib.LLong(0);
|
|
// 订阅统计通道数据时句柄
|
private NetSDKLib.LLong attachHandle = new NetSDKLib.LLong(0);
|
|
// 回调函数需要是静态的，防止被系统回收
|
// 断线回调
|
private static NetSDKLib.fDisConnect disConnectCB = DefaultDisconnectCallback.getINSTANCE();
|
// 重连回调
|
private static NetSDKLib.fHaveReConnect haveReConnectCB = DefaultHaveReconnectCallBack.getINSTANCE();
|
|
// 编码格式
|
public static String encode;
|
|
static {
|
String osPrefix = getOsPrefix();
|
if (osPrefix.toLowerCase().startsWith("win32-amd64")) {
|
encode = "GBK";
|
} else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
|
encode = "UTF-8";
|
}
|
}
|
|
/**
|
* 获取当前时间
|
*/
|
public static String GetDate() {
|
SimpleDateFormat simpleDate = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
return simpleDate.format(new java.util.Date()).replaceAll("[^0-9]", "-");
|
}
|
|
/**
|
* 初始化SDK库
|
*/
|
public static boolean Init() {
|
bInit = netsdk.CLIENT_Init(disConnectCB, null);// 进程启动时，初始化一次
|
if (!bInit) {
|
System.out.println("Initialize SDK failed");
|
return false;
|
}
|
// 配置日志
|
REIDConfigDemo.enableLog();
|
|
// 设置断线重连回调接口, 此操作为可选操作，但建议用户进行设置
|
netsdk.CLIENT_SetAutoReconnect(haveReConnectCB, null);
|
|
// 设置登录超时时间和尝试次数，可选
|
// 登录请求响应超时时间设置为3S
|
int waitTime = 3000;
|
// 登录时尝试建立链接 1 次
|
int tryTimes = 1;
|
netsdk.CLIENT_SetConnectTime(waitTime, tryTimes);
|
// 设置更多网络参数， NET_PARAM 的nWaittime ， nConnectTryNum 成员与 CLIENT_SetConnectTime
|
// 接口设置的登录设备超时时间和尝试次数意义相同,可选
|
NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
|
// 登录时尝试建立链接的超时时间
|
netParam.nConnectTime = 10000;
|
// 设置子连接的超时时间
|
netParam.nGetConnInfoTime = 3000;
|
netsdk.CLIENT_SetNetworkParam(netParam);
|
return true;
|
}
|
|
/**
|
* 打开 sdk log
|
*/
|
private static void enableLog() {
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
File path = new File("sdklog/");
|
if (!path.exists())
|
path.mkdir();
|
|
// 这里的log保存地址依据实际情况自己调整
|
String logPath = path.getAbsoluteFile().getParent() + "\\sdklog\\" + "sdklog" + GetDate() + ".log";
|
setLog.nPrintStrategy = 0;
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
System.out.println(logPath);
|
setLog.bSetPrintStrategy = 1;
|
bLogOpen = netsdk.CLIENT_LogOpen(setLog);
|
if (!bLogOpen)
|
System.err.println("Failed to open NetSDK log");
|
}
|
|
/**
|
* 高安全登录
|
*/
|
public void loginWithHighLevel() {
|
// 输入结构体参数
|
NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam = new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() {
|
{
|
szIP = m_strIpAddr.getBytes();
|
nPort = m_nPort;
|
szUserName = m_strUser.getBytes();
|
szPassword = m_strPassword.getBytes();
|
}
|
};
|
// 输出结构体参数
|
NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY pstOutParam = new NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY();
|
|
// 写入sdk
|
m_hLoginHandle = netsdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam);
|
if (m_hLoginHandle.longValue() == 0) {
|
System.err.printf("Login Device[%s] Port[%d]Failed. %s\n", m_strIpAddr, m_nPort,
|
netsdk.CLIENT_GetLastError());
|
} else {
|
deviceInfo = pstOutParam.stuDeviceInfo; // 获取设备信息
|
System.out.println("Login Success");
|
System.out.println("Device Address：" + m_strIpAddr);
|
System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道");
|
}
|
}
|
|
/**
|
* 退出
|
*/
|
public void logOut() {
|
if (m_hLoginHandle.longValue() != 0) {
|
netsdk.CLIENT_Logout(m_hLoginHandle);
|
System.out.println("LogOut Success");
|
}
|
}
|
|
/**
|
* 清理sdk环境并退出
|
*/
|
public static void cleanAndExit() {
|
if (bLogOpen) {
|
netsdk.CLIENT_LogClose(); // 关闭sdk日志打印
|
}
|
netsdk.CLIENT_Cleanup(); // 进程关闭时，调用一次
|
System.exit(0);
|
}
|
|
/**
|
* 查找工装合规组信息
|
*/
|
public void findWorkSuitCompareGroup() {
|
// 入参
|
NET_IN_FIND_WORKSUIT_COMPARE_GROUP pstInParam = new NET_IN_FIND_WORKSUIT_COMPARE_GROUP();
|
// 合规库组ID, 不填组ID表示查找全部组信息`
|
// String szGroupID = "1";
|
// System.arraycopy(szGroupID.getBytes(), 0,pstInParam.szGroupID,
|
// 0,szGroupID.getBytes().length);
|
pstInParam.write();
|
|
// 出参
|
NET_OUT_FIND_WORKSUIT_COMPARE_GROUP pstOutParam = new NET_OUT_FIND_WORKSUIT_COMPARE_GROUP();
|
// 工装合规组最大个数, 由用户指定, 即pstWorkSuitGroupInfo 数组大小
|
int nMaxGroupNum = 10; // 查询的最大值,如果设置的过大，会溢出，需要在eclipse里设置，增加堆内存
|
NET_WORKSUIT_COMPARE_GROUP_INFO[] arr = new NET_WORKSUIT_COMPARE_GROUP_INFO[nMaxGroupNum];
|
for (int i = 0; i < arr.length; i++) {
|
arr[i] = new NET_WORKSUIT_COMPARE_GROUP_INFO();
|
}
|
// 工装合规组信息指针初始化
|
pstOutParam.nMaxGroupNum = arr[0].size() * nMaxGroupNum; // 工装合规组信息数组大小
|
pstOutParam.pstWorkSuitGroupInfo = new Memory(arr[0].size() * nMaxGroupNum); // 初始化Pointer指针
|
pstOutParam.pstWorkSuitGroupInfo.clear(arr[0].size() * nMaxGroupNum);
|
|
ToolKits.SetStructArrToPointerData(arr, pstOutParam.pstWorkSuitGroupInfo); // 将数组内存拷贝给指针
|
pstOutParam.write();
|
|
// 调用接口
|
boolean flg = netsdk.CLIENT_FindWorkSuitCompareGroup(m_hLoginHandle, pstInParam.getPointer(),
|
pstOutParam.getPointer(), 3000);
|
if (flg) {
|
pstOutParam.read();
|
System.out.println("实际返回的工装合规组个数:" + pstOutParam.nRetGroupNum);
|
ToolKits.GetPointerDataToStructArr(pstOutParam.pstWorkSuitGroupInfo, arr); // 将指针的内容放入数组
|
for (int i = 0; i < pstOutParam.nRetGroupNum; i++) {
|
System.out.println("---------第" + (i + 1) + "个工装合规组信息-------------");
|
try {
|
System.out.println("合规组ID:" + new String(arr[i].szGroupID, encode));
|
System.out.println("合规组名称:" + new String(arr[i].szGroupName, encode));
|
System.out.println("合规组备注信息:" + new String(arr[i].szGroupDetail, encode));
|
System.out.println("工装优选方案:" + EM_WORKSUIT_GROUP_POLICY.getNoteByValue(arr[i].emWorkSuitPolicy));
|
System.out.println("相似度阈值:" + arr[i].nSimilarity);
|
System.out.println("合规组类型:" + EM_WORKSUIT_GROUP_TYPE.getNoteByValue(arr[i].emGroupType));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
} else {
|
System.err.println("查找工装合规组信息失败:" + ToolKits.getErrorCode());
|
}
|
|
}
|
|
/**
|
* 创建工装合规组
|
*
|
* @throws UnsupportedEncodingException
|
*/
|
public void createWorkSuitCompareGroup() throws UnsupportedEncodingException {
|
// 入参
|
NET_IN_CREATE_WORKSUIT_COMPARE_GROUP pstInParam = new NET_IN_CREATE_WORKSUIT_COMPARE_GROUP();
|
// 工装合规组信息
|
// 合规组名称
|
String szGroupName = "快递"; // 注意字符编码导致的乱码问题
|
System.arraycopy(szGroupName.getBytes(encode), 0, pstInParam.stuWorkSuitGroupInfo.szGroupName, 0,
|
szGroupName.getBytes(encode).length);
|
// 合规组备注信息
|
String szGroupDetail = "小区业主";
|
System.arraycopy(szGroupDetail.getBytes(encode), 0, pstInParam.stuWorkSuitGroupInfo.szGroupDetail, 0,
|
szGroupDetail.getBytes(encode).length);
|
// 工装优选方案 {@link com.netsdk.lib.enumeration.EM_WORKSUIT_GROUP_POLICY}
|
pstInParam.stuWorkSuitGroupInfo.emWorkSuitPolicy = EM_WORKSUIT_GROUP_POLICY.EM_WORKSUIT_GROUP_POLICY_WHOLE_BODY
|
.getValue();
|
// 相似度阈值，范围 [1, 100]，默认67
|
pstInParam.stuWorkSuitGroupInfo.nSimilarity = 67;
|
// 合规组类型 {@link com.netsdk.lib.enumeration.EM_WORKSUIT_GROUP_TYPE}
|
pstInParam.stuWorkSuitGroupInfo.emGroupType = EM_WORKSUIT_GROUP_TYPE.EM_WORKSUIT_GROUP_TYPE_BLOCK.getValue();
|
pstInParam.write();
|
|
// 出参
|
NET_OUT_CREATE_WORKSUIT_COMPARE_GROUP pstOutParam = new NET_OUT_CREATE_WORKSUIT_COMPARE_GROUP();
|
pstOutParam.write();
|
|
// 调用接口
|
boolean flg = netsdk.CLIENT_CreateWorkSuitCompareGroup(m_hLoginHandle, pstInParam.getPointer(),
|
pstOutParam.getPointer(), 3000);
|
if (flg) {
|
pstOutParam.read();
|
System.out.println("合规库组ID:" + new String(pstOutParam.szGroupID).trim());
|
} else {
|
System.err.println("创建工装合规组失败:" + ToolKits.getErrorCode());
|
}
|
|
}
|
|
/**
|
* 删除工装合规组
|
*/
|
public void deleteWorkSuitCompareGroup() {
|
// 入参
|
NET_IN_DELETE_WORKSUIT_COMPARE_GROUP pstInParam = new NET_IN_DELETE_WORKSUIT_COMPARE_GROUP();
|
// 合规库组ID
|
String szGroupID = "1";
|
System.arraycopy(szGroupID.getBytes(), 0, pstInParam.szGroupID, 0, szGroupID.getBytes().length);
|
pstInParam.write();
|
|
// 出参
|
NET_OUT_DELETE_WORKSUIT_COMPARE_GROUP pstOutParam = new NET_OUT_DELETE_WORKSUIT_COMPARE_GROUP();
|
pstOutParam.write();
|
|
// 调用接口
|
boolean flg = netsdk.CLIENT_DeleteWorkSuitCompareGroup(m_hLoginHandle, pstInParam.getPointer(),
|
pstOutParam.getPointer(), 3000);
|
if (flg) {
|
pstOutParam.read();
|
System.out.println("删除工装合规组成功");
|
} else {
|
System.err.println("删除工装合规组失败:" + ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 批量添加工装合规样本-下发图片路径
|
*
|
* @throws UnsupportedEncodingException
|
*/
|
public void multiAppendToWorkSuitCompareGroup() throws UnsupportedEncodingException {
|
// 入参
|
NET_IN_MULTI_APPEND_TO_WORKSUIT_GROUP pstInParam = new NET_IN_MULTI_APPEND_TO_WORKSUIT_GROUP();
|
int nWorkSuitSampleNum = 2;
|
pstInParam.nWorkSuitSampleNum = nWorkSuitSampleNum;// 工装合规样本个数, 由用户指定大小
|
NET_WORKSUIT_SAMPLE_INFO[] arr = new NET_WORKSUIT_SAMPLE_INFO[nWorkSuitSampleNum];
|
for (int i = 0; i < arr.length; i++) {
|
arr[i] = new NET_WORKSUIT_SAMPLE_INFO();// 初始化数组
|
}
|
/***
|
* 1.每次下发，图片只能下发同一个合规库组ID、合规库组名称(每个token下发时只能对应一个合规库组ID)；
|
* 2.每次下发token值，随机生成且值不能一样,不然会导致上传异常
|
*/
|
// 样本一
|
// 全景图唯一标识符，由平台生成
|
String szSourceUID1 = "A1";
|
System.arraycopy(szSourceUID1.getBytes(encode), 0, arr[0].szSourceUID, 0, szSourceUID1.getBytes(encode).length);
|
// 合规库组ID,创建工装合规组的出参
|
String szGroupID1 = "1";
|
System.arraycopy(szGroupID1.getBytes(encode), 0, arr[0].szGroupID, 0, szGroupID1.getBytes(encode).length);
|
// 合规库组名称,创建工装合规组的入参
|
String szGroupName1 = "快递";
|
System.arraycopy(szGroupName1.getBytes(encode), 0, arr[0].szGroupName, 0, szGroupName1.getBytes(encode).length);
|
// 全景图图片名称
|
String szSourceFileName1 = "图片1";
|
System.arraycopy(szSourceFileName1.getBytes(encode), 0, arr[0].szSourceFileName, 0,
|
szSourceFileName1.getBytes(encode).length);
|
// 文件路径, 支持HTTP URL表示; 支持FTP URL表示; 支持服务器本地路径,填写图片路径后无需填写图片信息中的offset与length字段
|
String szFilePath1 = "http://10.33.12.11/httpImg/work.jpg";
|
System.arraycopy(szFilePath1.getBytes(encode), 0, arr[0].szFilePath, 0, szFilePath1.getBytes(encode).length);
|
// 样本二
|
// 全景图唯一标识符，由平台生成
|
String szSourceUID2 = "A2";
|
System.arraycopy(szSourceUID2.getBytes(encode), 0, arr[1].szSourceUID, 0, szSourceUID2.getBytes(encode).length);
|
// 合规库组ID,创建工装合规组的出参
|
String szGroupID2 = "1";
|
System.arraycopy(szGroupID2.getBytes(encode), 0, arr[1].szGroupID, 0, szGroupID2.getBytes(encode).length);
|
// 合规库组名称,创建工装合规组的入参
|
String szGroupName2 = "快递";
|
System.arraycopy(szGroupName2.getBytes(encode), 0, arr[1].szGroupName, 0, szGroupName2.getBytes(encode).length);
|
// 全景图图片名称
|
String szSourceFileName2 = "图片2";
|
System.arraycopy(szSourceFileName2.getBytes(encode), 0, arr[1].szSourceFileName, 0,
|
szSourceFileName2.getBytes(encode).length);
|
// 文件路径, 支持HTTP URL表示; 支持FTP URL表示; 支持服务器本地路径,填写图片路径后无需填写图片信息中的offset与length字段
|
String szFilePath2 = "http://10.33.12.11/httpImg/work.jpg";
|
System.arraycopy(szFilePath2.getBytes(encode), 0, arr[1].szFilePath, 0, szFilePath2.getBytes(encode).length);
|
|
// 工装合规样本信息赋值到指针
|
pstInParam.pstWorkSuitSampleInfo = new Memory(arr[0].size() * nWorkSuitSampleNum); // 初始化Pointer指针
|
pstInParam.pstWorkSuitSampleInfo.clear(arr[0].size() * nWorkSuitSampleNum);
|
ToolKits.SetStructArrToPointerData(arr, pstInParam.pstWorkSuitSampleInfo); // 将数组内存拷贝给指针
|
|
// 工装合规导入标识信息
|
// 该次图片导入的token值，随机生成且不能一样,不然会导致上传异常，每个token下发时只能对应一个合规库组ID,建议使用数据库需要或者每次操作后加一处理
|
pstInParam.stuAppendIdentiInfo.nToken = randomNum();
|
pstInParam.write();
|
|
// 出参
|
NET_OUT_MULTI_APPEND_TO_WORKSUIT_GROUP pstOutParam = new NET_OUT_MULTI_APPEND_TO_WORKSUIT_GROUP();
|
pstOutParam.write();
|
|
// 调用接口
|
boolean flg = netsdk.CLIENT_MultiAppendToWorkSuitCompareGroup(m_hLoginHandle, pstInParam.getPointer(),
|
pstOutParam.getPointer(), 3000);
|
if (flg) {
|
pstOutParam.read();
|
System.out.println("工装合规导入返回的结果码信息--------");
|
System.out.println("工装合规导入返回的结果码个数:" + pstOutParam.nErrCodeNum);
|
int[] emErrCode = pstOutParam.emErrCode;
|
for (int i = 0; i < pstOutParam.nErrCodeNum; i++) {
|
System.out.println("第" + (i + 1) + "个错误码信息：" + EM_WORKSUIT_APPEND_ERRCODE.getNoteByValue(emErrCode[i]));
|
}
|
} else {
|
System.err.println("批量添加工装合规样本失败:" + ToolKits.getErrorCode());
|
}
|
}
|
|
public int randomNum() {
|
long randomNum = System.currentTimeMillis();
|
int randomNum1 = (int) randomNum;
|
System.out.println("token:" + randomNum1);
|
return randomNum1;
|
}
|
|
/**
|
* 通过全景图唯一标识符删除工装合规样本
|
*
|
* @throws UnsupportedEncodingException
|
*/
|
public void deleteWorkSuitBySourceUID() throws UnsupportedEncodingException {
|
// 入参
|
NET_IN_DELETE_WORKSUIT_BY_SOURCEUID pstInParam = new NET_IN_DELETE_WORKSUIT_BY_SOURCEUID();
|
// 全景图唯一标识符个数
|
pstInParam.nSourceUIDNum = 2;
|
String szSourceUID1 = "A1";
|
String szSourceUID2 = "A2";
|
System.arraycopy(szSourceUID1.getBytes(encode), 0, pstInParam.szSourceUID[0].arr, 0,
|
szSourceUID1.getBytes(encode).length);
|
System.arraycopy(szSourceUID2.getBytes(encode), 0, pstInParam.szSourceUID[1].arr, 0,
|
szSourceUID2.getBytes(encode).length);
|
// 工装合规组ID
|
String szGroupID = "1";
|
System.arraycopy(szGroupID.getBytes(encode), 0, pstInParam.szGroupID, 0, szGroupID.getBytes(encode).length);
|
pstInParam.write();
|
|
// 出参
|
NET_OUT_DELETE_WORKSUIT_BY_SOURCEUID pstOutParam = new NET_OUT_DELETE_WORKSUIT_BY_SOURCEUID();
|
pstOutParam.write();
|
|
// 调用接口
|
boolean flg = netsdk.CLIENT_DeleteWorkSuitBySourceUID(m_hLoginHandle, pstInParam.getPointer(),
|
pstOutParam.getPointer(), 3000);
|
if (flg) {
|
pstOutParam.read();
|
System.out.println("通过全景图唯一标识符删除工装合规样返回的结果码信息--------");
|
System.out.println("通过全景图唯一标识符删除工装合规样返回的结果码个数:" + pstOutParam.nErrCodeNum);
|
int[] emErrCode = pstOutParam.emErrCode;
|
for (int i = 0; i < pstOutParam.nErrCodeNum; i++) {
|
System.out.println(
|
"第" + (i + 1) + "个错误码信息：" + EM_DELETE_BY_SOURCEUID_ERRCODE.getNoteByValue(emErrCode[i]));
|
}
|
} else {
|
System.err.println("通过全景图唯一标识符删除工装合规样本失败:" + ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 订阅报警信息
|
*
|
*/
|
public void startListen() {
|
// 设置报警回调函数
|
netsdk.CLIENT_SetDVRMessCallBack(fAlarmAccessDataCB.getInstance(), null);
|
|
// 订阅报警
|
boolean bRet = netsdk.CLIENT_StartListenEx(m_hLoginHandle);
|
if (!bRet) {
|
System.err.println("订阅报警失败! LastError = 0x%x\n" + ToolKits.getErrorCode());
|
} else {
|
System.out.println("订阅报警成功.");
|
}
|
}
|
|
/**
|
* 报警事件回调
|
*/
|
private static class fAlarmAccessDataCB implements NetSDKLib.fMessCallBack {
|
private static fAlarmAccessDataCB instance = new fAlarmAccessDataCB();
|
|
private fAlarmAccessDataCB() {
|
}
|
|
public static fAlarmAccessDataCB getInstance() {
|
return instance;
|
}
|
|
public boolean invoke(int lCommand, LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP,
|
NativeLong nDevicePort, Pointer dwUser) {
|
switch (lCommand) {
|
case NetSDKLib.NET_ALARM_WORKSUIT_FEATURE_ABSTRACT: {// 工装特征向量建模结果上报事件(对应结构体ALARM_WORKSUIT_FEATURE_ABSTRACT_INFO)
|
System.out.println("-----工装特征向量建模结果上报事件-----");
|
ALARM_WORKSUIT_FEATURE_ABSTRACT_INFO msg = new ALARM_WORKSUIT_FEATURE_ABSTRACT_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println("事件动作:" + msg.nAction);
|
System.out.println("事件发生的时间:" + msg.stuTime.toStringTime());
|
System.out.println("工装建模结果个数:" + msg.nAbstractInfoNum);
|
NET_WORKSUIT_ABSTRACT_INFO[] stuAbstractInfo = msg.stuAbstractInfo;
|
for (int i = 0; i < msg.nAbstractInfoNum; i++) {
|
System.out.println("----第" + (i + 1) + "个工装建模结果信息----");
|
System.out.println("工装合规组ID:" + new String(stuAbstractInfo[i].szGroupID));
|
System.out.println("工装建模进度,百分比:" + stuAbstractInfo[i].nProcess);
|
// System.out.println("该次工装建模的token值:"+stuAbstractInfo[i].nToken);
|
System.out.println("工装图片建模成功的个数:" + stuAbstractInfo[i].nSucceedCnt);
|
System.out.println("工装图片建模失败的个数:" + stuAbstractInfo[i].nFailedCnt);
|
}
|
|
break;
|
}
|
case NetSDKLib.NET_ALARM_REID_CLUSTER_STATE: {// 聚档状态事件(对应结构体 NET_ALARM_REID_CLUSTER_STATE_INFO)
|
System.out.println("-----聚档状态事件-----");
|
NET_ALARM_REID_CLUSTER_STATE_INFO msg = new NET_ALARM_REID_CLUSTER_STATE_INFO();
|
ToolKits.GetPointerData(pStuEvent, msg);
|
System.out.println("事件动作:" + msg.nAction);
|
System.out.println("事件发生的时间:" + msg.stuUTC.toStringTime());
|
System.out.println("当前聚档状态 :" + msg.nClusterState);// 当前聚档状态 1.已完成. 2.进行中 3.聚档失败
|
System.out.println("上次聚档触发时间 :" + msg.nClusterDate);// 上次聚档触发时间，按照年月日记录，作为聚档的唯一key，单设备每日只有一条聚档记录.如20220530则表示在20220530当日已经聚档
|
System.out.println("上次聚档类型 :" + msg.nClusterType);// 上次聚档类型: 1.自动每日聚档 2.平台下发手动聚档 3.手动测试触发 4.聚档主动失败重试
|
System.out.println("记录更新时间:" + msg.stuUTC.toStringTime());// 记录更新时间，已设备本地时间为准
|
break;
|
}
|
default:
|
System.out.printf("Get Other Event 0x%x\n", lCommand);
|
break;
|
}
|
return true;
|
}
|
}
|
|
/**
|
* 取消订阅报警信息
|
*
|
* @return
|
*/
|
public void stopListen() {
|
// 停止订阅报警
|
boolean bRet = netsdk.CLIENT_StopListen(m_hLoginHandle);
|
if (bRet) {
|
System.out.println("取消订阅报警信息.");
|
}
|
}
|
|
/**
|
* 异步查询聚档完整数据
|
*/
|
public void findDetailNumberStatCluster() {
|
// 创建查询 下发条件
|
NET_IN_START_FIND_DETAIL_CLUSTER pstInParam = new NET_IN_START_FIND_DETAIL_CLUSTER();
|
pstInParam.stuCondition.nClusterDate = 20220925;
|
pstInParam.write();
|
NET_OUT_START_FIND_DETAIL_CLUSTER pstOutParam = new NET_OUT_START_FIND_DETAIL_CLUSTER();
|
pstOutParam.write();
|
boolean flg = netsdk.CLIENT_StartFindDetailNumberStatCluster(m_hLoginHandle, pstInParam.getPointer(),
|
pstOutParam.getPointer(), 3000);
|
if (flg) {
|
pstOutParam.read();
|
System.out.println("取到的查询令牌:" + pstOutParam.nToken);
|
System.out.println("记录总数:" + pstOutParam.nCount);
|
System.out.println("查询该天的营业开始时间:" + pstOutParam.stuClusterBeginTime.toStringTime());
|
System.out.println("查询该天的营业结束时间:" + pstOutParam.stuClusterEndTime.toStringTime());
|
} else {
|
System.err.println("创建查询 下发条件失败:" + ToolKits.getErrorCode());
|
return;
|
}
|
|
// 分布查询结果
|
NET_IN_DO_FIND_DETAIL_CLUSTER pstInParam1 = new NET_IN_DO_FIND_DETAIL_CLUSTER();
|
pstInParam1.nToken = pstOutParam.nToken; // start接口返回的token, token保存的数量有限, 未stop的会在连接销毁时或队列满时被释放,
|
// 再用同一token访问会导致失败
|
pstInParam1.nCount = pstOutParam.nCount;// 查询的记录数，单次不超过1024
|
pstInParam1.nStartIndex = 0;// 查询记录的开始偏移
|
pstInParam1.write();
|
NET_OUT_DO_FIND_DETAIL_CLUSTER pstOutParam1 = new NET_OUT_DO_FIND_DETAIL_CLUSTER();
|
pstOutParam1.write();
|
boolean flg1 = netsdk.CLIENT_DoFindDetailNumberStatCluster(m_hLoginHandle, pstInParam1.getPointer(),
|
pstOutParam1.getPointer(), 3000);
|
if (flg1) {
|
pstOutParam1.read();
|
System.out.println("查询记录条数:" + pstOutParam1.nFound);
|
System.out.println("返回记录实际条数:" + pstOutParam1.nFindInfoRealNum);
|
System.out.println("打印其中的一条记录数据-----");
|
if (pstOutParam1.nFindInfoRealNum > 1) {
|
System.out.println("设备端数据库ID：" + pstOutParam1.stuClusterFindInfo[1].nRcNo);
|
System.out.println("人员记录的唯一Key：" + new String(pstOutParam1.stuClusterFindInfo[1].szTrackID));
|
System.out.println("聚档结果ID：" + pstOutParam1.stuClusterFindInfo[1].nProfileID);
|
System.out.println("抓拍通道号：" + pstOutParam1.stuClusterFindInfo[1].nChannel);
|
System.out.println("年龄：" + pstOutParam1.stuClusterFindInfo[1].nAge);
|
System.out.println("性别：" + pstOutParam1.stuClusterFindInfo[1].nGender);
|
System.out.println("人员的经过属性：" + pstOutParam1.stuClusterFindInfo[1].nHumanState);
|
}
|
|
} else {
|
System.err.println("分布查询结果失败:" + ToolKits.getErrorCode());
|
return;
|
}
|
|
// 销毁查询对象
|
NET_IN_STOP_FIND_DETAIL_CLUSTER_INFO pstInParam2 = new NET_IN_STOP_FIND_DETAIL_CLUSTER_INFO();
|
pstInParam2.nToken = pstOutParam.nToken; // start接口返回的token, token仅会保存
|
pstInParam2.write();
|
NET_OUT_STOP_FIND_DETAIL_CLUSTER_INFO pstOutParam2 = new NET_OUT_STOP_FIND_DETAIL_CLUSTER_INFO();
|
pstOutParam2.write();
|
boolean flg2 = netsdk.CLIENT_StopFindDetailNumberStatCluster(m_hLoginHandle, pstInParam2.getPointer(),
|
pstOutParam2.getPointer(), 3000);
|
if (flg2) {
|
pstOutParam2.read();
|
System.out.println("销毁查询对象成功");
|
} else {
|
System.err.println("销毁查询对象失败:" + ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 平台主动获取设备聚档状态
|
*/
|
public void getClusterState() {
|
NET_IN_GET_CLUSTER_STATE_INFO pstInParam = new NET_IN_GET_CLUSTER_STATE_INFO();
|
pstInParam.nClusterDate = 20220925; // 非必选, 当包含该字段时查对应日期的聚档状态, 否则返回最近一次的状态
|
pstInParam.write();
|
NET_OUT_GET_CLUSTER_STATE_INFO pstOutParam = new NET_OUT_GET_CLUSTER_STATE_INFO();
|
pstOutParam.write();
|
boolean flg = netsdk.CLIENT_GetClusterState(m_hLoginHandle, pstInParam.getPointer(), pstOutParam.getPointer(),
|
3000);
|
if (flg) {
|
pstOutParam.read();
|
System.out.println("当前聚档状态:" + pstOutParam.nClusterState);// 当前聚档状态 1.已完成. 2.进行中 3.聚档失败
|
System.out.println("记录更新时间:" + pstOutParam.stuDealTime.toStringTime());// 记录更新时间，已设备本地时间为准
|
System.out.println("聚档触发时间:" + pstOutParam.nClusterState);// 聚档触发时间, 按照年月日记录,
|
// 作为聚档的唯一key,单设备每日只有一条聚档记录.如20220530则表示在20220530当日已经聚档
|
System.out.println("上次聚档类型:" + pstOutParam.nClusterType);// 上次聚档类型: 1.自动每日聚档 2.平台下发手动聚档 3.手动测试触发 4.聚档主动失败重试
|
} else {
|
System.err.println("平台主动获取设备聚档状态失败:" + ToolKits.getErrorCode());
|
return;
|
}
|
|
}
|
|
int channel = 14;
|
|
/**
|
* 订阅统计通道数据
|
*
|
* @throws UnsupportedEncodingException
|
*/
|
public void attachVideoStatStream() throws UnsupportedEncodingException {
|
NET_IN_ATTACH_VIDEOSTAT_STREAM input = new NET_IN_ATTACH_VIDEOSTAT_STREAM();
|
// 视频通道号
|
input.nVideoChannel = channel;
|
// 粒度模式,EM_STAT_GRANULARITY
|
input.emGranularity = 1;
|
// "NumberStat"：人数统计，统计进入离开数量 ; "ManNumDetection"：区域内人数统计，统计区域内人员数量及滞留时间
|
String ruleType = "ManNumDetection";
|
System.arraycopy(ruleType.getBytes(encode), 0, input.szRuleType, 0, ruleType.getBytes(encode).length);
|
// 开始时间，表示从什么时间开始统计上报，开始时间，需按周期取整。如推送周期是10分钟一次，那么开始时间，只能为，每个小时的
|
// 第0分，10分、20分、30分、40、分、50分。
|
String sartTime = "2022-12-13 08:00:00";
|
System.arraycopy(sartTime.getBytes(encode), 0, input.szStartTime, 0, sartTime.getBytes(encode).length);
|
// 与Granularity结合使用，如emGranularity为 EM_GRANULARITY_MINUTE， Cycle
|
// 值为5，表示以5分钟统计周期上报数据
|
input.nCycle = 1;
|
// 统计通道数据回调
|
input.cbVideoStatStream = VideoStatStreamCallBack.getInstance();
|
if ("ManNumDetection".equals(ruleType)) {
|
// 滞留情况数组大小，如填0则不下发该字段
|
input.nSendMinStayTimeValidNum = 2;
|
// 上报时间段内区域人员滞留情况, 表示统计的间隔结果中返回滞留时间大于3秒，大于5秒，大于10秒的记录,单位秒, 不下发时回调仅返回总人数和总滞留时长
|
input.nMinStayTime[0] = 1;
|
input.nMinStayTime[1] = 2;
|
}
|
|
input.write();
|
|
NET_OUT_ATTACH_VIDEOSTAT_STREAM outPut = new NET_OUT_ATTACH_VIDEOSTAT_STREAM();
|
outPut.write();
|
|
attachHandle = netsdk.CLIENT_AttachVideoStatStream(m_hLoginHandle, input.getPointer(), outPut.getPointer(),
|
3000);
|
if (attachHandle.longValue() == 0) {
|
System.out.printf("Chn[%d] CLIENT_AttachVideoStatStream Failed!LastError = %s\n", channel,
|
ToolKits.getErrorCode());
|
} else {
|
System.out.printf("Chn[%d] CLIENT_AttachVideoStatStream Success\n", channel);
|
}
|
|
}
|
|
/**
|
* 取消订阅统计通道数据
|
*/
|
public void detachVideoStatStream() {
|
boolean isSuccess = netsdk.CLIENT_DetachVideoStatStream(attachHandle);
|
if (isSuccess) {
|
System.out.println(" CLIENT_DetachVideoStatStream Success");
|
} else {
|
System.out.printf("Chn[%d] CLIENT_DetachVideoStatStream Failed!LastError = %s\n", channel,
|
ToolKits.getErrorCode());
|
}
|
}
|
|
/**
|
* 统计通道数据信息
|
*/
|
private static class VideoStatStreamCallBack implements NetSDKLib.fVideoStatStreamCallBack {
|
private static VideoStatStreamCallBack instance;
|
|
public static VideoStatStreamCallBack getInstance() {
|
if (instance == null) {
|
synchronized (VideoStatStreamCallBack.class) {
|
if (instance == null) {
|
instance = new VideoStatStreamCallBack();
|
}
|
}
|
}
|
return instance;
|
}
|
|
@Override
|
public void invoke(LLong lAttachHandle, Pointer pBuf, int nBufLen, Pointer dwUser) {
|
System.out.println("---------统计通道数据信息----------");
|
NET_CB_VIDEOSTAT_STREAM msg = new NET_CB_VIDEOSTAT_STREAM();
|
ToolKits.GetPointerData(pBuf, msg);
|
System.out.println("统计通道号: " + msg.nChannel);
|
try {
|
System.out.println("规则名称: " + new String(msg.szRuleNanme, encode));
|
System.out.println("当前这一统计周期的开始时间: " + new String(msg.szStartTime, encode));
|
System.out.println("规则类型: " + new String(msg.szRuleType, encode));
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
System.out.println("粒度: " + msg.emStatGranularity);
|
System.out.println("统计周期: " + msg.nCycle);
|
System.out.println("区域ID，没有该字段或者为0，为单区域: " + msg.nAreaID);
|
System.out.println("本周期内进入人数小计: " + msg.nEnteredSubtotal);
|
System.out.println("本周期内离开人数小计: " + msg.nExitedSubtotal);
|
System.out.println("本周期内经过人数小计: " + msg.nPassedSubtotal);
|
// 本周期区域内滞留人员统计信息, bIsSendMinStayTime为TRUE时有效 ruleType为“ManNumDetection”时，上报数据
|
System.out.println(" 本周期上报的区域内总人数: " + msg.stuInsideSubtotal.nTotal);
|
System.out.println(" 当前周期，所有人的总滞留时长: " + msg.stuInsideSubtotal.nTotalStayTime);
|
System.out.println(" 人次数据有效个数: " + msg.stuInsideSubtotal.nManStaySummaryValidNum);
|
if (msg.stuInsideSubtotal.nManStaySummaryValidNum > 0) {
|
System.out.println("人次数据-----------------------");
|
// 人次数据,例此处下发的规则为滞留时间大于3,5,10,300秒的规则.此处结果就是滞留时间大于3秒共10人次，大于5秒的6人次，10秒的3人次，300秒的0人次
|
int[] nManStaySummary = msg.stuInsideSubtotal.nManStaySummary;
|
for (int i = 0; i < msg.stuInsideSubtotal.nManStaySummaryValidNum; i++) {
|
System.out.println(" nManStaySummary[" + i + "]: " + nManStaySummary[i]);
|
}
|
}
|
|
System.out.println(" 总滞留时长有效个数: " + msg.stuInsideSubtotal.nTotalStayTimeSummaryValidNum);
|
if (msg.stuInsideSubtotal.nTotalStayTimeSummaryValidNum > 0) {
|
System.out.println("总滞留时长，单位秒-----------------------");
|
// 总滞留时长，单位秒,
|
// 例此处下发的规则为滞留时间大于3,5,10,300秒的规则,此处结果就是滞留时间大于3秒的人员的总滞留时长50秒，大于5秒的48秒，10秒的30秒，300秒的0秒
|
int[] nTotalStayTimeSummary = msg.stuInsideSubtotal.nTotalStayTimeSummary;
|
for (int i = 0; i < msg.stuInsideSubtotal.nTotalStayTimeSummaryValidNum; i++) {
|
System.out.println(" nTotalStayTimeSummary[" + i + "]: " + nTotalStayTimeSummary[i]);
|
}
|
}
|
|
}
|
|
}
|
|
/******************************** 测试控制台 ***************************************/
|
|
// 配置登陆地址，端口，用户名，密码
|
private String m_strIpAddr = "172.13.51.83";
|
private int m_nPort = 37777;
|
private String m_strUser = "admin";
|
private String m_strPassword = "admin123";
|
|
public static void main(String[] args) {
|
REIDConfigDemo demo = new REIDConfigDemo();
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
|
}
|
|
/**
|
* 初始化测试
|
*/
|
public void InitTest() {
|
REIDConfigDemo.Init();
|
this.loginWithHighLevel();
|
}
|
|
/**
|
* 加载测试内容
|
*/
|
public void RunTest() {
|
CaseMenu menu = new CaseMenu();
|
menu.addItem(new CaseMenu.Item(this, "查找工装合规组信息", "findWorkSuitCompareGroup"));
|
menu.addItem(new CaseMenu.Item(this, "创建工装合规组", "createWorkSuitCompareGroup"));
|
menu.addItem(new CaseMenu.Item(this, "删除工装合规组", "deleteWorkSuitCompareGroup"));
|
menu.addItem(new CaseMenu.Item(this, "批量添加工装合规样本", "multiAppendToWorkSuitCompareGroup"));
|
menu.addItem(new CaseMenu.Item(this, "通过全景图唯一标识符删除工装合规样本", "deleteWorkSuitBySourceUID"));
|
|
menu.addItem(new CaseMenu.Item(this, "订阅报警信息", "startListen"));
|
menu.addItem(new CaseMenu.Item(this, "取消订阅报警信息", "stopListen"));
|
|
menu.addItem(new CaseMenu.Item(this, "异步查询聚档完整数据", "findDetailNumberStatCluster"));
|
menu.addItem(new CaseMenu.Item(this, "平台主动获取设备聚档状态", "getClusterState"));
|
|
menu.addItem(new CaseMenu.Item(this, "订阅统计通道数据", "attachVideoStatStream"));
|
menu.addItem(new CaseMenu.Item(this, "取消订阅统计通道数据", "detachVideoStatStream"));
|
menu.run();
|
}
|
|
/**
|
* 结束测试
|
*/
|
public void EndTest() {
|
System.out.println("End Test");
|
this.logOut(); // 登出设备
|
System.out.println("See You...");
|
REIDConfigDemo.cleanAndExit(); // 清理资源并退出
|
}
|
/******************************** 结束 ***************************************/
|
}
|
