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.
149 lines
3.6 KiB
149 lines
3.6 KiB
# coding:utf-8
|
|
|
|
import sys
|
|
import io
|
|
import os
|
|
import time
|
|
import json
|
|
|
|
|
|
web_dir = os.getcwd() + "/web"
|
|
if os.path.exists(web_dir):
|
|
sys.path.append(web_dir)
|
|
os.chdir(web_dir)
|
|
|
|
import core.mw as mw
|
|
from utils.crontab import crontab as MwCrontab
|
|
|
|
|
|
|
|
app_debug = False
|
|
if mw.isAppleSystem():
|
|
app_debug = True
|
|
|
|
|
|
def getPluginName():
|
|
return 'rsyncd'
|
|
|
|
|
|
def getPluginDir():
|
|
return mw.getPluginDir() + '/' + getPluginName()
|
|
|
|
|
|
def getServerDir():
|
|
return mw.getServerDir() + '/' + getPluginName()
|
|
|
|
|
|
def getTaskConf():
|
|
conf = getServerDir() + "/task_config.json"
|
|
return conf
|
|
|
|
|
|
def getConfigData():
|
|
conf = getTaskConf()
|
|
if os.path.exists(conf):
|
|
return json.loads(mw.readFile(conf))
|
|
return []
|
|
|
|
|
|
def getConfigTpl():
|
|
tpl = {
|
|
"name": "",
|
|
"task_id": -1,
|
|
}
|
|
return tpl
|
|
|
|
|
|
def createBgTask(data):
|
|
removeBgTask()
|
|
for d in data:
|
|
if d['realtime'] == "false":
|
|
createBgTaskByName(d['name'], d)
|
|
|
|
|
|
def createBgTaskByName(name, args):
|
|
cfg = getConfigTpl()
|
|
_name = "[勿删]同步插件定时任务[" + name + "]"
|
|
res = mw.M("crontab").field("id, name").where("name=?", (_name,)).find()
|
|
if res:
|
|
return True
|
|
|
|
if "task_id" in cfg.keys() and cfg["task_id"] > 0:
|
|
res = mw.M("crontab").field("id, name").where("id=?", (cfg["task_id"],)).find()
|
|
if res and res["id"] == cfg["task_id"]:
|
|
print("计划任务已经存在!")
|
|
return True
|
|
|
|
period = args['period']
|
|
_hour = ''
|
|
_minute = ''
|
|
_where1 = ''
|
|
_type_day = "day"
|
|
if period == 'day':
|
|
_type_day = 'day'
|
|
_hour = args['hour']
|
|
_minute = args['minute']
|
|
elif period == 'minute-n':
|
|
_type_day = 'minute-n'
|
|
_where1 = args['minute-n']
|
|
_minute = ''
|
|
|
|
cmd = '''
|
|
rname=%s
|
|
plugin_path=%s
|
|
logs_file=$plugin_path/send/${rname}/run.log
|
|
''' % (name, getServerDir())
|
|
cmd += 'echo "★【`date +"%Y-%m-%d %H:%M:%S"`】 STSRT" >> $logs_file' + "\n"
|
|
cmd += 'echo ">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>" >> $logs_file' + "\n"
|
|
cmd += 'bash $plugin_path/send/${rname}/cmd >> $logs_file 2>&1' + "\n"
|
|
cmd += 'echo "【`date +"%Y-%m-%d %H:%M:%S"`】 END★" >> $logs_file' + "\n"
|
|
cmd += 'echo "<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<" >> $logs_file' + "\n"
|
|
|
|
params = {
|
|
'name': _name,
|
|
'type': _type_day,
|
|
'week': "",
|
|
'where1': _where1,
|
|
'hour': _hour,
|
|
'minute': _minute,
|
|
'save': "",
|
|
'backup_to': "",
|
|
'stype': "toShell",
|
|
'sname': '',
|
|
'sbody': cmd,
|
|
'url_address': '',
|
|
}
|
|
|
|
task_id = MwCrontab.instance().add(params)
|
|
if task_id > 0:
|
|
cfg["task_id"] = task_id
|
|
cfg["name"] = name
|
|
|
|
_dd = getConfigData()
|
|
_dd.append(cfg)
|
|
mw.writeFile(getTaskConf(), json.dumps(_dd))
|
|
|
|
|
|
def removeBgTask():
|
|
cfg_list = getConfigData()
|
|
for x in range(len(cfg_list)):
|
|
cfg = cfg_list[x]
|
|
if "task_id" in cfg.keys() and cfg["task_id"] > 0:
|
|
res = mw.M("crontab").field("id, name").where("id=?", (cfg["task_id"],)).find()
|
|
if res and res["id"] == cfg["task_id"]:
|
|
data = MwCrontab.instance().delete(cfg["task_id"])
|
|
if data[0]:
|
|
cfg["task_id"] = -1
|
|
cfg_list[x] = cfg
|
|
mw.writeFile(getTaskConf(), '[]')
|
|
return True
|
|
return False
|
|
|
|
|
|
if __name__ == "__main__":
|
|
if len(sys.argv) > 1:
|
|
action = sys.argv[1]
|
|
if action == "remove":
|
|
removeBgTask()
|
|
elif action == "add":
|
|
createBgTask()
|
|
|