| |
| |
| |
| |
| |
| |
| |
| |
| import json |
| import os |
| |
| |
| |
| import sys |
|
|
| if "/www/server/panel/class" not in sys.path: |
| sys.path.insert(0, "/www/server/panel/class") |
|
|
| os.chdir("/www/server/panel") |
| import public |
|
|
| if "/www/server/panel" not in sys.path: |
| sys.path.insert(0, "/www/server/panel") |
| from mod.project.nodejs.base import NodeJs |
|
|
|
|
| class main(NodeJs): |
|
|
| def __init__(self): |
| super(main, self).__init__() |
|
|
| |
| def check_path_status(self, get): |
| ''' |
| @name 查看指定目录是否符合创建要求 |
| ''' |
| get.path = get.get("path", None) |
| if get.path is None: |
| return public.returnResult(False, 'path参数不能为空', code=5) |
|
|
| if not os.path.exists(get.path): |
| return public.returnResult(False, '指定目录不存在', code=5) |
|
|
| package_json = True |
| if not os.path.exists(os.path.join(get.path, 'package.json')): |
| package_json = False |
|
|
| node_modules = True |
| if not os.path.exists(os.path.join(get.path, 'node_modules')): |
| node_modules = False |
|
|
| data = { |
| "package_json": package_json, |
| "node_modules": node_modules, |
| } |
|
|
| return public.returnResult(True, '', data=data, code=0) |
|
|
| |
| def pre_env(self, get): |
| ''' |
| @name 添加项目前置环境信息 |
| ''' |
| nodejs_versions = self.get_nodejs_version(get) |
| if not nodejs_versions: |
| return public.returnResult(False, '未安装nodejs', code=3) |
|
|
| nodejs_versions = sorted(nodejs_versions, key=self.version_key, reverse=True) |
|
|
| |
| import psutil |
| mem = psutil.virtual_memory() |
| mem = int(mem.total / 1024 / 1024) |
|
|
| data = { |
| 'nodejs_versions': nodejs_versions, |
| 'package_managers': self.package_managers(nodejs_versions), |
| 'user_list': sorted(self.get_system_user_list(get), reverse=True), |
| 'maximum_memory': mem, |
| } |
|
|
| return public.returnResult(True, '', data=data, code=0) |
|
|
| |
| def get_package_managers(self, get): |
| ''' |
| @name 获取指定的nodejs版本允许使用的包管理器 |
| ''' |
| get.version = get.get("version", None) |
| if get.version is None: |
| return public.returnResult(False, 'version参数不能为空', code=5) |
|
|
| nodejs_versions = [get.version] |
| package_managers = self.package_managers(nodejs_versions) |
| return public.returnResult(True, 'success', data={"package_managers": package_managers}, code=0) |
|
|
| |
| def create(self, get): |
| ''' |
| @name 创建项目 |
| @param get: dict_obj {} |
| nodejs项目： |
| get.project_cwd string 项目路径 /www/wwwroot/my_project 必传 |
| get.project_name string 项目名称 my_project 必传 |
| get.project_type string 项目类型 nodejs/pm2/general 必传 |
| get.project_script string 启动脚本 start/dev/... 必传 |
| get.run_user string 运行用户 www/root/... 必传 |
| get.port string 端口 4001 非必传 |
| get.env string 环境变量 key=value\nkey=value\n... 非必传 |
| get.nodejs_version string node版本 v20.15.0 必传 |
| get.pkg_manager string 包管理器 npm/yarn/pnpm/... 必传 |
| get.not_install_pkg bool 是否安装依赖包 True/False 非必传 |
| get.release_firewall bool 是否放行防火墙 True/False 非必传 |
| get.is_power_on bool 是否开机启动 True/False 非必传 |
| get.max_memory_limit int 最大内存限制 4096 非必传 |
| get.bind_extranet bool 是否绑定外网 True/False 依赖于get.port 非必传 |
| get.domains list 域名列表 ["www.bt.cn", "bt.cn", ...] 非必传 |
| get.project_ps string 备注 ps 非必传 |
| pm2项目： |
| get.project_type string 项目类型 nodejs/pm2/general 必传 |
| get.project_name string 项目名称 my_project 必传 |
| get.nodejs_version string node版本 v20.15.0 必传 |
| get.project_file string 项目启动文件 /www/wwwroot/my_project/server.js 自定义添加时必传 |
| get.project_cwd string 项目路径 /www/wwwroot/my_project 自定义添加时必传 |
| get.cluster int 实例数量 1 必传，默认1 |
| get.max_memory_limit int 最大内存限制 1024 必传，默认1024，mb |
| get.watch 自动重载 bool True/False 必传，默认False |
| get.pkg_manager string 包管理器 none/npm/yarn/pnpm/... 必传，默认none |
| get.not_install_pkg bool 是否安装依赖包 True/False 非必传 |
| get.run_user string 运行用户 www/root/... 必传 |
| get.config_file string 配置文件路径 /www/wwwroot/remix_app/ecosystem.config.cjs 配置文件方式添加时必传 |
| get.config_body string 配置文件内容 非必传 可以单独传config_body，如果选了config_file，这里就是必传，也要传config_body |
| get.port string 端口 4001 非必传 |
| get.release_firewall bool 是否放行防火墙 True/False 非必传 |
| get.is_power_on bool 是否开机启动 True/False 非必传 |
| get.bind_extranet bool 是否绑定外网 True/False 依赖于get.port 非必传 |
| get.domains list 域名列表 ["www.bt.cn", "bt.cn", ...] 非必传 |
| get.project_ps string 备注 ps 非必传 |
| general项目： |
| get.project_type string 项目类型 nodejs/pm2/general 必传 |
| get.project_name string 项目名称 my_project 必传 |
| get.nodejs_version string node版本 v20.15.0 必传 |
| get.project_file string 项目启动文件 /www/wwwroot/my_project/server.js 必传 |
| get.project_cwd string 项目路径 /www/wwwroot/my_project 必传 |
| get.project_args string 启动参数 --debug 非必传 |
| get.env string 环境变量 key=value\nkey=value\n... 非必传 |
| get.run_user string 运行用户 www/root/... 必传 |
| get.port string 端口 4001 非必传 |
| get.release_firewall bool 是否放行防火墙 True/False 非必传 |
| get.is_power_on bool 是否开机启动 True/False 非必传 |
| get.max_memory_limit int 最大内存限制 4096 非必传 |
| get.bind_extranet bool 是否绑定外网 True/False 依赖于get.port 非必传 |
| get.domains list 域名列表 ["www.bt.cn", "bt.cn", ...] 非必传 |
| get.project_ps string 备注 ps 非必传 |
| ''' |
| public.set_module_logs('node_site_{}'.format(get.get("project_type", None)), 'create_app', 1) |
| public.set_module_logs('node_site', 'create_app', 1) |
| self.set_self_get(get) |
| self.set_def_name(get.def_name) |
| get.project_type = get.get("project_type", None) |
| get.port = get.get('port', "") |
| get.bind_extranet = get.get('bind_extranet', 0) |
| if get.project_type is None: |
| self.ws_err_exit(False, 'project_type参数不能为空', code=2) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| self.ws_err_exit(False, '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), code=2) |
| if get.port != "": |
| if self.check_port_is_used(get.get('port/port')): |
| self.ws_err_exit(False, |
| '指定端口已被其它应用占用，请修改您的项目配置使用其它端口, 端口: {}'.format(get.port), |
| code=2) |
|
|
| if public.M('sites').where('name=?',(get.project_name.strip(),)).count(): |
| self.ws_err_exit(False, '指定项目名称已存在: {}'.format(get.project_name), code=2) |
|
|
| get.domains = get.get("domains", []) |
| if type(get.domains) == str: |
| get.domains = get.domains.split('\n') |
| domains = get.domains |
| if len(domains) > 0: |
| public.check_domain_cloud(domains[0]) |
| if get.port == "": |
| self.ws_err_exit(False, '绑定外网需要指定端口', code=2) |
| get.bind_extranet = 1 |
| if not public.is_apache_nginx(): |
| self.ws_err_exit(False, '需要安装Nginx或Apache才能使用外网映射功能', code=3) |
|
|
| from mod.base.web_conf import normalize_domain |
| domains, err = normalize_domain(*domains) |
| if err: |
| self.ws_err_exit(False, "域名输入错误", code=5) |
| for domain, port in domains: |
| if public.M('domain').where('name=? AND port=?', (domain, port)).count(): |
| self.ws_err_exit(False, '指定域名已存在: {}'.format(domain), code=4) |
| get.domains = ["{}:{}".format(d,p) for d, p in domains] |
|
|
| get.nodejs_version = get.get("nodejs_version", None) |
| if get.nodejs_version is None: |
| self.ws_err_exit(False, 'nodejs_version参数不能为空', code=2) |
| self.set_nodejs_version(get.nodejs_version).set_nodejs_bin() |
| if not os.path.exists(self.nodejs_bin): |
| self.ws_err_exit(False, '未安装nodejs版本: {}，请安装后再添加项目'.format(get.nodejs_version), code=2) |
|
|
| if get.project_type in ("nodejs", "pm2"): |
| get.pkg_manager = get.get("pkg_manager", "npm") |
| self.set_manager(get.pkg_manager) |
| self.set_pack_cmd(get.nodejs_version) |
| if self.pack_cmd is None or not os.path.exists(self.pack_cmd): |
| get._ws.send(json.dumps(self.wsResult(True, "【node {}】中未安装【{}】,已为您切换到npm创建".format( |
| get.nodejs_version, get.pkg_manager)))) |
| get.pkg_manager = "npm" |
|
|
| get.release_firewall = get.get("release_firewall", False) |
| get.project_ps = get.get("project_ps", "") |
|
|
| self.set_project_model(get.project_type) |
| self.projectModel.create_project(get) |
| if get.release_firewall: |
| from firewallModel.comModel import main as comModel |
| firewall_com = comModel() |
| if get.port != "": |
| firewall_com.set_port_rule(get) |
|
|
| |
| def delete(self, get): |
| ''' |
| @name 删除项目 |
| ''' |
| get.project_type = get.get("project_type", None) |
| if get.project_type is None: |
| return public.returnResult(False, 'project_type参数不能为空', code=5) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| return public.returnResult(False, |
| '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), |
| code=5) |
| get.project_name = get.get("project_name", None) |
| if get.project_name is None: |
| return public.returnResult(False, 'project_name参数不能为空', code=5) |
|
|
| self.set_project_model(get.project_type) |
| return self.projectModel.remove_project(get) |
|
|
| |
| def get_pm2_monit(self, get): |
| ''' |
| @name 获取pm2的监控数据 |
| ''' |
| from mod.project.nodejs.pm2Mod import main |
| return main().get_pm2_monit(get) |
|
|
| |
| def get_pm2_logs(self, get): |
| ''' |
| @name 获取指定pm2项目的日志 |
| @param get: dict_obj {} |
| get.mode string fork_mode/cluster_mode 必传 |
| get.id string pm2项目id 必传 mode=fork_mode |
| get.name string pm2项目名称 必传 mode=cluster_mode |
| get.log_type string 日志类型 all/out/err 非必传 |
| ''' |
| get.mode = get.get("mode", None) |
| if get.mode is None: |
| return public.returnResult(False, 'mode参数不能为空', code=5) |
| if not get.mode in ("fork_mode", "cluster_mode"): |
| return public.returnResult(False, 'mode参数错误, 只支持fork_mode/cluster_mode', code=5) |
|
|
| get.id = get.get("id", None) |
| get.name = get.get("name", None) |
| if get.mode == "fork_mode" and id is None: |
| return public.returnResult(False, 'id参数不能为空', code=5) |
| if get.mode == "cluster_mode" and get.name is None: |
| return public.returnResult(False, 'name参数不能为空', code=5) |
|
|
| get.log_type = get.get("log_type", "all") |
| if not get.log_type in ("all", "out", "err"): |
| return public.returnResult(False, 'log_type参数错误', code=5) |
| self.set_project_model("pm2") |
| return self.projectModel.get_logs(get.mode, get.id, get.name, get.log_type) |
|
|
| |
| def set_pm2_status(self, get): |
| ''' |
| @name 设置指定pm2项目的状态 |
| @param get: dict_obj {} |
| get.mode string fork_mode/cluster_mode 必传 |
| get.id string pm2项目id 必传 mode=fork_mode |
| get.name string pm2项目名称 必传 mode=cluster_mode |
| get.action string restart/stop/start 必传 |
| ''' |
| get.mode = get.get("mode", None) |
| if get.mode is None: |
| return public.returnResult(False, 'mode参数不能为空', code=5) |
| if not get.mode in ("fork_mode", "cluster_mode"): |
| return public.returnResult(False, 'mode参数错误, 只支持fork_mode/cluster_mode', code=5) |
|
|
| get.id = get.get("id", None) |
| get.name = get.get("name", None) |
| if get.mode == "fork_mode" and id is None: |
| return public.returnResult(False, 'id参数不能为空', code=5) |
| if get.mode == "cluster_mode" and get.name is None: |
| return public.returnResult(False, 'name参数不能为空', code=5) |
|
|
| get.status = get.get("status", None) |
| if get.status is None: |
| return public.returnResult(False, 'action参数不能为空', code=5) |
| if not get.status in ("restart", "stop", "start"): |
| return public.returnResult(False, 'action参数错误, 只支持restart/stop/start', code=5) |
|
|
| self.set_project_model("pm2") |
| return getattr(self.projectModel, get.status)(get.mode, get.id, get.name, get.get("project_name/s", "")) |
|
|
| |
| def del_pm2_project(self, get): |
| ''' |
| @name 删除指定pm2项目 |
| @param get: dict_obj {} |
| get.mode string fork_mode/cluster_mode 必传 |
| get.id string pm2项目id 必传 mode=fork_mode |
| get.name string pm2项目名称 必传 mode=cluster_mode |
| ''' |
| get.mode = get.get("mode", None) |
| if get.mode is None: |
| return public.returnResult(False, 'mode参数不能为空', code=5) |
| if not get.mode in ("fork_mode", "cluster_mode"): |
| return public.returnResult(False, 'mode参数错误, 只支持fork_mode/cluster_mode', code=5) |
|
|
| get.id = get.get("id", None) |
| get.name = get.get("name", None) |
| if get.mode == "fork_mode" and id is None: |
| return public.returnResult(False, 'id参数不能为空', code=5) |
| if get.mode == "cluster_mode" and get.name is None: |
| return public.returnResult(False, 'name参数不能为空', code=5) |
|
|
| self.set_project_model("pm2") |
| return self.projectModel.del_project(get.mode, get.id, get.name) |
|
|
| |
| def set_project_status(self, get): |
| ''' |
| @name 设置指定服务的状态 |
| ''' |
| get.project_type = get.get("project_type", None) |
| if get.project_type is None: |
| return public.returnResult(False, 'project_type参数不能为空', code=5) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| return public.returnResult(False, |
| '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), |
| code=5) |
| get.project_name = get.get("project_name", None) |
| if get.project_name is None: |
| return public.returnResult(False, 'project_name参数不能为空', code=5) |
|
|
| if get.project_type == "pm2": |
| get.pm2_name = get.get("pm2_name", "") |
| if get.pm2_name == "": |
| return public.returnResult(False, 'pm2_name参数不能为空', code=5) |
| get.mode = "cluster_mode" |
| get.name = get.pm2_name |
| return self.set_pm2_status(get) |
| else: |
| get.status = get.get("status", None) |
| if get.status is None: |
| return public.returnResult(False, 'action参数不能为空', code=5) |
| if not get.status in ("restart", "stop", "start"): |
| return public.returnResult(False, 'action参数错误, 只支持restart/stop/start', code=5) |
|
|
| self.set_project_model(get.project_type) |
| return getattr(self.projectModel, "{}_project".format(get.status))(get) |
|
|
| |
| def stop_project(self, get): |
| ''' |
| @name 停止指定项目 |
| ''' |
| get.project_type = get.get("project_type", None) |
| if get.project_type is None: |
| return public.returnResult(False, 'project_type参数不能为空', code=5) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| return public.returnResult(False, |
| '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), |
| code=5) |
| get.project_name = get.get("project_name", None) |
| if get.project_name is None: |
| return public.returnResult(False, 'project_name参数不能为空', code=5) |
|
|
| get.status = "stop" |
| if get.project_type == "pm2": |
| get.pm2_name = get.get("pm2_name", "") |
| if get.pm2_name == "": |
| return public.returnResult(False, 'pm2_name参数不能为空', code=5) |
| get.mode = "cluster_mode" |
| get.name = get.pm2_name |
| return self.set_pm2_status(get) |
| else: |
| from projectModel.nodejsModel import main |
| return getattr(main(), "{}_project".format(get.status))(get) |
|
|
| |
| def start_project(self, get): |
| ''' |
| @name 启动指定项目 |
| ''' |
| get.project_type = get.get("project_type", None) |
| if get.project_type is None: |
| return public.returnResult(False, 'project_type参数不能为空', code=5) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| return public.returnResult(False, |
| '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), |
| code=5) |
| get.project_name = get.get("project_name", None) |
| if get.project_name is None: |
| return public.returnResult(False, 'project_name参数不能为空', code=5) |
|
|
| get.status = "start" |
| if get.project_type == "pm2": |
| get.pm2_name = get.get("pm2_name", "") |
| if get.pm2_name == "": |
| return public.returnResult(False, 'pm2_name参数不能为空', code=5) |
| get.mode = "cluster_mode" |
| get.name = get.pm2_name |
| return self.set_pm2_status(get) |
| else: |
| from projectModel.nodejsModel import main |
| return getattr(main(), "{}_project".format(get.status))(get) |
|
|
| |
| def restart_project(self, get): |
| ''' |
| @name 重启指定项目 |
| ''' |
| get.project_type = get.get("project_type", None) |
| if get.project_type is None: |
| return public.returnResult(False, 'project_type参数不能为空', code=5) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| return public.returnResult(False, |
| '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), |
| code=5) |
| get.project_name = get.get("project_name", None) |
| if get.project_name is None: |
| return public.returnResult(False, 'project_name参数不能为空', code=5) |
|
|
| get.status = "restart" |
| if get.project_type == "pm2": |
| get.pm2_name = get.get("pm2_name", "") |
| if get.pm2_name == "": |
| return public.returnResult(False, 'pm2_name参数不能为空', code=5) |
| get.mode = "cluster_mode" |
| get.name = get.pm2_name |
| return self.set_pm2_status(get) |
| else: |
| from projectModel.nodejsModel import main |
| return getattr(main(), "{}_project".format(get.status))(get) |
|
|
| |
| def get_project_list(self, get): |
| ''' |
| @name 获取项目列表 |
| @author hwliang<2021-08-09> |
| @param get<dict_obj>{ |
| project_name: string<项目名称> |
| } |
| @return dict |
| ''' |
|
|
| if not 'p' in get: get.p = 1 |
| if not 'limit' in get: get.limit = 20 |
| if not 'callback' in get: get.callback = '' |
| if not 'order' in get: get.order = 'id desc' |
| type_id = None |
| if "type_id" in get: |
| try: |
| type_id = int(get.type_id) |
| except: |
| type_id = None |
|
|
| if 'search' in get: |
| get.project_name = get.search.strip() |
| search = "%{}%".format(get.project_name) |
| if type_id is None: |
| count = public.M('sites').where('project_type=? AND (name LIKE ? OR ps LIKE ?)', |
| ('Node', search, search)).count() |
| data = public.get_page(count, int(get.p), int(get.limit), get.callback) |
| data['data'] = public.M('sites').where('project_type=? AND (name LIKE ? OR ps LIKE ?)', |
| ('Node', search, search)).limit( |
| data['shift'] + ',' + data['row']).order(get.order).select() |
| else: |
| count = public.M('sites').where('project_type=? AND (name LIKE ? OR ps LIKE ?) AND type_id = ?', |
| ('Node', search, search, type_id)).count() |
| data = public.get_page(count, int(get.p), int(get.limit), get.callback) |
| data['data'] = public.M('sites').where('project_type=? AND (name LIKE ? OR ps LIKE ?) AND type_id = ?', |
| ('Node', search, search, type_id)).limit( |
| data['shift'] + ',' + data['row']).order(get.order).select() |
| else: |
| if type_id is None: |
| count = public.M('sites').where('project_type=?', 'Node').count() |
| data = public.get_page(count, int(get.p), int(get.limit), get.callback) |
| data['data'] = public.M('sites').where('project_type=?', 'Node').limit( |
| data['shift'] + ',' + data['row']).order(get.order).select() |
| else: |
| count = public.M('sites').where('project_type=? AND type_id = ?', ('Node', type_id)).count() |
| data = public.get_page(count, int(get.p), int(get.limit), get.callback) |
| data['data'] = public.M('sites').where('project_type=? AND type_id = ?', ('Node', type_id)).limit( |
| data['shift'] + ',' + data['row']).order(get.order).select() |
|
|
| if isinstance(data["data"], str) and data["data"].startswith("error"): |
| raise public.PanelError("数据库查询错误：" + data["data"]) |
|
|
| for i in range(len(data['data'])): |
| data['data'][i] = self.get_project_stat(data['data'][i]) |
| return data |
|
|
| |
| def get_project_info(self, get): |
| ''' |
| @name 获取指定项目信息 |
| @author hwliang<2021-08-09> |
| @param get<dict_obj>{ |
| project_name: string<项目名称> |
| } |
| @return dict |
| ''' |
| get.project_type = get.get("project_type", None) |
| if get.project_type is None: |
| return public.returnResult(False, 'project_type参数不能为空', code=5) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| return public.returnResult(False, |
| '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), |
| code=5) |
| get.project_name = get.get("project_name", None) |
| if get.project_name is None: |
| return public.returnResult(False, 'project_name参数不能为空', code=5) |
|
|
| project_info = public.M('sites').where('project_type=? AND name=?', ('Node', get.project_name)).find() |
| if not project_info: |
| return public.returnResult(False, '指定项目不存在!', code=5) |
| project_info = self.get_project_stat(project_info) |
| return project_info |
|
|
| |
| def modify_project(self, get): |
| ''' |
| @name 修改指定项目 |
| @author hwliang<2021-08-09> |
| @param get<dict_obj>{ |
| project_name: string<项目名称> |
| project_cwd: string<项目目录> |
| project_script: string<项目脚本> |
| project_ps: string<项目备注信息> |
| is_power_on: int<是否开机启动> 1:是 0:否 |
| run_user: string<运行用户> |
| max_memory_limit: int<最大内存限制> // 超出此值项目将被强制重启 |
| nodejs_version: string<nodejs版本> |
| } |
| @return dict |
| ''' |
| if not isinstance(get, public.dict_obj): return public.return_error('参数类型错误，需要dict_obj对像') |
| if not self.is_install_nodejs(get): |
| return public.returnResult(False, '请先安装nodejs版本管理器，并安装至少1个node.js版本', code=5) |
| project_find = self.get_project_find(get.project_name) |
| if not project_find: |
| return public.returnResult(False, '指定项目不存在: {}'.format(get.project_name), code=5) |
|
|
| if not os.path.exists(get.project_cwd): |
| return public.returnResult(False, '项目目录不存在: {}'.format(get.project_cwd), code=5) |
|
|
| get.project_type = get.get("project_type", None) |
| if get.project_type is None: |
| return public.returnResult(False, 'project_type参数不能为空', code=5) |
| if not get.project_type in ("nodejs", "pm2", "general"): |
| return public.returnResult(False, |
| '项目类型：{} 不合法, 暂时支持是nodejs/pm2/general'.format(get.project_type), |
| code=5) |
| get.project_name = get.get("project_name", None) |
| if get.project_name is None: |
| return public.returnResult(False, 'project_name参数不能为空', code=5) |
|
|
| rebuild = False |
| get.project_cwd = get.get("project_cwd", "") |
| if get.project_cwd == "": |
| return public.returnResult(False, 'project_cwd参数不能为空', code=5) |
| if not os.path.exists(get.project_cwd): |
| return public.returnResult(False, '{} 指定项目目录不存在'.format(get.project_cwd), code=5) |
| if not os.path.isdir(get.project_cwd): |
| return public.returnResult(False, '{} 指定项目目录不是一个目录'.format(get.project_cwd), code=5) |
|
|
| if hasattr(get, 'project_cwd'): |
| if get.project_cwd[-1] == '/': |
| get.project_cwd = get.project_cwd[:-1] |
| project_find['project_config']['project_cwd'] = get.project_cwd |
| project_find['project_config']['project_script'] = get.project_script.strip() |
|
|
| get.project_file = get.get("project_file", "") |
| get.run_user = get.get("run_user", "www") |
| if hasattr(get, 'run_user'): project_find['project_config']['run_user'] = get.run_user |
| get.port = get.get("port", "") |
| if hasattr(get, 'port') and get.port != "": |
| if not project_find['project_config']['port'] is None: |
| if int(project_find['project_config']['port']) != int(get.port): |
| if self.check_port_is_used(get.get('port/port'), True): |
| return public.returnResult(False, |
| '指定端口已被其它应用占用，请修改您的项目配置使用其它端口, 端口: {}'.format( |
| get.port), code=5) |
| project_find['project_config']['port'] = int(get.port) |
| else: |
| if self.check_port_is_used(get.get('port/port'), True): |
| return public.returnResult(False, |
| '指定端口已被其它应用占用，请修改您的项目配置使用其它端口, 端口: {}'.format( |
| get.port), code=5) |
| project_find['project_config']['port'] = int(get.port) |
| if get.port == "" or get.port is None: |
| project_find['project_config']['port'] = None |
|
|
| get.project_args = get.get("project_args", "") |
| project_find['project_config']['project_args'] = get.project_args |
| get.env = get.get("env", "") |
| if get.env != "": |
| env = get.env.split("\n") |
| for e in env: |
| if not "=" in e: |
| return public.returnResult(False, "环境变量: {} 格式错误，请重新输入例如：key=value".format(e), |
| code=5) |
| project_find['project_config']['env'] = get.env |
|
|
| get.nodejs_version = get.get("nodejs_version", None) |
| if get.nodejs_version is None: |
| return public.returnResult(False, 'nodejs_version参数不能为空', code=5) |
| if hasattr(get, 'nodejs_version'): |
| if project_find['project_config']['nodejs_version'] != get.nodejs_version: |
| rebuild = True |
| project_find['project_config']['nodejs_version'] = get.nodejs_version |
|
|
| get.pkg_manager = get.get("pkg_manager", "") |
| if get.pkg_manager in ("npm", "pnpm", "yarn") and project_find['project_config']['project_type'] in ("nodejs", "pm2"): |
| project_find['project_config']['pkg_manager'] = get.pkg_manager |
| elif project_find['project_config']['project_type'] == "general": pass |
| else: |
| return public.returnResult(False, 'pkg_manager参数错误，请输入npm或pnpm或yarn', code=5) |
|
|
| if project_find['project_config'].get('pkg_manager', "") == "pnpm": |
| _v = int(project_find['project_config']['nodejs_version'].split(".", 1)[0][1:]) |
| if _v < 12: |
| return public.returnResult(False, "pnpm不支持Nodejs12以下的版本", code=5) |
|
|
| get.not_install_pkg = get.get("not_install_pkg", False) |
| get.release_firewall = get.get("release_firewall", False) |
| get.is_power_on = get.get("is_power_on", True) |
| if hasattr(get, 'is_power_on'): project_find['project_config']['is_power_on'] = get.is_power_on |
| get.max_memory_limit = get.get("max_memory_limit", 1024) |
| if hasattr(get, 'max_memory_limit'): project_find['project_config']['max_memory_limit'] = get.max_memory_limit |
| get.project_ps = get.get("project_ps", "") |
| if get.project_type == "pm2": |
| from mod.project.nodejs.pm2Mod import main |
| get.config_file = get.get("config_file", "") |
| get.config_body = get.get("config_body", "") |
| get.watch = get.get("watch", False) |
| get.cluster = get.get("cluster/d", 1) |
| self.set_pm2_cmd(get.nodejs_version) |
| if get.config_file != "" or get.config_body != "": |
| if get.config_file != "": |
| if not os.path.exists(get.config_file): |
| return public.returnResult(False, '{} 指定项目配置文件不存在'.format(get.config_file), code=5) |
| if not os.path.isfile(get.config_file): |
| return public.returnResult(False, '{} 指定项目配置文件不是一个文件'.format(get.config_file), |
| code=5) |
| if get.config_body == "": |
| if get.config_file != "": |
| get.config_body = public.readFile(get.config_file) |
| if get.config_body == "": |
| return public.returnResult(False, '{} 配置文件格式错误，请检查'.format(get.config_file), code=5) |
| if not "module.exports" in get.config_body and not "apps:" in get.config_body: |
| return public.returnResult(False, '{} 配置文件格式错误，请检查'.format(get.config_file), code=5) |
| else: |
| get.max_memory_restart = "{}M".format(get.max_memory_limit) |
| main().structure_ecosystem(get) |
| main().structure_start_script(get) |
|
|
| res = main().delete_for_ecosystem(get.nodejs_version, project_find['project_config']['config_file']) |
| if not res["status"]: |
| return public.returnResult(False, "原项目停止失败：{}，请删除重新添加后再试".format(res["msg"])) |
| res = main().start_for_ecosystem(get.nodejs_version, get.config_file) |
| if not res["status"]: |
| return public.returnResult(False, "编辑后的项目启动失败：{}，请删除重新添加后再试".format(res["msg"])) |
| project_find['project_config']['config_file'] = get.config_file |
| project_find['project_config']['config_body'] = get.config_body |
| project_find['project_config']['watch'] = get.watch |
| project_find['project_config']['cluster'] = get.cluster |
| project_find['project_config']['project_file'] = get.project_file |
| project_find['project_config']['project_cwd'] = get.project_cwd |
| elif get.project_type == "general": |
| from mod.project.nodejs.generalMod import main |
| main().structure_start_script(get) |
| else: |
| if hasattr(get, 'project_script'): |
| if not get.project_script.strip(): |
| return public.returnResult(False, '启动命令不能为空', code=5) |
|
|
| pdata = { |
| 'path': get.project_cwd, |
| 'ps': get.project_ps, |
| 'project_config': json.dumps(project_find['project_config']) |
| } |
|
|
| public.M('sites').where('name=?', (get.project_name,)).update(pdata) |
| self.set_config(get.project_name) |
| public.WriteLog(self.log_name, '修改Node.js项目{}'.format(get.project_name)) |
| if rebuild: |
| self.rebuild_project(get.project_name) |
|
|
| return public.returnResult(True, '修改项目成功') |
|
|
