package com.netsdk.demo.example;

import java.io.File;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.LLong;
import com.netsdk.lib.NetSDKLib.fMessCallBack;
import com.netsdk.lib.NetSDKLib.fServiceCallBack;
import com.netsdk.lib.ToolKits;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

public class AutoRegister {
	
	static NetSDKLib NetSdk        = NetSDKLib.NETSDK_INSTANCE;
    static NetSDKLib ConfigSdk     = NetSDKLib.CONFIG_INSTANCE;
	
	/**
	 * NetSDK 库初始化
	 */
	private class SDKEnvironment { 
	    private boolean bInit = false;
	    private boolean bLogopen = false;
	    private DisConnect 		 disConnect    = new DisConnect();    // 设备断线通知回调
	    // 初始化
	    public boolean init() {    	
			// SDK 库初始化, 并设置断线回调
			bInit = NetSdk.CLIENT_Init(disConnect, null);
			if (!bInit) {
				System.err.println("Initialize SDK failed");
				return false;
			}
			
			// 打开日志，可选
			NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.LOG_SET_PRINT_INFO();
			
			File path = new File(".");			
			String logPath = path.getAbsoluteFile().getParent() + "\\sdk_log\\sdk.log";
			
			setLog.bSetFilePath = 1;
			System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);
			
			setLog.bSetPrintStrategy = 1;
			setLog.nPrintStrategy = 0;
			bLogopen = NetSdk.CLIENT_LogOpen(setLog);
			if (!bLogopen) {
				System.err.println("Failed to open NetSDK log !!!");
			}
			
			// 设置更多网络参数，NET_PARAM的nWaittime，nConnectTryNum成员与CLIENT_SetConnectTime 
			// 接口设置的登录设备超时时间和尝试次数意义相同
			// 此操作为可选操作
			NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
			netParam.nConnectTime = 5000; // 登录时尝试建立链接的超时时间
			NetSdk.CLIENT_SetNetworkParam(netParam);
	    	
	    	return true;
	    }
	    
	    // 清除环境
	    public void cleanup() {
	    	if (bLogopen) {
	    		NetSdk.CLIENT_LogClose();
	    	}
	    	
	    	if (bInit) {
	    		NetSdk.CLIENT_Cleanup();
	    	}
	    }
	    
