video-pc/mainwindow.cpp

#include "mainwindow.h"

#include <QSplitter>
#include <QStackedWidget>
#include <QTextBrowser>
#include <QThread>

#include <util/asynchelper.h>
#include <util/jsonmapper.h>
#include <util/layoutbuilder.h>

#include "api/userapi.h"
#include "appevent.h"
#include "capturer/video/wgc/App.h"
#include "network/websocketclient.h"
#include "qboxlayout.h"
#include "ui/av_recorder.h"
#include "views/loginwindow.h"

#include "widgets/bubbletip.h"
#include "widgets/chatView/chat1/chatview.h"
#include "widgets/chatView/chatwindow.h"
#include "widgets/framelessbase.h"
#include "widgets/maskoverlay.h"
#include "widgets/userprofilewidget.h"

#include <QDebug>
#include <QFutureWatcher>

#include <api/loginapi.h>

#include "util/qformatter.h"

#include <qtpromise/qpromise.h>
#include <qtpromise/qpromisefuture.h>
#include <qtpromise/qpromisehelpers.h>

#include "AvPlayer2/PlayWidget.h"

class MainWidget : public QWidget
{
public:
    explicit MainWidget(QWidget *parent = nullptr)
        : QWidget(parent)
        , userProfile(nullptr)
        , chatView(nullptr)
    {
        setupUI();
        initConnect();
    }

    ~MainWidget()
    {
        if (userProfile) {
            delete userProfile;
            userProfile = nullptr;
        }
    }
    void setupUI()
    {
        // 只创建一次布局和静态控件
        userProfile = new UserProfileWidget(this);
        chatView = new ChatWindow();
        chatView->setMinimumWidth(400);

        QWidget *rightWidget = new QWidget;
        QVBoxLayout *vbox = new QVBoxLayout(rightWidget);
        vbox->setContentsMargins(0, 0, 0, 0);
        vbox->addWidget(userProfile, 0);
        vbox->addWidget(chatView, 1);

        splitter = new QSplitter(Qt::Horizontal, this);
        // 先插入一个占位控件
        playerContainer = new QWidget(this);
        splitter->addWidget(playerContainer);
        splitter->addWidget(rightWidget);

        splitter->setStretchFactor(0, 70);
        splitter->setStretchFactor(1, 30);

        QVBoxLayout *mainLayout = new QVBoxLayout(this);
        mainLayout->addWidget(splitter, 1);
        mainLayout->setContentsMargins(0, 0, 0, 0);
        mainLayout->setSpacing(0);

        setLayout(mainLayout);

        // QWidget *playerWidget = nullptr;
        // if (currentRole == "role.admin") {
        //     playerWidget = new AvRecorder(this);
        // } else {
        //     playerWidget = new PlayWidget(this);
        // }

        // // 其余代码不变
        // userProfile = new UserProfileWidget(this);
        // chatView = new ChatWindow();
        // chatView->setMinimumWidth(400);

        // QWidget *widget = new QWidget;
        // QVBoxLayout *vbox = new QVBoxLayout(widget);
        // vbox->setContentsMargins(0, 0, 0, 0);
        // vbox->addWidget(userProfile, 0);
        // vbox->addWidget(chatView, 1);

        // QSplitter *splitter = new QSplitter(Qt::Horizontal, this);
        // splitter->addWidget(playerWidget);
        // splitter->addWidget(widget);

        // splitter->setStretchFactor(0, 70);
        // splitter->setStretchFactor(1, 30);

        // QWidget *statusBar = nullptr;
        // if (auto av = qobject_cast<AvRecorder *>(playerWidget)) {
        //     statusBar = av->statusBar();
        // } else {
        //     statusBar = new QWidget(this); // 或者 PlayWidget 也实现 statusBar
        //     statusBar->setFixedHeight(1);
        // }

        // QVBoxLayout *mainLayout = new QVBoxLayout(this);
        // mainLayout->addWidget(splitter, 1);
        // mainLayout->addWidget(statusBar, 0);
        // mainLayout->setContentsMargins(0, 0, 0, 0);
        // mainLayout->setSpacing(0);

        // setLayout(mainLayout);
    }
    void initConnect()
    {
        connect(AppEvent::instance(),
                &AppEvent::connectionStateChanged,
                this,
                [this](bool connected) {
                    if (userProfile) {
                        userProfile->setStatus(connected ? "在线" : "离线");
                    }
                });
    }

