Diuse/zhenxun_bot
1
0
Fork 0
mirror of https://github.com/zhenxun-org/zhenxun_bot.git synced 2025-12-15 06:12:53 +08:00
Code Issues Actions 7 Packages Projects Releases Wiki Activity

🎨代码优化 (#1586)

Browse Source 
* ✨ 更新插件俄罗斯轮盘

* 🎨代码优化
This commit is contained in:
xuanerwa 2024-08-27 17:34:44 +08:00 committed by GitHub
parent 72641c7983
commit ab1d0d22dd
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 21 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
zhenxun/builtin_plugins/scheduler/chat_check.py
View File

@ -19,22 +19,23 @@ from zhenxun.utils.platform import PlatformUtils
async def _():
"""检测群组发言时间并禁用全部被动"""
update_list = []
for bot in nonebot.get_bots().values():
group_list, _ = await PlatformUtils.get_group_list(bot)
group_list = [g for g in group_list if g.channel_id == None]
for group in group_list:
try:
last_message = (
await ChatHistory.filter(group_id=group.group_id)
.annotate()
.order_by("-create_time")
.first()
)
if last_message:
now = datetime.now(pytz.timezone("Asia/Shanghai"))
if modules := await TaskInfo.annotate().values_list(
"module", flat=True
):
if modules := await TaskInfo.annotate().values_list(
"module", flat=True
):
for bot in nonebot.get_bots().values():
group_list, _ = await PlatformUtils.get_group_list(bot)
group_list = [g for g in group_list if g.channel_id == None]
for group in group_list:
try:
last_message = (
await ChatHistory.filter(group_id=group.group_id)
.annotate()
.order_by("-create_time")
.first()
)
if last_message:
now = datetime.now(pytz.timezone("Asia/Shanghai"))
if now - timedelta(days=2) > last_message.create_time:
_group, _ = await GroupConsole.get_or_create(
group_id=group.group_id, channel_id__isnull=True
@ -46,9 +47,9 @@ async def _():
"Chat检测",
target=_group.group_id,
)
except Exception as e:
logger.error(
"检测群组发言时间失败...", "Chat检测", target=group.group_id
)
except Exception as e:
logger.error(
"检测群组发言时间失败...", "Chat检测", target=group.group_id
)
if update_list:
await GroupConsole.bulk_update(update_list, ["block_task"], 10)