File size: 2,165 Bytes
08c964e | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 | # import subprocess, os, sys
# os.chdir('/www/server/panel/')
# sys.path.insert(0, "class/")
# import public
# def get_crontab_data():
# # 实际上您需要从数据库获取数据
# cront = public.M('crontab').select()
# return cront
# def execute_startup_services():
# crontab_data = get_crontab_data() # 获取crontab数据
# for task in crontab_data:
# if task['sType'] == 'startup_services': # 检查任务类型
# commands = task['sBody'].split('\n') # 使用换行符分割多个命令
# for command in commands:
# try:
# print(f"Executing: {command}")
# result = subprocess.run(command, shell=True, capture_output=True, text=True)
# if result.stderr:
# print(f"Command Error Output:\n{result.stderr}")
# else:
# print(f"Command executed successfully: {command}")
# except Exception as e:
# print(f"Error executing command: {e}")
# # 执行示例
# execute_startup_services()
import subprocess, os, sys
# 假设已经改变了工作目录并设置了sys.path
os.chdir('/www/server/panel/')
sys.path.insert(0, "class/")
import public
import crontab
def get_crontab_data():
# 从数据库获取数据
cront = public.M('crontab').select()
return cront
def StartTask(task_id):
# 这里只是示意，你需要根据实际情况来调整
# 假设StartTask已经在public或相关模块中定义
try:
result = public.StartTask({'id': task_id})
print(f"Task {task_id} executed, result: {result}")
except Exception as e:
print(f"Error executing task {task_id}: {e}")
def execute_startup_services():
get = public.dict_obj()
p = crontab.crontab()
crontab_data = get_crontab_data() # 获取crontab数据
for task in crontab_data:
if task['sType'] == 'startup_services': # 检查任务类型
get.id=task['id']
# 直接调用StartTask函数执行任务
p.StartTask(get)
# 执行示例
execute_startup_services()
|