package com.netsdk.demo.customize;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.ToolKits;
|
import com.netsdk.lib.Utils;
|
import com.netsdk.lib.enumeration.EM_RECORD_BACKUP_FIND_TYPE;
|
import com.netsdk.lib.structure.*;
|
import com.netsdk.lib.utils.Initialization;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import java.nio.charset.Charset;
|
import static com.netsdk.lib.NetSDKLib.EM_FILE_QUERY_TYPE.NET_FILE_QUERY_EXAM;
|
|
/**
|
* @author 291189
|
* @version 1.0
|
* @description GIP220427035 & GIP220601015
|
* @date 2022/5/16 20:07
|
*/
|
public class FindRecordBackupRestoreTaskInfosDemo extends Initialization {
|
|
// 跨平台编码
|
private static final Charset sdkEncode = Charset.forName(Utils.getPlatformEncode());
|
// 任务ID
|
private final int[] taskID = new int[1024];
|
|
/**
|
* 根据查询条件返回录像备份任务的信息表
|
*/
|
public void findTaskInfos() {
|
// 入参
|
NET_IN_FIND_REC_BAK_RST_TASK pInParam = new NET_IN_FIND_REC_BAK_RST_TASK();
|
// 根据条件查询备份任务的查询方式
|
pInParam.emFindType = EM_RECORD_BACKUP_FIND_TYPE.EM_RECORD_BACKUP_FIND_TYPE_BY_TASKID.getValue();
|
if(pInParam.emFindType == 1) {
|
|
// 按照任务号查询
|
pInParam.dwTaskID =1897909;
|
}else if(pInParam.emFindType == 2) {
|
// 按照通道和录制时间段查询
|
// 通道号
|
pInParam.nLocalChannelID = 3;
|
//录制时间段
|
pInParam.stuStartTime.setTime(2020, 10, 1, 0, 0, 0);
|
pInParam.stuEndTime.setTime(2023, 10, 1, 23, 0, 0);
|
}else if(pInParam.emFindType==3){
|
//按照主动注册的设备ID查
|
byte[] szDeviceID = pInParam.szDeviceID;
|
String deviceID="evs52172121184";
|
ToolKits.StringToByteArr(deviceID,szDeviceID);
|
|
}
|
pInParam.write();
|
|
// 出参
|
NET_OUT_FIND_REC_BAK_RST_TASK pOutParam = new NET_OUT_FIND_REC_BAK_RST_TASK();
|
pOutParam.nMaxCount = 100;
|
NetSDKLib.NET_REC_BAK_RST_TASK[] Tasks = new NetSDKLib.NET_REC_BAK_RST_TASK[pOutParam.nMaxCount];
|
for (int i = 0; i < pOutParam.nMaxCount; i++) {
|
Tasks[i] = new NetSDKLib.NET_REC_BAK_RST_TASK();
|
}
|
pOutParam.pTasks = new Memory(Tasks[0].size() * pOutParam.nMaxCount);
|
pOutParam.pTasks.clear(Tasks[0].size() * pOutParam.nMaxCount);
|
ToolKits.SetStructArrToPointerData(Tasks, pOutParam.pTasks);
|
|
|
pOutParam.write();
|
boolean ret = netSdk.CLIENT_FindRecordBackupRestoreTaskInfos(loginHandle, pInParam.getPointer(), pOutParam.getPointer(), 3000);
|
|
if (!ret) {
|
System.err.printf("findTaskInfosByTime false Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}else {
|
System.out.println("findTaskInfosByTime success");
|
}
|
pOutParam.read();
|
ToolKits.GetPointerDataToStructArr(pOutParam.pTasks,Tasks);
|
|
int nRetCount = Math.min(pOutParam.nMaxCount, pOutParam.nRetCount);
|
ToolKits.GetPointerDataToStructArr(pOutParam.pTasks, Tasks);
|
if (nRetCount == 0) {
|
System.out.println("没有发现任务；请添加");
|
return;
|
}
|
for (int i = 0; i < nRetCount; i++) {
|
String szDevice = new String(Tasks[i].szDeviceID, sdkEncode).trim();
|
taskID[i] = Tasks[i].nTaskID;
|
System.out.println("任务ID: " + taskID[i] + " 设备ID: " + szDevice
|
+ " 通道号: " + Tasks[i].nChannelID + " 录像开始时间: " + Tasks[i].stuStartTime.toStringTime()
|
+ " 录像结束时间: " + Tasks[i].stuEndTime.toStringTime()
|
+" 任务开始时间, nState为1、2、3的情况下该时间点有效： "+Tasks[i].stuTaskStartTime.toStringTime()
|
+" 任务结束时间, nState为2、3的情况下该时间点有效： "+Tasks[i].stuTaskEndTime.toStringTime()
|
+"备份源通道:"+Tasks[i].nRemoteChannel);
|
|
System.out.println("当前备份状态(0 等待 1 进行中 2 完成 3 失败):" + Tasks[i].nState);
|
System.out.println(" 失败的原因, 当nState字段为3的情况下有效,参考EM_RECORD_BACKUP_FAIL_REASON:"+Tasks[i].emFailReason);
|
}
|
}
|
// 按查询条件查询文件
|
public void FindFileEx(){
|
|
//对应 NET_MEDIAFILE_EXAM_PARAM 和 NET_MEDIAFILE_EXAM_INFO
|
NET_MEDIAFILE_EXAM_PARAM netMediafileExamParam=new NET_MEDIAFILE_EXAM_PARAM();
|
|
String name="张三";
|
ToolKits.StringToByteArr(name, netMediafileExamParam.szName);
|
|
Pointer pointer = new Memory(netMediafileExamParam.size());
|
pointer.clear(netMediafileExamParam.size());
|
ToolKits.SetStructDataToPointer(netMediafileExamParam,pointer,0);
|
|
NetSDKLib.LLong lLong
|
= netSdk.CLIENT_FindFileEx(loginHandle, NET_FILE_QUERY_EXAM, pointer, null, 3000);
|
if(lLong.longValue()!=0){
|
System.out.println("CLIENT_FindFileEx success lLong:"+lLong);
|
}else {
|
System.err.printf("CLIENT_FindFileEx false Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
}
|
}
|
|
|
public void SetExamRecordingPlans(){
|
NET_IN_SET_EXAM_RECORDING_PLANS input=new NET_IN_SET_EXAM_RECORDING_PLANS();
|
|
input.nPlansNum=1;
|
|
|
NET_EXAM_RECORDING_PLAN_INFO[] info=new NET_EXAM_RECORDING_PLAN_INFO[2];
|
for(int i=0;i<info.length;i++){
|
info[i]=new NET_EXAM_RECORDING_PLAN_INFO();
|
|
String name="张三";
|
ToolKits.StringToByteArr(name, info[i].szName);
|
String szNumber="878789";
|
ToolKits.StringToByteArr(szNumber, info[i].szNumber);
|
|
info[i].nCameraIPNum=2;
|
|
String ip1="172.12.10.37";
|
String ip2="10.33.12.205";
|
|
System.arraycopy(ip1.getBytes(), 0, info[i].szCameraIP, 0, ip1.getBytes().length);
|
|
System.arraycopy(ip2.getBytes(), 0, info[i].szCameraIP, 32, ip2.getBytes().length);
|
info[i].stuStartTime.setTime(2022, 5, 21, 9, 0, 0);
|
info[i].stuEndTime.setTime(2022, 5, 21, 16, 30, 0);
|
|
}
|
|
|
Pointer pointerInfo = new Memory(new NET_EXAM_RECORDING_PLAN_INFO().size() * info.length);
|
|
pointerInfo.clear(new NET_EXAM_RECORDING_PLAN_INFO().size() * info.length);
|
ToolKits.SetStructArrToPointerData(info,pointerInfo);
|
|
input.pstuPlans=pointerInfo;
|
|
|
Pointer pointerInput = new Memory(input.size());
|
pointerInput.clear(input.size());
|
ToolKits.SetStructDataToPointer(input,pointerInput,0);
|
|
|
|
NET_OUT_SET_EXAM_RECORDING_PLANS outPut=new NET_OUT_SET_EXAM_RECORDING_PLANS();
|
|
Pointer pointerOut = new Memory(outPut.size());
|
pointerOut.clear(outPut.size());
|
ToolKits.SetStructDataToPointer(outPut,pointerOut,0);
|
|
|
boolean b = netSdk.CLIENT_SetExamRecordingPlans(loginHandle, pointerInput, pointerOut, 3000);
|
if (!b) {
|
System.err.printf("CLIENT_SetExamRecordingPlans false Last Error[0x%x]\n", netSdk.CLIENT_GetLastError());
|
return;
|
}else {
|
System.out.println("CLIENT_SetExamRecordingPlans success");
|
}
|
|
}
|
public void RunTest()
|
{
|
System.out.println("Run Test");
|
CaseMenu menu = new CaseMenu();;
|
menu.addItem((new CaseMenu.Item(this , "findTaskInfos" , "findTaskInfos")));
|
menu.addItem((new CaseMenu.Item(this , "FindFileEx" , "FindFileEx")));
|
menu.addItem((new CaseMenu.Item(this , "SetExamRecordingPlans" , "SetExamRecordingPlans")));
|
|
menu.run();
|
}
|
|
public static void main(String[] args) {
|
FindRecordBackupRestoreTaskInfosDemo findRecordBackupRestoreTaskInfosDemo=new FindRecordBackupRestoreTaskInfosDemo();
|
InitTest("172.12.5.248",37777,"admin","admin123");
|
findRecordBackupRestoreTaskInfosDemo.RunTest();
|
LoginOut();
|
|
}
|
}
|
