update apis

Author: wu-clan

backend/app/admin/api/v1/sys/config.py

@@ -71,9 +71,9 @@ async def save_policy_config() -> ResponseModel:
     return response_base.success()
 
 
-@router.get('', summary='获取系统配置详情', dependencies=[DependsJwtAuth])
-async def get_config() -> ResponseModel:
-    config = await config_service.get()
+@router.get('/{pk}', summary='获取系统配置详情', dependencies=[DependsJwtAuth])
+async def get_config(pk: Annotated[int, Path(...)]) -> ResponseModel:
+    config = await config_service.get(pk)
     return response_base.success(data=config)
 
 

backend/app/admin/service/config_service.py

@@ -1,57 +1,38 @@
 #!/usr/bin/env python3
 # -*- coding: utf-8 -*-
-from backend.app.admin.conf import admin_settings
 from backend.app.admin.crud.crud_config import config_dao
 from backend.app.admin.model import Config
 from backend.app.admin.schema.config import CreateConfigParam, UpdateConfigParam
 from backend.common.exception import errors
 from backend.database.db_mysql import async_db_session
-from backend.database.db_redis import redis_client
-from backend.utils.serializers import select_as_dict
 
 
 class ConfigService:
     @staticmethod
     async def get() -> Config | dict:
         async with async_db_session() as db:
-            cache_config = await redis_client.hgetall(admin_settings.CONFIG_REDIS_KEY)
-            if not cache_config:
-                config = await config_dao.get_one(db)
-                if not config:
-                    raise errors.NotFoundError(msg='系统配置不存在')
-                data_map = select_as_dict(config)
-                del data_map['created_time']
-                del data_map['updated_time']
-                await redis_client.hset(admin_settings.CONFIG_REDIS_KEY, mapping=data_map)
-                return config
-            else:
-                return cache_config
+            config = await config_dao.get(db)
+            if not config:
+                raise errors.NotFoundError(msg='配置不存在')
+            return config
+
+    @staticmethod
+    async def get_select(): ...
 
     @staticmethod
     async def create(*, obj: CreateConfigParam) -> None:
-        async with async_db_session.begin() as db:
-            config = await config_dao.get_one(db)
-            if config:
-                raise errors.ForbiddenError(msg='系统配置已存在')
-            await config_dao.create(db, obj)
-            await redis_client.hset(admin_settings.CONFIG_REDIS_KEY, mapping=obj.model_dump())
+        async with async_db_session.begin():
+            ...
 
     @staticmethod
     async def update(*, pk: int, obj: UpdateConfigParam) -> int:
-        async with async_db_session.begin() as db:
-            count = await config_dao.update(db, pk, obj)
-            await redis_client.hset(admin_settings.CONFIG_REDIS_KEY, mapping=obj.model_dump())
-            return count
+        async with async_db_session.begin():
+            ...
 
     @staticmethod
     async def delete(*, pk: list[int]) -> int:
-        async with async_db_session.begin() as db:
-            configs = await config_dao.get_all(db)
-            if len(configs) == 1:
-                raise errors.ForbiddenError(msg='系统配置无法彻底删除')
-            count = await config_dao.delete(db, pk)
-            await redis_client.delete(admin_settings.CONFIG_REDIS_KEY)
-            return count
+        async with async_db_session.begin():
+            ...
 
 
 config_service: ConfigService = ConfigService()