Rename main.py to app.py

main.py → app.py

@@ -15,71 +15,45 @@ import sys
 import traceback
 import io
 import time
+import threading
 from PIL import Image, ImageDraw, ImageFont
-from flask import Flask
-from threading import Thread
+import gradio as gr  # 替换 Flask 为 Gradio
 
 # ==============================================================================
-# 0. 机构级审计日志 (Hugging Face Optimized Logging)
+# 0. 机构级审计日志 (Institutional Logging)
 # ==============================================================================
 logging.basicConfig(
     level=logging.INFO,
     format='%(asctime)s [%(levelname)s] %(message)s',
     handlers=[logging.StreamHandler(sys.stdout)]
 )
-logger = logging.getLogger("BK_GTA_ARCHITECT_HF")
+logger = logging.getLogger("BK_GTA_ARCHITECT_GRADIO")
 
 # ==============================================================================
-# 1. 物理层适配：Hugging Face 端口映射 (Port 7860)
+# 1. 物理层适配：Gradio 哨兵 (Sentinel Probe)
 # ==============================================================================
-app = Flask(__name__)
-
-@app.route('/')
-def home():
+def get_status():
     """
-    HF Spaces 健康检查探针。
-    返回 200 OK 以告知 HF 负载均衡器容器存活。
-    注入 bot.latency 以确保监控访问能强制唤醒 Discord 线程。
+    提供给 UptimeRobot 的监控探针内容
+    Gradio 会自动将其渲染为一个 API 端点，确保 HF 容器不休眠
     """
     now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
     latency = "N/A"
     try:
-        # 核心逻辑：通过读取 bot 属性，强制 Python 解释器保持 Discord 线程活跃
-        if bot.is_ready():
+        if bot and bot.is_ready():
             latency = f"{round(bot.latency * 1000, 2)}ms"
-    except Exception as e:
-        logger.warning(f"Heartbeat probe warning: {e}")
+    except:
+        pass
     
     return {
-        "status": "BK-GTA-HF-TITAN-ACTIVE",
-        "platform": "Hugging Face Docker Node",
-        "engine": "V62.9-Titan",
+        "status": "BK-GTA-GRADIO-TITAN-ACTIVE",
+        "version": "V62.9-Full-Stack",
         "bot_latency": latency,
         "server_time": now,
-        "sentinel": "PROTECTED",
-        "memory_pool": f"{sys.getsizeof(bk_engine.data) / 1024:.2f} KB"
+        "keys_loaded": len(KEY_POOL),
+        "memory_usage": f"{sys.getsizeof(bk_engine.data) / 1024:.2f} KB"
     }
 
-def run_web_server():
-    """
-    [CRITICAL] Hugging Face 强制要求监听 7860 端口。
-    这是外部 UptimeRobot 能够触达容器的唯一物理入口。
-    """
-    try:
-        logger.info("📡 [Sentinel] Starting Web Server on Port 7860...")
-        import logging
-        log = logging.getLogger('werkzeug')
-        log.setLevel(logging.ERROR)
-        app.run(host='0.0.0.0', port=7860, threaded=True)
-    except Exception as e:
-        logger.error(f"⚠️ [Sentinel] Web Server Failure: {e}")
-
-def keep_alive():
-    """开启独立守护线程运行 Web 服务"""
-    t = Thread(target=run_web_server)
-    t.daemon = True 
-    t.start()
-
 # ==============================================================================
 # 2. 密钥池与环境配置 (Key Rotation Engine)
 # ==============================================================================
@@ -87,7 +61,6 @@ DISCORD_TOKEN = os.environ.get('DISCORD_TOKEN')
 SESSION_ID = random.randint(10000, 99999)
 
 # [CORE] 8 密钥轮询加载器
-# 在 HF Secrets 中设置 GEMINI_KEYS_POOL = key1,key2,key3...
 raw_keys = os.environ.get('GEMINI_KEYS_POOL', '')
 KEY_POOL = []
 
