package com.netsdk.demo.customize;
|
|
import java.io.File;
|
|
import com.netsdk.demo.util.CaseMenu;
|
import com.netsdk.lib.NetSDKLib;
|
import com.netsdk.lib.NetSDKLib.LLong;
|
import com.netsdk.lib.ToolKits;
|
import com.sun.jna.Memory;
|
import com.sun.jna.Pointer;
|
import com.sun.jna.ptr.IntByReference;
|
|
/**
|
* 查找图片demo
|
*/
|
public class FindFilePicture {
|
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); //登陆句柄
|
|
|
// 设备断线回调: 通过 CLIENT_Init 设置该回调函数,当设备出现断线时,SDK会调用该函数
|
public class fDisConnectCB implements NetSDKLib.fDisConnect{
|
public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser){
|
System.out.printf("Device[%s] Port[%d] Disconnect!\n" , pchDVRIP , nDVRPort);
|
}
|
}
|
|
// 网络连接恢复,设备重连成功回调
|
// 通过 CLIENT_SetAutoReconnect 设置该回调函数,当已断线的设备重连成功时,SDK会调用该函数
|
public class HaveReConnect implements NetSDKLib.fHaveReConnect {
|
public void invoke(LLong loginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
|
System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
|
}
|
}
|
|
private fDisConnectCB m_DisConnectCB = new fDisConnectCB();
|
private HaveReConnect haveReConnect = new HaveReConnect();
|
|
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(m_DisConnectCB, null);
|
|
// 设置断线重连回调接口,设置过断线重连成功回调函数后,当设备出现断线情况,SDK内部会自动进行重连操作
|
// 此操作为可选操作,但建议用户进行设置
|
netsdkApi.CLIENT_SetAutoReconnect(haveReConnect, null);
|
|
//设置登录超时时间和尝试次数,可选
|
int waitTime = 5000; //登录请求响应超时时间设置为5S
|
int tryTimes = 3; //登录时尝试建立链接3次
|
netsdkApi.CLIENT_SetConnectTime(waitTime, tryTimes);
|
|
// 设置更多网络参数,NET_PARAM的nWaittime,nConnectTryNum成员与CLIENT_SetConnectTime
|
// 接口设置的登录设备超时时间和尝试次数意义相同,可选
|
NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
|
netParam.nConnectTime = 10000; //登录时尝试建立链接的超时时间
|
netsdkApi.CLIENT_SetNetworkParam(netParam);
|
|
// 打开日志,可选
|
NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
|
|
File path = new File(".");
|
String logPath = path.getAbsoluteFile().getParent() + "\\sdk_log\\" + System.currentTimeMillis() + ".log";
|
|
setLog.bSetFilePath = 1;
|
System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
|
|
setLog.bSetPrintStrategy = 1;
|
setLog.nPrintStrategy = 0;
|
boolean bLogopen = netsdkApi.CLIENT_LogOpen(setLog);
|
if (!bLogopen) {
|
System.err.println("Failed to open NetSDK log !!!");
|
}
|
|
// 向设备登入
|
int nSpecCap = 0;
|
Pointer pCapParam = null;
|
IntByReference nError = new IntByReference(0);
|
loginHandle = netsdkApi.CLIENT_LoginEx2(m_strIp, m_nPort, m_strUser ,
|
m_strPassword ,nSpecCap,pCapParam, deviceinfo,nError);
|
|
if(loginHandle.longValue() != 0) {
|
System.out.printf("Login Device[%s] Port[%d]Success!\n" , m_strIp , m_nPort);
|
}
|
else {
|
System.out.printf("Login Device[%s] Port[%d]Fail.Last Error[0x%x]\n" , m_strIp , m_nPort , netsdkApi.CLIENT_GetLastError());
|
EndTest();
|
}
|
}
|
|
/**
|
* 获取接口错误码
|
* @return
|
*/
|
public static String getErrorCode() {
|
return " { error code: ( 0x80000000|" + (netsdkApi.CLIENT_GetLastError() & 0x7fffffff) +" ). 参考 NetSDKLib.java }";
|
}
|
|
/**
|
* 查找录像,需要指定查询录像的最大个数
|
*/
|
public void QueryRecordFile() {
|
NetSDKLib.NET_TIME stTimeStart = new NetSDKLib.NET_TIME();
|
stTimeStart.dwYear = 2017;
|
stTimeStart.dwMonth = 8;
|
stTimeStart.dwDay = 11;
|
stTimeStart.dwHour = 2;
|
stTimeStart.dwMinute = 0;
|
stTimeStart.dwSecond = 0;
|
|
NetSDKLib.NET_TIME stTimeEnd = new NetSDKLib.NET_TIME();
|
stTimeEnd.dwYear = 2017;
|
stTimeEnd.dwMonth = 8;
|
stTimeEnd.dwDay = 11;
|
stTimeEnd.dwHour = 3;
|
stTimeEnd.dwMinute = 0;
|
stTimeEnd.dwSecond = 0;
|
|
//**************按时间查找视频文件**************
|
int nFileCount = 50; //每次查询的最大文件个数
|
NetSDKLib.NET_RECORDFILE_INFO[] numberFile = (NetSDKLib.NET_RECORDFILE_INFO[])new NetSDKLib.NET_RECORDFILE_INFO().toArray(nFileCount);
|
int maxlen = nFileCount * numberFile[0].size();
|
|
IntByReference outFileCoutReference = new IntByReference(0);
|
|
boolean cRet = netsdkApi.CLIENT_QueryRecordFile(loginHandle, 0, 0, stTimeStart, stTimeEnd, null, numberFile, maxlen, outFileCoutReference, 5000, false);
|
|
if(cRet) {
|
System.out.println("QueryRecordFile Succeed! \n" + "查询到的视频个数:" + outFileCoutReference.getValue()
|
+ "\n" + "码流类型:" + numberFile[0].bRecType);
|
for(int i=0; i<outFileCoutReference.getValue(); i++) {
|
System.out.println("【" + i + "】:");
|
System.out.println("开始时间:" + numberFile[i].starttime);
|
System.out.println("结束时间:" + numberFile[i].endtime);
|
System.out.println("通道号:" + numberFile[i].ch);
|
}
|
|
} else {
|
System.err.println("QueryRecordFile Failed!" + netsdkApi.CLIENT_GetLastError());
|
}
|
}
|
|
|
/**
|
* 查询录像/图片文件
|
*/
|
public void FindPicture() {
|
int type = NetSDKLib.EM_FILE_QUERY_TYPE.NET_FILE_QUERY_FILE;
|
|
// 查询条件
|
NetSDKLib.NET_IN_MEDIA_QUERY_FILE queryCondition = new NetSDKLib.NET_IN_MEDIA_QUERY_FILE();
|
|
// 工作目录列表,一次可查询多个目录,为空表示查询所有目录。
|
// 目录之间以分号分隔,如“/mnt/dvr/sda0;/mnt/dvr/sda1”,szDirs==null 或"" 表示查询所有
|
queryCondition.szDirs = "";
|
|
// 文件类型,0:查询任意类型,1:查询jpg图片,2:查询dav
|
queryCondition.nMediaType = 1;
|
|
// 通道号从0开始,-1表示查询所有通道
|
queryCondition.nChannelID = -1;
|
|
// 开始时间
|
queryCondition.stuStartTime.dwYear = 2020;
|
queryCondition.stuStartTime.dwMonth = 12;
|
queryCondition.stuStartTime.dwDay = 1;
|
queryCondition.stuStartTime.dwHour = 0;
|
queryCondition.stuStartTime.dwMinute = 0;
|
queryCondition.stuStartTime.dwSecond = 0;
|
|
// 结束时间
|
queryCondition.stuEndTime.dwYear = 2020;
|
queryCondition.stuEndTime.dwMonth = 12;
|
queryCondition.stuEndTime.dwDay = 25;
|
queryCondition.stuEndTime.dwHour = 0;
|
queryCondition.stuEndTime.dwMinute = 0;
|
queryCondition.stuEndTime.dwSecond = 0;
|
|
queryCondition.write();
|
LLong lFindHandle = netsdkApi.CLIENT_FindFileEx(loginHandle, type, queryCondition.getPointer(), null, 3000);
|
if(lFindHandle.longValue() == 0) {
|
System.err.println("FindFileEx Failed!" + getErrorCode());
|
return;
|
}
|
queryCondition.read();
|
|
///////////////////////////
|
int nMaxConut = 10; // 每次查询的个数,循环查询
|
NetSDKLib.NET_OUT_MEDIA_QUERY_FILE[] pMediaQueryFile = new NetSDKLib.NET_OUT_MEDIA_QUERY_FILE[nMaxConut];
|
for (int i = 0; i < pMediaQueryFile.length; ++i) {
|
pMediaQueryFile[i] = new NetSDKLib.NET_OUT_MEDIA_QUERY_FILE();
|
}
|
|
int MemorySize = pMediaQueryFile[0].size() * nMaxConut;
|
Pointer mediaFileInfo = new Memory(MemorySize);
|
mediaFileInfo.clear(MemorySize);
|
|
ToolKits.SetStructArrToPointerData(pMediaQueryFile, mediaFileInfo);
|
|
//循环查询
|
int nCurCount = 0;
|
int nFindCount = 0;
|
while(true) {
|
int nRet = netsdkApi.CLIENT_FindNextFileEx(lFindHandle, nMaxConut, mediaFileInfo, MemorySize, null, 3000);
|
ToolKits.GetPointerDataToStructArr(mediaFileInfo, pMediaQueryFile);
|
System.out.println("nRet : " + nRet);
|
|
if (nRet <= 0) {
|
break;
|
}
|
|
for (int i = 0; i < nRet; i++) {
|
nFindCount = i + nCurCount * nMaxConut;
|
System.out.println("[" + nFindCount + "]通道号 :" + pMediaQueryFile[i].nChannelID);
|
System.out.println("[" + nFindCount + "]开始时间 :" + pMediaQueryFile[i].stuStartTime.toStringTime());
|
System.out.println("[" + nFindCount + "]结束时间 :" + pMediaQueryFile[i].stuEndTime.toStringTime());
|
if(pMediaQueryFile[i].byFileType == 1) {
|
System.out.println("[" + nFindCount + "]文件类型 : jpg图片");
|
} else if ((pMediaQueryFile[i].byFileType == 2)){
|
System.out.println("[" + nFindCount + "]文件类型 : dav");
|
}
|
System.out.println("[" + nFindCount + "]文件路径 :" + new String(pMediaQueryFile[i].szFilePath).trim());
|
}
|
|
if(nRet < nMaxConut) {
|
break;
|
} else {
|
nCurCount++;
|
}
|
}
|
|
// 关闭查询
|
netsdkApi.CLIENT_FindCloseEx(lFindHandle);
|
}
|
|
////////////////////////////////////////////////////////////////
|
// String m_strIp = "172.23.2.92";
|
String m_strIp = "10.80.9.45";
|
// String m_strIp = "10.80.9.44";
|
|
int m_nPort = 37777;
|
String m_strUser = "admin";
|
String m_strPassword = "2020";
|
////////////////////////////////////////////////////////////////
|
|
public void RunTest()
|
{
|
System.out.println("Run Test");
|
CaseMenu menu = new CaseMenu();
|
|
menu.addItem(new CaseMenu.Item(this , "FindPicture" , "FindPicture"));
|
|
menu.run();
|
}
|
|
public static void main(String[]args)
|
{
|
FindFilePicture demo = new FindFilePicture();
|
|
demo.InitTest();
|
demo.RunTest();
|
demo.EndTest();
|
}
|
}
|