Update app.py

app.py

@@ -20,67 +20,60 @@ from PIL import Image, ImageDraw, ImageFont
 import gradio as gr
 
 # ==============================================================================
-# 0. 机构级审计日志 (Institutional Logging)
+# 0. 机构级审计日志 (Institutional Log Engine)
 # ==============================================================================
 logging.basicConfig(
     level=logging.INFO,
     format='%(asctime)s [%(levelname)s] %(message)s',
     handlers=[logging.StreamHandler(sys.stdout)]
 )
-logger = logging.getLogger("BK_GTA_ARCHITECT_GRADIO")
+logger = logging.getLogger("BK_GTA_ARCHITECT_TITAN")
 
 # ==============================================================================
-# 1. 物理层适配：Gradio 哨兵 (Sentinel Probe)
+# 1. 物理层：Gradio 哨兵与探针 (Gradio Sentinel)
 # ==============================================================================
 def get_status():
     """
-    提供给 UptimeRobot 的监控探针内容
+    提供给外部（如 UptimeRobot/Cron-Job）的心跳对账数据
     """
     now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+    bot_status = "OFFLINE"
     latency = "N/A"
     try:
         if bot and bot.is_ready():
+            bot_status = "ONLINE"
             latency = f"{round(bot.latency * 1000, 2)}ms"
-    except:
-        pass
+    except Exception as e:
+        logger.error(f"Status check failed: {e}")
     
     return {
-        "status": "BK-GTA-GRADIO-TITAN-ACTIVE",
-        "version": "V62.9-Stable",
-        "bot_latency": latency,
+        "status": "BK-GTA-TITAN-ACTIVE",
+        "logic_integrity": "100%",
+        "engine_version": "V62.9-Gradio-Final",
+        "discord_bot": bot_status,
+        "latency": latency,
         "server_time": now,
-        "keys_loaded": len(KEY_POOL),
-        "memory_usage": f"{sys.getsizeof(bk_engine.data) / 1024:.2f} KB"
+        "keys_pool": len(KEY_POOL),
+        "db_size": f"{sys.getsizeof(bk_engine.data) / 1024:.2f} KB"
     }
 
 # ==============================================================================
-# 2. 密钥池与环境配置 (Key Rotation Engine)
+# 2. 密钥池与环境配置 (Key Rotation & Env)
 # ==============================================================================
-DISCORD_TOKEN = os.environ.get('DISCORD_TOKEN')
+DISCORD_TOKEN = os.environ.get('DISCORD_TOKEN', '').strip()
 SESSION_ID = random.randint(10000, 99999)
 
 # [CORE] 8 密钥轮询加载器
 raw_keys = os.environ.get('GEMINI_KEYS_POOL', '')
-KEY_POOL = []
-
-if raw_keys:
-    parts = raw_keys.split(',')
-    for k in parts:
-        clean_key = k.strip()
-        if clean_key:
-            KEY_POOL.append(clean_key)
-    logger.info(f"✅ [System] Loaded GEMINI_KEYS_POOL with {len(KEY_POOL)} keys.")
-else:
-    # 兼容单密钥模式
+KEY_POOL = [k.strip() for k in raw_keys.split(',') if k.strip()]
+if not KEY_POOL:
     single = os.environ.get('GEMINI_KEY')
-    if single:
-        KEY_POOL.append(single)
-        logger.warning("⚠️ [System] Running in SINGLE KEY mode.")
+    if single: KEY_POOL.append(single)
 
 if not KEY_POOL:
-    logger.critical("❌ [CRITICAL] NO API KEYS FOUND! Please set GEMINI_KEYS_POOL in Secrets.")
+    logger.critical("❌ [CRITICAL] NO API KEYS FOUND! Please set GEMINI_KEYS_POOL.")
 
-# 设置 Discord 权限
+# 权限位设置
 intents = discord.Intents.default()
 intents.message_content = True
 intents.members = True
@@ -88,21 +81,18 @@ bot = commands.Bot(command_prefix='!', intents=intents)
 
 # 并发审计锁
 audit_lock = asyncio.Lock()
