package com.netsdk.demo.example;

import java.io.File;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.List;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.Enum.EM_SEND_SEARCH_TYPE;
import com.netsdk.lib.structure.NET_IN_STARTSERACH_DEVICE;
import com.netsdk.lib.structure.NET_OUT_STARTSERACH_DEVICE;
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 multiNICsearch {
	public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
	// 登陆句柄
    private  LLong loginHandle = 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(new HaveReConnectCallBack(), 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.23.8.94";
private int    m_nPort 				    = 37777;
private String m_strUser 			    = "admin";
private String m_strPassword 		    = "admin123";
////////////////////////////////////////////////////////////////
	
public void multNICsearch() throws SocketException {
	//入参结构体
	for(int i =0 ;i<getHostAddress().size() ;i++) {
	NET_IN_STARTSERACH_DEVICE pInparm = new NET_IN_STARTSERACH_DEVICE();
	System.arraycopy(getHostAddress().get(i).getBytes(), 0, pInparm.szLocalIp, 0, getHostAddress().get(i).getBytes().length);
	pInparm.cbSearchDevices=SearchDevicesCBEx.getInstance();
	pInparm.emSendType=EM_SEND_SEARCH_TYPE.EM_SEND_SEARCH_TYPE_MULTICAST_AND_BROADCAST.ordinal();
	Pointer pInbuf =new Memory(pInparm.size());
	ToolKits.SetStructDataToPointer(pInparm, pInbuf, 0);
	//出参结构体
	NET_OUT_STARTSERACH_DEVICE pOutparn = new NET_OUT_STARTSERACH_DEVICE();
	Pointer pOutbuf =new Memory(pOutparn.size());
	ToolKits.SetStructDataToPointer(pOutparn, pOutbuf, 0);
	
	LLong lSearchHandle = netSdk.CLIENT_StartSearchDevicesEx(pInbuf, pOutbuf);
	if(lSearchHandle.longValue()!=0) {
		System.out.println("multNICsearch success");
	}else {
		System.err.printf("multNICsearch [%s] Fail.Error[%s]\n", m_strIp, ToolKits.getErrorCode());
	}
	}
}

public List<String> getHostAddress() throws SocketException {
	 /**
     * 多网卡
     */
    List<String> ipList = new ArrayList<>();
    Enumeration<NetworkInterface> networkInterfaces = NetworkInterface.getNetworkInterfaces();
    while (networkInterfaces.hasMoreElements()) {
        NetworkInterface networkInterface = networkInterfaces.nextElement();
        Enumeration<InetAddress> inetAddresses = networkInterface.getInetAddresses();
        while (inetAddresses.hasMoreElements()) {
            InetAddress inetAddress = inetAddresses.nextElement();
            if (inetAddress.isLoopbackAddress()) {//回路地址，如127.0.0.1
//                System.out.println("loop addr:" + inetAddress);
            } else if (inetAddress.isLinkLocalAddress()) {//169.254.x.x
//                System.out.println("link addr:" + inetAddress);
            } else {
                //非链接和回路真实ip
                String localname = inetAddress.getHostName();
                String localip = inetAddress.getHostAddress();
                ipList.add(localip);
					/*
					 * System.err.println("localname:" + localname); System.err.println("localip:" +
					 * localip);
					 */
            }
        }
    }

    //System.err.println("list:" + ipList.toString());
	return ipList;

}

/**
 * 异步搜索设备回调
 */
private static class SearchDevicesCBEx implements NetSDKLib.fSearchDevicesCBEx {

	 private SearchDevicesCBEx() {
	    }

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

	    public static SearchDevicesCBEx getInstance() {
	        return CallBackHolder.instance;
	    }
	
	@Override
	public void invoke(LLong lSearchHandle, Pointer pDevNetInfo, Pointer pUserData) {
		// TODO Auto-generated method stub
			/*
			 * DEVICE_NET_INFO_EX2 DeviceInfo =new DEVICE_NET_INFO_EX2();
			 * ToolKits.GetPointerData(pDevNetInfo, DeviceInfo); System.out.println(new
			 * String(DeviceInfo.szLocalIP) + new String(DeviceInfo.stuDevInfo.szIP) +
			 * (DeviceInfo.stuDevInfo.byInitStatus & 3));
			 */
	}

    
}


	/**
	 * 设备断线回调
	 */
	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,"获取本地网卡信息","multNICsearch"));
		menu.run();
	}
	
	 public static void main(String []args){
		 multiNICsearch XM=new multiNICsearch();
		
		  XM.InitTest(); XM.RunTest(); XM.LoginOut();
		 
	    }
}