# +======================================================================
# | DjangoAdmin 企业数字化开发平台 [ 赋能开发者，助力企业发展 ]
# +----------------------------------------------------------------------
# | Copyright (c) 2021-2026 一米阳光团队 版权所有
# +----------------------------------------------------------------------
# | 开源协议: Apache-2.0
# | 重要声明: 未经书面许可，不得移除或修改本框架相关版权标识。
# +----------------------------------------------------------------------
# | 官方网站: https://www.djangoadmin.cn
# +----------------------------------------------------------------------
# | 研发团队: 一米阳光团队 荣誉出品
# +======================================================================
# | 版权和免责声明:
# | 一、知识产权声明
# | 本团队对该软件框架产品（以下简称“本产品”）拥有完整知识产权，包括但不限于商标权、专利权、
# | 著作权、商业秘密等。前述权利均受中华人民共和国及相关国际法律法规保护。未经本团队书面授权，
# | 任何个人或单位不得基于本产品本身申请任何形式的知识产权。
# | 二、使用限制与禁止条款
# | 您理解并同意，禁止将本产品用于以下任何行为：
# | 1. 任何违反中华人民共和国法律法规的用途；
# | 2. 任何侵害他人合法权益（包括但不限于人身权、财产权、知识产权等）的行为；
# | 3. 任何危害国家安全、公共利益及社会道德风尚的行为。
# | 三、责任豁免
# | 因使用本产品而产生的任何损失或法律纠纷（包括但不限于直接损失、间接损失、附带损失、衍生损失
# | 以及因违约、侵权等引发的责任），本团队均不承担任何法律责任。若因违规使用本产品导致任何第三
# | 方提起索赔或行政机关进行调查，您应独立承担全部责任。
# | 四、违约与法律责任
# | 如发现任何违反本声明的行为，本团队有权：
# | 1. 无条件配合公安机关及其他有权机关的调查取证工作；
# | 2. 依法追究相关方的民事责任，并要求赔偿全部损失；
# | 3. 保留进一步采取刑事控告等法律措施的权利。
# | 五、许可范围说明
# | 1、被授权方应视本产品源代码为核心机密信息，负有最高标准的保密与保管义务。禁止以任何形式（包
# | 括但不限于直接或间接的分享、复制、传播、分发、转售、出租、开源、反向工程、反编译、反汇编或通
# | 过网络服务提供给任何第三方）泄露、披露或处置源代码的全部或部分内容。任何未经授权的复制、使用、
# | 传播行为均构成对本团队知识产权的严重侵权，本团队有权依法追究其全部法律责任，并要求赔偿因此造
# | 成的一切经济损失及商誉损害。
# | 2、本产品仅限于公司或个人在法律允许范围内，用于内部且合规的软件产品研发。具体权利义务以《软件
# | 许可协议》附件为准。
# +======================================================================

"""
定时任务调度器扩展模块
负责初始化和管理 APScheduler 定时任务
"""

import logging
from flask import Flask

logger = logging.getLogger(__name__)


class Scheduler:
    """
    定时任务调度器管理类

    负责调度器的初始化和生命周期管理
    """

    def __init__(self):
        """初始化调度器实例"""
        self._initialized = False

    def init_app(self, app: Flask):
        """
        初始化定时任务调度器

        Args:
            app: Flask 应用实例

        使用示例:
            from extensions.scheduler import scheduler

            def create_app():
                app = Flask(__name__)
                # ... 其他配置
                scheduler.init_app(app)
                return app
        """
        # 避免重复初始化
        if self._initialized:
            logger.warning("定时任务调度器已初始化，跳过重复初始化")
            return

        # ============================================================
        # 在应用上下文中执行初始化
        # ============================================================
        with app.app_context():
            try:
                from src.modules.job.scheduler_service import reload_scheduler

                # 重新加载所有任务
                count = reload_scheduler()

                self._initialized = True

                if count > 0:
                    logger.info(f"定时任务调度器初始化完成，已加载 {count} 个任务")
                else:
                    logger.info("定时任务调度器初始化完成，当前无可用任务")

                # 打印调度器状态（调试用）
                self._log_scheduler_status()

            except Exception as e:
                logger.error(f"定时任务调度器初始化失败: {str(e)}")
                raise

    def _log_scheduler_status(self):
        """打印调度器状态（用于调试）"""
        try:
            from src.modules.job.scheduler_service import scheduler

            if scheduler.running:
                jobs = scheduler.get_jobs()
                if jobs:
                    logger.debug("当前调度器中的任务列表:")
                    for job in jobs:
                        logger.debug(f"  - ID: {job.id}, Name: {job.name}, Next run: {job.next_run_time}")
                else:
                    logger.debug("当前调度器中无任务")
            else:
                logger.warning("调度器未运行")
        except Exception as e:
            logger.error(f"获取调度器状态失败: {str(e)}")

    def shutdown(self):
        """
        关闭定时任务调度器

        在应用退出时调用
        """
        try:
            from src.modules.job.scheduler_service import scheduler

            if scheduler.running:
                scheduler.shutdown()
                logger.info("定时任务调度器已关闭")
        except Exception as e:
            logger.error(f"关闭调度器失败: {str(e)}")

    def reload(self) -> int:
        """
        重新加载所有定时任务

        Returns:
            int: 成功加载的任务数量
        """
        try:
            from src.modules.job.scheduler_service import reload_scheduler
            count = reload_scheduler()
            logger.info(f"重新加载定时任务完成，共加载 {count} 个任务")
            return count
        except Exception as e:
            logger.error(f"重新加载定时任务失败: {str(e)}")
            return 0

    def get_status(self) -> dict:
        """
        获取调度器状态

        Returns:
            dict: 包含调度器运行状态和任务列表
        """
        try:
            from src.modules.job.scheduler_service import scheduler

            jobs = scheduler.get_jobs()
            job_list = []

            for job in jobs:
                job_list.append({
                    'id': job.id,
                    'name': job.name,
                    'next_run_time': str(job.next_run_time) if job.next_run_time else None,
                    'trigger': str(job.trigger)
                })

            return {
                'initialized': self._initialized,
                'running': scheduler.running,
                'job_count': len(job_list),
                'jobs': job_list
            }
        except Exception as e:
            logger.error(f"获取调度器状态失败: {str(e)}")
            return {
                'initialized': self._initialized,
                'running': False,
                'job_count': 0,
                'jobs': [],
                'error': str(e)
            }


# ============================================================
# 创建全局调度器单例实例
# ============================================================
scheduler = Scheduler()