package com.netsdk.demo.customize;

import com.netsdk.demo.units.TimeUtils;
import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.NetSDKLib.LOG_SET_PRINT_INFO;
import com.netsdk.lib.NetSDKLib.NET_CFG_SCENE_SNAP_SHOT_WITH_RULE2_INFO;
import com.netsdk.lib.NetSDKLib.NET_SCENE_SNAP_SHOT_WITH_RULE2_INFO;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.enumeration.ENUMERROR;
import com.netsdk.lib.enumeration.NET_EM_CFG_OPERATE_TYPE;
import com.netsdk.lib.structure.START_LISTEN_FINISH_RESULT_INFO;
import com.sun.jna.Memory;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

import javax.imageio.ImageIO;
import java.awt.image.BufferedImage;
import java.io.ByteArrayInputStream;
import java.io.File;
import java.io.IOException;
import java.util.Date;
import static com.netsdk.lib.Utils.getOsPrefix;


/**
 * @description: 烟火报警及规则坐标信息  智能事件有图片（该事件在报警收尾各报一次)&&普通事件上报坐标
 * @author: 251589
 * @time: 2020/11/18 20:50
 */
public class FireWarnDemo {

    static 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);


    /**
     * 通用服务
     */
    static class SDKGeneralService {

        // 网络断线回调
        // 调用 CLIENT_Init设置此回调, 当设备断线时会自动调用.
        public static class DisConnect implements NetSDKLib.fDisConnect {

            private DisConnect() {
            }

            private static class CallBackHolder {
                private static final com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.DisConnect cb = new com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.DisConnect();
            }

            public static final com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.DisConnect getInstance() {
                return com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.DisConnect.CallBackHolder.cb;
            }

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

        // 网络连接恢复回调
        // 调用 CLIENT_SetAutoReconnect设置此回调, 当设备重连时会自动调用.
        public static class HaveReConnect implements NetSDKLib.fHaveReConnect {

            private HaveReConnect() {
            }

            private static class CallBackHolder {
                private static final com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.HaveReConnect cb = new com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.HaveReConnect();
            }

            public static final com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.HaveReConnect getInstance() {
                return com.netsdk.demo.customize.FireWarnDemo.SDKGeneralService.HaveReConnect.CallBackHolder.cb;
            }

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

        /**
         * SDK初始化
         */
        public static void init() {
            // SDK资源初始化
            netSdk.CLIENT_Init(com.netsdk.demo.customize.SDSnap.SDKGeneralService.DisConnect.getInstance(), null);

            // 设置断线重连回调，当设备断线后会自动重连并在重连后自动调用HaveReConnect(可选)
            netSdk.CLIENT_SetAutoReconnect(com.netsdk.demo.customize.SDSnap.SDKGeneralService.HaveReConnect.getInstance(), null);

            // 打开SDK日志（可选）
            LOG_SET_PRINT_INFO setLog = new LOG_SET_PRINT_INFO();
            setLog.bSetFilePath = 1;
            setLog.bSetPrintStrategy = 1;
            setLog.nPrintStrategy = 0;
            String logPath = new File(".").getAbsoluteFile().getParent() + File.separator + "sdk_log" + File.separator + "sdk.log";

            System.arraycopy(logPath.getBytes(), 0, setLog.szLogFilePath, 0, logPath.getBytes().length);

            boolean bLogopen = netSdk.CLIENT_LogOpen(setLog);
            if (!bLogopen)
                System.err.println("Failed to open NetSDK log !!!");

            netSdk.CLIENT_SetSnapRevCallBack(com.netsdk.demo.customize.SDSnap.SnapCallback.getInstance(), null);
        }

        /**
         * SDK反初始化——释放资源
         */
        public static void cleanup() {
            netSdk.CLIENT_Cleanup();
        }
    }

    /**
     * 登录设备
     */
    public boolean login() {
        int nSpecCap = 0;
        Pointer pCapParam = null;
        IntByReference nError = new IntByReference(0);
        loginHandle = netSdk.CLIENT_LoginEx2(ip, port, username,
                password, nSpecCap, pCapParam, deviceInfo, nError);

        if (loginHandle.longValue() != 0) {
            System.out.printf("Login Device[%s] Port[%d] Success!\n", ip, port);
        } else {
            System.out.printf("Login Device[%s] Port[%d] Failed. %s\n", ip, port, ToolKits.getErrorCode() + ENUMERROR.getErrorMessage());
        }

        return loginHandle.longValue() != 0;
    }


    /**
     * 登出设备
     */
    public void logout() {
        if (loginHandle.longValue() != 0)
            netSdk.CLIENT_Logout(loginHandle);
    }

    public void InitTest() {
        com.netsdk.demo.customize.SDSnap.SDKGeneralService.init(); // SDK初始化
        if (!login())  // 登陆设备
            EndTest();
    }

    public void EndTest() {
        stopLoadPicture();    // 取消订阅
        logout(); //	登出设备
        System.out.println("See You...");
        netSdk.CLIENT_Cleanup();
        System.exit(0);
    }

    // 远程抓图
    public void snapPicture() {
        //设置抓图回调函数， 图片主要在m_SnapReceiveCB中返回
        netSdk.CLIENT_SetSnapRevCallBack(fSnapReceiveCB, null);

        // 发送抓图命令给前端设备，抓图的信息
        NetSDKLib.SNAP_PARAMS stuSnapParams = new NetSDKLib.SNAP_PARAMS();
        stuSnapParams.Channel = 1;  //抓图通道
        stuSnapParams.mode = 0;     //表示请求一帧
        stuSnapParams.Quality = 3;
        stuSnapParams.InterSnap = 5;
        stuSnapParams.CmdSerial = 100; // 请求序列号，有效值范围 0~65535，超过范围会被截断为

        IntByReference reserved = new IntByReference(0);

        if (netSdk.CLIENT_SnapPictureEx(loginHandle, stuSnapParams, reserved)) {
            System.out.println("CLIENT_SnapPictureEx success");
        } else {
            System.out.printf("CLIENT_SnapPictureEx Failed!Last Error[%x]\n", netSdk.CLIENT_GetLastError());
            return;
        }
    }

    private fSnapReceiveCB fSnapReceiveCB = new fSnapReceiveCB();

    public class fSnapReceiveCB implements NetSDKLib.fSnapRev {
        public void invoke(NetSDKLib.LLong lLoginID, Pointer pBuf, int RevLen, int EncodeType, int CmdSerial, Pointer dwUser) {
            //pBuf收到的图片数据
            File currentPath = new File(".");
            String strFileName = currentPath.getAbsoluteFile().getParent() + "\\" + System.currentTimeMillis() + ".jpg";

            byte[] buf = pBuf.getByteArray(0, RevLen);
            ByteArrayInputStream byteArrInput = new ByteArrayInputStream(buf);
            try {
                BufferedImage bufferedImage = ImageIO.read(byteArrInput);
                if (bufferedImage == null) {
                    return;
                }
                ImageIO.write(bufferedImage, "jpg", new File(strFileName));
            } catch (IOException e) {
                e.printStackTrace();
            }

			//保存图片到本地文件
			ToolKits.savePicture(pBuf , RevLen , strFileName);
			System.out.println("strFileName : " + strFileName);
        }
    }

    /**
     * 远程抓图（异步）
     */
    public void snapPicture1() {
        // send capture picture instruction to device
        NetSDKLib.SNAP_PARAMS stuSnapParams = new NetSDKLib.SNAP_PARAMS();
        stuSnapParams.Channel = 0;            // channel
        stuSnapParams.mode = 0;               // capture picture mode
        stuSnapParams.Quality = 3;            // picture quality
        stuSnapParams.InterSnap = 0;
        stuSnapParams.CmdSerial = 0;

        IntByReference reserved = new IntByReference(0);
        if (netSdk.CLIENT_SnapPictureEx(loginHandle, stuSnapParams, reserved)) {
            System.out.println("CLIENT_SnapPictureEx success");
        } else {
            System.err.printf("CLIENT_SnapPictureEx Failed!" + ToolKits.getErrorCode() + ENUMERROR.getErrorMessage());

        }
    }

    public static class SnapCallback implements NetSDKLib.fSnapRev {
        private static com.netsdk.demo.customize.FireWarnDemo.SnapCallback instance = new com.netsdk.demo.customize.FireWarnDemo.SnapCallback();

        private File path;

        private SnapCallback() {
            path = new File("./Snap/");
            if (!path.exists()) {
                path.mkdir();
            }
        }

        // 回调需是单例
        public static FireWarnDemo.SnapCallback getInstance() {
            return instance;
        }

        public void invoke(NetSDKLib.LLong lLoginID, Pointer pBuf, int RevLen, int EncodeType, int CmdSerial, Pointer dwUser) {
            if (EncodeType == 10) { // jpg
                String fileName = path + File.separator + "AsyncSnapPicture_" + TimeUtils.getTimeStringWithoutSign(new Date()) + ".jpg";
                //保存图片到本地文件
                ToolKits.savePicture(pBuf, RevLen, fileName);
            }
        }
    }

    /**
     * 智能訂閱事件 帶圖
     *
     * @return
     */
    public boolean realLoadPicture() {
        int bNeedPicture = 1;   // 是否需要图片
        int channel = 1; // 订阅全通道
        if (deviceInfo.byChanNum == 1)
            channel = 0;
        int emType = NetSDKLib.EVENT_IVS_FIREWARNING;
        attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, emType, bNeedPicture, FireWarnDemo.AnalyzerDataCB.getInstance(), null, null);
        if (attachHandle.longValue() != 0) {
            System.out.printf("Channel[%d] RealLoad Picture Succeed！\n", channel);
        } else {
            System.err.printf("Channel[%d] RealLoad Picture Failed！ errCode == %s\n errMsg == %s\n", channel, ToolKits.getErrorCode(), ENUMERROR.getErrorMessage());
        }
        return attachHandle.longValue() != 0;
    }

    /**
     * 订阅报警信息(普通事件)
     *
     * @return
     */
    public void startListen() {
        // 设置报警回调函数
        netSdk.CLIENT_SetDVRMessCallBack(FireWarningInfoCallBack.getSingleInstance(), null);
        // 订阅报警
        boolean bRet = netSdk.CLIENT_StartListenEx(loginHandle);
        if (bRet) {
            System.out.println("订阅报警成功.");
        } else {
            System.err.printf("订阅报警失败! error:%d\n", netSdk.CLIENT_GetLastError() + ENUMERROR.getErrorMessage());
        }
    }

    /**
     * 退订报警信息(普通事件)
     *
     * @return
     */
    public void stopListen() {
        boolean bRet = netSdk.CLIENT_StopListen(loginHandle);
        if (bRet) {
            System.out.println("取消订阅报警信息.");
        }
    }

    public static class FireWarningInfoCallBack implements NetSDKLib.fMessCallBackEx1 {
        private static FireWarningInfoCallBack singleInstance = new FireWarningInfoCallBack();

        public static FireWarningInfoCallBack getSingleInstance() {
            return singleInstance;
        }

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

        /**
         * @param lCommand
         * @param lLoginID
         * @param pStuEvent
         * @param dwBufLen
         * @param strDeviceIP
         * @param nDevicePort
         * @param bAlarmAckFlag
         * @param nEventID
         * @param dwUser
         * @return
         * @description 普通事件回調
         */
        @Override
        public boolean invoke(int lCommand, NetSDKLib.LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP, NativeLong nDevicePort, int bAlarmAckFlag, NativeLong nEventID, Pointer dwUser) {
            switch (lCommand) {
                case NetSDKLib.NET_ALARM_FIREWARNING_INFO: { // 0X31da 热成像火情事件信息上报(对应结构体 ALARM_FIREWARNING_INFO_DETAIL)
                    dealData(pStuEvent);
                    new Thread(new Runnable() {
                        @Override
                        public void run() {
                            /**
                             * 抓圖
                             */
                            int bNeedPicture = 1;   // 是否需要图片
                            int channel = -1; // 订阅全通道
                            int emType = NetSDKLib.EVENT_IVS_FIREWARNING;
                            AnalyzerDataCB analyzerDataCB = AnalyzerDataCB.getInstance();
                            NetSDKLib.LLong attachHandle = netSdk.CLIENT_RealLoadPictureEx(lLoginID, channel, emType, bNeedPicture, analyzerDataCB, null, null);
                            if (attachHandle.longValue() != 0) {
                                System.out.printf("Channel[%d] RealLoad Picture Succeed！\n", channel);
                            } else {
                                System.err.printf("Channel[%d] RealLoad Picture Failed！ errCode == %s\n errMsg == %s\n", channel, ToolKits.getErrorCode(), ENUMERROR.getErrorMessage());
                            }
                        }
                    }).start();
                    break;
                }
                case NetSDKLib.NET_ALARM_FIREWARNING: { // 0x31b5 热成像着火点事件 (对应结构体 ALARM_FIREWARNING_INFO)
                    dealData4FireWarning(pStuEvent);
                    break;
                }

                case NetSDKLib.NET_START_LISTEN_FINISH_EVENT: {// 订阅事件接口完成异步通知事件, 信息为 START_LISTEN_FINISH_RESULT_INFO
                    dealData4ListenFinish(pStuEvent);
                    break;
                }

                default: {
                    System.out.printf("其他事件 0x%x\n", lCommand);
                    break;
                }
            }
            return false;
        }

        // 热成像火情事件信息上报事件, 对应事件
        private  void dealData(Pointer pAlarmInfo) {
            NetSDKLib.ALARM_FIREWARNING_INFO_DETAIL msg = new NetSDKLib.ALARM_FIREWARNING_INFO_DETAIL();
            ToolKits.GetPointerData(pAlarmInfo, msg);
            for (int i = 0; i < msg.stuFireWarningInfo.length; i++) {
                System.out.println("msg 距离" + msg.stuFireWarningInfo[i].nDistance);
                System.out.println("msg GPS" + msg.stuFireWarningInfo[i].stuGpsPoint.dwLatidude + "," + msg.stuFireWarningInfo[i].stuGpsPoint.dwLongitude);
                System.out.println("msg 温度" + msg.stuFireWarningInfo[i].nTemperatureUnit);
                NetSDKLib.NET_FIREWARNING_INFO[]    stuFireWarningInfo = msg.stuFireWarningInfo;
                for (int j = 0; j < stuFireWarningInfo.length; j++) {
                    int nFSIDInner = stuFireWarningInfo[j].nFSID;
                    if (nFSID == nFSIDInner && nFSID != -1){
                        System.out.println("同一火情事件！");
                    }

                }
            }

        }

        // 订阅事件接口完成异步通知事件
        private  void dealData4ListenFinish(Pointer pAlarmInfo) {
            START_LISTEN_FINISH_RESULT_INFO msg = new START_LISTEN_FINISH_RESULT_INFO();
            ToolKits.GetPointerData(pAlarmInfo, msg);
            System.out.println("订阅事件接口完成异步通知事件完成" + msg.dwEventResult);
        }

        // 处理事件 坐標信息   热成像着火点报警
        private  void dealData4FireWarning(Pointer pAlarmInfo) {
            NetSDKLib.ALARM_FIREWARNING_INFO msg = new NetSDKLib.ALARM_FIREWARNING_INFO();
            ToolKits.GetPointerData(pAlarmInfo, msg);
            System.out.println("msg 距离" + msg.nDistance);
            System.out.println("msg GPS" + msg.stGpsPoint.dwLongitude + "," + msg.stGpsPoint.dwLatidude);
            System.out.println("msg 温度" + msg.fTemperature);

        }

    }

    private static int nFSID = -1;


    /**
     * 报警事件（智能）回调
     */
    public static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
        private NetSDKLib.DEV_EVENT_FIREWARNING_INFO detail;
        private File path;

        private AnalyzerDataCB() {
            detail = new NetSDKLib.DEV_EVENT_FIREWARNING_INFO();
            path = new File("./Snap/");
            if (!path.exists())
                path.mkdir();
        }

        private static class CallBackHolder {
            private static FireWarnDemo.AnalyzerDataCB instance = new com.netsdk.demo.customize.FireWarnDemo.AnalyzerDataCB();
        }

        public static AnalyzerDataCB getInstance() {
            return AnalyzerDataCB.CallBackHolder.instance;
        }

        // 回调
        public int invoke(NetSDKLib.LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo,
                          Pointer pBuffer, int dwBufSize, Pointer dwUser, int nSequence, Pointer reserved) {
            if (lAnalyzerHandle == null || lAnalyzerHandle.longValue() == 0) {
                return -1;
            }
            switch (dwAlarmType) {
                case NetSDKLib.EVENT_IVS_FIREWARNING: { // 火警事件(对应 DEV_EVENT_FIREWARNING_INFO)
                    dealData(pAlarmInfo);
                    break;
                }
                default: {
                    System.out.println("其他事件： " + dwAlarmType);
                    break;
                }
            }
            return 0;
        }

        // 处理事件
        private void dealData(Pointer pAlarmInfo) {
            ToolKits.GetPointerData(pAlarmInfo, detail);
            nFSID = detail.nFSID;
            System.out.println("火情信息所对应的事件ID" + nFSID);
        }


    }

    /**
     * 停止智能订阅
     */
    public void stopLoadPicture() {
        if (attachHandle.longValue() != 0) {
            netSdk.CLIENT_StopLoadPic(attachHandle);
            attachHandle.setValue(0);
            System.out.println("Had Stop RealLoad Picture！");
        }
    }

    /**
     * 云台配置
     */
    public void cfgPTZ() {
        NetSDKLib.CFG_PTZ_INFO stuPTZ = new NetSDKLib.CFG_PTZ_INFO();
        if (!ToolKits.GetDevConfig(loginHandle, 0, NetSDKLib.CFG_CMD_PTZ, stuPTZ)) {
            System.err.println("Get PTZ Failed!" + ToolKits.getErrorCode());
            return;
        }

        System.out.printf("Enable: %d  PresetId:%d FreeSec:%d \n", stuPTZ.bEnable,
                stuPTZ.stuPresetHoming.nPtzPresetId, stuPTZ.stuPresetHoming.nFreeSec);

        stuPTZ.bEnable = 1;    // 使能
        stuPTZ.stuPresetHoming.nFreeSec = 36; // 归位时间，单位为秒
        if (!ToolKits.SetDevConfig(loginHandle, 0, NetSDKLib.CFG_CMD_PTZ, stuPTZ)) {
            System.err.println("Set PTZ Failed!" + ToolKits.getErrorCode());
        } else {
            System.err.println("Set PTZ Success!");
        }
    }

    // 选中目标进行抓拍
    public void snapPictureByAnalyseObject() {
        NetSDKLib.NET_IN_SNAP_BY_ANALYSE_OBJECT stuIn = new NetSDKLib.NET_IN_SNAP_BY_ANALYSE_OBJECT();

        stuIn.nChannelID = 0;    // 通道号
        stuIn.nSnapObjectNum = 1;    // 抓拍物体个数
        // 抓拍物体信息 (点坐标归一化到[0, 8192]坐标)
        // 实际使用时通过如下计算:  8192.0 * 相对坐标/显示宽(高) 其中左右通过显示的宽度计算，上下通过显示的高度计算
        // 如 (int)(8192.0*80/120)——浮点计算是为了使结果更精确
//    	stuIn.stuSnapObjects[0].stuBoundingBox.left = 0;
//    	stuIn.stuSnapObjects[0].stuBoundingBox.top = 0;
//    	stuIn.stuSnapObjects[0].stuBoundingBox.right = 8192;
//    	stuIn.stuSnapObjects[0].stuBoundingBox.bottom = 8192;
        stuIn.stuSnapObjects[0].stuBoundingBox.left = 4154;
        stuIn.stuSnapObjects[0].stuBoundingBox.top = 3172;
        stuIn.stuSnapObjects[0].stuBoundingBox.right = 5160;
        stuIn.stuSnapObjects[0].stuBoundingBox.bottom = 4380;

        NetSDKLib.NET_OUT_SNAP_BY_ANALYSE_OBJECT stuOut = new NetSDKLib.NET_OUT_SNAP_BY_ANALYSE_OBJECT();
        if (!netSdk.CLIENT_SnapPictureByAnalyseObject(loginHandle, stuIn, stuOut, 5000)) {
            System.err.println("Snap Picture By Analyse Object Failed!" + ToolKits.getErrorCode());
        } else {
            System.err.println("Snap Picture By Analyse Object Success!");
        }
    }

    /**
     * 场景抓拍设置
     */
    public void snapShotWithRulecfg() {
        int nMaxRuleNum = 10;    // 可根据实际修改
        NetSDKLib.NET_SCENE_SNAP_SHOT_WITH_RULE2_INFO[] stuRule = new NetSDKLib.NET_SCENE_SNAP_SHOT_WITH_RULE2_INFO[nMaxRuleNum];
        for (int i = 0; i < nMaxRuleNum; ++i) {
            stuRule[i] = new NET_SCENE_SNAP_SHOT_WITH_RULE2_INFO();
        }

        int emCfgOpType = NET_EM_CFG_OPERATE_TYPE.NET_EM_CFG_SCENE_SNAP_SHOT_WITH_RULE2;    // 场景抓拍设置
        int nChannelID = 0;
        NET_CFG_SCENE_SNAP_SHOT_WITH_RULE2_INFO stuCfg = new NET_CFG_SCENE_SNAP_SHOT_WITH_RULE2_INFO();
        stuCfg.nMaxRuleNum = nMaxRuleNum;
        stuCfg.pstuSceneSnapShotWithRule = new Memory(nMaxRuleNum * stuRule[0].size());
        stuCfg.pstuSceneSnapShotWithRule.clear(nMaxRuleNum * stuRule[0].size());
        ToolKits.SetStructArrToPointerData(stuRule, stuCfg.pstuSceneSnapShotWithRule);

        // 获取
        stuCfg.write();
        if (!netSdk.CLIENT_GetConfig(loginHandle, emCfgOpType, nChannelID,
                stuCfg.getPointer(), stuCfg.size(), 4000, null)) {
            System.err.println("获取场景抓拍配置失败!" + ToolKits.getErrorCode());
            return;
        }

        stuCfg.read();
        ToolKits.GetPointerDataToStructArr(stuCfg.pstuSceneSnapShotWithRule, stuRule);

        System.out.printf("stuRule[0]--PresetID:%d RuleNum:%d RuleType:%x SingleInterval:%d\n",
                stuRule[0].nPresetID, stuRule[0].nRetSnapShotRuleNum,
                stuRule[0].stuSnapShotWithRule[0].dwRuleType, stuRule[0].stuSnapShotWithRule[0].nSingleInterval[1]);

        // 设置，在获取的基础上设置
        IntByReference restart = new IntByReference(0);
        stuRule[0].stuSnapShotWithRule[0].nSingleInterval[1] = 15; // 抓图时间间隔
        ToolKits.SetStructArrToPointerData(stuRule, stuCfg.pstuSceneSnapShotWithRule);
        stuCfg.write();
        if (!netSdk.CLIENT_SetConfig(loginHandle, emCfgOpType, nChannelID,
                stuCfg.getPointer(), stuCfg.size(), 4000, restart, null)) {
            System.err.println("设置场景抓拍配置失败!" + ToolKits.getErrorCode() + " \n errMsg: " + ENUMERROR.getErrorMessage());
        } else {
            System.err.println("设置场景抓拍配置成功!");
        }
    }


    public void RunTest() {
        CaseMenu menu = new CaseMenu();
        menu.addItem(new CaseMenu.Item(this, "开启订阅普通和智能事件", "attachAllEvent"));
        menu.addItem(new CaseMenu.Item(this, "开启退订普通和智能事件", "attachAllEvent"));
        menu.addItem(new CaseMenu.Item(this, "远程抓图", "snapPicture"));
        menu.run();
    }

    /**
     * 开启智能、普通事件订阅
     */
    public void attachAllEvent(){
        realLoadPicture(); // 根据产品定义，智能事件会在报警首尾各报一次 <-- 有图无坐标
        startListen(); // 该事件在报警发生中间隔上报  <-- 有坐标无图
    }

    /**
     * 退订智能、普通事件
     */
    public void deAttachAllEvent(){
        stopLoadPicture();
        stopListen();
    }


    /**
     * Parameter for login
     */
    ////////////////////////////////////////////////////////////////
    private String ip = "172.32.101.59"; //"10.11.16.168";
    private int port = 37777;
    private String username = "admin";
    private String password = "admin123";

    ////////////////////////////////////////////////////////////////
    public static void main(String[] args) {
        FireWarnDemo demo = new FireWarnDemo();
        demo.InitTest();
        System.out.println("Run Test");
        demo.RunTest();
        demo.EndTest();
    }
}