mqtt/mqtt_recv.py

@@ -235,6 +235,7 @@ def deal_get_debug_info(msg:mqtt.MQTTMessage):
             }
             plans_info.append(item)
 
+        LOGINFO(f"send debug info ...")
         mqtt_send.las_debug_info(plans_info)
 
     except json.JSONDecodeError as e:

mqtt/mqtt_send.py

@@ -92,7 +92,8 @@ def las_test_resp():
 def las_debug_info(plans_info:list):
     sp_id   = sys_comm.g_sys_conf["sp_id"]
     format_json = dict()
-    format_json["plans_info"]       = plans_info
-    format_json["sp_id"]            = sp_id
-    send_msg(TOPICS.las_test_resp, format_json, 2)
+    format_json["plans_info"]   = plans_info
+    format_json["plans_total"]  = len(plans_info)
+    format_json["sp_id"]        = sp_id
+    send_msg(TOPICS.las_debug_info, format_json, 0)