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.AnalyzerDataCallBack;
import com.netsdk.lib.callback.securityCheck.NotifyPopulationStatisticsInfoCallBack;
import com.netsdk.lib.structure.NET_IN_ATTACH_GATE_POPULATION_STATISTICS_INFO;
import com.netsdk.lib.structure.NET_IN_GET_POPULATION_STATISTICS;
import com.netsdk.lib.structure.NET_OUT_ATTACH_GATE_POPULATION_STATISTICS_INFO;
import com.netsdk.lib.structure.NET_OUT_GET_POPULATION_STATISTICS;
import com.sun.jna.Memory;
import com.sun.jna.Pointer;

import java.io.File;

import static com.netsdk.lib.Utils.getOsPrefix;

/**
 * @author 291189
 * @version 1.0
 * @description 安全门功能demo
 * @date 2021/7/05
 */
public class SafetyCheckDemo {
    /**

     10.35.232.160 admin admin123

     */
    private String m_strIpAddr 				    = "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 static NetSDKLib.LLong m_hAttachHandle = new NetSDKLib.LLong(0);

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

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

        private DisconnectCallback() {
        }

        public static 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 HaveReconnectCallback instance = new HaveReconnectCallback();

        private HaveReconnectCallback() {
        }

        public static 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(DisconnectCallback.getInstance(), null);

        // 设置断线重连成功回调函数
        netSdk.CLIENT_SetAutoReconnect(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!!!");
        }

