This commit is contained in:
Mr Chen
2024-11-05 00:58:40 +08:00
parent 39c634ab14
commit 8010ead35a
2 changed files with 35 additions and 25 deletions
+23 -25
View File
@@ -24,12 +24,8 @@ web_dir = os.getcwd() + "/web"
os.chdir(web_dir)
sys.path.append(web_dir)
from admin import app
from admin import model
import thisdb
import core.mw as mw
import core.db as db
import thisdb
g_log_file = mw.getPanelTaskLog()
isTask = mw.getMWLogs() + '/panelTask.pl'
@@ -118,7 +114,7 @@ def runPanelTask():
thisdb.setTaskData(run_task['id'], end=end)
thisdb.setTaskStatus(run_task['id'], 1)
except Exception as e:
print(str(e))
print(mw.getTracebackInfo())
# 站点过期检查
# siteEdate()
@@ -130,7 +126,7 @@ def startPanelTask():
runPanelTask()
time.sleep(1)
except Exception as e:
print(str(e))
print(mw.getTracebackInfo())
time.sleep(10)
startPanelTask()
@@ -164,6 +160,7 @@ def systemTask():
monitor.instance().run()
time.sleep(5)
except Exception as ex:
print(mw.getTracebackInfo())
time.sleep(30)
systemTask()
@@ -249,6 +246,7 @@ def startPHPVersion(version):
if os.path.exists(cgi):
return True
except Exception as e:
print(mw.getTracebackInfo())
mw.writeLog('PHP守护程序', '自动修复异常:'+str(e))
return True
@@ -326,31 +324,31 @@ def setDaemon(t):
def run():
# # 系统监控
sysTask = threading.Thread(target=systemTask)
sysTask = setDaemon(sysTask)
sysTask.start()
# sysTask = threading.Thread(target=systemTask)
# sysTask = setDaemon(sysTask)
# sysTask.start()
# # PHP 502错误检查线程
php502 = threading.Thread(target=check502Task)
php502 = setDaemon(php502)
php502.start()
# php502 = threading.Thread(target=check502Task)
# php502 = setDaemon(php502)
# php502.start()
# OpenResty Restart At Once Start
oraos = threading.Thread(target=openrestyRestartAtOnce)
oraos = setDaemon(oraos)
oraos.start()
# # OpenResty Restart At Once Start
# oraos = threading.Thread(target=openrestyRestartAtOnce)
# oraos = setDaemon(oraos)
# oraos.start()
# OpenResty Auto Restart Start
oar = threading.Thread(target=openrestyAutoRestart)
oar = setDaemon(oar)
oar.start()
# # OpenResty Auto Restart Start
# oar = threading.Thread(target=openrestyAutoRestart)
# oar = setDaemon(oar)
# oar.start()
# Panel Restart Start
rps = threading.Thread(target=restartPanelService)
rps = setDaemon(rps)
rps.start()
# # Panel Restart Start
# rps = threading.Thread(target=restartPanelService)
# rps = setDaemon(rps)
# rps.start()
# 面板后台任务
startPanelTask()
+12
View File
@@ -57,6 +57,18 @@ def getTaskList(
start = (page - 1) * size
limit = str(start) + ',' + str(size)
field = 'id,name,type,start,end,status,add_time'
task_list = mw.M('tasks').where('', ()).field(field).limit(limit).order('id asc').select()
return task_list
def getTaskPage(
status: int | None = 1,
page: int | None = 1,
size: int | None = 10,
):
start = (page - 1) * size
limit = str(start) + ',' + str(size)
field = 'id,name,type,start,end,status,add_time'
task_list = mw.M('tasks').where('', ()).field(field).limit(limit).order('id asc').select()
count = mw.M('tasks').where('', ()).count()