ts/TransmitterSwitch/WebAPI/FromWebAPI.cpp

#include "FromWebAPI.h"

#include <QVector>
#include <QString>
#include <QUuid>
#include <QApplication>

#include "LHQLogAPI.h"
#include "TransmitterSwitchInfo.h"


FromWebAPI::FromWebAPI()
{
    
}

FromWebAPI::~FromWebAPI()
{
    if(m_httpApi != nullptr)
    {
        delete m_httpApi;
        m_httpApi = nullptr;
    }
}


/* 初始化WebApi */
bool FromWebAPI::initWebApi(const QString& url, const QString& serverID, const QString& serverKey)
{
    if(m_httpApi == nullptr)
    {
        m_httpApi = new lhhttpapi;
    }
#if defined(Q_OS_WIN)
    #ifdef QT_DEBUG
    QString libFile = QString("%1/LHSqlWebInterfaced.dll").arg(QApplication::applicationDirPath());
    #else
    QString libFile = QString("%1/LHSqlWebInterface.dll").arg(QApplication::applicationDirPath());
    #endif
#elif defined(Q_OS_LINUX)
    #ifdef QT_DEBUG
    QString libFile = QString("%1/libLHSqlWebInterfaced.so").arg(QApplication::applicationDirPath());
    #else
    QString libFile = QString("%1/libLHSqlWebInterface.so").arg(QApplication::applicationDirPath());
    #endif
#endif
    if(!m_httpApi->Load(libFile))
    {
        LH_WRITE_ERROR("Load WebAPI failed");
        return false;
    }
    LH_WRITE_LOG_DEBUG(QString("URL:%1").arg(url));
    LH_WRITE_LOG_DEBUG(QString("ServerID:%1").arg(serverID));
    LH_WRITE_LOG_DEBUG(QString("ServerKey:%1").arg(serverKey));

    m_httpApi->DBInit(url.toStdString().c_str());
    
    int ret = 0;

#ifdef QT_DEBUG
    /* 获取服务器列表 */
    char serverList[8192];
    ret = m_httpApi->DBGetServerList(serverList, 8192);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("Get server list failed:%1, error info:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    // LH_WRITE_LOG(QString("\nGet server list success:%1").arg(serverList));
#endif

    /* 登录，第二个参数是限制的服务 */
    ret = m_httpApi->DBLogin("", serverID, serverKey, m_userToken);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("Login failed:%1, error info:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    LH_WRITE_LOG("Login success!");

    return true;
}

/* 获取设备信息 */
bool FromWebAPI::getDeviceInfo(QMap<QString, DeviceInfo>& mapDevice)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    
    nJson json0;
    json0["opName"] = "ESM8C_GetDevice";
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("从数据库获取设备失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    /* 解析获取到的JSON数据 */
    // LH_WRITE_LOG_DEBUG(strRet);

    try 
    {
        nJson json1 = nJson::parse(strRet.toStdString());
        int retCode = json1["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取设备数据失败");
            return false;
        }
        nJson result = json1["result"];
        for(auto& it : result)
        {
            DeviceInfo DevInfo;
            QString devName = QString::fromStdString(it["dname"].get<std::string>());
            DevInfo.devName = devName;
            DevInfo.DID = it["did"].is_null() ? -1 : it["did"].get<int>();
            DevInfo.DTID = it["dtid"].is_null() ? -1 : it["dtid"].get<int>();
            DevInfo.MPID = it["mpid"].is_null() ? -1 : it["mpid"].get<int>();
            DevInfo.PTTypeCode = it["pttypecode"].is_null() ? -1 : it["pttypecode"].get<int>();
            DevInfo.ChannelID = it["chnid"].is_null() ? -1 : it["chnid"].get<int>();
            if(DevInfo.ChannelID <= 0)
            {
                LH_WRITE_LOG_DEBUG(QString("通道ID错误:%1").arg(DevInfo.ChannelID));
                continue;
            }

            /* 查找对应的设备类型，根据PTTypeCode来查找，这个是唯一的 */
            auto devType = DevTypeContainer.getDevType(DevInfo.PTTypeCode);
            if(devType.PTTypeCode < 0)
            {
                LH_WRITE_LOG_DEBUG(QString("未找到设备类型:%1").arg(DevInfo.PTTypeCode));
                continue;
            }

            DevInfo.DevType = devType;
            /* 检查有没有设置主备 */
            int devMB = it["dClass"].is_null() ? -1 : it["dClass"].get<int>();
            if(devMB < 0)
            {
                LH_WRITE_ERROR(QString("设备类型:%1《主/备》 类型为空").arg(DevInfo.DevType.PTTypeCode));
                continue;
            }
            mapDevice.insert(DevInfo.devName, DevInfo);
        }

        LH_WRITE_LOG(QString("获取设备数据成功，设备数目:%1").arg(mapDevice.size()));

    } catch (const nJson::parse_error& e) {
        LH_WRITE_ERROR("解析ESM-8C设备数据失败");
        return false;
    }
    catch (const nJson::exception& e)
    {
        LH_WRITE_ERROR("解析ESM-8C设备数据失败");
        return false;
    }
    catch(...)
    {
        LH_WRITE_ERROR("解析ESM-8C设备数据失败");
        return false;
    }

    return true;
}



/**
 * @brief 将数据写入EQM数据库，这里不需要模版编号和名称，编号都设置成0
 * 
 * @param list 
 * @return true 
 * @return false 
 */
bool FromWebAPI::insertData(QList<ExecPlanItemInfo>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    /* 先删除表格中的数据 */
    deleteAllTransmitterPlan();

    QDate zeroDate(1970,1,1);
    /* 写入数据 */
    nJson json0 = nJson::array();
    try{
        for(auto& it : list)
        {
            nJson json1;
            json1["opName"] = "ESM8C_InsertDataToExecPlan";
            json1["Key"] = QUuid::createUuid().toString().toStdString();
            nJson json2;
            json2["ExecType"] = it.ExecType;
            json2["WeekDay"] = it.WeekDay;
            json2["Date"] = it.date.toString("yyyy-MM-dd").toStdString();
            json2["ExecTime"] = it.execTime.toString("hh:mm:ss").toStdString();
            json2["DeviceName"] = it.devName.toStdString();
            json2["ActionName"] = it.actionName.toStdString();
            json2["ActionID"] = static_cast<int>(it.actionID);
            /* 根据设备名称找到设备信息 */
            auto devInfo = DeviceContainer.getDevice(it.devName);
            if(devInfo.PTTypeCode < 0)
            {
                LH_WRITE_ERROR(QString("未找到设备:%1").arg(it.devName));
                continue;
            }
            json2["PTTypeCode"] = devInfo.PTTypeCode;
            json2["DID"] = devInfo.DID;
            json2["MPID"] = devInfo.MPID;
            json2["ChannelID"] = devInfo.ChannelID;


            json1["paramList"] = json2;

            json0.push_back(json1);
        }
    }catch (const nJson::parse_error& e) {
        SPDLOG_ERROR("生成json数据失败:{}", e.what());
        return false;
    }
    catch (const nJson::exception& e)
    {
        SPDLOG_ERROR("生成json数据失败:{}", e.what());
        return false;
    }
    catch (...)
    {
        SPDLOG_ERROR("生成json数据失败");
        return false;
    }


    /* 将json写入本地文件 */
#ifdef C_DEBUG
    QString fileJson(QString::fromStdString(json0.dump(4)));
    // LH_WRITE_LOG_DEBUG("\n" + fileJson);
    
    // QString filePath = QApplication::applicationDirPath() + QString("ExecPlanData.json");
    // SPDLOG_LOGGER_DEBUG(m_logger,"To EQM Json写入文件:{}", filePath.toStdString());
    // QFile file(filePath);
    // if(file.open(QIODevice::WriteOnly | QIODevice::Truncate))
    // {
    //     file.write(fileJson.toUtf8());
    //     file.close();
    // }else {
    //     SPDLOG_LOGGER_ERROR(m_logger,"打开文件失败:{}", filePath.toStdString());
    // }
#endif
    /* 写入EQM数据库 */
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("写入EQM数据库失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    LH_WRITE_LOG("写入EQM数据库成功");


    return true;
}

/**
 * @brief 获取tExecPlan表格数据，获取到的数据会根据设备名查找对应的设备信息，如果没有查找到，就抛弃这个计划
 * 
 * @param list 
 * @return true 
 * @return false 
 */
bool FromWebAPI::getExecPlanData(QList<ExecPlanItemInfo>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    nJson json0;
    json0["opName"] = "ESM8C_GetExecPlan";
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("从EQM获取tExecPlan表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    /* 解析获取到的JSON数据 */
    // SPDLOG_LOGGER_DEBUG(m_logger,"获取执行计划:\n{}",strRet.toStdString());
    try 
    {
        nJson json1 = nJson::parse(strRet.toStdString());
        int retCode = json1["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取tExecPlan表格数据失败");
            return false;
        }
        nJson result = json1["result"];
        for(auto& it : result)
        {
            ExecPlanItemInfo info;
            info.devName = QString::fromStdString(it["deviceName"].get<std::string>());
            if(!DeviceContainer.findDevice(info.devName))
            {
                LH_WRITE_LOG(QString("未找到设备:%1").arg(info.devName));
                continue;
            }

            info.ExecType = it["execType"].get<int>();
            info.WeekDay = it["weekDay"].get<int>();
            auto tmpDate = it["date"].is_null() ? "" : it["date"].get<std::string>();
            if(!tmpDate.empty())
            {
                info.date = QDate::fromString(QString::fromStdString(tmpDate),"yyyy-MM-dd");
            }
            info.execTime = QTime::fromString(QString::fromStdString(it["execTime"].get<std::string>()),"hh:mm:ss");
            info.actionName = QString::fromStdString(it["actionName"].get<std::string>());
            info.actionID = it["actionID"].get<int>();

            list.append(info);
        }

        LH_WRITE_LOG(QString("获取tExecPlan表格数据成功，数据数目:%1").arg(list.size()));

    } catch (const nJson::parse_error& e) {
        LH_WRITE_ERROR(QString("解析tExecPlan表格数据失败:%1").arg(e.what()));
        return false;
    }
    catch (const nJson::exception& e)
    {
        LH_WRITE_ERROR(QString("解析tExecPlan表格数据失败:%1").arg(e.what()));
        return false;
    }
    catch(...)
    {
        LH_WRITE_ERROR("解析tExecPlan表格数据失败");
        return false;
    }

    LH_WRITE_LOG_DEBUG(QString("从EQM.tExecPlan表格获取数据成功，数据数目:%1").arg(list.size()));


    return true;
}


/* 获取EQM数据库中的模版编号 */
bool FromWebAPI::getEQMTemplateID(QList<int>& listId)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    nJson json0;
    json0["opName"] = "ESMC_GetTemplateNumFromExecPlan";
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("从EQM获取模版编号失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    /* 解析获取到的JSON数据 */
    LH_WRITE_LOG_DEBUG(strRet);
    try 
    {
        nJson json1 = nJson::parse(strRet.toStdString());
        int retCode = json1["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取模版编号失败");
            return false;
        }
        nJson result = json1["result"];
        for(auto& it : result)
        {
            if(it["templateNum"].is_null())
            {
                LH_WRITE_ERROR("模版编号为空");
                continue;
            }
            auto id = it["templateNum"].get<int>();
            if(listId.contains(id))
            {
                continue;
            }
            listId.append(id);
        }

    } catch (const nJson::parse_error& e) {
        LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
        return false;
    }
    catch (const nJson::exception& e)
    {
        LH_WRITE_ERROR(QString("解析模版编号失败:%1").arg(e.what()));
        return false;
    }
    catch(...)
    {
        LH_WRITE_ERROR("解析模版编号失败");
        return false;
    }

    return true;
}


/* 删除所有行 */
bool FromWebAPI::deleteAllRow()
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    nJson json0;
    json0["opName"] = "ESM8C_DeleteAllRow";
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("删除所有行失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    
    return true;
}


/* 删除所有的发射机计划 */
bool FromWebAPI::deleteAllTransmitterPlan()
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    /* 查找出有多少发射机类型 */
    QList<int> listPttypeCodeID;
    for(auto& it : DevTypeContainer.getMapDevType())
    {
        listPttypeCodeID.append(it.PTTypeCode);
    }
    nJson json0;
    json0["opName"] = "ESM8C_DeleteRowBasePTTypeCode";
    for(const auto& it : listPttypeCodeID)
    {
        json0["paramList"].clear();
        nJson json1;
        json1["PTTypeCode"] = it;
        json0["paramList"].push_back(json1);
        QString strCmd = QString::fromStdString(json0.dump());
        QString strRet;
        auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet);
        if(ret < 0)
        {
            LH_WRITE_ERROR(QString("删除发射机(%3)计划失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)).arg(it));
        }else {
            LH_WRITE_LOG(QString("删除发射机(%1)计划成功!").arg(it));
        }
    }
    return true;
}


/* 保存到模板 */
bool FromWebAPI::saveTemplate(const QString& templateName, QList<ExecPlanItemInfo>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    nJson json0 = nJson::array();
    for(const auto& it : list)
    {
        nJson json1;
        json1["opName"] = "TMS_ExecPlanSaveToTemplate";
        json1["Key"] = QUuid::createUuid().toString().toStdString();
        nJson json2;

        json2["templateName"] = templateName.toStdString();
        json2["execDate"] = it.date.toString("yyyy-MM-dd").toStdString();
        json2["execTime"] = it.execTime.toString("hh:mm:ss").toStdString();
        json2["deviceName"] = it.devName.toStdString();
        json2["actionName"] = it.actionName.toStdString();
        json2["actionID"] = static_cast<int>(it.actionID);

        json1["paramList"] = json2;
        json0.push_back(json1);
    }

    /* 将json写入本地文件 */
#ifdef C_DEBUG
    // QString fileJson(QString::fromStdString(json0.dump(4)));
    // LH_WRITE_LOG_DEBUG("\n" + fileJson);
#endif
    /* 写入EQM数据库 */
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("保存到模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    LH_WRITE_LOG("保存到模板成功");

    return true;
    

}

/* 获取模板内容 */
bool FromWebAPI::getTemplate(QString templateName, QList<ExecPlanItemInfo>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    nJson json0;
    json0["opName"] = "TMS_GetExecPlanTemplateData";
    nJson json1;
    json1["templateName"] = templateName.toStdString();
    json0["paramList"] = json1;
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("获取模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    /* 解析获取到的JSON数据 */
    try
    {
        nJson json2 = nJson::parse(strRet.toStdString());
        int retCode = json2["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取模板失败");
            return false;
        }
        nJson result = json2["result"];
        for(auto& it : result)
        {
            ExecPlanItemInfo info;
            info.devName = QString::fromStdString(it["deviceName"].get<std::string>());
            if(!DeviceContainer.findDevice(info.devName))
            {
                LH_WRITE_LOG(QString("未找到设备:%1").arg(info.devName));
                continue;
            }
            auto tmpDate = it["execDate"].is_null() ? "" : it["execDate"].get<std::string>();
            if(!tmpDate.empty())
            {
                info.date = QDate::fromString(QString::fromStdString(tmpDate),"yyyy-MM-dd");
            }
            info.execTime = QTime::fromString(QString::fromStdString(it["execTime"].get<std::string>()),"hh:mm:ss");
            info.actionName = QString::fromStdString(it["actionName"].get<std::string>());
            info.actionID = it["actionID"].get<int>();

            list.append(info);
        }

        LH_WRITE_LOG(QString("获取模板成功，数据数目:%1").arg(list.size()));
    }
    catch (const nJson::parse_error& e)
    {
        LH_WRITE_ERROR(QString("解析模板失败:%1").arg(e.what()));
        return false;
    }
    catch (const nJson::exception& e)
    {
        LH_WRITE_ERROR(QString("解析模板失败:%1").arg(e.what()));
        return false;
    }
    catch(...)
    {
        LH_WRITE_ERROR("解析模板失败");
        return false;
    }

    return true;
}

/* 获取模板列表 */
bool FromWebAPI::getTemplateList(QStringList& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    nJson json0;
    json0["opName"] = "TMS_GetExecPlanTemplateList";
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("获取模板列表失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    /* 解析获取到的JSON数据 */
    // LH_WRITE_LOG_DEBUG(strRet);
    try 
    {
        nJson json1 = nJson::parse(strRet.toStdString());
        int retCode = json1["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取模板列表失败");
            return false;
        }
        nJson result = json1["result"];
        for(auto& it : result)
        {
            if(it["templateName"].is_null())
            {
                LH_WRITE_ERROR("模板名称为空");
                continue;
            }
            auto name = QString::fromStdString(it["templateName"].get<std::string>());
            if(list.contains(name))
            {
                continue;
            }
            list.append(name);
        }

    } catch (const nJson::parse_error& e) {
        LH_WRITE_ERROR(QString("解析模板列表失败:%1").arg(e.what()));
        return false;
    }
    catch (const nJson::exception& e)
    {
        LH_WRITE_ERROR(QString("解析模板列表失败:%1").arg(e.what()));
        return false;
    }
    catch(...)
    {
        LH_WRITE_ERROR("解析模板列表失败");
        return false;
    }

    /* 对模版按照名称排序 */
    list.sort();

    return true;
}

/* 删除一个模板 */
bool FromWebAPI::deleteTemplate(const QString& name)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    
    nJson json0;
    json0["opName"] = "TMS_DeleteExecPlanTemplate";
    nJson json1;
    json1["templateName"] = name.toStdString();
    json0["paramList"] = json1;
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet);
    if(ret < 0)
    {
        LH_WRITE_ERROR(QString("删除模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }

    return true;
}