From 07a7e41f72cfa9dfd207a04445f4aa5b0b6fa3ce Mon Sep 17 00:00:00 2001
From: Lint Action <noreply@github.com>
Date: Tue, 4 May 2021 06:09:42 +0000
Subject: =?UTF-8?q?:rotating=5Flight:=20=E8=87=AA=E5=8A=A8=E8=BF=9B?=
 =?UTF-8?q?=E8=A1=8C=E4=BB=A3=E7=A0=81=E6=A0=BC=E5=BC=8F=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ATRI/plugins/manage/modules/broadcast.py | 42 ++++++++++++++------------------
 1 file changed, 18 insertions(+), 24 deletions(-)

(limited to 'ATRI/plugins/manage/modules/broadcast.py')

diff --git a/ATRI/plugins/manage/modules/broadcast.py b/ATRI/plugins/manage/modules/broadcast.py
index 5086fcf..7f7816d 100644
--- a/ATRI/plugins/manage/modules/broadcast.py
+++ b/ATRI/plugins/manage/modules/broadcast.py
@@ -15,52 +15,46 @@ __doc__ = """
   广播 内容
 """
 
-broadcast = sv.on_command(
-    cmd="广播",
-    docs=__doc__,
-    permission=SUPERUSER
-)
+broadcast = sv.on_command(cmd="广播", docs=__doc__, permission=SUPERUSER)
+
 
 @broadcast.args_parser  # type: ignore
-async def _broadcast_load(bot: Bot,
-                          event: MessageEvent,
-                          state: T_State) -> None:
+async def _broadcast_load(bot: Bot, event: MessageEvent, state: T_State) -> None:
     msg = str(event.message)
-    quit_list = ['算了', '罢了', '取消']
+    quit_list = ["算了", "罢了", "取消"]
     if msg in quit_list:
-        await broadcast.finish('好吧...')
+        await broadcast.finish("好吧...")
     if not msg:
-        await broadcast.reject('想群发啥呢0w0')
+        await broadcast.reject("想群发啥呢0w0")
     else:
-        state['msg'] = msg
+        state["msg"] = msg
+
 
 @broadcast.handle()
 async def _broadcast(bot: Bot, event: MessageEvent, state: T_State) -> None:
     msg = str(event.message).strip()
     if msg:
-        state['msg'] = msg
-    
-@broadcast.got('msg', prompt='请告诉咱需要群发的内容~！')
-async def _deal_broadcast(bot: Bot,
-                          event: MessageEvent,
-                          state: T_State) -> None:
-    msg = state['msg']
+        state["msg"] = msg
+
+
+@broadcast.got("msg", prompt="请告诉咱需要群发的内容~！")
+async def _deal_broadcast(bot: Bot, event: MessageEvent, state: T_State) -> None:
+    msg = state["msg"]
     group_list = await bot.get_group_list()
     succ_list = []
     err_list = []
-    
+
     for group in group_list:
         await asyncio.sleep(randint(0, 2))
         try:
-            await bot.send_group_msg(group_id=group["group_id"],
-                                     message=msg)
+            await bot.send_group_msg(group_id=group["group_id"], message=msg)
         except BaseException:
             err_list.append(group["group_id"])
-    
+
     msg0 = ""
     for i in err_list:
         msg0 += f"    {i}\n"
-    
+
     repo_msg = (
         f"推送消息：\n{msg}\n"
         "————————\n"
-- 
cgit v1.2.3