@@ -114,31 +87,27 @@ intents.message_content = True
 intents.members = True
 bot = commands.Bot(command_prefix='!', intents=intents)
 
-# 并发审计锁 (防止 OOM)
+# 并发审计锁 (防止内存溢出)
 audit_lock = asyncio.Lock()
 
-# 数据库路径适配 (优先使用 HF 持久化目录 /data)
+# 数据库路径适配 (Gradio 模式也支持 /data 持久化)
 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 lost on restart): {DB_PATH_CONFIG}")
+    logger.warning(f"⚠️ [Storage] Using Ephemeral Storage (Data lost on restart).")
 
 # ==============================================================================
-# 3. 状态引擎与持久化数据库 (BKEngine HF Adapter)
+# 3. 状态引擎 (BKEngine Core)
 # ==============================================================================
 class BKEngine:
-    """
-    核心数据引擎：负责量化资产持久化、状态树管理及风险指标对账
-    """
     def __init__(self):
         self.db_file = DB_PATH_CONFIG
         self.data = self._load_db()
         self.pending_challenges = {}
         self.active_duels = {}
         self.active_bets = {} 
-        self.system_uptime = datetime.datetime.now()
 
     def _load_db(self):
         if os.path.exists(self.db_file):
@@ -154,7 +123,7 @@ class BKEngine:
 
     def _init_schema(self):
         return {
-            "version": "62.9-HF-Titan",
+            "version": "62.9-Gradio",
             "users": {},
             "factions": {
                 "BULLS": {"score": 0, "emoji": "🐂", "total_wins": 0}, 
@@ -166,7 +135,6 @@ class BKEngine:
         }
 
     def save_db(self):
-        """执行物理持久化，确保数据资产安全"""
         try:
             # 原子写入防止文件损坏
             temp = self.db_file + '.tmp'
@@ -189,7 +157,6 @@ class BKEngine:
                 "win_streak": 0, 
                 "mdd_record": 0.0, 
                 "sharpe_record": 0.0,
-                "performance_log": [],
                 "last_active": str(datetime.datetime.now())
             }
         return self.data["users"][uid]
@@ -198,144 +165,104 @@ class BKEngine:
         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
         u["last_active"] = str(datetime.datetime.now())
-        u["performance_log"].append({"score": score, "time": str(datetime.datetime.now())})
         self.save_db()
 
     def update_elo(self, winner_id, loser_id):
-        """
-        基于 ELO 等级分系统的量化能力更新算法
-        K = 32 (常数项)
-        """
-        w = self.get_user(winner_id)
-        l = self.get_user(loser_id)
-
+        w, l = self.get_user(winner_id), self.get_user(loser_id)
         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"] and w["faction"] in self.data["factions"]:
+        if w["faction"]: 
             self.data["factions"][w["faction"]]["score"] += 15
             self.data["factions"][w["faction"]]["total_wins"] += 1
-
         self.save_db()
         return w["elo"], l["elo"], w["win_streak"]
 
 bk_engine = BKEngine()
 
 # ==============================================================================
-# 4. 辅助内核与密钥轮询 (Multi-Key Multiplexer)
+# 4. 辅助内核 (Helper Kernels)
 # ==============================================================================
 def safe_extract_float(text, key):
-    """鲁棒性数值提取引擎，支持多重前缀匹配"""
     try:
         patterns = [
-            rf"{key}:\s*([-+]?\d*\.?\d+)",
+            rf"{key}:\s*([-+]?\d*\.?\d+)", 
             rf"{key}\s*=\s*([-+]?\d*\.?\d+)",
             rf"【{key}】\s*([-+]?\d*\.?\d+)"
         ]
-        for pattern in patterns:
-            match = re.search(pattern, text, re.IGNORECASE)
+        for p in patterns:
+            match = re.search(p, text, re.IGNORECASE)
             if match: return float(match.group(1))
         return 0.0
