2024-10-24

   - 优化MQTT底层方法，通过判断topic的值来发送不同的消息体。
   - 优化安卓信息上报.py脚本通过读配置文件中的topic，调用build_message时传入topic进行主题判断。后续方便进行MQTT主题与消息体的管理。
   - 补充毫米波雷达数据上报数据，毫米波设备的device_id需要与实际设备匹配才行。

.idea/workspace.xml

@@ -4,7 +4,14 @@
     <option name="autoReloadType" value="SELECTIVE" />
   </component>
   <component name="ChangeListManager">
-    <list default="true" id="1b298f03-b3a2-4f3f-9fa2-7f833ec35924" name="更改" comment="" />
+    <list default="true" id="1b298f03-b3a2-4f3f-9fa2-7f833ec35924" name="更改" comment="">
+      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/预定系统/base/Mqtt_Send.py" beforeDir="false" afterPath="$PROJECT_DIR$/预定系统/base/Mqtt_Send.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/预定系统/安卓信息模块/安卓信息上报.py" beforeDir="false" afterPath="$PROJECT_DIR$/预定系统/安卓信息模块/安卓信息上报.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/预定系统/毫米波雷达模块/毫米波雷达上报.py" beforeDir="false" afterPath="$PROJECT_DIR$/预定系统/毫米波雷达模块/毫米波雷达上报.py" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/预定系统/测试数据/MQTT安卓上报数据.csv" beforeDir="false" afterPath="$PROJECT_DIR$/预定系统/测试数据/MQTT安卓上报数据.csv" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/预定系统/测试数据/MQTT毫米波上报数据.csv" beforeDir="false" afterPath="$PROJECT_DIR$/预定系统/测试数据/MQTT毫米波上报数据.csv" afterDir="false" />
+    </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
     <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
@@ -128,7 +135,7 @@
       <workItem from="1729481397357" duration="2465000" />
       <workItem from="1729519480013" duration="13278000" />
       <workItem from="1729685636638" duration="4482000" />
-      <workItem from="1729690521898" duration="8028000" />
+      <workItem from="1729690521898" duration="8355000" />
     </task>
     <servers />
   </component>

预定系统/base/Mqtt_Send.py

@@ -109,7 +109,7 @@ class Mqtt:
     @staticmethod
     def read_config_from_csv(file_path):
         """
-        从 CSV 文件读取配置
+        从 CSV 文件读取配置-
 
         :param file_path: CSV 文件路径
         :return: 配置列表

预定系统/安卓信息模块/安卓信息上报.py

@@ -25,7 +25,7 @@ if __name__ == "__main__":
 
             # 遍历配置文件中的每一行数据
             for config in configs:
-                # 构建消息内容
+                # 构建消息内容-
                 topic = config["topic"]
                 current_time = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
                 message = Mqtt.build_message(config, current_time, topic)

预定系统/毫米波雷达模块/毫米波雷达上报.py

@@ -12,7 +12,7 @@ if __name__ == "__main__":
     num_repeats = 100  # 重复执行的次数
     interval_between_repeats = 0.2  # 每次重复之间的间隔时间（秒）
 
-    # 创建 MQTT 客户端实例
+    # 创建 MQTT 客户端实例-
     mqtt_client = Mqtt(broker_address, port)
 
     try:

预定系统/测试数据/MQTT安卓上报数据.csv

@@ -58,4 +58,4 @@ rebootResponseTopic,48134e6047a19a30,AND-2CT-0130,CN-2CT-UBAINS,63fdb9a82a270e58
 /uams/android/broadcast,,,,,,,,48134e6047a19a27,aa44e258a4e1e027
 /uams/android/broadcast,,,,,,,,48134e6047a19a28,aa44e258a4e1e028
 /uams/android/broadcast,,,,,,,,48134e6047a19a29,aa44e258a4e1e029
-/uams/android/broadcast,,,,,,,,48134e6047a19a30,aa44e258a4e1e030
+/uams/android/broadcast,,,,,,,,48134e6047a19a30,aa44e258a4e1e031

预定系统/测试数据/MQTT毫米波上报数据.csv

@@ -98,4 +98,4 @@ topic,client_id,presence_state,kaiguan,julishezhi,lingmindushezhi,wifi_mac,ble_m
 /c1_100_wifi_u/D4F98D094097/event/upload,D4F98D094097,1,0,3,2,D4F98D094097,D4F98D093097,D4F98D092097,192.168.1.97
 /c1_100_wifi_u/D4F98D094098/event/upload,D4F98D094098,1,0,3,2,D4F98D094098,D4F98D093098,D4F98D092098,192.168.1.98
 /c1_100_wifi_u/D4F98D094099/event/upload,D4F98D094099,1,0,3,2,D4F98D094099,D4F98D093099,D4F98D092099,192.168.1.99
-/c1_100_wifi_u/D4F98D094100/event/upload,D4F98D094100,1,0,3,2,D4F98D094100,D4F98D093100,D4F98D092100,192.168.1.100
+/c1_100_wifi_u/D4F98D094100/event/upload,D4F98D094100,1,0,3,2,D4F98D094100,D4F98D093100,D4F98D092100,192.168.1.101