安卓信息消息监听脚本也增加MQTT账号密码的配置处理。

预定系统/README.md

@@ -304,4 +304,6 @@
    - 增加兰州项目定制自动化处理，调试兰州自动化的JSON数据运行。
 87. 2025-05-26：
    - 使用crate_csv_test脚本生成安卓信息上报与心跳上报的csv文件，并使用MQTT脚本模拟两千台设备上报消息至预定系统。
-   - 处理MQTT创建客户端实例时补充账号密码的配置。
\ No newline at end of file
+   - 处理MQTT创建客户端实例时补充账号密码的配置。
+88. 2025-05-27：
+   - 安卓信息消息监听脚本也增加MQTT账号密码的配置处理。
\ No newline at end of file

预定系统/cases/设备管理/安卓信息-消息监听.py

@@ -8,7 +8,7 @@ logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(
 def on_connect(client, userdata, flags, rc):
     logging.info("已连接到MQTT服务器")
     # 订阅多个主题
-    topics = ["/androidPanel/", "/uams/android/broadcast", "/material/client/79f18c1a9a3bcfb1/","rebootResponseTopic"]
+    topics = ["/androidPanel/", "/uams/android/broadcast", "/material/client/79f18c1a9a3bcfb1/", "rebootResponseTopic"]
     for t in topics:
         client.subscribe(t)
 
@@ -17,7 +17,6 @@ def on_message(client, userdata, msg):
 
 if __name__ == "__main__":
     # 5.218测试环境 192.168.5.218 1883
-
     broker_address = "192.168.5.218"
     username = "mqtt@cmdb"  # 你的MQTT用户名
     password = "mqtt@webpassw0RD"  # 你的MQTT密码
@@ -26,6 +25,9 @@ if __name__ == "__main__":
     # 创建 MQTT 客户端实例
     mqtt_client = mqtt.Client()
 
+    # 设置用户名和密码
+    mqtt_client.username_pw_set(username, password)  # 添加账号密码验证
+
     # 设置回调函数
     mqtt_client.on_connect = on_connect
     mqtt_client.on_message = on_message
@@ -42,4 +44,4 @@ if __name__ == "__main__":
 
     finally:
         # 断开与 MQTT 服务器的连接
-        mqtt_client.disconnect()
\ No newline at end of file
+        mqtt_client.disconnect()

预定系统/测试数据/create_csv_text.py

@@ -7,7 +7,7 @@ def create_AndroidMessageUp_csv():
         "appToken": "AND-2IK-0021",
         "companyNumber": "CN-2IK-UBAINS",
         "cnum": "",
-        "conferenceId": "100",
+        "conferenceId": "100",  # 初始值为字符串
         "macAddress": "20:59:20:00:28:01",
     }
 
@@ -32,15 +32,19 @@ def create_AndroidMessageUp_csv():
             app_token = f"AND-2IK-{index_str}"
             auth_code = app_token
 
+            # conferenceId 从100开始递增
+            current_conference_id = str(int(base_data["conferenceId"]) + i)
+
             # 写入一行数据
             writer.writerow([
                 base_data["topic"], client_id, app_token, base_data["companyNumber"],
-                base_data["cnum"], base_data["conferenceId"], base_data["macAddress"],
+                base_data["cnum"], current_conference_id, base_data["macAddress"],
                 auth_code, client_id, device_id
             ])
 
     print(f"成功生成 {output_file} 文件，包含2000条数据。")
 
+
 import csv
 
 def create_Androidbroadcast_csv():
@@ -75,6 +79,6 @@ def create_Androidbroadcast_csv():
     print(f"成功生成 {output_file} 文件，包含2000条数据。")
 
 
-if __name__ == "__main__":
-    create_AndroidMessageUp_csv()
-    create_Androidbroadcast_csv()
\ No newline at end of file
+# if __name__ == "__main__":
+    # create_AndroidMessageUp_csv()
+    # create_Androidbroadcast_csv()
\ No newline at end of file