package com.netsdk.demo.customize.securityCheck;


import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.callback.securityCheck.SecurityGateAttachAlarmStatisticsCallBack;
import com.netsdk.lib.structure.NET_IN_SECURITYGATE_ATTACH_ALARM_STATISTICS;
import com.netsdk.lib.structure.NET_OUT_SECURITYGATE_ATTACH_ALARM_STATISTICS;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

import java.io.File;
import java.util.UUID;

import static com.netsdk.lib.Utils.getOsPrefix;
/**
 * @author 291189
 * @version 1.0
 * @description 安全门报警订阅和统计信息
 * @date 2021/6/29
 */
public class ShSecurityCheckDemo {
    /**

     10.35.232.160 安检门环境
     admin  admin123

     安检机 10.35.233.144
     admin  admin123

     */

    // 配置登陆地址，端口，用户名，密码

    private String m_strIp 				    = "10.35.232.160";
    private int    m_nPort 				    = 37777;
    private String m_strUser 			    = "admin";
    private String m_strPassword 		    = "admin123";

    static NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
    static NetSDKLib configApi = NetSDKLib.CONFIG_INSTANCE;


   // public static final NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;
    // 登陆句柄
    private static NetSDKLib.LLong loginHandle = new NetSDKLib.LLong(0);

    // 订阅句柄
    private static NetSDKLib.LLong AttachHandle = new NetSDKLib.LLong(0);

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

    /**
     * 设备断线回调
     */
    private static class DisconnectCallback implements NetSDKLib.fDisConnect {
        private static ShSecurityCheckDemo.DisconnectCallback instance = new ShSecurityCheckDemo.DisconnectCallback();

        private DisconnectCallback() {
        }

        public static ShSecurityCheckDemo.DisconnectCallback getInstance() {
            return instance;
        }

        public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
            System.out.printf("Device[%s:%d] Disconnect!\n", pchDVRIP, nDVRPort);
        }
    }
    /**
     * 设备重连回调
     */
    private static class HaveReconnectCallback implements NetSDKLib.fHaveReConnect {
        private static ShSecurityCheckDemo.HaveReconnectCallback instance = new ShSecurityCheckDemo.HaveReconnectCallback();

        private HaveReconnectCallback() {
        }

        public static ShSecurityCheckDemo.HaveReconnectCallback getInstance() {
            return instance;
        }

        public void invoke(NetSDKLib.LLong lLoginID, String pchDVRIP, int nDVRPort, Pointer dwUser) {
            System.out.printf("Device[%s:%d] HaveReconnected!\n", pchDVRIP, nDVRPort);
        }
    }


    public void InitTest(){
        // 初始化SDK库
        netSdk.CLIENT_Init(ShSecurityCheckDemo.DisconnectCallback.getInstance(), null);

        // 设置断线重连成功回调函数
        netSdk.CLIENT_SetAutoReconnect(ShSecurityCheckDemo.HaveReconnectCallback.getInstance(), null);

        //打开日志，可选0
        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);
    }


    // 编码格式
    public static String encode;

    static {
        String osPrefix = getOsPrefix();
        if (osPrefix.toLowerCase().startsWith("win64-amd64")) {
            encode = "GBK";
        } else if (osPrefix.toLowerCase().startsWith("linux-amd64")) {
            encode = "UTF-8";
        }
    }


    /**
     * 订阅安全门报警统计信息接口
     */
    public void attachDadarAlarmInfo() {

        //入参
        NET_IN_SECURITYGATE_ATTACH_ALARM_STATISTICS net_in_securitygate_attach_alarm_statistics=new NET_IN_SECURITYGATE_ATTACH_ALARM_STATISTICS();

        UUID uuid= UUID.randomUUID();
        byte[] szUUID = net_in_securitygate_attach_alarm_statistics.szUUID;

        String numbers =uuid.toString();
        //beda31a3-a7b5-4126-81b9-6e67402b7b0c?
        int i = numbers.lastIndexOf("-");

        String[] split = numbers.split("-");
        //UUID算法(8-4-4-16格式)

        numbers=split[0]+"-"+split[1]+""+split[2]+"-"+split[3]+split[4];

        System.arraycopy(numbers.getBytes(), 0, szUUID, 0, numbers.getBytes().length);

        net_in_securitygate_attach_alarm_statistics.szUUID=szUUID;

        Pointer user=new Memory(1024);
        net_in_securitygate_attach_alarm_statistics.dwUser=user;
        net_in_securitygate_attach_alarm_statistics.cbNotify= SecurityGateAttachAlarmStatisticsCallBack.getInstance();
        Pointer pInParam=new Memory(net_in_securitygate_attach_alarm_statistics.size());
        ToolKits.SetStructDataToPointer(net_in_securitygate_attach_alarm_statistics, pInParam, 0);

        //出参

        NET_OUT_SECURITYGATE_ATTACH_ALARM_STATISTICS net_out_securitygate_attach_alarm_statistics=
                new NET_OUT_SECURITYGATE_ATTACH_ALARM_STATISTICS();

        Pointer pOutParam=new Memory(net_out_securitygate_attach_alarm_statistics.size());
        ToolKits.SetStructDataToPointer(net_out_securitygate_attach_alarm_statistics, pOutParam, 0);

        AttachHandle
                = netSdk.CLIENT_SecurityGateAttachAlarmStatistics(loginHandle, pInParam,
                pOutParam, 5000);

        if(AttachHandle.longValue() == 0) {
            System.out.printf("SecurityGateAttachAlarmStatistics fail, ErrCode=%x\n", netSdk.CLIENT_GetLastError() );
        }else {
            System.out.println("SecurityGateAttachAlarmStatistics success");
        }
    }



    public void RunTest()
    {
        System.out.println("Run Test");
        CaseMenu menu = new CaseMenu();
        menu.addItem(new CaseMenu.Item(this , "attachDadarAlarmInfo" , "attachDadarAlarmInfo"));
        menu.run();
    }




    public static  void main(String[] args){
        ShSecurityCheckDemo shSecurityCheckDemo=new ShSecurityCheckDemo();
        shSecurityCheckDemo.InitTest();
        shSecurityCheckDemo.RunTest();
        shSecurityCheckDemo.LoginOut();

    }



}