From b76647cdc0673589d3a3eaa7b0c5640445b37b04 Mon Sep 17 00:00:00 2001 From: Mr Chen Date: Fri, 2 Nov 2018 10:18:58 +0800 Subject: [PATCH] u --- task.py | 21 ++++++++++++++------- tmp/panelTask.pl | 1 + 2 files changed, 15 insertions(+), 7 deletions(-) create mode 100644 tmp/panelTask.pl diff --git a/task.py b/task.py index 063fe9a23..0018f23dd 100755 --- a/task.py +++ b/task.py @@ -22,8 +22,14 @@ pre = 0 timeoutCount = 0 isCheck = 0 oldEdate = None -logPath = '/tmp/panelExec.log' -isTask = '/tmp/panelTask.pl' + +logPath = os.getcwd() + '/tmp/panelExec.log' +isTask = os.getcwd() + '/tmp/panelTask.pl' + +if ~os.path.exists(os.getcwd() + "/tmp"): + os.system('mkdir -p ' + os.getcwd() + "/tmp") + os.system("echo '' > " + logPath) + os.system("echo '' > " + isTask) class MyBad(): @@ -97,8 +103,7 @@ def WriteLogs(logMsg): def startTask(): # 任务队列 global isTask - # import time - # import public + print isTask try: while True: try: @@ -108,6 +113,7 @@ def startTask(): "status=?", ('-1',)).setField('status', '0') taskArr = sql.table('tasks').where("status=?", ('0',)).field( 'id,type,execstr').order("id asc").select() + print tasksArr for value in taskArr: start = int(time.time()) if not sql.table('tasks').where("id=?", (value['id'],)).count(): @@ -122,14 +128,15 @@ def startTask(): end = int(time.time()) sql.table('tasks').where("id=?", (value['id'],)).save( 'status,end', ('1', end)) - if(sql.table('tasks').where("status=?", ('0')).count() < 1): - os.system('rm -f ' + isTask) + # if(sql.table('tasks').where("status=?", ('0')).count() < 1): + # os.system('rm -f ' + isTask) except: pass siteEdate() - mainSafe() + # mainSafe() time.sleep(2) except: + print "ff" time.sleep(60) startTask() diff --git a/tmp/panelTask.pl b/tmp/panelTask.pl new file mode 100644 index 000000000..8b1378917 --- /dev/null +++ b/tmp/panelTask.pl @@ -0,0 +1 @@ +