✨ 两日内未发送消息的群组将被关闭所有被动

zhenxun/builtin_plugins/chat_history/chat_message.py

@@ -44,7 +44,8 @@ TEMP_LIST = []
 
 @chat_history.handle()
 async def _(message: UniMsg, session: EventSession):
-    group_id = session.id3 or session.id2
+    # group_id = session.id3 or session.id2
+    group_id = session.id2
     TEMP_LIST.append(
         ChatHistory(
             user_id=session.id1,

zhenxun/builtin_plugins/scheduler/chat_check.py

@@ -0,0 +1,54 @@
+from datetime import datetime, timedelta
+
+import nonebot
+import pytz
+from nonebot_plugin_apscheduler import scheduler
+
+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.utils.platform import PlatformUtils
+
+
+@scheduler.scheduled_job(
+    "cron",
+    hour=4,
+    minute=40,
+)
+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 now - timedelta(days=2) > last_message.create_time:
+                            _group, _ = await GroupConsole.get_or_create(
+                                group_id=group.group_id, channel_id__isnull=True
+                            )
+                            _group.block_task = ",".join(modules) + ","  # type: ignore
+                            update_list.append(_group)
+                            logger.info(
+                                "群组两日内未发送任何消息，关闭该群全部被动",
+                                "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)