ts/TransmitterSwitch/WebAPI/FromWebAPI.cpp

#include "FromWebAPI.h"

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

#include "LHQLogAPI.h"
#include "TransmitterSwitchInfo.h"
#include "lhhttpapi.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/libLHSqlWebInterface.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));

    auto pHttp = m_httpApi->DBInit(url.toStdString().c_str(), true);
    
    int ret = 0;

#ifdef QT_DEBUG
    /* 获取服务器列表 */
    char serverList[8192]={0};
    ret = m_httpApi->DBGetServerList(serverList, 8192-1);
    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, true, pHttp);
    ret = m_httpApi->DBLogin("", serverID, "ESM8C", m_userToken, true, pHttp);
    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("\n");
    LH_WRITE_LOG("WebAPI 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, true);
    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;
}


/* 获取频率信息 */
bool FromWebAPI::getChannelInfo(QMap<int, ChannelInfo>& mapFreq)
{
    /* 测试，创建几个频率 */
    // for(int i = 0; i < 12; i++)
    // {
    //     ChannelInfo freqInfo;
    //     freqInfo.ChannelID = i + 1;
    //     freqInfo.ChannelName = QString("频率%1").arg(freqInfo.ChannelID);
    //     mapFreq.insert(freqInfo.ChannelID, freqInfo);
    // }


    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    nJson json0;
    json0["opName"] = "ESM8C_GetChannel";
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("从数据库获取频率信息失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }

    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)
        {
            ChannelInfo freqInfo;
            freqInfo.ChannelID = it["chnid"].is_null() ? -1 : it["chnid"].get<int>();
            if(freqInfo.ChannelID <= 0)
            {
                LH_WRITE_LOG_DEBUG(QString("通道ID错误:%1").arg(freqInfo.ChannelID));
                continue;
            }
            freqInfo.ChannelName = QString::fromStdString(it["chnname"].get<std::string>());
            mapFreq.insert(freqInfo.ChannelID, freqInfo);
        }
    }
    catch (const nJson::parse_error& e) {
        LH_WRITE_ERROR("解析频率信息数据失败");
        return false;
    }
    catch (const nJson::exception& e)
    {
        LH_WRITE_ERROR("解析频率信息数据失败");
        return false;
    }
    catch(...)
    {
        LH_WRITE_ERROR("解析频率信息数据失败");
        return false;
    }
    LH_WRITE_LOG_DEBUG(QString("获取频率数据成功，频率数目:%1").arg(mapFreq.size()));

    return true;
}


/**
 * @brief 将数据写入EQM数据库
 * 
 * @param chnID 频率ID
 * @param list 
 * @return true 
 * @return false 
 */
bool FromWebAPI::insertData(int chnID, QList<OnePlanItemInfo>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    /* 先删除表格中的数据 */
    deleteOneChnPlan(chnID);

    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["channelID"] = it.ChannelID;
            json2["channelName"] = it.ChannelName.toStdString();
            json2["onWeekDay"] = it.onWeekDay;
            json2["onDate"] = it.onDateTime.date().toString("yyyy-MM-dd").toStdString();
            json2["onTime"] = it.onDateTime.time().toString("hh:mm:ss").toStdString();
            json2["offWeekDay"] = it.offWeekDay;
            json2["offDate"] = it.offDateTime.date().toString("yyyy-MM-dd").toStdString();
            json2["offTime"] = it.offDateTime.time().toString("hh:mm:ss").toStdString();

            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, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("写入EQM数据库失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    // LH_WRITE_LOG(QString("计划写入EQM数据库成功, 计划数目:%1").arg(QString::number(list.size())));

    return true;
}

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

    nJson json0;
    json0["opName"] = "ESM8C_GetOneChnPlan";
    nJson json1;
    json1["channelID"] = chnID;
    json0["paramList"] = json1;
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
    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 json2 = nJson::parse(strRet.toStdString());
        int retCode = json2["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取tExecPlan表格数据失败");
            return false;
        }
        nJson result = json2["result"];
        for(auto& it : result)
        {
            OnePlanItemInfo info;
            info.ChannelID = chnID;
            info.ChannelName = QString::fromStdString(it["channelName"].get<std::string>());
            info.onWeekDay = static_cast<enum_WeekDay>(it["onWeekDay"].get<int>());
            info.onDateTime.setDate(QDate::fromString(QString::fromStdString(it["onDate"].get<std::string>()), "yyyy-MM-dd"));
            info.onDateTime.setTime(QTime::fromString(QString::fromStdString(it["onTime"].get<std::string>()), "hh:mm:ss"));
            info.offWeekDay = static_cast<enum_WeekDay>(it["offWeekDay"].get<int>());
            info.offDateTime.setDate(QDate::fromString(QString::fromStdString(it["offDate"].get<std::string>()), "yyyy-MM-dd"));
            info.offDateTime.setTime(QTime::fromString(QString::fromStdString(it["offTime"].get<std::string>()), "hh:mm:ss"));

            list.append(info);
        }

    } 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;
}

