Update start.sh

start.sh

@@ -47,8 +47,11 @@ app = Flask('kitakaze')
 SELF = '3823042923'
 API_BASE = 'http://127.0.0.1:7667'
 
-HF_SPACE_URL = "ffzeroHua/Jiantao"
-HF_TOKEN = os.getenv("HF_TOKEN")
+HF_SPACE_URL = "https://hf.4z.autos/" 
+HF_TOKEN = os.getenv('HF_TOKEN')
+
+# 如果你的 Hugging Face 仓库是 Private 的，必须在请求头里带上 Token 才能访问 API
+HEADERS = {"Authorization": f"Bearer {HF_TOKEN}"} if HF_TOKEN else {}
 
 try:
     print("正在初始化 Hugging Face 云端连接...")
@@ -75,24 +78,59 @@ def Send(msg, uid, gid=None):
 
 def ContainsRoundInfo(s): return '局' in s or '本场' in s
 
+def extract_paipu_id(paipu_url_or_msg):
+    """在本地计算牌谱 ID，确保生成的链接与云端保存的文件名完全一致"""
+    match = re.search(r'log=([\w-]+)', paipu_url_or_msg)
+    if match:
+        return match.group(1)
+    return hashlib.md5(paipu_url_or_msg.encode('utf-8')).hexdigest()
+
 def start_analyze(mid, uid, gid, msg, hanchan=False):
     def analyze_task():
         try:
-            response_str = hf_client.predict(msg, hanchan)
-            result_data = json.loads(response_str)
+            # 1. 提取或生成本次请求对应的 ID
+            paipu_id = extract_paipu_id(msg)
+            
+            # 2. 准备 HTTP 请求，目标是我们刚才用 FastAPI 写好的兼容接口
+            # 注意：如果 URL 结尾有斜杠则去掉，防止拼出双斜杠
+            api_endpoint = HF_SPACE_URL.rstrip('/') + "/api/predict"
+            payload = {"data": [msg, hanchan]}
+            
+            # 3. 发送纯正的 POST 请求（设置超时时间，以防云端检讨太久假死）
+            response = requests.post(
+                api_endpoint, 
+                json=payload, 
+                headers=HEADERS, 
+                timeout=180
+            )
+            response.raise_for_status() # 如果是 401/404/500 等 HTTP 错误会直接跳入 except
+            
+            # 4. 解析后端返回的 JSON 数据
+            # 后端返回格式是 {"data": ["{真正的结果JSON字符串}"]}
+            response_json = response.json()
+            result_str = response_json.get("data", ["{}"])[0]
+            result_data = json.loads(result_str)
+            
+            # 5. 业务错误处理
             if "error" in result_data:
-                Send(Reply(mid) + f"云端检讨失败，可能牌谱链接有误\n（{result_data['error'][:50]}...）", uid, gid)
+                error_msg = str(result_data['error'])[:50]
+                Send(Reply(mid) + f"云端检讨失败，可能牌谱链接有误\n（{error_msg}...）", uid, gid)
                 return
-            os.makedirs('reviewreports', exist_ok=True)
-            ID = hex(int(time.time()))
-            filename = f"reviewreports/{ID}.json"
-            with open(filename, 'w', encoding='utf-8') as f:
-                json.dump(result_data.get("logs", []), f, ensure_ascii=False)
+                
+            # 6. 构造最终要发送给用户的消息（不再需要把 result_data 写入本地磁盘）
             overall_rating = result_data.get("overall_rating", 0.0)
-            final_msg = f'看完啦！\nhttps://online.4z.autos/?id={ID}\n总体评分 {overall_rating}'
+            final_msg = f'看完啦！\nhttps://online.4z.autos/?id={paipu_id}\n总体评分 {overall_rating}'
+            
             Send(Reply(mid) + final_msg, uid, gid)
+            
+        except requests.exceptions.RequestException as e:
+            print(f"HTTP 通信出错: {e}")
+            Send(Reply(mid) + '有点不懂，改日再看\n（云端连接断开或超时）', uid, gid)
         except Exception as e:
-            Send(Reply(mid) + '有点不懂，改日再看\n（本地调度或网络通信出错）', uid, gid)
+            print(f"解析或调度出错: {e}")
+            Send(Reply(mid) + '有点不懂，改日再看\n（客户端处理异常）', uid, gid)
+
+    # 启动后台线程
     thread = threading.Thread(target=analyze_task)
     thread.daemon = True  
     thread.start()