package com.ycl.api.DH.utils;

import com.sun.jna.Pointer;
import com.ycl.api.DH.lib.NetSDKLib;
import com.ycl.api.DH.lib.ToolKits;
import com.ycl.api.DH.module.LoginModule;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.PreDestroy;
import org.springframework.beans.factory.annotation.Value;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.nio.ByteBuffer;

/**
 * 初始化
 *
 * @author Yan Xu
 * @version 1.0
 * @date 2021/8/6
 * Copyright © goodits
 */
@Component
@Slf4j
public class InitUtils {

    @Value("${spring.profiles.active}")
    private String activeEnv;
    /**
     * // 设备断线回调: 通过 CLIENT_Init 设置该回调函数，当设备出现断线时，SDK会调用该函数
     */
    private static class DisConnect implements NetSDKLib.fDisConnect {
        @Override
        public void invoke(NetSDKLib.LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
            log.info("Device[{}}] Port[{}}] DisConnect!\n", pchDVRIP, nDVRPort);
        }
    }

    /**
     * // 网络连接恢复，设备重连成功回调
     * // 通过 CLIENT_SetAutoReconnect 设置该回调函数，当已断线的设备重连成功时，SDK会调用该函数
     */
    private static class HaveReConnect implements NetSDKLib.fHaveReConnect {
        @Override
        public void invoke(NetSDKLib.LLong m_hLoginHandle, String pchDVRIP, int nDVRPort, Pointer dwUser) {
            log.info("ReConnect Device[{}] Port[{}]\n", pchDVRIP, nDVRPort);

        }
    }


    /**
     * 写成静态主要是防止被回收
     */
    private static class AnalyzerDataCB implements NetSDKLib.fAnalyzerDataCallBack {
        private AnalyzerDataCB() {
        }

        public static AnalyzerDataCB INSTANCE = new AnalyzerDataCB();

        public static AnalyzerDataCB getInstance() {
            return INSTANCE;
        }

        public int invoke(
                NetSDKLib.LLong lAnalyzerHandle,
                int dwAlarmType,
                Pointer pAlarmInfo,
                Pointer pBuffer,
                int dwBufSize,
                Pointer dwUser,
                int nSequence,
                Pointer reserved) {
            if (lAnalyzerHandle.longValue() == 0 || pAlarmInfo == null) {
                return -1;
            }

            switch (dwAlarmType) {

                case NetSDKLib.EVENT_IVS_ACCESS_CTL:// /< 门禁事件
                {
                    NetSDKLib.DEV_EVENT_ACCESS_CTL_INFO msg = new NetSDKLib.DEV_EVENT_ACCESS_CTL_INFO();
                    ToolKits.GetPointerData(pAlarmInfo, msg);
                    // 获取门禁信息
                    //打印msg中的卡信息和用戶信息
                    int szCardNo = ByteBuffer.wrap(msg.szCardNo).getInt();
                    System.out.println("卡号：" + szCardNo);
                    int szUserId = ByteBuffer.wrap(msg.szUserID).getInt();
                    System.out.printf("用户ID：%d\n", szUserId);

                    log.info("门禁事件：卡号：{}，用户ID：{}", szCardNo, szUserId);
                    // 释放内存
                    msg = null;
                    System.gc();

                    break;
                }
                case NetSDKLib.EVENT_IVS_FACERECOGNITION: // /< 人脸识别事件
                {
                    // DEV_EVENT_FACERECOGNITION_INFO 结构体比较大，new对象会比较耗时， ToolKits.GetPointerData内容拷贝是不耗时的。
                    // 如果多台设备或者事件处理比较频繁，可以考虑将 static DEV_EVENT_FACERECOGNITION_INFO msg = new
                    // DEV_EVENT_FACERECOGNITION_INFO(); 改为全局。
                    // 写成全局，是因为每次new花费时间较多, 如果改为全局，此case下的处理需要加锁
                    // 加锁，是因为共用一个对象，防止数据出错

                    // 耗时800ms左右
                    NetSDKLib.DEV_EVENT_FACERECOGNITION_INFO msg = new NetSDKLib.DEV_EVENT_FACERECOGNITION_INFO();
                    // 耗时20ms左右
                    ToolKits.GetPointerData(pAlarmInfo, msg);
                    // 保存人脸对比信息

                    // 释放内存
                    msg = null;
                    System.gc();

                    break;
                }
                case NetSDKLib.EVENT_IVS_FACEDETECT: // /< 人脸检测
                {
                    NetSDKLib.DEV_EVENT_FACEDETECT_INFO msg = new NetSDKLib.DEV_EVENT_FACEDETECT_INFO();
                    ToolKits.GetPointerData(pAlarmInfo, msg);
                    // 保存图片，获取图片缓存

                    // 释放内存
                    msg = null;
                    System.gc();
                    break;
                }
                default:
                    break;
            }

            return 0;
        }
    }

    /**
     * 设备断线通知回调
     */
    private static final DisConnect DIS_CONNECT = new DisConnect() {
    };

    /**
     * 网络连接恢复
     */
    private static final HaveReConnect HAVE_RE_CONNECT = new HaveReConnect();


    @PostConstruct
    void init() {
        if("prod".equals(activeEnv)) {
            LoginModule.init(DIS_CONNECT, HAVE_RE_CONNECT);
        }
    }
    @PreDestroy
    void clean(){
        if("prod".equals(activeEnv)) {
            LoginModule.cleanup();
        }
    }
}