TeamPGM/PagerMaid_Plugins_Pyro
2
0
Fork 0
mirror of https://github.com/TeamPGM/PagerMaid_Plugins_Pyro.git synced 2024-11-26 05:04:28 +00:00
Code Issues Actions Projects Releases Wiki Activity

clean_member 支持移除所有人

Browse Source
This commit is contained in:
xtaodada 2022-09-15 14:41:16 +08:00
parent 9a7373bfdd
commit ef25fdfe75
Signed by: xtaodada
GPG Key ID: 4CBB3F4FA8C85659
1 changed files with 19 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
clean_member/main.py
View File

@ -1,9 +1,10 @@
import contextlib import contextlib
from asyncio import sleep from asyncio import sleep
from random import uniform
from pyrogram.enums import ChatMemberStatus from pyrogram.enums import ChatMemberStatus
from pyrogram import filters from pyrogram import filters
from pyrogram.errors import ChatAdminRequired, FloodWait, UserAdminInvalid, PeerIdInvalid from pyrogram.errors import ChatAdminRequired, FloodWait, UserAdminInvalid, PeerIdInvalid, BadRequest
from datetime import datetime, timedelta from datetime import datetime, timedelta
@ -28,11 +29,15 @@ async def check_self_and_from(message: Message):
async def kick_chat_member(cid, uid, only_search: bool = False): async def kick_chat_member(cid, uid, only_search: bool = False):
if only_search: if only_search:
return return
with contextlib.suppress(UserAdminInvalid, PeerIdInvalid): try:
with contextlib.suppress(UserAdminInvalid, PeerIdInvalid, BadRequest):
await bot.ban_chat_member( await bot.ban_chat_member(
cid, cid,
uid, uid,
datetime.now() + timedelta(minutes=5)) datetime.now() + timedelta(minutes=5))
except FloodWait as e:
await sleep(e.value + uniform(0.5, 1.0))
await kick_chat_member(cid, uid, only_search)
async def process_clean_member(message: Message, mode: str, day: int, only_search: bool = False): async def process_clean_member(message: Message, mode: str, day: int, only_search: bool = False):
@ -60,6 +65,9 @@ async def process_clean_member(message: Message, mode: str, day: int, only_searc
if mode == "4" and member.user.is_deleted: if mode == "4" and member.user.is_deleted:
member_count += 1 member_count += 1
await kick_chat_member(message.chat.id, member.user.id, only_search) await kick_chat_member(message.chat.id, member.user.id, only_search)
if mode == "5":
member_count += 1
await kick_chat_member(message.chat.id, member.user.id, only_search)
if not only_search: if not only_search:
await message.edit(f'成功清理了 `{member_count}` 人。') await message.edit(f'成功清理了 `{member_count}` 人。')
else: else:
@ -83,7 +91,8 @@ async def clean_member(client: Client, message: Message):
"1. 按未上线时间清理\n" "1. 按未上线时间清理\n"
"2. 按未发言时间清理（大群慎用）\n" "2. 按未发言时间清理（大群慎用）\n"
"3. 按发言数清理\n" "3. 按发言数清理\n"
"4. 清理死号\n") "4. 清理死号\n"
"5. 清理所有人（大群慎用）")
try: try:
async with client.conversation(message.chat.id, filters=filters.user(uid)) as conv: async with client.conversation(message.chat.id, filters=filters.user(uid)) as conv:
await sleep(1) await sleep(1)
@ -104,7 +113,9 @@ async def clean_member(client: Client, message: Message):
res = await conv.get_response() res = await conv.get_response()
day = int(res.text) day = int(res.text)
await res.safe_delete() await res.safe_delete()
elif mode != "4": elif mode == "4":
pass
elif mode != "5":
raise ValueError("清理模式错误") raise ValueError("清理模式错误")
await reply.edit("查找还是清理？") await reply.edit("查找还是清理？")
await sleep(1) await sleep(1)