        loginWithHighLevel();
    }
    /**
     * 高安全登录
     */
    public void loginWithHighLevel() {
        // 输入结构体参数
        NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam = new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() {
            {
                szIP = m_strIpAddr.getBytes();
                nPort = m_nPort;
                szUserName = m_strUser.getBytes();
                szPassword = m_strPassword.getBytes();
            }
        };

        // 输出结构体参数
        NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY pstOutParam = new NetSDKLib.NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY();

        // 写入sdk
        loginHandle = netSdk.CLIENT_LoginWithHighLevelSecurity(pstlnParam, pstOutParam);
        if (loginHandle.longValue() == 0) {
            System.err.printf("Login Device[%s] Port[%d]Failed. %s\n", m_strIpAddr, m_nPort,
                    netSdk.CLIENT_GetLastError());
        } else {
            deviceInfo = pstOutParam.stuDeviceInfo; // 获取设备信息
            System.out.println("Login Success");
            System.out.println("Device Address：" + m_strIpAddr);
            System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道");
        }
    }

    /**
     * 退出清理环境
     */
    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";
        }
    }

   // CLIENT_AttachPopulationStatistics
    // 订阅安检门人数变化信息,pstInParam与pstOutParam内存由用户申请释放
    // CLIENT_NET_API LLONG CALL_METHOD CLIENT_AttachPopulationStatistics(LLONG lLoginID, NET_IN_ATTACH_GATE_POPULATION_STATISTICS_INFO* pstInParam, NET_OUT_ATTACH_GATE_POPULATION_STATISTICS_INFO* pstOutParam , int nWaitTime);

    public void AttachPopulationStatistics(){
        // 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
        DetachPopulationStatistics();
        //入参
        NET_IN_ATTACH_GATE_POPULATION_STATISTICS_INFO inParam=new NET_IN_ATTACH_GATE_POPULATION_STATISTICS_INFO();

        Pointer user=new Memory(1024);
        inParam.dwUser=user;
        inParam.cbNotifyPopulationStatisticsInfo = NotifyPopulationStatisticsInfoCallBack.getInstance();

        Pointer pInParam=new Memory(inParam.size());

        ToolKits.SetStructDataToPointer(inParam, pInParam, 0);

        //出参
        NET_OUT_ATTACH_GATE_POPULATION_STATISTICS_INFO outParam=new NET_OUT_ATTACH_GATE_POPULATION_STATISTICS_INFO();

        Pointer pOutParam=new Memory(outParam.size());

        ToolKits.SetStructDataToPointer(outParam, pOutParam, 0);
////CLIENT_NET_API LLONG CALL_METHOD CLIENT_AttachPopulationStatistics(LLONG lLoginID, NET_IN_ATTACH_GATE_POPULATION_STATISTICS_INFO* pstInParam, NET_OUT_ATTACH_GATE_POPULATION_STATISTICS_INFO* pstOutParam , int nWaitTime);
        AttachHandle= netSdk.CLIENT_AttachPopulationStatistics(loginHandle,pInParam,pOutParam,3000);

        if (AttachHandle.longValue() != 0) {
            System.out.println("CLIENT_AttachPopulationStatistics Success");
        } else {
            System.out.println("CLIENT_AttachPopulationStatistics Failed!LastError = %s\n"+ToolKits.getErrorCode());
        }
    }

    // 取消订阅安检门人数变化信息
    public void DetachPopulationStatistics(){
        if (AttachHandle.longValue() != 0) {
            netSdk.CLIENT_DetachPopulationStatistics(AttachHandle);
        }

    }
 // 获取安检门人数统计信息
 //CLIENT_NET_API BOOL CALL_METHOD CLIENT_GetPopulationStatistics(LLONG lLoginID, const NET_IN_GET_POPULATION_STATISTICS *pInParam, NET_OUT_GET_POPULATION_STATISTICS *pOutParam, int nWaitTime);
 //public boolean CLIENT_GetPopulationStatistics(NetSDKLib.LLong lLoginID, Pointer pstInParam, Pointer pstOutParam, int nWaitTime);

   public void  GetPopulationStatistics(){
        //入参
       NET_IN_GET_POPULATION_STATISTICS inParam=new NET_IN_GET_POPULATION_STATISTICS();

       Pointer pInParam=new Memory(inParam.size());

       ToolKits.SetStructDataToPointer(inParam, pInParam, 0);

       //出参
       NET_OUT_GET_POPULATION_STATISTICS msg=new NET_OUT_GET_POPULATION_STATISTICS();

       Pointer pOutParam=new Memory(msg.size());

       ToolKits.SetStructDataToPointer(msg, pOutParam, 0);

       //CLIENT_NET_API BOOL CALL_METHOD CLIENT_GetPopulationStatistics(LLONG lLoginID, const NET_IN_GET_POPULATION_STATISTICS *pInParam, NET_OUT_GET_POPULATION_STATISTICS *pOutParam, int nWaitTime);

       boolean DoFind = netSdk.CLIENT_GetPopulationStatistics(loginHandle, pInParam, pOutParam, 3000);

       if(!DoFind){
           System.err.printf("Do Find PopulationStatistics.Error[%s]\n", ToolKits.getErrorCode());
           return;
       }

       ToolKits.GetPointerData(pOutParam, msg);

       int nPassPopulation = msg.nPassPopulation; // 正向通过人数

       System.out.println("正向通过人数:"+nPassPopulation);

       int nMetalAlarmPopulation = msg.nMetalAlarmPopulation;

       System.out.println("正向触发金属报警人数:"+nMetalAlarmPopulation);

       int nReversePassPopulation = msg.nReversePassPopulation;

       System.out.println("反向通过人数:"+nReversePassPopulation);

       int nReverseMetalAlarmPopulation = msg.nReverseMetalAlarmPopulation;

       System.out.println("反向触发金属报警人数:"+nReverseMetalAlarmPopulation);

       long nTempNormalPopulation = msg.nTempNormalPopulation;

       System.out.println("体温正常人数:"+nTempNormalPopulation);

       long nTempAlarmPopulation = msg.nTempAlarmPopulation;

       System.out.println("体温异常人数:"+nTempAlarmPopulation);

   }

    /**
     * 订阅智能分析数据
     */
    public void realLoadPicture() {
        int bNeedPicture = 1; // 是否需要图片
        int ChannelId = 0;   // -1代表全通道

        m_hAttachHandle =  netSdk.CLIENT_RealLoadPictureEx(loginHandle, ChannelId,  NetSDKLib.EVENT_IVS_SECURITYGATE_PERSONALARM,
                bNeedPicture , AnalyzerDataCallBack.getInstance() , null , null);
        if(m_hAttachHandle.longValue() != 0) {
            System.out.println("智能订阅成功.");
        } else {
            System.err.println("智能订阅失败." + ToolKits.getErrorCode());
            return;
        }
    }

    /**
     * 停止侦听智能事件
     */
    public void DetachEventRealLoadPic() {
        if (m_hAttachHandle.longValue() != 0) {
            netSdk.CLIENT_StopLoadPic(m_hAttachHandle);
        }
    }
    public void RunTest()
    {
        System.out.println("Run Test");
        CaseMenu menu = new CaseMenu();
        menu.addItem(new CaseMenu.Item(this , "订阅安检门人数变化信息" , "AttachPopulationStatistics"));
        menu.addItem(new CaseMenu.Item(this , "取消订阅安检门人数变化信息" , "DetachPopulationStatistics"));
        menu.addItem((new CaseMenu.Item(this , "获取安检门人数统计信息" , "GetPopulationStatistics")));
        menu.addItem((new CaseMenu.Item(this , "订阅智能分析数据" , "realLoadPicture")));
        menu.addItem((new CaseMenu.Item(this , "取消实时智能分析数据" , "DetachEventRealLoadPic")));
        menu.run();
    }

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

    }
}