bool FromWebAPI::getExecPlanData(QMap<int, QList<OnePlanItemInfo>>& mapPlan)
{

    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    nJson json0;
    json0["opName"] = "ESM8C_GetExecPlan";
    nJson json1;
    json0["paramList"] = json1;
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
    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 json2 = nJson::parse(strRet.toStdString());
        int retCode = json2["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取tExecPlan表格数据失败");
            return false;
        }
        nJson result = json2["result"];
        for(auto& it : result)
        {
            OnePlanItemInfo info;
            info.ChannelID = it["channelID"].is_null() ? -1 : it["channelID"].get<int>();
            info.ChannelName = QString::fromStdString(it["channelName"].get<std::string>());
            info.onWeekDay = static_cast<enum_WeekDay>(it["onWeekDay"].get<int>());
            info.onDateTime.setDate(QDate::fromString(QString::fromStdString(it["onDate"].get<std::string>()), "yyyy-MM-dd"));
            info.onDateTime.setTime(QTime::fromString(QString::fromStdString(it["onTime"].get<std::string>()), "hh:mm:ss"));
            info.offWeekDay = static_cast<enum_WeekDay>(it["offWeekDay"].get<int>());
            info.offDateTime.setDate(QDate::fromString(QString::fromStdString(it["offDate"].get<std::string>()), "yyyy-MM-dd"));
            info.offDateTime.setTime(QTime::fromString(QString::fromStdString(it["offTime"].get<std::string>()), "hh:mm:ss"));

            /* 查找对应的设备列表 */
            auto list = mapPlan.find(info.ChannelID);
            if(list == mapPlan.end())
            {
                /* 创建一个新的列表 */
                QList<OnePlanItemInfo> listPlan;
                listPlan.append(info);
                mapPlan.insert(info.ChannelID, listPlan);
            }else {
                /* 找到对应的列表 */
                list->append(info);
            }
        }

    } 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;
    }

    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, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("删除所有行失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    
    return true;
}


/* 删除一个发射机计划 */
bool FromWebAPI::deleteOneChnPlan(int chnID)
{
    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_DeleteOneChnPlan";

    json0["paramList"].clear();
    nJson json1;
    json1["channelID"] = chnID;
    json0["paramList"].push_back(json1);
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("删除频率: %3 计划失败: %1, 错误信息: %2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)).arg(chnID));
    }else {
        // LH_WRITE_LOG(QString("删除频率: %1 计划成功!").arg(chnID));
    }
    return true;
}


/**
 * @brief 将页面的配置写入数据库，主要是默认计划和执行模式
 * 
 * @param mapConfig 
 * @return true 
 * @return false 
 */
