QFD2/QFD/dbService/DBServiceSet.cpp

#include "DBServiceSet.h"
#include "SqlDBHelper.h"
#include <QDebug>

DBServiceSet::DBServiceSet(QObject *parent) { }

//////////////////////common-start////////////////////
int DBServiceSet::getNextId(QString tableName)
{
    int nextId = -1;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString selectSql       = QString("SELECT seq from sqlite_sequence  WHERE name = '%1'").arg(tableName);
        QueryResult queryResult = t.execQuery(selectSql);
        if (queryResult.next()) {
            nextId = queryResult.value(0).toInt() + 1;
        }
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return nextId;
}
//////////////////////common-end////////////////////

//////////////////////节点权重值持久化-start////////////////////

bool DBServiceSet::AddNodeWeightInfo(const DemandWeight &demandWeight)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        InsertQuery q = t.insertInto("t_demand_weight (engineer_id,expert_id, node_name, node_weight, "
                                     "node_value,table_index )");
        q.values(demandWeight.engineerId, demandWeight.expertId, demandWeight.nodeName, demandWeight.nodeWeight,
                 demandWeight.nodeValue, demandWeight.tableIndex)
                .exec();
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

/*批量节点信息新增*/
bool DBServiceSet::AddNodeWeightInfoList(const QList<DemandWeight *> &demandWeightList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        for (int i = 0; i < demandWeightList.length(); i++) {
            DemandWeight *demandWeight = demandWeightList.at(i);
            InsertQuery q              = t.insertInto("t_demand_weight (engineer_id,expert_id, node_name, node_weight, "
                                         "node_value,table_index,table_msg,is_valid,page_index )");
            q.values(demandWeight->engineerId, demandWeight->expertId, demandWeight->nodeName, demandWeight->nodeWeight,
                     demandWeight->nodeValue, demandWeight->tableIndex, demandWeight->tableMsg, demandWeight->isValid,
                     demandWeight->pageIndex)
                    .exec();
            t.commit();
        }
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

/*修改节点值*/
bool DBServiceSet::UpdateNodeValue(const DemandWeight &demandWeight)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.update("t_demand_weight")
                .set("NODE_VALUE", demandWeight.nodeValue)
                .set("NODE_WEIGHT", demandWeight.nodeWeight)
                .where("ENGINEER_ID = ? and expert_id = ? and node_name = ? ", demandWeight.engineerId,
                       demandWeight.expertId, demandWeight.nodeName);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::UpdateNodeValueList(const QList<DemandWeight *> demandWeightList)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret = false;
    for (int i = 0; i < demandWeightList.length(); i++) {
        DemandWeight *demandWeight = demandWeightList.at(i);
        QString updateSql          = QString("UPDATE t_demand_weight SET NODE_VALUE ='%1' , NODE_WEIGHT = '%2' "
                                    "WHERE ENGINEER_ID =%3 AND expert_id =%4"
                                    " AND node_name = '%5' AND table_index =%6 and table_msg ='%7' and page_index=%8")
                                    .arg(demandWeight->nodeValue)
                                    .arg(demandWeight->nodeWeight)
                                    .arg(demandWeight->engineerId)
                                    .arg(demandWeight->expertId)
                                    .arg(demandWeight->nodeName)
                                    .arg(demandWeight->tableIndex)
                                    .arg(demandWeight->tableMsg)
                                    .arg(demandWeight->pageIndex);
        // qDebug() << updateSql;
        query.exec(updateSql);
        ret = true;
    }

    return ret;
}
bool DBServiceSet::QueryByTableIndexAndTableMsg(int expertId, int engineerId, int tableIndex, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "=%1 and engineer_id =%2 and table_index=%3 and table_msg='%4'")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(QString::number(tableIndex))
                                .arg(tableMsg);
    // qDebug() << "sql===" << selectSql;
    if (query.exec(selectSql)) {
        if (query.next()) {
            ret = true;
        }

    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryByTableIndexAndTableMsg(QString expertId, int engineerId, int tableIndex, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "='%1' and engineer_id =%2 and table_index=%3 and table_msg='%4'")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(QString::number(tableIndex))
                                .arg(tableMsg);
    // qDebug() << "sql===" << selectSql;
    if (query.exec(selectSql)) {
        if (query.next()) {
            ret = true;
        }

    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryByTableIndexAndTableMsgAndPage(QString expertId, int engineerId, int tableIndex,
                                                       QString tableMsg, int page)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "='%1' and engineer_id =%2 and table_index=%3 and table_msg='%4' and page_index=%5")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(QString::number(tableIndex))
                                .arg(tableMsg)
                                .arg(page);
    // qDebug() << "sql===" << selectSql;
    if (query.exec(selectSql)) {
        if (query.next()) {
            ret = true;
        }

    } else {
        qDebug() << query.lastError();
    }
    return ret;
}
bool DBServiceSet::QueryByTableIndexAndTableMsg(QList<DemandWeight *> *demandWeightList, int expertId, int engineerId,
                                                int tableIndex, QString tableMsg)

