Upload app.py

app.py

@@ -5,6 +5,7 @@ import json
 import time
 import logging
 import hashlib
+import uuid
 from datetime import datetime
 
 logging.basicConfig(level=logging.INFO, format="%(asctime)s [%(levelname)s] %(message)s")
@@ -413,12 +414,30 @@ def _count_chunks(scope):
 
 # --- 原始文件管理（Supabase Storage + uploaded_files 表）---
 
+def _safe_storage_path(scope, filename):
+    """生成 ASCII 安全的 Storage 路径（Supabase Storage 不支持中文/特殊字符）。"""
+    import os
+    ext = os.path.splitext(filename)[1].lower()  # 保留扩展名
+    safe_name = uuid.uuid4().hex[:16] + ext
+    return f"{scope}/{safe_name}"
+
+
 def _save_uploaded_file_to_storage(scope, uploaded_file):
     """上传原始文件到 Supabase Storage，并记录元数据。"""
-    storage_path = f"{scope}/{uploaded_file.name}"
     uploaded_file.seek(0)
     file_bytes = uploaded_file.read()
 
+    # 检查是否已有同名文件记录，复用其 storage_path
+    try:
+        existing = _sb().table("uploaded_files").select("storage_path").eq(
+            "scope", scope).eq("filename", uploaded_file.name).execute()
+        if existing.data:
+            storage_path = existing.data[0]["storage_path"]
+        else:
+            storage_path = _safe_storage_path(scope, uploaded_file.name)
+    except Exception:
+        storage_path = _safe_storage_path(scope, uploaded_file.name)
+
     # 上传到 Storage（存在则覆盖）
     try:
         _sb().storage.from_(STORAGE_BUCKET).upload(
@@ -426,7 +445,6 @@ def _save_uploaded_file_to_storage(scope, uploaded_file):
             file_options={"content-type": "application/octet-stream", "upsert": "true"}
         )
     except Exception as e:
-        # supabase-py 某些版本 upsert 需要先删再传
         logger.warning(f"Storage upload fallback: {e}")
         try:
             _sb().storage.from_(STORAGE_BUCKET).remove([storage_path])
@@ -437,7 +455,7 @@ def _save_uploaded_file_to_storage(scope, uploaded_file):
             file_options={"content-type": "application/octet-stream"}
         )
 
-    # 记录元数据到 uploaded_files 表
+    # 记录元数据到 uploaded_files 表（filename 保留原始中文名）
     _sb().table("uploaded_files").upsert({
         "scope": scope,
         "filename": uploaded_file.name,
@@ -471,9 +489,13 @@ def _list_uploaded_files_db(scope):
 
 def _delete_uploaded_file_from_storage(scope, filename):
     """删除 Storage 中的文件和 uploaded_files 表记录。"""
-    storage_path = f"{scope}/{filename}"
     try:
-        _sb().storage.from_(STORAGE_BUCKET).remove([storage_path])
+        # 从数据库查真实 storage_path
+        resp = _sb().table("uploaded_files").select("storage_path").eq(
+            "scope", scope).eq("filename", filename).execute()
+        if resp.data:
+            storage_path = resp.data[0]["storage_path"]
+            _sb().storage.from_(STORAGE_BUCKET).remove([storage_path])
     except Exception as e:
         logger.warning(f"Storage 删除失败: {e}")
     try: