-
-
Notifications
You must be signed in to change notification settings - Fork 128
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Update code generator API file structure (#460)
- Loading branch information
Showing
4 changed files
with
160 additions
and
130 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,85 @@ | ||
| #!/usr/bin/env python3 | ||
| # -*- coding: utf-8 -*- | ||
| from typing import Annotated | ||
|
|
||
| from fastapi import APIRouter, Depends, Path | ||
|
|
||
| from backend.app.generator.schema.gen_business import ( | ||
| CreateGenBusinessParam, | ||
| GetGenBusinessListDetails, | ||
| UpdateGenBusinessParam, | ||
| ) | ||
| from backend.app.generator.service.gen_business_service import gen_business_service | ||
| from backend.app.generator.service.gen_model_service import gen_model_service | ||
| from backend.common.response.response_schema import ResponseModel, response_base | ||
| from backend.common.security.jwt import DependsJwtAuth | ||
| from backend.common.security.permission import RequestPermission | ||
| from backend.common.security.rbac import DependsRBAC | ||
| from backend.utils.serializers import select_as_dict, select_list_serialize | ||
|
|
||
| router = APIRouter() | ||
|
|
||
|
|
||
| @router.get('/all', summary='获取所有代码生成业务', dependencies=[DependsJwtAuth]) | ||
| async def get_all_businesses() -> ResponseModel: | ||
| businesses = await gen_business_service.get_all() | ||
| data = select_list_serialize(businesses) | ||
| return response_base.success(data=data) | ||
|
|
||
|
|
||
| @router.get('/{pk}', summary='获取代码生成业务详情', dependencies=[DependsJwtAuth]) | ||
| async def get_business(pk: Annotated[int, Path(...)]) -> ResponseModel: | ||
| business = await gen_business_service.get(pk=pk) | ||
| data = GetGenBusinessListDetails(**select_as_dict(business)) | ||
| return response_base.success(data=data) | ||
|
|
||
|
|
||
| @router.get('/{pk}/models', summary='获取代码生成业务所有模型', dependencies=[DependsJwtAuth]) | ||
| async def get_business_models(pk: Annotated[int, Path(...)]) -> ResponseModel: | ||
| models = await gen_model_service.get_by_business(business_id=pk) | ||
| data = select_list_serialize(models) | ||
| return response_base.success(data=data) | ||
|
|
||
|
|
||
| @router.post( | ||
| '', | ||
| summary='创建代码生成业务', | ||
| deprecated=True, | ||
| dependencies=[ | ||
| Depends(RequestPermission('gen:code:business:add')), | ||
| DependsRBAC, | ||
| ], | ||
| ) | ||
| async def create_business(obj: CreateGenBusinessParam) -> ResponseModel: | ||
| await gen_business_service.create(obj=obj) | ||
| return response_base.success() | ||
|
|
||
|
|
||
| @router.put( | ||
| '/{pk}', | ||
| summary='更新代码生成业务', | ||
| dependencies=[ | ||
| Depends(RequestPermission('gen:code:business:edit')), | ||
| DependsRBAC, | ||
| ], | ||
| ) | ||
| async def update_business(pk: Annotated[int, Path(...)], obj: UpdateGenBusinessParam) -> ResponseModel: | ||
| count = await gen_business_service.update(pk=pk, obj=obj) | ||
| if count > 0: | ||
| return response_base.success() | ||
| return response_base.fail() | ||
|
|
||
|
|
||
| @router.delete( | ||
| '/{pk}', | ||
| summary='删除代码生成业务', | ||
| dependencies=[ | ||
| Depends(RequestPermission('gen:code:business:del')), | ||
| DependsRBAC, | ||
| ], | ||
| ) | ||
| async def delete_business(pk: Annotated[int, Path(...)]) -> ResponseModel: | ||
| count = await gen_business_service.delete(pk=pk) | ||
| if count > 0: | ||
| return response_base.success() | ||
| return response_base.fail() |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,71 @@ | ||
| #!/usr/bin/env python3 | ||
| # -*- coding: utf-8 -*- | ||
| from typing import Annotated | ||
|
|
||
| from fastapi import APIRouter, Depends, Path | ||
|
|
||
| from backend.app.generator.schema.gen_model import CreateGenModelParam, GetGenModelListDetails, UpdateGenModelParam | ||
| from backend.app.generator.service.gen_model_service import gen_model_service | ||
| from backend.common.response.response_schema import ResponseModel, response_base | ||
| from backend.common.security.jwt import DependsJwtAuth | ||
| from backend.common.security.permission import RequestPermission | ||
| from backend.common.security.rbac import DependsRBAC | ||
| from backend.utils.serializers import select_as_dict | ||
|
|
||
| router = APIRouter() | ||
|
|
||
|
|
||
| @router.get('/types', summary='获取代码生成模型列类型', dependencies=[DependsJwtAuth]) | ||
| async def get_model_types() -> ResponseModel: | ||
| model_types = await gen_model_service.get_types() | ||
| return response_base.success(data=model_types) | ||
|
|
||
|
|
||
| @router.get('/{pk}', summary='获取代码生成模型详情', dependencies=[DependsJwtAuth]) | ||
| async def get_model(pk: Annotated[int, Path(...)]) -> ResponseModel: | ||
| model = await gen_model_service.get(pk=pk) | ||
| data = GetGenModelListDetails(**select_as_dict(model)) | ||
| return response_base.success(data=data) | ||
|
|
||
|
|
||
| @router.post( | ||
| '', | ||
| summary='创建代码生成模型', | ||
| dependencies=[ | ||
| Depends(RequestPermission('gen:code:model:add')), | ||
| DependsRBAC, | ||
| ], | ||
| ) | ||
| async def create_model(obj: CreateGenModelParam) -> ResponseModel: | ||
| await gen_model_service.create(obj=obj) | ||
| return response_base.success() | ||
|
|
||
|
|
||
| @router.put( | ||
| '/{pk}', | ||
| summary='更新代码生成模型', | ||
| dependencies=[ | ||
| Depends(RequestPermission('gen:code:model:edit')), | ||
| DependsRBAC, | ||
| ], | ||
| ) | ||
| async def update_model(pk: Annotated[int, Path(...)], obj: UpdateGenModelParam) -> ResponseModel: | ||
| count = await gen_model_service.update(pk=pk, obj=obj) | ||
| if count > 0: | ||
| return response_base.success() | ||
| return response_base.fail() | ||
|
|
||
|
|
||
| @router.delete( | ||
| '/{pk}', | ||
| summary='删除代码生成模型', | ||
| dependencies=[ | ||
| Depends(RequestPermission('gen:code:model:del')), | ||
| DependsRBAC, | ||
| ], | ||
| ) | ||
| async def delete_model(pk: Annotated[int, Path(...)]) -> ResponseModel: | ||
| count = await gen_model_service.delete(pk=pk) | ||
| if count > 0: | ||
| return response_base.success() | ||
| return response_base.fail() |