vue-fastapi-admin/vue-fastapi-backend/module_admin/controller/metadata_config_controller.py

from datetime import datetime
from fastapi import APIRouter, Depends, Request, Form
from pydantic_validation_decorator import ValidateFields
from sqlalchemy.ext.asyncio import AsyncSession
from module_admin.entity.vo.metadata_config_vo import MetadataClasModel, MetadataClasPageQueryModel,MetadataSecModel,MetadataSecPageQueryModel
from module_admin.service.metadata_config_service import MetadataConfigService
from config.get_db import get_db
from utils.response_util import ResponseUtil
from utils.page_util import PageResponseModel
from utils.log_util import logger
from module_admin.service.login_service import LoginService
from module_admin.entity.vo.user_vo import CurrentUserModel

metadataConfigController = APIRouter(prefix="/metadataConfig")

@metadataConfigController.get("/clas/list", response_model=PageResponseModel)
async def get_metadata_clas_list(
    request: Request,
    query: MetadataClasPageQueryModel = Depends(MetadataClasPageQueryModel.as_query),
    query_db: AsyncSession = Depends(get_db),
):
    result = await MetadataConfigService.get_metadata_clas_list_services(query_db, query, is_page=True)
    logger.info("获取元数据分类列表成功")
    return ResponseUtil.success(model_content=result)


@metadataConfigController.post("/clas")
@ValidateFields(validate_model="add_metadata_clas")
async def add_metadata_clas(
    request: Request,
    add_clas: MetadataClasModel,
    query_db: AsyncSession = Depends(get_db),
    current_user: CurrentUserModel = Depends(LoginService.get_current_user),

):
    add_clas.upd_time = datetime.now()
    add_clas.rec_subm_prsn = current_user.user.user_name

    # 这里没有用户信息，若需要创建人信息可自行补充
    result = await MetadataConfigService.add_metadata_clas_services(query_db, add_clas)
    logger.info(result.message)
    return ResponseUtil.success(msg=result.message)


@metadataConfigController.put("/clas")
@ValidateFields(validate_model="edit_metadata_clas")
async def edit_metadata_clas(
    request: Request,
    edit_clas: MetadataClasModel,
    query_db: AsyncSession = Depends(get_db),
    current_user: CurrentUserModel = Depends(LoginService.get_current_user),

):
    edit_clas.upd_time = datetime.now()
    edit_clas.rec_subm_prsn = current_user.user.user_name
    result = await MetadataConfigService.edit_metadata_clas_services(query_db, edit_clas)
    logger.info(result.message)
    return ResponseUtil.success(msg=result.message)


@metadataConfigController.delete("/clas/{clas_ids}")
async def delete_metadata_clas(
    request: Request,
    clas_ids: str,
    query_db: AsyncSession = Depends(get_db),
):
    result = await MetadataConfigService.delete_metadata_clas_services(query_db, clas_ids)
    logger.info(result.message)
    return ResponseUtil.success(msg=result.message)


@metadataConfigController.get("/clas/{clas_id}", response_model=MetadataClasModel)
async def get_metadata_clas_detail(
    request: Request,
    clas_id: int,
    query_db: AsyncSession = Depends(get_db),
):
    result = await MetadataConfigService.get_metadata_clas_detail_services(query_db, clas_id)
    logger.info(f"获取元数据分类ID={clas_id}详情成功")
    return ResponseUtil.success(data=result)
# ------------------------ MetadataSec 控制接口 ------------------------ #

@metadataConfigController.get("/sec/list", response_model=PageResponseModel)
async def get_metadata_sec_list(
    request: Request,
    query: MetadataSecPageQueryModel = Depends(MetadataSecPageQueryModel.as_query),
    query_db: AsyncSession = Depends(get_db),
):
    result = await MetadataConfigService.get_metadata_sec_list_services(query_db, query, is_page=True)
    logger.info("获取数据安全配置列表成功")
    return ResponseUtil.success(model_content=result)


@metadataConfigController.post("/sec")
@ValidateFields(validate_model="add_metadata_sec")
async def add_metadata_sec(
    request: Request,
    add_sec: MetadataSecModel,
    query_db: AsyncSession = Depends(get_db),
    current_user: CurrentUserModel = Depends(LoginService.get_current_user),
):
    add_sec.upd_time = datetime.now()
    add_sec.rec_subm_prsn = current_user.user.user_name

    result = await MetadataConfigService.add_metadata_sec_services(query_db, add_sec)
    logger.info(result.message)
    return ResponseUtil.success(msg=result.message)


@metadataConfigController.put("/sec")
@ValidateFields(validate_model="edit_metadata_sec")
async def edit_metadata_sec(
    request: Request,
    edit_sec: MetadataSecModel,
    query_db: AsyncSession = Depends(get_db),
    current_user: CurrentUserModel = Depends(LoginService.get_current_user),
):
    edit_sec.upd_time = datetime.now()
    edit_sec.rec_subm_prsn = current_user.user.user_name

    result = await MetadataConfigService.edit_metadata_sec_services(query_db, edit_sec)
    logger.info(result.message)
    return ResponseUtil.success(msg=result.message)


@metadataConfigController.delete("/sec/{sec_ids}")
async def delete_metadata_sec(
    request: Request,
    sec_ids: str,
    query_db: AsyncSession = Depends(get_db),
):
    result = await MetadataConfigService.delete_metadata_sec_services(query_db, sec_ids)
    logger.info(result.message)
    return ResponseUtil.success(msg=result.message)


@metadataConfigController.get("/sec/{sec_id}", response_model=MetadataSecModel)
async def get_metadata_sec_detail(
    request: Request,
    sec_id: str,
    query_db: AsyncSession = Depends(get_db),
):
    result = await MetadataConfigService.get_metadata_sec_detail_services(query_db, sec_id)
    logger.info(f"获取数据安全配置 onum={sec_id} 详情成功")
    return ResponseUtil.success(data=result)