package com.ard.work.sdk.hb.service;

import com.ard.work.sdk.hb.lib.HBNetSDK;
import lombok.extern.slf4j.Slf4j;
import java.io.FileWriter;

/**
 * @Description: 视频流回调函数
 * @ClassName: StreamCallBack
 * @Author: 刘苏义
 * @Date: 2026年03月11日08:05:40
 **/
@Slf4j
public class StreamCallBack implements HBNetSDK.PHB_NET_STREAMDATA_PROC {
    private final String id;
    public StreamCallBack(String id) {
        this.id = id;
    }

    @Override
    public void invoke(long lRealHandle, HBNetSDK.HB_NET_DATACALLBACK data) {
        // 1. 最外层的try-catch捕获所有异常
        try {
            // 2. 参数检查
            if (data == null) {
                return;
            }

            data.read();   // 必须加
            // 3. 只处理视频数据
            if ((data.dwDataType == 2 || data.dwDataType == 64) && data.dwDataSize > 0) {

                // 4. 再次检查数据有效性
                if (data.pFrame == null) {
                    return;
                }

                // 5. 安全的拷贝数据
                byte[] frameData = new byte[data.dwDataSize];
                try {
                    data.pFrame.read(0, frameData, 0, data.dwDataSize);
                } catch (IndexOutOfBoundsException e) {
                    // 数据越界异常
                    System.err.println("数据越界: " + e.getMessage());
                    return;
                }

                // 6. 入队（非阻塞）
                CameraStreamQueueManager.offerDataToQueue(id,frameData);
                //queue.offer(frameData);
            }

        } catch (Throwable t) {
            // 7. 捕获所有异常和错误，防止崩溃
            System.err.println("回调发生严重错误: " + t.getMessage());
            t.printStackTrace();

            // 8. 记录到日志文件
            try {
                FileWriter fw = new FileWriter("/root/test/callback_error.log", true);
                fw.write(new java.util.Date() + " - " + t.toString() + "\n");
                fw.close();
            } catch (Exception e) {
                // 忽略
            }
        }
    }
}