's'

liveMan.py

@@ -26,7 +26,7 @@ import pyttsx3  #
 from protobuf.douyin import *
 from ws_server import push_to_frontend
 import asyncio
-
+from dataclasses import asdict
 
 @contextmanager
 def patched_popen_encoding(encoding='utf-8'):
@@ -329,22 +329,21 @@ class DouyinLiveWebFetcher:
         user_id = message.user.id
         gender = ["女", "男"][message.user.gender]
         # avatar = message.user.avatar
-        user_data = {
+        user_data = asdict(message.user)
-        "user_id": user_id,
+        # user_data = {
-        "user_name": user_name,
+        # "user_id": user_id,
-        "gender": gender,
+        # "user_name": user_name,
-        # "avatar": avatar,
+        # "gender": gender,
-    }
+        # }
       
         # ✅ 播放语音播报
         try:
-            engine = pyttsx3.init()
+            # engine = pyttsx3.init()
-            engine.setProperty('rate', 170)  # 语速，建议范围 120-200
+            # engine.setProperty('rate', 170)  # 语速，建议范围 120-200
-            engine.setProperty('volume', 1.0)  # 音量 0.0 ~ 1.0
+            # engine.setProperty('volume', 1.0)  # 音量 0.0 ~ 1.0
-            # engine.say(f"{gender}观众 {user_name} 进入了直播间")
+            # # engine.say(f"{gender}观众 {user_name} 进入了直播间")
-            engine.say(f"{user_name}进入了直播间")
+            # engine.say(f"{user_name}进入了直播间")
-
+            # engine.runAndWait()
-            engine.runAndWait()
               # 推送给 WebSocket 客户端
             push_to_frontend(user_data) 
         except Exception as e:

main.py

@@ -25,7 +25,7 @@ time.sleep(1)
 
 # ✅ 主程序启动直播监听
 if __name__ == '__main__':
-    live_id = '429953664718'
+    live_id = '721887789964'
     room = DouyinLiveWebFetcher(live_id)
     room.get_room_status()
     room.start()