添加测试页面相关指令

appsrc/appbase/dep.hpp

@@ -8,6 +8,7 @@
 #include "gconfig.hpp"
 #include "iflytop/core/components/jobs/work_queue.hpp"
 #include "iflytop/core/components/stringutils.hpp"
+#include "iflytop/core/utils/uuid/uuid.hpp"
 #include "project_setting.hpp"
 //
 #include "app_protocols/apperrorcode/apperrorcode.hpp"

appsrc/baseservice/iflytop_front_end_service/iflytop_front_end_service.cpp

@@ -68,7 +68,9 @@ void IflytopFrontEndService::sendReport(json& report) {
    * @brief 广播消息给所有连接的客户端
    */
 
-  report["timeStamp"] = duration_cast<milliseconds>(system_clock::now().time_since_epoch()).count();
+  report["timeStamp"]   = duration_cast<milliseconds>(system_clock::now().time_since_epoch()).count();
+  report["messageId"]   = UUID().toString();
+  report["messageType"] = "Report";
   logger->debug("uplink msg: {}", report.dump());
 
   auto clients = m_reportServer->getClients();
@@ -77,6 +79,12 @@ void IflytopFrontEndService::sendReport(json& report) {
       each->sendText(report.dump());
     }
   }
+  auto serverClients = m_server->getClients();
+  for (auto& each : serverClients) {
+    if (each) {
+      each->sendText(report.dump());
+    }
+  }
 }
 
 void IflytopFrontEndService::onMessageCallback(weak_ptr<WebSocket> webSocket, shared_ptr<ConnectionState> connectionState, const ix::WebSocketMessagePtr& msg) {
@@ -120,9 +128,10 @@ void IflytopFrontEndService::processRxMessage(weak_ptr<WebSocket> webSocket, str
 
     json command = json::parse(msgtext);
     json receipt;
-    receipt["messageId"] = command["messageId"];
-    receipt["ackcode"]   = 0;
-    receipt["timeStamp"] = duration_cast<milliseconds>(system_clock::now().time_since_epoch()).count();
+    receipt["messageId"]   = command["messageId"];
+    receipt["ackcode"]     = 0;
+    receipt["messageType"] = "Ack";
+    receipt["timeStamp"]   = duration_cast<milliseconds>(system_clock::now().time_since_epoch()).count();
     try {
       onMessage(webSocket, command, receipt);
       ws->sendText(receipt.dump(1));
@@ -163,7 +172,6 @@ void IflytopFrontEndService::processRxMessage(weak_ptr<WebSocket> webSocket, str
       ws->sendText(receipt.dump(1));
     }
 
-
   } catch (const std::exception& e) {
     logger->error("m_iflytopWSService:onMessag,parse json failed,exception:{},{}", e.what(), msgtext);
     return;

appsrc/service/test_page_mgr_service.cpp

@@ -8,6 +8,7 @@ void TestPageMgrService::initialize() {
   REGFN(TestPageMgrService, getTestPageCfgInfo);
   REGFN(TestPageMgrService, onButton);
   REGFN(TestPageMgrService, readState);
+  REGFN(TestPageMgrService, triggerOnePrompt);
 }
 
 void TestPageMgrService::getTestPageCfgInfo(shared_ptr<MsgProcessContext> cxt) {
@@ -93,4 +94,21 @@ void TestPageMgrService::readState(shared_ptr<MsgProcessContext> cxt) {
   } else if (stateName == "acCurrent") {
     cxt->content["value"] = "10";
   }
-}
+}
+
+void TestPageMgrService::triggerOnePrompt(shared_ptr<MsgProcessContext> cxt) {
+  // {
+  //     "messageId":"1234",
+  //     "timeStamp":1112312,
+  //     "messageType":"Report",
+  //     "eventType":"Prompt"
+  //     "content":{
+  //        "message":"测试提示信息"
+  //     }
+  // }
+
+  json report;
+  report["eventType"]          = "Prompt";
+  report["content"]["message"] = "测试提示信息.....";
+  GET_SERVICE(IflytopFrontEndService)->sendReport(report);
+}

appsrc/service/test_page_mgr_service.hpp

@@ -26,6 +26,7 @@ class TestPageMgrService : public enable_shared_from_this<TestPageMgrService> {
   void getTestPageCfgInfo(shared_ptr<MsgProcessContext> cxt);
   void onButton(shared_ptr<MsgProcessContext> cxt);
   void readState(shared_ptr<MsgProcessContext> cxt);
+  void triggerOnePrompt(shared_ptr<MsgProcessContext> cxt);
 
  private:
 };