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_BREED_DETECTION_INFO;
import com.netsdk.lib.structure.NET_VAOBJECT_ANIMAL_INFO;
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 ERR220413169 
 * @date 2022/4/15 15:18
 */
public class BreedDetectionDemo extends Initialization {

    private static String ipAddr = "172.11.1.113";
    private static int port = 37777;
    private static String user = "admin";
    private static String password = "admin123";

    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_BREED_DETECTION, 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 (dwAlarmType) {
                case NetSDKLib.EVENT_IVS_BREED_DETECTION : {
                    System.out.println("智慧养殖检测事件");
                    //智慧养殖检测事件 (对应 DEV_EVENT_BREED_DETECTION_INFO)
                    DEV_EVENT_BREED_DETECTION_INFO msg=new DEV_EVENT_BREED_DETECTION_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);
                    //事件名称
                    byte[] szName = msg.szName;
                    try {
                        System.out.println("szName utf-8："+new String(szName,"utf-8"));
                        System.out.println("szName gbk："+new String(szName,"gbk"));
                    } catch (UnsupportedEncodingException e) {
                        e.printStackTrace();
                    }
//  事件发生的时间
                    System.out.println("UTC："+msg.UTC);
// 事件ID
                    int nEventID = msg.nEventID;
                    System.out.println("事件ID："+nEventID);
//智能事件所属大类 {@link com.netsdk.lib.NetSDKLib.EM_CLASS_TYPE}
                    System.out.println("emClassType："+msg.emClassType);
//全景广角图
                    NetSDKLib.SCENE_IMAGE_INFO_EX stuSceneImage = msg.stuSceneImage;

                    if ( stuSceneImage.nLength > 0) {
                        String senceExPicture = picturePath + "\\" + System.currentTimeMillis() + "senceEx.jpg";
                        ToolKits.savePicture(pBuffer, stuSceneImage.nOffSet, stuSceneImage.nLength, senceExPicture);
                    }
                    //检测到的物体个数
                    int nObjectNum = msg.nObjectNum;
                    System.out.println("nObjectNum:"+nObjectNum);
//检测到的物体信息
                    NET_VAOBJECT_ANIMAL_INFO[] stuObjects
                            = msg.stuObjects;

                    for (int i=0;i<nObjectNum;i++){
                        NET_VAOBJECT_ANIMAL_INFO stuObject = stuObjects[i];
//物体ID，每个ID表示一个唯一的物体
                        System.out.println("nObjectID："+stuObject.nObjectID);
//智慧养殖检测目标子类型 {@link com.netsdk.lib.enumeration.EM_BREED_DETECT_CATEGORY_TYPE}
                        System.out.println("emCategoryType："+stuObject.emCategoryType);
//对象重量, 单位: g
                        System.out.println("nObjectWeight："+stuObject.nObjectWeight);

                        NetSDKLib.SCENE_IMAGE_INFO_EX stuImageData = stuObject.stuImageData;
                            System.out.println("stuImageData.nLength:"+stuImageData.nLength);
                        System.out.println("stuImageData.szFilePath:"+new String(stuImageData.szFilePath));

                        if ( stuImageData.nLength > 0) {
                            String sencePicture = picturePath + "\\" + System.currentTimeMillis() + "sence.jpg";
                            ToolKits.savePicture(pBuffer, stuImageData.nOffSet, stuImageData.nLength, sencePicture);
                        }
                    }


                    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()
    {
        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.run();
    }

    public static void main(String[] args){
        InitTest(ipAddr, port, user, password);
        BreedDetectionDemo breedDetectionDemo=new BreedDetectionDemo();
        breedDetectionDemo.RunTest();
        LoginOut();
    }

}