ytCam_WuJi/CamDog/dogobject.cpp

#include "dogobject.h"

#include <QDebug>

MyEHomeShm *ytShm;
MyEHomeMQShm *ytMqShm;

void setFullTime(FullTime *fTime, QDateTime qTime){
    fTime->YEAR = qTime.date().year()&0xffff;
    fTime->MONTH = qTime.date().month()&0xff;
    fTime->DAY = qTime.date().day()&0xff;
    fTime->HOUR = qTime.time().hour()&0xff;
    fTime->MINUTE = qTime.time().minute()&0xff;
    fTime->SECOND = qTime.time().second()&0xff;
    fTime->TIMESTAMP = qTime.toTime_t();
}

DogObject::DogObject(QObject *parent) :
    QObject(parent)
{
    shmLoad = false;
    isWorking = false;
    isEqual = false;
    hour = 255;
    //公司187生产环境对应的数据库配置
//    db = QSqlDatabase::addDatabase("QMYSQL","conf_db");
//    db.setDatabaseName("ytIoT");
//    db.setHostName("47.98.201.187");
//    db.setUserName("root");
//    db.setPassword("Yt2018IoT");
    //伍继158环境对应的数据库配置
//    db = QSqlDatabase::addDatabase("QMYSQL","conf_db");
//    db.setDatabaseName("ytIoT");
//    db.setHostName("124.70.160.158");
//    db.setUserName("root");
//    db.setPassword("Y48hD&Eg");
    //伍继91环境对应的数据库配置
      db = QSqlDatabase::addDatabase("QMYSQL","conf_db");
      db.setDatabaseName("ytiot");
      db.setHostName("192.168.0.206");
      db.setUserName("electric");
      db.setPassword("Y48hD&Eg");
    db.open();
    shmLoad = load_shm();
    start_t = QDateTime::currentDateTime().toTime_t();
    timer = new QTimer(this);
    connect(timer,SIGNAL(timeout()),this,SLOT(time_out()));

    netAccessManager = new QNetworkAccessManager(this);
    connect(netAccessManager,SIGNAL(finished(QNetworkReply*)),this,SLOT(finishedSlot(QNetworkReply*)));

    for(int i=0;i<16;i++)
        ytShm->workingTime[i] = 0;
    devConfList.clear();
    if(db.isOpen()){
        QSqlQuery qry = db.exec("select device_code, comm_type, company_code, dev_name from ytiot_v_video order by device_code");
        while(qry.next()){
            devConfList.append(DevConf(qry.value(0).toString(),qry.value(1).toUInt()&0xff,qry.value(2).toString(),qry.value(3).toString()));
        }
        qry.clear();
    }
    else{
        printf("db disconnect\n");
    }
    QDateTime zeroTime = QDateTime::fromTime_t(0);
    for(int i=0;i<DEVICES_COUNT;i++){
        ytShm->eHomeDevice[i].io[8] = 0x00;
    }
    for(int i=0;i<devConfList.length();i++){
        if(i>1024){
            break;
        }
        ytShm->eHomeDevice[i].LoginId = -1;
        ytShm->eHomeDevice[i].SessionId = -1;
        ytShm->eHomeDevice[i].listen_preview_handle = -1;
        ytShm->eHomeDevice[i].listen_alarm_handle = -1;
        ytShm->eHomeDevice[i].lLinkHandle = -1;
        ytShm->eHomeDevice[i].previewId = -1;
        ytShm->eHomeDevice[i].previewport = 58000+i;
        ytShm->eHomeDevice[i].alarmport = 0;
        ytShm->eHomeDevice[i].Connected = 0x00;
        ytShm->eHomeDevice[i].Inited = 0x00;
        ytShm->eHomeDevice[i].onLined = 0x00;
        ytShm->eHomeDevice[i].savetmp = 0x00;
        ytShm->eHomeDevice[i].transed = 0x00;
        for(int j=0;j<16;j++)
            ytShm->eHomeDevice[i].io[j] = 0x00;
        ytShm->eHomeDevice[i].time[0]=0;
        ytShm->eHomeDevice[i].time[1]=0;
        bzero(ytShm->eHomeDevice[i].deviceID,sizeof(ytShm->eHomeDevice[i].deviceID));
        ytShm->eHomeDevice[i].tmpfile = NULL;
        setFullTime(&(ytShm->eHomeDevice[i].onLinetime),zeroTime);
        setFullTime(&(ytShm->eHomeDevice[i].transtime),zeroTime);
        sprintf(ytShm->eHomeDevice[i].deviceID,"%s",devConfList.at(i).DeviceId.toUtf8().data());
        sprintf(ytShm->eHomeDevice[i].rtsppath,"%s",devConfList.at(i).rtspPath.toUtf8().data());

        sprintf(ytMqShm->eHomeDeviceMq[i].deviceID,"%s",devConfList.at(i).DeviceId.toUtf8().data());
        sprintf(ytMqShm->eHomeDeviceMq[i].deviceName,"%s",devConfList.at(i).deviceName.toUtf8().data());

        ytShm->eHomeDevice[i].io[8] = devConfList.at(i).CommType;
        printf("%d)%s\n",i+1,ytShm->eHomeDevice[i].deviceID);
    }
}

