#include "dbthread.h"

DBThread::DBThread(QObject *parent) : QThread(parent)
{
    keepWorking = false;
    db = QSqlDatabase::addDatabase("QSQLITE","stdb");
    db.setDatabaseName("db/conf.db");
    sqllist.clear();
}

bool DBThread::chkTable(QString tbname, QStringList list)
{
    for(int i=0;i<list.length();i++){
        if(QString::compare(tbname,list.at(i))==0)
            return true;
    }
    return false;
}

void DBThread::stop(){
    keepWorking = false;
}

void DBThread::initdb()
{
    QString TermId = "a7f82b3f-f909-44bd-87c3-336b03ad5aa1";//博华
    QString TermKey = "123456";
    QString Loginname = "bhds";
    QString Password = "bhds123";
    QString CompanyId = "10122";
    QString AppUrl = "https://fire.usky.cn:8443";
    if(db.open()){
        if(!chkTable("yt_t_conf", db.tables())){
            db.exec("create table yt_t_conf (AppId text, AppKey text, LoginName text, PassWord text, CompanyId text);");
            db.exec(QString("insert into yt_t_conf (AppId, AppKey, LoginName, PassWord, CompanyId) values ('%1', '%2', '%3', '%4', '%5');")
                    .arg(TermId).arg(TermKey).arg(Loginname).arg(Password).arg(CompanyId));
        }
        if(!chkTable("yt_t_url",db.tables())){
            db.exec("create table yt_t_url (AppUrl text);");
            db.exec(QString("insert into yt_t_url (AppUrl) values ('%1')").arg(AppUrl));
        }
        QSqlQuery qry = db.exec("select AppId, AppKey, LoginName, PassWord, CompanyId from yt_t_conf;");
        if(qry.next()){
            TermId = qry.value(0).toString();
            TermKey = qry.value(1).toString();
            Loginname = qry.value(2).toString();
            Password = qry.value(3).toString();
            CompanyId = qry.value(4).toString();
        }
        qry.clear();
        qry = db.exec("select AppUrl from yt_t_url");
        if(qry.next()){
            AppUrl = qry.value(0).toString();
        }
        qry.clear();
        db.close();
    }
    emit getParam(TermId, TermKey, Loginname, Password, CompanyId, AppUrl);
}

void DBThread::appendSql(QString sql)
{
    sqllist.append(sql);
}

void DBThread::run()
{
    keepWorking = true;
    while (keepWorking) {
        if(sqllist.length()>0){
            if(db.open()){
                while (sqllist.length()>0) {
                    db.exec(sqllist.first());
                    sqllist.removeFirst();
                    usleep(10000);
                }
                db.close();
            }
        }
        usleep(100000);
    }
}