-    except Exception: return 0.0
+    except: return 0.0
 
 def safe_extract_text(text, key_start, key_end=None):
-    """逻辑块提取引擎，支持长文本切片"""
     try:
-        if key_end:
-            pattern = rf"{key_start}:(.*?){key_end}:"
-        else:
-            pattern = rf"{key_start}:(.*)"
-        match = re.search(pattern, text, re.DOTALL | re.IGNORECASE)
+        p = rf"{key_start}:(.*?){key_end}:" if key_end else rf"{key_start}:(.*)"
+        match = re.search(p, text, re.DOTALL | re.IGNORECASE)
         if match:
-            content = match.group(1).strip()
-            # 过滤 Markdown 字符防止渲染崩溃
-            return content.replace('*', '').replace('`', '').strip()
+            return match.group(1).strip().replace('*', '').replace('`', '').strip()
         return "N/A"
-    except Exception: return "N/A"
+    except: return "N/A"
 
 async def call_gemini_multiplex(prompt, attachment=None):
     """
     [Core Logic] 8 密钥自动轮询与故障转移
-    异步多密钥池轮询请求核心 | 具备 429 限流自动熔断机制
     """
-    if not KEY_POOL: 
-        logger.error("Request Blocked: No API Keys available.")
-        return "ERROR: NO_KEYS_CONFIGURED"
+    if not KEY_POOL: return "ERROR: NO_KEYS_CONFIGURED"
     
     image_data = None
     if attachment:
-        try:
-            image_data = await attachment.read()
-        except Exception as e:
-            logger.error(f"Attachment Read Error: {e}")
-            return "ERROR: IMG_READ_FAIL"
+        try: image_data = await attachment.read()
+        except: return "ERROR: IMG_READ_FAIL"
 
     loop = asyncio.get_running_loop()
-    
-    # 随机打乱密钥顺序以实现负载均衡
     shuffled_keys = list(KEY_POOL)
     random.shuffle(shuffled_keys)
 
     for i, api_key in enumerate(shuffled_keys):
         try:
-            # 实例化客户端
             client = genai.Client(api_key=api_key)
-            req_contents = [prompt]
+            contents = [prompt]
             if image_data:
-                req_contents.append(types.Part.from_bytes(data=image_data, mime_type='image/png'))
+                contents.append(types.Part.from_bytes(data=image_data, mime_type='image/png'))
 
-            # 使用线程池执行同步 SDK 调用以防阻塞事件循环
             response = await loop.run_in_executor(
                 None, 
-                functools.partial(client.models.generate_content, model="gemini-1.5-flash", contents=req_contents)
+                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}/{len(KEY_POOL)} Rate Limited (429). Switching...")
-                continue # 立即尝试下一个密钥
-            elif "400" in err_msg: # 图片格式错误等
-                logger.error(f"❌ Bad Request: {err_msg}")
-                return "ERROR: BAD_REQUEST"
-            else:
-                logger.error(f"🤖 Gemini Error on Key {i+1}: {err_msg}")
-                continue # 尝试下一个
+                logger.warning(f"⚠️ Key {i+1} Rate Limited. Switching...")
+                continue
+            logger.error(f"🤖 Key {i+1} Error: {err_msg}")
+            continue
 
     return "ERROR: ALL_KEYS_EXHAUSTED"
 
 # ==============================================================================
-# 5. 模块一：全网天梯与个人档案 (Rank & Profile)
+# 5. 模块一：全网天梯 (Leaderboard)
 # ==============================================================================
 @bot.command()
 async def profile(ctx, member: discord.Member = None):
-    """
-    展现量化交易员的详细画像与 ELO 评级
-    """
     target = member or ctx.author
     u = bk_engine.get_user(target.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
@@ -346,98 +273,65 @@ async def profile(ctx, member: discord.Member = None):
     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)