    // 动态插入或替换播放器控件
    void setPlayerWidget(QWidget *newPlayer)
    {
        if (playerWidget) {
            playerWidget->setParent(nullptr);
            playerWidget->deleteLater();
        }
        playerWidget = newPlayer;
        playerWidget->setParent(playerContainer);

        // 清空 playerContainer 的布局
        QLayout *oldLayout = playerContainer->layout();
        if (oldLayout) {
            QLayoutItem *item;
            while ((item = oldLayout->takeAt(0)) != nullptr) {
                if (item->widget())
                    item->widget()->setParent(nullptr);
                delete item;
            }
            delete oldLayout;
        }
        QVBoxLayout *vbox = new QVBoxLayout(playerContainer);
        vbox->setContentsMargins(0, 0, 0, 0);
        vbox->addWidget(playerWidget);
    }

    // 角色切换时调用
    void setRole(const QStringList &roleList)
    {
        QWidget *newPlayer = nullptr;
        if (roleList.contains("role.admin")) {
            newPlayer = new AvRecorder(this);
        } else {
            newPlayer = new PlayWidget(this);
        }
        setPlayerWidget(newPlayer);
    }

    QString currentRole;

    QSplitter *splitter = nullptr;
    QWidget *playerContainer = nullptr;
    QWidget *playerWidget = nullptr;
    UserProfileWidget *userProfile = nullptr;
    ChatWindow *chatView = nullptr;
};

MainWindow::MainWindow(QWidget *parent)
    : TMainWindow(parent)
{
    setWindowTitle("test");
    setCentralWidget(new QWidget(this));
    // 创建主布局
    layout = new QVBoxLayout(centralWidget());
    layout->setContentsMargins(0, 0, 0, 0);

    // 创建堆叠部件
    stackedWidget = new QStackedWidget(this);
    layout->addWidget(stackedWidget);

    // 创建登录页面
    loginWidget = new LoginWidget(this);
    stackedWidget->addWidget(loginWidget);

    mainWidget = nullptr;

    connect(loginWidget, &LoginWidget::loginRequested, this, &MainWindow::onLoginSuccess);
    resize(1280, 600);

    // 显示登录页面
    stackedWidget->setCurrentWidget(loginWidget);
}

MainWindow::~MainWindow() {}

void MainWindow::createMainWindow()
{
    if (mainWidget) {
        delete mainWidget;
        mainWidget = nullptr;
    }
    // 主窗口
    mainWidget = new MainWidget(this);
    stackedWidget->addWidget(mainWidget);

    // 退出处理
    connect(mainWidget->userProfile, &UserProfileWidget::logoutClicked, this, [this]() {
        AppEvent *appEvent = AppEvent::instance();
        appEvent->setJwtToken(QString());
        appEvent->setRefreshTime(0);

        if (mainWidget->userProfile) {
            stackedWidget->setCurrentWidget(loginWidget);
        }
    });
}

