package com.netsdk.demo.customize;

import java.io.File;
import java.io.UnsupportedEncodingException;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.*;
import com.netsdk.lib.ToolKits;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

public class MatrixCameras {
	static NetSDKLib netsdkApi 	= NetSDKLib.NETSDK_INSTANCE;
	static NetSDKLib configApi 	= NetSDKLib.CONFIG_INSTANCE;
	
	private NetSDKLib.NET_DEVICEINFO_Ex deviceinfo = new NetSDKLib.NET_DEVICEINFO_Ex();
	private 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]Failed! %s\n" , m_strIp , m_nPort , ToolKits.getErrorCode());
    		EndTest();
    	}
	}
	
	/**
	 * 获取所有有效显示源
	 * @throws UnsupportedEncodingException 
	 */
	public void MatrixGetCameras () throws UnsupportedEncodingException {					
		// 显示源信息数组初始化
		int nCameraCount = 60;
		int nMaxVideoInputCount = 10; //视频输入通道最大数
		NET_MATRIX_CAMERA_INFO[]  cameras = new NET_MATRIX_CAMERA_INFO[nCameraCount];
		// 视频输入通道信息数组初始化
		NetSDKLib.NET_VIDEO_INPUTS[] inputs= new NetSDKLib.NET_VIDEO_INPUTS[nMaxVideoInputCount];
		for (int j = 0; j < nMaxVideoInputCount; j++) {
			inputs[j] = new NetSDKLib.NET_VIDEO_INPUTS();
		}
		for(int i = 0; i < nCameraCount; i++) {
			NetSDKLib.NET_MATRIX_CAMERA_INFO camera = new NetSDKLib.NET_MATRIX_CAMERA_INFO();
			NetSDKLib.NET_REMOTE_DEVICE device = new NetSDKLib.NET_REMOTE_DEVICE();
			device.nMaxVideoInputCount = nMaxVideoInputCount;// 视频输入通道最大数							
			device.pstuVideoInputs = new Memory(inputs[0].size() * nMaxVideoInputCount);	
			device.pstuVideoInputs.clear(inputs[0].size() * nMaxVideoInputCount);
			// 将数组内存拷贝到Pointer
			ToolKits.SetStructArrToPointerData(inputs, device.pstuVideoInputs);
			camera.stuRemoteDevice = device;										
			cameras[i] = camera;
		}	
		
		/*
		 *  入参
		 */
		NetSDKLib.NET_IN_MATRIX_GET_CAMERAS stuIn = new NetSDKLib.NET_IN_MATRIX_GET_CAMERAS();
		
		/*
		 *  出参
		 */
		NET_OUT_MATRIX_GET_CAMERAS stuOut = new NET_OUT_MATRIX_GET_CAMERAS();
		stuOut.nMaxCameraCount = nCameraCount;
		stuOut.pstuCameras = new Memory(cameras[0].size() * nCameraCount);
		stuOut.pstuCameras.clear(cameras[0].size() * nCameraCount);
		
		ToolKits.SetStructArrToPointerData(cameras, stuOut.pstuCameras);  // 将数组内存拷贝到Pointer
		
		if(netsdkApi.CLIENT_MatrixGetCameras(loginHandle, stuIn, stuOut, 5000)) {
			ToolKits.GetPointerDataToStructArr(stuOut.pstuCameras, cameras);  // 将 Pointer 的内容 输出到   数组
			
			for(int j = 0; j < stuOut.nRetCameraCount; j++) {
				if(cameras[j].bRemoteDevice == 0) {   
					System.out.println("NVR通道号：" + cameras[j].nUniqueChannel);
					System.out.println("前端通道号(远程设备)：" + cameras[j].nChannelID);
					System.out.println("设备ID : " + new String(cameras[j].szDevID).trim());
					//System.out.println("IP : " + new String(cameras[j].stuRemoteDevice.szIp).trim());
					//System.out.println("nPort : " + cameras[j].stuRemoteDevice.nPort);
					//System.out.println("szUser : " + new String(cameras[j].stuRemoteDevice.szUser).trim());
					//System.out.println("szPwd : " + new String(cameras[j].stuRemoteDevice.szPwd).trim());
					System.out.println("通道个数 : " + cameras[j].stuRemoteDevice.nVideoInputChannels + "\n");					
				} else {
					System.out.println("NVR通道号：" + cameras[j].nUniqueChannel);
					System.out.println("前端通道号(远程设备)：" + cameras[j].nChannelID);
					System.out.println("设备ID : " + new String(cameras[j].szDevID).trim());
					System.out.println("设备类型 : " + new String(cameras[j].stuRemoteDevice.szDevClass).trim());
					System.out.println("设备序列号 : " + new String(cameras[j].stuRemoteDevice.szSerialNo).trim());
					System.out.println("实际返回通道个数 : " + cameras[j].stuRemoteDevice.nRetVideoInputCount);					
					ToolKits.GetPointerDataToStructArr(cameras[j].stuRemoteDevice.pstuVideoInputs, inputs);  // 将 Pointer 的内容 输出到   数组	
					for (int i = 0; i < cameras[j].stuRemoteDevice.nRetVideoInputCount; i++) {
						System.out.println("使能："+inputs[i].bEnable);
						System.out.println("通道名称："+new String(inputs[i].szChnName,"GBK"));
						System.out.println("控制ID："+new String(inputs[i].szControlID));
						System.out.println("主码流url地址："+new String(inputs[i].szMainStreamUrl)+"\n");
					}					
				}
			}
		} else {
			System.err.println("获取所有有效显示源失败！" + ToolKits.getErrorCode());
		}
	}
	
	/**
	 * 设置显示源
	 */
	public void MatrixSetCameras() {
		// 设置的显示源个数
		int nCameraCount = 1;  
		
		// 显示源信息数组初始化
		NET_MATRIX_CAMERA_INFO[] cameras = new NET_MATRIX_CAMERA_INFO[nCameraCount];
		for(int i = 0; i < nCameraCount; i++) {
			cameras[i] = new NET_MATRIX_CAMERA_INFO();
		}
		
		cameras[0].nUniqueChannel = 0;
		cameras[0].nChannelID = 0; // 通道号
		
		/*
		 * 入参
		 */
		NET_IN_MATRIX_SET_CAMERAS stuIn = new NET_IN_MATRIX_SET_CAMERAS();
		stuIn.nCameraCount = nCameraCount;
		stuIn.pstuCameras = new Memory(cameras[0].size() * nCameraCount);
		stuIn.pstuCameras.clear(cameras[0].size() * nCameraCount);
		
		ToolKits.SetStructArrToPointerData(cameras, stuIn.pstuCameras);  // 将数组内存拷贝到Pointer
		
		/*
		 * 出参
		 */
		NET_OUT_MATRIX_SET_CAMERAS stuOut = new NET_OUT_MATRIX_SET_CAMERAS();
		
		if(netsdkApi.CLIENT_MatrixSetCameras(loginHandle, stuIn, stuOut, 5000)) {
			System.out.println("设置显示源成功！");
		} else {
			System.err.println("设置显示源失败！" + ToolKits.getErrorCode());
		}
	}
	
	
	public void GetRemoteDevice() {
		int nChnCount = deviceinfo.byChanNum;
		NetSDKLib.AV_CFG_RemoteDevice deviceInfo[] = new NetSDKLib.AV_CFG_RemoteDevice[nChnCount];
		for (int i = 0; i < nChnCount; ++ i) {
			deviceInfo[i] = new NetSDKLib.AV_CFG_RemoteDevice();
		}
		
		/// 获取服务器所有远程设备的信息
		int realCount = ToolKits.GetDevConfig(loginHandle, -1, NetSDKLib.CFG_CMD_REMOTEDEVICE, deviceInfo);
		System.out.println("个数：" + realCount);
		if(realCount < 1) {
			return;
		}

		for(int i = 0; i < realCount; ++ i)
		{
			try {
				String remoteInfoString = "用户名： " + new String(deviceInfo[i].szUser).trim() + "\n"
						+ "密码： " + new String(deviceInfo[i].szPassword).trim() + "\n"
						+ "设备IP：" + new String(deviceInfo[i].szIP).trim() + "\n"
						+ "设备Port：" + deviceInfo[i].nPort + "\n"
						+ "设备名称：" + new String(deviceInfo[i].szName, "GBK").trim() + "\n"
						+ "部署地点： " + new String(deviceInfo[i].szAddress, "GBK").trim() + "\n"
						+ "设备类型:" + new String(deviceInfo[i].szDevClass).trim() + "\n"
						+ "设备型号:" + new String(deviceInfo[i].szDevType).trim();	
				
				System.out.println(remoteInfoString);
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
		}	
	}
	
	
	////////////////////////////////////////////////////////////////
	// 登陆信息
	String m_strIp 			= "172.32.103.250"; 
	int    m_nPort 			= 37777;
	String m_strUser 		= "admin";
	String m_strPassword 	= "admin123";
	////////////////////////////////////////////////////////////////
	
	public void RunTest()
	{
		System.out.println("Run Test");		
		CaseMenu menu = new CaseMenu();
		
		menu.addItem(new CaseMenu.Item(this , "获取远程设备信息" , "GetRemoteDevice"));
		
		menu.addItem(new CaseMenu.Item(this , "获取所有有效显示源" , "MatrixGetCameras"));
		menu.addItem(new CaseMenu.Item(this , "设置显示源" , "MatrixSetCameras"));
		
		menu.run(); 
	}	

	public static void main(String[]args)
	{		
		MatrixCameras demo = new MatrixCameras();
		demo.InitTest();
		demo.RunTest();
		demo.EndTest();
	}
}