Merge branch 'feature-1007488' into 'release'

修改mqtt断线08

See merge request !70

CameraHandle.cpp

@@ -1072,11 +1072,8 @@ int CameraHandle::resetGb28181(QString &uuiq){
         }
         }
     }
     }
     // 阻塞等待5秒
     // 阻塞等待5秒
-    //QThread::sleep(5);
-    QTimer* timer = new QTimer(this);
-    timer->moveToThread(this->thread());
+    QThread::sleep(5);
     // 连接 QTimer 的超时信号到匿名槽函数
     // 连接 QTimer 的超时信号到匿名槽函数
-    QObject::connect(timer, &QTimer::timeout, [this, &is_wifi, &result, &uuiq, &connectedCameraHandle, &newHandle, &device, &old, timer]() {
     QString old_ip;
     QString old_ip;
     int res = 1;
     int res = 1;
     MainWindow::sp_this->findSnMapIp(this->sSn, old_ip);
     MainWindow::sp_this->findSnMapIp(this->sSn, old_ip);
@@ -1109,13 +1106,7 @@ int CameraHandle::resetGb28181(QString &uuiq){
             }
             }
         }
         }
     }
     }
-        MainWindow::sp_this->mqttEmitAsynchronous(uuiq, res, device.sSn);
-        timer->deleteLater(); // 确保在任务完成后删除 QTimer
-    });
 
 
-    // 设置 QTimer 的超时时间为 5 秒
-    timer->setSingleShot(true);
-    timer->start(5000);
     //this->updateSdkDevStatus(true);
     //this->updateSdkDevStatus(true);
     return 1;
     return 1;
 }
 }

MqttSubscriber.cpp

@@ -58,8 +58,6 @@ void MqttSubscriber::init(vides_data::MqttConfig &config, QString &httpUrl, QStr
 MqttSubscriber::MqttSubscriber(QObject* parent)
 MqttSubscriber::MqttSubscriber(QObject* parent)
     : QObject(parent), retryTimer(new QTimer(this)), client(nullptr) {
     : QObject(parent), retryTimer(new QTimer(this)), client(nullptr) {
 
 
-    connect(this, &MqttSubscriber::asynchronousMqtt, this, &MqttSubscriber::asynchronousPush, Qt::QueuedConnection);
-
     
     
     // 连接信号和槽
     // 连接信号和槽
     connect(this, &MqttSubscriber::connectionLostSignal, this, &MqttSubscriber::reconnectAndFetchConfig, Qt::QueuedConnection);
     connect(this, &MqttSubscriber::connectionLostSignal, this, &MqttSubscriber::reconnectAndFetchConfig, Qt::QueuedConnection);
@@ -107,9 +105,6 @@ void MqttSubscriber::start() {
         qInfo() << "启动连接失败，返回编码" << rc;
         qInfo() << "启动连接失败，返回编码" << rc;
     }
     }
 }
 }
-void MqttSubscriber::emitAsynchronous(QString &uniq,int &res,QString &sn){
-    emit asynchronousMqtt(uniq,res,sn);
-}
 
 
 
 
 void MqttSubscriber::onConnect(MQTTAsync_successData* response) {
 void MqttSubscriber::onConnect(MQTTAsync_successData* response) {
@@ -250,11 +245,6 @@ int MqttSubscriber::messageArrived(char* topicName, int topicLen, MQTTAsync_mess
         }
         }
         res=(connectedCameraHandle->distributionNetwork(ipAddress,response.sn,hDevice)?0x01 :-1);
         res=(connectedCameraHandle->distributionNetwork(ipAddress,response.sn,hDevice)?0x01 :-1);
     }
     }
-    if (response.msg_type == 8) {
-        qInfo() << "mqtt 复位GB28181 异步走卡槽函数触发";
-        return  -1;
-    }
-
     vides_data::requestMqttData request;
     vides_data::requestMqttData request;
     request.code = (res >= 0) ? 0 : 0x01;
     request.code = (res >= 0) ? 0 : 0x01;
     request.msg =  (res >= 0) ?"成功":"失败";
     request.msg =  (res >= 0) ?"成功":"失败";