bool FromWebAPI::insertConfigData(QMap<int, ConfigData>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    deleteConfigData(list);

    nJson json0 = nJson::array();
    try{
        for(auto begin = list.begin(), end = list.end(); begin != end; begin++)
        {
            nJson json1;
            json1["opName"] = "ESM8C_InsertExecPlanConfig";
            json1["Key"] = QUuid::createUuid().toString().toStdString();
            nJson json2;
            json2["keyWord"] = begin->key;
            json2["value1"] = begin->value;
            json2["updateTime"] = begin->updateTime.toString("yyyy-MM-dd hh:mm:ss").toStdString();
            json2["notes"] = begin->notes.toStdString();
            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;
    }

    /* 写入EQM数据库 */
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("写入tExecPlanConfig失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    LH_WRITE_LOG_DEBUG(QString("页面配置写入tExecPlanConfig成功, 数目:%1").arg(QString::number(list.size())));

    return true;
}

/* 删除配置数据 */
bool FromWebAPI::deleteConfigData(QMap<int, ConfigData>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    nJson json0 = nJson::array();
    try{
        for(auto begin = list.begin(), end = list.end(); begin != end; begin++)
        {
            nJson json1;
            json1["opName"] = "ESM8C_DeleteExecPlanConfig";
            json1["Key"] = QUuid::createUuid().toString().toStdString();
            nJson json2;
            json2["keyWord"] = begin->key;
            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;
    }

    /* 写入EQM数据库 */
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("删除tExecPlanConfig表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    LH_WRITE_LOG_DEBUG(QString("删除tExecPlanConfig表格数据成功, 计划数目:%1").arg(QString::number(list.size())));

    return true;
}

/* 获取配置数据 */
bool FromWebAPI::getConfigData(QMap<int, ConfigData>& list)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    nJson json0;
    json0["opName"] = "ESM8C_GetExecPlanConfig";
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("获取tExecPlanConfig表格数据失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    /* 解析获取到的JSON数据 */
    // LH_WRITE_LOG_DEBUG(QString("Ret:%1").arg(ret));
    // LH_WRITE_LOG_DEBUG(strRet);
    try{
        nJson json1 = nJson::parse(strRet.toStdString());
        int retCode = json1["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取tExecPlanConfig失败");
            return false;
        }
        nJson result = json1["result"];
        for(auto& it : result)
        {
            ConfigData data;
            data.key = it["keyWord"].get<int>();
            data.value = it["value1"].get<int>();
            data.updateTime = QDateTime::fromString(QString::fromStdString(it["updateTime"].get<std::string>()),"yyyy-MM-dd hh:mm:ss");
            data.notes = QString::fromStdString(it["notes"].get<std::string>());
            list.insert(data.key, data);
        }

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

    LH_WRITE_LOG_DEBUG(QString("获取tExecPlanConfig表格数据成功，数据数目:%1").arg(list.size()));
    
    return true;
}

/* 单独获取某个关键字的数据 */
bool FromWebAPI::getConfigData(int key, ConfigData& data)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    nJson json0;
    json0["opName"] = "ESM8C_GetExecPlanConfigOfKeyWord";
    nJson json1;
    json1["keyWord"] = key;
    json0["paramList"] = json1;

    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("获取tExecPlanConfig表格数据失败:%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("获取tExecPlanConfig失败");
            return false;
        }
        nJson result = json1["result"];
        for(auto& it : result)
        {
            data.key = it["keyWord"].get<int>();
            if(data.key != key)
            {
                LH_WRITE_ERROR("获取到的数据和传入的关键字不匹配");
                continue;
            }
            data.value = it["value1"].get<int>();
            data.updateTime = QDateTime::fromString(QString::fromStdString(it["updateTime"].get<std::string>()),"yyyy-MM-dd hh:mm:ss");
            data.notes = QString::fromStdString(it["notes"].get<std::string>());
            break;
        }

    } catch (const nJson::parse_error& e) {
        LH_WRITE_ERROR(QString("解析tExecPlanConfig数据失败:%1").arg(e.what()));
        return false;
    }
    catch (const nJson::exception& e)
    {
        LH_WRITE_ERROR(QString("解析tExecPlanConfig数据失败:%1").arg(e.what()));
        return false;
    }
    catch(...)
    {
        LH_WRITE_ERROR("解析tExecPlanConfig数据失败");
        return false;
    }
    if(data.key != key)
    {
        LH_WRITE_ERROR("获取到的数据和传入的关键字不匹配");
        return false;
    }

    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, true);
    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::saveTemplate(const QString& templateName, QList<OnePlanItemInfo>& 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_InsertToExecPlanTemplate";
        json1["Key"] = QUuid::createUuid().toString().toStdString();
        nJson json2;

        json2["templateName"] = templateName.toStdString();
        json2["channelID"] = it.ChannelID;
        json2["channelName"] = it.ChannelName.toStdString();
        json2["onWeekDay"] = it.onWeekDay;
        json2["onDate"] = it.onDateTime.date().toString("yyyy-MM-dd").toStdString();
        json2["onTime"] = it.onDateTime.time().toString("hh:mm:ss").toStdString();
        json2["offWeekDay"] = it.offWeekDay;
        json2["offDate"] = it.offDateTime.date().toString("yyyy-MM-dd").toStdString();
        json2["offTime"] = it.offDateTime.time().toString("hh:mm:ss").toStdString();

        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, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("保存到模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    // LH_WRITE_LOG("保存到模板成功,模板名称:" + templateName + ", 计划数目:" + QString::number(list.size()));

    return true;
    

}


/* 批量写入模版数据 */
bool FromWebAPI::saveTemplateList(const QMap<OneTemplateInfo, QList<OnePlanItemInfo>>& mapTemplate)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    
    nJson json0 = nJson::array();
    try
    {
        for(auto list = mapTemplate.begin(), end = mapTemplate.end(); list != end; list++)
        {
            for(auto& item : *list)
            {
                nJson json1;
                json1["opName"] = "TMS_InsertToExecPlanTemplate";
                json1["Key"] = QUuid::createUuid().toString().toStdString();
                nJson json2;

                json2["templateName"] = list.key().templateName.toStdString();
                json2["channelID"] = item.ChannelID;
                json2["channelName"] = item.ChannelName.toStdString();
                json2["onWeekDay"] = item.onWeekDay;
                json2["onDate"] = item.onDateTime.date().toString("yyyy-MM-dd").toStdString();
                json2["onTime"] = item.onDateTime.time().toString("hh:mm:ss").toStdString();
                json2["offWeekDay"] = item.offWeekDay;
                json2["offDate"] = item.offDateTime.date().toString("yyyy-MM-dd").toStdString();
                json2["offTime"] = item.offDateTime.time().toString("hh:mm:ss").toStdString();

                json1["paramList"] = json2;
                json0.push_back(json1);
            }
        }
    }
    catch(...)
    {
        LH_WRITE_ERROR("生成json数据失败");
        return false;
    }
    /* 写入EQM数据库 */
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("保存到模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    // LH_WRITE_LOG("保存到模板成功,模板名称:" + templateName + ", 计划数目:" + QString::number(list.size()));

    return true;
}


/* 获取模板内容 */
bool FromWebAPI::getOneTemplateData(QString templateName, QList<OnePlanItemInfo>& 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, true);
    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)
        {
            OnePlanItemInfo info;
            
            info.ChannelID = it["channelID"].is_null() ? -1 : it["channelID"].get<int>();
            info.ChannelName = QString::fromStdString(it["channelName"].get<std::string>());
            info.onWeekDay = static_cast<enum_WeekDay>(it["onWeekDay"].get<int>());
            info.onDateTime.setDate(QDate::fromString(QString::fromStdString(it["onDate"].get<std::string>()), "yyyy-MM-dd"));
            info.onDateTime.setTime(QTime::fromString(QString::fromStdString(it["onTime"].get<std::string>()), "hh:mm:ss"));
            info.offWeekDay = static_cast<enum_WeekDay>(it["offWeekDay"].get<int>());
            info.offDateTime.setDate(QDate::fromString(QString::fromStdString(it["offDate"].get<std::string>()), "yyyy-MM-dd"));
            info.offDateTime.setTime(QTime::fromString(QString::fromStdString(it["offTime"].get<std::string>()), "hh:mm:ss"));

            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::getTemplateData(QList<OneTemplateInfo>& listTemplate, QMap<int, QList<OnePlanItemInfo>>& mapPlan)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    nJson jsonArry = nJson::array();
    for(auto& it : listTemplate)
    {
        jsonArry.push_back(it.templateName.toStdString());
    }
    nJson json0;
    json0["opName"] = "TMS_GetExecPlanTemplateData";
    nJson json1;
    json1["templateName"] = jsonArry;
    json0["paramList"] = json1;
    /* 打印生成的JSON */
    // LH_WRITE_LOG_DEBUG(QString::fromStdString(json0.dump(4)));

    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("获取模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    // LH_WRITE_LOG_DEBUG(strRet);
    /* 解析获取到的JSON数据 */
    try
    {
        nJson jsonRet = nJson::parse(strRet.toStdString());
        int retCode = jsonRet["code"].get<int>();
        if(retCode != 0)
        {
            LH_WRITE_ERROR("获取模板失败");
            return false;
        }
        nJson result = jsonRet["result"];
        for(auto& it : result)
        {
            OnePlanItemInfo info;
            
            info.ChannelID = it["channelID"].is_null() ? -1 : it["channelID"].get<int>();
            info.ChannelName = QString::fromStdString(it["channelName"].get<std::string>());
            info.onWeekDay = static_cast<enum_WeekDay>(it["onWeekDay"].get<int>());
            info.onDateTime.setDate(QDate::fromString(QString::fromStdString(it["onDate"].get<std::string>()), "yyyy-MM-dd"));
            info.onDateTime.setTime(QTime::fromString(QString::fromStdString(it["onTime"].get<std::string>()), "hh:mm:ss"));
            info.offWeekDay = static_cast<enum_WeekDay>(it["offWeekDay"].get<int>());
            info.offDateTime.setDate(QDate::fromString(QString::fromStdString(it["offDate"].get<std::string>()), "yyyy-MM-dd"));
            info.offDateTime.setTime(QTime::fromString(QString::fromStdString(it["offTime"].get<std::string>()), "hh:mm:ss"));

            /* 查找该频率所属的列表 */
            auto list = mapPlan.find(info.ChannelID);
            if(list == mapPlan.end())
            {
                /* 创建一个新的列表 */
                QList<OnePlanItemInfo> listPlan;
                listPlan.append(info);
                mapPlan.insert(info.ChannelID, listPlan);
            }else {
                /* 找到对应的列表 */
                list->append(info);
            }
        }

    }
    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;
    }

    LH_WRITE_LOG_DEBUG(QString("获取多个频率模板成功，频率数目:%1").arg(mapPlan.size()));

    return true;
}

/* 获取模板列表 */
bool FromWebAPI::getTemplateList(QMultiMap<int, OneTemplateInfo>& mapTemplate)
{
    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, true);
    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)
        {
            OneTemplateInfo info;
            info.channelInfo.ChannelID = it["channelID"].get<int>();
            info.templateName = QString::fromStdString(it["templateName"].get<std::string>());
            mapTemplate.insert(info.channelInfo.ChannelID, info);
        }

    } 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;
    }

    // for(auto it = list.begin(); it != list.end(); it++)
    // {
    //     LH_WRITE_LOG_DEBUG(QString("模板名称:%1, 类型:%2").arg(it.key()).arg(it.value()));
    // }

    return true;
}


