import asyncio
import os
import sys
import logging

project_root = os.path.dirname(os.path.abspath(__file__))
if project_root not in sys.path:
    sys.path.append(project_root)

import T1_TeLaiDian
import T2_XinDianTu
import T3_AiTeJiYiChong
import T4_YeLiTe

logger = logging.getLogger("T0_Full")


async def run_all():
    logger.info("=== 开始全流程任务 (四运营商统一抓取) ===")
    try:
        logger.info(">>> 开始：特来电 全流程")
        await T1_TeLaiDian.run_process()
        logger.info(">>> 完成：特来电 全流程")

        logger.info(">>> 开始：新电途 全流程")
        await T2_XinDianTu.run_process()
        logger.info(">>> 完成：新电途 全流程")

        logger.info(">>> 开始：艾特吉易充 全流程")
        await T3_AiTeJiYiChong.run_process()
        logger.info(">>> 完成：艾特吉易充 全流程")

        logger.info(">>> 开始：驿来特 全流程")
        await T4_YeLiTe.run_process()
        logger.info(">>> 完成：驿来特 全流程")

        logger.info("=== 四运营商全流程任务结束 ===")
    except Exception as e:
        logger.exception(f"❌ T0_Full 运行异常: {e}")


if __name__ == "__main__":
    try:
        asyncio.run(run_all())
    except KeyboardInterrupt:
        logger.info("\n🛑 用户手动停止了程序 (Ctrl+C)。")
    except Exception as e:
        logger.exception(f"主程序崩溃: {e}")