Update app.py

app.py

@@ -16,6 +16,7 @@ import traceback
 import io
 import time
 import threading
+import socket
 from PIL import Image, ImageDraw, ImageFont
 import gradio as gr
 
@@ -29,6 +30,35 @@ logging.basicConfig(
 )
 logger = logging.getLogger("BK_GTA_ARCHITECT_TITAN")
 
+# ==============================================================================
+# 0.5 DNS 修复：注入可靠 DNS 服务器
+# ==============================================================================
+def fix_dns():
+    """
+    HuggingFace Spaces 容器的默认 DNS 解析器不稳定。
+    注入 Google (8.8.8.8) 和 Cloudflare (1.1.1.1) DNS 作为备用。
+    """
+    dns_entries = "\nnameserver 8.8.8.8\nnameserver 1.1.1.1\n"
+    try:
+        # 先读取当前内容，避免重复添加
+        with open('/etc/resolv.conf', 'r') as f:
+            current = f.read()
+        if '8.8.8.8' not in current:
+            with open('/etc/resolv.conf', 'a') as f:
+                f.write(dns_entries)
+            logger.info("✅ [DNS] Injected Google & Cloudflare DNS servers.")
+        else:
+            logger.info("✅ [DNS] Reliable DNS servers already present.")
+    except PermissionError:
+        logger.warning("⚠️ [DNS] Cannot write /etc/resolv.conf (read-only). Trying res_init...")
+        # 备用方案：通过环境变量影响 DNS
+        os.environ['RES_OPTIONS'] = 'timeout:3 attempts:5'
+    except Exception as e:
+        logger.warning(f"⚠️ [DNS] Fix attempt failed: {e}")
+
+# 启动时立即执行 DNS 修复
+fix_dns()
+
 # ==============================================================================
 # 1. 物理层：Gradio 哨兵与探针 (Gradio Sentinel)
 # ==============================================================================
