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.ToolKits;
import com.netsdk.lib.NetSDKLib.*;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

public class AutoRegisterEng {
	
	static NetSDKLib NetSdk        = NetSDKLib.NETSDK_INSTANCE;
    static NetSDKLib ConfigSdk     = NetSDKLib.CONFIG_INSTANCE;
	
	/**
	 * NetSDK Init
	 */
	private class SDKEnvironment { 
	    private boolean bInit = false;
	    private boolean bLogopen = false;
	    private DisConnect 		 disConnect    = new DisConnect();    // Device disconnect CallBack

	    public boolean init() {    	
			// SDK init
			bInit = NetSdk.CLIENT_Init(disConnect, null);
			if (!bInit) {
				System.err.println("Initialize SDK failed");
				return false;
			}
			
			// Open Log
			LOG_SET_PRINT_INFO setLog = new 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 !!!");
			}
			
			// Set log in network environment
			NET_PARAM netParam = new NET_PARAM();
			netParam.nConnectTime = 5000; // Connection timeout value(Unit is ms), 0:default 1500ms.
			NetSdk.CLIENT_SetNetworkParam(netParam);
	    	
	    	return true;
	    }
	    
	    // Cleanup
	    public void cleanup() {
	    	if (bLogopen) {
	    		NetSdk.CLIENT_LogClose();
	    	}
	    	
	    	if (bInit) {
	    		NetSdk.CLIENT_Cleanup();
	    	}
	    }
	    
	    // Network disconnection callback function original shape 
	    public class DisConnect implements 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; 	// Local Server Handle
	
	// Device List
	private static List<Device> deviceList = new ArrayList<Device>();
	
	private static Map<LLong, Device> deviceMap = new HashMap<LLong, AutoRegisterEng.Device>();
	
	private static Map<LLong, LLong> attachBusMap = new HashMap<LLong, LLong>();
	
	private static Map<LLong, LLong> busMap = new HashMap<LLong, LLong>();
	
	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; 	// Device Handle, identify unique devices
		public String address; 		// Device ip
		public int port; 			// Device port
		public String username; 	// username
		public String password; 	// password
		public String serialNumber; // SN
		
		public boolean loginSuccess; // Login Status

