diff options
author | Lint Action <[email protected]> | 2021-05-04 06:09:42 +0000 |
---|---|---|
committer | Lint Action <[email protected]> | 2021-05-04 06:09:42 +0000 |
commit | 07a7e41f72cfa9dfd207a04445f4aa5b0b6fa3ce (patch) | |
tree | b02c1b4e674acf6f56cf7335ad05acd0523af91c /ATRI/plugins/manage/modules/broadcast.py | |
parent | 8e94b4cd4aea1943a9639b900e33fe0fa1de5bb8 (diff) | |
download | ATRI-07a7e41f72cfa9dfd207a04445f4aa5b0b6fa3ce.tar.gz ATRI-07a7e41f72cfa9dfd207a04445f4aa5b0b6fa3ce.tar.bz2 ATRI-07a7e41f72cfa9dfd207a04445f4aa5b0b6fa3ce.zip |
:rotating_light: 自动进行代码格式化
Diffstat (limited to 'ATRI/plugins/manage/modules/broadcast.py')
-rw-r--r-- | ATRI/plugins/manage/modules/broadcast.py | 42 |
1 files changed, 18 insertions, 24 deletions
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 - [email protected]('msg', prompt='请告诉咱需要群发的内容~!') -async def _deal_broadcast(bot: Bot, - event: MessageEvent, - state: T_State) -> None: - msg = state['msg'] + state["msg"] = msg + + [email protected]("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" |