添加异步发送socket函数

fmp_epay_p.cpp

@@ -94,6 +94,7 @@ void FMPePayPrivate::Init()
     Q_Q(FMPePay);
     q->_inited = true;
     _wakeupByMonitor=false;
+    _preOrderDone=true;
     clearorder();
 
     if(_network == nullptr)
@@ -586,6 +587,9 @@ void FMPePayPrivate::ParsePayJson(const QByteArray &json)
     QJsonDocument jsonDoc = QJsonDocument::fromJson( json, &jsonError);
     if(jsonError.error == QJsonParseError::NoError)
     {
+        if(!_preOrderDone){
+
+        }
         QJsonObject jsonObject = jsonDoc.object();
         QJsonArray _array = jsonObject["transactions"].toArray();
         QJsonObject transactions=_array.at(0).toObject();
@@ -598,6 +602,7 @@ void FMPePayPrivate::ParsePayJson(const QByteArray &json)
         if(_payDialog != NULL)
             _payDialog->setEditNum(order_amount);
         _wakeupByMonitor=true;
+        _preOrderDone=false;
 
     }else
     {
@@ -632,3 +637,19 @@ void FMPePayPrivate::SetWakeupFlag(bool status)
 {
     _wakeupByMonitor=status;
 }
+
+void FMPePayPrivate::SendToMonitor(const QByteArray &data)
+{
+    QTcpSocket client;
+   // char data[]="hello qt!";
+    client.connectToHost(QHostAddress("127.0.0.1"), 23771);
+    if (client.waitForConnected()){
+        client->write(data);
+        if(!client.waitForBytesWritten())
+            FMP_INFO() << "socket 发送失败！";
+    }
+    else{
+        FMP_INFO() << "socket 连接失败！";
+    }
+    client.close();
+}

fmp_epay_p.h

@@ -37,6 +37,7 @@ public:
 
     void                SetWakeupFlag(bool status);
     void                ClosePayWindow(int type=1);
+    void                SendToMonitor(const QByteArray &data);
 
     QSqlTableModel      *model() const;
 
@@ -77,6 +78,7 @@ public:
 
 private:
     bool                _wakeupByMonitor;
+    bool                _preOrderDone;    //前一个订单是否已经处理结束
     QJsonObject         _current_json;
     QByteArray          _pay_json;