-
-# 数据库路径适配
-if os.path.exists('/data'):
-    DB_PATH_CONFIG = '/data/bk_gta_v62_unified.json'
-    logger.info(f"📂 [Storage] Using Persistent Storage: {DB_PATH_CONFIG}")
-else:
-    DB_PATH_CONFIG = 'bk_gta_v62_unified.json'
-    logger.warning(f"⚠️ [Storage] Using Ephemeral Storage.")
+# 优先使用持久化目录 /data
+DB_PATH = '/data/bk_gta_v62_unified.json' if os.path.exists('/data') else 'bk_gta_v62_unified.json'
 
 # ==============================================================================
 # 3. 状态引擎 (BKEngine Core)
 # ==============================================================================
 class BKEngine:
+    """
+    负责量化资产的持久化、ELO 计算及风险对账
+    """
     def __init__(self):
-        self.db_file = DB_PATH_CONFIG
+        self.db_file = DB_PATH
         self.data = self._load_db()
         self.pending_challenges = {}
         self.active_duels = {}
@@ -122,15 +112,15 @@ class BKEngine:
 
     def _init_schema(self):
         return {
-            "version": "62.9-Gradio",
+            "version": "62.9-Titan",
             "users": {},
             "factions": {
-                "BULLS": {"score": 0, "emoji": "🐂", "total_wins": 0}, 
-                "BEARS": {"score": 0, "emoji": "🐻", "total_wins": 0}
+                "BULLS": {"score": 0, "emoji": "🐂", "wins": 0}, 
+                "BEARS": {"score": 0, "emoji": "🐻", "wins": 0}
             },
             "prize_pool": 1000000.0,
             "logs": [],
-            "last_global_sync": str(datetime.datetime.now())
+            "last_sync": str(datetime.datetime.now())
         }
 
     def save_db(self):
@@ -140,33 +130,31 @@ class BKEngine:
                 json.dump(self.data, f, ensure_ascii=False, indent=4)
             os.replace(temp, self.db_file)
         except Exception as e:
-            logger.error(f"💾 [DB Error] Failed to persist data: {e}")
+            logger.error(f"💾 [DB Error] {e}")
 
     def get_user(self, user_id):
         uid = str(user_id)
         if uid not in self.data["users"]:
             self.data["users"][uid] = {
-                "elo": 1200, 
-                "points": 1000, 
-                "faction": None,
-                "audits_count": 0, 
-                "total_score": 0.0, 
-                "highest_score": 0.0,
-                "win_streak": 0, 
-                "mdd_record": 0.0, 
-                "sharpe_record": 0.0,
-                "last_active": str(datetime.datetime.now())
+                "elo": 1200, "points": 1000, "faction": None,
+                "audits_count": 0, "total_score": 0.0, "highest_score": 0.0,
+                "win_streak": 0, "mdd_record": 0.0, "sharpe_record": 0.0,
+                "audit_history": [], "last_active": str(datetime.datetime.now())
             }
         return self.data["users"][uid]
 
-    def update_audit_stats(self, user_id, score, mdd=None, sharpe=None):
+    def update_audit(self, user_id, score, mdd=None, sharpe=None):
         u = self.get_user(user_id)
         u["audits_count"] += 1
         u["total_score"] += score
-        if score > u.get("highest_score", 0): u["highest_score"] = score
+        if score > u.get("highest_score", 0):
+            u["highest_score"] = score
         if mdd is not None: u["mdd_record"] = mdd
         if sharpe is not None: u["sharpe_record"] = sharpe
         u["points"] += 50
+        # 记录最近 5 次审计历史
+        u["audit_history"].append({"s": score, "t": str(datetime.datetime.now())})
+        u["audit_history"] = u["audit_history"][-5:]
         u["last_active"] = str(datetime.datetime.now())
         self.save_db()
 
@@ -175,20 +163,24 @@ class BKEngine:
         K = 32
         Rw, Rl = w["elo"], l["elo"]
         Ew = 1 / (1 + 10 ** ((Rl - Rw) / 400))
+        
         w["elo"] = round(Rw + K * (1 - Ew))
         l["elo"] = round(Rl + K * (0 - Ew))
+        
         w["win_streak"] += 1
         l["win_streak"] = 0
-        if w["faction"]: 
+        
+        if w["faction"] and w["faction"] in self.data["factions"]:
             self.data["factions"][w["faction"]]["score"] += 15
-            self.data["factions"][w["faction"]]["total_wins"] += 1
+            self.data["factions"][w["faction"]]["wins"] += 1
+        
         self.save_db()
         return w["elo"], l["elo"], w["win_streak"]
 
 bk_engine = BKEngine()
 
 # ==============================================================================