/* 获取某个频率的模版列表 */
bool FromWebAPI::getTemplateList(int chnID, QList<OneTemplateInfo>& listTemplate)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }

    nJson json0;
    json0["opName"] = "TMS_GetExecPlanOneTemplateList";
    nJson jsonParam;
    jsonParam["channelID"] = chnID;
    json0["paramList"] = jsonParam;
    /* 发送请求 */
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Select, strCmd, strRet, true);
    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)
        {
            OneTemplateInfo info;
            info.channelInfo.ChannelID = it["channelID"].get<int>();
            info.templateName = QString::fromStdString(it["templateName"].get<std::string>());
            listTemplate.append(info);
        }

    } 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::deleteTemplate(const OneTemplateInfo& info)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    
    nJson json0;
    json0["opName"] = "TMS_DeleteExecPlanTemplate";
    nJson json1;
    json1["channelID"] = info.channelInfo.ChannelID;
    json1["templateName"] = info.templateName.toStdString();
    json0["paramList"] = json1;
    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_Delete, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("删除模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }

    return true;
}

/* 一次删除多个模版 */
bool FromWebAPI::deleteTemplateList(const QList<OneTemplateInfo>& listTemplate)
{
    if(m_httpApi == nullptr)
    {
        LH_WRITE_ERROR("WebAPI is nullptr");
        return false;
    }
    nJson json0 = nJson::array();
    for(auto& it : listTemplate)
    {
        nJson json1;
        json1["opName"] = "TMS_DeleteExecPlanTemplate";
        json1["Key"] = QUuid::createUuid().toString().toStdString();
        nJson json2;
        json2["channelID"] = it.channelInfo.ChannelID;
        json2["templateName"] = it.templateName.toStdString();
        json1["paramList"] = json2;
        json0.push_back(json1);
    }

    /* 打印生成的JSON */
    LH_WRITE_LOG_DEBUG(QString::fromStdString(json0.dump(4)));

    QString strCmd = QString::fromStdString(json0.dump());
    QString strRet;
    auto ret = m_httpApi->DBDoInterface(enDBOperatorType::EDBOT_BatchTransAction, strCmd, strRet, true);
    if(ret != 0)
    {
        LH_WRITE_ERROR(QString("获取模板失败:%1, 错误信息:%2").arg(ret).arg(m_httpApi->DoGetLastError(&ret)));
        return false;
    }
    // LH_WRITE_LOG_DEBUG(strRet);

    return true;
}

/**
 * @brief 修改模版，先删除该频率相同名称的模版，再插入新的模版
 * 
 * @param info 
 * @param list 新的模版计划
 * @return true 
 * @return false 
 */
bool FromWebAPI::modifyTemplate(const OneTemplateInfo& info, QList<OnePlanItemInfo>& list)
{
    if(deleteTemplate(info) == false)
    {
        LH_WRITE_ERROR("删除模版失败");
        return false;
    }
    if(saveTemplate(info.templateName, list) == false)
    {
        LH_WRITE_ERROR("保存模版失败");
        return false;
    }

    return true;
}

/* 批量修改模版 */
bool FromWebAPI::modifyTemplateList(const QMap<OneTemplateInfo, QList<OnePlanItemInfo>>& mapTemplate)
{
    /* 先批量删除模版 */
    if(deleteTemplateList(mapTemplate.keys()) == false)
    {
        LH_WRITE_ERROR("批量删除模版失败");
        return false;
    }
    /* 再批量插入模版 */
    if(!saveTemplateList(mapTemplate))
    {
        LH_WRITE_ERROR("批量插入模版失败");
        return false;
    }
    return true;
}