DogObject::~DogObject()
{
    netAccessManager->deleteLater();
}

bool DogObject::load_shm()
{
    int shmid;
    key_t key;
    if((key = ftok(SHM_PATH,(int)SHM_PORT))==-1)
        return false;
    if((shmid = shmget(key,sizeof(MyEHomeShm),IPC_CREAT|0666))==-1)
        return false;
    ytShm = (MyEHomeShm *)shmat(shmid,NULL,0);
    if((key = ftok(SHMMQ_PATH,(int)(SHM_PORT+10)))==-1)
        return false;
    if((shmid = shmget(key,sizeof(MyEHomeMQShm),IPC_CREAT|0666))==-1)
        return false;
    ytMqShm = (MyEHomeMQShm *)shmat(shmid,NULL,0);
    return true;
}

void DogObject::start()
{
    if(shmLoad&&db.isOpen())
        timer->start(5000);
}

void DogObject::time_out()
{
    if(hour != QTime::currentTime().hour()){
        hour = QTime::currentTime().hour();

        QByteArray post_data;
        uint t = QDateTime::currentDateTime().toTime_t();

        QString tmp="";
            QString number= QString("%1%2%3").arg("usky").arg(t).arg("056ac8fae059c9c9e700b734922edfc8");
            QByteArray str;
            str = QCryptographicHash::hash(number.toLatin1(),QCryptographicHash::Md5);
            tmp.append(str.toHex());


        post_data.append(QString("requestType=%1&").arg(3));
        post_data.append(QString("publicKey=%1&").arg(tmp));
        post_data.append(QString("timeStamp=%1").arg(t));

        QNetworkRequest *req = new QNetworkRequest();
        req->setUrl(QUrl("https://iot.usky.cn/ytapi/admin/Manage/wooGiApi"));
        req->setHeader(QNetworkRequest::ContentTypeHeader,"application/x-www-form-urlencoded");
        req->setHeader(QNetworkRequest::ContentLengthHeader,post_data.length());
        QNetworkReply* reply = netAccessManager->post(*req,post_data);
    }

    uint t = QDateTime::currentDateTime().toTime_t();
    if(isWorking)
        return;
    isWorking = true;
    if(db.isOpen()){
        devConfList.clear();
        QSqlQuery qry = db.exec("select device_code, comm_type, company_code, dev_name from ytiot_v_video order by device_code");
//        qDebug()<<"select devicd_code, comm_type from ytiot_v_video";
        while(qry.next()){
            devConfList.append(DevConf(qry.value(0).toString(),qry.value(1).toUInt()&0xff,qry.value(2).toString(),qry.value(3).toString()));
//            qDebug()<<qry.value(0).toString().toUtf8().data()<<QString("%1").arg(qry.value(1).toUInt()&0xff).toUtf8().data();
        }
        qry.clear();
    }else
        db.open();
    for(int i=0;i<DEVICES_COUNT;i++){
        t = QDateTime::currentDateTime().toTime_t();
        for(int j=0;j<devConfList.length();j++){
            if(strcmp(ytShm->eHomeDevice[i].deviceID,devConfList.at(j).DeviceId.toUtf8().data())==0)
            {
                ytShm->eHomeDevice[i].io[8] = devConfList.at(j).CommType;
                break;
            }
        }
//        if(QString(ytShm->eHomeDevice[i].filename).length()>0){
//            QFileInfo f_info(QString(ytShm->eHomeDevice[i].filename));
//            if((f_info.exists())&&((t-f_info.lastModified().toTime_t())>120)){
//                system("killall ytCamCore");
//                system("rm -f /usr/local/nginx/html/hls/*");
//                system("rm /tmp/*.mp4");
//                system("ytCamCore &");
//                ytShm->workingTime[0]=t;
//                break;
//            }
//        }
        if(ytShm->eHomeDevice[i].Inited==0x01){
            if(ytShm->eHomeDevice[i].io[1]==0x01)
                ytShm->eHomeDevice[i].io[0]=0x00;
            if(ytShm->eHomeDevice[i].Connected==0x01){
                if((ytShm->eHomeDevice[i].time[0]>0)&&((t-ytShm->eHomeDevice[i].time[0])>10)){
                    if(ytShm->eHomeDevice[i].io[0]==0x01)
                        ytShm->eHomeDevice[i].io[0]=0x00;
//                }else if((ytShm->eHomeDevice[i].time[1]>0)&&((t-ytShm->eHomeDevice[i].time[1])>300)){
//                    if(ytShm->eHomeDevice[i].io[0]==0x01)
//                        ytShm->eHomeDevice[i].io[0]=0x00;
                }
            }
        }
    }
    t = QDateTime::currentDateTime().toTime_t();
    if(((t-ytShm->workingTime[0])>30)&&(isEqual)){
        system("killall ytCamCore");
        system("rm -f /usr/local/nginx/html/hls/*");
        system("rm /tmp/*.mp4");
        system("ytCamCore &");
        ytShm->workingTime[0]=t;
    }
    isWorking = false;
}



