mirror of https://github.com/midoks/mdserver-web
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
88 lines
2.6 KiB
88 lines
2.6 KiB
# coding: utf-8
|
|
|
|
import psutil
|
|
import time
|
|
import os
|
|
import sys
|
|
import mw
|
|
import re
|
|
import json
|
|
import pwd
|
|
|
|
|
|
from flask import request
|
|
|
|
|
|
class task_api:
|
|
|
|
def __init__(self):
|
|
pass
|
|
|
|
def countApi(self):
|
|
c = mw.M('tasks').where("status!=?", ('1',)).count()
|
|
return str(c)
|
|
|
|
def listApi(self):
|
|
|
|
p = request.form.get('p', '1')
|
|
limit = request.form.get('limit', '10').strip()
|
|
search = request.form.get('search', '').strip()
|
|
|
|
start = (int(p) - 1) * int(limit)
|
|
limit_str = str(start) + ',' + str(limit)
|
|
|
|
_list = mw.M('tasks').where('', ()).field(
|
|
'id,name,type,status,addtime,start,end').limit(limit_str).order('id desc').select()
|
|
_ret = {}
|
|
_ret['data'] = _list
|
|
|
|
count = mw.M('tasks').where('', ()).count()
|
|
_page = {}
|
|
_page['count'] = count
|
|
_page['tojs'] = 'remind'
|
|
_page['p'] = p
|
|
|
|
# return data
|
|
_ret['count'] = count
|
|
_ret['page'] = mw.getPage(_page)
|
|
return mw.getJson(_ret)
|
|
|
|
def getExecLogApi(self):
|
|
file = os.getcwd() + "/tmp/panelExec.log"
|
|
v = mw.getLastLine(file, 100)
|
|
return v
|
|
|
|
def getTaskSpeedApi(self):
|
|
tempFile = os.getcwd() + '/tmp/panelExec.log'
|
|
freshFile = os.getcwd() + '/tmp/panelFresh'
|
|
|
|
find = mw.M('tasks').where('status=? OR status=?',
|
|
('-1', '0')).field('id,type,name,execstr').find()
|
|
if not len(find):
|
|
return mw.returnJson(False, '当前没有任务队列在执行-2!')
|
|
|
|
isTask = os.getcwd() + '/tmp/panelTask.pl'
|
|
mw.writeFile(isTask, 'True')
|
|
|
|
echoMsg = {}
|
|
echoMsg['name'] = find['name']
|
|
echoMsg['execstr'] = find['execstr']
|
|
if find['type'] == 'download':
|
|
import json
|
|
try:
|
|
tmp = mw.readFile(tempFile)
|
|
if len(tmp) < 10:
|
|
return mw.returnJson(False, '当前没有任务队列在执行-3!')
|
|
echoMsg['msg'] = json.loads(tmp)
|
|
echoMsg['isDownload'] = True
|
|
except:
|
|
mw.M('tasks').where(
|
|
"id=?", (find['id'],)).save('status', ('0',))
|
|
return mw.returnJson(False, '当前没有任务队列在执行-4!')
|
|
else:
|
|
echoMsg['msg'] = mw.getLastLine(tempFile, 10)
|
|
echoMsg['isDownload'] = False
|
|
|
|
echoMsg['task'] = mw.M('tasks').where("status!=?", ('1',)).field(
|
|
'id,status,name,type').order("id asc").select()
|
|
return mw.getJson(echoMsg)
|
|
|