refactor: migrate plugin data read queries

app/db/models/plugindata.py

@@ -4,7 +4,7 @@ from sqlalchemy.ext.asyncio import AsyncSession
 from sqlalchemy.orm import Mapped, Session, mapped_column
 
 from app.db.base import get_id_column, Base
-from app.db.decorators import db_query, async_db_query
+from app.db.decorators import run_legacy_async_query, run_legacy_sync_query
 
 
 class PluginData(Base):
@@ -21,28 +21,54 @@ class PluginData(Base):
     )
 
     @classmethod
-    @db_query
-    def get_plugin_data(cls, db: Session, plugin_id: str):
+    def get_plugin_data(cls, db: Session | None = None, plugin_id: str | None = None):
+        """在调用方 Session 中读取插件全部数据，并兼容旧无会话入口。"""
+        if plugin_id is None:
+            raise TypeError("plugin_id is required")
+        if not isinstance(db, Session):
+            return run_legacy_sync_query(lambda session: cls.get_plugin_data(session, plugin_id))
         return list(db.execute(select(cls).where(cls.plugin_id == plugin_id)).scalars().all())
 
     @classmethod
-    @async_db_query
-    async def async_get_plugin_data(cls, db: AsyncSession, plugin_id: str):
+    async def async_get_plugin_data(
+        cls, db: AsyncSession | None = None, plugin_id: str | None = None
+    ):
+        """在调用方 AsyncSession 中读取插件全部数据，并兼容旧无会话入口。"""
+        if plugin_id is None:
+            raise TypeError("plugin_id is required")
+        if not isinstance(db, AsyncSession):
+            return await run_legacy_async_query(
+                lambda session: cls.async_get_plugin_data(session, plugin_id)
+            )
         result = await db.execute(select(cls).where(cls.plugin_id == plugin_id))
         return list(result.scalars().all())
 
     @classmethod
-    @db_query
-    def get_plugin_data_by_key(cls, db: Session, plugin_id: str, key: str):
+    def get_plugin_data_by_key(
+        cls, db: Session | None = None, plugin_id: str | None = None, key: str | None = None
+    ):
+        """在调用方 Session 中按键读取插件数据，并兼容旧无会话入口。"""
+        if plugin_id is None or key is None:
+            raise TypeError("plugin_id and key are required")
+        if not isinstance(db, Session):
+            return run_legacy_sync_query(
+                lambda session: cls.get_plugin_data_by_key(session, plugin_id, key)
+            )
         return db.execute(
             select(cls).where(cls.plugin_id == plugin_id, cls.key == key)
         ).scalars().first()
 
     @classmethod
-    @async_db_query
     async def async_get_plugin_data_by_key(
-        cls, db: AsyncSession, plugin_id: str, key: str
+        cls, db: AsyncSession | None = None, plugin_id: str | None = None, key: str | None = None
     ):
+        """在调用方 AsyncSession 中按键读取插件数据，并兼容旧无会话入口。"""
+        if plugin_id is None or key is None:
+            raise TypeError("plugin_id and key are required")
+        if not isinstance(db, AsyncSession):
+            return await run_legacy_async_query(
+                lambda session: cls.async_get_plugin_data_by_key(session, plugin_id, key)
+            )
         result = await db.execute(
             select(cls).where(cls.plugin_id == plugin_id, cls.key == key)
         )
@@ -59,14 +85,28 @@ class PluginData(Base):
         db.execute(delete(cls).where(cls.plugin_id == plugin_id))
 
     @classmethod
-    @db_query
-    def get_plugin_data_by_plugin_id(cls, db: Session, plugin_id: str):
+    def get_plugin_data_by_plugin_id(
+        cls, db: Session | None = None, plugin_id: str | None = None
+    ):
+        """在调用方 Session 中按插件 ID 读取数据，并兼容旧无会话入口。"""
+        if plugin_id is None:
+            raise TypeError("plugin_id is required")
+        if not isinstance(db, Session):
+            return run_legacy_sync_query(
+                lambda session: cls.get_plugin_data_by_plugin_id(session, plugin_id)
+            )
         return list(db.execute(select(cls).where(cls.plugin_id == plugin_id)).scalars().all())
 
     @classmethod
-    @async_db_query
     async def async_get_plugin_data_by_plugin_id(
-        cls, db: AsyncSession, plugin_id: str
+        cls, db: AsyncSession | None = None, plugin_id: str | None = None
     ):
+        """在调用方 AsyncSession 中按插件 ID 读取数据，并兼容旧无会话入口。"""
+        if plugin_id is None:
+            raise TypeError("plugin_id is required")
+        if not isinstance(db, AsyncSession):
+            return await run_legacy_async_query(
+                lambda session: cls.async_get_plugin_data_by_plugin_id(session, plugin_id)
+            )
         result = await db.execute(select(cls).where(cls.plugin_id == plugin_id))
         return list(result.scalars().all())