-# 4. 辅助内核 (Helper Kernels)
+# 4. 辅助内核与密钥多路复用 (Multiplexing Kernel)
 # ==============================================================================
 def safe_extract_float(text, key):
     try:
@@ -198,78 +190,80 @@ def safe_extract_float(text, key):
             rf"【{key}】\s*([-+]?\d*\.?\d+)"
         ]
         for p in patterns:
-            match = re.search(p, text, re.IGNORECASE)
+            match = re.search(p, text, re.I)
             if match: return float(match.group(1))
         return 0.0
     except: return 0.0
 
-def safe_extract_text(text, key_start, key_end=None):
+def safe_extract_text(text, start, end=None):
     try:
-        p = rf"{key_start}:(.*?){key_end}:" if key_end else rf"{key_start}:(.*)"
-        match = re.search(p, text, re.DOTALL | re.IGNORECASE)
+        p = rf"{start}:(.*?){end}:" if end else rf"{start}:(.*)"
+        match = re.search(p, text, re.S | re.I)
         if match:
             return match.group(1).strip().replace('*', '').replace('`', '').strip()
         return "N/A"
     except: return "N/A"
 
-async def call_gemini_multiplex(prompt, attachment=None):
-    if not KEY_POOL: return "ERROR: NO_KEYS_CONFIGURED"
+async def call_gemini(prompt, attachment=None):
+    """
+    [Core Logic] 8 密钥池高频轮询与故障自动迁移
+    """
+    if not KEY_POOL: return "ERROR: NO_KEYS"
     
-    image_data = None
+    img_data = None
     if attachment:
-        try: image_data = await attachment.read()
-        except: return "ERROR: IMG_READ_FAIL"
+        try: img_data = await attachment.read()
+        except: return "ERROR: READ_FAIL"
 
     loop = asyncio.get_running_loop()
-    shuffled_keys = list(KEY_POOL)
-    random.shuffle(shuffled_keys)
+    shuffled = list(KEY_POOL)
+    random.shuffle(shuffled)
 
-    for i, api_key in enumerate(shuffled_keys):
+    for api_key in shuffled:
         try:
             client = genai.Client(api_key=api_key)
             contents = [prompt]
-            if image_data:
-                contents.append(types.Part.from_bytes(data=image_data, mime_type='image/png'))
+            if img_data:
+                contents.append(types.Part.from_bytes(data=img_data, mime_type='image/png'))
 
             response = await loop.run_in_executor(
                 None, 
                 functools.partial(client.models.generate_content, model="gemini-1.5-flash", contents=contents)
             )
-
-            if response and response.text: return response.text
-                
+            if response and response.text:
+                return response.text
         except Exception as e:
-            err_msg = str(e)
-            if "429" in err_msg:
-                logger.warning(f"⚠️ Key {i+1} Rate Limited. Switching...")
+            if "429" in str(e):
+                logger.warning("Key Rate Limited. Retrying with next...")
                 continue
-            logger.error(f"🤖 Key {i+1} Error: {err_msg}")
+            logger.error(f"Gemini API Error: {e}")
             continue
 
     return "ERROR: ALL_KEYS_EXHAUSTED"
 
 # ==============================================================================
-# 5. 模块一：全网天梯
+# 5. 模块一：全网天梯 (Rank & Stats)
 # ==============================================================================
 @bot.command()
 async def profile(ctx, member: discord.Member = None):
-    target = member or ctx.author
-    u = bk_engine.get_user(target.id)
+    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"📊 Quantitative Profile: {target.display_name}", color=color)
-    emb.add_field(name="Rating (ELO)", value=f"**{elo}**\nRank: `{rank}`", inline=True)
-    emb.add_field(name="Assets (Points)", value=f"💰 **{u['points']}**", inline=True)
+    # 动态段位
+    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", "")
+    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 = (
@@ -277,147 +271,165 @@ async def profile(ctx, member: discord.Member = None):
         f"Peak Score: {u['highest_score']:.1f}\n"
         f"Max MDD: {u.get('mdd_record',0):.2f}%"
     )
-    emb.add_field(name="Performance Metrics", value=f"```yaml\n{stats}\n```", inline=False)
+    emb.add_field(name="Institutional Metrics", value=f"```yaml\n{stats}\n```", inline=False)
     
