mirror of
https://github.com/Websoft9/websoft9.git
synced 2025-01-24 18:30:23 +08:00
197 lines
8.9 KiB
Python
197 lines
8.9 KiB
Python
from typing import Optional, List
|
||
|
||
from fastapi import APIRouter, status, Depends, Query, Request
|
||
from pydantic import BaseModel, Field
|
||
from starlette.responses import JSONResponse
|
||
import os, io, sys, platform, shutil, time, subprocess, json, datetime
|
||
|
||
from api.model.app import App
|
||
from api.model.response import Response
|
||
from api.service import manage
|
||
from api.utils import shell_execute, const
|
||
from api.utils.common_log import myLogger
|
||
from api.exception.command_exception import CommandException
|
||
|
||
router = APIRouter()
|
||
|
||
rd1 = "code：请求操作内部响应码（0：成功 -1：失败）\n\nmessage：请求操作结果描述\n\ndata：返回请求结果内容\n\n" \
|
||
"[\n\n" \
|
||
"  app_id：应用ID,\n\n" \
|
||
"  name：应用名,\n\n" \
|
||
"  customer_name：自定义应用名,\n\n" \
|
||
"  trade_mark：应用商标,\n\n" \
|
||
"  status_code：应用运行状态码,\n\n"
|
||
|
||
status = '  status：应用运行状态,\n\n'
|
||
status_detail = "  status：应用运行状态,（running:正常运行，stop：停止，error：错误）\n\n"
|
||
status_list = "  status：应用运行状态,（waiting：等待安装，installing：安装中，running:正常运行，stop：停止，error：错误）\n\n"
|
||
|
||
rd2 = "  port：应用端口,\n\n" \
|
||
"  volume：yml文件路径,\n\n" \
|
||
"  url：应用网址,\n\n" \
|
||
"  image_url：图片路径,\n\n" \
|
||
"  admin_url：管理员网址,\n\n" \
|
||
"  user_name：用户名,\n\n" \
|
||
"  password：密码,\n\n" \
|
||
"  official_app：是否为官方应用\n\n" \
|
||
"]"
|
||
rd = rd1 + status + rd2
|
||
rd_detail = rd1 + status_detail + rd2
|
||
rd_list = rd1 + status_list + rd2
|
||
rd_process = "code：请求操作内部响应码（0：成功 -1：失败）\n\nmessage：请求操作结果描述\n\nstatus：应用运行状态," \
|
||
"（pulling：拉取镜像，creating：容器启动，inting：容器初始化，running:正常运行）"
|
||
rd_two = "code：请求操作内部响应码（0：成功 -1：失败）\n\nmessage：请求操作结果描述\n\ndata：None"
|
||
|
||
|
||
@router.api_route("/AppStatus", methods=["GET", "POST"], summary="获取指定APP的信息",
|
||
response_description=rd_detail,
|
||
response_model=Response)
|
||
def AppStatus(app_id: Optional[str] = Query(default=None, description="应用ID")):
|
||
try:
|
||
myLogger.info_logger("Receive request: /AppStatus")
|
||
ret = {}
|
||
ret['ResponseData'] = manage.get_app_status(app_id)
|
||
except CommandException as ce:
|
||
ret = {}
|
||
ret['ResponseData'] = None
|
||
ret['Error'] = manage.get_error_info(ce.code, ce.message, str(ce))
|
||
except Exception as e:
|
||
ret = {}
|
||
ret['ResponseData'] = None
|
||
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
|
||
return JSONResponse(ret)
|
||
|
||
|
||
@router.api_route("/AppList", methods=["GET", "POST"], summary="获取所有APP的信息", response_description=rd_list,
|
||
response_model=Response)
|
||
def AppList(request: Request, app_id: Optional[str] = Query(default=None, description="应用ID")):
|
||
try:
|
||
myLogger.info_logger("Receive request: /AppList")
|
||
get_headers(request)
|
||
ret = {}
|
||
ret['ResponseData'] = manage.get_my_app
|
||
except CommandException as ce:
|
||
ret = {}
|
||
ret['ResponseData'] = None
|
||
ret['Error'] = manage.get_error_info(ce.code, ce.message, str(ce))
|
||
except Exception as e:
|
||
ret = {}
|
||
ret['ResponseData'] = None
|
||
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
|
||
return JSONResponse(content=ret)
|
||
|
||
|
||
@router.api_route("/AppInstall", methods=["GET", "POST"], summary="安装APP", response_description=rd_two,
|
||
response_model=Response)
|
||
def AppInstall(request: Request, app_name: Optional[str] = Query(default=None, description="应用名"),
|
||
customer_name: Optional[str] = Query(default=None, description="应用自定义名字"),
|
||
app_version: Optional[str] = Query(default=None, description="应用版本")):
|
||
try:
|
||
myLogger.info_logger("Receive request: /AppInstall")
|
||
get_headers(request)
|
||
ret = manage.install_app(app_name, customer_name, app_version)
|
||
except CommandException as ce:
|
||
myLogger.error_logger(ce.code)
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
|
||
except Exception as e:
|
||
myLogger.error_logger(str(e))
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
|
||
|
||
myLogger.info_logger(ret)
|
||
return JSONResponse(content=ret)
|
||
|
||
|
||
@router.api_route("/AppStart", methods=["GET", "POST"], summary="启动APP", response_description=rd_two,
|
||
response_model=Response)
|
||
def start_app(app_id: Optional[str] = Query(default=None, description="应用ID")):
|
||
try:
|
||
myLogger.info_logger("Receive request: /AppStart")
|
||
get_headers(request)
|
||
manage.start_app(app_id)
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
except CommandException as ce:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
|
||
except Exception as e:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
|
||
return JSONResponse(content=ret)
|
||
|
||
|
||
@router.api_route("/AppStop", methods=["GET", "POST"], summary="停止APP", response_description=rd_two,
|
||
response_model=Response)
|
||
def stop_app(app_id: Optional[str] = Query(default=None, description="应用ID")):
|
||
try:
|
||
myLogger.info_logger("Receive request: /AppStop")
|
||
manage.stop_app(app_id)
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
except CommandException as ce:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
|
||
except Exception as e:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
|
||
return JSONResponse(content=ret)
|
||
|
||
|
||
@router.api_route("/AppRestart", methods=["GET", "POST"], summary="重启APP", response_description=rd_two,
|
||
response_model=Response)
|
||
def AppRestart(app_id: Optional[str] = Query(default=None, description="应用ID")):
|
||
try:
|
||
myLogger.info_logger("Receive request: /AppRestart")
|
||
ret = manage.restart_app(app_id)
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
except CommandException as ce:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
|
||
except Exception as e:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(const.ERROR_SERVER_SYSTEM, "system original error", str(e))
|
||
return JSONResponse(content=ret)
|
||
|
||
|
||
@router.api_route("/AppUninstall", methods=["GET", "POST"], summary="卸载APP", response_description=rd_two,
|
||
response_model=Response)
|
||
def AppUninstall(request: Request, app_id: Optional[str] = Query(default=None, description="应用ID"),
|
||
delete_image: bool = Query(default=False, description="是否删除镜像"),
|
||
delete_data: bool = Query(default=True, description='是否删除所有数据')):
|
||
|
||
try:
|
||
myLogger.info_logger("Receive request: /AppUninstall")
|
||
get_headers(request)
|
||
manage.uninstall_app(app_name, customer_name, app_version)
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
except CommandException as ce:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
ret['Error'] = manage.get_error_info(ce.code, ce.message, ce.detail)
|
||
except Exception as e:
|
||
ret = {}
|
||
ret['ResponseData']['AppID'] = app_name + "_" + customer_name
|
||
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:
|
||
version = headers.get('Version')
|
||
language = headers.get('Language')
|
||
myLogger.info_logger("Version: " + version + ", Language: " + language)
|
||
except:
|
||
pass
|