void DogObject::finishedSlot(QNetworkReply *reply)
{
    //printf("enter finishedSlot ++++++++++++++\n");
    QVariant status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute);
    if(status_code == 200){
        if(reply->error() == QNetworkReply::NoError){
            QString message = QString::fromUtf8(reply->readAll());
            QByteArray data = message.toLatin1();
            QJsonParseError json_err;
            QJsonDocument jsondoc(QJsonDocument::fromJson(data,&json_err));
            //printf("json_err.error = %d\n ",json_err.error);
            if(json_err.error==QJsonParseError::NoError){
                QJsonObject root = jsondoc.object();
                QJsonObject obj = root.value("data").toObject();
                QString num = "";
                int t = 0;
                if((!obj.value("publicKey").isUndefined())&&(!obj.value("publicKey").isNull())){
                    num = obj.value("publicKey").toString();
                }
                if((!obj.value("timeStamp").isUndefined())&&(!obj.value("timeStamp").isNull())){
                    t = obj.value("timeStamp").toInt();
                }

                QString temp="";
                QString number = QString("%1%2%3").arg("usky").arg(t).arg("056ac8fae059c9c9e700b734922edfc8");
                QByteArray str = QCryptographicHash::hash(number.toLatin1(),QCryptographicHash::Md5);
                temp.append(str.toHex());
                if(QString::compare(num,temp)!=0){
                    isEqual = false;
                }
                else{
                    isEqual = true;
                }


            }


        }else{

        }

    }else{

    }

    reply->abort();
    reply->close();
    reply->deleteLater();
}