package com.netsdk.demo.customize.querySystemState;

import com.netsdk.demo.customize.queryFaceDetection.QueryFaceDetectionUtils;
import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.structure.*;
import com.sun.jna.Memory;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;

import java.io.UnsupportedEncodingException;

/**
 * className：QuerySystemState
 * description：
 * author：251589
 * createTime：2021/2/25 14:37
 *
 * @version v1.0
 */

public class QuerySystemStateDemo {
    // The constant net sdk
    public static final NetSDKLib netSDK = NetSDKLib.NETSDK_INSTANCE;

    // The constant config sdk.
    public static NetSDKLib configSDK = NetSDKLib.CONFIG_INSTANCE;

    ////////////////////////////////////// 登录相关 ///////////////////////////////

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

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

    /**
     * 登录设备
     *
     * @return
     */
//    public boolean login() {
//        System.out.println("Function: Login Device." + ip);
//        final int tcpSpecCap = 0;
//        final IntByReference errorReference = new IntByReference(0);
//        final NetSDKLib.NET_DEVICEINFO deviceinfo = new NetSDKLib.NET_DEVICEINFO();
//        loginHandle = netSDK.CLIENT_LoginEx(ip, port, username, password, tcpSpecCap, null, deviceinfo, errorReference);
//        if (loginHandle.longValue() == 0) {
//            System.err.println("Failed to Login " + ip + getErrorCode());
//            return false;
//        }
//        System.out.println("Success to Login " + ip);
//        return true;
//    }

