data-agbox/agElevatorProcess/httpthread.cpp

#include "httpthread.h"
#include "../AGBoxDog/boxshm.h"

HttpThread::HttpThread(QObject *parent) : QObject(parent)
{
    minute = 255;
    minute1 = 255;
    keep = false;
    isWaiting = false;
    networkManager = new QNetworkAccessManager(this); //查询梯控历史事件信息
    connect(networkManager,SIGNAL(finished(QNetworkReply *)),this,SLOT(finishedSlot(QNetworkReply *)));
    isWaiting1 = false;
    networkManager1 = new QNetworkAccessManager(this); //获取梯控主机在线状态
    connect(networkManager1,SIGNAL(finished(QNetworkReply *)),this,SLOT(finishedSlot1(QNetworkReply *)));

    timer = new QTimer(this);
    connect(timer,&QTimer::timeout,this,&HttpThread::time_out);
    timer->start(5000);

}

void HttpThread::stop()
{
    keep = false;
}

void  HttpThread::finishedSlot(QNetworkReply *reply)
{
    if(reply->error()==QNetworkReply::NoError){
        QString data = QString::fromUtf8(reply->readAll());
        QByteArray ba = data.toLocal8Bit();
        ba = QString::fromLocal8Bit(ba).toUtf8();
        QJsonParseError parseError;
        QJsonDocument doc = QJsonDocument::fromJson(ba,&parseError);
        printf("event parseError.error %d\n",parseError.error);
        if(parseError.error == QJsonParseError::NoError){
            QJsonObject obj_doc = doc.object();
            QJsonValue data_value = obj_doc.value("data");
            QJsonObject data_object = data_value.toObject();
            QJsonValue list_value = data_object.value("rows");
            if(list_value.isArray()){
                QJsonArray list_array = list_value.toArray();
                for(int i=0;i<list_array.size();i++){
                    QJsonObject list_object = list_array.at(i).toObject();
                    QString device_code = list_object.value("deviceCode").toString();
                    QString deviceName = list_object.value("deviceName").toString();
                    QString liftName = list_object.value("liftName").toString();
                    QString eventId = list_object.value("eventId").toString();
                    int eventType = list_object.value("eventType").toInt();
                    QString eventName = list_object.value("eventName").toString();
                    QDateTime date = QDateTime::fromString(list_object.value("eventTime").toString(), "yyyy-MM-ddTHH:mm:ss.zzz+08:00");
                    QString eventTime = date.toLocalTime().toString("yyyy-MM-dd HH:mm:ss");
                    QString personId = list_object.value("personId").toString();
                    QString cardNo = list_object.value("cardNo").toString();
                    QString personName = list_object.value("personName").toString();
                    QString orgId = list_object.value("orgId").toString();
                    QString orgName = list_object.value("orgName").toString();
                    QDateTime date1 = QDateTime::fromString(list_object.value("receiveTime").toString(), "yyyy-MM-ddTHH:mm:ss.zzz+08:00");
                    QString receiveTime = date.toLocalTime().toString("yyyy-MM-dd HH:mm:ss");
                    for(int i=0;i<1024;i++){
                        if(agBoxShm->device[i].Enabled == 0x01){
                            if(device_code.compare(QString(agBoxShm->device[i].device_code))==0){
                                emit mqttEvent(QString("{\"device_id\":\"%1\",\"device_code\":\"%2\",\"product_id\":\"%3\",\"timestamp\":%4,\"tags\":{\"device_id\":\"%5\",\"device_code\":\"%6\",\"device_name\":\"%7\",\"lift_name\":\"%8\",\"event_id\":\"%9\",\"event_name\":\"%10\",\"event_time\":\"%11\",\"person_id\":\"%12\",\"card_no\":\"%13\",\"person_name\":\"%14\",\"org_id\":\"%15\",\"org_name\":\"%16\",\"receive_time\":\"%17\"},\"metrics\":{\"event_type\":%18},\"device_type\":\"%19-lc\"}")
                                              .arg(QString(agBoxShm->device[i].device_id)).arg(device_code).arg(QString(agBoxShm->device[i].product_code)).arg(QDateTime::currentDateTime().toTime_t()).arg(QString(agBoxShm->device[i].device_id)).arg(device_code).arg(deviceName).arg(liftName).arg(eventId).arg(eventName).arg(eventTime).arg(personId).arg(cardNo).arg(personName).arg(orgId).arg(orgName).arg(receiveTime).arg(eventType).arg(agBoxShm->device[i].device_type));
                                break;
                            }
                        }
                    }


                }
            }


        }else{
            emit dataLog(QString("event QJson Parse  Error  %1").arg(parseError.error));
        }

        emit dataLog(QString("[%1] event QNetworkReply Status %2").arg(QDateTime::fromTime_t(QDateTime::currentDateTime().toTime_t()).toString("yyyy-MM-dd HH:mm:ss")).arg(data));
    }else{
        emit dataLog(QString("[%1] event QNetworkReply Status Err  %2").arg(QDateTime::fromTime_t(QDateTime::currentDateTime().toTime_t()).toString("yyyy-MM-dd HH:mm:ss")).arg(reply->error()));
    }

    isWaiting = false;
    reply->abort();
    reply->deleteLater();
}

