package com.netsdk.demo.event;

import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.CFG_ACCESS_EVENT_INFO;
import com.netsdk.lib.NetSDKLib.CFG_ACCESS_STATE;
import com.netsdk.lib.NetSDKLib.CFG_ACCESS_TIMESCHEDULE_INFO;
import com.netsdk.lib.NetSDKLib.CFG_OPEN_DOOR_GROUP_INFO;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.callback.impl.AnalyzerDataCB;
import com.sun.jna.Callback;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

import java.io.File;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

public class DeviceModule {

	/*static{
		System.setProperty("java.io.tmpdir", "/home/liu_sai/java");
	}*/

    public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;

    // 设备信息扩展
    private NetSDKLib.NET_DEVICEINFO_Ex deviceInfo = new NetSDKLib.NET_DEVICEINFO_Ex();

    // 登陆句柄
    private NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0);

    // 智能订阅句柄
    private NetSDKLib.LLong attachHandle = new NetSDKLib.LLong(0);
    
    private Map<Integer, NetSDKLib.LLong> mapAttachHandle = new HashMap<Integer, NetSDKLib.LLong>();
    
    // 普通报警监听标记
    private boolean listening = false;

    /**
     * 初始化sdk
     */
    public static void init() {
        // 初始化SDK库
        netSdk.CLIENT_Init(DisConnectCallBack.getInstance(), null);

        // 设置断线重连成功回调函数
        netSdk.CLIENT_SetAutoReconnect(HaveReConnectCallBack.getInstance(), 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!!!");
        }
    }
    
    /**
	 * 设置报警回调函数
	 */
	public static void setDVRMessCallBack(Callback callback) {		
		netSdk.CLIENT_SetDVRMessCallBack(callback, null);
	}

    /*
     * 设备登陆
     * @param ip            ip地址
     * @param port          端口
     * @param username      用户名
     * @param password      密码
     */
    public boolean login(String ip, int port, String username, String password) {

        // 登陆设备
        int nSpecCap = NetSDKLib.EM_LOGIN_SPAC_CAP_TYPE.EM_LOGIN_SPEC_CAP_TCP;    // TCP登入
        IntByReference nError = new IntByReference(0);
        loginHandle = netSdk.CLIENT_LoginEx2(ip, port, username,
                password ,nSpecCap, null, deviceInfo, nError);
        if (loginHandle.longValue() != 0) {
            System.out.printf("Login Device[%s] Success!\n", ip);
        }
        else {
            System.err.printf("Login Device[%s] Fail.Error[%s]\n", ip, ToolKits.getErrorCode());
        }
        return loginHandle.longValue() != 0;
    }

    /**
     * 是否登录
     */
    public boolean isLogined() {
        return loginHandle.longValue() != 0;
    }
    
    /**
     * 获取登录句柄
     */
    public final NetSDKLib.LLong getLoginHandle() {
		return loginHandle;
	}
    
    /**
     * 获取通道个数
     */
    public int getChannelNum() {
		return deviceInfo.byChanNum;
	}
    
    /**
     * 设备登出
     */
    public void logout() {
        if (loginHandle != null && loginHandle.longValue() != 0) {
            netSdk.CLIENT_Logout(loginHandle);
            System.out.println("Logout Device.");
        }
    }
    
    /**
     * 智能订阅(订阅所有通道)
     */
    public boolean realLoadPicture() {
        int channel = -1; // 所有通道
        if (deviceInfo.byChanNum == 1) {
        	channel = 0;
        }
        return realLoadPicture(channel);
    }
    
    /**
     * 指定通道智能订阅
     * @param channel 通道号(-1代表全通道)
     */
    public boolean realLoadPicture(int channel) {
        int bNeedPicture = 1;   // 是否需要图片
        NetSDKLib.LLong attachHandle =  netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel,
                NetSDKLib.EVENT_IVS_ALL, bNeedPicture, AnalyzerDataCB.getInstance(), null , null);
        if (attachHandle.longValue() == 0) {
        	System.err.printf("Channel[%d] RealLoad Picture Failed！ %s\n", channel, ToolKits.getErrorCode());
            return false;
        }
        
        System.out.printf("Channel[%d] RealLoad Picture Success！\n", channel);
        mapAttachHandle.put(channel, attachHandle);
        return true;
    }
    
    /**
     * 指定通道停止智能订阅
     */
    public void stopLoadPicture(int channel) {
    	NetSDKLib.LLong attachHandle = mapAttachHandle.get(channel);
    	if (attachHandle != null) {
            netSdk.CLIENT_StopLoadPic(attachHandle);
            System.out.println("Had Stop RealLoad Picture！");
    	}
    }

    /**
     * 停止智能订阅
     */
    public void stopLoadPicture() {
    	for (NetSDKLib.LLong attachHandle: mapAttachHandle.values()) {
            netSdk.CLIENT_StopLoadPic(attachHandle);
    	}
        System.out.println("Had Stop RealLoad Picture！");
    	mapAttachHandle.clear();
    }
    
    /**
	 * 报警监听
	 */
	public boolean startListen() {
		if (listening) {
			return true;
		}
		
		listening = netSdk.CLIENT_StartListenEx(loginHandle);
		if (!listening) {
			System.err.println("Start Listen Failed!" + ToolKits.getErrorCode());
		} else { 
			System.out.println("Start Listen Success."); 
		}
		
		return listening;
	}

    /**
     * 报警监听，传入 handle
     */
    public boolean startListen(NetSDKLib.LLong m_loginHandle) {
        if (listening) {
            return true;
        }

        listening = netSdk.CLIENT_StartListenEx(m_loginHandle);
        if (!listening) {
            System.err.println("Start Listen Failed!" + ToolKits.getErrorCode());
        } else {
            System.out.println("Start Listen Success.");
        }

        return listening;
    }

    /**
	 * 停止报警监听
	 */
	public void stopListen() {
		if (listening) {
			netSdk.CLIENT_StopListen(loginHandle);
			listening = false;
		}
	}

    /**
     * 停止报警监听 传入 handle
     */
    public void stopListen(NetSDKLib.LLong m_loginHandle) {
        if (listening) {
            netSdk.CLIENT_StopListen(m_loginHandle);
            listening = false;
        }
    }
	
	/**
	 * 门禁事件配置
	 * @param nChannel 		通道号
	 * @param emState		门禁状态
	 * @param nTimeIndex	常开、常关时间段索引
	 */
	public boolean accessControlConfig(int nChannel, int emState, int nOpenTimeIndex, int nCloseTimeIndex) {
		// 获取
		String szCommand = NetSDKLib.CFG_CMD_ACCESS_EVENT;
		CFG_ACCESS_EVENT_INFO accessCfg = new CFG_ACCESS_EVENT_INFO();
		if (!ToolKits.GetDevConfig(loginHandle, nChannel, szCommand, accessCfg)) {
            System.err.println("Get Access Control Config Failed.");
            return false;
		}
		
		// 常关、常开时间段值为CFG_ACCESS_TIMESCHEDULE_INFO配置的数组下标
		System.out.printf("[通道%d] 使能:%d 门禁状态(0-普通 1-常闭 2-常开 3-无人状态常闭 4-无人状态常开):%d 常开时间段：%d 常关时间段:%d\n", 
				nChannel, accessCfg.bEnable, accessCfg.emState, accessCfg.nOpenAlwaysTimeIndex, accessCfg.nCloseAlwaysTimeIndex);
		
		accessCfg.bEnable = 1; // 使能
		accessCfg.emState = emState;
		if (emState == CFG_ACCESS_STATE.ACCESS_STATE_NORMAL) {
			accessCfg.nOpenAlwaysTimeIndex = nOpenTimeIndex;
			accessCfg.nCloseAlwaysTimeIndex = nCloseTimeIndex;
		}

		// 设置
		if (!ToolKits.SetDevConfig(loginHandle, nChannel, szCommand, accessCfg)) {
			System.err.println("Set Access Control Config Failed!");
			return false;
		}
		
		System.out.println("Set Access Control Config Succeed!");
		return true;
	}
	
	/**
	 * 门禁刷卡时间段设置
	 * @param nChannel 		通道号
	 */
	public CFG_ACCESS_TIMESCHEDULE_INFO getAccessTimeSchedule(int nChannel) {
		CFG_ACCESS_TIMESCHEDULE_INFO cfg = new CFG_ACCESS_TIMESCHEDULE_INFO();
		
		String strCmd = NetSDKLib.CFG_CMD_ACCESSTIMESCHEDULE;		
		// 获取
		if (!ToolKits.GetDevConfig(loginHandle, nChannel, strCmd, cfg)) {
			System.err.println("Get Access Time Schedule Failed!");
			return null;
		}
		
		return cfg;
	}

	/**
	 * 门禁刷卡时间段设置
	 * @param nChannel		通道号
	 * @param cfg			门禁刷卡时间段配置
	 */
	public boolean setAccessTimeSchedule(int nChannel, CFG_ACCESS_TIMESCHEDULE_INFO cfg) {
		String strCmd = NetSDKLib.CFG_CMD_ACCESSTIMESCHEDULE;		
		if (!ToolKits.SetDevConfig(loginHandle, nChannel, strCmd, cfg)) {
			System.err.println("Set Access Time Schedule Failed!");
			return false;
		}
		
		System.out.println("Set Access Time Schedule Succeed!");
		return true;
	}
	
	/**
	 * 多人多开门方式组合配置
	 * @param nChannel		通道号
	 * @param msg			 多人多开门方式组合配置
	 */
	public boolean MoreOpenDoor(int nChannel,CFG_OPEN_DOOR_GROUP_INFO msg){ 
		// 获取
		String szCommand = NetSDKLib.CFG_CMD_OPEN_DOOR_GROUP;
		if (!ToolKits.GetDevConfig(loginHandle, nChannel, szCommand, msg)) {
		       System.err.println("Get more open door Failed.");
		       return false;
		}
		System.out.println("有效组合数" + msg.nGroup + " 用户数目 " + msg.stuGroupInfo.length );
		
		//设置
		msg.stuGroupInfo[0].stuGroupDetail[0].emMethod=1;
		msg.stuGroupInfo[0].stuGroupDetail[1].emMethod=1;
		/*msg.stuGroupInfo[1].stuGroupDetail[0].emMethod=1;
		msg.stuGroupInfo[1].stuGroupDetail[1].emMethod=1;*/
		System.arraycopy("123".getBytes(), 0, msg.stuGroupInfo[0].stuGroupDetail[0].szUserID, 0, "123".getBytes().length);
		System.arraycopy("234".getBytes(), 0, msg.stuGroupInfo[0].stuGroupDetail[1].szUserID, 0, "234".getBytes().length);
		/*System.arraycopy("345".getBytes(), 0, msg.stuGroupInfo[1].stuGroupDetail[0].szUserID, 0, "345".getBytes().length);
		System.arraycopy("456".getBytes(), 0, msg.stuGroupInfo[1].stuGroupDetail[1].szUserID, 0, "456".getBytes().length);*/
    	for(int i=0;i<msg.stuGroupInfo.length;i++){
    		msg.stuGroupInfo[i].nUserCount=2;
    		msg.stuGroupInfo[i].nGroupNum=2;
    		msg.stuGroupInfo[i].bGroupDetailEx=true;
    	}
    	if(!ToolKits.SetDevConfig(loginHandle, nChannel, szCommand, msg)){
    		System.err.println("Set more open door Failed!");
			return false;
    	}
    	System.out.println("Set more open door Succeed!");
		return true;
    }
	

    public void copyByteArray(byte[] src, byte[] dst) {
        Arrays.fill(dst, (byte)0);
        int length = dst.length-1 > src.length ? src.length : dst.length-1;
        System.arraycopy(src, 0, dst, 0, length);
    }

    /**
     *  SDK退出清理
     */
    public static void cleanup() {
        netSdk.CLIENT_Cleanup();
    }
    
    /**
     * 设备断线回调
     */
    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);

        }
    }
}