+    
+    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)
 
-    f_name = u['faction']
-    f_emoji = bk_engine.data["factions"].get(f_name, {}).get("emoji", "🌐") if f_name else "Ronin"
-    emb.add_field(name="Faction", value=f"{f_emoji} {f_name or 'Unassigned'}", inline=True)
-
-    # 展开性能统计指标
-    perf_stats = (
+    stats = (
         f"Total Audits: {u['audits_count']}\n"
-        f"Peak Audit Score: {u['highest_score']:.2f}\n"
-        f"Historical MDD: {u.get('mdd_record', 0):.2f}%\n"
-        f"Max Win Streak: {u['win_streak']}"
+        f"Peak Score: {u['highest_score']:.1f}\n"
+        f"Max MDD: {u.get('mdd_record',0):.2f}%"
     )
-    emb.add_field(name="Risk-Adjusted Performance", value=f"```yaml\n{perf_stats}\n```", inline=False)
-
-    if target.avatar:
-        emb.set_thumbnail(url=target.avatar.url)
+    emb.add_field(name="Performance Metrics", value=f"```yaml\n{stats}\n```", inline=False)
     
-    emb.set_footer(text=f"System Session: {SESSION_ID} | Node: HuggingFace")
+    if target.avatar: emb.set_thumbnail(url=target.avatar.url)
+    emb.set_footer(text=f"Session: {SESSION_ID} | Node: HuggingFace")
     await ctx.send(embed=emb)
 
 @bot.command()
 async def leaderboard(ctx):
-    """
-    全量天梯对账，展示排名前 10 的顶级交易员
-    """
-    all_users = []
-    for uid, data in bk_engine.data["users"].items():
-        all_users.append({"id": uid, "elo": data["elo"], "score": data["highest_score"]})
-
-    # 按 ELO 排序
-    top_elo = sorted(all_users, key=lambda x: x["elo"], reverse=True)[:10]
-
+    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]
+    
     desc = ""
-    for idx, u in enumerate(top_elo):
-        medal = "🥇" if idx == 0 else "🥈" if idx == 1 else "🥉" if idx == 2 else f"{idx+1}."
-        desc += f"{medal} <@{u['id']}> : ELO **{u['elo']}** | Peak Score: **{u['score']:.1f}**\n"
-
-    emb = discord.Embed(
-        title="🏆 BK-GTA Institutional Leaderboard", 
-        description=desc or "Scanning market data... (Waiting for submissions)", 
-        color=0xf1c40f
-    )
+    for i, u in enumerate(top):
+        icon = ["🥇","🥈","🥉"][i] if i < 3 else f"{i+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)
+    
+    # 阵营战况
+    f_txt = ""
+    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 = ""
-    for name, info in bk_engine.data["factions"].items():
-        f_info += f"{info['emoji']} {name}: {info['score']} pts  "
-    if f_info:
-        emb.add_field(name="⚔️ Faction War Status", value=f_info, inline=False)
-
     await ctx.send(embed=emb)
 
 # ==============================================================================
-# 6. 模块二：宏观情报分析 (Macro Intelligence Engine)
+# 6. 模块二：宏观情报 (Macro Intelligence)
 # ==============================================================================
 @bot.command()
 async def news(ctx):
-    """
-    分析新闻/报表截图，并基于机构逻辑给出宏观评分
-    """
-    if not ctx.message.attachments:
-        return await ctx.send("❌ Audit Refused: 请上传新闻图表。")
-
-    m = await ctx.send("📡 **[HF-Node] Parsing Macro Pulse...**")
-
+    if not ctx.message.attachments: return await ctx.send("❌ Audit Refused: Please upload an image.")
+    m = await ctx.send("📡 **[HF-Node] Analyzing Macro Pulse...**")
+    
     prompt = (
-        "你是一名对冲基金首席策略师。请解析此截图并输出：\n"
-        "1. 情绪评分 (SCORE): -10 (极度利空) 到 +10 (极度利多)。\n"
-        "2. 核心变量 (SUMMARY): 30字内概括。\n"
-        "3. 隐含逻辑 (TAKE): 机构视角的解读 (100字内)。\n"
-        "输出格式必须严格如下：\n"
-        "SCORE: [分值]\n"
-        "SUMMARY: [内容]\n"
-        "TAKE: [解读]"
+        "Analyze chart/news. Output: SCORE: (-10 to 10), SUMMARY: (text), TAKE: (institutional view). "
+        "Format: SCORE: [v] SUMMARY: [v] TAKE: [v]"
     )
