mirror of
https://github.com/zhenxun-org/zhenxun_bot.git
synced 2026-09-29 08:39:59 +08:00
Copaan
8afc8f8673
* bugfix:更换数据库初始化超时路径以修复连接超时问题 * 移除部分观测链路 * 细节修改 * 权限检查细节修改2 * bugfix:修复金币懒加载造成插件金币消耗不了的问题 * bugfix:整理鉴权逻辑 * 完善缓存系统 * 优化官端使用 * bugfix:增加官机和频道的前导统一剥离，新增获取群列表自愈 * bugfix:修复导入问题
76 lines
2.9 KiB
Python
76 lines
2.9 KiB
Python
from datetime import datetime, timedelta
|
|
|
|
import nonebot
|
|
from nonebot_plugin_apscheduler import scheduler
|
|
import pytz
|
|
|
|
from zhenxun.configs.config import Config
|
|
from zhenxun.models.chat_history import ChatHistory
|
|
from zhenxun.models.group_console import GroupConsole
|
|
from zhenxun.models.task_info import TaskInfo
|
|
from zhenxun.services.log import logger
|
|
from zhenxun.services.message_load import should_pause_tasks
|
|
from zhenxun.utils.platform import PlatformUtils
|
|
|
|
Config.add_plugin_config(
|
|
"chat_check",
|
|
"STATUS",
|
|
True,
|
|
help="是否开启群组两日内未发送任何消息，关闭该群全部被动",
|
|
default_value=True,
|
|
type=bool,
|
|
)
|
|
|
|
|
|
@scheduler.scheduled_job(
|
|
"cron",
|
|
hour=4,
|
|
minute=40,
|
|
)
|
|
async def _():
|
|
if should_pause_tasks():
|
|
return
|
|
if not Config.get_config("chat_history", "FLAG"):
|
|
logger.debug("未开启历史发言记录，过滤群组发言检测...")
|
|
return
|
|
if not Config.get_config("chat_check", "STATUS"):
|
|
logger.debug("未开启群组聊天时间检查，过滤群组发言检测...")
|
|
return
|
|
"""检测群组发言时间并禁用全部被动"""
|
|
update_list = []
|
|
if modules := await TaskInfo.get_modules(load_status=None):
|
|
for bot in nonebot.get_bots().values():
|
|
group_list, _ = await PlatformUtils.get_group_list(bot, True)
|
|
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_root_group(
|
|
group.group_id
|
|
)
|
|
modules = [f"<{module}" for module in modules]
|
|
_group.block_task = ",".join(modules) + "," # type: ignore
|
|
update_list.append(_group)
|
|
logger.info(
|
|
"群组两日内未发送任何消息，关闭该群全部被动",
|
|
"Chat检测",
|
|
target=_group.group_id,
|
|
)
|
|
except Exception:
|
|
logger.error(
|
|
"检测群组发言时间失败...", "Chat检测", target=group.group_id
|
|
)
|
|
if update_list:
|
|
await GroupConsole.bulk_update(update_list, ["block_task"], 10)
|
|
from zhenxun.services.cache.runtime_cache import GroupMemoryCache
|
|
|
|
for group in update_list:
|
|
await GroupMemoryCache.upsert_from_model(group)
|