video-pc/widgets/recorderwidget.h

#pragma once

#include <QWidget>
#include <QVBoxLayout>
#include <QHBoxLayout>
#include <QPushButton>
#include <QLabel>
#include <QCheckBox>
#include <QComboBox>
#include <QGroupBox>
#include <QTimer>
#include <QTime>
#include <QStatusBar>
#include <QOpenGLWidget>
#include <QOpenGLFunctions>
#include <QOpenGLShaderProgram>
#include <QOpenGLTexture>
#include <QMutex>
#include <QThread>
#include <QFuture>
#include <QtConcurrent>

// 引入新的Recorder库
#include "../libs/Recorder/export.h"

/**
 * 基于新Recorder库的录制推流组件
 * 用于替换原有的AvRecorder实现
 */
class RecorderWidget : public QWidget
{
    Q_OBJECT

public:
    struct Settings {
        std::string liveUrl = "rtmp://127.0.0.1:1935/stream/V1";
        std::string liveName = "stream";
        std::string outputDir = ".";
        int videoBitRate = 8000000;  // 8Mbps
        int videoFrameRate = 30;
        int videoQuality = 100;
        int audioBitRate = 128000;   // 128kbps
    };

public:
    explicit RecorderWidget(QWidget *parent = nullptr);
    ~RecorderWidget();

    // 设置录制推流参数
    void setSettings(const Settings& settings);
    
    // 开始录制
    bool startRecording();
    
    // 停止录制
    void stopRecording();
    
    // 开始推流
    bool startStreaming();
    
    // 停止推流
    void stopStreaming();
    
    // 获取状态栏
    QWidget* statusBar() const { return m_statusBar; }

public slots:
    void onRecordButtonClicked();
    void onStreamButtonClicked();
    void onSettingsButtonClicked();
    void onAudioDeviceButtonClicked();
    void updatePreview();
    void updateStatus();

signals:
    void recordingStarted();
    void recordingStopped();
    void streamingStarted();
    void streamingStopped();
    void errorOccurred(const QString& error);

private:
    void initUI();
    void initStatusBar();
    void initRecorder();
    void releaseRecorder();
    void setupCallbacks();
    void refreshAudioDevices();
    void refreshVideoEncoders();
    
    // 回调函数
    static void onDurationCallback(uint64_t duration);
    static void onErrorCallback(int error);
    static void onDeviceChangeCallback(int type);
    static void onPreviewYUVCallback(const unsigned char *data, unsigned int size, int width, int height, int type);
    static void onPreviewAudioCallback();

private:
    // UI组件
    QVBoxLayout* m_mainLayout = nullptr;
    QOpenGLWidget* m_previewWidget = nullptr;
    QPushButton* m_recordButton = nullptr;
    QPushButton* m_streamButton = nullptr;
    QPushButton* m_settingsButton = nullptr;
    QPushButton* m_audioDeviceButton = nullptr;
    QCheckBox* m_drawCursorCheckBox = nullptr;
    QCheckBox* m_syncRecordCheckBox = nullptr;
    QComboBox* m_encoderComboBox = nullptr;
    QComboBox* m_micComboBox = nullptr;
    QComboBox* m_speakerComboBox = nullptr;
    QStatusBar* m_statusBar = nullptr;
    QLabel* m_statusLabel = nullptr;
    QLabel* m_timeLabel = nullptr;
    QLabel* m_encoderLabel = nullptr;
    
    // 定时器
    QTimer* m_previewTimer = nullptr;
    QTimer* m_statusTimer = nullptr;
    
    // 录制相关
    Settings m_settings;
    AMRECORDER_SETTING m_recorderSetting;
    AMRECORDER_CALLBACK m_callbacks;
    
    // 设备信息
    AMRECORDER_DEVICE* m_micDevices = nullptr;
    AMRECORDER_DEVICE* m_speakerDevices = nullptr;
    AMRECORDER_ENCODERS* m_encoders = nullptr;
    int m_micCount = 0;
    int m_speakerCount = 0;
    int m_encoderCount = 0;
    
    // 状态
    bool m_isRecording = false;
    bool m_isStreaming = false;
    bool m_isInitialized = false;
    QTime m_recordStartTime;
    
    // 预览相关
    QMutex m_previewMutex;
    QByteArray m_previewData;
    int m_previewWidth = 0;
    int m_previewHeight = 0;
    
    // 静态实例指针，用于回调
    static RecorderWidget* s_instance;
};