#include "EffectResultService.h"
#include "SqlDBHelper.h"
#include <QDebug>
EffectResultService::EffectResultService(QObject *parent) { }

int EffectResultService::AddEffectResult(const EffectResult &effectResult)
{
    int ret = -1;
    try {
        Transaction t(SqlDBHelper::getDatabase());
        InsertQuery query = t.insertInto("t_effect_result(`project_id`, `effect_old`, `effect_new`, "
                                         "`effect_result`, `create_time`)");
        NonQueryResult result =
                query.values(effectResult.projectId, effectResult.effectOld, effectResult.effectNew,
                             effectResult.effectResult, QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss"))
                        .exec();
        t.commit();
        ret = result.lastInsertId().toInt();
    } catch (const DBException &ex) {
        qDebug() << ex.lastError.text();
    }
    return ret;
}

bool EffectResultService::QueryAllEffectResultByProjectId(QList<EffectResult *> *effectResult, int projectId)
{

    QSqlDatabase db = SqlDBHelper::getDatabase();
    QSqlQuery query(db);
    bool ret          = false;
    QString selectSql = QString("SELECT id, project_id, effect_old,effect_new,effect_result,create_time FROM "
                                "t_effect_result where project_id = %1 order by create_time desc")
                                .arg(projectId);
    if (query.exec(selectSql)) {
        while (query.next()) {
            if (query.isNull(0) == false) {
                EffectResult *projectInfo = new EffectResult();
                projectInfo->id           = query.value(0).toInt();
                projectInfo->effectOld    = query.value(1).toString();
                projectInfo->effectNew    = query.value(2).toString();
                projectInfo->effectResult = query.value(3).toString();
                projectInfo->createTime   = query.value(4).toString();
                effectResult->append(projectInfo);
            }
            ret = true;
        }
    } else {
        qDebug() << query.lastError();
    }
    return ret;
}