package com.netsdk.demo.customize;

import java.io.File;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.NetSDKLib.*;
import com.sun.jna.Memory;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

/**
 * 多设备登陆demo
 */
public class JNAInterface {
	static NetSDKLib NetSdk        = NetSDKLib.NETSDK_INSTANCE;
    static NetSDKLib ConfigSdk     = NetSDKLib.CONFIG_INSTANCE;
    
    private static DisConnect disConnect = new DisConnect();  // 设备断线通知回调
    private static HaveReConnect haveReConnect = new HaveReConnect(); // 网络连接恢复
    
    private static fAnalyzerDataCB m_AnalyzerDataCB = new fAnalyzerDataCB();
    
    // 设备断线回调: 通过 CLIENT_Init 设置该回调函数，当设备出现断线时，SDK会调用该函数
    public static 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);
        }
    }
	
	// 网络连接恢复，设备重连成功回调
	// 通过 CLIENT_SetAutoReconnect 设置该回调函数，当已断线的设备重连成功时，SDK会调用该函数
    public static class HaveReConnect implements NetSDKLib.fHaveReConnect {
        public void invoke(LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
        	System.out.printf("ReConnect Device[%s] Port[%d]\n", pchDVRIP, nDVRPort);
        }
    }
    
	///////////////// sdk 相关信息 /////////////////
	/**
	 * NetSDK 库初始化
	 */
	private class SDKEnvironment {  
	    private boolean bInit = false;
	    private boolean bLogopen = false;
  
	    // 初始化
	    public boolean init() {
	    	loginHandleList.clear();
	    	deviceMap.clear();
	    	stopRealLoadPictureMap.clear();
	    	realLoadPictureMap.clear();
	    	remotedeviceInfoMap.clear(); 	
	    	
			// 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\\Interface_" + System.currentTimeMillis() + ".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 !!!");
			}
			
			// 获取版本, 可选操作
			System.out.printf("NetSDK Version [%d]\n", NetSdk.CLIENT_GetSDKVersion());		
			
			// 设置断线重连回调接口，设置过断线重连成功回调函数后，当设备出现断线情况，SDK内部会自动进行重连操作
			// 此操作为可选操作，但建议用户进行设置
			NetSdk.CLIENT_SetAutoReconnect(haveReConnect, null);
			
			// 设置登录超时时间和尝试次数 , 此操作为可选操作	   
			int waitTime = 5000;   // 登录请求响应超时时间设置为 5s
			int tryTimes = 3;      // 登录时尝试建立链接3次
			NetSdk.CLIENT_SetConnectTime(waitTime, tryTimes);
			
			// 设置更多网络参数，NET_PARAM的nWaittime，nConnectTryNum成员与CLIENT_SetConnectTime 
			// 接口设置的登录设备超时时间和尝试次数意义相同
			// 此操作为可选操作
			NetSDKLib.NET_PARAM netParam = new NetSDKLib.NET_PARAM();
			netParam.nConnectTime = 10000; // 登录时尝试建立链接的超时时间
			NetSdk.CLIENT_SetNetworkParam(netParam);
	    	
	    	return true;
	    }
	    
	    // 清除环境
	    public void cleanup() {
	    	if (bLogopen) {
	    		NetSdk.CLIENT_LogClose();
	    	}
	    	
	    	if (bInit) {
	    		NetSdk.CLIENT_Cleanup();
	    	}
	    }
	}
	
	// 登录句柄列表
	private static List<LLong> loginHandleList = new ArrayList<LLong>();
	
	// 设备信息Map  key:登录句柄   value: 设备信息
	private static Map<LLong, Device> deviceMap = new HashMap<LLong, Device>();
	
	// 用于停止订阅， key:登录句柄   value:智能订阅句柄列表
	private static Map<LLong, List<LLong>> stopRealLoadPictureMap = new HashMap<LLong, List<LLong>>();
	
	// 用于智能订阅回调里获取登录句柄， key:智能订阅句柄   value:登录句柄  
	private static Map<LLong, LLong> realLoadPictureMap = new HashMap<LLong, LLong>();
	
	// key:登陆句柄   value:对应的< 视频分析通道, 设备信息 > 关联表
	private static Map<LLong, Map<Integer, String>> remotedeviceInfoMap = new HashMap<LLong, Map<Integer, String>>();
	
	// 设备信息
	private static class Device {
		public Device(String ip, int port, String username, String password) {
			super();
			this.ip = ip;
			this.port = port;
			this.username = username;
			this.password = password;
			this.deviceinfo = null;
			
			this.mLoginHandle = null;
		}

		public LLong mLoginHandle; 			// 设备句柄, 标识唯一的设备
		public String ip; 					 		// 设备地址
		public int port; 					 		// 设备端口
		public String username; 			 		// 用户名
		public String password; 			 		// 密码
		public NET_DEVICEINFO_Ex deviceinfo; 		// 设备信息

		@Override
		public String toString() {
			return "Device [address=" + ip + "]";
		}
	} 
	
	////////////////// 添加/获取设备信息 ///////////////////
	public synchronized static void addDevice(final Device device) {
		if (device != null) {
			loginHandleList.add(device.mLoginHandle);
			deviceMap.put(device.mLoginHandle, device);
		}
	}
	
	/////////////////// 初始化 ////////////////////////
	private SDKEnvironment environment = new SDKEnvironment();
	public void init() {
		environment.init();
		System.out.println("Init Succeed");
	}
	
	public void cleanup() {
		environment.cleanup();
	}

	////////////////// 获取接口错误码 ////////////////
	public static String getErrorCode() {
		return " { error code: ( 0x80000000|" + (NetSdk.CLIENT_GetLastError() & 0x7fffffff) +" ). 参考  NetSDKLib.java }";
	}
	
	///////////////// 事件执行 /////////////////////
	/**
	 * 登录按钮事件
	 */
	private static LLong login(Device device) {		
		System.out.println("设备地址：" + device.ip
							+  "\n端口号：" + device.port
							+  "\n用户名：" + device.username
							+  "\n密码：" + device.password);
		
		// 登录设备
		device.deviceinfo = new NetSDKLib.NET_DEVICEINFO_Ex();
		
		IntByReference nError = new IntByReference(0);
		LLong mLoginHandle = NetSdk.CLIENT_LoginEx2(device.ip, device.port, device.username , device.password, 0, null, device.deviceinfo, nError);
        if(mLoginHandle.longValue() == 0) {
            System.err.println("登录失败， " + getErrorCode());
        } else {
        	System.out.println("登陆成功  [ " + device.ip +" ]");  
        	System.out.println("设备通道数 :" + device.deviceinfo.byChanNum); 
        }
        
        return mLoginHandle;
	}
	
	/**
	 * 登出按钮事件
	 */
	private static void logout(LLong mLoginHandle) {
		if (mLoginHandle.longValue() != 0) {
    		if (NetSdk.CLIENT_Logout(mLoginHandle)) {
    			System.out.println("登出设备[" + deviceMap.get(mLoginHandle).ip + "]");
    			loginHandleList.remove(mLoginHandle);
    			deviceMap.remove(mLoginHandle);		
    		}    		
    	}
	}
		
	/**
	 * 开始订阅智能事件
	 */
	public static boolean realLoadPicture(LLong mLoginHandle) {
		// 智能订阅句柄列表，用于停止订阅
		List<LLong> realLoadPictureHandleList = new ArrayList<LLong>();
		
		if (mLoginHandle.longValue() == 0 ) {
			return false;
		}
		
		/**
		 * 说明：
		 * 	通道数可以在有登录是返回的信息 m_stDeviceInfo.byChanNum 获取
		 *  下列仅订阅了0通道的智能事件.
		 *  订阅IVS-IP7200全部通道需要轮训调用 CLIENT_RealLoadPictureEx
		 */
		int bNeedPicture = 1;   // 是否需要图片
		for(int i = 0; i < deviceMap.get(mLoginHandle).deviceinfo.byChanNum; i++) {
			int ChannelId = i;     // 通道号 , 有些设备 -1代表全通道		
			
			LLong m_hAttachHandle =  NetSdk.CLIENT_RealLoadPictureEx(mLoginHandle, ChannelId,  NetSDKLib.EVENT_IVS_ALL , bNeedPicture, m_AnalyzerDataCB , null , null);
	        if( m_hAttachHandle.longValue() != 0  ) {
	            
	        	realLoadPictureHandleList.add(m_hAttachHandle);
	        	realLoadPictureMap.put(m_hAttachHandle, mLoginHandle);
	        	
	            System.out.println("CLIENT_RealLoadPictureEx Success\n");
	        } else {  
	        	 System.err.println("CLIENT_RealLoadPictureEx Failed!" + getErrorCode());
	        	 return false;
	        }
		}

		stopRealLoadPictureMap.put(mLoginHandle, realLoadPictureHandleList);
		return true;
	}
	
	/**
	 * 结束订阅智能事件
	 */
	public static boolean stopRealLoadPicture(LLong mLoginHandle) {	
		for(LLong realLoadHandle : stopRealLoadPictureMap.get(mLoginHandle)) {
			if (0 != realLoadHandle.longValue()) {
	            NetSdk.CLIENT_StopLoadPic(realLoadHandle);
	            System.out.println("Stop detach IVS event");
	            
	            realLoadPictureMap.remove(realLoadHandle);
	                  
	            return true;
	        }
		}
		stopRealLoadPictureMap.remove(mLoginHandle);

		return false;
	}	

	/* 智能报警事件回调 */
    public static class fAnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
        private String m_imagePath;
        NetSDKLib.NET_MSG_OBJECT m_stuObject; 	// 物体信息
        NetSDKLib.NET_TIME_EX utc; // 事件时间
       
        String EventMsg; // 事件信息        
        
        String bigPicture; // 大图
        String smallPicture; // 小图
              
        public fAnalyzerDataCB() {
        	m_imagePath = "./PlateNumber/";
            File path = new File(m_imagePath);
            if (!path.exists()) {
                path.mkdir();
            }
        }
        
        // 回调
        public int invoke(LLong lAnalyzerHandle, int dwAlarmType,
                Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize,
                Pointer dwUser, int nSequence, Pointer reserved) 
        {
            if (lAnalyzerHandle.longValue() == 0) {
                return -1;
            }         
            
            // 获取事件信息        
            m_stuObject = new NetSDKLib.NET_MSG_OBJECT();
            utc = new NetSDKLib.NET_TIME_EX(); // 事件时间
            
            EventMsg = ""; // 事件信息
            
            // 解析事件
            GetStuObject(lAnalyzerHandle, dwAlarmType, pAlarmInfo, m_stuObject, pBuffer, dwBufSize);
            
            // 更新界面
            // messageTextArea.append(EventMsg);
                    
            return 0;
        }
        
        // 获取识别对象 车身对象 事件发生时间 车道号等信息
        private boolean GetStuObject(LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, NetSDKLib.NET_MSG_OBJECT stuObject, Pointer pBuffer, int dwBufSize)
        {
        	boolean bRet = true;
        	if(pAlarmInfo == null) {
        		return false;
        	}
        	
        	int channel = -1;
        	
        	switch(dwAlarmType)
            {
	            case NetSDKLib.EVENT_IVS_TRAFFICJUNCTION: ///< 路口事件
	            {
	            	NetSDKLib.DEV_EVENT_TRAFFICJUNCTION_INFO msg = new NetSDKLib.DEV_EVENT_TRAFFICJUNCTION_INFO();
	            	ToolKits.GetPointerData(pAlarmInfo, msg);
	            	m_stuObject = msg.stuObject;
	                utc = msg.UTC;
	                EventMsg = "[ "+ utc.toStringTime() + " ] " + "路口事件";
	                
	                
	                /**
	                 * 1、先根据订阅句柄获取服务器的登陆句柄
	                 * 2、根据登陆句柄，获取对应的服务器的IP
	                 * 3、根据登陆句柄获取对应服务器的前端信息，然后根据通道号，获取对应的前端信息
	                 */
	                
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
      
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                    
	                break;
	            }
	        	case NetSDKLib.EVENT_IVS_FACEDETECT: /// 目标检测事件
	        	{
	        		NetSDKLib.DEV_EVENT_FACEDETECT_INFO msg = new NetSDKLib.DEV_EVENT_FACEDETECT_INFO();
	        		ToolKits.GetPointerData(pAlarmInfo, msg);
                    m_stuObject = msg.stuObject;
                    utc = msg.UTC;
                    EventMsg = 	">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID +"; 目标检测事件";
                    
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
	        		break;
	        	}
                case NetSDKLib.EVENT_IVS_CROSSLINEDETECTION: // 警戒线事件
                {
                	NetSDKLib.DEV_EVENT_CROSSLINE_INFO msg = new NetSDKLib.DEV_EVENT_CROSSLINE_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                    m_stuObject = msg.stuObject;
                    utc = msg.UTC;
                    EventMsg = 	">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID +"; 警戒线事件";
                    if (msg.bDirection == 1) {//表示入侵方向, 0-由左至右, 1-由右至左
                    	EventMsg += "; 入侵方向: 由右至左";
                    }
                    else {
                    	EventMsg += "; 入侵方向: 由左至右";
                    }
                    
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                   
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                    channel = msg.nChannelID;
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                	break;
                }
                case NetSDKLib.EVENT_IVS_CROSSREGIONDETECTION: // 警戒区事件
                {
                	NetSDKLib.DEV_EVENT_CROSSREGION_INFO msg = new NetSDKLib.DEV_EVENT_CROSSREGION_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                    m_stuObject = msg.stuObject;
                    utc = msg.UTC;
                    EventMsg = ">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID + "; 警戒区事件; ";
                    
                    String[] Dir = {"进入", "离开" , "出现" , "消失"};
                    
                    if (msg.bDirection >= 0 && msg.bDirection < Dir.length) {// 0-进入, 1-离开,2-出现,3-消失
                    	EventMsg += Dir[msg.bDirection];
                    }
                    
                    EventMsg += "; nObjectNum = " + msg.nObjectNum;

                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                    channel = msg.nChannelID;
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
                case NetSDKLib.EVENT_IVS_WANDERDETECTION: // 徘徊事件
                {
                	NetSDKLib.DEV_EVENT_WANDER_INFO msg = new NetSDKLib.DEV_EVENT_WANDER_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                	m_stuObject = null;
                    utc = msg.UTC;
                    EventMsg = ">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID + "; 徘徊事件";

                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                    channel = msg.nChannelID;
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
                case NetSDKLib.EVENT_IVS_FIGHTDETECTION: // 斗殴事件
                {
                	NetSDKLib.DEV_EVENT_FIGHT_INFO msg = new NetSDKLib.DEV_EVENT_FIGHT_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                    m_stuObject = null;
                    utc = msg.UTC;
                    EventMsg = ">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID + "; 斗殴事件";

                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg);  
                    
                    channel = msg.nChannelID;
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
                case NetSDKLib.EVENT_IVS_AUDIO_ABNORMALDETECTION: //  声音异常检测
                {
                	NetSDKLib.DEV_EVENT_IVS_AUDIO_ABNORMALDETECTION_INFO msg = new NetSDKLib.DEV_EVENT_IVS_AUDIO_ABNORMALDETECTION_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                    m_stuObject = null;
                    utc = msg.UTC;
                    EventMsg = ">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID + "; 声音异常检测";
                    EventMsg += "; 声音强度 " + msg.nDecibel;

                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                    channel = msg.nChannelID;
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
                case NetSDKLib.EVENT_IVS_CLIMBDETECTION: // 攀高检测事件
                {
                	NetSDKLib.DEV_EVENT_IVS_CLIMB_INFO msg = new NetSDKLib.DEV_EVENT_IVS_CLIMB_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                    m_stuObject = msg.stuObject;
                    utc = msg.UTC;
                    EventMsg = ">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID + "; 攀高检测事件";
                    
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg);  
                    
                    channel = msg.nChannelID;
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
                case NetSDKLib.EVENT_IVS_LEAVEDETECTION: // 离岗检测事件
                {
                	NetSDKLib.DEV_EVENT_IVS_LEAVE_INFO msg = new NetSDKLib.DEV_EVENT_IVS_LEAVE_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                    m_stuObject = msg.stuObject;
                    utc = msg.UTC;
                    EventMsg = ">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID + "; 离岗检测事件";
                    
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                    channel = msg.nChannelID;
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
                case NetSDKLib.EVENT_IVS_TRAFFIC_FCC: // 加油站提枪、挂枪事件
                {
                    NetSDKLib.DEV_EVENT_TRAFFIC_FCC_INFO msg = new NetSDKLib.DEV_EVENT_TRAFFIC_FCC_INFO();
                    ToolKits.GetPointerData(pAlarmInfo, msg);
                    utc = msg.UTC;
                    EventMsg = ">> " + utc.toStringTime() + " 通道号 " + msg.nChannelID + "; 加油站提枪、挂枪事件";
                    EventMsg += "; 车牌号 " + new String(msg.szText).trim();
                    EventMsg += "; nLitre " + msg.nLitre + "; dwMoney " + msg.dwMoney;
                    
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
                case NetSDKLib.EVENT_IVS_TRAFFIC_OVERSPEED: ///< 交通违章-超速
                {
                	NetSDKLib.DEV_EVENT_TRAFFIC_OVERSPEED_INFO msg = new NetSDKLib.DEV_EVENT_TRAFFIC_OVERSPEED_INFO();
                	ToolKits.GetPointerData(pAlarmInfo, msg);
                	m_stuObject = msg.stuObject;
                    utc = msg.UTC;
                    EventMsg = "[ "+ utc.toStringTime() + " ] " + "超速事件";
                    
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
                    break;
                }
	            case NetSDKLib.EVENT_IVS_TRAFFIC_FLOWSTATE: ///< 交通流量统计事件
	            {
	            	NetSDKLib.DEV_EVENT_TRAFFIC_FLOW_STATE msg = new NetSDKLib.DEV_EVENT_TRAFFIC_FLOW_STATE();
	            	ToolKits.GetPointerData(pAlarmInfo, msg);

                    utc = msg.UTC;
  
                    EventMsg = "[ "+ utc.toStringTime() + " ] " + "交通流量统计事件" + "flowNum :" + msg.nStateNum;     
                    
                    LLong loginHandleLong = realLoadPictureMap.get(lAnalyzerHandle); // 获取登陆句柄
                    
                    System.out.printf("\n服务器IP[%s]", deviceMap.get(loginHandleLong).ip);
                    
                    if(!remotedeviceInfoMap.containsKey(loginHandleLong)) {
                    	break;
                    }
                    
                    Map<Integer, String> chnDevice = remotedeviceInfoMap.get(loginHandleLong);    // 根据登陆句柄获取  通道及前端信息的Map

                    System.out.println("对应的通道 " + msg.nChannelID + " 的信息\n" + chnDevice.get(new Integer(msg.nChannelID)));               // 获取通道对应的前端信息
                    System.out.println(EventMsg); 
                    
                   	// 保存图片
                	SavePlatePic(m_stuObject, pBuffer, dwBufSize);
                	
	                break;
	            }
                default:
                	bRet = false;
                    System.out.printf("Get Event 0x%x\n", dwAlarmType);
                    EventMsg = ">> " + "未处理事件 dwAlarmType = " + String.format("0x%x", dwAlarmType); 
                    break;
            }
        	
        	EventMsg += "\n";
        	
        	return bRet;
        }
        
        // 2014年后，陆续有设备版本，支持单独传车牌小图，小图附录在pBuffer后面。
        private void SavePlatePic(NetSDKLib.NET_MSG_OBJECT stuObject, Pointer pBuffer, int dwBufSize) {      	
        	
			// 保存大图
        	if (pBuffer != null && dwBufSize > 0) {
            	bigPicture = m_imagePath + "Big_" + UUID.randomUUID().toString() + ".jpg";
            	ToolKits.savePicture(pBuffer, 0, dwBufSize, bigPicture);             
        	}
        	
        	// 保存小图
        	if (stuObject == null) {
        		return;
        	}
        	if (stuObject.bPicEnble == 1) {
        		//根据pBuffer中数据偏移保存小图图片文件
        		int picLength = stuObject.stPicInfo.dwFileLenth;
        		if (picLength > 0) {
            		smallPicture = m_imagePath + "small_" + UUID.randomUUID().toString() + ".jpg";
            		ToolKits.savePicture(pBuffer, stuObject.stPicInfo.dwOffSet, picLength, smallPicture);
        		}
        	}	
        }
    
    }
    
	/**
	 * 获取 IVS 的远程设备信息
	 */
	public static Map<String, String> getRemoteDeivceInfo(LLong mLoginHandle) {
		// key：设备名    value：设备信息
		Map<String, String> devnameDevInfoMap = new HashMap<String, String>();
		
		int remoteDevCount = deviceMap.get(mLoginHandle).deviceinfo.byChanNum; // 通道数
		NetSDKLib.AV_CFG_RemoteDevice deviceInfo[] = new NetSDKLib.AV_CFG_RemoteDevice[remoteDevCount];
		for (int i = 0; i < remoteDevCount; ++ i) {
			deviceInfo[i] = new NetSDKLib.AV_CFG_RemoteDevice();
		}
		
		/// 获取服务器所有远程设备的信息
		int realCount = GetDevConfig(mLoginHandle, -1, NetSDKLib.CFG_CMD_REMOTEDEVICE, deviceInfo);
		System.out.println("个数：" + realCount);
		if(realCount < 1) {
			return null;
		}

		for(int i = 0; i < realCount; ++ i)
		{
			try {
				String devName = new String(deviceInfo[i].szName, "GBK").trim();

				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();			
				devnameDevInfoMap.put(devName, remoteInfoString);   // 一个服务器里，设备名称对应的设备信息
			} catch (UnsupportedEncodingException e) {
				e.printStackTrace();
			}
		}	
		
		return devnameDevInfoMap;
	}
	
	/**
	 * 获取前端的设备信息
	 */
	public static void getDeviceInfo(LLong mLoginHandle) {
		Map<String, String> devicNameDevInfoMap = getRemoteDeivceInfo(mLoginHandle);
		if(devicNameDevInfoMap == null) {
			return;
		}
		
		// IVS < 视频分析通道, 设备信息 > 关联表,  key:通道号  value:对应的前端信息
		Map<Integer, String> channelDevInfoMap = new HashMap<Integer, String>();
		
		/// 获取服务器视频分析通道的信息，该通道和事件上报通道对应
		int remoteDevCount = deviceMap.get(mLoginHandle).deviceinfo.byChanNum; // 通道数
		
		NetSDKLib.CFG_ANALYSESOURCE_INFO[] channelInfo = new NetSDKLib.CFG_ANALYSESOURCE_INFO[remoteDevCount];
		for(int i = 0; i < remoteDevCount; i++) {
			channelInfo[i] = new NetSDKLib.CFG_ANALYSESOURCE_INFO();
		}
		
		for(int channel = 0; channel < remoteDevCount; ++channel) {
			if (GetDevConfig(mLoginHandle, channel, NetSDKLib.CFG_CMD_ANALYSESOURCE, channelInfo[channel])) {
				String devName = "";
				try {
					devName = new String(channelInfo[channel].szRemoteDevice, "GBK").trim();
				} catch (UnsupportedEncodingException e) {
					e.printStackTrace();
				}
				if (channelInfo[channel].bEnable == 1) {			
					System.out.println("Channel = " + channel
						+ "\n 设备名称：" + devName
						+ "\n 前端设备的视频通道号：" + channelInfo[channel].nChannelID
						+ "\n "
						);
				}

				if (devicNameDevInfoMap.get(devName) != null) {
					// 添加到关联表中				
					String devInfo = devicNameDevInfoMap.get(devName) 
							       + "\n 前端设备的视频通道号：" + channelInfo[channel].nChannelID;    // 根据设备名称获取设备信息
					channelDevInfoMap.put(new Integer(channel), devInfo);  		   					  // 每个通道对应的设备信息		
					System.out.println(devInfo);
				}	
			}
		}
		remotedeviceInfoMap.put(mLoginHandle, channelDevInfoMap);      // 每个登陆句柄，对应的服务器
	}
	
	/**
	 * 订阅报警信息
	 */
	public static boolean startListen(LLong mLoginHandle) {
		boolean bRet = false;
		
		if (mLoginHandle.longValue() == 0 ) {
			return false;
		}
		
	    // 设置报警回调函数
		NetSdk.CLIENT_SetDVRMessCallBack(m_AlarmDataCB, null);
		
		// 订阅报警
		bRet = NetSdk.CLIENT_StartListenEx(mLoginHandle);
		if (!bRet) {
			System.err.println("Subscrible alarm event failed!" + getErrorCode());
		}
		else {
			System.out.println("Subscrible alarm event success.\r\n");
		}
	
		return bRet;
	}
	
	/**
	 * 取消订阅报警信息
	 */
	public static boolean stopListen(LLong mLoginHandle) {
		if(mLoginHandle.longValue() == 0) {
			return false;
		}
		// 停止订阅报警
	   	if (NetSdk.CLIENT_StopListen(mLoginHandle)) {
	   		System.out.println("Stop subscrible alarm event success.\r\n");
	   		return true;
	   	}
		
		return false;
	}
	
	/**
	 * 报警信息回调函数原形
	 */
	private static fAlarmDataCB m_AlarmDataCB = new fAlarmDataCB();
	
	static class fAlarmDataCB implements NetSDKLib.fMessCallBack{
	  	public boolean invoke(int lCommand, LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP,  NativeLong nDevicePort, Pointer dwUser){
	  		switch (lCommand)
	  		{
	  		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("Channel is " + stuALARM_ALARM_INFO_EX2.nChannelID);
	  			System.out.println("Action is " + stuALARM_ALARM_INFO_EX2.nAction);
	  			System.out.println("Happend time is " + stuALARM_ALARM_INFO_EX2.stuTime.toStringTime());
	  			System.out.println("Sense type is " + stuALARM_ALARM_INFO_EX2.emSenseType);
	  			System.out.println("Defence area type is " + stuALARM_ALARM_INFO_EX2.emDefenceAreaType);
	  			break;
	  		default:
	  			break;
	  		}
	  		
	  		return true;
		}
	}
		


	/*********** 常用接口 **************/
	/**
	 * 设置配置
	 * @param strCmd 命令
	 * @param cmdObject 命令相关类
	 * @param hHandle 登录句柄
	 * @param nChn 通道号
	 * @return
	 */
	private boolean SetDevConfig(LLong hLoginHandle, int nChn, String strCmd, SdkStructure cmdObject) {
        boolean result = false;
    	int nBufferLen = 100*1024;
        byte szBuffer[] = new byte[nBufferLen];
        for(int i=0; i<nBufferLen; i++)szBuffer[i]=0;
		IntByReference error = new IntByReference(0);
		IntByReference restart = new IntByReference(0);
        
		cmdObject.write();
		if (ConfigSdk.CLIENT_PacketData(strCmd, cmdObject.getPointer(), cmdObject.size(),
				szBuffer, nBufferLen))
        {	
			cmdObject.read();
        	if( NetSdk.CLIENT_SetNewDevConfig(hLoginHandle, strCmd , nChn , szBuffer, nBufferLen, error, restart, 3000))
        	{
        		result = true;
        	}
        	else
        	{
        		 System.out.printf("Set %s Config Failed! Last Error = %x\n" , strCmd , NetSdk.CLIENT_GetLastError());
	        	 result = false;
        	}
        }
        else
        {
        	System.out.println("Packet " + strCmd + " Config Failed!");
         	result = false;
        }
        
        return result;
    }

	/**
	 * 获取配置
	 * @param strCmd 命令
	 * @param cmdObject 命令相关类
	 * @param hHandle 登录句柄
	 * @param nChn 通道号
	 * @return
	 */
	private static boolean GetDevConfig(LLong hLoginHandle, int nChn, String strCmd, SdkStructure cmdObject) {
		boolean result = false;
		IntByReference error = new IntByReference(0);
		int nBufferLen = 100*1024;
	    byte[] strBuffer = new byte[nBufferLen];
	   
	    if(NetSdk.CLIENT_GetNewDevConfig( hLoginHandle, strCmd , nChn, strBuffer, nBufferLen,error,3000,null) )
	    {  
	    	cmdObject.write();
			if (ConfigSdk.CLIENT_ParseData(strCmd, strBuffer, cmdObject.getPointer(),
					cmdObject.size(), null))
	     	{
				cmdObject.read();
	     		result = true;
	     	}
	     	else
	     	{
	     		System.out.println("Parse " + strCmd + " Config Failed!");
	     		result = false;
		 	}
		 }
		 else
		 {
			 System.out.printf("Get %s Config Failed!Last Error = %x\n" , strCmd , NetSdk.CLIENT_GetLastError());
			 result = false;
		 }
			
	     return result;
	  }

	/**
	 * 获取配置
	 * @param hLoginHandle 登录句柄
	 * @param nChn 通道
	 * @param strCmd 命令
	 * @param Objects 对象数组
	 * @return 成功返回 有效数组个数
	 */
	private static int GetDevConfig(LLong hLoginHandle, int nChn, String strCmd, SdkStructure[] cmdObjects)
	{
		IntByReference error = new IntByReference(0);
		int nBufferLen = 100*1024;
	    byte[] strBuffer = new byte[nBufferLen];
	    
	    if(!NetSdk.CLIENT_GetNewDevConfig(hLoginHandle, strCmd , nChn, strBuffer, nBufferLen, error, 3000,null))
	    {
	    	System.out.printf("Get %s Config Failed!Last Error = %x\n" , strCmd , NetSdk.CLIENT_GetLastError());
	    	return -1;
	    }
	    
	    IntByReference retLength = new IntByReference(0);
	    int memorySize = cmdObjects.length * cmdObjects[0].size();
	    Pointer objectsPointer = new Memory(memorySize);
	    objectsPointer.clear(memorySize);
	    
	    ToolKits.SetStructArrToPointerData(cmdObjects, objectsPointer);
	    
		if (!ConfigSdk.CLIENT_ParseData(strCmd, strBuffer, objectsPointer, memorySize, retLength.getPointer())) {		     		
     		System.out.println("Parse " + strCmd + " Config Failed!");
     		return -1;
		}
		
		ToolKits.GetPointerDataToStructArr(objectsPointer, cmdObjects);
		
		return (retLength.getValue() / cmdObjects[0].size());
	}
	
	/**
	 * 业务接口
	 */
	public static class Business implements Runnable {
		private Device device;
		
		public Business(Device device) {
			this.device = device;
		}
		
		public void run() {
			/// 登录设备
			device.mLoginHandle = login(device);
			if (device.mLoginHandle == null || device.mLoginHandle.longValue() == 0) {
				return;
			}
			
			// 将设备信息添加到设备列表中
			addDevice(device);
			
			// 查询前端设备信息 
			getDeviceInfo(device.mLoginHandle); 
			
			// 智能订阅监听
			realLoadPicture(device.mLoginHandle);
			
//			// 报警监听
//			startListen(device.mLoginHandle);
		}
	} 

	public static void main(String[] args) {
		final JNAInterface demo = new JNAInterface();
		demo.init();
		
		Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
			public void run() {
				for(LLong loginHandle : loginHandleList) {
					stopRealLoadPicture(loginHandle);
//					stopListen(loginHandle);
					logout(loginHandle);
				}
				demo.cleanup();
				synchronized (demo) {
					demo.notify();
				}
				
				System.out.println("Logout Device Success");
			}
		}));
		
//		new Thread(new Business(new Device("10.35.104.18", 37777, "admin", "abc123"))).start();	
		new Thread(new Business(new Device("172.23.12.16", 37777, "admin", "admin123"))).start();
//		new Thread(new Business(new Device("172.32.5.90", 37777, "admin", "admin321"))).start();
		
		synchronized (demo) {
			try {
				demo.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
				System.exit(-1);
			}
		}
	}	
}