-
     res = await call_gemini_multiplex(prompt, ctx.message.attachments[0])
     
-    if "ERROR" in res:
-        await m.delete()
-        return await ctx.send("🔴 [Audit Failure] Intelligence node offline.")
-
     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 Sentiment Pulse", 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 Analysis", value=f"```\n{take}\n```", inline=False)
-
+    
+    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)
+    
     await m.delete()
     await ctx.send(embed=emb)
 
@@ -447,39 +341,28 @@ async def news(ctx):
 @bot.command()
 async def evaluate(ctx):
     """
-    基于截图全维度识别回测/实盘参数，并执行风控打分。
-    带有并发锁 (Semaphore) 防止 HF 容器 OOM。
+    带有并发锁的审计功能，防止 HF 容器 OOM
     """
-    if not ctx.message.attachments:
-        return await ctx.send("❌ Audit Refused: 请上传结算单或净值曲线。")
-
+    if not ctx.message.attachments: return await ctx.send("❌ No image detected.")
+    
     # [Lock Check] 检查是否忙碌
     if audit_lock.locked():
-        return await ctx.send("⚠️ **[System Busy]** Another audit is processing. Please wait 10s to prevent memory overflow.")
+        return await ctx.send("⚠️ **[System Busy]** Another audit is processing. Please wait 10s.")
 
     async with audit_lock:
-        sid = random.randint(1000, 9999)
-        m = await ctx.send(f"🛡️ **[SID:{sid}] Audit Engine Initializing... (Locked Mode)**")
-
-        # 深度审计 Prompt
+        m = await ctx.send("🛡️ **[Audit Engine] Processing... (Locked)**")
         prompt = (
-            "你是一名顶级量化风险官。请执行全维度审计。\n"
-            "【提取要求】：\n"
-            "1. 核心指标：RET(收益率), MDD(最大回撤), PF(盈利因子), SHARPE(夏普), TRADES(笔数)。\n"
-            "2. 亮点 (H_ZH): 中文优势概括。\n"
-            "3. 评分 (S_BASE): 基础评分 (0-100)。\n"
-            "4. 否决项 (VIOLATION): MDD > 35% 或 交易笔数 < 10 时为 TRUE。\n"
-            "输出格式：\n"
-            "RET: [值]\nMDD: [值]\nPF: [值]\nSHARPE: [值]\nTRADES: [笔数]\nS_BASE: [分]\nVIOLATION: [TRUE/FALSE]\nH_ZH: [优势]"
+            "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]"
         )
-
+        
         res = await call_gemini_multiplex(prompt, ctx.message.attachments[0])
-
+        
         if "ERROR" in res:
             await m.delete()
-            return await ctx.send("🔴 [Audit Crash] Engine disconnected.")
+            return await ctx.send(f"🔴 Audit Failed: {res}")
 
-        # 提取数值
         ret = safe_extract_float(res, "RET")
         mdd = safe_extract_float(res, "MDD")
         pf = safe_extract_float(res, "PF")
@@ -488,199 +371,134 @@ async def evaluate(ctx):
         s_base = safe_extract_float(res, "S_BASE")
         violation = "TRUE" in res.upper()
 
