1.爆破工程下发所有未注册的工程

blastProject/HProjectDao.h

@@ -26,6 +26,7 @@ public:
     HProject getHProjectById(qint64 id);
     PaginatedHProjectResult getAllHProjects(int page, int pageSize);
     PaginatedHProjectResult getAllHProjectsByOpera(int page, int pageSize);
+    QList<QSharedPointer<HProject> > getAllHProjectsReg();
 
 private:
     QSqlDatabase database;

blastProject/blastprojectpage.cpp

@@ -260,8 +260,21 @@ void BlastProjectPage::insertPlan(const QMap<QString, QString> &data)
     project.setCreatedAt(QDateTime::currentDateTime());
     if(dao.addHProject(project)){
         RefreshData();
-        QByteArray jsonData  = project.ProjectToJson(project);
-        client->sendMessage("hxgc/companycode", jsonData);
+        QJsonArray jsonArray;
+        QList<QSharedPointer<HProject>> projectsReg = dao.getAllHProjectsReg();
+        for (const auto& projectPtr : projectsReg) {
+            if (projectPtr) {
+                QByteArray projectJson = projectPtr->ProjectToJson(*projectPtr);
+                QJsonDocument doc = QJsonDocument::fromJson(projectJson);
+                jsonArray.append(doc.object());
+            }
+        }
+
+        QJsonDocument jsonDoc(jsonArray);
+        QByteArray jsonData = jsonDoc.toJson(QJsonDocument::Indented);
+
+        client->sendMessage("hxgc/companycode/pro/B", jsonData);
+        qDebug() <<"mqtt单例："<< client;
     }
 
 }

blastProject/hprojectdao.cpp

@@ -169,6 +169,21 @@ PaginatedHProjectResult HProjectDao::getAllHProjectsByOpera(int page, int pageSi
     return { projects, totalCount };
 }
 
+QList<QSharedPointer<HProject>> HProjectDao::getAllHProjectsReg()
+{
+    QList<QSharedPointer<HProject>> projects;
+    QSqlQuery query(database);
+    query.prepare("SELECT * FROM h_project WHERE blast_status =1 ORDER BY created_at ");
+    // 执行查询并打印SQL
+    if (query.exec()) {
+        while (query.next()) {
+            projects.append(recordToProject(query.record()));
+        }
+    } else {
+        qWarning() << "Query execution failed: " << query.lastError().text();
+    }
+    return projects;
+}
 
 //更改状态
 bool HProjectDao::updateBlastStatusByUuid(const QString &uuid, const QString &blastStatus)