		@Override
		public String toString() {
			return "Device [address=" + address + ", serialNumber="
					+ serialNumber + "]";
		}
	} 
	
	// Listen Server CallBack, it is recommended to write a singleton pattern
	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);
			
			// convert pParam to SN
			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", "123456", 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);
	}
	
	/**
	 * 
	 * @param handle : login handle
	 * @param attachHandle : attach handle
	 */
	public synchronized static void addAttachBus(LLong handle, LLong attachHandle) {
		if(attachHandle != null) {
			attachBusMap.put(handle, attachHandle);
			busMap.put(attachHandle, handle);
		}
	}
	
	public synchronized static LLong getAttachBus(LLong handle) {
		return attachBusMap.get(handle);
	}
	
	public synchronized static LLong getLoginHandle(LLong attachHandle) {
		return busMap.get(attachHandle);
	}
	
	///////////////////////////////////////////////////////////////////////////
	private SDKEnvironment environment = new SDKEnvironment();
	public void init() {
		environment.init();
	}
	
	public void cleanup() {
		environment.cleanup();
	}

	/**
	 * Start Server
	 * @param address Local IP Address
	 * @param port Local port
	 * @return
	 */
	public boolean startServer(String address, int port) {
		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;
	}
	
	/**
	 * Stop Server
	 * @return
	 */
	public boolean stopServer() {
		boolean stopSuccess = NetSdk.CLIENT_StopListenServer(this.serverHandler);		
		
		finishBusiness();
		
		return stopSuccess;
	}
	
	/**
	 * AutoRegister Login
	 * @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;// AutoRegister type
		final IntByReference errorReference = new IntByReference(0);
		final NET_DEVICEINFO_Ex deviceinfo = new NET_DEVICEINFO_Ex();
		
		// convert SN to 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);
	}
	
	// Alarm CallBack，it is recommended to write a singleton pattern
	private static class MessCallBack implements fMessCallBack {
		private MessCallBack() {}

		private static class MessCallBackHolder {
			private static MessCallBack msgCallBack = new MessCallBack();
		}
		
		public static MessCallBack getInstance() {
			return MessCallBackHolder.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());
			} 
			
			if(pStuEvent == null || dwBufLen <= 0) {
				return false;
			}
			
			/// 具体事件类, 
			switch (lCommand) {
				case NetSDKLib.NET_ALARM_TEMPERATURE : //  temperature alarm    
				{
		  			ALARM_TEMPERATURE_INFO msg = new ALARM_TEMPERATURE_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("温度过高报警");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stTime.toStringTime());
		  			break;
				}	
				case NetSDKLib.NET_ALARM_VIDEO_LOSS : // alarm of video loss
				{
		  			ALARM_VIDEO_LOSS_INFO msg = new ALARM_VIDEO_LOSS_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("视频丢失事件");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			break;
				}
				case NetSDKLib.NET_ALARM_HIGH_SPEED : // alarm of high speed
				{
		  			ALARM_HIGH_SPEED_INFO msg = new ALARM_HIGH_SPEED_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("车辆超速报警事件");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			break;
				}	
				case NetSDKLib.NET_ALARM_BUS_SHARP_ACCELERATE : // Vehicle abrupt speed up event  
				{
		  			ALARM_BUS_SHARP_ACCELERATE_INFO msg = new ALARM_BUS_SHARP_ACCELERATE_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("车辆急加速事件");
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			break;
				}
				case NetSDKLib.NET_ALARM_BUS_SHARP_DECELERATE : // Vehicle abrupt slow down event 
				{
		  			ALARM_BUS_SHARP_DECELERATE_INFO msg = new ALARM_BUS_SHARP_DECELERATE_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("车辆急减速事件");
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			break;
				}
				case NetSDKLib.NET_ALARM_GPS_NOT_ALIGNED : // GPS not aligned alarm 
				{
		  			ALARM_GPS_NOT_ALIGNED_INFO msg = new ALARM_GPS_NOT_ALIGNED_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("GPS未定位报警");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			break;
				}
				case NetSDKLib.NET_ALARM_FRONTDISCONNECT : // front IPC disconnect alarm  
				{
		  			ALARM_FRONTDISCONNET_INFO msg = new ALARM_FRONTDISCONNET_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("前端IPC断网报警");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toStringTime());
		  			break;
				} 
				case NetSDKLib.NET_ALARM_STORAGE_FAILURE_EX : // storage mistake
				{
		  			ALARM_STORAGE_FAILURE_EX msg = new ALARM_STORAGE_FAILURE_EX();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("存储错误报警");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			break;
				}
				case NetSDKLib.NET_ALARM_STORAGE_NOT_EXIST : // A storage group does not exist
				{
		  			ALARM_STORAGE_NOT_EXIST_INFO msg = new ALARM_STORAGE_NOT_EXIST_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("存储组不存在事件");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toStringTime());
		  			break;
				}
				case NetSDKLib.NET_ALARM_VEHICLE_ACC : // Vehicle acc event    
				{
		  			ALARM_VEHICLE_ACC_INFO msg = new ALARM_VEHICLE_ACC_INFO();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("车辆ACC报警事件");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			break;
				}
				case NetSDKLib.NET_ALARM_ALARM_EX2: // local alarm event 
				{
		  			ALARM_ALARM_INFO_EX2 msg = new ALARM_ALARM_INFO_EX2();
		  			ToolKits.GetPointerData(pStuEvent, msg);
		  			
		  			System.out.println("本地报警事件");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toStringTime());

		  			break;
				}
				case NetSDKLib.NET_ALARM_VIDEOBLIND: // alarm of video blind
				{
					ALARM_VIDEO_BLIND_INFO msg = new ALARM_VIDEO_BLIND_INFO();
					ToolKits.GetPointerData(pStuEvent, msg);
					
					System.out.println("视频遮挡事件");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			
					break;
				}
				case NetSDKLib.NET_URGENCY_ALARM_EX2: // Emergency ALARM EX2
				{
					ALARM_URGENCY_ALARM_EX2 msg = new ALARM_URGENCY_ALARM_EX2();
					ToolKits.GetPointerData(pStuEvent, msg);
					
					System.out.println("紧急报警EX2");
		  			System.out.println("nID : " + msg.nID);
		  			System.out.println("Time : " + msg.stuTime.toStringTime());
		  			
					break;
				}
				case NetSDKLib.NET_ALARM_DRIVER_NOTCONFIRM: // alarm of driver not confirm
				{
					ALARM_DRIVER_NOTCONFIRM_INFO msg = new ALARM_DRIVER_NOTCONFIRM_INFO();
					ToolKits.GetPointerData(pStuEvent, msg);
					
					System.out.println("司机未按确认按钮报警事件");
		  			System.out.println("nAction : " + msg.nAction);
		  			System.out.println("Time : " + msg.stuTime.toString());
		  			
					break;
				}
				case NetSDKLib.NET_ALARM_ALARM_EX: // External alarm
				{
					System.out.println("外部报警");
					
					byte[] msg = pStuEvent.getByteArray(0, dwBufLen);
					
					for(int i = 0; i < msg.length; i++) {
						System.out.print("channel : " + i + " state : " + msg[i]);   // i : channel
					}															     // msg[i]  1:alarm  0:no alarm
					
					break;
				}
				case NetSDKLib.NET_DISKERROR_ALARM_EX:  // HDD malfunction alarm
				{
					System.out.println("坏硬盘报警");
					
					byte[] msg = pStuEvent.getByteArray(0, dwBufLen);
					
					for(int i = 0; i < msg.length; i++) {
						System.out.print("channel : " + i + " state : " + msg[i]);  // i : channel; 
					}                                                               // msg[i]  1:alarm  0:no alarm
					
					break;
				}
				default:
					break;
			}
			
			return true;
		}
	}
	
	/*
	 * GPS CallBack，it is recommended to write a singleton pattern
	 */
	private static class GPSMessageCallBack implements fGPSRevEx2 {
		private GPSMessageCallBack(){}
		
		private static class GPSMessageCallBackHolder {
			private static GPSMessageCallBack gpsMessage = new GPSMessageCallBack();
		}
		
		public static GPSMessageCallBack getInstance() {
			return GPSMessageCallBackHolder.gpsMessage;
		}
		
		@Override
		public void invoke(LLong lLoginID, NET_GPS_LOCATION_INFO lpData,
						Pointer dwUserData, Pointer reserved) {
			final Device device = getDevice(lLoginID);
			if (device != null) {
//				System.out.println("\t" + device.toString());
			} 
			
			System.out.println("longitude : " + lpData.stuGpsInfo.longitude);
			System.out.println("latidude : " + lpData.stuGpsInfo.latidude);


			double latidude = 0;
			double longitude = 0;
			if(lpData.stuGpsInfo.latidude > 90*1000000)
			{
				latidude = (lpData.stuGpsInfo.latidude - 90*1000000)/1000000;
			}
			else
			{
				latidude = (90*1000000 - lpData.stuGpsInfo.latidude)/1000000;
			}
			
			
			if(lpData.stuGpsInfo.longitude > 180*1000000 )
			{
				longitude = (lpData.stuGpsInfo.longitude - 180*1000000)/1000000;
			}
			else
			{
				longitude = (180*1000000 - lpData.stuGpsInfo.longitude)/1000000;
			}

			System.out.println("virtual longitude : " + longitude);
			System.out.println("virtual latidude : " + latidude);
		}	
	}
	
	/*
	 * order Bus status call function model, it is recommended to write a singleton pattern
	 */
	private static class BusStateCallBack implements fBusStateCallBack {
		private BusStateCallBack() {}
		private static class BusStateCallBackHolder {
			private static BusStateCallBack busstate = new BusStateCallBack();
		}
		
		public static BusStateCallBack getInstance() {
			return BusStateCallBackHolder.busstate;
		}
		
		@Override
		public void invoke(LLong lAttachHandle, int lCommand,
				Pointer pBuf, int dwBufLen, Pointer dwUser) {
			
			final Device device = getDevice(getLoginHandle(lAttachHandle));
			if (device != null) {
//				System.out.println("\t" + device.toString());
			} 
			
			switch(lCommand) {
				case NetSDKLib.NET_ALARM_BUS_PASSENGER_CARD_CHECK:  // Passenger card check event
				{
					ALARM_PASSENGER_CARD_CHECK msg = new ALARM_PASSENGER_CARD_CHECK();
					ToolKits.GetPointerData(pBuf, msg);
					
					System.out.println("乘客刷卡事件");	
					System.out.println("szCardNum : " + new String(msg.szCardNum).trim());
					System.out.println("UTC : " + msg.UTC.toString());	
					
					break;
				}
				default:
					break;
			}		
		}	
	}
	
	/**
	 * StartListen
	 */
	public static boolean startListenAlarm(LLong handle) {	
		/// Alarm CallBack
		NetSdk.CLIENT_SetDVRMessCallBack(MessCallBack.getInstance(), null);
		
		return NetSdk.CLIENT_StartListenEx(handle);
	}
	
	/**
	 * StopListen
	 */
	public static void stopListenAlarm(LLong handle) {
		NetSdk.CLIENT_StopListen(handle);
	}
	
	/**
	 * SubcribeGPS
	 */
	public static boolean subcribeGPS(LLong handle) {
		NetSdk.CLIENT_SetSubcribeGPSCallBackEX2(GPSMessageCallBack.getInstance(), null);
		    
		int bStart = 1;    // 0：Cancel; 1:SubcribeGPS  
		int KeepTime = -1; // subscribe time last (unit second) value:-1  means indefinite duration last  
		int InterTime = 5; // unit: s
		return NetSdk.CLIENT_SubcribeGPS(handle, bStart, KeepTime, InterTime);
	}
	
	/*
	 * Stop subcribeGPS
	 */
	public static boolean stopSubcribeGPS(LLong handle) {
		int bStart = 0;    // 0：Cancel; 1:SubcribeGPS   
		int KeepTime = -1; // subscribe time last (unit second) value:-1  means indefinite duration last 
		return NetSdk.CLIENT_SubcribeGPS(handle, bStart, KeepTime, 3000);
	}
	
	/*
	 * Attach bus state
	 */
	public static LLong attachBusState(LLong handle) {
		NET_IN_BUS_ATTACH inBusAttach = new NET_IN_BUS_ATTACH();
		inBusAttach.cbBusState = BusStateCallBack.getInstance();
		inBusAttach.dwUser = null;
		
		NET_OUT_BUS_ATTACH outBusAtach = new NET_OUT_BUS_ATTACH();
		LLong attachHandle =  NetSdk.CLIENT_AttachBusState(handle, inBusAttach, outBusAtach, 5000);
		
		return attachHandle;
	}
	
	/*
	 * Stop attach bus state
	 */
	public static boolean DetachBusState(LLong handle) {
		return NetSdk.CLIENT_DetachBusState(getAttachBus(handle));
	}
	
	
	/**
	 * Get Error Code
	 * @return
	 */
	public static String getErrorCode() {
		return " { error code: ( 0x80000000|" + (NetSdk.CLIENT_GetLastError() & 0x7fffffff) +" ). 参考  java }";
	}
	
	/**
	 * Finish Business
	 * @param device
	 */
	public void finishBusiness() {
		
		System.out.println("[finishBusiness]");
		
		for (Device device : deviceList) {
			if (device.loginSuccess) {
				stopListenAlarm(device.handle);
				stopSubcribeGPS(device.handle);
				DetachBusState(device.handle);
				logout(device.handle);
			}
		}
	}
	
	/**
	 * Business Interface
	 */
	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.");
			/// Login Device
			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;
			
			/// add Device to List
			addDevice(device);
						
			/// StartListen
			startListenAlarm(device.handle);			
			
			// SubcribeGPS
			subcribeGPS(device.handle);
			
			// Attach bus state 
			addAttachBus(device.handle, attachBusState(device.handle));
			
			System.out.println("End of doing business.");
		}
	} 

	public static void main(String[] args) throws UnknownHostException {
		
		InetAddress address = InetAddress.getLocalHost();
		
		System.out.println(address.getHostAddress());
		
		System.out.println("Begin of testing.");
		
		AutoRegister demo = new AutoRegister();
		
		demo.init();
		demo.startServer(address.getHostAddress(), 1001);
		
		int count = 0;
		while(true) {
			try {
				Thread.sleep(1000);
				if (1000 == count++) {
					break;
				}
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		
		demo.stopServer();
		demo.cleanup();
		System.out.println("End of testing.");
	}

}