QFD2/QFD/mindmap/api/http/JQLibrary/main.cpp

// Qt lib import
#include <QImage>
#include <QJsonObject>
#include <QtCore>
// JQLibrary import
#include "JQHttpServer.h"
#include "JQNet.h"

void startUp(const QPointer<JQHttpServer::Session>& session)
{
    const auto&& reply = JQNet::HTTP::get("http://127.0.0.1:7998/api/request/startUp");
    qDebug() << reply.first << reply.second;
    QJsonObject obj;
    if (reply.first) {
        obj["code"] = 0;
    } else {
        obj["code"] = -2;
        obj["msg"] = "time out";
    }
    session->replyJsonObject(obj);
}
void login(const QPointer<JQHttpServer::Session>& session)
{
    const auto&& reply = JQNet::HTTP::get("http://127.0.0.1:7998/api/request/login");
    qDebug() << reply.first << reply.second;
    QJsonObject obj;
    if (reply.first) {
        obj["code"] = 0;
    } else {
        obj["code"] = -2;
        obj["msg"] = "time out";
    }
    session->replyJsonObject(obj);
}
void startChat(const QPointer<JQHttpServer::Session>& session)
{
    QString targetId = session->requestUrlQuery()["targetId"];
    QString url = "http://127.0.0.1:7998/api/request/startChat?";
    url.append("targetId=" + targetId);

    const auto&& reply = JQNet::HTTP::get(url);
    qDebug() << reply.first << reply.second;
    QJsonObject obj;
    if (reply.first) {
        obj["code"] = 0;
    } else {
        obj["code"] = -2;
        obj["msg"] = "time out";
    }
    session->replyJsonObject(obj);
}
void logoutLinkdood(const QPointer<JQHttpServer::Session>& session)
{

    QString token = session->requestUrlQuery()["token"];
    QString server = session->requestUrlQuery()["server"];
    QString url = "http://127.0.0.1:7998/api/request/logoutLinkdood?";
    url.append("token=" + token);
    url.append("&server=" + server);

    const auto&& reply = JQNet::HTTP::get(url);
    qDebug() << reply.first << reply.second;
    QJsonObject obj;
    if (reply.first) {
        obj["code"] = 0;
    } else {
        obj["code"] = -2;
        obj["msg"] = "time out";
    }
    session->replyJsonObject(obj);
}
void exitLinkdood(const QPointer<JQHttpServer::Session>& session)
{
    const auto&& reply = JQNet::HTTP::get("http://127.0.0.1:7998/api/request/exitLinkdood");
    qDebug() << reply.first << reply.second;
    QJsonObject obj;
    if (reply.first) {
        obj["code"] = 0;
    } else {
        obj["code"] = -2;
        obj["msg"] = "time out";
    }
    session->replyJsonObject(obj);
}
int main(int argc, char* argv[])
{
    QCoreApplication a(argc, argv);

    // 设置最大处理线程数
    JQHttpServer::TcpServerManage tcpServerManage(10);
    tcpServerManage.setHttpAcceptedCallback([](const QPointer<JQHttpServer::Session>& session) {
        // 回调发生在新的线程内，不是主线程，请注意线程安全
        qDebug() << Q_FUNC_INFO << session->requestUrlPath() << "," << session->requestBody() << ","
                 << session->requestUrl();

        if (session->requestUrlPath() == "/api/request/startUp") {
            startUp(session);
        } else if (session->requestUrlPath() == "/api/request/login") {
            login(session);
        } else if (session->requestUrlPath() == "/api/request/startChat") {
            startChat(session);
        } else if (session->requestUrlPath() == "/api/request/logoutLinkdood") {
            logoutLinkdood(session);
        } else if (session->requestUrlPath() == "/api/request/exitLinkdood") {
            exitLinkdood(session);
        } else if (session->requestUrlPath() == "/api/time") {
            qDebug() << QDateTime::currentDateTime();
            qDebug() << session->requestUrlQuery();
        } else {
            QJsonObject obj;
            obj["code"] = -1;
            obj["msg"] = "invalid url.";
            session->replyJsonObject(obj);
        }
    });
    qDebug() << "listen:" << tcpServerManage.listen(QHostAddress::Any, 3333);

    return a.exec();
}