-        # 逻辑加权算法展开：S = S_base * (log10(Trades)/1.5) * Sharpe_Factor
-        # 如果 MDD > 35%，执行风控一票否决
         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 = 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 = "✅ AUDIT CLEARED"
+            status = "CLEARED"
             color = 0x2ecc71
 
-        # 持久化
         bk_engine.update_audit_stats(ctx.author.id, s_final, mdd, sharpe)
-        h_zh = safe_extract_text(res, "H_ZH")
-
-        emb = discord.Embed(title="🛡️ BK-GTA Gene Audit Report", color=color)
-        emb.add_field(name="Verdict", value=f"**{status}**", inline=False)
         
-        metrics = (
-            f"💰 Return: {ret}% | MDD: {mdd}%\n"
-            f"⚖️ PF: {pf} | Sharpe: {sharpe}\n"
-            f"🎯 Sample Size: {trades} trades"
-        )
-        emb.add_field(name="Data Extraction", value=f"```\n{metrics}\n```", inline=False)
-        emb.add_field(name="Analysis Score", value=f"**{s_final:.2f} / 100**", inline=True)
-        emb.add_field(name="Highlights", value=h_zh, inline=False)
+        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.set_footer(text=f"SID: {sid} | Assets +50")
         await m.delete()
         await ctx.send(embed=emb)
 
 # ==============================================================================
-# 8. 模块四：博弈盘口 (Institutional Betting System)
+# 8. 模块四：博弈盘口 (Betting System)
 # ==============================================================================
 @bot.command()
 @commands.has_permissions(administrator=True)
-async def open_bet(ctx, *, topic: str):
-    """
-    由合伙人开启的宏观/行情博弈盘口
-    """
+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": {},
+        "topic": topic, 
+        "up": 0, "down": 0, 
+        "u_up": {}, "u_down": {}, 
         "status": "OPEN",
         "start_time": str(datetime.datetime.now())
     }
-    await ctx.send(f"🎰 **[Bet-ID:{bid}]** New Market Entry!\nTopic: **{topic}**\nJoin: `!bet {bid} UP/DOWN [Amt]`")
+    await ctx.send(f"🎰 **Bet Market Open [{bid}]**\nTopic: {topic}\nType `!bet {bid} UP 100` to join.")
 
 @bot.command()
 async def bet(ctx, bid: str, side: str, amt: int):
-    """
-    交易员消耗积分参与盘口对冲
-    """
-    if bid not in bk_engine.active_bets:
-        return await ctx.send("❌ Error: Invalid Bet ID.")
-    
-    b = bk_engine.active_bets[bid]
-    if b["status"] != "OPEN":
-        return await ctx.send("❌ Error: This market is closed.")
-
+    if bid not in bk_engine.active_bets or bk_engine.active_bets[bid]["status"] != "OPEN": return
     u = bk_engine.get_user(ctx.author.id)
-    if u["points"] < amt or amt <= 0:
-        return await ctx.send("❌ Error: Insufficient asset points.")
-
-    side = side.upper()
-    if side not in ["UP", "DOWN"]:
-        return await ctx.send("❌ Error: Choose UP or DOWN.")
-
-    # 锁定积分
-    u["points"] -= amt
-    uid = str(ctx.author.id)
+    if u["points"] < amt: return await ctx.send("❌ Insufficient funds.")
+    
+    u["points"] -= amt; side = side.upper()
+    if side not in ["UP", "DOWN"]: return await ctx.send("❌ Choose UP or DOWN.")
     
-    pool_key = "u_up" if side == "UP" else "u_down"
+    pool = "u_up" if side == "UP" else "u_down"
+    b = bk_engine.active_bets[bid]
     b[side.lower()] += amt
-    b[pool_key][uid] = b[pool_key].get(uid, 0) + amt
-
+    b[pool][str(ctx.author.id)] = b[pool].get(str(ctx.author.id), 0) + amt
     bk_engine.save_db()