void MainWindow::onLoginSuccess(const QString &username, const QString &password)
{
    // 准备登录参数
    AuthApi::LoginParams loginParams;
    loginParams.username = username;
    loginParams.password = password;

    // 使用链式调用处理异步请求
    // AsyncHelper::http(AuthApi::loginApi(loginParams))
    //     .withMask(stackedWidget)
    //     .onSuccess([this](const HttpResponse &response) {
    //         qDebug() << response.code << response.data << response.message;
    //         if (response.code != 200) {
    //             BubbleTip::showTip(this, response.message, BubbleTip::Top, 3000);
    //             return;
    //         }
    //         QString token;
    //         if (response.data.isObject()) {
    //             QJsonObject dataObj = response.data.toObject();
    //             token = dataObj["accessToken"].toString();
    //             AppEvent::instance()->setJwtToken(token);
    //             authLogin();
    //         }

    //         if (!token.isEmpty()) {
    //             qDebug() << "登录成功，获取到的令牌：" << token;
    //             // 存储令牌
    //         }
    //     })
    //     .onError(
    //         [this](const QString &error) { BubbleTip::showTip(this, error, BubbleTip::Top, 2000); })
    //     .exec(); // 执行请求

    QFuture<HttpResponse> loginApiFuture = AuthApi::loginApi(loginParams);

    // 使用fromQFuture将QFuture转换为QPromise
    QtPromise::QPromise<HttpResponse> loginApiPromise = QtPromise::resolve(loginApiFuture);

    MaskOverlay::instance()->show(stackedWidget, 0, MaskOverlay::ActiveWindow);

    loginApiPromise
        .then([this](const HttpResponse &response) {
            qDebug() << response.code << response.data << response.message;
            if (response.code != 0) {
                BubbleTip::showTip(this, response.message, BubbleTip::Top, 3000);
                return;
            }
            QString token;
            if (response.data.isObject()) {
                QJsonObject dataObj = response.data.toObject();
                qDebug() << dataObj;
                token = dataObj["token"].toString();
                AppEvent::instance()->setJwtToken(token);
                authLogin(); // 获取登录信息
            }

            if (!token.isEmpty()) {
                qDebug() << "登录成功，获取到的令牌：" << token;
                // 存储令牌
            }
        })
        .finally([]() { MaskOverlay::instance()->hide(); });
}
void MainWindow::authLogin()
{
    // 创建两个异步操作的Promise
    QFuture<HttpResponse> userInfoFuture = getUserInfoApi();
    QFuture<HttpResponse> accessCodesFuture = AuthApi::getAccessCodesApi();

    // 使用fromQFuture将QFuture转换为QPromise
    QtPromise::QPromise<HttpResponse> userInfoPromise = QtPromise::resolve(userInfoFuture);
    QtPromise::QPromise<HttpResponse> accessCodesPromise = QtPromise::resolve(accessCodesFuture);

    // 使用QtPromise::all等待所有Promise完成
    QtPromise::all(QVector<QtPromise::QPromise<HttpResponse>>{userInfoPromise, accessCodesPromise})
        .then([this](const QVector<HttpResponse> &results) {
            // 处理用户信息

            // 用户信息: 200 QJsonValue(object, QJsonObject({"id":"e52e6b47-f4d3-43a6-b481-570ffcc1c9db","role":[],"username":"admin"})) "success"
            // 访问代码: 203 QJsonValue(null) "Error transferring http://127.0.0.1:8888/api/auth/codes - server replied: Not Found"
            const HttpResponse &userInfo = results[0];
            qDebug() << "用户信息:" << userInfo.code << userInfo.data << userInfo.message;
            UserInfo user = JsonMapper::fromJson<UserInfo>(userInfo.data);
            // 处理访问代码
            const HttpResponse &accessCodes = results[1];
            qDebug() << "访问代码:" << accessCodes.code << accessCodes.data << accessCodes.message;

            // 处理成功的逻辑
            if (userInfo.code == 0 && accessCodes.code == 0) {
                qDebug() << "所有请求成功完成";
                // 这里可以添加后续处理逻辑
            }
            qDebug() << "当前角色:" << user.roleName;
            AppEvent::instance()->setRoles(user.roleName);

            createMainWindow();
            // 创建主界面部件
            mainWidget->userProfile->setUsername(user.username);
            mainWidget->chatView->initWebsocket();
            mainWidget->setRole(user.roleName);

            stackedWidget->addWidget(mainWidget);
            stackedWidget->setCurrentWidget(mainWidget);
        })
        .fail([this](const std::exception &e) {
            // 处理错误
            qWarning() << "登录后处理失败:" << e.what();
            BubbleTip::showTip(this,
                               QString("请求失败: %1").arg(e.what()),
                               BubbleTip::Top,
                               3000,
                               BubbleTip::Type::Error);
        });
}