package com.netsdk.demo.customize;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.structure.DEV_EVENT_TRAFFIC_DRIVER_ABNORMAL_INFO;
import com.netsdk.lib.structure.NET_TIME_EX;
import com.netsdk.lib.utils.Initialization;
import com.sun.jna.Pointer;
import java.io.File;
import java.io.UnsupportedEncodingException;

/**
 * @author 291189
 * @version 1.0
 * @description ERR211022043
 * @date 2021/11/4 9:22
 */
public class TrafficDriverAbnormalDemo  extends Initialization {

    int channel=-1;
    NetSDKLib.LLong    attachHandle=new NetSDKLib.LLong(0);
    /**
     * 订阅智能任务
     */
    public NetSDKLib.LLong AttachEventRealLoadPic() {
        // 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
        if(attachHandle.longValue()!=0){
            this.DetachEventRealLoadPic();
        }

        // 需要图片
        int bNeedPicture = 1;
        attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, NetSDKLib.EVENT_IVS_TRAFFIC_DRIVER_ABNORMAL, bNeedPicture, AnalyzerDataCB.getInstance(), null, null);
        // attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, NetSDKLib.EVENT_IVS_ALL, bNeedPicture, AnalyzerDataCB.getInstance(), null, null);

        if (attachHandle.longValue() != 0) {
            System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n", channel);
        } else {
            System.out.printf("Ch[%d] CLIENT_RealLoadPictureEx Failed!LastError = %s\n", channel,
                    ToolKits.getErrorCode());
        }

        return attachHandle;
    }
    /**
     * 报警事件（智能）回调
     */
    private static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
        private final File picturePath;
        private static AnalyzerDataCB instance;

        private AnalyzerDataCB() {
            picturePath = new File("./AnalyzerPicture/");
            if (!picturePath.exists()) {
                picturePath.mkdirs();
            }
        }

        public static AnalyzerDataCB getInstance() {
            if (instance == null) {
                synchronized (AnalyzerDataCB.class) {
                    if (instance == null) {
                        instance = new AnalyzerDataCB();
                    }
                }
            }
            return 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_TRAFFIC_DRIVER_ABNORMAL: //   驾驶员异常报警事件(对应 DEV_EVENT_TRAFFIC_DRIVER_ABNORMAL_INFO)


                    DEV_EVENT_TRAFFIC_DRIVER_ABNORMAL_INFO msg=new DEV_EVENT_TRAFFIC_DRIVER_ABNORMAL_INFO();

                    ToolKits.GetPointerData(pAlarmInfo, msg);

                    /** 通道号*/
                    int nChannelID = msg.nChannelID;

                    System.out.println("nChannelID:"+nChannelID);

                    /** 事件动作, 0表示脉冲事件, 1表示持续性事件开始, 2表示持续性事件结束*/
                    int nAction = msg.nAction;
                    System.out.println("nAction:"+nAction);

                    /** GPS信息*/
                    NetSDKLib.NET_GPS_STATUS_INFO stuGPSStatusInfo = msg.stuGPSStatusInfo;
                        //定位时间
                        NetSDKLib.NET_TIME revTime = stuGPSStatusInfo.revTime;

                        System.out.println("revTime:"+revTime);

                    byte[] dvrSerial = stuGPSStatusInfo.DvrSerial;

                    String serial = new String(dvrSerial);// 设备序列号
                             System.out.println("serial:"+serial);

                    double longitude = stuGPSStatusInfo.longitude;//经度(单位是百万分之度,范围0-360度)
                    System.out.println("longitude:"+longitude);

                    double  latidude = stuGPSStatusInfo.latidude; // 纬度(单位是百万分之度,范围0-180度)
                    System.out.println("latidude:"+latidude);

                    double height=stuGPSStatusInfo.height;        // 高度(米)
                    System.out.println("height:"+height);

                    double  angle=stuGPSStatusInfo.angle;         // 方向角(正北方向为原点,顺时针为正)
                    System.out.println("angle:"+angle);

                    double   speed=stuGPSStatusInfo.speed;       // 速度(单位km/H)
                    System.out.println("speed:"+speed);

                    /** 事件发生的时间*/
                     NET_TIME_EX UTC= msg.UTC;
                    System.out.println("UTC:"+UTC);
                    /**  违章关联视频FTP上传路径 */
                    try {
                        String videoPath = new String(msg.szVideoPath, "GBK");

                        System.out.println("videoPath:"+videoPath);

                    } catch (UnsupportedEncodingException e) {
                        e.printStackTrace();
                    }


                    break;
                default:
                    System.out.println("其他事件--------------------"+ dwAlarmType);
                    break;
            }

            return 0;
        }
    }

    /**
     * 停止侦听智能事件
     */
    public void DetachEventRealLoadPic() {
        if (this.attachHandle.longValue() != 0) {
            netSdk.CLIENT_StopLoadPic(this.attachHandle);
        }
    }


    /**
     * 加载测试内容
     */
    public void RunTest() {
        CaseMenu menu = new CaseMenu();
        menu.addItem(new CaseMenu.Item(this, "订阅智能事件", "AttachEventRealLoadPic"));
        menu.addItem(new CaseMenu.Item(this, "停止侦听智能事件", "DetachEventRealLoadPic"));
        menu.run();
    }

    public static void main(String[] args) {


        Initialization.InitTest("10.35.221.232", 37777, "admin", "admin123");
        new TrafficDriverAbnormalDemo().RunTest();
        Initialization.LoginOut();
    }
}