diff --git a/backend/package/yuxi/repositories/channels/base.py b/backend/package/yuxi/repositories/channels/base.py index a69f578f..1e30af91 100644 --- a/backend/package/yuxi/repositories/channels/base.py +++ b/backend/package/yuxi/repositories/channels/base.py @@ -30,7 +30,9 @@ from __future__ import annotations from datetime import datetime -from sqlalchemy import delete as sa_delete, func, select, update as sa_update +from sqlalchemy import delete as sa_delete +from sqlalchemy import func, select +from sqlalchemy import update as sa_update from sqlalchemy.ext.asyncio import AsyncSession from yuxi.utils.datetime_utils import utc_now_naive diff --git a/backend/package/yuxi/repositories/channels/channel_audit_log_repository.py b/backend/package/yuxi/repositories/channels/channel_audit_log_repository.py index 3fe62b83..0d2a2cad 100644 --- a/backend/package/yuxi/repositories/channels/channel_audit_log_repository.py +++ b/backend/package/yuxi/repositories/channels/channel_audit_log_repository.py @@ -6,7 +6,8 @@ from __future__ import annotations import datetime as dt from typing import Any -from sqlalchemy import delete as sa_delete, func, select +from sqlalchemy import delete as sa_delete +from sqlalchemy import func, select from yuxi.repositories.channels.base import BaseRepository from yuxi.storage.postgres.models_channels import ChannelAuditLog diff --git a/backend/package/yuxi/repositories/channels/channel_idempotency_repository.py b/backend/package/yuxi/repositories/channels/channel_idempotency_repository.py index bd95ecaa..1df820cc 100644 --- a/backend/package/yuxi/repositories/channels/channel_idempotency_repository.py +++ b/backend/package/yuxi/repositories/channels/channel_idempotency_repository.py @@ -6,7 +6,8 @@ from __future__ import annotations import datetime as dt from typing import Any -from sqlalchemy import delete as sa_delete, select, update +from sqlalchemy import delete as sa_delete +from sqlalchemy import select, update from yuxi.repositories.channels.base import BaseRepository from yuxi.storage.postgres.models_channels import ChannelIdempotency diff --git a/backend/package/yuxi/repositories/channels/channel_outbox_repository.py b/backend/package/yuxi/repositories/channels/channel_outbox_repository.py index 72f92f9d..16c9737c 100644 --- a/backend/package/yuxi/repositories/channels/channel_outbox_repository.py +++ b/backend/package/yuxi/repositories/channels/channel_outbox_repository.py @@ -235,11 +235,7 @@ class ChannelOutboxRepository(BaseRepository): limit: 返回数量上限。 before: 仅返回 ``updated_at`` 早于此时间的条目(可选)。 """ - stmt = ( - select(ChannelOutboxEntry) - .where(ChannelOutboxEntry.status == "failed") - .where(self._not_deleted()) - ) + stmt = select(ChannelOutboxEntry).where(ChannelOutboxEntry.status == "failed").where(self._not_deleted()) if before is not None: stmt = stmt.where(ChannelOutboxEntry.updated_at < before) stmt = stmt.order_by(ChannelOutboxEntry.updated_at.asc()).limit(limit) diff --git a/backend/package/yuxi/repositories/channels/channel_session_repository.py b/backend/package/yuxi/repositories/channels/channel_session_repository.py index 2cb4fb60..8d9a7cf8 100644 --- a/backend/package/yuxi/repositories/channels/channel_session_repository.py +++ b/backend/package/yuxi/repositories/channels/channel_session_repository.py @@ -12,7 +12,6 @@ from yuxi.repositories.channels.base import BaseRepository from yuxi.storage.postgres.models_channels import ChannelAccount, ChannelSession from yuxi.utils.datetime_utils import utc_now_naive - # 僵尸会话阈值:最近消息时间早于该天数视为僵尸会话(仅未关闭) _ZOMBIE_SESSION_DAYS = 7 diff --git a/backend/package/yuxi/repositories/channels/content_review_record_repository.py b/backend/package/yuxi/repositories/channels/content_review_record_repository.py index dfd06c15..073c2dd5 100644 --- a/backend/package/yuxi/repositories/channels/content_review_record_repository.py +++ b/backend/package/yuxi/repositories/channels/content_review_record_repository.py @@ -4,10 +4,10 @@ from __future__ import annotations from datetime import UTC, datetime - from typing import Any -from sqlalchemy import case, delete as sa_delete, func, select +from sqlalchemy import case, func, select +from sqlalchemy import delete as sa_delete from yuxi.repositories.channels.base import BaseRepository from yuxi.storage.postgres.models_channels import ChannelContentReviewRecord