Server-py/sri-server-bg02/lib/JobManage.py

from hub import Global, methods

import os

# --- for linux
# save_dir = f'/home/server/logs'

# --- for windows
save_dir = r'C:\temp'  # sri内网测试环境

class JobManage(object):
    """"""

    # --- 接口认证信息 ---
    # username = '500A7062'
    # password = '198797#cjhxbin'

    @classmethod
    def run(cls):
        """启动全部任务"""

        # --- test ---
        # Global.aps.create_job(func=cls.job101, trigger='interval', seconds=3)  # 循环测试
        # Global.aps.create_job(func=cls.job101, trigger='date', run_date='2022-02-23 18:54:00')  # 定时测试
        # Global.aps.create_job(func=cls.job301, trigger='interval', seconds=60)  # 循环测试
        # Global.aps.create_job(func=cls.job20102, trigger='date', run_date='2022-07-28 17:15:30')  # 定时测试

        # --- release ---
        Global.aps.create_job(func=cls.job101, trigger='cron', hour=22)  # 每天晚10点  release
        # Global.aps.create_job(func=cls.job20102, trigger='interval', seconds=600)  # 每10分钟  release
        # Global.aps.create_job(func=cls.job301, trigger='interval', seconds=300)  # 每5分钟  release

    @classmethod
    def end(cls):
        """暂停全部任务"""
        Global.aps.pause_all()

    @staticmethod
    def job101():
        """
        每日22点清理30天之前的日志

        todo 根据UserWorkRecordList.start_at来判断过去7天的数据
        """
        # --- get list ---
        file_path_list = methods.get_file_path_list(save_dir)
        file_name_list = [i.split('/')[-1] for i in file_path_list]
        # methods.debug_log('JobManage44', f"#file_name_list: {file_name_list}")

        # --- test ---
        # for file_name in file_name_list:
        #     file_path = os.path.join(save_dir, file_name)
        #     if methods.is_file(file_path):
        #         methods.remove_file(file_path)

        # --- cut list ---
        # remove_count = 30 * 24  # 按小时
        # for file_name in file_name_list[remove_count:]:
        #     file_path = os.path.join(save_dir, file_name)
        #     if methods.is_file(file_path):
        #         methods.remove_file(file_path)