From f8aa4b141d1551db4a57c51d3405dacbf01f800a Mon Sep 17 00:00:00 2001
From: "WLT\\Eric.hu" <Eric.hu@zerofinance.com>
Date: Mon, 14 Apr 2025 16:08:49 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B6=88=E6=81=AF=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 liveMan.py | 15 +++++++--------
 main.py    |  2 +-
 2 files changed, 8 insertions(+), 9 deletions(-)

diff --git a/liveMan.py b/liveMan.py
index 4bd508a..6bce832 100644
--- a/liveMan.py
+++ b/liveMan.py
@@ -334,7 +334,7 @@ class DouyinLiveWebFetcher:
         asyncio.run(send_message(f"【点赞msg】{user_name} 点了{count}个赞"))
 
     
-    async def _parseMemberMsg(self, payload):
+    def _parseMemberMsg(self, payload):
         '''进入直播间消息'''
         message = MemberMessage().parse(payload)
         user_name = message.user.nick_name
@@ -358,7 +358,7 @@ class DouyinLiveWebFetcher:
         current = message.total
         total = message.total_pv_for_anchor
         print(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}")
-        asyncio.run(send_message(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}"))
+        # asyncio.run(send_message(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}"))
 
     
     def _parseFansclubMsg(self, payload):
@@ -385,22 +385,21 @@ class DouyinLiveWebFetcher:
         common = message.common
         room_id = common.room_id
         print(f"【直播间msg】直播间id:{room_id}")
-        asyncio.run(send_message(f"【直播间msg】直播间id:{room_id}"))
+        # asyncio.run(send_message(f"【直播间msg】直播间id:{room_id}"))
 
     
     def _parseRoomStatsMsg(self, payload):
         message = RoomStatsMessage().parse(payload)
         display_long = message.display_long
         print(f"【直播间统计msg】{display_long}")
-        asyncio.run(send_message(f"【直播间统计msg】{display_long}"))
+        # asyncio.run(send_message(f"【直播间统计msg】{display_long}"))
 
     
     def _parseRankMsg(self, payload):
         message = RoomRankMessage().parse(payload)
         ranks_list = message.ranks_list
         print(f"【直播间排行榜msg】{ranks_list}")
-        asyncio.run(send_message(f"【直播间排行榜msg】{ranks_list}"))
-
+        # asyncio.run(send_message(f"【直播间排行榜msg】{ranks_list}"))
     
     def _parseControlMsg(self, payload):
         '''直播间状态消息'''
@@ -408,12 +407,12 @@ class DouyinLiveWebFetcher:
         
         if message.status == 3:
             print("直播间已结束")
-            asyncio.run(send_message(f"直播间已结束"))
+            # asyncio.run(send_message(f"直播间已结束"))
             self.stop()
     
     def _parseRoomStreamAdaptationMsg(self, payload):
         message = RoomStreamAdaptationMessage().parse(payload)
         adaptationType = message.adaptation_type
         print(f'直播间adaptation: {adaptationType}')
-        asyncio.run(send_message(f'直播间adaptation: {adaptationType}'))
+        # asyncio.run(send_message(f'直播间adaptation: {adaptationType}'))
 
diff --git a/main.py b/main.py
index 71e4674..d4e7541 100644
--- a/main.py
+++ b/main.py
@@ -6,7 +6,7 @@ import asyncio
 from ws_server import start_ws_server
 
 if __name__ == '__main__':
-    live_id = '139226983757'
+    live_id = '174880838400'
     room = DouyinLiveWebFetcher(live_id)
     room.get_room_status()
     room.start()