@@ -265,14 +255,6 @@ int MqttSubscriber::messageArrived(char* topicName, int topicLen, MQTTAsync_mess
     MQTTAsync_free(topicName);
     MQTTAsync_free(topicName);
     return 1;
     return 1;
 }
 }
-void MqttSubscriber::asynchronousPush(QString &uniq,int &res,QString &sn){
-    vides_data::requestMqttData request;
-    request.code = (res >= 0) ? 0 : 0x01;
-    request.msg =  (res >= 0) ?"成功":"失败";
-    request.uniq= uniq;
-    sendSubscriptionConfirmation(request,sn);
-}
-
 void MqttSubscriber::sendSubscriptionConfirmation(const vides_data::requestMqttData& response,QString &sn) {
 void MqttSubscriber::sendSubscriptionConfirmation(const vides_data::requestMqttData& response,QString &sn) {
     QString responseTopic = "/thingshub/" +response.uniq+ "/device/post";
     QString responseTopic = "/thingshub/" +response.uniq+ "/device/post";
     QByteArray bResponseTopic = responseTopic.toUtf8();
     QByteArray bResponseTopic = responseTopic.toUtf8();

MqttSubscriber.h

@@ -14,15 +14,12 @@ public:
 
 
     void init(vides_data:: MqttConfig& config,QString &httpUrl,QString &serialNumber);
     void init(vides_data:: MqttConfig& config,QString &httpUrl,QString &serialNumber);
     void start();
     void start();
-    void emitAsynchronous(QString &uniq,int &res,QString &sn);
 signals:
 signals:
    void connectionLostSignal();
    void connectionLostSignal();
-   void asynchronousMqtt(QString &uniq,int &res,QString &sn);
 
 
 
 
 private slots:
 private slots:
     void reconnectAndFetchConfig();
     void reconnectAndFetchConfig();
-    void asynchronousPush(QString &uniq,int &res,QString &sn);
 
 
 private:
 private:
     MqttSubscriber(QObject* parent = nullptr);
     MqttSubscriber(QObject* parent = nullptr);

mainwindow.cpp

@@ -133,12 +133,6 @@ MainWindow::MainWindow():isResetting(false)
     this->mqttConfig= config.mqttConfig;
     this->mqttConfig= config.mqttConfig;
     runOrRebootMqtt(mqttConfig,httpurl,serialNumber);
     runOrRebootMqtt(mqttConfig,httpurl,serialNumber);
 }
 }
-
-void MainWindow::mqttEmitAsynchronous(QString &uuiq,int &res,QString &sn){
-    MqttSubscriber* subscriber = MqttSubscriber::getInstance(this);
-    subscriber->emitAsynchronous(uuiq,res,sn);
-}
-
 void MainWindow::runOrRebootMqtt(vides_data::MqttConfig &mqtt_config,QString &httpUrl,QString &serialNumber){
 void MainWindow::runOrRebootMqtt(vides_data::MqttConfig &mqtt_config,QString &httpUrl,QString &serialNumber){
     MqttSubscriber* subscriber = MqttSubscriber::getInstance(this);
     MqttSubscriber* subscriber = MqttSubscriber::getInstance(this);
     subscriber->init(mqtt_config,httpUrl,serialNumber);
     subscriber->init(mqtt_config,httpUrl,serialNumber);

mainwindow.h

@@ -50,8 +50,6 @@ public:
     
     
     static MainWindow * sp_this;
     static MainWindow * sp_this;
     
     
-    void mqttEmitAsynchronous(QString &uniq,int &res,QString &sn);
-    
     CameraHandle* findHandle(QString sn);
     CameraHandle* findHandle(QString sn);
 
 
     void modifySnMapIp(QString &sn,QString &ip);
     void modifySnMapIp(QString &sn,QString &ip);