package com.netsdk.demo.example;

import java.io.File;
import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NativeString;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.MEDIAFILE_SNAPSHORT_WITH_MARK_INFO;
import com.netsdk.lib.NetSDKLib.MEDIAFILE_SNAPSHORT_WITH_MARK_PARAM;
import com.netsdk.lib.NetSDKLib.NET_IN_DOWNLOAD_REMOTE_FILE;
import com.netsdk.lib.NetSDKLib.NET_OUT_DOWNLOAD_REMOTE_FILE;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.NetSDKLib.LLong;
import com.netsdk.lib.NetSDKLib.NET_DEVICEINFO_Ex;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

public class FindMark {
	public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
	// 登陆句柄
    private static LLong loginHandle = new LLong(0);
    
    //文件查询句柄
    private LLong lFindHandle = new LLong(0);    
    
    // 设备信息扩展
    private NET_DEVICEINFO_Ex deviceInfo = new NET_DEVICEINFO_Ex();
	
    
	public void InitTest(){
		// 初始化SDK库
        netSdk.CLIENT_Init(DisConnectCallBack.getInstance(), null);

        // 设置断线重连成功回调函数
        netSdk.CLIENT_SetAutoReconnect(HaveReConnectCallBack.getInstance(), 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);
	}
	
////////////////////////////////////////////////////////////////
private String m_strIp 				    = "172.9.9.81";
private int    m_nPort 				    = 37777;
private String m_strUser 			    = "admin";
private String m_strPassword 		    = "admin123";
////////////////////////////////////////////////////////////////

public void FindFileEx(){
	
	int emType=NetSDKLib.EM_FILE_QUERY_TYPE.NET_FILE_QUERY_SNAPSHOT_WITH_MARK;
	MEDIAFILE_SNAPSHORT_WITH_MARK_PARAM pQueryCondition=new MEDIAFILE_SNAPSHORT_WITH_MARK_PARAM();
	pQueryCondition.stuStartTime.setTime(2020, 2, 16, 00, 00, 00);
	pQueryCondition.stuEndTime.setTime(2020, 2, 18, 23, 59, 59);
	pQueryCondition.write();
	lFindHandle=netSdk.CLIENT_FindFileEx(loginHandle, emType, pQueryCondition.getPointer(), null, 3000);
	if(lFindHandle.longValue()==0){
		System.err.println("FindFileEx Failed!" + netSdk.CLIENT_GetLastError());
		return;
	}
	
	int nMaxConut=10;
	
	MEDIAFILE_SNAPSHORT_WITH_MARK_INFO[] MarkInfo=new MEDIAFILE_SNAPSHORT_WITH_MARK_INFO[nMaxConut];
	
	for (int i = 0; i < MarkInfo.length; ++i) {
		MarkInfo[i] = new NetSDKLib.MEDIAFILE_SNAPSHORT_WITH_MARK_INFO();
		/*System.out.println(MarkInfo[i].nChannelID+MarkInfo[i].nFileSize+new String(MarkInfo[i].szFilePath).trim());
		System.out.println(MarkInfo[i].stuMarkInfo.stuPosition.nx+MarkInfo[i].stuMarkInfo.stuPosition.ny);*/
	}
	
	int MemorySize=MarkInfo[0].size()*nMaxConut;
	Pointer pointer=new Memory(MemorySize);
	pointer.clear(MemorySize);	
	ToolKits.SetStructArrToPointerData(MarkInfo, pointer);
	
	//循环查询
	int nCurCount = 0;
	int nFindCount = 0;
	while(true) {
		int nRetCount = netSdk.CLIENT_FindNextFileEx(lFindHandle, nMaxConut, pointer, MemorySize, null, 3000);
		ToolKits.GetPointerDataToStructArr(pointer, MarkInfo);
		
		if (nRetCount <= 0) {
			System.err.println("FindNextFileEx failed!" + netSdk.CLIENT_GetLastError());
            break;
		} 
		for (int i = 0; i < nRetCount; i++) {
			nFindCount = i + nCurCount * nMaxConut;
			System.out.println("[" + nFindCount + "]通道号 :" + MarkInfo[i].nChannelID);
			System.out.println("[" + nFindCount + "]开始时间 :" + MarkInfo[i].stuStartTime.toStringTime());
			System.out.println("[" + nFindCount + "]结束时间 :" + MarkInfo[i].stuEndTime.toStringTime());
			System.out.println("[" + nFindCount + "]文件路径 :" + new String(MarkInfo[i].szFilePath).trim());
			DownloadRemoteFile(new String(MarkInfo[i].szFilePath).trim());
		}
		if(nRetCount < nMaxConut) {
			break;
		} else {
			nCurCount++;
		}
	}
	netSdk.CLIENT_FindCloseEx(lFindHandle);
}

public  void  DownloadRemoteFile(String filePath){
	NET_IN_DOWNLOAD_REMOTE_FILE pInParam=new NET_IN_DOWNLOAD_REMOTE_FILE();
	pInParam.pszFileName = new NativeString(filePath).getPointer();
	pInParam.pszFileDst = new NativeString("./face.jpg").getPointer();
	NET_OUT_DOWNLOAD_REMOTE_FILE pOutParam=new NET_OUT_DOWNLOAD_REMOTE_FILE();
	if(!netSdk.CLIENT_DownloadRemoteFile(loginHandle, pInParam, pOutParam, 3000)){
			System.err.printf("CLIENT_DownloadRemoteFile failed, ErrCode=%x\n", netSdk.CLIENT_GetLastError());
	}else{
		System.out.println("CLIENT_DownloadRemoteFile success");
	}
}

/**
 * 设备断线回调
 */
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;
    }

    public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
        System.out.printf("Device[%s] Port[%d] DisConnect!\n", pchDVRIP, nDVRPort);
    }
}

/**
 * 设备重连回调
 */
private static class HaveReConnectCallBack implements NetSDKLib.fHaveReConnect {
    private HaveReConnectCallBack() {
    }

    private static class CallBackHolder {
        private static HaveReConnectCallBack instance = new HaveReConnectCallBack();
    }

    public static 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);

    }
}

public void RunTest(){
	CaseMenu menu=new CaseMenu();
	menu.addItem((new CaseMenu.Item(this , "FindFileEx" , "FindFileEx")));
	menu.run();
}

public static void  main(String []args){
	FindMark XM=new FindMark();
    XM.InitTest();
    XM.RunTest();
    XM.LoginOut();
}
}