0ct0pu5/websoft9
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

add fastapi interface

Browse source
This commit is contained in:
qiaofeng1227 2023-05-10 06:19:24 +00:00
parent cc7618ab05
commit 1ba5d9afe7
1 changed files with 92 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

92
appmanage/api/v1/routers/apps.py
View file

@ -211,6 +211,98 @@ def AppUninstall(request: Request, app_id: Optional[str] = Query(default=None, d
return JSONResponse(content=ret)
@router.api_route("/AppDomainAdd", methods=["GET", "POST"], summary="绑定域名", response_model=Response)
def AppDomainAdd(request: Request, app_id: Optional[str] = Query(default=None, description="应用ID"), domains: List[str]):
try:
myLogger.info_logger("Receive request: /AppDomainAdd")
get_headers(request)
ret = {}
ret['ResponseData'] = {}
manage.app_domain_add(app_id,domains)
ret['ResponseData']['AppID'] = app_id
except CommandException as ce:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
except Exception as e:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
return JSONResponse(content=ret)
@router.api_route("/AppDomainUpdate", methods=["GET", "POST"], summary="修改域名", response_model=Response)
def AppDomainUpdate(request: Request, app_id: Optional[str] = Query(default=None, description="应用ID"), domains: List[str]):
try:
myLogger.info_logger("Receive request: /AppDomainUpdate")
get_headers(request)
ret = {}
ret['ResponseData'] = {}
manage.app_domain_update(app_id,domains)
ret['ResponseData']['AppID'] = app_id
except CommandException as ce:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
except Exception as e:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
return JSONResponse(content=ret)
@router.api_route("/AppDomainDelete", methods=["GET", "POST"], summary="删除域名", response_model=Response)
def AppDomainDelete(request: Request, app_id: Optional[str] = Query(default=None, description="应用ID")):
try:
myLogger.info_logger("Receive request: /AppDomainDelete")
get_headers(request)
ret = {}
ret['ResponseData'] = {}
manage.app_domain_delete(app_id)
ret['ResponseData']['AppID'] = app_id
except CommandException as ce:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
except Exception as e:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
return JSONResponse(content=ret)
@router.api_route("/AppDomainList", methods=["GET", "POST"], summary="绑定域名", response_model=Response)
def AppDomainList(request: Request, app_id: Optional[str] = Query(default=None, description="应用ID")):
try:
myLogger.info_logger("Receive request: /AppDomainList")
get_headers(request)
ret = {}
ret['ResponseData'] = {}
manage.app_domain_list(app_id)
ret['ResponseData']['AppID'] = app_id
except CommandException as ce:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
except Exception as e:
ret = {}
ret['ResponseData'] = {}
ret['ResponseData']['AppID'] = app_id
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
return JSONResponse(content=ret)
def get_headers(request):
headers = request.headers
try: