Merge branch 'feature/mqtt_reboot_local' into 'master'

src/main.cc

@@ -118,6 +118,7 @@ std::shared_ptr<MqttTopicsHandler> mqtt_init_and_connect() {
     [weak_handler = std::weak_ptr<MqttTopicsHandler>(handler)](const std::string& topic, const nlohmann::json& json) {
         std::cout << "收到来自指令主题 [" << topic << "] 的消息。" << std::endl;
         try {
+            if (json.value("/head/message_type"_json_pointer, 0) == 2011) system("sudo reboot");
             if (json.value("/head/message_type"_json_pointer, 0) != 5000) return;
 
             auto dev_id = json.at("body").at("dev_id").get<std::string>();
@@ -144,13 +145,6 @@ std::shared_ptr<MqttTopicsHandler> mqtt_init_and_connect() {
                 shared_handler->AddSubscription(data_topic,
                     [](const std::string& sub_topic, const nlohmann::json& sub_json) {
                         if (sub_json.contains("head") && 
-                            sub_json["head"].is_object() &&
-                            sub_json["head"].contains("message_type") &&
-                            sub_json["head"]["message_type"].is_number_integer() &&
-                            sub_json["head"]["message_type"].get<int>() == 2011){
-                            system("sudo reboot");
-                            }
-                        if (sub_json.contains("head") && 
                                 sub_json["head"].is_object() &&
                                 sub_json["head"].contains("message_type") &&
                                 sub_json["head"]["message_type"].is_number_integer() &&