Update main.py

main.py

@@ -1,48 +1,53 @@
-from fastapi import FastAPI
-import subprocess
-import asyncio
-from contextlib import asynccontextmanager
-
-# 如果两个机器人进同一个房间，就填两个一样的；如果进不同房间，就改数字
-ROOMS = ["4442", "4442"] 
-
-bots = [None, None]
-
-async def run_bot(index, room_id):
-    global bots
-    while True:
-        print(f"========== 正在启动机器人 {index + 1} (房间 {room_id}) ==========")
-        # 启动对应的机器人进程，传入房间号
-        bots[index] = subprocess.Popen(["python", "core_for_test_3.py", room_id])
-        
-        # 每秒检查一次该进程是否退出（例如打完一局执行了 exit）
-        while bots[index].poll() is None:
-            await asyncio.sleep(1)
-            
-        print(f"========== 机器人 {index + 1} 已退出，5秒后自动重连 ==========")
-        await asyncio.sleep(5)
-
-@asynccontextmanager
-async def lifespan(app: FastAPI):
-    # 服务启动时，创建两个独立的后台任务运行机器人
-    tasks = []
-    for i, room in enumerate(ROOMS):
-        tasks.append(asyncio.create_task(run_bot(i, room)))
-    yield
-    # 容器关闭时，清理这两个进程
-    for bot in bots:
-        if bot:
-            bot.terminate()
-    for t in tasks:
-        t.cancel()
-
-app = FastAPI(lifespan=lifespan)
-
-# 提供给外部服务定时访问的保活接口
-@app.get("/")
-def health_check():
-    status = []
-    for i, bot in enumerate(bots):
-        state = "运行中" if bot and bot.poll() is None else "重启中"
-        status.append(f"Bot {i+1}: {state}")
+from fastapi import FastAPI
+import subprocess
+import asyncio
+from contextlib import asynccontextmanager
+
+# ================= 关键配置 =================
+# 在这里配置两个机器人的房间号和对应的独立账号 ID！
+# 注意：第二个账号必须换成您拥有的另一个有效天凤 ID。
+BOT_CONFIGS = [
+    {"room": "4441", "id": "ID215416DE-EJPGCHM8"},  
+    {"room": "4441", "id": "ID27101B05-nRUZ8Xgg"} 
+] 
+# ============================================
+
+bots = [None, None]
+
+async def run_bot(index, config):
+    global bots
+    while True:
+        room_id = config["room"]
+        bot_id = config["id"]
+        print(f"========== 正在启动机器人 {index + 1} (房间 {room_id} | 账号 {bot_id}) ==========")
+        
+        # 启动脚本，不仅传房间号，还把专属 ID 传进去
+        bots[index] = subprocess.Popen(["python", "-u", "core_for_test_3.py", room_id, bot_id])
+        
+        while bots[index].poll() is None:
+            await asyncio.sleep(1)
+            
+        print(f"========== 机器人 {index + 1} 已退出，5秒后自动重连 ==========")
+        await asyncio.sleep(5)
+
+@asynccontextmanager
+async def lifespan(app: FastAPI):
+    tasks = []
+    for i, config in enumerate(BOT_CONFIGS):
+        tasks.append(asyncio.create_task(run_bot(i, config)))
+    yield
+    for bot in bots:
+        if bot:
+            bot.terminate()
+    for t in tasks:
+        t.cancel()
+
+app = FastAPI(lifespan=lifespan)
+
+@app.get("/")
+def health_check():
+    status = []
+    for i, bot in enumerate(bots):
+        state = "运行中" if bot and bot.poll() is None else "重启中"
+        status.append(f"Bot {i+1}: {state}")
     return {"status": "alive", "bots": status}