-    if target.avatar: emb.set_thumbnail(url=target.avatar.url)
-    emb.set_footer(text=f"Session: {SESSION_ID} | Node: HuggingFace")
+    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):
-    users = [{"id": k, "elo": v["elo"], "score": v["highest_score"]} for k,v in bk_engine.data["users"].items()]
-    top = sorted(users, key=lambda x: x["elo"], reverse=True)[:10]
+    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 i, u in enumerate(top):
-        icon = ["🥇","🥈","🥉"][i] if i < 3 else f"{i+1}."
+    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="🏆 Global Ranking (Institutional)", description=desc or "No data available.", color=0xf1c40f)
+    emb = discord.Embed(title="🏆 BK-GTA Institutional Leaderboard", description=desc or "No data.", color=0xf1c40f)
     
-    f_txt = ""
+    f_info = ""
     for k, v in bk_engine.data["factions"].items():
-        f_txt += f"{v['emoji']} {k}: {v['score']} pts | "
-    if f_txt: emb.add_field(name="Faction War Status", value=f_txt, inline=False)
-    
+        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)
 
 # ==============================================================================
-# 6. 模块二：宏观情报
+# 6. 模块二：宏观情报 (Macro Analysis)
 # ==============================================================================
 @bot.command()
 async def news(ctx):
-    if not ctx.message.attachments: return await ctx.send("❌ Audit Refused: Please upload an image.")
-    m = await ctx.send("📡 **[HF-Node] Analyzing Macro Pulse...**")
+    if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传情报截图。")
+    m = await ctx.send("📡 **[Sentinel] Analyzing Macro Pulse...**")
     
     prompt = (
-        "Analyze chart/news. Output: SCORE: (-10 to 10), SUMMARY: (text), TAKE: (institutional view). "
-        "Format: SCORE: [v] SUMMARY: [v] TAKE: [v]"
+        "你是一名顶级对冲基金策略师。请解析截图内容：\n"
+        "1. 评分 (SCORE): -10 (极大利空) 到 +10 (极大利多)。\n"
+        "2. 总结 (SUMMARY): 30字内概括核心变量。\n"
+        "3. 解读 (TAKE): 机构视角的隐含逻辑。\n"
+        "格式必须为：\nSCORE: [v]\nSUMMARY: [v]\nTAKE: [v]"
     )
-    res = await call_gemini_multiplex(prompt, ctx.message.attachments[0])
+    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")
     
-    emb = discord.Embed(title="📰 Macro Intelligence", color=0x2ecc71 if score > 0 else 0xe74c3c)
-    emb.add_field(name="Sentiment Score", value=f"**{score:+.1f}**")
-    emb.add_field(name="Executive Summary", value=summary, inline=False)
-    emb.add_field(name="Institutional Take", value=f"```{take}```", inline=False)
+    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)
 
 # ==============================================================================
-# 7. 模块三：量化审计
+# 7. 模块三：量化审计 (Institutional Audit)
 # ==============================================================================
 @bot.command()
 async def evaluate(ctx):
-    if not ctx.message.attachments: return await ctx.send("❌ No image detected.")
+    if not ctx.message.attachments: return await ctx.send("❌ Error: 请上传回测或结算截图。")
+    
     if audit_lock.locked():
-        return await ctx.send("⚠️ **[System Busy]** Another audit is processing. Please wait 10s.")
+        return await ctx.send("⚠️ **[System Busy]** 正在处理另一项审计，请稍后。")
 
     async with audit_lock:
-        m = await ctx.send("🛡️ **[Audit Engine] Processing... (Locked)**")
+        m = await ctx.send("🛡️ **[Audit Engine] 启动深度扫描... (锁闭模式)**")
         prompt = (
-            "Quant Audit. Extract RET, MDD, PF, SHARPE, TRADES. S_BASE(0-100). "
-            "VIOLATION(TRUE if MDD>35). Highlights(H_ZH). "
-            "Format: RET:[v] MDD:[v] PF:[v] SHARPE:[v] TRADES:[v] S_BASE:[v] VIOLATION:[v] H_ZH:[v]"
+            "你是一名顶级量化风险官。请提取并审计以下指标：\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]"
         )
         
-        res = await call_gemini_multiplex(prompt, ctx.message.attachments[0])
+        res = await call_gemini(prompt, ctx.message.attachments[0])
         
         if "ERROR" in res:
             await m.delete()
-            return await ctx.send(f"🔴 Audit Failed: {res}")
+            return await ctx.send("🔴 [Audit Crash] 引擎请求失败。")
 
         ret = safe_extract_float(res, "RET")
         mdd = safe_extract_float(res, "MDD")
