package com.netsdk.demo.customize;

import com.netsdk.demo.util.CaseMenu;
import com.netsdk.demo.util.EventTaskHandler;
import com.netsdk.demo.util.QueueGeneration;
import com.netsdk.lib.NetSDKLib;
import com.netsdk.lib.ToolKits;
import com.netsdk.lib.enumeration.ENUMERROR;
import com.netsdk.lib.structure.DEV_EVENT_NONMOTOR_ENTRYING_INFO;
import com.sun.jna.Pointer;
import com.sun.jna.ptr.IntByReference;

import java.io.BufferedOutputStream;
import java.io.DataOutputStream;
import java.io.File;
import java.io.FileOutputStream;

import static com.netsdk.lib.Utils.getOsPrefix;

/**
 * className：NonMotorEntryingDemo
 * description： 前端电梯电动车禁入半球、IVSS708，SDK对接第三方平台，实现报警信息在小区平台上展现
 * author：251589
 * createTime：2020/12/21 11:26
 *
 * @version v1.0
 */
public class NonMotorEntryingDemo {
    static NetSDKLib netSdk = NetSDKLib.NETSDK_INSTANCE;

    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";
        }
    }


    // 设备信息
    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 NonMotorEntryingDemo.SDKGeneralService.DisConnect cb = new NonMotorEntryingDemo.SDKGeneralService.DisConnect();
            }

            public static final NonMotorEntryingDemo.SDKGeneralService.DisConnect getInstance() {
                return NonMotorEntryingDemo.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.NonMotorEntryingDemo.SDKGeneralService.HaveReConnect cb = new com.netsdk.demo.customize.NonMotorEntryingDemo.SDKGeneralService.HaveReConnect();
            }

            public static final com.netsdk.demo.customize.NonMotorEntryingDemo.SDKGeneralService.HaveReConnect getInstance() {
                return com.netsdk.demo.customize.NonMotorEntryingDemo.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日志（可选）
            NetSDKLib.LOG_SET_PRINT_INFO setLog = new NetSDKLib.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(mIp, mPort, mUserName,
                mPassword, nSpecCap, pCapParam, deviceInfo, nError);

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

        return loginHandle.longValue() != 0;
    }


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

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


    /**
     * 智能事件回调
     */
    public static class AnalyzerDataCallBack implements NetSDKLib.fAnalyzerDataCallBack {
        private static AnalyzerDataCallBack singleInstance;

        public static AnalyzerDataCallBack getSingleInstance() {
            if (singleInstance == null) {
                singleInstance = new AnalyzerDataCallBack();
            }
            return singleInstance;
        }


        private QueueGeneration eventCBQueueService = new QueueGeneration();    // 保存图片用队列

        public AnalyzerDataCallBack() {
            eventCBQueueService.init();
        }

        private final String imageSaveFolder = "pic/";      // 图片保存路径


        @Override
        public int invoke(NetSDKLib.LLong lAnalyzerHandle, int dwAlarmType, Pointer pAlarmInfo, Pointer pBuffer, int dwBufSize, Pointer dwUser, int nSequence, Pointer reserved) {
            File path = new File("./EventPicture/");
            if (!path.exists())
                path.mkdir();
            //public static final int EVENT_IVS_NONMOTOR_ENTRYING = 0x0000030C; // 非机动车进入电梯(对应 DEV_EVENT_NONMOTOR_ENTRYING_INFO)
            switch (dwAlarmType) {
                case NetSDKLib.EVENT_IVS_NONMOTOR_ENTRYING: {
                    System.out.println("非机动车进入电梯事件！");
                    DEV_EVENT_NONMOTOR_ENTRYING_INFO info = new DEV_EVENT_NONMOTOR_ENTRYING_INFO();
                    ToolKits.GetPointerData(pAlarmInfo, info);

                    ////////////////////////////////// 事件主要信息 ///////////////////////////
                    StringBuilder mainInfo = new StringBuilder()
                            .append("事件ID: ").append(info.nEventID).append("\n")
                            .append("过车时间(毫秒时间戳): ").append(info.PTS).append("\n")
                            .append("规则ID: ").append(info.nRuleID).append("\n")
                            .append("智能事件所属大类: ").append(info.emClassType).append("\n");
                    System.out.println("事件主要信息" + mainInfo.toString());
                    //保存全景图
                    if (info.stuSceneImage.nLength > 0) {
                        String strFileName = path + "\\" + System.currentTimeMillis() + "全景图.jpg";
                        ToolKits.savePicture(pBuffer, info.stuSceneImage.nOffSet, info.stuSceneImage.nLength, strFileName);
                    } else {
                        System.out.println("非机动车进入电梯事件无全景图");
                    }
                    break;
                }
                default:
                    System.out.println("其他事件-> " + dwAlarmType);
                    break;
            }
            return 0;
        }

        // 处理保存图片
        private class SavePicHandler implements EventTaskHandler {
            private static final long serialVersionUID = 1L;
            private final byte[] imgBuffer;
            private final int length;
            private final String savePath;

            public SavePicHandler(Pointer pBuf, int dwBufOffset, int dwBufSize, String sDstFile) {
                this.imgBuffer = pBuf.getByteArray(dwBufOffset, dwBufSize);
                this.length = dwBufSize;
                this.savePath = sDstFile;
            }

            @Override
            public void eventCallBackProcess() {
                System.out.println("保存图片中...路径：" + savePath);
                File path = new File(imageSaveFolder);
                if (!path.exists()) path.mkdir();
                try {
                    DataOutputStream out = new DataOutputStream(new BufferedOutputStream(new FileOutputStream(savePath)));
                    out.write(imgBuffer, 0, length);
                    out.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }

    private NetSDKLib.fAnalyzerDataCallBack analyzerDataCB = AnalyzerDataCallBack.getSingleInstance();

    /**
     * 订阅智能事件
     */
    public void attachEventRealLoadPic() {
        int bNeedPicture = 1;
        int channel = 0; // 订阅全通道
        attachHandle = netSdk.CLIENT_RealLoadPictureEx(loginHandle, channel, NetSDKLib.EVENT_IVS_ALL, bNeedPicture, analyzerDataCB, null, null);
        if (attachHandle.longValue() != 0) {
            System.out.println("订阅： " + channel + " 通道号成功！");
        } else {
            System.out.println("订阅： " + channel + " 通道号失败！" + ToolKits.getErrorCode() + ENUMERROR.getErrorMessage());
        }
    }

    /**
     * 退订智能事件
     */
    public void detachEventRealLoadPic() {
        if (attachHandle.longValue() != 0) {
            netSdk.CLIENT_StopLoadPic(attachHandle);
        }
    }

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

    public void RunTest() {
        CaseMenu menu = new CaseMenu();
        menu.addItem(new CaseMenu.Item(this, "事件订阅", "attachEventRealLoadPic"));
        menu.addItem(new CaseMenu.Item(this, "退订事件", "detachEventRealLoadPic"));
        menu.run();
    }

    /**
     * Parameter for login
     */
    ////////////////////////////////////////////////////////////////
    private String mIp = "10.34.3.110";//"172.12.66.45"; //"172.12.66.45"; //"10.11.16.168"; // 172.23.12.179
    private int mPort = 37777;
    private String mUserName = "admin";
    private String mPassword = "admin";

    ////////////////////////////////////////////////////////////////
    public static void main(String[] args) {
        NonMotorEntryingDemo demo = new NonMotorEntryingDemo();
        demo.InitTest();
        demo.RunTest();
        demo.EndTest();
    }

}