-    await ctx.send(f"✅ Position Locked: {ctx.author.name} added {amt} to {side} pool.")
+    await ctx.send(f"✅ Bet {amt} on {side} confirmed.")
 
 @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_win = b["up"] if winner == "UP" else b["down"]
-    total_lose = b["down"] if winner == "UP" else b["up"]
-
-    if total_win > 0:
+    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_win) * total_lose
-            user = bk_engine.get_user(int(uid))
-            user["points"] += round(amt + profit)
+            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}**. Profits Distributed.")
+    await ctx.send(f"🏁 Bet {bid} Settled. Winner: {winner}. Payouts Distributed.")
 
 # ==============================================================================
-# 9. 模块五：PVP 竞技场 (Arena PvP Engine)
+# 9. 模块五：PVP 竞技场 (Arena)
 # ==============================================================================
 @bot.command()
 async def challenge(ctx, member: discord.Member):
-    """
-    发起基于量化能力的 1对1 竞技
-    """
-    if member.id == ctx.author.id:
-        return await ctx.send("❌ Logical Error: 不能向自己发起决斗。")
-
-    did = f"DUEL-{random.randint(100, 999)}"
-    bk_engine.pending_challenges[member.id] = {
-        "challenger": ctx.author.id,
-        "did": did,
-        "expiry": datetime.datetime.now() + datetime.timedelta(hours=1)
-    }
-
-    await ctx.send(f"⚔️ **{ctx.author.name}** 发起决斗请求！目标：{member.mention}\nID: `{did}` | `!accept` 接受。")
+    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.")
 
 @bot.command()
 async def accept(ctx):
-    """
-    接受竞技场挑战
-    """
-    if ctx.author.id not in bk_engine.pending_challenges:
-        return await ctx.send("❌ Error: No pending challenges.")
-
+    if ctx.author.id not in bk_engine.pending_challenges: return
     req = bk_engine.pending_challenges.pop(ctx.author.id)
-    did = req["did"]
-
-    bk_engine.active_duels[did] = {
-        "p1": req["challenger"], "p2": ctx.author.id,
-        "s1": None, "s2": None,
-        "start": str(datetime.datetime.now())
-    }
-
-    await ctx.send(f"🔥 **ARENA LOCKED!** Duel ID: `{did}`\n双方请通过 `!duel_submit {did}` 上传审计截图。")
+    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']}`")
 
 @bot.command()
 async def duel_submit(ctx, did: str):
-    """
-    在对决中提交截图，执行最终胜负判定
-    """
-    if did not in bk_engine.active_duels:
-        return await ctx.send("❌ Error: Duel not active.")
-
-    if not ctx.message.attachments:
-        return await ctx.send("❌ Refused: 请上传结算截图。")
-
+    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(f"🔍 **[Arena] Auditing Submission...**")
-    prompt = "Arena Duel Audit: Identify Audit Score (0-100). FORMAT: SCORE: [val]"
-    res = await call_gemini_multiplex(prompt, ctx.message.attachments[0])
+    
+    m = await ctx.send("🔍 Auditing duel submission...")
+    res = await call_gemini_multiplex("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:
-        wid, lid = (duel["p1"], duel["p2"]) if duel["s1"] > duel["s2"] else (duel["p2"], duel["p1"])
-        new_w, new_l, strk = bk_engine.update_elo(wid, lid)
-
-        emb = discord.Embed(title="🏆 Arena Final Verdict", color=0xf1c40f)
-        emb.add_field(name="🥇 Winner", value=f"<@{wid}>\nScore: {max(duel['s1'], duel['s2']):.1f}\nNew ELO: {new_w}", inline=True)
-        emb.add_field(name="🥈 Loser", value=f"<@{lid}>\nScore: {min(duel['s1'], duel['s2']):.1f}\nNew ELO: {new_l}", inline=True)
-        emb.set_footer(text=f"Streak: {strk} | Duel ID: {did}")
+        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)
         