-        pf = safe_extract_float(res, "PF")
         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()
 
+        # 风控核心：MDD 否决制
         if violation or mdd > 35.0:
             s_final = 0.0
-            status = "REJECTED (High Risk)"
+            status = "❌ REJECTED (High Risk)"
             color = 0xe74c3c
         else:
-            trades_adj = math.log10(max(trades, 1)) / 1.5
-            s_final = s_base * min(max(trades_adj, 0.5), 1.2) * (sharpe/2.0 if sharpe>0 else 0.5)
-            s_final = min(max(s_final, 0.0), 100.0)
-            status = "CLEARED"
+            # 复合评分逻辑：基础分 * 样本权重 * 风险权重
+            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_stats(ctx.author.id, s_final, mdd, sharpe)
+        bk_engine.update_audit(ctx.author.id, s_final, mdd, sharpe)
+        highlights = safe_extract_text(res, "H_ZH")
         
-        emb = discord.Embed(title="🛡️ Audit Report", color=color)
-        emb.add_field(name="Verdict", value=status, inline=False)
-        emb.add_field(name="Metrics", value=f"```Return: {ret}%\nMDD: {mdd}%\nSharpe: {sharpe}\nPF: {pf}```", inline=False)
-        emb.add_field(name="Score", value=f"**{s_final:.1f}**")
-        emb.add_field(name="Highlights", value=safe_extract_text(res, "H_ZH"), inline=False)
+        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)
         
         await m.delete()
         await ctx.send(embed=emb)
 
 # ==============================================================================
-# 8. 模块四：博弈盘口
+# 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",
-        "start_time": str(datetime.datetime.now())
+        "topic": topic, "up": 0, "down": 0, 
+        "u_up": {}, "u_down": {}, "status": "OPEN",
+        "time": str(datetime.datetime.now())
     }
-    await ctx.send(f"🎰 **Bet Market Open [{bid}]**\nTopic: {topic}\nType `!bet {bid} UP 100` to join.")
+    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
+    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: return await ctx.send("❌ Insufficient funds.")
+    if u["points"] < amt or amt <= 0:
+        return await ctx.send("❌ 资产点数不足。")
     
-    u["points"] -= amt; side = side.upper()
-    if side not in ["UP", "DOWN"]: return await ctx.send("❌ Choose UP or DOWN.")
+    side = side.upper()
+    if side not in ["UP", "DOWN"]: return await ctx.send("❌ 必须选择 UP 或 DOWN。")
     
-    pool = "u_up" if side == "UP" else "u_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"✅ Bet {amt} on {side} confirmed.")
+    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()
+    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"]
@@ -425,29 +437,35 @@ async def settle_bet(ctx, bid: str, winner: str):
     
     if total_w > 0:
         for uid, amt in win_pool.items():
-            profit = (amt/total_w) * total_l
+            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"🏁 Bet {bid} Settled. Winner: {winner}. Payouts Distributed.")
+    await ctx.send(f"🏁 盘口 {bid} 已结算！胜利方：**{winner}**。资产已自动划转。")
 
 # ==============================================================================
-# 9. 模块五：PVP 竞技场
+# 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] = {"c": ctx.author.id, "id": did}
-    await ctx.send(f"⚔️ {ctx.author.name} challenges {member.name}!\nID: `{did}`. Type `!accept` to start.")
+    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
+    if ctx.author.id not in bk_engine.pending_challenges:
+        return await ctx.send("❌ 没有待处理的决斗请求。")
+    
     req = bk_engine.pending_challenges.pop(ctx.author.id)
-    bk_engine.active_duels[req["id"]] = {"p1": req["c"], "p2": ctx.author.id, "s1": None, "s2": None}
-    await ctx.send(f"🔥 Duel `{req['id']}` Active! Submit screenshots via `!duel_submit {req['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}` 提交审计截图。")
 
 @bot.command()
 async def duel_submit(ctx, did: str):
@@ -457,8 +475,8 @@ async def duel_submit(ctx, did: str):
     duel = bk_engine.active_duels[did]
     if ctx.author.id not in [duel["p1"], duel["p2"]]: return
     