@@ -46,7 +76,7 @@ def get_status():
     return {
         "status": "BK-GTA-TITAN-ACTIVE",
         "logic_integrity": "100%",
-        "engine_version": "V62.9-Gradio-Final",
+        "engine_version": "V63.0-DNS-Fix",
         "discord_bot": bot_status,
         "latency": latency,
         "server_time": now,
@@ -72,7 +102,12 @@ if not KEY_POOL:
 intents = discord.Intents.default()
 intents.message_content = True
 intents.members = True
-bot = commands.Bot(command_prefix='!', intents=intents)
+
+def create_bot():
+    """创建 Bot 实例的工厂函数"""
+    return commands.Bot(command_prefix='!', intents=intents)
+
+bot = create_bot()
 
 audit_lock = asyncio.Lock()
 DB_PATH = '/data/bk_gta_v62_unified.json' if os.path.exists('/data') else 'bk_gta_v62_unified.json'
@@ -102,7 +137,7 @@ class BKEngine:
 
     def _init_schema(self):
         return {
-            "version": "62.9-Titan",
+            "version": "63.0-Titan",
             "users": {},
             "factions": {
                 "BULLS": {"score": 0, "emoji": "🐂", "wins": 0},
@@ -224,407 +259,387 @@ async def call_gemini(prompt, attachment=None):
     return "ERROR: ALL_KEYS_EXHAUSTED"
 
 # ==============================================================================
-# 5. 模块一：全网天梯 (Rank & Stats)
+# 5. 注册所有命令的函数 (Command Registration)
 # ==============================================================================
-@bot.command()
-async def profile(ctx, member: discord.Member = None):
-    t = member or ctx.author
-    u = bk_engine.get_user(t.id)
-    elo = u['elo']
-
-    if elo < 1300: rank, color = "Iron 学徒 🗑️", 0x717d7e
-    elif elo < 1500: rank, color = "Bronze 资深 🥉", 0xcd7f32
-    elif elo < 1800: rank, color = "Silver 精英 🥈", 0xbdc3c7
-    elif elo < 2100: rank, color = "Gold 专家 🥇", 0xf1c40f
-    elif elo < 2500: rank, color = "Platinum 大师 💎", 0x3498db
-    else: rank, color = "Grandmaster 传奇 👑", 0x9b59b6
-
-    emb = discord.Embed(title=f"📊 Quant Profile: {t.display_name}", color=color)
-    emb.add_field(name="Rating (ELO)", value=f"**{elo}** ({rank})", inline=True)
-    emb.add_field(name="Assets", value=f"💰 **{u['points']}**", inline=True)
-
-    f_info = u['faction'] or "Free Agent"
-    f_emoji = bk_engine.data["factions"].get(f_info, {}).get("emoji", "🌐")
-    emb.add_field(name="Faction", value=f"{f_emoji} {f_info}", inline=True)
-
-    stats = (
-        f"Total Audits: {u['audits_count']}\n"
-        f"Peak Score: {u['highest_score']:.1f}\n"
-        f"Max MDD: {u.get('mdd_record',0):.2f}%"
-    )
-    emb.add_field(name="Institutional Metrics", value=f"```yaml\n{stats}\n```", inline=False)
-
-    if target_avatar := t.avatar:
-        emb.set_thumbnail(url=target_avatar.url)
-    emb.set_footer(text=f"Node: HuggingFace Titan | Session: {SESSION_ID}")
-    await ctx.send(embed=emb)
-
-@bot.command()
-async def leaderboard(ctx):
-    all_users = []
-    for uid, d in bk_engine.data["users"].items():
-        all_users.append({"id": uid, "elo": d["elo"], "score": d["highest_score"]})
-
-    top = sorted(all_users, key=lambda x: x["elo"], reverse=True)[:10]
-    desc = ""
-    for idx, u in enumerate(top):
-        icon = ["🥇","🥈","🥉"][idx] if idx < 3 else f"{idx+1}."
-        desc += f"{icon} <@{u['id']}> : **{u['elo']}** (Peak: {u['score']:.1f})\n"
-
-    emb = discord.Embed(title="🏆 BK-GTA Institutional Leaderboard", description=desc or "No data.", color=0xf1c40f)
-
-    f_info = ""
-    for k, v in bk_engine.data["factions"].items():
-        f_info += f"{v['emoji']} {k}: {v['score']} pts  "
-    if f_info:
-        emb.add_field(name="⚔️ Faction War", value=f_info, inline=False)
-
-    await ctx.send(embed=emb)
+def register_commands(target_bot):
+    """将所有命令和事件注册到指定的 bot 实例上"""
+
+    # --- 清除已有命令,避免重复注册 ---
+    target_bot.remove_command('help')
+
+    @target_bot.command()
+    async def profile(ctx, member: discord.Member = None):
+        t = member or ctx.author
+        u = bk_engine.get_user(t.id)
+        elo = u['elo']
+
+        if elo < 1300: rank, color = "Iron 学徒 🗑️", 0x717d7e
+        elif elo < 1500: rank, color = "Bronze 资深 🥉", 0xcd7f32
+        elif elo < 1800: rank, color = "Silver 精英 🥈", 0xbdc3c7
+        elif elo < 2100: rank, color = "Gold 专家 🥇", 0xf1c40f
+        elif elo < 2500: rank, color = "Platinum 大师 💎", 0x3498db
+        else: rank, color = "Grandmaster 传奇 👑", 0x9b59b6
+
+        emb = discord.Embed(title=f"📊 Quant Profile: {t.display_name}", color=color)
+        emb.add_field(name="Rating (ELO)", value=f"**{elo}** ({rank})", inline=True)
+        emb.add_field(name="Assets", value=f"💰 **{u['points']}**", inline=True)
+
+        f_info = u['faction'] or "Free Agent"
+        f_emoji = bk_engine.data["factions"].get(f_info, {}).get("emoji", "🌐")
+        emb.add_field(name="Faction", value=f"{f_emoji} {f_info}", inline=True)
+
+        stats = (
+            f"Total Audits: {u['audits_count']}\n"
+            f"Peak Score: {u['highest_score']:.1f}\n"
+            f"Max MDD: {u.get('mdd_record',0):.2f}%"
+        )
+        emb.add_field(name="Institutional Metrics", value=f"```yaml\n{stats}\n```", inline=False)
 
-# ==============================================================================
-# 6. 模块二：宏观情报 (Macro Analysis)
-# ==============================================================================
-@bot.command()
-async def news(ctx):
-    if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传情报截图。")
-    m = await ctx.send("📡 **[Sentinel] Analyzing Macro Pulse...**")
-
-    prompt = (
-        "你是一名顶级对冲基金策略师。请解析截图内容：\n"
-        "1. 评分 (SCORE): -10 (极大利空) 到 +10 (极大利多)。\n"
-        "2. 总结 (SUMMARY): 30字内概括核心变量。\n"
-        "3. 解读 (TAKE): 机构视角的隐含逻辑。\n"
-        "格式必须为：\nSCORE: [v]\nSUMMARY: [v]\nTAKE: [v]"
-    )
-    res = await call_gemini(prompt, ctx.message.attachments[0])
-
-    score = safe_extract_float(res, "SCORE")
-    summary = safe_extract_text(res, "SUMMARY", "TAKE")
-    take = safe_extract_text(res, "TAKE")
-
-    color = 0x2ecc71 if score > 0 else 0xe74c3c if score < 0 else 0xbdc3c7
-    emb = discord.Embed(title="📰 Macro Intelligence Analysis", color=color)
-    emb.add_field(name="Sentiment Score", value=f"**{score:+.1f} / 10**", inline=True)
-    emb.add_field(name="Core Catalyst", value=summary, inline=False)
-    emb.add_field(name="Institutional View", value=f"```\n{take}\n```", inline=False)
-
-    await m.delete()
-    await ctx.send(embed=emb)
+        if target_avatar := t.avatar:
+            emb.set_thumbnail(url=target_avatar.url)
+        emb.set_footer(text=f"Node: HuggingFace Titan | Session: {SESSION_ID}")
+        await ctx.send(embed=emb)
 
-# ==============================================================================
-# 7. 模块三：量化审计 (Institutional Audit)
-# ==============================================================================
-@bot.command()
-async def evaluate(ctx):
-    if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传回测或结算截图。")
+    @target_bot.command()
+    async def leaderboard(ctx):
+        all_users = []
+        for uid, d in bk_engine.data["users"].items():
+            all_users.append({"id": uid, "elo": d["elo"], "score": d["highest_score"]})
+
+        top = sorted(all_users, key=lambda x: x["elo"], reverse=True)[:10]
+        desc = ""
+        for idx, u in enumerate(top):
+            icon = ["🥇","🥈","🥉"][idx] if idx < 3 else f"{idx+1}."
+            desc += f"{icon} <@{u['id']}> : **{u['elo']}** (Peak: {u['score']:.1f})\n"
+
+        emb = discord.Embed(title="🏆 BK-GTA Institutional Leaderboard", description=desc or "No data.", color=0xf1c40f)
+        f_info = ""
+        for k, v in bk_engine.data["factions"].items():
+            f_info += f"{v['emoji']} {k}: {v['score']} pts  "
+        if f_info:
+            emb.add_field(name="⚔️ Faction War", value=f_info, inline=False)
+        await ctx.send(embed=emb)
 
-    if audit_lock.locked():
-        return await ctx.send("⚠️ **[System Busy]** 正在处理另一项审计，请稍后。")
+    @target_bot.command()
+    async def news(ctx):
+        if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传情报截图。")
+        m = await ctx.send("📡 **[Sentinel] Analyzing Macro Pulse...**")
 
-    async with audit_lock:
-        m = await ctx.send("🛡️ **[Audit Engine] 启动深度扫描... (锁闭模式)**")
         prompt = (
-            "你是一名顶级量化风险官。请提取并审计以下指标：\n"
-            "RET: 收益率, MDD: 最大回撤, PF: 盈利因子, SHARPE: 夏普比率, TRADES: 总笔数, S_BASE: 基础评分(0-100)。\n"
-            "若 MDD > 35% 或交易笔数 < 10，则 VIOLATION 为 TRUE。\n"
-            "H_ZH: 中文核心优势或致命风险概括。\n"
-            "格式：\nRET: [v]\nMDD: [v]\nPF: [v]\nSHARPE: [v]\nTRADES: [v]\nS_BASE: [v]\nVIOLATION: [TRUE/FALSE]\nH_ZH: [v]"
+            "你是一名顶级对冲基金策略师。请解析截图内容：\n"
+            "1. 评分 (SCORE): -10 (极大利空) 到 +10 (极大利多)。\n"
+            "2. 总结 (SUMMARY): 30字内概括核心变量。\n"
+            "3. 解读 (TAKE): 机构视角的隐含逻辑。\n"
+            "格式必须为：\nSCORE: [v]\nSUMMARY: [v]\nTAKE: [v]"
         )
-
         res = await call_gemini(prompt, ctx.message.attachments[0])
 
-        if "ERROR" in res:
-            await m.delete()
-            return await ctx.send("🔴 [Audit Crash] 引擎请求失败。")
-
-        ret = safe_extract_float(res, "RET")
-        mdd = safe_extract_float(res, "MDD")
-        sharpe = safe_extract_float(res, "SHARPE")
-        trades = int(safe_extract_float(res, "TRADES"))
-        s_base = safe_extract_float(res, "S_BASE")
-        violation = "TRUE" in res.upper()
-
-        if violation or mdd > 35.0:
-            s_final = 0.0
-            status = "❌ REJECTED (High Risk)"
-            color = 0xe74c3c
-        else:
-            weight_sample = math.log10(max(trades, 1)) / 1.5
-            weight_risk = (sharpe / 2.0) if sharpe > 0 else 0.5
-            s_final = min(max(s_base * weight_sample * weight_risk, 0.0), 100.0)
-            status = "✅ AUDIT CLEARED"
-            color = 0x2ecc71
-
-        bk_engine.update_audit(ctx.author.id, s_final, mdd, sharpe)
-        highlights = safe_extract_text(res, "H_ZH")
-
-        emb = discord.Embed(title="🛡️ Quantitative Audit Report", color=color)
-        emb.add_field(name="Verdict", value=f"**{status}**", inline=False)
-        metrics = f"Return: {ret}% | MDD: {mdd}%\nSharpe: {sharpe} | Trades: {trades}"
-        emb.add_field(name="Key Metrics", value=f"```\n{metrics}\n```", inline=False)
-        emb.add_field(name="Logic Score", value=f"**{s_final:.2f} / 100**", inline=True)
-        emb.add_field(name="Highlights", value=highlights, inline=False)
+        score = safe_extract_float(res, "SCORE")
+        summary = safe_extract_text(res, "SUMMARY", "TAKE")
+        take = safe_extract_text(res, "TAKE")
+
+        color = 0x2ecc71 if score > 0 else 0xe74c3c if score < 0 else 0xbdc3c7
+        emb = discord.Embed(title="📰 Macro Intelligence Analysis", color=color)
+        emb.add_field(name="Sentiment Score", value=f"**{score:+.1f} / 10**", inline=True)
+        emb.add_field(name="Core Catalyst", value=summary, inline=False)
+        emb.add_field(name="Institutional View", value=f"```\n{take}\n```", inline=False)
 
         await m.delete()
         await ctx.send(embed=emb)
 
-# ==============================================================================
-# 8. 模块四：博弈盘口 (Institutional Betting)
-# ==============================================================================
-@bot.command()
-@commands.has_permissions(administrator=True)
-async def open_bet(ctx, *, topic):
-    bid = str(random.randint(100, 999))
-    bk_engine.active_bets[bid] = {
-        "topic": topic, "up": 0, "down": 0,
-        "u_up": {}, "u_down": {}, "status": "OPEN",
-        "time": str(datetime.datetime.now())
-    }
-    await ctx.send(f"🎰 **[Bet-ID:{bid}]** 新博弈盘口已开启！\n主题：**{topic}**\n输入 `!bet {bid} UP/DOWN [金额]` 参与。")
-
-@bot.command()
-async def bet(ctx, bid: str, side: str, amt: int):
-    if bid not in bk_engine.active_bets or bk_engine.active_bets[bid]["status"] != "OPEN":
-        return await ctx.send("❌ 盘口不存在或已关闭。")
-
-    u = bk_engine.get_user(ctx.author.id)
-    if u["points"] < amt or amt <= 0:
-        return await ctx.send("❌ 资产点数不足。")
-
-    side = side.upper()
-    if side not in ["UP", "DOWN"]: return await ctx.send("❌ 必须选择 UP 或 DOWN。")
-
-    u["points"] -= amt
-    b = bk_engine.active_bets[bid]
-    pool = "u_up" if side == "UP" else "u_down"
-    b[side.lower()] += amt
-    b[pool][str(ctx.author.id)] = b[pool].get(str(ctx.author.id), 0) + amt
-
-    bk_engine.save_db()
-    await ctx.send(f"✅ 已确认：{ctx.author.name} 向 {side} 注入 {amt} 点资产。")
-
-@bot.command()
-@commands.has_permissions(administrator=True)
-async def settle_bet(ctx, bid: str, winner: str):
-    if bid not in bk_engine.active_bets: return
-    b = bk_engine.active_bets[bid]
-    winner = winner.upper()
-
-    win_pool = b["u_up"] if winner == "UP" else b["u_down"]
-    total_w = b["up"] if winner == "UP" else b["down"]
-    total_l = b["down"] if winner == "UP" else b["up"]
-
-    if total_w > 0:
-        for uid, amt in win_pool.items():
-            profit = (amt / total_w) * total_l
-            bk_engine.get_user(int(uid))["points"] += int(amt + profit)
-
-    b["status"] = "SETTLED"
-    bk_engine.save_db()
-    await ctx.send(f"🏁 盘口 {bid} 已结算！胜利方：**{winner}**。资产已自动划转。")
+    @target_bot.command()
+    async def evaluate(ctx):
+        if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传回测或结算截图。")
+
+        if audit_lock.locked():
+            return await ctx.send("⚠️ **[System Busy]** 正在处理另一项审计，请稍后。")
+
+        async with audit_lock:
+            m = await ctx.send("🛡️ **[Audit Engine] 启动深度扫描... (锁闭模式)**")
+            prompt = (
+                "你是一名顶级量化风险官。请提取并审计以下指标：\n"
+                "RET: 收益率, MDD: 最大回撤, PF: 盈利因子, SHARPE: 夏普比率, TRADES: 总笔数, S_BASE: 基础评分(0-100)。\n"
+                "若 MDD > 35% 或交易笔数 < 10，则 VIOLATION 为 TRUE。\n"
+                "H_ZH: 中文核心优势或致命风险概括。\n"
+                "格式：\nRET: [v]\nMDD: [v]\nPF: [v]\nSHARPE: [v]\nTRADES: [v]\nS_BASE: [v]\nVIOLATION: [TRUE/FALSE]\nH_ZH: [v]"
+            )
 
-# ==============================================================================
-# 9. 模块五：PVP 竞技场 (Duel Arena)
-# ==============================================================================
-@bot.command()
-async def challenge(ctx, member: discord.Member):
-    if member.id == ctx.author.id: return
-    did = f"D-{random.randint(1000, 9999)}"
-    bk_engine.pending_challenges[member.id] = {"challenger": ctx.author.id, "id": did}
-    await ctx.send(f"⚔️ {ctx.author.name} 向 {member.mention} 发起挑战！\nID: `{did}`. 输入 `!accept` 接受。")
-
-@bot.command()
-async def accept(ctx):
-    if ctx.author.id not in bk_engine.pending_challenges:
-        return await ctx.send("❌ 没有待处理的决斗请求。")
-
-    req = bk_engine.pending_challenges.pop(ctx.author.id)
-    did = req["id"]
-    bk_engine.active_duels[did] = {
-        "p1": req["challenger"], "p2": ctx.author.id,
-        "s1": None, "s2": None, "t": str(datetime.datetime.now())
-    }
-    await ctx.send(f"🔥 **竞技场锁定！** 决斗 ID: `{did}`\n请双方通过 `!duel_submit {did}` 提交审计截图。")
+            res = await call_gemini(prompt, ctx.message.attachments[0])
+
+            if "ERROR" in res:
+                await m.delete()
+                return await ctx.send("🔴 [Audit Crash] 引擎请求失败。")
+
+            ret = safe_extract_float(res, "RET")
+            mdd = safe_extract_float(res, "MDD")
+            sharpe = safe_extract_float(res, "SHARPE")
+            trades = int(safe_extract_float(res, "TRADES"))
+            s_base = safe_extract_float(res, "S_BASE")
+            violation = "TRUE" in res.upper()
+
+            if violation or mdd > 35.0:
+                s_final = 0.0
+                status = "❌ REJECTED (High Risk)"
+                color = 0xe74c3c
+            else:
+                weight_sample = math.log10(max(trades, 1)) / 1.5
+                weight_risk = (sharpe / 2.0) if sharpe > 0 else 0.5
+                s_final = min(max(s_base * weight_sample * weight_risk, 0.0), 100.0)
+                status = "✅ AUDIT CLEARED"
+                color = 0x2ecc71
+
+            bk_engine.update_audit(ctx.author.id, s_final, mdd, sharpe)
+            highlights = safe_extract_text(res, "H_ZH")
+
+            emb = discord.Embed(title="🛡️ Quantitative Audit Report", color=color)
+            emb.add_field(name="Verdict", value=f"**{status}**", inline=False)
+            metrics = f"Return: {ret}% | MDD: {mdd}%\nSharpe: {sharpe} | Trades: {trades}"
+            emb.add_field(name="Key Metrics", value=f"```\n{metrics}\n```", inline=False)
+            emb.add_field(name="Logic Score", value=f"**{s_final:.2f} / 100**", inline=True)
+            emb.add_field(name="Highlights", value=highlights, inline=False)
 
-@bot.command()
-async def duel_submit(ctx, did: str):
-    if did not in bk_engine.active_duels: return
-    if not ctx.message.attachments: return
+            await m.delete()
+            await ctx.send(embed=emb)
+
+    @target_bot.command()
+    @commands.has_permissions(administrator=True)
+    async def open_bet(ctx, *, topic):
+        bid = str(random.randint(100, 999))
+        bk_engine.active_bets[bid] = {
+            "topic": topic, "up": 0, "down": 0,
+            "u_up": {}, "u_down": {}, "status": "OPEN",
+            "time": str(datetime.datetime.now())
+        }
+        await ctx.send(f"🎰 **[Bet-ID:{bid}]** 新博弈盘口已开启！\n���题：**{topic}**\n输入 `!bet {bid} UP/DOWN [金额]` 参与。")
+
+    @target_bot.command()
+    async def bet(ctx, bid: str, side: str, amt: int):
+        if bid not in bk_engine.active_bets or bk_engine.active_bets[bid]["status"] != "OPEN":
+            return await ctx.send("❌ 盘口不存在或已关闭。")
+
+        u = bk_engine.get_user(ctx.author.id)
+        if u["points"] < amt or amt <= 0:
+            return await ctx.send("❌ 资产点数不足。")
+
+        side = side.upper()
+        if side not in ["UP", "DOWN"]: return await ctx.send("❌ 必须选择 UP 或 DOWN。")
+
+        u["points"] -= amt
+        b = bk_engine.active_bets[bid]
+        pool = "u_up" if side == "UP" else "u_down"
+        b[side.lower()] += amt
+        b[pool][str(ctx.author.id)] = b[pool].get(str(ctx.author.id), 0) + amt
+
+        bk_engine.save_db()
+        await ctx.send(f"✅ 已确认：{ctx.author.name} 向 {side} 注入 {amt} 点资产。")
+
+    @target_bot.command()
+    @commands.has_permissions(administrator=True)
+    async def settle_bet(ctx, bid: str, winner: str):
+        if bid not in bk_engine.active_bets: return
+        b = bk_engine.active_bets[bid]
+        winner = winner.upper()
+
+        win_pool = b["u_up"] if winner == "UP" else b["u_down"]
+        total_w = b["up"] if winner == "UP" else b["down"]
+        total_l = b["down"] if winner == "UP" else b["up"]
+
+        if total_w > 0:
+            for uid, amt in win_pool.items():
+                profit = (amt / total_w) * total_l
+                bk_engine.get_user(int(uid))["points"] += int(amt + profit)
+
+        b["status"] = "SETTLED"
+        bk_engine.save_db()
+        await ctx.send(f"🏁 盘口 {bid} 已结算！胜利方：**{winner}**。资产已自动划转。")
+
+    @target_bot.command()
+    async def challenge(ctx, member: discord.Member):
+        if member.id == ctx.author.id: return
+        did = f"D-{random.randint(1000, 9999)}"
+        bk_engine.pending_challenges[member.id] = {"challenger": ctx.author.id, "id": did}
+        await ctx.send(f"⚔️ {ctx.author.name} 向 {member.mention} 发起挑战！\nID: `{did}`. 输入 `!accept` 接受。")
+
+    @target_bot.command()
+    async def accept(ctx):
+        if ctx.author.id not in bk_engine.pending_challenges:
+            return await ctx.send("❌ 没有待处理的决斗请求。")
+
+        req = bk_engine.pending_challenges.pop(ctx.author.id)
+        did = req["id"]
+        bk_engine.active_duels[did] = {
+            "p1": req["challenger"], "p2": ctx.author.id,
+            "s1": None, "s2": None, "t": str(datetime.datetime.now())
+        }
+        await ctx.send(f"🔥 **竞技场锁定！** 决斗 ID: `{did}`\n请双方通过 `!duel_submit {did}` 提交审计截图。")
+
+    @target_bot.command()
+    async def duel_submit(ctx, did: str):
+        if did not in bk_engine.active_duels: return
+        if not ctx.message.attachments: return
+
+        duel = bk_engine.active_duels[did]
+        if ctx.author.id not in [duel["p1"], duel["p2"]]: return
+
+        m = await ctx.send("🔍 正在审计决斗数据...")
+        res = await call_gemini("Extract SCORE:[0-100]. Format: SCORE:[v]", ctx.message.attachments[0])
+        score = safe_extract_float(res, "SCORE")
+
+        if ctx.author.id == duel["p1"]: duel["s1"] = score
+        else: duel["s2"] = score
+
+        if duel["s1"] is not None and duel["s2"] is not None:
+            p1, p2 = duel["p1"], duel["p2"]
+            s1, s2 = duel["s1"], duel["s2"]
+            wid, lid = (p1, p2) if s1 > s2 else (p2, p1)
+            w_elo, l_elo, streak = bk_engine.update_elo(wid, lid)
+
+            emb = discord.Embed(title="🏆 Duel Arena Verdict", color=0xf1c40f)
+            emb.add_field(name="Winner", value=f"<@{wid}>\nScore: {max(s1,s2)}\nELO: {w_elo}", inline=True)
+            emb.add_field(name="Loser", value=f"<@{lid}>\nScore: {min(s1,s2)}\nELO: {l_elo}", inline=True)
+            emb.set_footer(text=f"Win Streak: {streak} | Duel ID: {did}")
+            await ctx.send(embed=emb)
+            del bk_engine.active_duels[did]
+        else:
+            await ctx.send(f"✅ 交易员 <@{ctx.author.id}> 分数已锁定 ({score})。等待对手提交。")
+        await m.delete()
 
-    duel = bk_engine.active_duels[did]
-    if ctx.author.id not in [duel["p1"], duel["p2"]]: return
+    @target_bot.command()
+    async def viral_audit(ctx):
+        if not ctx.message.attachments: return
+        m = await ctx.send("🎨 **[GPU-Node] 正在渲染视觉海报...**")
 
-    m = await ctx.send("🔍 正在审计决斗数据...")
-    res = await call_gemini("Extract SCORE:[0-100]. Format: SCORE:[v]", ctx.message.attachments[0])
-    score = safe_extract_float(res, "SCORE")
+        p = "Extract RET: [v] and SHARPE: [v]. Format: RET: [v] SHARPE: [v]"
+        res = await call_gemini(p, ctx.message.attachments[0])
+        ret, sharpe = safe_extract_float(res, "RET"), safe_extract_float(res, "SHARPE")
 
-    if ctx.author.id == duel["p1"]: duel["s1"] = score
-    else: duel["s2"] = score
+        try:
+            W, H = 600, 800
+            base = Image.new('RGB', (W, H), (18, 20, 30))
+            draw = ImageDraw.Draw(base)
+
+            for i in range(0, W, 40): draw.line([(i, 0), (i, H)], fill=(30, 35, 45), width=1)
+            for j in range(0, H, 40): draw.line([(0, j), (W, j)], fill=(30, 35, 45), width=1)
+
+            draw.rectangle([10, 10, 590, 790], outline=(46, 204, 113), width=2)
+            draw.rectangle([20, 20, 580, 780], outline=(46, 204, 113), width=5)
+
+            draw.text((40, 60), "BK-GTA QUANTITATIVE SYSTEM", fill=(255, 255, 255))
+            draw.text((40, 150), f"TRADER: {ctx.author.name.upper()}", fill=(46, 204, 113))
+            draw.text((40, 260), f"ALPHA RET: +{ret}%", fill=(255, 255, 255))
+            draw.text((40, 360), f"SHARPE: {sharpe}", fill=(255, 255, 255))
+            draw.text((40, 460), f"SESSION: {SESSION_ID}", fill=(100, 100, 110))
+            draw.text((40, 720), "VERIFIED BY SENTINEL AI", fill=(46, 204, 113))
+
+            fp = io.BytesIO()
+            base.save(fp, 'PNG')
+            fp.seek(0)
+            await ctx.send(file=discord.File(fp, filename=f"Viral_{ctx.author.id}.png"))
+        except Exception as e:
+            logger.error(f"Render Error: {e}")
+            await ctx.send(f"❌ 渲染引擎崩溃: `{e}`")
+        finally:
+            await m.delete()
 
-    if duel["s1"] is not None and duel["s2"] is not None:
-        p1, p2 = duel["p1"], duel["p2"]
-        s1, s2 = duel["s1"], duel["s2"]
-        wid, lid = (p1, p2) if s1 > s2 else (p2, p1)
-        w_elo, l_elo, streak = bk_engine.update_elo(wid, lid)
+    # --- 事件注册 ---
+    @target_bot.event
+    async def on_ready():
+        if not auto_backup.is_running():
+            auto_backup.start()
+        await target_bot.change_presence(
+            activity=discord.Activity(type=discord.ActivityType.watching, name="HuggingFace Node")
+        )
+        logger.info(f"✅ [Online] BK-GTA V63.0-Titan Live. Session: {SESSION_ID}")
 
-        emb = discord.Embed(title="🏆 Duel Arena Verdict", color=0xf1c40f)
-        emb.add_field(name="Winner", value=f"<@{wid}>\nScore: {max(s1,s2)}\nELO: {w_elo}", inline=True)
-        emb.add_field(name="Loser", value=f"<@{lid}>\nScore: {min(s1,s2)}\nELO: {l_elo}", inline=True)
-        emb.set_footer(text=f"Win Streak: {streak} | Duel ID: {did}")
-        await ctx.send(embed=emb)
-        del bk_engine.active_duels[did]
-    else:
-        await ctx.send(f"✅ 交易员 <@{ctx.author.id}> 分数已锁定 ({score})。等待对手提交。")
-    await m.delete()
+    @target_bot.event
+    async def on_disconnect():
+        logger.warning("⚠️ [Gateway] Disconnected. discord.py will auto-reconnect...")
 
-# ==============================================================================
-# 10. 模块六：海报渲染引擎 (Poster Rendering)
-# ==============================================================================
-@bot.command()
-async def viral_audit(ctx):
-    if not ctx.message.attachments: return
-    m = await ctx.send("🎨 **[GPU-Node] 正在渲染视觉海报...**")
+    @target_bot.event
+    async def on_resumed():
+        logger.info("✅ [Gateway] Session resumed successfully.")
 
-    p = "Extract RET: [v] and SHARPE: [v]. Format: RET: [v] SHARPE: [v]"
-    res = await call_gemini(p, ctx.message.attachments[0])
-    ret, sharpe = safe_extract_float(res, "RET"), safe_extract_float(res, "SHARPE")
+    logger.info(f"📋 [Init] Registered {len(target_bot.commands)} commands to bot.")
 
-    try:
-        W, H = 600, 800
-        base = Image.new('RGB', (W, H), (18, 20, 30))
-        draw = ImageDraw.Draw(base)
-
-        for i in range(0, W, 40): draw.line([(i, 0), (i, H)], fill=(30, 35, 45), width=1)
-        for j in range(0, H, 40): draw.line([(0, j), (W, j)], fill=(30, 35, 45), width=1)
-
-        draw.rectangle([10, 10, 590, 790], outline=(46, 204, 113), width=2)
-        draw.rectangle([20, 20, 580, 780], outline=(46, 204, 113), width=5)
-
-        draw.text((40, 60), "BK-GTA QUANTITATIVE SYSTEM", fill=(255, 255, 255))
-        draw.text((40, 150), f"TRADER: {ctx.author.name.upper()}", fill=(46, 204, 113))
-        draw.text((40, 260), f"ALPHA RET: +{ret}%", fill=(255, 255, 255))
-        draw.text((40, 360), f"SHARPE: {sharpe}", fill=(255, 255, 255))
-        draw.text((40, 460), f"SESSION: {SESSION_ID}", fill=(100, 100, 110))
-        draw.text((40, 720), "VERIFIED BY SENTINEL AI", fill=(46, 204, 113))
-
-        fp = io.BytesIO()
-        base.save(fp, 'PNG')
-        fp.seek(0)
-        await ctx.send(file=discord.File(fp, filename=f"Viral_{ctx.author.id}.png"))
-    except Exception as e:
-        logger.error(f"Render Error: {e}")
-        await ctx.send(f"❌ 渲染引擎崩溃: `{e}`")
-    finally:
-        await m.delete()
+# 注册命令到初始 bot
+register_commands(bot)
 
 # ==============================================================================
-# 11. 系统守护与自动备份链 (Maintenance)
+# 6. 系统守护与自动备份 (Maintenance)
 # ==============================================================================
 @tasks.loop(hours=1)
 async def auto_backup():
     bk_engine.save_db()
     logger.info("💾 [System] Hourly Database Backup Executed.")
 
-@bot.event
-async def on_ready():
-    if not auto_backup.is_running():
-        auto_backup.start()
-    await bot.change_presence(
-        activity=discord.Activity(
-            type=discord.ActivityType.watching,
-            name="HuggingFace Node"
-        )
-    )
-    logger.info(f"✅ [Online] BK-GTA V62.9-Titan Live. Session: {SESSION_ID}")
-
-@bot.event
-async def on_disconnect():
-    logger.warning("⚠️ [Gateway] Disconnected. discord.py will auto-reconnect...")
-
-@bot.event
-async def on_resumed():
-    logger.info("✅ [Gateway] Session resumed successfully.")
 # ==============================================================================
-# 12. 启动入口 — DNS 就绪探测 + 安全重试
+# 7. 启动入口 — DNS 修复 + 安全重试
 # ==============================================================================
-import socket
-
-def wait_for_network(host="discord.com", port=443, timeout=120):
-    """
-    在容器启动后等待 DNS 解析就绪。
-    HuggingFace Spaces 容器冷启动时网络栈可能延迟 10-30 秒。
-    """
-    start = time.time()
-    attempt = 0
-    while time.time() - start < timeout:
-        attempt += 1
-        try:
-            socket.setdefaulttimeout(10)
-            socket.getaddrinfo(host, port)
-            logger.info(f"✅ [Network] DNS resolved {host} successfully (attempt {attempt})")
-            return True
-        except socket.gaierror as e:
-            logger.warning(f"⏳ [Network] DNS not ready (attempt {attempt}): {e}")
-            time.sleep(5)
-        except Exception as e:
-            logger.warning(f"⏳ [Network] Check failed (attempt {attempt}): {e}")
-            time.sleep(5)
-    logger.error(f"❌ [Network] DNS resolution failed after {timeout}s")
-    return False
-
-
 def run_bot():
     """
-    [核心修复]
-    1. bot.start() 替代 bot.run()：避免子线程信号处理器崩溃
-    2. DNS 就绪探测：等待 HuggingFace 容器网络栈初始化完成
-    3. 安全重试：DNS 暂时失败时自动等待重连
+    核心修复:
+    1. fix_dns() 注入可靠 DNS (Google/Cloudflare)
+    2. bot.start() 替代 bot.run() (子线程安全)
+    3. 网络失败时自动重试, 重建 bot 实例
     """
+    global bot
+
     if not DISCORD_TOKEN:
         logger.critical("❌ [FATAL] DISCORD_TOKEN is missing!")
         return
 
-    # ====== 第一步：等待网络就绪 ======
-    logger.info("🌐 [Bot Thread] Waiting for network/DNS to be ready...")
-    if not wait_for_network():
-        logger.critical("❌ [FATAL] Network never became available. Bot cannot start.")
-        return
+    max_retries = 10
 
-    # ====== 第二步：带重试的连接 ======
-    max_retries = 5
     for attempt in range(1, max_retries + 1):
-        logger.info(f"🚀 [Bot Thread] Connection attempt {attempt}/{max_retries}...")
+        logger.info(f"🚀 [Bot] Connection attempt {attempt}/{max_retries}...")
+
+        # 每次重试前等待网络稳定
+        if attempt > 1:
+            wait_time = min(30 * attempt, 180)
+            logger.info(f"⏳ [Bot] Waiting {wait_time}s for network to stabilize...")
+            time.sleep(wait_time)
+
+            # 重建 bot 实例 (close 后不可复用)
+            logger.info("🔄 [Bot] Rebuilding bot instance...")
+            bot = create_bot()
+            register_commands(bot)
 
         loop = asyncio.new_event_loop()
         asyncio.set_event_loop(loop)
 
         try:
+            # 先做一次快速 DNS 测试 (非阻塞式, 失败也继续)
+            try:
+                socket.setdefaulttimeout(10)
+                addr = socket.getaddrinfo("discord.com", 443)
+                logger.info(f"✅ [DNS] discord.com resolved: {addr[0][4]}")
+            except Exception as dns_err:
+                logger.warning(f"⚠️ [DNS] Pre-check failed: {dns_err} — will try connecting anyway")
+
             loop.run_until_complete(bot.start(DISCORD_TOKEN, reconnect=True))
-            # 如果 bot.start() 正常返回（比如被手动 close），跳出循环
-            break
+            break  # 正常退出则跳出
 
         except discord.LoginFailure:
-            logger.critical("❌ [FATAL] DISCORD_TOKEN is invalid! Check your token.")
-            break  # Token 错误不重试
+            logger.critical("❌ [FATAL] Invalid DISCORD_TOKEN!")
+            break  # 不重试
 
         except discord.PrivilegedIntentsRequired:
             logger.critical(
                 "❌ [FATAL] Privileged Intents not enabled!\n"
-                "→ Discord Developer Portal → Bot tab\n"
+                "→ https://discord.com/developers/applications → Bot tab\n"
                 "→ Enable 'SERVER MEMBERS INTENT' and 'MESSAGE CONTENT INTENT'"
             )
-            break  # 权限错误不重试
+            break  # 不重试
 
-        except (OSError, ConnectionError, asyncio.TimeoutError) as e:
-            # 网络类错误：值得重试
-            logger.error(f"⚠️ [Bot] Network error on attempt {attempt}: {e}")
+        except (OSError, ConnectionError) as e:
+            logger.error(f"🌐 [Bot] Network error (attempt {attempt}): {e}")
+            # 网络错误值得重试
 
         except Exception as e:
-            logger.error(f"❌ [Bot] Unexpected error on attempt {attempt}: {e}")
+            logger.error(f"❌ [Bot] Error (attempt {attempt}): {e}")
             traceback.print_exc()
 
         finally:
-            # 清理本次循环的事件循环
             try:
                 pending = asyncio.all_tasks(loop)
                 for task in pending:
@@ -638,89 +653,37 @@ def run_bot():
             finally:
                 loop.close()
 
-        # 重试等待（递增延迟）
-        if attempt < max_retries:
-            wait_time = min(30 * attempt, 120)
-            logger.info(f"⏳ [Bot] Waiting {wait_time}s before retry...")
-            time.sleep(wait_time)
-
-            # 重试前再次确认 DNS
-            if not wait_for_network(timeout=60):
-                logger.error("❌ [Bot] Network still unavailable, retrying anyway...")
-
-            # 重建 bot 实例（因为 close() 后无法复用）
-            _rebuild_bot()
-
-    logger.error("🔴 [Bot Thread] Bot has stopped after all attempts.")
-
-
-def _rebuild_bot():
-    """
-    重建 bot 实例并重新绑定所有命令和事件。
-    bot.close() 后内部 session 被销毁，必须创建新实例。
-    """
-    global bot
-    old_commands = {cmd.name: cmd for cmd in bot.commands}
-    old_listeners = {}
-
-    # 保存已注册的事件监听器
-    for event_name in ['on_ready', 'on_disconnect', 'on_resumed']:
-        listener = getattr(bot, event_name, None)
-        if listener:
-            old_listeners[event_name] = listener
-
-    # 创建新实例
-    bot = commands.Bot(command_prefix='!', intents=intents)
-
-    # 恢复命令
-    for name, cmd in old_commands.items():
-        try:
-            bot.add_command(cmd)
-        except Exception:
-            pass
-
-    # 重新注册事件
-    @bot.event
-    async def on_ready():
-        if not auto_backup.is_running():
-            auto_backup.start()
-        await bot.change_presence(
-            activity=discord.Activity(type=discord.ActivityType.watching, name="HuggingFace Node")
-        )
-        logger.info(f"✅ [Online] BK-GTA V62.9-Titan Live. Session: {SESSION_ID}")
-
-    @bot.event
-    async def on_disconnect():
-        logger.warning("⚠️ [Gateway] Disconnected. discord.py will auto-reconnect...")
-
-    @bot.event
-    async def on_resumed():
-        logger.info("✅ [Gateway] Session resumed successfully.")
-
-    logger.info("🔄 [Bot] Instance rebuilt with all commands restored.")
+    logger.error("🔴 [Bot Thread] Bot startup exhausted all retries.")
 
 
 if __name__ == "__main__":
     logger.info("=" * 60)
-    logger.info("  BK-GTA V62.9-Titan Starting...")
-    logger.info(f"  Token present: {'YES' if DISCORD_TOKEN else 'NO (!!)'}")
+    logger.info("  BK-GTA V63.0-Titan Starting...")
+    logger.info(f"  Token present: {'YES' if DISCORD_TOKEN else '!! NO !!'}")
     logger.info(f"  Token length:  {len(DISCORD_TOKEN)} chars")
     logger.info(f"  Gemini keys:   {len(KEY_POOL)}")
     logger.info(f"  DB path:       {DB_PATH}")
     logger.info("=" * 60)
 
-    # 1. 启动 Discord Bot 后台线程
-    bot_thread = threading.Thread(target=run_bot, daemon=True)
-    bot_thread.start()
-    logger.info("📡 [Main] Bot thread launched.")
-
-    # 2. 启动 Gradio 前台哨兵
-    logger.info("📡 [Main] Starting Gradio on port 7860...")
-    iface = gr.Interface(
-        fn=get_status,
-        inputs=None,
-        outputs="json",
-        title="BK-GTA Sentinel AI",
-        description="Physical architecture monitor. Logic Integrity: Secure."
-    )
-    iface.launch(server_name="0.0.0.0", server_port=7860)
+    # 1. 先启动 Gradio (让 HuggingFace 认为服务已就绪)
+    #    Gradio 在后台线程运行, Bot 在主逻辑中延迟启动
+    def run_gradio():
+        iface = gr.Interface(
+            fn=get_status,
+            inputs=None,
+            outputs="json",
+            title="BK-GTA Sentinel AI",
+            description="Physical architecture monitor. Logic Integrity: Secure."
+        )
+        iface.launch(server_name="0.0.0.0", server_port=7860)
+
+    gradio_thread = threading.Thread(target=run_gradio, daemon=True)
+    gradio_thread.start()
+    logger.info("📡 [Main] Gradio launched on port 7860.")
+
+    # 2. 等待容器网络完全就绪 (关键!)
+    logger.info("⏳ [Main] Waiting 10s for container network to initialize...")
+    time.sleep(10)
+
+    # 3. 在主线程运行 Bot (避免子线程信号问题)
+    run_bot()