50 lines
1.4 KiB
Python
50 lines
1.4 KiB
Python
|
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}")
|
||
|
|
|