关闭节奏风暴的参考方法

Dr-WeiAL · Apr 12, 2019 · 467b747 · 467b747
1 parent d4f626f
commit 467b747
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/danmu/bili_danmu_monitor.py b/danmu/bili_danmu_monitor.py
@@ -96,6 +96,6 @@ def handle_danmu(self, data: dict):
             elif msg_type == 6:
                 raffle_name = '二十倍节奏风暴'
                 print(f'{self._area_id}号数据连接检测到{real_roomid:^9}的{raffle_name}')
-                # raffle_handler.push2queue(StormRaffleHandlerTask, real_roomid)
+                raffle_handler.push2queue(StormRaffleHandlerTask, real_roomid)
                 bili_statistics.add2pushed_raffles(raffle_name)
         return True
diff --git a/danmu/yj_monitor.py b/danmu/yj_monitor.py
@@ -83,7 +83,7 @@ def handle_danmu(self, dict_danmu):
                     if type == '~' and not msg_id % 2:
                         raffle_id = id
                         print(f'{self._area_id}号弹幕监控检测到{"0":^9}的节奏风暴(id: {raffle_id})')
-                        # raffle_handler.exec_at_once(StormRaffleHandlerTask, 0, raffle_id)
+                        raffle_handler.exec_at_once(StormRaffleHandlerTask, 0, raffle_id)
                         bili_statistics.add2pushed_raffles('Yj协同节奏风暴', 2)
                 result = self.__combine_piece(uid, msg)
                 if result is None:
@@ -171,7 +171,7 @@ def handle_danmu(self, data: dict):
             raffle_id = data['raffle_id']
             raffle_roomid = 0
             print(f'{self._area_id}号弹幕监控检测到{raffle_roomid:^9}的节奏风暴(id: {raffle_id})')
-            # raffle_handler.exec_at_once(StormRaffleHandlerTask, 0, raffle_id)
+            raffle_handler.exec_at_once(StormRaffleHandlerTask, 0, raffle_id)
             bili_statistics.add2pushed_raffles('Yj协同节奏风暴', 2)
         elif raffle_type == 'GUARD':
             raffle_id = data['raffle_id']

diff --git a/tasks/storm_raffle_handler.py b/tasks/storm_raffle_handler.py
@@ -15,6 +15,7 @@ def target(step):
     # 为了速度，有时不用等room_id验证就参加,置room_id为0，is_normal_room自然会返回固定值true
     @staticmethod
     async def check(user, room_id, raffle_id=None):
+        return
         if not await UtilsTask.is_normal_room(user, room_id):
             return
         if raffle_id is not None: