LANDWELL/USIAS-LANDWELL/pointthread.cpp

#include "pointthread.h"

#include <QSettings>

PointThread::PointThread(QObject *parent) : QThread(parent)
{
    naManagerPoint = new QNetworkAccessManager(this);
    //QNetworkAccessManager 向前台发送消息，等消息finished之后，才可以触发收前台返回的数据（不能把发送前台消息操作和前台返回数据操作放在一个函数里处理，有先后顺序）
    QObject::connect(naManagerPoint, &QNetworkAccessManager::finished, this, &PointThread::getData);

}



void PointThread::SendJSONData(QByteArray m_httpData)
{
    QNetworkRequest request;

    QSettings sets("sys.ini", QSettings::IniFormat);
    QString pointUrl = sets.value("POINT_HTTPURL").toString();
    //前端测试环境
    //request.setUrl(QUrl(pointUrl));
    QSslConfiguration config = request.sslConfiguration();
    config.setPeerVerifyMode(QSslSocket::VerifyNone);
    config.setProtocol(QSsl::TlsV1SslV3);
    request.setSslConfiguration(config);
    request.setUrl(QUrl(pointUrl));
    //request.setHeader(QNetworkRequest::ContentTypeHeader,QVariant("application/json"));
    //前端生产环境
    //request.setUrl(QUrl("http://121.40.217.77:8081/pt/patrollingPointPush"));

    reply = naManagerPoint->post(request, m_httpData);


}



void PointThread::getData(QNetworkReply*)
{
    QString responseData;

    reply->attribute(QNetworkRequest::HttpStatusCodeAttribute);
    reply->attribute(QNetworkRequest::RedirectionTargetAttribute);


    QNetworkReply::NetworkError err = reply->error();
    if(err != QNetworkReply::NoError) {
        responseData.append(QString("Failed: %1").arg(reply->errorString()));
    }
    else {
        // 获取返回内容
        QString string = QString::fromUtf8(reply->readAll());
        responseData.append(QString::fromUtf8("%1").arg(string));
    }

    reply->deleteLater();

    logList.append(responseData);

    QDate today = QDate::currentDate();
    QFile file(QString("log/responsePointData-%1%2%3.txt").arg(today.year(),4,10,QChar('0')).arg(today.month(),2,10,QChar('0')).arg(today.day(),2,10,QChar('0')));
    if(file.open(QIODevice::Text|QIODevice::Append|QIODevice::WriteOnly)){
        while (logList.length()>0) {
            file.write(logList.first().toUtf8()+"\n");
            logList.removeFirst();
            usleep(10000);
        }
        file.close();
    }

}


void PointThread::DealAccessDBData(QString pId,QString pCard,QString pName,QString pNumber,QString pType)
{
    if(db.open()){
        bool found = false;
        QStringList tables = db.tables();
        for(int i=0;i<tables.length();i++){
            if(QString::compare(tables.at(i),"usky_point_data")==0){
                found = true;
                break;
            }
        }
        if(!found){
            if(db.transaction()){
                db.exec("create table usky_point_data (pId text,pCard text,pName text,pNumber text,pType text,createTime text);");
                db.exec(QString("insert into usky_point_data (pId,pCard, pName,pNumber,pType,createTime) values ('%1', '%2', '%3', '%4', '%5', '%6');").arg(pId).arg(pCard).arg(pName).arg(pNumber).arg(pType).arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")));
                db.commit();
            }
        }else{
            db.exec(QString("insert into usky_point_data (pId,pCard, pName,pNumber,pType,createTime) values ('%1', '%2', '%3', '%4', '%5', '%6');").arg(pId).arg(pCard).arg(pName).arg(pNumber).arg(pType).arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")));
            db.commit();
         }
    }
    db.close();


}

void PointThread::deletePointData()
{

    //新创建数据库
    //db = QSqlDatabase::addDatabase("QSQLITE","landwell_db");
    //db.setDatabaseName("landwell.db");
    //建立现有数据库连接(这个是在已存在数据库的基础上)
    db = QSqlDatabase::database("landwell_db");

    //直接操作表  在插入数据之前，先清空表中的数据
    //db.exec("delete from usky_point_data");
    if(db.open()){
        bool found = false;
        QStringList tables = db.tables();
        for(int i=0;i<tables.length();i++){
            if(QString::compare(tables.at(i),"usky_point_data")==0){
                found = true;
                break;
            }
        }
        if(!found){

        }else{
            db.exec("delete from usky_point_data");
            db.commit();
         }
    }
    db.close();

}