Class RoverUserActivity

RoverSign/utils/database/rover_user_activity.py:16–187

RoverSign 用户活跃度记录表 记录每个用户（user_id + bot_id + bot_self_id）的最后活跃时间 通过 hook 机制自动更新，用于判断用户活跃度

class RoverUserActivity(BaseBotIDModel, table=True):
    """RoverSign 用户活跃度记录表

    记录每个用户（user_id + bot_id + bot_self_id）的最后活跃时间
    通过 hook 机制自动更新，用于判断用户活跃度
    """

    __tablename__ = "RoverUserActivity"
    __table_args__: Dict[str, Any] = {"extend_existing": True}

    user_id: str = Field(default="", title="用户ID")
    bot_self_id: str = Field(default="", title="机器人自身ID")
    last_active_time: Optional[int] = Field(default=None, title="最后活跃时间")

    @classmethod
    async def update_user_activity(
        cls: Type[T_RoverUserActivity],
        user_id: str,
        bot_id: str,
        bot_self_id: str,
    ) -> bool:
        """更新用户活跃时间（带数据库错误保护）"""
        try:
            return await cls._do_update_user_activity(user_id, bot_id, bot_self_id)
        except Exception as e:
            if "malformed" in str(e) or "corrupt" in str(e):
                logger.warning(f"[库洛签到·用户活跃度] 数据库损坏，跳过活跃度更新: {e}")
                return False
            raise

    @classmethod
    @with_lock
    @with_session
    async def _do_update_user_activity(
        cls: Type[T_RoverUserActivity],
        session: AsyncSession,
        user_id: str,
        bot_id: str,
        bot_self_id: str,
    ) -> bool:
        import time

        current_time = int(time.time())

        sql = select(cls).where(
            and_(
                cls.user_id == user_id,
                cls.bot_id == bot_id,
                cls.bot_self_id == bot_self_id,
            )
        )
        result = await session.execute(sql)
        existing = result.scalars().first()

        if existing:
            existing.last_active_time = current_time
            session.add(existing)
        else: