|
|
@@ -14,13 +14,29 @@ wgelectcore::wgelectcore(QObject *parent) : QObject(parent)
|
|
|
dbThread->start();
|
|
|
connect(dbThread,&DatabaseThread::AlarmReport,this,&wgelectcore::AlarmReport);
|
|
|
|
|
|
+ elcomthread = new ELCommThread(this);
|
|
|
+ connect(elcomthread,&ELCommThread::SendDevData,this,&wgelectcore::ReceiveDevData);
|
|
|
+
|
|
|
electdata = new Electdata(this);
|
|
|
connect(electdata,&Electdata::SendLog,this,&wgelectcore::ReceiveLog);
|
|
|
connect(electdata,&Electdata::appendSql,this,&wgelectcore::appendSql);
|
|
|
connect(electdata,&Electdata::appendAlarm,this,&wgelectcore::appendAlarm);
|
|
|
|
|
|
- elcomthread = new ELCommThread(this);
|
|
|
- connect(elcomthread,&ELCommThread::SendDevData,this,&wgelectcore::ReceiveDevData);
|
|
|
+ elcomthread171 = new ELCommThread171(this);
|
|
|
+ connect(elcomthread171,&ELCommThread171::sendDevData171,this,&wgelectcore::ReceiveDevData171);
|
|
|
+
|
|
|
+ electdata171 = new Electdata171(this);
|
|
|
+ connect(electdata171,&Electdata171::sendLog,this,&wgelectcore::ReceiveLog);
|
|
|
+ connect(electdata171,&Electdata171::appendSql,this,&wgelectcore::appendSql);
|
|
|
+ connect(electdata171,&Electdata171::appendAlarm,this,&wgelectcore::appendAlarm);
|
|
|
+
|
|
|
+ elcomthread173 = new ELCommThread173(this);
|
|
|
+ connect(elcomthread173,&ELCommThread173::sendDevData173,this,&wgelectcore::ReceiveDevData173);
|
|
|
+
|
|
|
+ electdata173 = new Electdata173(this);
|
|
|
+ connect(electdata173,&Electdata173::sendLog,this,&wgelectcore::ReceiveLog);
|
|
|
+ connect(electdata173,&Electdata173::appendSql,this,&wgelectcore::appendSql);
|
|
|
+ connect(electdata173,&Electdata173::appendAlarm,this,&wgelectcore::appendAlarm);
|
|
|
|
|
|
elcompub = new ELCommThreadPub(this);
|
|
|
connect(elcompub,&ELCommThreadPub::SendPubData,this,&wgelectcore::ReceiveLog);
|
|
|
@@ -36,8 +52,23 @@ wgelectcore::wgelectcore(QObject *parent) : QObject(parent)
|
|
|
netAccessManager = new QNetworkAccessManager(this);
|
|
|
connect(netAccessManager,SIGNAL(finished(QNetworkReply*)),this,SLOT(finishedSlot(QNetworkReply*)));
|
|
|
|
|
|
+ netAccessManager1 = new QNetworkAccessManager(this);
|
|
|
+ connect(netAccessManager1,SIGNAL(finished(QNetworkReply*)),this,SLOT(finishedSlot1(QNetworkReply*)));
|
|
|
+
|
|
|
+ netAccessManager2 = new QNetworkAccessManager(this);
|
|
|
+ connect(netAccessManager2,SIGNAL(finished(QNetworkReply*)),this,SLOT(finishedSlot2(QNetworkReply*)));
|
|
|
+
|
|
|
+ netAccessManager3 = new QNetworkAccessManager(this);
|
|
|
+ connect(netAccessManager3,SIGNAL(finished(QNetworkReply*)),this,SLOT(finishedSlot3(QNetworkReply*)));
|
|
|
+
|
|
|
+ timer = new QTimer(this);
|
|
|
+ connect(timer,SIGNAL(timeout()),this,SLOT(time_out()));
|
|
|
+
|
|
|
WXList.clear();
|
|
|
+ WXList171.clear();
|
|
|
+ WXList173.clear();
|
|
|
count =0;
|
|
|
+ hour = 255;
|
|
|
|
|
|
}
|
|
|
|
|
|
@@ -46,19 +77,54 @@ wgelectcore::~wgelectcore()
|
|
|
logThread->stop();
|
|
|
dbThread->stop();
|
|
|
electdata->stop();
|
|
|
+ electdata171->stop();
|
|
|
+ electdata173->stop();
|
|
|
|
|
|
netAccessManager->deleteLater();
|
|
|
+ netAccessManager1->deleteLater();
|
|
|
+ netAccessManager2->deleteLater();
|
|
|
+ netAccessManager3->deleteLater();
|
|
|
}
|
|
|
|
|
|
void wgelectcore::start()
|
|
|
{
|
|
|
electdata->start();
|
|
|
+ electdata171->start();
|
|
|
+ electdata173->start();
|
|
|
elcompub->start();
|
|
|
elcomsub->start();
|
|
|
ws->start();
|
|
|
+ timer->start(60000);
|
|
|
|
|
|
}
|
|
|
|
|
|
+void wgelectcore::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);
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
|
|
|
|
|
|
void wgelectcore::ReceiveDevData(QString topic,QByteArray devdata)
|
|
|
@@ -68,6 +134,17 @@ void wgelectcore::ReceiveDevData(QString topic,QByteArray devdata)
|
|
|
electdata->DevMessage(DevData(topic,devdata));
|
|
|
}
|
|
|
|
|
|
+void wgelectcore::ReceiveDevData171(QString topic,QByteArray devdata)
|
|
|
+{
|
|
|
+ electdata171->DevMessage(DevData171(topic,devdata));
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void wgelectcore::ReceiveDevData173(QString topic,QByteArray devdata)
|
|
|
+{
|
|
|
+ electdata173->DevMessage(DevData173(topic,devdata));
|
|
|
+}
|
|
|
+
|
|
|
void wgelectcore::ReceiveLog(QString topic,QString devdata,QByteArray devBData)
|
|
|
{
|
|
|
logThread->appendData(QString("time: %1, topic: %2, devicedata: %3, \n QJasonArray: %4\r\n").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")).arg(topic).arg(devdata).arg(QString(devBData)));
|
|
|
@@ -101,45 +178,115 @@ void wgelectcore::AlarmReport(QString DeviceCode,QString lastid,QString SETime,Q
|
|
|
if(wgdev->devs[i].Enabled == 0x01){
|
|
|
if(DeviceCode.compare(wgdev->devs[i].deviceCode)==0){
|
|
|
wgdev->devs[i].LastCommtime=(QDateTime::currentDateTime()).toTime_t();
|
|
|
- for(int j=0;j<35;j++){
|
|
|
- if(QString(wgdev->devs[i].alarm[j].measname).compare("BusOutage")==0){
|
|
|
- busTime0 = wgdev->devs[i].alarm[j].soetime0;
|
|
|
- busTime1 = wgdev->devs[i].alarm[j].soetime1;
|
|
|
+ if(wgdev->devs[i].devicetype == 1){
|
|
|
+ for(int j=0;j<35;j++){
|
|
|
+ if(QString(wgdev->devs[i].alarm[j].measname).compare("BusOutage")==0){
|
|
|
+ busTime0 = wgdev->devs[i].alarm[j].soetime0;
|
|
|
+ busTime1 = wgdev->devs[i].alarm[j].soetime1;
|
|
|
|
|
|
+ }
|
|
|
}
|
|
|
- }
|
|
|
- for(int j=0;j<35;j++){
|
|
|
- if(MeasName.compare(wgdev->devs[i].alarm[j].measname)==0){
|
|
|
- if(DigitalValue.compare("0")==0){
|
|
|
- if((soeTime-wgdev->devs[i].alarm[j].soetime0)>60){
|
|
|
- if((soeTime-busTime0)>60){
|
|
|
- WXRep wxrep = WXRep(DeviceCode,lastid,SETime,MeasDesc,DigitalValue);
|
|
|
- WXList.append(wxrep);
|
|
|
- //推送微信端
|
|
|
- sendData();
|
|
|
- printf("推送微信端 soeTime = %d, busTime0 = %d ,digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,busTime0,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
+ for(int j=0;j<35;j++){
|
|
|
+ if(MeasName.compare(wgdev->devs[i].alarm[j].measname)==0){
|
|
|
+ if(DigitalValue.compare("0")==0){
|
|
|
+ if((soeTime-wgdev->devs[i].alarm[j].soetime0)>60){
|
|
|
+ if((soeTime-busTime0)>60){
|
|
|
+ WXRep wxrep = WXRep(DeviceCode,lastid,SETime,MeasDesc,DigitalValue,MeasName);
|
|
|
+ WXList.append(wxrep);
|
|
|
+ //推送微信端
|
|
|
+ sendData();
|
|
|
+ printf("推送微信端 soeTime = %d, busTime0 = %d ,digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,busTime0,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
+
|
|
|
+
|
|
|
+ wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
+ wgdev->devs[i].alarm[j].soetime0 = soeTime;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }else{
|
|
|
+ if((soeTime-wgdev->devs[i].alarm[j].soetime1)>60){
|
|
|
+ if((soeTime-busTime1)>60){
|
|
|
+ WXRep wxrep = WXRep(DeviceCode,lastid,SETime,MeasDesc,DigitalValue,MeasName);
|
|
|
+ WXList.append(wxrep);
|
|
|
+ //推送微信端
|
|
|
+ sendData();
|
|
|
+ printf("推送微信端 soeTime = %d, busTime1 = %d ,digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,busTime1,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
+
|
|
|
|
|
|
+ wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
+ wgdev->devs[i].alarm[j].soetime1 = soeTime;
|
|
|
+ }
|
|
|
}
|
|
|
+
|
|
|
}
|
|
|
|
|
|
- wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
- wgdev->devs[i].alarm[j].soetime0 = soeTime;
|
|
|
- }else{
|
|
|
- if((soeTime-wgdev->devs[i].alarm[j].soetime1)>60){
|
|
|
- if((soeTime-busTime1)>60){
|
|
|
- WXRep wxrep = WXRep(DeviceCode,lastid,SETime,MeasDesc,DigitalValue);
|
|
|
- WXList.append(wxrep);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }else if(wgdev->devs[i].devicetype == 3){
|
|
|
+ for(int j=0;j<16;j++){
|
|
|
+ if(MeasName.compare(wgdev->devs[i].alarm[j].measname)==0){
|
|
|
+ if(DigitalValue.compare("0")==0){
|
|
|
+ if((soeTime-wgdev->devs[i].alarm[j].soetime0)>60){
|
|
|
+ WXRep17 wxrep = WXRep17(DeviceCode,lastid,SETime,MeasDesc,DigitalValue);
|
|
|
+ WXList171.append(wxrep);
|
|
|
//推送微信端
|
|
|
- sendData();
|
|
|
- printf("推送微信端 soeTime = %d, busTime1 = %d ,digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,busTime1,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
+ sendData171();
|
|
|
+ printf("推送微信端 soeTime = %d, digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
|
|
|
+
|
|
|
+ wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
+ wgdev->devs[i].alarm[j].soetime0 = soeTime;
|
|
|
}
|
|
|
+
|
|
|
+ }else{
|
|
|
+ if((soeTime-wgdev->devs[i].alarm[j].soetime1)>60){
|
|
|
+ WXRep17 wxrep = WXRep17(DeviceCode,lastid,SETime,MeasDesc,DigitalValue);
|
|
|
+ WXList171.append(wxrep);
|
|
|
+ //推送微信端
|
|
|
+ sendData171();
|
|
|
+ printf("推送微信端 soeTime = %d, digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
+
|
|
|
+
|
|
|
+ wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
+ wgdev->devs[i].alarm[j].soetime1 = soeTime;
|
|
|
+ }
|
|
|
+
|
|
|
}
|
|
|
|
|
|
- wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
- wgdev->devs[i].alarm[j].soetime1 = soeTime;
|
|
|
}
|
|
|
+ }
|
|
|
+ }else if(wgdev->devs[i].devicetype == 4){
|
|
|
+ for(int j=0;j<18;j++){
|
|
|
+ if(MeasName.compare(wgdev->devs[i].alarm[j].measname)==0){
|
|
|
+ if(DigitalValue.compare("0")==0){
|
|
|
+ if((soeTime-wgdev->devs[i].alarm[j].soetime0)>60){
|
|
|
+ WXRep17 wxrep = WXRep17(DeviceCode,lastid,SETime,MeasDesc,DigitalValue);
|
|
|
+ WXList173.append(wxrep);
|
|
|
+ //推送微信端
|
|
|
+ sendData173();
|
|
|
+ printf("推送微信端 soeTime = %d, digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
+
|
|
|
+
|
|
|
+ wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
+ wgdev->devs[i].alarm[j].soetime0 = soeTime;
|
|
|
+ }
|
|
|
+
|
|
|
+ }else{
|
|
|
+ if((soeTime-wgdev->devs[i].alarm[j].soetime1)>60){
|
|
|
+ WXRep17 wxrep = WXRep17(DeviceCode,lastid,SETime,MeasDesc,DigitalValue);
|
|
|
+ WXList173.append(wxrep);
|
|
|
+ //推送微信端
|
|
|
+ sendData173();
|
|
|
+ printf("推送微信端 soeTime = %d, digital[digitalNo] = %s,DigitalValue.toUtf8().data()= %s,DigitalValue.toUInt() = %d \n",soeTime,MeasName.toUtf8().data(),DigitalValue.toUtf8().data(),DigitalValue.toUInt());
|
|
|
+
|
|
|
+
|
|
|
+ wgdev->devs[i].alarm[j].digitalvalue = DigitalValue.toUInt();
|
|
|
+ wgdev->devs[i].alarm[j].soetime1 = soeTime;
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
@@ -152,7 +299,9 @@ void wgelectcore::AlarmReport(QString DeviceCode,QString lastid,QString SETime,Q
|
|
|
|
|
|
void wgelectcore::finishedSlot(QNetworkReply *reply)
|
|
|
{
|
|
|
- printf("enter finishedSlot++++++++++++++\n");
|
|
|
+ WXList.removeFirst();
|
|
|
+
|
|
|
+ //printf("enter finishedSlot++++++++++++++\n");
|
|
|
QVariant status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute);
|
|
|
if(status_code == 200){
|
|
|
if(reply->error() == QNetworkReply::NoError){
|
|
|
@@ -171,7 +320,6 @@ void wgelectcore::finishedSlot(QNetworkReply *reply)
|
|
|
}
|
|
|
|
|
|
}else{
|
|
|
- WXList.removeFirst();
|
|
|
logThread->appendData(QString("%1-----WXChartThread::finishedSlot fail------").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")));
|
|
|
}
|
|
|
|
|
|
@@ -181,10 +329,122 @@ void wgelectcore::finishedSlot(QNetworkReply *reply)
|
|
|
}
|
|
|
|
|
|
|
|
|
+void wgelectcore::finishedSlot1(QNetworkReply *reply)
|
|
|
+{
|
|
|
+ //printf("enter finishedSlot1 ++++++++++++++\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){
|
|
|
+ exit(1);
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ }else{
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ }else{
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ reply->abort();
|
|
|
+ reply->close();
|
|
|
+ reply->deleteLater();
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void wgelectcore::finishedSlot2(QNetworkReply *reply)
|
|
|
+{
|
|
|
+ WXList173.removeFirst();
|
|
|
+
|
|
|
+ //printf("enter finishedSlot2++++++++++++++\n");
|
|
|
+ QVariant status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute);
|
|
|
+ if(status_code == 200){
|
|
|
+ if(reply->error() == QNetworkReply::NoError){
|
|
|
+ QString message = QString::fromUtf8(reply->readAll());
|
|
|
+ logThread->appendData(QString("%1 WXChartThread send success message: %2").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")).arg(message));
|
|
|
+ }else{
|
|
|
+// count++;
|
|
|
+// sendData();
|
|
|
+// if(count > 9){
|
|
|
+// count = 0;
|
|
|
+// WXList.removeFirst();
|
|
|
+// }
|
|
|
+
|
|
|
+ //logThread->appendData(QString("WXChartThread send error 重发次数: %1 InsertId: %2").arg(count).arg(WXList173.first().LastId));
|
|
|
+ logThread->appendData(QString("%1 WXChartThread send error ").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")));
|
|
|
+ }
|
|
|
+
|
|
|
+ }else{
|
|
|
+ logThread->appendData(QString("%1-----WXChartThread::finishedSlot2 fail------").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")));
|
|
|
+ }
|
|
|
+
|
|
|
+ reply->abort();
|
|
|
+ reply->close();
|
|
|
+ reply->deleteLater();
|
|
|
+}
|
|
|
+
|
|
|
+void wgelectcore::finishedSlot3(QNetworkReply *reply)
|
|
|
+{
|
|
|
+ WXList171.removeFirst();
|
|
|
+
|
|
|
+ //printf("enter finishedSlot3++++++++++++++\n");
|
|
|
+ QVariant status_code = reply->attribute(QNetworkRequest::HttpStatusCodeAttribute);
|
|
|
+ if(status_code == 200){
|
|
|
+ if(reply->error() == QNetworkReply::NoError){
|
|
|
+ QString message = QString::fromUtf8(reply->readAll());
|
|
|
+ logThread->appendData(QString("%1 WXChartThread send success message: %2").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")).arg(message));
|
|
|
+ }else{
|
|
|
+// count++;
|
|
|
+// sendData();
|
|
|
+// if(count > 9){
|
|
|
+// count = 0;
|
|
|
+// WXList.removeFirst();
|
|
|
+// }
|
|
|
+
|
|
|
+ //logThread->appendData(QString("WXChartThread send error 重发次数: %1 InsertId: %2").arg(count).arg(WXList173.first().LastId));
|
|
|
+ logThread->appendData(QString("%1 WXChartThread send error ").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")));
|
|
|
+ }
|
|
|
+
|
|
|
+ }else{
|
|
|
+ logThread->appendData(QString("%1-----WXChartThread::finishedSlot3 fail------").arg(QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")));
|
|
|
+ }
|
|
|
+
|
|
|
+ reply->abort();
|
|
|
+ reply->close();
|
|
|
+ reply->deleteLater();
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
void wgelectcore::sendData()
|
|
|
{
|
|
|
WXRep data = WXList.first();
|
|
|
- WXList.removeFirst();
|
|
|
+ //WXList.removeFirst();
|
|
|
QByteArray post_data;
|
|
|
post_data.append(QString("device_code=%1&").arg(data.DeviceCode));
|
|
|
post_data.append(QString("insert_id=%1&").arg(data.LastId));
|
|
|
@@ -193,10 +453,11 @@ void wgelectcore::sendData()
|
|
|
post_data.append(QString("evt_name=%1&").arg(data.MeasDesc));
|
|
|
post_data.append(QString("user_from=%1&").arg("CDL1"));
|
|
|
post_data.append(QString("alarm_status=%1&").arg(data.DigitalValue));
|
|
|
+ post_data.append(QString("meas_name=%1&").arg(data.MeasName));
|
|
|
post_data.append(QString("bz=%1").arg("测试阶段"));
|
|
|
|
|
|
QNetworkRequest *req = new QNetworkRequest();
|
|
|
- req->setUrl(QUrl("https://iot.usky.cn/jdxf/wxapp7.php/Home/Powerwarn/message_dl"));
|
|
|
+ req->setUrl(QUrl("https://wx.ewoogi.com/USKYOF/USKYOF.php/Home/Powerwarn/message_dl"));
|
|
|
req->setHeader(QNetworkRequest::ContentTypeHeader,"application/x-www-form-urlencoded");
|
|
|
req->setHeader(QNetworkRequest::ContentLengthHeader,post_data.length());
|
|
|
QNetworkReply* reply = netAccessManager->post(*req,post_data);
|
|
|
@@ -205,6 +466,55 @@ void wgelectcore::sendData()
|
|
|
}
|
|
|
|
|
|
|
|
|
+void wgelectcore::sendData171()
|
|
|
+{
|
|
|
+ WXRep17 data = WXList171.first();
|
|
|
+ //WXList171.removeFirst();
|
|
|
+ QByteArray post_data;
|
|
|
+ post_data.append(QString("device_code=%1&").arg(data.DeviceCode));
|
|
|
+ post_data.append(QString("insert_id=%1&").arg(data.LastId));
|
|
|
+ post_data.append(QString("phone=%1&").arg("17630065224"));
|
|
|
+ post_data.append(QString("time=%1&").arg(data.SoeTime));
|
|
|
+ post_data.append(QString("evt_name=%1&").arg(data.MeasDesc));
|
|
|
+ post_data.append(QString("user_from=%1&").arg("CDL1"));
|
|
|
+ post_data.append(QString("alarm_status=%1&").arg(data.DigitalValue));
|
|
|
+ post_data.append(QString("bz=%1").arg("测试阶段"));
|
|
|
+
|
|
|
+ QNetworkRequest *req = new QNetworkRequest();
|
|
|
+ //req->setUrl(QUrl("https://iot.usky.cn/jdxf/wxapp7.php/Home/Powerwarn/message_dl"));
|
|
|
+ req->setUrl(QUrl("https://iot.usky.cn/ytapi/admin/Manage/ceShiUrl"));
|
|
|
+ req->setHeader(QNetworkRequest::ContentTypeHeader,"application/x-www-form-urlencoded");
|
|
|
+ req->setHeader(QNetworkRequest::ContentLengthHeader,post_data.length());
|
|
|
+ QNetworkReply* reply = netAccessManager3->post(*req,post_data);
|
|
|
+
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+void wgelectcore::sendData173()
|
|
|
+{
|
|
|
+ WXRep17 data = WXList173.first();
|
|
|
+ //WXList173.removeFirst();
|
|
|
+ QByteArray post_data;
|
|
|
+ post_data.append(QString("device_code=%1&").arg(data.DeviceCode));
|
|
|
+ post_data.append(QString("insert_id=%1&").arg(data.LastId));
|
|
|
+ post_data.append(QString("phone=%1&").arg("17630065224"));
|
|
|
+ post_data.append(QString("time=%1&").arg(data.SoeTime));
|
|
|
+ post_data.append(QString("evt_name=%1&").arg(data.MeasDesc));
|
|
|
+ post_data.append(QString("user_from=%1&").arg("CDL1"));
|
|
|
+ post_data.append(QString("alarm_status=%1&").arg(data.DigitalValue));
|
|
|
+ post_data.append(QString("bz=%1").arg("测试阶段"));
|
|
|
+
|
|
|
+ QNetworkRequest *req = new QNetworkRequest();
|
|
|
+ //req->setUrl(QUrl("https://iot.usky.cn/jdxf/wxapp7.php/Home/Powerwarn/message_dl"));
|
|
|
+ req->setUrl(QUrl("https://iot.usky.cn/ytapi/admin/Manage/ceShiUrl"));
|
|
|
+ req->setHeader(QNetworkRequest::ContentTypeHeader,"application/x-www-form-urlencoded");
|
|
|
+ req->setHeader(QNetworkRequest::ContentLengthHeader,post_data.length());
|
|
|
+ QNetworkReply* reply = netAccessManager2->post(*req,post_data);
|
|
|
+
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
void wgelectcore::receivewsdata(QString devicename,QString method,QString faultrecordtype,QString starttime,QString endtime)
|
|
|
{
|
|
|
elcompub->dataPub(devicename,method,faultrecordtype,starttime,endtime);
|