    /**
     * login with high level 高安全级别登陆
     */
    public void loginWithHighLevel() {
        NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY pstlnParam =
                new NetSDKLib.NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY() {{
                    szIP = ip.getBytes();
                    nPort = port;
                    szUserName = username.getBytes();
                    szPassword = password.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() == 0L) {
            System.err.printf("Login Device[%s] Port[%d]Failed. %s\n", ip, port,
                    netSDK.CLIENT_GetLastError());
        } else {
            deviceInfo = pstOutParam.stuDeviceInfo;   // 获取设备信息
            System.out.println("Login Success");
            System.out.println("Device Address：" + ip);
            System.out.println("设备包含：" + deviceInfo.byChanNum + "个通道");
        }
    }

    /**
     * logout 退出
     */
    public void logOut() {
        if (loginHandle.longValue() != 0L) {
            netSDK.CLIENT_Logout(loginHandle);
            System.out.println("LogOut Success");
        }
    }

    public void querySystemStatus() {

        NET_SYSTEM_STATUS netSystemStatus = new NET_SYSTEM_STATUS();
        // CPU 状态
        NET_CPU_STATUS netCpuStatus = new NET_CPU_STATUS();
        netCpuStatus.write();

        // 内存状态
        NET_MEMORY_STATUS netMemoryStatus = new NET_MEMORY_STATUS();
        netMemoryStatus.write();

        // 风扇状态
        NET_FAN_STATUS netFanStatus = new NET_FAN_STATUS();
        netFanStatus.write();

        // 电源状态
        NET_POWER_STATUS netPowerStatus = new NET_POWER_STATUS();
        netPowerStatus.write();

        // 温度状态
        NET_TEMPERATURE_STATUS netTemperatureStatus = new NET_TEMPERATURE_STATUS();
        netTemperatureStatus.write();

        netSystemStatus.pstuCPU = netCpuStatus.getPointer();
        netSystemStatus.pstuMemory = netMemoryStatus.getPointer();
        netSystemStatus.pstuFan = netFanStatus.getPointer();
        netSystemStatus.pstuPower = netPowerStatus.getPointer();
        netSystemStatus.pstuTemp = netTemperatureStatus.getPointer();

        netSystemStatus.write();
        boolean ret = netSDK.CLIENT_QuerySystemStatus(loginHandle, netSystemStatus.getPointer(), 1000);
        if (ret) {
            System.out.println("查询成功！");

            netSystemStatus.read();

            netCpuStatus.read();
            netMemoryStatus.read();
            netFanStatus.read();
            netPowerStatus.read();
            netTemperatureStatus.read();

            // cpu信息
            System.out.println("cpu状态-> 数量: " + netCpuStatus.nCount + " 查询是否成功: " + netCpuStatus.bEnable);

            for (int i = 0; i < netCpuStatus.nCount; i++) {
                System.out.println("CPU使用率 :" + netCpuStatus.stuCPUs[i].nUsage);
            }

            // 内存信息
            System.out.println("内存信息：" + netMemoryStatus.bEnable + "  总量： " + netMemoryStatus.stuMemory.dwTotal);

            // 电源、池信息
            for (int i = 0; i < netPowerStatus.nCount; i++) {
                System.out.printf("电源[%d] 电源状态: %d, 电池状态: %d%n", i + 1,
                        netPowerStatus.stuPowers[i].bPowerOn,
                        netPowerStatus.stuBatteries[i].bCharging);
            }

            System.err.println("个数：" + netFanStatus.nCount);
            for (int i = 0; i < netFanStatus.nCount; i++) {
                try {
                    System.err.println("stuFans: " + netFanStatus.stuFans[i].nSpeed + " 名称：" +
                            new String(netFanStatus.stuFans[i].szName, "gbk"));
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }


            System.out.println("温度信息：" + netTemperatureStatus.bEnable + " 数量： " + netTemperatureStatus.nCount);

            for (int i = 0; i < netTemperatureStatus.nCount; i++) {
                try {
                    System.out.println("温度信息： " + netTemperatureStatus.stuTemps[i].fTemperature + new String(netTemperatureStatus.stuTemps[i].szName, "gbk"));
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }


        } else {
            System.err.println("系统状态查询失败！！！" + netSDK.CLIENT_GetLastError());
        }

    }

    /**
     * 报警信息回调函数原形,建议写成单例模式
     */
    private static class fAlarmDataCB implements NetSDKLib.fMessCallBack {
        private fAlarmDataCB() {
        }

        private static class fAlarmDataCBHolder {
            private static fAlarmDataCB callback = new fAlarmDataCB();
        }

        public static fAlarmDataCB getCallBack() {
            return fAlarmDataCB.fAlarmDataCBHolder.callback;
        }

        public boolean invoke(int lCommand, NetSDKLib.LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP, NativeLong nDevicePort, Pointer dwUser) {
            switch (lCommand) {
                case NetSDKLib.NET_DISKFULL_ALARM_EX: { // 硬盘满报警，数据为1个字节，
                    System.out.println("硬盘满报警");
                    if (dwBufLen > 0) {
                        byte[] channelState = pStuEvent.getByteArray(0, dwBufLen);  // 将缓存pStuEvent的值，按byte[]输出
                        for (int i = 0; i < dwBufLen; i++) {
                            System.out.print(" Channel[" + i + "] State = " + (channelState[i]));  // 1为有硬盘满报警，0为无报警。
                        }
                    }
                    break;
                }
                case NetSDKLib.NET_DISKERROR_ALARM_EX: {
                    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_ALARM_RAID_STATE_EX: {
                    System.out.println("RAID异常报警");
                    ALARM_RAID_INFO_EX msg = new ALARM_RAID_INFO_EX();
                    ToolKits.GetPointerData(pStuEvent, msg);
                    System.out.println("错误类型: 0未知，1RAID错误，2RAID降级: " + msg.emErrorType);
                    System.out.println("开始/结束，0开始，1结束: " + msg.nAction);
                    break;
                }
                default:
                    break;
            }
            return true;
        }
    }

    public void startListenAlarm() {
        // 设置报警回调函数
        //
        netSDK.CLIENT_SetDVRMessCallBack(fAlarmDataCB.getCallBack(), null);

        // 向设备订阅报警--扩展
        if (netSDK.CLIENT_StartListenEx(loginHandle)) {
            System.out.printf("CLIENT_StartListenEx Success\n");
        } else {
            System.out.printf("CLIENT_StartListenEx Failed!LastError = %x\n", netSDK.CLIENT_GetLastError());
        }
    }

    public void stopListenAlarm() {
        // 向设备停止报警--扩展
        if (netSDK.CLIENT_StopListen(loginHandle)) {
            System.out.printf("CLIENT_StopListen Success\n");
        } else {
            System.out.printf("CLIENT_StopListen Failed!LastError = %x\n", netSDK.CLIENT_GetLastError());
        }
    }

    // 结束测试
    public void endTest() {
        System.out.println("End Test");
        this.logOut();  // 退出
        System.out.println("See You...");
        QueryFaceDetectionUtils.cleanAndExit();  // 清理资源并退出
    }

    // 加载测试内容
    public void runTest() {
        CaseMenu menu = new CaseMenu();
        menu.addItem(new CaseMenu.Item(this, "查询系统状态", "querySystemStatus"));
        menu.addItem(new CaseMenu.Item(this, "事件监听", "startListenAlarm"));
        menu.addItem(new CaseMenu.Item(this, "退订", "stopListenAlarm"));
        menu.run();
    }

    // 初始化测试
    public void initTest() {
        QuerySystemStatusUtils.Init();         // 初始化SDK库
        this.loginWithHighLevel();   // 高安全登录
    }


    /////////////// 配置登陆地址，端口，用户名，密码  ////////////////////////
    private String ip = "171.35.0.25";
    private int port = 37777;
    private String username = "admin";
    private String password = "admin1234";
    //////////////////////////////////////////////////////////////////////

    public static void main(String[] args) {
        QuerySystemStateDemo demo = new QuerySystemStateDemo();

        demo.initTest();
        demo.runTest();
        demo.endTest();
    }
}