+        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}")
         await ctx.send(embed=emb)
         del bk_engine.active_duels[did]
     else:
-        await ctx.send(f"✅ Submission Received (Score: {score:.1f}). Waiting for Opponent...")
-    
+        await ctx.send(f"✅ Score {score} recorded. Waiting for opponent.")
     await m.delete()
 
 # ==============================================================================
-# 10. 模块六：病毒式海报渲染 (Social Poster Engine)
+# 10. 模块六：海报渲染 (Full Viral Poster)
 # ==============================================================================
 @bot.command()
 async def viral_audit(ctx):
     """
-    提取审计数据并渲染具备社交传播属性的海报图片
+    [完整版] 提取审计数据并渲染具备社交传播属性的海报图片
     包含完整的 PIL 绘图逻辑，无省略。
     """
     if not ctx.message.attachments:
@@ -729,52 +547,39 @@ async def viral_audit(ctx):
         await m.delete()
 
 # ==============================================================================
-# 11. 系统对账与自动化任务 (System Reliability)
+# 11. 启动引擎 (Gradio + Discord Thread)
 # ==============================================================================
 @tasks.loop(hours=1)
 async def auto_backup():
-    """本地资产数据库每小时原子化备份"""
     bk_engine.save_db()
-    logger.info("💾 [Checkpoint] Data persistence 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-Node Ultimate"))
+    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}")
 
-    logger.info(f"--------------------------------------------------")
-    logger.info(f"✅ [V62.9-HF-Titan] BK-GTA Architecture Online")
-    logger.info(f"🚀 Session: {SESSION_ID} | Logic Integrity: Full")
-    logger.info(f"🛡️ Sentinel Port: 7860 (Active)")
-    logger.info(f"--------------------------------------------------")
-
-@bot.event
-async def on_command_error(ctx, error):
-    """全局错误拦截器，严禁静默失效"""
-    if isinstance(error, commands.CommandNotFound): return
-    if isinstance(error, commands.MissingPermissions):
-        return await ctx.send("❌ 权限审计未通过：仅限合伙人执行。")
-    
-    # 堆栈追踪打印至 Console
-    exc = "".join(traceback.format_exception(type(error), error, error.__traceback__))
-    logger.error(f"🔥 [System Crash] {exc}")
-    await ctx.send(f"⚠️ [Logic Breach] 内部逻辑断裂: `{error}`")
-
-# ==============================================================================
-# 12. 物理点火启动链 (Physical Start Engine)
-# ==============================================================================
-if __name__ == "__main__":
-    # 1. 物理启动 Web 哨兵接口 (Port 7860)
-    keep_alive()
-
-    # 2. 逻辑启动 Discord Bot 核心
-    if not DISCORD_TOKEN:
-        logger.critical("❌ CRITICAL: DISCORD_TOKEN is missing in environment.")
-    else:
+def run_discord_bot():
+    if DISCORD_TOKEN:
         try:
             bot.run(DISCORD_TOKEN)
         except Exception as e:
-            logger.critical(f"🔥 FINAL ENGINE COLLAPSE: {e}")
+            logger.critical(f"Bot Crash: {e}")
+    else:
+        logger.critical("No Token")
+
+if __name__ == "__main__":
+    # 1. 在后台线程启动 Discord 机器人 (非阻塞)
+    threading.Thread(target=run_discord_bot).start()
+    
+    # 2. 在主线程启动 Gradio UI (这是 HF 要求的保活入口)
+    # 这会生成一个网页，显示 JSON 状态，UptimeRobot 访问这个网页就能保活
+    iface = gr.Interface(
+        fn=get_status, 
+        inputs=None, 
+        outputs="json", 
+        title="BK-GTA Sentinel",
+        description="Core logic is running in background thread.",
+        every=5 # 自动刷新
+    )
+    iface.launch(server_name="0.0.0.0", server_port=7860)