add banban yaml add mqtt_handler log

talkingq-url/handlers/mqtt_handler.py

@@ -121,6 +121,13 @@ class TalkingQMQTTService:
 
     async def _handle_device_info(self, device_id: str, payload: dict):
         data = payload.get("data", {})
+        d_id = data.get("id")
+        power = data.get("power")
+        signal = data.get("signal")
+        version = data.get("version")
+        voice = data.get("voice")
+        logger.info(device_id, "", f"[设备信息] 设备 {d_id} 信息: 电量={power}, 信号强度={signal}, 版本号={version}, 音量={voice}")
+        
         await self._schedule_persistence(
             device_id,
             "device_info",
@@ -147,7 +154,10 @@ class TalkingQMQTTService:
                 parsed_device_time = datetime.fromisoformat(raw_device_time.strip())
             except ValueError:
                 parsed_device_time = None
-
+        lat = data.get("latitude")
+        lon = data.get("longitude")
+        logger.info(device_id, "", f"[GPS] 设备 {device_id} 位置: 纬度={lat}, 经度={lon}")
+        
         await self._schedule_persistence(
             device_id,
             "gps",
@@ -175,6 +185,8 @@ class TalkingQMQTTService:
         current_level = data.get("current_level")
         if current_level is None:
             return
+        logger.info(device_id, "", f"[音量] 设备 {device_id} 当前音量: {current_level}")
+            
         await self._schedule_persistence(
             device_id,
             "volume",
@@ -197,6 +209,10 @@ class TalkingQMQTTService:
             progress_value = None
 
         if status == "accepted":
+            current = data.get("current_version")
+            target = data.get("target_version")
+            logger.info(device_id, "", f"[OTA] 设备 {device_id} 已接受升级: {current} -> {target}")
+        
             await self._schedule_persistence(
                 device_id,
                 "ota",
@@ -220,6 +236,8 @@ class TalkingQMQTTService:
             )
         elif status == "success":
             new_version = data.get("new_version") or data.get("version")
+            logger.info(device_id, "", f"[OTA] 设备 {device_id} 升级完成: {new_version}")
+            
             await self._schedule_persistence(
                 device_id,
                 "ota",