# 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()