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.enumeration.EM_EVENT_IVS_TYPE;
import com.netsdk.lib.enumeration.EM_EVENT_TYPE;
import com.netsdk.lib.structure.*;
import com.netsdk.lib.utils.Initialization;
import com.sun.jna.NativeLong;
import com.sun.jna.Pointer;

import java.io.File;
import java.io.UnsupportedEncodingException;
import java.util.Objects;

/**
 * @author 291189
 * @version 1.0
 * @description ERR220822100 
 * @date 2022/9/1 19:39
 */
public class RadarRegionDemo extends Initialization {

    int channel=0;
    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, EM_EVENT_TYPE.EVENT_IVS_RADAR_REGION_DETECTION.getType(), bNeedPicture,
                AnalyzerDataCB.getInstance(), null, null);
        if (attachHandle.longValue() != 0) {
            System.out.printf("Chn[%d] CLIENT_RealLoadPictureEx Success\n", channel);
        } else {
            System.out.printf("Chn[%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;
        }

        @Override
        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 (Objects.requireNonNull(EM_EVENT_IVS_TYPE.getEventType(dwAlarmType))) {
                case EVENT_IVS_RADAR_REGION_DETECTION : {
                    System.out.println("雷达警戒区检测事件");

                    DEV_EVENT_RADAR_REGION_DETECTION_INFO msg = new DEV_EVENT_RADAR_REGION_DETECTION_INFO();

                    ToolKits.GetPointerData(pAlarmInfo, msg);
                    /**
                     报警类型 {@link com.netsdk.lib.enumeration.EM_RADAR_ALARM_TYPE}
                     */
                    int emAlarmType = msg.emAlarmType;

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



                    /**
                     触发事件目标的id,范围[0,63]
                     */
                    System.out.println("nTrackID:"+msg.nTrackID);
                    /**
                     触发事件目标的速度，用整型传输，扩大100倍 单位m/s
                     */
                    System.out.println("nSpeed:"+msg.nSpeed);
/**
 触发事件目标的类型的掩码: 0x00未识别目标 0x01目标为人 0x02目标为交通工具 0x03目标为树 0x04目标为建筑物 0x05目标为屏幕 0x06目标为动物 0x07目标为大船 0x08目标为中船 0x09目标为小船
 */
                    System.out.println("nObjectType:"+msg.nObjectType);
                    /**
                     当前触发事件目标的像素极坐标值--距离，扩大100倍的结果,单位米
                     */
                    System.out.println("nDistance:"+msg.nDistance);
                    /**
                     当前触发事件目标的极坐标值--角度，扩大100倍的结果，单位度
                     */
                    System.out.println("nAngle:"+msg.nAngle);


                    /**
                     报警等级
                     */
                    byte[] szAlarmLevel = msg.szAlarmLevel;
                    try {
                        System.out.println("szAlarmLevel:"+new String(szAlarmLevel,encode));
                        /**
                         报警输入通道号
                         */
                        System.out.println("nAlarmChannel:"+msg.nAlarmChannel);
                        /**
                         RFID卡片信息个数
                         */
                        int nRFIDCardIdNum = msg.nRFIDCardIdNum;
                        System.out.println("nRFIDCardIdNum:"+nRFIDCardIdNum);


                        NET_RFID_CARD_INFO[] stuRFIDCardId = msg.stuRFIDCardId;

                        for (int i=0;i<nRFIDCardIdNum;i++){
                            NET_RFID_CARD_INFO info = stuRFIDCardId[i];


                            byte[] szCardId = info.szCardId;

                            System.out.println("szCardId:"+new String(szCardId,encode));
                        }

                        int nstuSceneImageExNum = msg.nstuSceneImageExNum;

                        NetSDKLib.SCENE_IMAGE_INFO_EX[] stuSceneImageEx = msg.stuSceneImageEx;


                        for(int i=0;i<nstuSceneImageExNum;i++){
                            NetSDKLib.SCENE_IMAGE_INFO_EX stuSceneImage = stuSceneImageEx[i];

                            //图片
                            if (stuSceneImage != null && stuSceneImage.nLength > 0) {
                                String picture = picturePath + "/" + System.currentTimeMillis() + "_stuImgaeInfo.jpg";
                                ToolKits.savePicture(pBuffer, stuSceneImage.nOffSet, stuSceneImage.nLength, picture);
                            }
                        }

                        int nDistance = msg.nDistance;
                        System.out.println("nDistance:"+nDistance);
                        int nAngle = msg.nAngle;
                        System.out.println("nAngle:"+nAngle);

                    } 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 startListen() {



        // 设置报警回调函数
        netSdk.CLIENT_SetDVRMessCallBack(fAlarmAccessDataCB.getInstance(), null);

        // 订阅报警
        boolean bRet = netSdk.CLIENT_StartListenEx(loginHandle);
        if (!bRet) {
            System.err.println("订阅报警失败! LastError = 0x%x\n" + netSdk.CLIENT_GetLastError());
        } else {
            System.out.println("订阅报警成功.");
        }
    }

    /**
     * 报警事件回调
     */
    private static class fAlarmAccessDataCB implements NetSDKLib.fMessCallBack {
        private static fAlarmAccessDataCB instance = new fAlarmAccessDataCB();

        private fAlarmAccessDataCB() {
        }

        public static fAlarmAccessDataCB getInstance() {
            return instance;
        }

        public boolean invoke(int lCommand, NetSDKLib.LLong lLoginID, Pointer pStuEvent, int dwBufLen, String strDeviceIP,
                              NativeLong nDevicePort, Pointer dwUser) {
            switch (lCommand) {
                case NetSDKLib.NET_ALARM_RADAR_REGIONDETECTION: {// 雷达区域检测事件(对应结构体 ALARM_RADAR_REGIONDETECTION_INFO)

                    ALARM_RADAR_REGIONDETECTION_INFO msg = new ALARM_RADAR_REGIONDETECTION_INFO();
                    ToolKits.GetPointerData(pStuEvent, msg);
                    System.out.println(" 雷达区域检测事件 时间(UTC):" + msg.stuTime.toStringTime() +
                            " 通道号:" + msg.nChannelID +" RFID卡片数量:" + msg.nCardNum+" 报警等级:" + msg.nAlarmLevel);

                    /**
                     触发事件目标的id,范围[0,63]
                     */
                    System.out.println("nTrackID:"+msg.nTrackID);
                    /**
                     触发事件目标的速度，用整型传输，扩大100倍 单位m/s
                     */
                    System.out.println("nSpeed:"+msg.nSpeed);
/**
 触发事件目标的类型的掩码: 0x00未识别目标 0x01目标为人 0x02目标为交通工具 0x03目标为树 0x04目标为建筑物 0x05目标为屏幕 0x06目标为动物 0x07目标为大船 0x08目标为中船 0x09目标为小船
 */
                    System.out.println("nObjectType:"+msg.nObjectType);
                        /**
                         当前触发事件目标的像素极坐标值--距离，扩大100倍的结果,单位米
                         */
                    System.out.println("nDistance:"+msg.nDistance);
                         /**
                          当前触发事件目标的极坐标值--角度，扩大100倍的结果，单位度
                         */
                    System.out.println("nAngle:"+msg.nAngle);
                    NET_RADAR_REGIONDETECTION_RFIDCARD_INFO[] stuCardInfo = msg.stuCardInfo;
                    try {
                        System.out.println("----------------卡片ID开始----------------");
                        for (int i = 0; i < msg.nCardNum; i++) {
                            System.out.println("卡片ID[：" +(i+1)+"]"+ new String(stuCardInfo[i].szCardID, encode));
                        }
                        System.out.println("----------------卡片ID结束----------------");
                    } catch (UnsupportedEncodingException e) {
                        e.printStackTrace();
                    }
            /**
             当前触发事件目标的像素极坐标值--距离，扩大100倍的结果,单位米
             */
                    int nDistance = msg.nDistance;

                    System.out.println("nDistance:"+nDistance);
                    int nAngle = msg.nAngle;
                    System.out.println("nAngle:"+nAngle);

                    break;
                }
            }
            return true;
        }
    }

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

    // 订阅句柄
    private static NetSDKLib.LLong RadarAlarmHandle = new NetSDKLib.LLong(0);
    //订阅雷达的报警点信息
    public void attachRadarAlarmInfo() {

        // 先退订，设备不会对重复订阅作校验，重复订阅后会有重复的事件返回
        if(RadarAlarmHandle.longValue()!=0){
            this.detachRadarAlarmInfo();
        }

        NET_IN_RADAR_ALARMPOINTINFO pIn = new NET_IN_RADAR_ALARMPOINTINFO();
        pIn.nChannel = 0;
        pIn.cbAlarmPointInfo = CBRadarAlarmPointInfoCallBack.getInstance();
        pIn.write();
        NET_OUT_RADAR_ALARMPOINTINFO pOut = new NET_OUT_RADAR_ALARMPOINTINFO();
        pOut.write();
        RadarAlarmHandle = netSdk.CLIENT_AttachRadarAlarmPointInfo(loginHandle, pIn.getPointer(), pOut.getPointer(), 3000);
        if (RadarAlarmHandle.longValue() == 0) {
            System.out.printf("attachDadarAlarmInfo fail, ErrCode=%x\n", netSdk.CLIENT_GetLastError());
        } else {
            System.out.println("attachDadarAlarmInfo success");
        }
    }

    public void detachRadarAlarmInfo() {
        if (RadarAlarmHandle.longValue() != 0) {
            netSdk.CLIENT_DetachRadarAlarmPointInfo(RadarAlarmHandle);
        } else {
            System.out.println("订阅句柄为空,请先订阅");
        }
    }

    /**
     * 雷达报警点信息回调
     */
    private static class CBRadarAlarmPointInfoCallBack implements NetSDKLib.fRadarAlarmPointInfoCallBack {

        private CBRadarAlarmPointInfoCallBack() {
        }

        private static class CallBackHolder {
            private static CBRadarAlarmPointInfoCallBack instance = new CBRadarAlarmPointInfoCallBack();
        }

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

        @Override
        public void invoke(NetSDKLib.LLong lLoginId, NetSDKLib.LLong lAttachHandle, Pointer pBuf, int dwBufLen, Pointer pReserved,
                           Pointer dwUser) {
            System.out.println("雷达报警点信息回调");
            // TODO Auto-generated method stub
            NET_RADAR_NOTIFY_ALARMPOINTINFO radarInfo = new NET_RADAR_NOTIFY_ALARMPOINTINFO();
            ToolKits.GetPointerData(pBuf, radarInfo);
            for (int i = 0; i < radarInfo.nNumAlarmPoint; i++) {
                System.out.println("通道号:" + radarInfo.nChannel + "\n点类型:" + radarInfo.stuAlarmPoint[i].nPointType
                        + "\n当前点所属的防区编号:" + radarInfo.stuAlarmPoint[i].nRegionNumber + "\n点所指对象的类型:"
                        + radarInfo.stuAlarmPoint[i].emObjectType + "\n点所属的轨迹号:" + radarInfo.stuAlarmPoint[i].nTrackID
                        + "\n当前点像素极坐标值-距离:" + radarInfo.stuAlarmPoint[i].nDistance + "\n当前点像素极坐标值-角度:"
                        + radarInfo.stuAlarmPoint[i].nAngle +
                        "\n正在跟踪目标的球机的IP地址:" + new String(radarInfo.stuAlarmPoint[i].szTrackerIP)
                        +"\n当前点速度:" + radarInfo.stuAlarmPoint[i].nSpeed + "\n\n");
            }

        }
    }

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

    menu.addItem((new CaseMenu.Item(this , "startListen" , "startListen")));
    menu.addItem((new CaseMenu.Item(this , "stopListen" , "stopListen")));

    menu.addItem((new CaseMenu.Item(this , "attachRadarAlarmInfo" , "attachRadarAlarmInfo")));
    menu.addItem((new CaseMenu.Item(this , "detachRadarAlarmInfo" , "detachRadarAlarmInfo")));

    menu.run();
}

    public static void main(String[] args) {
        RadarRegionDemo radarDemo=new RadarRegionDemo();
        InitTest("10.11.9.191",37777,"admin","admin456");
        radarDemo.RunTest();
        LoginOut();

    }


}