-    m = await ctx.send("🔍 Auditing duel submission...")
-    res = await call_gemini_multiplex("Extract SCORE:[0-100]. Format: SCORE:[v]", ctx.message.attachments[0])
+    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
@@ -468,97 +486,102 @@ async def duel_submit(ctx, did: str):
         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, _ = bk_engine.update_elo(wid, lid)
+        w_elo, l_elo, streak = bk_engine.update_elo(wid, lid)
         
-        emb = discord.Embed(title="🏆 Duel Result", color=0xf1c40f)
-        emb.add_field(name="Winner", value=f"<@{wid}>\nScore: {max(s1,s2)}\nELO: {w_elo}")
-        emb.add_field(name="Loser", value=f"<@{lid}>\nScore: {min(s1,s2)}\nELO: {l_elo}")
+        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"✅ Score {score} recorded. Waiting for opponent.")
+        await ctx.send(f"✅ 交易员 <@{ctx.author.id}> 分数已锁定 ({score})。等待对手提交。")
     await m.delete()
 
 # ==============================================================================
-# 10. 模块六：海报渲染
+# 10. 模块六：海报渲染引擎 (Poster Rendering)
 # ==============================================================================
 @bot.command()
 async def viral_audit(ctx):
     """
-    [完整版] 提取审计数据并渲染具备社交传播属性的海报图片
+    [完全版] 提取审计数据并渲染具备像素级视觉逻辑的海报
     """
-    if not ctx.message.attachments:
-        return await ctx.send("❌ 请上传审计截图。")
-
-    m = await ctx.send("🎨 **[GPU-Node] Rendering Institutional Poster...**")
+    if not ctx.message.attachments: return
+    m = await ctx.send("🎨 **[GPU-Node] 正在渲染视觉海报...**")
     
-    prompt = "Extract RET: [val] and SHARPE: [val]. FORMAT: RET: [v] SHARPE: [v]"
-    res = await call_gemini_multiplex(prompt, ctx.message.attachments[0])
+    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")
 
     try:
         W, H = 600, 800
-        base = Image.new('RGB', (W, H), color=(18, 20, 30))
+        # 暗色底板
+        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 ID: {ctx.author.name.upper()}", fill=(46, 204, 113))
-        draw.text((40, 260), f"ALPHA RETURN: +{ret}%", fill=(255, 255, 255))
-        draw.text((40, 360), f"SHARPE RATIO: {sharpe}", fill=(255, 255, 255))
-        draw.text((40, 460), f"SESSION: {SESSION_ID}", fill=(120, 120, 130))
-        
-        draw.text((40, 720), "VERIFIED BY BK-GTA SENTINEL AI", fill=(46, 204, 113))
+        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}`")
+        await ctx.send(f"❌ 渲染引擎崩溃: `{e}`")
     finally:
         await m.delete()
 
 # ==============================================================================
-# 11. 启动引擎 (Gradio + Discord Thread)
+# 11. 系统守护与自动备份链 (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="HF-Native Node"))
-    logger.info(f"✅ [V62.9-Gradio] Online. Session: {SESSION_ID}")
+    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}")
 
-def run_discord_bot():
-    if DISCORD_TOKEN:
+def run_bot():
+    if not DISCORD_TOKEN: 
+        logger.critical("❌ [FATAL] DISCORD_TOKEN Missing.")
+        return
+    
+    # 自动重连容器
+    while True:
         try:
             bot.run(DISCORD_TOKEN)
         except Exception as e:
-            logger.critical(f"Bot Crash: {e}")
-    else:
-        logger.critical("No Token")
+            logger.error(f"⚠️ [Socket Error] {e}. Restarting in 10s...")
+            time.sleep(10)
 
 if __name__ == "__main__":
-    # 1. 在后台线程启动 Discord 机器人 (非阻塞)
-    threading.Thread(target=run_discord_bot).start()
+    # 1. 启动 Discord 后台线程
+    threading.Thread(target=run_bot, daemon=True).start()
     
-    # 2. 在主线程启动 Gradio UI
-    # [FIX] 移除了 every=5 参数以修复 TypeError
+    # 2. 启动 Gradio 前台哨兵 (强制监听 7860 端口)
     iface = gr.Interface(
         fn=get_status, 
         inputs=None, 
         outputs="json", 
-        title="BK-GTA Sentinel",
-        description="Core logic is running in background thread."
+        title="BK-GTA Sentinel AI",
+        description="Physical architecture monitor. Logic Integrity: Secure."
     )
     iface.launch(server_name="0.0.0.0", server_port=7860)