{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "=%1 and engineer_id =%2 and table_index=%3 and table_msg='%4'")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(QString::number(tableIndex))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeight->tableMsg     = query.value(7).toString();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryByTableIndexAndTableMsg(QList<DemandWeight *> *demandWeightList, QString expertId,
                                                int engineerId, int tableIndex, QString tableMsg)

{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "='%1' and engineer_id =%2 and table_index=%3 and table_msg='%4'")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(QString::number(tableIndex))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeight->tableMsg     = query.value(7).toString();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryByPageIndexAndTableMsg(QList<DemandWeight *> *demandWeightList, QString expertId,
                                               int engineerId, int pageIndex, QString tableMsg)

{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "='%1' and engineer_id =%2 and page_index=%3 and table_msg='%4'")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(QString::number(pageIndex))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeight->tableMsg     = query.value(7).toString();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::updateValidByExperIdAndEngineerId(int expertId, int engineerId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret = false;
    try {
        QString updateSql = QString("UPDATE t_demand_weight SET is_valid =1  "
                                    "WHERE ENGINEER_ID =%1 AND expert_id =%2")
                                    .arg(engineerId)
                                    .arg(expertId);
        // qDebug() << updateSql;
        query.exec(updateSql);
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}
bool DBServiceSet::QueryFirstDemandWeightByEngineerId(QList<DemandWeight *> *demandWeightList, int expertId,
                                                      int engineerId, QString tableMsg)
{

    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "=%1 and engineer_id =%2 and table_msg = "
                                "'%3' and table_index = 0")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryLastDemandWeightByEngineerId(QList<DemandWeight *> *demandWeightList, int expertId,
                                                     int engineerId, QString tableMsg, int tableIndex)
{

    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "=%1 and engineer_id =%2 and table_msg = "
                                "'%3' and table_index = %4")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(tableMsg)
                                .arg(QString::number(tableIndex));
    qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryFirstDemandWeightByEngineerId(QList<DemandWeight *> *demandWeightList, QString expertId,
                                                      int engineerId, QString tableMsg)
{

    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "='%1' and engineer_id =%2 and table_msg = "
                                "'%3' and table_index = 0")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryLastPageDemandWeightByEngineerId(QList<DemandWeight *> *demandWeightList, QString expertId,
                                                         int engineerId, QString tableMsg, int page)
{

    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "='%1' and engineer_id =%2 and table_msg = "
                                "'%3' and page_index = %4")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(tableMsg)
                                .arg(page);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QuerySecondDemandWeightByEngineerId(QList<DemandWeight *> *demandWeightList, int expertId,
                                                       int engineerId, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "=%1 and engineer_id =%2 and table_msg = "
                                "'%3' and table_index != 0")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QuerySecondDemandWeightByEngineerIdAndMaxPage(QList<DemandWeight *> *demandWeightList, int expertId,
                                                                 int engineerId, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "=%1 and engineer_id =%2 and table_msg = "
                                "'%3' and page_index = (select max(page_index) from t_demand_weight where expert_id "
                                "=%1 and engineer_id =%2 and table_msg = '%3' ) order by table_index ")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QuerySecondDemandWeightByEngineerId(QList<DemandWeight *> *demandWeightList, QString expertId,
                                                       int engineerId, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_demand_weight where expert_id "
                                "='%1' and engineer_id =%2 and table_msg = "
                                "'%3' and table_index != 0")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                DemandWeight *demandWeight = new DemandWeight();
                demandWeight->id           = query.value(0).toInt();
                demandWeight->engineerId   = query.value(1).toInt();
                demandWeight->expertId     = query.value(2).toInt();
                demandWeight->nodeName     = query.value(3).toString();
                demandWeight->nodeValue    = query.value(4).toDouble();
                demandWeight->nodeWeight   = query.value(5).toDouble();
                demandWeight->tableIndex   = query.value(6).toInt();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

//////////////////////common-end////////////////////

/////////////////////方案持久化-start////////////////
bool DBServiceSet::AddSchemeInfoList(const QList<SchemaEval *> &schemeList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        for (int i = 0; i < schemeList.length(); i++) {
            SchemaEval *scheme = schemeList.at(i);
            InsertQuery q      = t.insertInto("t_scheme_info (engineer_id,name,remark,value_str,score)");
            q.values(scheme->engineerId, scheme->name, scheme->remark, scheme->valueStr, scheme->score).exec();
            t.commit();
        }
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::DeleteSchemeByEngineerId(int engineerId)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.deleteFrom("t_scheme_info").where("engineer_id = ?", engineerId);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::QuerySchemeInfoByEngineerId(QList<SchemaEval *> *schemeList, int engineerId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,engineer_id,name,remark,value_str "
                                ",score from t_scheme_info where "
                                " engineer_id =%1 ")
                                .arg(QString::number(engineerId));
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                SchemaEval *scheme = new SchemaEval();
                scheme->id         = query.value(0).toInt();
                scheme->engineerId = query.value(1).toInt();
                scheme->name       = query.value(2).toString();
                scheme->remark     = query.value(3).toString();
                scheme->valueStr   = query.value(4).toString();
                scheme->score      = query.value(5).toDouble();
                schemeList->append(scheme);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}
///////////////////////common-end/////////////////////

//////////////////////技术重要度持久化-start////////////////////

bool DBServiceSet::AddTechnicalImportInfo(const TechnicalImport &technicalImport)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        InsertQuery q = t.insertInto("t_technical_import (engineer_id,expert_id,node_name,node_value)");
        q.values(technicalImport.engineerId, technicalImport.expertId, technicalImport.nodeName,
                 technicalImport.nodeValue)
                .exec();
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

/*批量节点信息新增*/
bool DBServiceSet::AddTechnicalImportInfoList(const QList<TechnicalImport *> &technicalImportList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        for (int i = 0; i < technicalImportList.length(); i++) {
            TechnicalImport *technical = technicalImportList.at(i);
            InsertQuery q = t.insertInto("t_technical_import (engineer_id,expert_id,node_name,node_value)");
            q.values(technical->engineerId, technical->expertId, technical->nodeName, technical->nodeValue).exec();
            t.commit();
        }
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::UpdateTechnicalImportInfoList(const QList<TechnicalImport *> technicalImportList)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret = false;
    for (int i = 0; i < technicalImportList.length(); i++) {
        TechnicalImport *demandWeight = technicalImportList.at(i);
        QString updateSql             = QString("UPDATE t_technical_import SET NODE_VALUE ='%1'  "
                                    "WHERE ENGINEER_ID =%2 AND expert_id =%3"
                                    " AND node_name = '%4' ")
                                    .arg(demandWeight->nodeValue)
                                    .arg(demandWeight->engineerId)
                                    .arg(demandWeight->expertId)
                                    .arg(demandWeight->nodeName);
        // qDebug() << updateSql;
        query.exec(updateSql);
        ret = true;
    }

    return ret;
}

bool DBServiceSet::QueryTechnicalImportInfoByEngineerId(QList<TechnicalImport *> *demandWeightList, int expertId,
                                                        int engineerId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_technical_import where "
                                "expert_id =%1 and engineer_id =%2 ")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId));
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                TechnicalImport *demandWeight = new TechnicalImport();
                demandWeight->id              = query.value(0).toInt();
                demandWeight->engineerId      = query.value(1).toInt();
                demandWeight->expertId        = query.value(2).toInt();
                demandWeight->nodeName        = query.value(3).toString();
                demandWeight->nodeValue       = query.value(4).toDouble();
                demandWeightList->append(demandWeight);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryTechnicalImportInfoByEngineerId(int expertId, int engineerId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select * from t_technical_import where "
                                "expert_id =%1 and engineer_id =%2 ")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId));
    // qDebug() << "sql=" << selectSql;
    if (query.exec(selectSql)) {
        if (query.next()) {

            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

//////////////////////common-end////////////////////

//////////////////////节点矩阵信息表-start////////////////////
bool DBServiceSet::AddNodeMatrixInfo(const NodeMatrixInfo &nodeMatrixInfo)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        InsertQuery q = t.insertInto("t_node_matrix_info (expert_name, engineer_id, node, "
                                     "abscissa, ordinate, "
                                     "node_value, expert_id,mind_name,write_date,mark)");
        q.values(nodeMatrixInfo.expertName, nodeMatrixInfo.engineerId, nodeMatrixInfo.node, nodeMatrixInfo.abscissa,
                 nodeMatrixInfo.ordinate, nodeMatrixInfo.nodeValue, nodeMatrixInfo.expertId, nodeMatrixInfo.mindId,
                 nodeMatrixInfo.writeDate.toString(), nodeMatrixInfo.mark)
                .exec();
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

/*批量节点信息新增*/
bool DBServiceSet::AddNodeMatrixInfoList(const QList<NodeMatrixInfo *> &jbInfoList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        for (int i = 0; i < jbInfoList.length(); i++) {
            NodeMatrixInfo *nodeMatrixInfo = jbInfoList.at(i);
            InsertQuery query = t.insertInto("t_node_matrix_info (expert_name, engineer_id, node, abscissa, "
                                             "ordinate, "
                                             "node_value, expert_id,mind_id,write_date,mark,table_msg)");
            query.values(nodeMatrixInfo->expertName, nodeMatrixInfo->engineerId, nodeMatrixInfo->node,
                         nodeMatrixInfo->abscissa, nodeMatrixInfo->ordinate, nodeMatrixInfo->nodeValue,
                         nodeMatrixInfo->expertId, nodeMatrixInfo->mindId, nodeMatrixInfo->writeDate.toString(),
                         nodeMatrixInfo->mark, nodeMatrixInfo->tableMsg)
                    .exec();
            t.commit();
        }

        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

/*批量节点信息新增----专家端*/
bool DBServiceSet::AddNodeMatrixInfoList2(const QList<NodeMatrixInfo *> &jbInfoList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase2());
        for (int i = 0; i < jbInfoList.length(); i++) {
            NodeMatrixInfo *nodeMatrixInfo = jbInfoList.at(i);
            InsertQuery query = t.insertInto("t_node_matrix_info (expert_name, engineer_id, node, abscissa, "
                                             "ordinate, "
                                             "node_value, expert_id,mind_id,write_date,mark,table_msg,tab_index)");
            query.values(nodeMatrixInfo->expertName, nodeMatrixInfo->engineerId, nodeMatrixInfo->node,
                         nodeMatrixInfo->abscissa, nodeMatrixInfo->ordinate, nodeMatrixInfo->nodeValue,
                         nodeMatrixInfo->expertId, nodeMatrixInfo->mindId, nodeMatrixInfo->writeDate.toString(),
                         nodeMatrixInfo->mark, nodeMatrixInfo->tableMsg, nodeMatrixInfo->tabIndex)
                    .exec();
            t.commit();
        }

        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

/*修改节点值*/
bool DBServiceSet::UpdateNodeMatrixNodeValue(const NodeMatrixInfo &nodeMatrixInfo)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.update("t_node_matrix_info")
                .set("NODE_VALUE", nodeMatrixInfo.nodeValue)
                .where("ENGINEER_ID = ? and expert_name = and abscissa = ? and "
                       "ordinate = ?  ",
                       nodeMatrixInfo.engineerId, nodeMatrixInfo.expertName, nodeMatrixInfo.abscissa,
                       nodeMatrixInfo.ordinate);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::UpdateNodeMatrixNodeValueList(const QList<NodeMatrixInfo *> jbInfoList)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret = false;
    for (int i = 0; i < jbInfoList.length(); i++) {
        NodeMatrixInfo *nodeMatrixInfo = jbInfoList.at(i);
        QString updateSql              = QString("UPDATE t_node_matrix_info SET NODE_VALUE ='%1' WHERE "
                                    "ENGINEER_ID = %2 AND expert_name = '%3'"
                                    " AND abscissa = '%4' AND ordinate = '%5' and table_msg = '%6' "
                                    "and mark = '%7'")
                                    .arg(nodeMatrixInfo->nodeValue)
                                    .arg(nodeMatrixInfo->engineerId)
                                    .arg(nodeMatrixInfo->expertName)
                                    .arg(nodeMatrixInfo->abscissa)
                                    .arg(nodeMatrixInfo->ordinate)
                                    .arg(nodeMatrixInfo->tableMsg)
                                    .arg(nodeMatrixInfo->mark);
        // qDebug() << updateSql;
        query.exec(updateSql);
        ret = true;
    }

    return ret;
}

bool DBServiceSet::UpdateNodeMatrixNodeValueList2(const QList<NodeMatrixInfo *> jbInfoList)
{
    QSqlDatabase db = SqlDBHelper::getDatabase2();
    QSqlQuery query(db);
    bool ret = false;
    for (int i = 0; i < jbInfoList.length(); i++) {
        NodeMatrixInfo *nodeMatrixInfo = jbInfoList.at(i);
        QString updateSql              = QString("UPDATE t_node_matrix_info SET NODE_VALUE ='%1' WHERE "
                                    "ENGINEER_ID = %2 AND expert_name = '%3'"
                                    " AND abscissa = '%4' AND ordinate = '%5' and table_msg = '%6' "
                                    "and mark = '%7' and tab_index = '%8'")
                                    .arg(nodeMatrixInfo->nodeValue)
                                    .arg(nodeMatrixInfo->engineerId)
                                    .arg(nodeMatrixInfo->expertName)
                                    .arg(nodeMatrixInfo->abscissa)
                                    .arg(nodeMatrixInfo->ordinate)
                                    .arg(nodeMatrixInfo->tableMsg)
                                    .arg(nodeMatrixInfo->mark)
                                    .arg(nodeMatrixInfo->tabIndex);
        // qDebug() << updateSql;
        query.exec(updateSql);
        ret = true;
    }

    return ret;
}

/*根据专家姓名和工程id获取节点信息*/
bool DBServiceSet::QueryNodeMatrixListByExpertNameAndEngineerId(QString expertName, int engineerId, QString tableMsg,
                                                                QString mark)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_name "
                                "= '%1' and engineer_id ='%2' and table_msg='%3' and mark = '%4'")
                                .arg(expertName)
                                .arg(QString::number(engineerId))
                                .arg(tableMsg)
                                .arg(mark);

    if (query.exec(selectSql)) {
        if (query.next()) {
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    qDebug() << ret;
    return ret;
}

/*根据专家姓名和工程id获取节点信息*/
bool DBServiceSet::QueryNodeMatrixListByExpertIdAndEngineerId(QString expertId, int engineerId, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_id "
                                "= '%1' and engineer_id ='%2' and table_msg='%3'")
                                .arg(expertId)
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << selectSql;

    if (query.exec(selectSql)) {
        if (query.next()) {
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    // qDebug() << ret;
    return ret;
}

bool DBServiceSet::QueryNodeMatrixListByExpertNameAndEngineerId(QList<NodeMatrixInfo *> *nodeMatrixInfoList,
                                                                QString expertName, int engineerId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_name "
                                "= '%1' and engineer_id ='%2'")
                                .arg(expertName)
                                .arg(QString::number(engineerId));
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                NodeMatrixInfo *nodeMatrixInfo = new NodeMatrixInfo();
                nodeMatrixInfo->id             = query.value(0).toInt();
                nodeMatrixInfo->expertName     = query.value(1).toString();
                nodeMatrixInfo->node           = query.value(2).toString();
                nodeMatrixInfo->engineerId     = query.value(3).toInt();
                nodeMatrixInfo->abscissa       = query.value(4).toString();
                nodeMatrixInfo->ordinate       = query.value(5).toString();
                nodeMatrixInfo->nodeValue      = query.value(6).toString();
                nodeMatrixInfo->expertId       = query.value(7).toInt();
                nodeMatrixInfo->mindId         = query.value(8).toInt();
                nodeMatrixInfo->writeDate      = query.value(9).toDateTime();
                nodeMatrixInfo->mark           = query.value(10).toString();
                nodeMatrixInfoList->append(nodeMatrixInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryNodeMatrixListByExpertNameAndEngineerId2(QString expertName, int engineerId, QString tableMsg,
                                                                 QString mark, int tabIndex)
{
    QSqlDatabase db = SqlDBHelper::getDatabase2();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_name "
                                "= '%1' and engineer_id ='%2' and table_msg='%3' and mark = '%4' and tab_index = '%5'")
                                .arg(expertName)
                                .arg(QString::number(engineerId))
                                .arg(tableMsg)
                                .arg(mark)
                                .arg(tabIndex);

    if (query.exec(selectSql)) {
        if (query.next()) {
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    qDebug() << ret;
    return ret;
}

bool DBServiceSet::QueryNodesByExpertNameAndEngineerId2(QList<NodeMatrixInfo *> *nodeMatrixInfoList, QString expertName,
                                                        int engineerId, QString tableMsg, QString mark, int tabIndex)
{
    QSqlDatabase db = SqlDBHelper::getDatabase2();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_name "
                                "= '%1' and engineer_id ='%2' and table_msg='%3' and mark = '%4' and tab_index = '%5'")
                                .arg(expertName)
                                .arg(QString::number(engineerId))
                                .arg(tableMsg)
                                .arg(mark)
                                .arg(tabIndex);
    // qDebug() << "----" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                NodeMatrixInfo *nodeMatrixInfo = new NodeMatrixInfo();
                nodeMatrixInfo->id             = query.value(0).toInt();
                nodeMatrixInfo->expertName     = query.value(1).toString();
                nodeMatrixInfo->node           = query.value(2).toString();
                nodeMatrixInfo->engineerId     = query.value(3).toInt();
                nodeMatrixInfo->abscissa       = query.value(4).toString();
                nodeMatrixInfo->ordinate       = query.value(5).toString();
                nodeMatrixInfo->nodeValue      = query.value(6).toString();
                nodeMatrixInfo->expertId       = query.value(7).toInt();
                nodeMatrixInfo->mindId         = query.value(8).toInt();
                nodeMatrixInfo->writeDate      = query.value(9).toDateTime();
                nodeMatrixInfo->mark           = query.value(10).toString();
                nodeMatrixInfoList->append(nodeMatrixInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    qDebug() << ret;
    return ret;
}

bool DBServiceSet::QueryNodeValueByUserIdAndEngineerId(int experId, int engineerId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_id "
                                "= '%1' and engineer_id ='%2'")
                                .arg(QString::number(experId))
                                .arg(QString::number(engineerId));
    // qDebug() << "selectSql=" << selectSql;
    if (query.exec(selectSql)) {
        if (query.next()) {

            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryNodeMatrixListByExpertIdAndEngineerId(QList<NodeMatrixInfo *> *nodeMatrixInfoList, int expertId,
                                                              int engineerId, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_id "
                                "= '%1' and engineer_id ='%2' and table_msg ='%3'")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << "selectSql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                NodeMatrixInfo *nodeMatrixInfo = new NodeMatrixInfo();
                nodeMatrixInfo->id             = query.value(0).toInt();
                nodeMatrixInfo->expertName     = query.value(1).toString();
                nodeMatrixInfo->node           = query.value(2).toString();
                nodeMatrixInfo->engineerId     = query.value(3).toInt();
                nodeMatrixInfo->abscissa       = query.value(4).toString();
                nodeMatrixInfo->ordinate       = query.value(5).toString();
                nodeMatrixInfo->nodeValue      = query.value(6).toString();
                nodeMatrixInfo->expertId       = query.value(7).toInt();
                nodeMatrixInfo->mindId         = query.value(8).toInt();
                nodeMatrixInfo->writeDate      = query.value(9).toDateTime();
                nodeMatrixInfo->mark           = query.value(10).toString();
                nodeMatrixInfoList->append(nodeMatrixInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryNodeMatrixListByExpertIdAndEngineerId2(QList<NodeMatrixInfo *> *nodeMatrixInfoList,
                                                               int expertId, int engineerId, QString tableMsg)
{
    QSqlDatabase db = SqlDBHelper::getDatabase2();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_id,write_date from "
                                "t_node_matrix_info where expert_id "
                                "= '%1' and engineer_id ='%2' and table_msg ='%3'")
                                .arg(QString::number(expertId))
                                .arg(QString::number(engineerId))
                                .arg(tableMsg);
    // qDebug() << "selectSql=" << selectSql;
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                NodeMatrixInfo *nodeMatrixInfo = new NodeMatrixInfo();
                nodeMatrixInfo->id             = query.value(0).toInt();
                nodeMatrixInfo->expertName     = query.value(1).toString();
                nodeMatrixInfo->node           = query.value(2).toString();
                nodeMatrixInfo->engineerId     = query.value(3).toInt();
                nodeMatrixInfo->abscissa       = query.value(4).toString();
                nodeMatrixInfo->ordinate       = query.value(5).toString();
                nodeMatrixInfo->nodeValue      = query.value(6).toString();
                nodeMatrixInfo->expertId       = query.value(7).toInt();
                nodeMatrixInfo->mindId         = query.value(8).toInt();
                nodeMatrixInfo->writeDate      = query.value(9).toDateTime();
                nodeMatrixInfo->mark           = query.value(10).toString();
                nodeMatrixInfoList->append(nodeMatrixInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

/*根据专家姓名查询对应的节点信息*/
bool DBServiceSet::QueryNodeMatrixListByExpertName(QList<NodeMatrixInfo *> *nodeMatrixInfoList, QString expertName)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_name,write_date from "
                                "t_node_matrix_info where expert_name = '%1'")
                                .arg(expertName);
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                NodeMatrixInfo *nodeMatrixInfo = new NodeMatrixInfo();
                nodeMatrixInfo->id             = query.value(0).toInt();
                nodeMatrixInfo->expertName     = query.value(1).toString();
                nodeMatrixInfo->node           = query.value(2).toString();
                nodeMatrixInfo->engineerId     = query.value(3).toInt();
                nodeMatrixInfo->abscissa       = query.value(4).toString();
                nodeMatrixInfo->ordinate       = query.value(5).toString();
                nodeMatrixInfo->nodeValue      = query.value(6).toString();
                nodeMatrixInfo->expertId       = query.value(7).toInt();
                nodeMatrixInfo->mindId         = query.value(8).toInt();
                nodeMatrixInfo->writeDate      = query.value(9).toDateTime();
                nodeMatrixInfo->mark           = query.value(10).toString();
                nodeMatrixInfoList->append(nodeMatrixInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

/*根据专家姓名编号对应的节点信息*/
bool DBServiceSet::QueryNodeMatrixListByExpertId(QList<NodeMatrixInfo *> *nodeMatrixInfoList, int expertId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id,mind_name,write_date from "
                                "t_node_matrix_info where expert_id = '%1'")
                                .arg(expertId);
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                NodeMatrixInfo *nodeMatrixInfo = new NodeMatrixInfo();
                nodeMatrixInfo->id             = query.value(0).toInt();
                nodeMatrixInfo->expertName     = query.value(1).toString();
                nodeMatrixInfo->node           = query.value(2).toString();
                nodeMatrixInfo->engineerId     = query.value(3).toInt();
                nodeMatrixInfo->abscissa       = query.value(4).toString();
                nodeMatrixInfo->ordinate       = query.value(5).toString();
                nodeMatrixInfo->nodeValue      = query.value(6).toString();
                nodeMatrixInfo->expertId       = query.value(7).toInt();
                nodeMatrixInfo->mindId         = query.value(8).toInt();
                nodeMatrixInfo->writeDate      = query.value(9).toDateTime();
                nodeMatrixInfo->mark           = query.value(10).toString();
                nodeMatrixInfoList->append(nodeMatrixInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}
/*根据工程编号查询对应的节点信息*/
bool DBServiceSet::QueryNodeMatrixListByEngineerId(QList<NodeMatrixInfo *> *nodeMatrixInfoList, int engineerId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("select id,expert_name, engineer_id, node, abscissa, ordinate, "
                                "node_value, expert_id ,mind_name,write_date from "
                                "t_node_matrix_info where engineer_id = '%1'")
                                .arg(engineerId);
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                NodeMatrixInfo *nodeMatrixInfo = new NodeMatrixInfo();
                nodeMatrixInfo->id             = query.value(0).toInt();
                nodeMatrixInfo->expertName     = query.value(1).toString();
                nodeMatrixInfo->node           = query.value(2).toString();
                nodeMatrixInfo->engineerId     = query.value(3).toInt();
                nodeMatrixInfo->abscissa       = query.value(4).toString();
                nodeMatrixInfo->ordinate       = query.value(5).toString();
                nodeMatrixInfo->nodeValue      = query.value(6).toString();
                nodeMatrixInfo->expertId       = query.value(7).toInt();
                nodeMatrixInfo->mindId         = query.value(8).toInt();
                nodeMatrixInfo->writeDate      = query.value(9).toDateTime();
                nodeMatrixInfo->mark           = query.value(10).toString();
                nodeMatrixInfoList->append(nodeMatrixInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

/*根据工程编号删除对应的节点信息*/
bool DBServiceSet::DeleteNodeMatrixListByEngineerId(int engineerId)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.deleteFrom("t_node_matrix_info").where("engineer_id = ?", engineerId);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}
/*根据专家名称删除对应的节点信息*/
bool DBServiceSet::DeleteNodeMatrixListByExpertName(QString expertName)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.deleteFrom("t_node_matrix_info").where("expert_name = ?", expertName);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}
/*根据专家编号删除对应的节点信息*/
bool DBServiceSet::DeleteNodeMatrixListByExpertId(int expertId)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.deleteFrom("t_node_matrix_info").where("expert_id = ?", expertId);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}
//////////////////////节点矩阵信息表-end////////////////////

//////////////////////评估方案信息表-start////////////////////
bool DBServiceSet::AddPlanInfo(const PlanInfo &planInfo)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        InsertQuery q = t.insertInto("t_plan_info (plan_name, engineer_id, desc,create_time)");
        q.values(planInfo.planName, planInfo.engineerId, planInfo.desc,
                 QDateTime::currentDateTime().toString("yyyy.MM.dd hh:mm:ss.zzz"))
                .exec();
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::UpdatePlanInfo(const PlanInfo &planInfo)
{

    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.update("t_plan_info")
                .set("plan_name", planInfo.planName)
                .set("engineer_id", planInfo.engineerId)
                .set("desc", planInfo.desc)
                .set("update_time", QDateTime::currentDateTime().toString("yyyy.MM.dd hh:mm:ss.zzz"))
                .where("id=?", planInfo.id);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}
bool DBServiceSet::QueryPlanInfoById(PlanInfo *planInfo, int planId)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString selectSql = QString("SELECT id, plan_name,engineer_id, desc from t_plan_info "
                                    " WHERE id = %1")
                                    .arg(planId);
        QueryResult queryResult = t.execQuery(selectSql);
        if (queryResult.next()) {
            planInfo->id         = queryResult.value(0).toInt();
            planInfo->planName   = queryResult.value(1).toString();
            planInfo->engineerId = queryResult.value(2).toInt();
            planInfo->desc       = queryResult.value(3).toString();
            ret                  = true;
        }
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}
bool DBServiceSet::QueryPlanListByColumnAndColumnValue(QList<PlanInfo *> *planInfoList, QString columnName,
                                                       QString columnValue)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString selectSql = QString("SELECT id, plan_name,engineer_id, desc from t_plan_info "
                                    " WHERE %1 = '%2'")
                                    .arg(columnName)
                                    .arg(columnValue);
        QueryResult queryResult = t.execQuery(selectSql);
        while (queryResult.next()) {
            PlanInfo *planInfo   = new PlanInfo();
            planInfo->id         = queryResult.value(0).toInt();
            planInfo->planName   = queryResult.value(1).toString();
            planInfo->engineerId = queryResult.value(2).toInt();
            planInfo->desc       = queryResult.value(3).toString();
            planInfoList->append(planInfo);
            ret = true;
        }
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::QueryPlanList(QList<PlanInfo *> *planInfoList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString selectSql       = QString("SELECT id, plan_name,engineer_id, desc from t_plan_info ");
        QueryResult queryResult = t.execQuery(selectSql);
        while (queryResult.next()) {
            PlanInfo *planInfo   = new PlanInfo();
            planInfo->id         = queryResult.value(0).toInt();
            planInfo->planName   = queryResult.value(1).toString();
            planInfo->engineerId = queryResult.value(2).toInt();
            planInfo->desc       = queryResult.value(3).toString();
            planInfoList->append(planInfo);
            ret = true;
        }
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::DeletePlanById(int planId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString deleteSql = QString("DELETE FROM t_plan_info WHERE id = %1").arg(planId);
    if (query.exec(deleteSql)) {
        ret = true;
        qDebug() << "deleteSql success!";
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}
//////////////////////评估方案信息表-end////////////////////
//////////////////////指标体系评估方案关系信息表-start////////////////////

/*批量信息新增*/
bool DBServiceSet::AddIndexSetPlanInfoList(const QList<IndexSetPlanInfo *> planInfoList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString insertTime = QDateTime::currentDateTime().toString("yyyy.MM.dd hh:mm:ss.zzz");

        for (int i = 0; i < planInfoList.length(); i++) {
            IndexSetPlanInfo *indexSetPlanInfo = planInfoList.at(i);
            InsertQuery query = t.insertInto("t_plan_index (index_set_id, plan_id, weight, create_time)");
            query.values(indexSetPlanInfo->indexSetId, indexSetPlanInfo->planId, indexSetPlanInfo->weight, insertTime)
                    .exec();
        }
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::UpdateIndexSetPlanInfo(const IndexSetPlanInfo &planInfo)
{

    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        t.update("t_plan_index")
                .set("weight", planInfo.weight)
                .set("update_time", QDateTime::currentDateTime().toString("yyyy.MM.dd hh:mm:ss.zzz"))
                .where("index_set_id =? and plan_id=?", planInfo.indexSetId, planInfo.planId);
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::UpdateIndexSetPlanInfoList(const QList<IndexSetPlanInfo *> planInfoList)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString updateTime = QDateTime::currentDateTime().toString("yyyy.MM.dd hh:mm:ss.zzz");
        for (int i = 0; i < planInfoList.length(); i++) {
            IndexSetPlanInfo *indexSetPlanInfo = planInfoList.at(i);
            t.update("t_plan_index")
                    .set("weight", indexSetPlanInfo->weight)
                    .set("update_time", updateTime)
                    .where("index_set_id =? and plan_id=?", indexSetPlanInfo->indexSetId, indexSetPlanInfo->planId);
        }
        t.commit();
        ret = true;
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}
bool DBServiceSet::DeleteIndexSetPlanById(int Id)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString deleteSql = QString("DELETE FROM t_plan_index WHERE id = %1").arg(Id);
    if (query.exec(deleteSql)) {
        ret = true;
        qDebug() << "deleteSql success!";
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}
bool DBServiceSet::DeleteIndexSetPlanByPlanId(int planId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString deleteSql = QString("DELETE FROM t_plan_index WHERE plan_id = %1").arg(planId);
    if (query.exec(deleteSql)) {
        ret = true;
        qDebug() << "deleteSql success!";
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}
bool DBServiceSet::DeleteIndexSetPlanByIndexSetId(int indexSetId)
{
    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString deleteSql = QString("DELETE FROM t_plan_index WHERE index_set_id = %1").arg(indexSetId);
    if (query.exec(deleteSql)) {
        ret = true;
        qDebug() << "deleteSql success!";
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}

bool DBServiceSet::QueryIndexSetPlanInfo(IndexSetPlanInfo *planInfo, int Id)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString selectSql = QString("SELECT id, plan_id,index_set_id,weight from t_plan_index "
                                    " WHERE id = %1")
                                    .arg(Id);
        QueryResult queryResult = t.execQuery(selectSql);
        if (queryResult.next()) {
            planInfo->id         = queryResult.value(0).toInt();
            planInfo->planId     = queryResult.value(1).toInt();
            planInfo->indexSetId = queryResult.value(2).toInt();
            planInfo->weight     = queryResult.value(3).toDouble();
            ret                  = true;
        }
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool DBServiceSet::QueryIndexSetPlanListByColumnAndColumnValue(QList<IndexSetPlanInfo *> *planInfoList,
                                                               QString columnName, QString columnValue)
{
    bool ret = false;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        QString selectSql = QString("SELECT id, plan_id,index_set_id,weight from "
                                    "t_plan_index where %1 = '%2' ")
                                    .arg(columnName)
                                    .arg(columnValue);
        QueryResult queryResult = t.execQuery(selectSql);
        while (queryResult.next()) {
            IndexSetPlanInfo *planInfo = new IndexSetPlanInfo();
            planInfo->id               = queryResult.value(0).toInt();
            planInfo->planId           = queryResult.value(1).toInt();
            planInfo->indexSetId       = queryResult.value(2).toInt();
            planInfo->weight           = queryResult.value(3).toDouble();
            planInfoList->append(planInfo);
            ret = true;
        }
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

//////////////////////指标体系评估方案关系信息表-end////////////////////