ts/TransmitterSwitch/WebAPI/FromWebAPI.cpp

#include "FromWebAPI.h"

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

#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(!m_httpApi->Load())
    {
        LH_WRITE_ERROR("Load WebAPI failed");
        return false;
    }

    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("Get 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.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_ERROR(QString("通道ID错误:%1").arg(DevInfo.ChannelID));
                continue;
            }

            /* 查找对应的设备类型，根据PTTypeCode来查找，这个是唯一的 */
            auto devType = DevTypeContainer.getDevType(DevInfo.PTTypeCode);
            if(devType.PTTypeCode < 0)
            {
                LH_WRITE_ERROR(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;
    }
    /* 先删除表格中的数据 */
    if(!deleteAllRow())
    {
        LH_WRITE_ERROR("删除EQM.tExecPlan表格中的数据失败");
        return false;
    }

    nJson json0 = nJson::array();
    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") == "1970-01-01" ? nullptr : 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);
        // json2["PTTypeCode"] = it.cfgDev->PTTypeCode < 0 ? 0 : it.cfgDev->PTTypeCode;
        // if(it.cfgDev == nullptr)
        // {
        //     json2["DID"] = 0;
        //     json2["DTID"] = 0;
        //     json2["ChannelID"] = 0;
        // }else 
        // {
        //     json2["DID"] = (it.cfgDev->DID < 0 ? 0 : it.cfgDev->DID);
        //     json2["DTID"] = (it.cfgDev->DTID < 0 ? 0 : it.cfgDev->DTID);
        //     json2["ChannelID"] = (it.cfgDev->ChannelID < 0 ? 0 : it.cfgDev->ChannelID);
        // }
        json1["paramList"] = json2;

        json0.push_back(json1);
    }


    /* 将json写入本地文件 */
#ifdef DEBUG
    QString fileJson(QString::fromStdString(json0.dump()));
    QString filePath = GlobalInfo.ExecPath() + GlobalInfo.ExecPlanPath + 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_Insert, 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>() - 1;
            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;
}