	    // 设备断线回调: 通过 CLIENT_Init 设置该回调函数，当设备出现断线时，SDK会调用该函数
	    public class DisConnect 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);
	        }
	    }
	}
	
	private LLong serverHandler; 	// 本地服务器句柄
	
	// 设备列表
	private static List<Device> deviceList = new ArrayList<Device>();
	
	private static Map<LLong, Device> deviceMap = new HashMap<LLong, AutoRegister.Device>();
	
	private static class Device {
		public Device(String address, int port, String username,
				String password, String serialNumber) {
			super();
			this.address = address;
			this.port = port;
			this.username = username;
			this.password = password;
			this.serialNumber = serialNumber;
			
			this.handle = null;
			loginSuccess = false;
		}

		public LLong handle; 	// 设备句柄, 标识唯一的设备
		public String address; 		// 设备地址
		public int port; 			// 设备端口
		public String username; 	// 用户名
		public String password; 	// 密码
		public String serialNumber; // 序列号
		
		public boolean loginSuccess; // 登录状态

		@Override
		public String toString() {
			return "Device [address=" + address + ", serialNumber="
					+ serialNumber + "]";
		}
	} 
	
	// 侦听服务器回调函数, 建议写成单例模式
	public static class ServiceCB implements fServiceCallBack {
		private ServiceCB() {
		}
		private static ServiceCB serviceCB = new ServiceCB();
		
		public static ServiceCB getInstance() {
			return serviceCB;
		} 
		
		@Override
		public int invoke(LLong lHandle, final String pIp, final int wPort,
				int lCommand, Pointer pParam, int dwParamLen,
				Pointer dwUserData) {
			System.out.println("注册设备信息  Device address " + pIp + ", port " + wPort);
			
			// 将 pParam 转化为序列号
			byte[] buf = new byte[dwParamLen];
			pParam.read(0, buf, 0, dwParamLen);
			final String sn = new String(buf).trim();
			
			final Device device = new Device(pIp, wPort, "admin", "aaaaa111", sn);
			
			new Thread(new Business(device)).start();
			
			return 0;
		}
	}
	
	///////////////////////////////////////////////////////////////////////////
	public synchronized static void addDevice(final Device device) {
		if (device != null) {
			deviceList.add(device);
			deviceMap.put(device.handle, device);
		}
	}
	
	public synchronized static Device getDevice(LLong handle) {
		return deviceMap.get(handle);
	}
	
	///////////////////////////////////////////////////////////////////////////
	private SDKEnvironment environment = new SDKEnvironment();
	public void init() {
		environment.init();
	}
	
	public void cleanup() {
		environment.cleanup();
	}

	/**
	 * 开启服务
	 * @param address 本地IP地址
	 * @param port 本地端口, 可以任意
	 * @return
	 */
	public boolean startServer(String address, int port) {
		
		init();
		
		this.serverHandler = NetSdk.CLIENT_ListenServer(address, port, 1000, ServiceCB.getInstance(), null);
		if (0 == serverHandler.longValue()) {
			System.err.println("Failed to start server. " + getErrorCode());
		}
		return serverHandler.longValue() != 0;
	}
	
	/**
	 * 结束服务
	 * @return
	 */
	public boolean stopServer() {
	
		boolean stopSuccess = NetSdk.CLIENT_StopListenServer(this.serverHandler);		
		
		finishBusiness();
		
		cleanup();
		
		return stopSuccess;
	}
	
	/**
	 * 主动注册方式登录
	 * @param address
	 * @param port
	 * @param userName
	 * @param password
	 * @param sn 序列号, 必填
	 * @return
	 */
	public static LLong login(String address, int port, String userName, String password, String sn) {
		System.out.println("Function: login " + address + " sn " + sn + "]");
		final int tcpSpecCap = 2;// 主动注册方式
		final IntByReference errorReference = new IntByReference(0);
		final NetSDKLib.NET_DEVICEINFO_Ex deviceinfo = new NetSDKLib.NET_DEVICEINFO_Ex();
		
		// 将 序列号 转化为 pointer 类型
		com.netsdk.lib.NativeString serial = new com.netsdk.lib.NativeString(sn);
		LLong handle = NetSdk.CLIENT_LoginEx2(address, port, userName, password, tcpSpecCap, serial.getPointer(), deviceinfo, errorReference);
		if (0 == handle.longValue()) {
			System.err.println("Failed to Login " + address + getErrorCode());
			return null;
		}
		System.out.println("Success to Login " + address);
		return handle;
	}
	
	public static void logout(LLong handle) {
		System.out.println("[Function: Logout device.");
		NetSdk.CLIENT_Logout(handle);
	}
	
	/**
	 * 开门
	 * @param handle
	 * @return
	 */
	public static boolean openDoor(LLong handle) {
		System.out.println("[Function: openDoor.]");
		
		NetSDKLib.NET_CTRL_ACCESS_OPEN open = new NetSDKLib.NET_CTRL_ACCESS_OPEN();
		open.nChannelID = 0;
		
		open.write();
		boolean openSuccess = NetSdk.CLIENT_ControlDeviceEx(handle, NetSDKLib.CtrlType.CTRLTYPE_CTRL_ACCESS_OPEN, open.getPointer(), null, 3000);
		if (!openSuccess) {
			System.err.println("Failed to open door." + getErrorCode());
		}
		open.read();
		
		return openSuccess;
	}
	
	// 回调建议写成单例模式
	private static class MessCallBack implements fMessCallBack {
		private MessCallBack() {}
		static MessCallBack msgCallBack = new MessCallBack();
		
		public static MessCallBack getInstance() {
			return msgCallBack;
		}

		public boolean invoke(int lCommand, final LLong lLoginID,
				Pointer pStuEvent, int dwBufLen, String strDeviceIP,
				NativeLong nDevicePort, Pointer dwUser) {
			
			System.out.println(">> Event invoke. alarm command 0x" + Integer.toHexString(lCommand));
			
			final Device device = getDevice(lLoginID);
			if (device != null) {
				System.out.println("\t" + device.toString());
			} 
			
			/// 具体事件类, 
			switch (lCommand) {
				case NetSDKLib.NET_ALARM_ACCESS_CTL_EVENT: {
					NetSDKLib.ALARM_ACCESS_CTL_EVENT_INFO info = new NetSDKLib.ALARM_ACCESS_CTL_EVENT_INFO();
					ToolKits.GetPointerData(pStuEvent, info);
					System.out.println(info.toString());
					
					if (info.nErrorCode == 0x10) {
						// 密码开门
						if (info.emOpenMethod == NetSDKLib.NET_ACCESS_DOOROPEN_METHOD.NET_ACCESS_DOOROPEN_METHOD_PWD_ONLY) {
							System.out.println("密码开门失败");
						}
						else if (info.emOpenMethod == NetSDKLib.NET_ACCESS_DOOROPEN_METHOD.NET_ACCESS_DOOROPEN_METHOD_CARD) { 
						// 刷卡开门  - (1202B-D 的 二维码方式)
							System.out.println("刷卡方式失败");
						}
					}
					

					/// 触发开门
					new Thread(new Runnable() {
						@Override
						public void run() {
							openDoor(lLoginID);
						}
					}).start();
					
					break;
				}
				case NetSDKLib.NET_ALARM_ALARMCLEAR: {
					break;
				}
				case NetSDKLib.NET_ALARM_ALARM_EX: {
					break;
				}
				case NetSDKLib.NET_ALARM_TALKING_INVITE : //  设备请求对方发起对讲事件
		  			NetSDKLib.ALARM_TALKING_INVITE_INFO stu_Invite_Info = new NetSDKLib.ALARM_TALKING_INVITE_INFO();
		  			ToolKits.GetPointerData(pStuEvent, stu_Invite_Info);
		  			
		  			System.out.println("\temCaller :" + stu_Invite_Info.emCaller);
		  			System.out.println("\tstuTime :" + stu_Invite_Info.stuTime);
		  			System.out.println("\tszCallID :" + new String(stu_Invite_Info.szCallID).trim());
		  			System.out.println("\tnLevel :" + stu_Invite_Info.nLevel);
		  			
		  			break;
				case NetSDKLib.NET_ALARM_ALARM_EX2: // 本地报警事件
		  			NetSDKLib.ALARM_ALARM_INFO_EX2 stuALARM_ALARM_INFO_EX2 = new NetSDKLib.ALARM_ALARM_INFO_EX2();
		  			ToolKits.GetPointerData(pStuEvent, stuALARM_ALARM_INFO_EX2);
		  			
		  			System.out.println("\tChannel is " + stuALARM_ALARM_INFO_EX2.nChannelID);
		  			System.out.println("\tAction is " + stuALARM_ALARM_INFO_EX2.nAction);
		  			System.out.println("\tHappend time is " + stuALARM_ALARM_INFO_EX2.stuTime.toStringTime());
		  			System.out.println("\tSense type is " + stuALARM_ALARM_INFO_EX2.emSenseType + "\r\n");
		  			System.out.println("\tDefence area type is " + stuALARM_ALARM_INFO_EX2.emDefenceAreaType);
		  			
		  			if(stuALARM_ALARM_INFO_EX2.emSenseType == 1) 
		  			{
		  				System.out.println("\t被动红外对射入侵报警");
		  			} else if(stuALARM_ALARM_INFO_EX2.emSenseType == 5) 
		  			{
		  				System.out.println("\t主动红外对射入侵报警");
		  			}

		  			break;
				default:
					break;
			}
			
			return true;
		}
	}
	
	/**
	 * 监听事件
	 */
	public static boolean startListenAlarm(LLong handle) {
		
		/// 设置报警事件回调
		NetSdk.CLIENT_SetDVRMessCallBack(MessCallBack.getInstance(), null);
		
		return NetSdk.CLIENT_StartListenEx(handle);
	}
	
	/**
	 * 结束监听事件
	 */
	public static void stopListenAlarm(LLong handle) {
		NetSdk.CLIENT_StopListen(handle);
	}
	
	/**
	 * 获取接口错误码
	 * @return
	 */
	public static String getErrorCode() {
		return " { error code: ( 0x80000000|" + (NetSdk.CLIENT_GetLastError() & 0x7fffffff) +" ). 参考  NetSDKLib.java }";
	}
	
	/**
	 * 完成业务
	 */
	public void finishBusiness() {
		
		System.out.println("[finishBusiness]");
		
		for (Device device : deviceList) {
			if (device.loginSuccess) {
				stopListenAlarm(device.handle);
				
				logout(device.handle);
			}
		}
	}/**/
	
	/**
	 * 业务接口
	 */
	public static class Business implements Runnable {
		private Device device;
		
		public Business(Device device) {
			this.device = device;
		}
		
		public void run() {
			System.out.println("Begin of doing business.");
			/// 登录设备
			device.handle = login(device.address, device.port, device.username, device.password, device.serialNumber);
			if (device.handle == null || device.handle.longValue() == 0) {
				System.err.println("Failed to Login." + getErrorCode());
				return;
			}
			
			device.loginSuccess = true;
			
			/// 将设备信息添加到设备列表中
			addDevice(device);
						
			/// 监听事件
			startListenAlarm(device.handle);
						
			/// 下发卡, 请查考 JNADemoCommon.java
			// RecordSetAccess() 函数	
			
			System.out.println("End of doing business.");
		}
	} 

	public static void main(String[] args) throws UnknownHostException {
		
		InetAddress address = InetAddress.getLocalHost();
		Integer port = Integer.valueOf(1001);
		
		final AutoRegister demo = new AutoRegister();
		
		Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
			public void run() {
				demo.stopServer();		
				synchronized (demo) {
					demo.notify();
				}
				
				System.out.println("Stop Server Success");
			}
		}));	
				
		try {
			boolean retVal = demo.startServer(address.getHostAddress(), port);
			if (!retVal) {
				System.err.println("Failed to Start Service " + address.getHostAddress());
			}
			
			System.out.println("Start Server Success. [" + address.getHostAddress() + ":" + port + "]");
			
			synchronized (demo) {
				demo.wait();
			}
			
		} catch (Exception e) {
			e.printStackTrace();
			System.exit(-1);
		} 		
	}
}