pull/632/head
Mr Chen 6 months ago
parent 910defe18b
commit ef7b680e37
  1. 2
      panel_task.py
  2. 16
      web/thisdb/tasks.py

@ -99,6 +99,7 @@ def runPanelTask():
run_list = thisdb.getTaskList(status=0) run_list = thisdb.getTaskList(status=0)
for run_task in run_list: for run_task in run_list:
print(run_task)
start = int(time.time()) start = int(time.time())
thisdb.setTaskData(run_task['id'], start=start) thisdb.setTaskData(run_task['id'], start=start)
thisdb.setTaskStatus(run_task['id'], -1) thisdb.setTaskStatus(run_task['id'], -1)
@ -157,7 +158,6 @@ def systemTask():
monitor.instance().run() monitor.instance().run()
time.sleep(5) time.sleep(5)
except Exception as ex: except Exception as ex:
print(mw.getTracebackInfo())
time.sleep(30) time.sleep(30)
systemTask() systemTask()

@ -10,6 +10,8 @@
import core.mw as mw import core.mw as mw
__FIELD = 'id,name,type,start,end,cmd,status,add_time'
def getTaskCount( def getTaskCount(
status: int | None = -1 status: int | None = -1
) -> int: ) -> int:
@ -56,9 +58,7 @@ def getTaskList(
): ):
start = (page - 1) * size start = (page - 1) * size
limit = str(start) + ',' + str(size) limit = str(start) + ',' + str(size)
task_list = mw.M('tasks').where('', ()).field(__FIELD).limit(limit).order('id asc').select()
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 return task_list
def getTaskPage( def getTaskPage(
@ -68,9 +68,7 @@ def getTaskPage(
): ):
start = (page - 1) * size start = (page - 1) * size
limit = str(start) + ',' + str(size) limit = str(start) + ',' + str(size)
task_list = mw.M('tasks').where('', ()).field(__FIELD).limit(limit).order('id asc').select()
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() count = mw.M('tasks').where('', ()).count()
rdata = {} rdata = {}
@ -79,8 +77,7 @@ def getTaskPage(
return rdata return rdata
def getTaskFirstByRun() -> None: def getTaskFirstByRun() -> None:
field = 'id,name,type,start,end,status,add_time' data = mw.M('tasks').where('status=?', (-1,)).field(__FIELD).order('id asc').find()
data = mw.M('tasks').where('status=?', (-1,)).field(field).order('id asc').find()
if item is None: if item is None:
return None return None
return data return data
@ -92,8 +89,7 @@ def getTaskRunList(
start = (page - 1) * size start = (page - 1) * size
limit = str(start) + ',' + str(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 desc').select()
task_list = mw.M('tasks').where('', ()).field(field).limit(limit).order('id desc').select()
count = mw.M('tasks').where('', ()).count() count = mw.M('tasks').where('', ()).count()
rdata = {} rdata = {}

Loading…
Cancel
Save