mirror of
https://github.com/aaPanel/aaPanel.git
synced 2026-08-20 06:35:47 +02:00
135 lines
4.0 KiB
Python
135 lines
4.0 KiB
Python
# coding: utf-8
|
|
import sys, os
|
|
|
|
os.chdir('/www/server/panel/')
|
|
sys.path.insert(0, "class/")
|
|
import PluginLoader
|
|
import public
|
|
import time
|
|
|
|
|
|
def clear_hosts():
|
|
"""
|
|
@name 清理hosts文件中的bt.cn记录
|
|
@return:
|
|
"""
|
|
remove = 0
|
|
try:
|
|
import requests
|
|
requests.packages.urllib3.disable_warnings(requests.packages.urllib3.exceptions.InsecureRequestWarning)
|
|
|
|
url = f'{public.OfficialWaf2Base()}/api/ip/info_json'
|
|
res = requests.post(url, verify=False)
|
|
|
|
if res.status_code == 404:
|
|
remove = 1
|
|
elif res.status_code == 200 or res.status_code == 400:
|
|
res = res.json()
|
|
if res != "[]":
|
|
remove = 1
|
|
except:
|
|
result = public.ExecShell(f"curl -sS --connect-timeout 3 -m 60 -k {public.OfficialWaf2Base()}/api/ip/info_json")[0]
|
|
if result != "[]":
|
|
remove = 1
|
|
|
|
hosts_file = '/etc/hosts'
|
|
if remove == 1 and os.path.exists(hosts_file):
|
|
public.ExecShell('sed -i "/www.bt.cn/d" /etc/hosts')
|
|
|
|
def flush_cache():
|
|
'''
|
|
@name 更新缓存
|
|
@author hwliang
|
|
@return void
|
|
'''
|
|
try:
|
|
# start_time = time.time()
|
|
res = PluginLoader.get_plugin_list(1)
|
|
spath = '{}/data/pay_type.json'.format(public.get_panel_path())
|
|
public.downloadFile(public.get_url() + '/install/lib/pay_type.json', spath)
|
|
import plugin_deployment
|
|
plugin_deployment.plugin_deployment().GetCloudList(None)
|
|
|
|
# timeout = time.time() - start_time
|
|
if 'ip' in res and res['ip']:
|
|
pass
|
|
else:
|
|
if isinstance(res, dict) and not 'msg' in res: res['msg'] = 'Connection failure!'
|
|
except:
|
|
pass
|
|
|
|
|
|
def flush_php_order_cache():
|
|
"""
|
|
更新软件商店php顺序缓存
|
|
@return:
|
|
"""
|
|
spath = '{}/data/php_order.json'.format(public.get_panel_path())
|
|
public.downloadFile(public.get_url() + '/install/lib/php_order.json', spath)
|
|
|
|
|
|
def flush_msg_json():
|
|
"""
|
|
@name 更新消息json
|
|
"""
|
|
try:
|
|
spath = '{}/data/msg.json'.format(public.get_panel_path())
|
|
public.downloadFile(public.get_url() + '/linux/panel/msg/msg.json', spath)
|
|
except:
|
|
pass
|
|
|
|
|
|
def flush_docker_project_info():
|
|
'''
|
|
@name 更新docker_project版本信息
|
|
@author wzz
|
|
@return void
|
|
'''
|
|
msg = "docker_projcet version information"
|
|
try:
|
|
# start_time = time.time()
|
|
res = PluginLoader.get_plugin_list(1)
|
|
config_path = f"{public.get_panel_path()}/config"
|
|
spath = f"{config_path}/docker_project_info.json"
|
|
url = "/install/lib/docker_project/docker_project_info.json"
|
|
public.downloadFile(f"{public.get_url()}{url}", spath)
|
|
import plugin_deployment
|
|
plugin_deployment.plugin_deployment().GetCloudList(None)
|
|
|
|
# timeout = time.time() - start_time
|
|
if 'ip' in res and res['ip']:
|
|
pass
|
|
else:
|
|
if isinstance(res, dict) and not 'msg' in res: res['msg'] = 'Connection failure!'
|
|
except:
|
|
pass
|
|
|
|
|
|
# 2024/3/20 上午 11:09 更新docker_hub镜像排行数据
|
|
def flush_docker_hub_repos():
|
|
'''
|
|
@name 更新docker_hub镜像排行数据
|
|
@author wzz <2024/3/20 上午 11:09>
|
|
@param "data":{"参数名":""} <数据类型> 参数描述
|
|
@return dict{"status":True/False,"msg":"提示信息"}
|
|
'''
|
|
public.ExecShell("/www/server/panel/pyenv/bin/python3 /www/server/panel/class_v2/btdockerModelV2/script/syncreposdb.py")
|
|
|
|
|
|
if __name__ == '__main__':
|
|
tip_date_tie = '/tmp/.fluah_time'
|
|
if os.path.exists(tip_date_tie):
|
|
last_time = int(public.readFile(tip_date_tie))
|
|
timeout = time.time() - last_time
|
|
if timeout < 600:
|
|
print("Execution interval is too short, exit - {}!".format(timeout))
|
|
sys.exit()
|
|
clear_hosts()
|
|
flush_cache()
|
|
flush_php_order_cache()
|
|
flush_msg_json()
|
|
flush_docker_project_info()
|
|
flush_docker_hub_repos()
|
|
|
|
public.writeFile(tip_date_tie, str(int(time.time())))
|