'commit'

T0_Full.py

@@ -0,0 +1,49 @@
+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}")
+