void HttpThread::reply_timeout()
{
    printf("[%s] event reply_timeout\n",QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss").toUtf8().data());
    isWaiting = false;
}

void  HttpThread::finishedSlot1(QNetworkReply *reply)
{
    if(reply->error()==QNetworkReply::NoError){
        QString data = QString::fromUtf8(reply->readAll());
        QByteArray ba = data.toLocal8Bit();
        ba = QString::fromLocal8Bit(ba).toUtf8();
        QJsonParseError parseError;
        QJsonDocument doc = QJsonDocument::fromJson(ba,&parseError);
        printf("status parseError.error %d\n",parseError.error);
        if(parseError.error == QJsonParseError::NoError){
            QJsonObject obj_doc = doc.object();
            QJsonValue data_value = obj_doc.value("data");

            QJsonObject data_object = data_value.toObject();
            QJsonValue list_value = data_object.value("list");
            if(list_value.isArray()){
                QJsonArray list_array = list_value.toArray();
                for(int i=0;i<list_array.size();i++){
                    QJsonObject list_object = list_array.at(i).toObject();
                    QString device_code = list_object.value("indexCode").toString();
                    int deviceStatus = list_object.value("online").toInt();

                    for(int i=0;i<1024;i++){
                        if(agBoxShm->device[i].Enabled == 0x01){
                            if(device_code.compare(QString(agBoxShm->device[i].device_code))==0){
                                emit mqttData(QString("{\"device_id\":\"%1\",\"device_code\":\"%2\",\"product_id\":\"%3\",\"timestamp\":%4,\"tags\":{\"conn_type\":\"\",\"type\":\"\"},\"metrics\":{\"device_status\":%5},\"device_type\":\"%6-lc\"}")
                                              .arg(QString(agBoxShm->device[i].device_id)).arg(device_code).arg(QString(agBoxShm->device[i].product_code)).arg(QDateTime::currentDateTime().toTime_t()).arg(deviceStatus).arg(agBoxShm->device[i].device_type));
                                break;
                            }
                        }
                    }


                }
            }


        }else{
            emit dataLog(QString("status QJson Parse  Error  %1").arg(parseError.error));
        }

        emit dataLog(QString("[%1] status QNetworkReply Status %2").arg(QDateTime::fromTime_t(QDateTime::currentDateTime().toTime_t()).toString("yyyy-MM-dd HH:mm:ss")).arg(data));
    }else{
        emit dataLog(QString("[%1] status QNetworkReply Status Err  %2").arg(QDateTime::fromTime_t(QDateTime::currentDateTime().toTime_t()).toString("yyyy-MM-dd HH:mm:ss")).arg(reply->error()));
    }

    isWaiting1 = false;
    reply->abort();
    reply->deleteLater();
}

void HttpThread::reply_timeout1()
{
    printf("[%s] status reply_timeout\n",QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss").toUtf8().data());
    isWaiting1 = false;
}

void HttpThread::app_info(QString url, QString key, QString signature, QString url1, QString key1, QString signature1)
{
    url = url;
    key = key;
    signature = signature;
    url1 = url1;
    key1 = key1;
    signature1 = signature1;
}

void HttpThread::time_out()
{
    agBoxShm->processStatus[3].t_time=QDateTime::currentDateTime().toTime_t();

    if(QDateTime::currentDateTime().time().minute()!=minute){//每分钟获取过去第八分钟这分钟的人员通行数据，封装成mqtt推送到写程序，然后由写程序处理
        minute = QDateTime::currentDateTime().time().minute();
        QString tempTime1 = QDateTime::currentDateTime().addSecs(-480).toString("yyyy-MM-ddTHH:mm");
//        QString tempTime2 = QDateTime::currentDateTime().addSecs(-60).toString("yyyy-MM-ddTHH:mm");
        startTime = QString("%1:00+08:00").arg(tempTime1);
        endTime = QString("%1:59+08:00").arg(tempTime1);

        printf("startTime: %s, endTime %s\n",startTime.toUtf8().data(),endTime.toUtf8().data());

        if(!isWaiting){
            isWaiting = true;
            QNetworkRequest *req = new QNetworkRequest();
            req->setUrl(QUrl(url));
            req->setHeader(QNetworkRequest::ContentTypeHeader,"application/json");
            req->setRawHeader("Accept","*/*");
            req->setRawHeader("Connection","keep-alive");
            req->setRawHeader("Cache-Control"," no-cache");
            req->setRawHeader("X-Ca-Key",key);
            req->setRawHeader("X-Ca-Signature",signature);
            req->setRawHeader("X-Ca-Signature-Headers","x-ca-key");
            config = req->sslConfiguration();
            config.setPeerVerifyMode(QSslSocket::VerifyNone);
            config.setProtocol(QSsl::TlsV1_0OrLater);
            req->setSslConfiguration(config);
            QString postdata = QString("{\"startTime\": \"%1\",\"endTime\": \"%2\",\"pageNo\": 1,\"pageSize\": 500}").arg(startTime).arg(endTime);
            emit dataLog(QString(" events QNetworkReply event [%1]").arg(postdata));
            req->setRawHeader("Content_Length",QString("%1").arg(postdata.length()).toUtf8());
            QNetworkReply *reply = networkManager->post(*req,postdata.toUtf8());
            QReplayTimeout *pTimeout = new QReplayTimeout(reply,10000);
            connect(pTimeout, SIGNAL(net_timeout()),this,SLOT(reply_timeout()));

        }
    }

    if(QDateTime::currentDateTime().time().minute()!=minute1){//每半个小时执行一次，同步设备状态
      minute1 = QDateTime::currentDateTime().time().minute();
      if(!isWaiting1 && ((minute1==00)||(minute1==30))){
          isWaiting1 = true;
          QNetworkRequest *req = new QNetworkRequest();
          req->setUrl(QUrl(url1));
          req->setHeader(QNetworkRequest::ContentTypeHeader,"application/json");
          req->setRawHeader("Accept","*/*");
          req->setRawHeader("Connection","keep-alive");
          req->setRawHeader("Cache-Control"," no-cache");
          req->setRawHeader("X-Ca-Key",key1);
          req->setRawHeader("X-Ca-Signature",signature1);
          req->setRawHeader("X-Ca-Signature-Headers","x-ca-key");
          config = req->sslConfiguration();
          config.setPeerVerifyMode(QSslSocket::VerifyNone);
          config.setProtocol(QSsl::TlsV1_0OrLater);
          req->setSslConfiguration(config);
          QString postdata = QString("{}");
          req->setRawHeader("Content_Length",QString("%1").arg(postdata.length()).toUtf8());
          QNetworkReply *reply = networkManager1->post(*req,postdata.toUtf8());
          QReplayTimeout *pTimeout = new QReplayTimeout(reply,10000);
          connect(pTimeout, SIGNAL(net_timeout()),this,SLOT(reply_timeout1()));

      }
  }

}