Deploy v3.9.2 unified download manager

README.md

@@ -9,7 +9,7 @@ app_port: 7860
 
 # Global Marine Foundation Data Agent
 
-Current UI release: **v3.9.0**.
+Current UI release: **v3.9.2**.
 
 
 ## v3.4.0 稳定性重构（第一阶段）

VERSION

@@ -1 +1 @@
-3.9.0
+3.9.2

routes/downloads.py

@@ -0,0 +1,102 @@
+from __future__ import annotations
+
+import os
+from urllib.parse import urlparse
+
+import httpx
+from fastapi import HTTPException, Request
+from fastapi.responses import StreamingResponse
+
+def _inject(context):
+    globals().update(context)
+
+def _host_allowed(host: str) -> bool:
+    host=(host or "").lower().strip(".")
+    if not host:
+        return False
+
+    dynamic=set()
+    for value in (MARINE_API_URL, MEMORY_API_URL):
+        try:
+            parsed=urlparse(value)
+            if parsed.hostname:
+                dynamic.add(parsed.hostname.lower())
+        except Exception:
+            pass
+
+    extra={
+        x.strip().lower()
+        for x in os.environ.get("DOWNLOAD_PROXY_EXTRA_HOSTS","").split(",")
+        if x.strip()
+    }
+    if host in dynamic or host in extra:
+        return True
+
+    trusted_suffixes=(
+        "huggingface.co",
+        "hf.co",
+        "xethub.hf.co",
+    )
+    return any(host==suffix or host.endswith("."+suffix) for suffix in trusted_suffixes)
+
+async def proxy_download(request: Request):
+    await resolve_request_user(request)
+    url=str(request.query_params.get("url") or "").strip()
+    if not url:
+        raise HTTPException(400,"missing url")
+
+    try:
+        parsed=urlparse(url)
+    except Exception as exc:
+        raise HTTPException(400,"invalid url") from exc
+
+    if parsed.scheme not in {"http","https"}:
+        raise HTTPException(400,"unsupported url scheme")
+    if not _host_allowed(parsed.hostname or ""):
+        raise HTTPException(403,"external download host is not allowlisted")
+
+    client=httpx.AsyncClient(
+        follow_redirects=True,
+        timeout=httpx.Timeout(connect=15.0,read=None,write=30.0,pool=15.0),
+    )
+    try:
+        upstream=await client.send(
+            client.build_request("GET",url,headers={"User-Agent":"Global-Marine-Data-Agent/3.9.2"}),
+            stream=True,
+        )
+    except Exception:
+        await client.aclose()
+        raise
+
+    if upstream.status_code>=400:
+        body=await upstream.aread()
+        await upstream.aclose()
+        await client.aclose()
+        raise HTTPException(upstream.status_code,body[:500].decode("utf-8","replace"))
+
+    async def body_iter():
+        try:
+            async for chunk in upstream.aiter_bytes():
+                if chunk:
+                    yield chunk
+        finally:
+            await upstream.aclose()
+            await client.aclose()
+
+    headers={}
+    for key in ("content-length","content-type","content-disposition","etag","last-modified"):
+        value=upstream.headers.get(key)
+        if value:
+            headers[key]=value
+    headers["cache-control"]="no-store"
+    headers["x-download-proxied"]="1"
+
+    return StreamingResponse(
+        body_iter(),
+        media_type=upstream.headers.get("content-type","application/octet-stream"),
+        headers=headers,
+    )
+
+def register_download_routes(app, context):
+    _inject(context)
+    app.add_api_route("/api/download/proxy",proxy_download,methods=["GET"])

static/css/app.css

@@ -664,3 +664,23 @@ body.sidebar-tools-collapsed .primary-tools{
 .uq-row span{min-width:0;white-space:nowrap;overflow:hidden;text-overflow:ellipsis;color:#9fc0d8;font-size:11.5px}
 .uq-row small{color:#7191aa}
 @media(max-width:900px){.uq-plan-grid{grid-template-columns:1fr 1fr}.uq-row{grid-template-columns:1fr}.uq-row span{white-space:normal}}
+
+
+.download-progress-overlay{position:fixed;inset:0;z-index:9999;display:none;align-items:flex-end;justify-content:flex-end;padding:22px;pointer-events:none}
+.download-progress-overlay.show{display:flex}
+.download-progress-card{width:min(430px,calc(100vw - 28px));pointer-events:auto;border:1px solid rgba(103,180,238,.25);border-radius:16px;padding:14px 15px;background:rgba(3,22,40,.96);box-shadow:0 18px 50px rgba(0,0,0,.38);backdrop-filter:blur(16px)}
+.download-progress-head{display:flex;align-items:flex-start;justify-content:space-between;gap:12px}
+.download-progress-head b{display:block;font-size:13px}
+.download-progress-head span{display:block;color:var(--muted);font-size:11px;margin-top:4px}
+.download-progress-close{border:0;background:transparent;color:#8eacc2;cursor:pointer;font-size:20px;line-height:1}
+.download-progress-track{height:9px;margin:13px 0 9px;border-radius:999px;overflow:hidden;background:rgba(255,255,255,.08)}
+.download-progress-bar{height:100%;width:0;border-radius:999px;background:linear-gradient(90deg,#398cff,#62d9ff);transition:width .18s linear}
+.download-progress-bar.indeterminate{width:36%;animation:download-indeterminate 1.2s ease-in-out infinite}
+.download-progress-bar.done{background:linear-gradient(90deg,#25b978,#6ce0aa)}
+.download-progress-bar.error{width:100%;background:linear-gradient(90deg,#c7465d,#ff8c9d)}
+.download-progress-meta{display:grid;grid-template-columns:1fr auto auto;gap:12px;font-size:10.5px;color:#9dbbd0}
+.download-progress-hint{margin-top:9px;color:#7898af;font-size:10.5px;line-height:1.5}
+.download-progress-actions{display:flex;justify-content:flex-end;margin-top:10px}
+@keyframes download-indeterminate{0%{transform:translateX(-120%)}50%{transform:translateX(120%)}100%{transform:translateX(280%)}}
+
+.download-progress-source{font-size:10px;color:#6f8ca1;margin-top:5px}

static/js/app.js

@@ -126,8 +126,7 @@ async function pushWorkspaceToServer(){if(!AUTH_ENABLED||!AUTH_TOKEN)return;WORK
 async function syncWorkspaceFromServer(){if(!AUTH_ENABLED||!AUTH_TOKEN){WORKSPACE_SYNC={enabled:false,storage_mode:"local",status:"local"};return}try{const localSessions=loadSessions(),localSettings=loadSettings();const data=await j("/api/sidebar/workspace?user_id="+encodeURIComponent(USER_ID));S=mergeSessions(data.sessions||[],localSessions);SETTINGS={...SETTINGS,...localSettings,...(data.settings||{})};localStorage.setItem(K,JSON.stringify(S.slice(0,50)));localStorage.setItem(scopedKey(SETTINGS_BASE_K),JSON.stringify(SETTINGS));WORKSPACE_SYNC={enabled:!!data.sync_enabled,storage_mode:data.storage_mode||"server_session",status:"synced"};if(localSessions.length||Object.keys(localSettings||{}).length)await pushWorkspaceToServer()}catch(err){WORKSPACE_SYNC={enabled:false,storage_mode:"local",status:"error"};console.warn("workspace sync failed",err)}}
 function exportWorkspaceBackup(){
   const payload={schema:"squid-workspace-backup",schema_version:1,app_version:APP_VERSION,exported_at:new Date().toISOString(),sessions:S.slice(0,50),favorites:FAVORITES.slice(0,100),settings:SETTINGS};
-  const blob=new Blob([JSON.stringify(payload,null,2)],{type:"application/json;charset=utf-8"}),url=URL.createObjectURL(blob),a=document.createElement("a");
-  a.href=url;a.download="squid_workspace_backup_"+new Date().toISOString().slice(0,10)+".json";a.click();setTimeout(()=>URL.revokeObjectURL(url),1000);toast("本地工作区备份已导出")
+  const blob=new Blob([JSON.stringify(payload,null,2)],{type:"application/json;charset=utf-8"});saveBlobWithProgress(blob,"squid_workspace_backup_"+new Date().toISOString().slice(0,10)+".json",{title:"正在导出工作区备份"});toast("本地工作区备份已导出")
 }
 async function importWorkspaceBackup(file){
   if(!file)return;if(file.size>5*1024*1024)throw Error("备份文件不能超过 5 MB");
@@ -822,22 +821,22 @@ async function openDatasetComparison(items){
   if(items.length<2){toast("请先选择至少 2 个数据集");return}
   document.querySelector(".drawer-backdrop")?.remove();const wrap=document.createElement("div");wrap.className="drawer-backdrop";
   wrap.innerHTML='<aside class="detail-drawer" role="dialog" aria-modal="true" aria-label="数据集对比"><div class="drawer-head"><div><h2>数据集对比</h2><p>正在读取 '+items.length+' 个数据源的最新详情</p></div><div class="view-actions"><button class="view-btn compare-export" disabled>↓ 导出 CSV</button><button class="drawer-close" aria-label="关闭">×</button></div></div><div class="comparison-live"><div class="loading">正在生成对比…</div></div></aside>';document.body.appendChild(wrap);const close=()=>wrap.remove();wrap.querySelector(".drawer-close").onclick=close;wrap.onclick=e=>{if(e.target===wrap)close()};
-  try{const details=await Promise.all(items.map(x=>fetchDatasetDetail(x).catch(()=>x)));if(!wrap.isConnected)return;const rows=[{label:"接入状态",value:x=>datasetStatusLabel(x.status)},{label:"元数据完整度",value:x=>(x.metadata_completeness?.score??0)+"%（"+(x.metadata_completeness?.present_count??0)+" / "+(x.metadata_completeness?.expected_count??7)+"）"},{label:"数据平面",value:x=>x.metadata?.data_plane||x.group},{label:"变量",value:x=>(x.variables||[]).map(v=>v+((x.variable_labels||{})[v]?" / "+x.variable_labels[v]:"")).join("、")||"读取具体文件确认"},{label:"匹配文件",value:x=>x.metadata?.file_count||"不适用 / 未返回"},{label:"数据量",value:x=>x.metadata?.total_size||"未返回"},{label:"时间范围",value:x=>x.metadata?.time_range||"实时接口未提供"},{label:"时间分辨率",value:x=>x.metadata?.temporal_resolution||"实时接口未提供"},{label:"空间分辨率",value:x=>x.metadata?.spatial_resolution||"实时接口未提供"},{label:"数据形态",value:x=>x.reference?.data_shape||"读取具体文件确认"},{label:"详情来源",value:x=>(x.provenance||[]).join("；")||"当前卡片摘要"}];wrap.querySelector(".comparison-live").innerHTML='<div class="compare-wrap"><table class="compare-table"><thead><tr><th>对比项</th>'+details.map(x=>'<th>'+esc(x.name)+'<br><span class="dataset-zh">'+esc(x.name_zh||"")+'</span></th>').join("")+'</tr></thead><tbody>'+rows.map(row=>'<tr><td>'+esc(row.label)+'</td>'+details.map(x=>'<td>'+esc(datasetMetaValue(row.value(x)))+'</td>').join("")+'</tr>').join("")+'</tbody></table></div>';const exportBtn=wrap.querySelector(".compare-export");exportBtn.disabled=false;exportBtn.onclick=()=>{const csvRows=[["对比项",...details.map(x=>x.name+(x.name_zh?" · "+x.name_zh:""))],...rows.map(row=>[row.label,...details.map(x=>datasetMetaValue(row.value(x)))])],csv=csvRows.map(row=>row.map(v=>'"'+String(v??"").replace(/"/g,'""')+'"').join(",")).join("\r\n"),blob=new Blob(["\ufeff"+csv],{type:"text/csv;charset=utf-8"}),url=URL.createObjectURL(blob),a=document.createElement("a");a.href=url;a.download="marine_dataset_comparison_"+new Date().toISOString().slice(0,10)+".csv";a.click();setTimeout(()=>URL.revokeObjectURL(url),1000);toast("对比表已导出")}}catch(err){wrap.querySelector(".comparison-live").innerHTML='<div class="detail-note">对比读取失败：'+esc(err.message||String(err))+'</div>'}
+  try{const details=await Promise.all(items.map(x=>fetchDatasetDetail(x).catch(()=>x)));if(!wrap.isConnected)return;const rows=[{label:"接入状态",value:x=>datasetStatusLabel(x.status)},{label:"元数据完整度",value:x=>(x.metadata_completeness?.score??0)+"%（"+(x.metadata_completeness?.present_count??0)+" / "+(x.metadata_completeness?.expected_count??7)+"）"},{label:"数据平面",value:x=>x.metadata?.data_plane||x.group},{label:"变量",value:x=>(x.variables||[]).map(v=>v+((x.variable_labels||{})[v]?" / "+x.variable_labels[v]:"")).join("、")||"读取具体文件确认"},{label:"匹配文件",value:x=>x.metadata?.file_count||"不适用 / 未返回"},{label:"数据量",value:x=>x.metadata?.total_size||"未返回"},{label:"时间范围",value:x=>x.metadata?.time_range||"实时接口未提供"},{label:"时间分辨率",value:x=>x.metadata?.temporal_resolution||"实时接口未提供"},{label:"空间分辨率",value:x=>x.metadata?.spatial_resolution||"实时接口未提供"},{label:"数据形态",value:x=>x.reference?.data_shape||"读取具体文件确认"},{label:"详情来源",value:x=>(x.provenance||[]).join("；")||"当前卡片摘要"}];wrap.querySelector(".comparison-live").innerHTML='<div class="compare-wrap"><table class="compare-table"><thead><tr><th>对比项</th>'+details.map(x=>'<th>'+esc(x.name)+'<br><span class="dataset-zh">'+esc(x.name_zh||"")+'</span></th>').join("")+'</tr></thead><tbody>'+rows.map(row=>'<tr><td>'+esc(row.label)+'</td>'+details.map(x=>'<td>'+esc(datasetMetaValue(row.value(x)))+'</td>').join("")+'</tr>').join("")+'</tbody></table></div>';const exportBtn=wrap.querySelector(".compare-export");exportBtn.disabled=false;exportBtn.onclick=()=>{const csvRows=[["对比项",...details.map(x=>x.name+(x.name_zh?" · "+x.name_zh:""))],...rows.map(row=>[row.label,...details.map(x=>datasetMetaValue(row.value(x)))])],csv=csvRows.map(row=>row.map(v=>'"'+String(v??"").replace(/"/g,'""')+'"').join(",")).join("\r\n"),blob=new Blob(["\ufeff"+csv],{type:"text/csv;charset=utf-8"});saveBlobWithProgress(blob,"marine_dataset_comparison_"+new Date().toISOString().slice(0,10)+".csv",{title:"正在导出数据集对比表"});toast("对比表已导出")}}catch(err){wrap.querySelector(".comparison-live").innerHTML='<div class="detail-note">对比读取失败：'+esc(err.message||String(err))+'</div>'}
 }
 function exportDatasetInventory(items,updatedAt){
-  const rows=[["数据平面","分类","英文名称","中文名称","接入状态","匹配文件数","匹配数据量(B)","变量","匹配依据","路径示例","盘点时间"],...items.map(x=>[x.group,x.category_zh||"海洋环境",x.name,x.name_zh||"",datasetStatusLabel(x.status),x.file_count??"",x.size_bytes??"",(x.variables||[]).join(";"),x.metadata?.matching_rule||"",(x.examples||[]).join(";"),updatedAt||""])],csv=rows.map(row=>row.map(v=>'"'+String(v??"").replace(/"/g,'""')+'"').join(",")).join("\r\n"),blob=new Blob(["\ufeff"+csv],{type:"text/csv;charset=utf-8"}),url=URL.createObjectURL(blob),a=document.createElement("a");a.href=url;a.download="marine_dataset_live_inventory_"+new Date().toISOString().slice(0,10)+".csv";a.click();setTimeout(()=>URL.revokeObjectURL(url),1000);toast("实时盘点表已导出")
+  const rows=[["数据平面","分类","英文名称","中文名称","接入状态","匹配文件数","匹配数据量(B)","变量","匹配依据","路径示例","盘点时间"],...items.map(x=>[x.group,x.category_zh||"海洋环境",x.name,x.name_zh||"",datasetStatusLabel(x.status),x.file_count??"",x.size_bytes??"",(x.variables||[]).join(";"),x.metadata?.matching_rule||"",(x.examples||[]).join(";"),updatedAt||""])],csv=rows.map(row=>row.map(v=>'"'+String(v??"").replace(/"/g,'""')+'"').join(",")).join("\r\n"),blob=new Blob(["\ufeff"+csv],{type:"text/csv;charset=utf-8"});saveBlobWithProgress(blob,"marine_dataset_live_inventory_"+new Date().toISOString().slice(0,10)+".csv",{title:"正在导出实时盘点表"});toast("实时盘点表已导出")
 }
 function openDatasetQuality(){
   document.querySelector(".drawer-backdrop")?.remove();const wrap=document.createElement("div");wrap.className="drawer-backdrop";
   wrap.innerHTML='<aside class="detail-drawer" role="dialog" aria-modal="true" aria-label="仓库体检"><div class="drawer-head"><div><h2>Hugging Face 仓库体检</h2><p>基于 main 分支实时文件树的轻量检查</p></div><button class="drawer-close" aria-label="关闭">×</button></div><div class="quality-live"><div class="loading">正在检查仓库清单…</div></div><div class="card-actions"><button class="view-btn quality-refresh">↻ 重新体检</button><button class="view-btn quality-export" disabled>↓ 导出体检 JSON</button></div></aside>';document.body.appendChild(wrap);const close=()=>wrap.remove();wrap.querySelector(".drawer-close").onclick=close;wrap.onclick=e=>{if(e.target===wrap)close()};
-  const load=async(refresh=false)=>{const box=wrap.querySelector(".quality-live"),exportBtn=wrap.querySelector(".quality-export");box.innerHTML='<div class="loading">正在检查仓库清单…</div>';exportBtn.disabled=true;try{const d=await j("/api/sidebar/datasets/quality"+(refresh?"?refresh=true":""));if(!wrap.isConnected)return;const stats=[["实际文件",d.file_count],["数据总量",formatBytes(d.total_size_bytes)],["零字节文件",d.zero_byte_count],["同名文件组",d.duplicate_basename_group_count],["未归类文件",d.unmapped_file_count],["≥1 GB 文件",d.large_file_count]],extensions=Object.entries(d.extension_counts||{}).map(([k,v])=>'<span class="tag">'+esc(k)+' · '+esc(v)+'</span>').join(""),findings=(d.findings||[]).map(x=>'<div class="finding '+esc(x.severity)+'"><b>'+esc(x.title)+'</b><p>'+esc(x.detail)+'</p></div>').join("")||'<div class="finding info"><b>未发现清单级异常</b><p>仍建议继续进行文件内部字段和缺失值质检。</p></div>',dups=(d.duplicate_groups||[]).map(x=>'<li><b>'+esc(x.basename)+'</b> · '+esc(x.count)+' 个路径<br>'+esc((x.paths||[]).join("；"))+'</li>').join(""),unmapped=(d.unmapped_files||[]).map(x=>'<li>'+esc(x)+'</li>').join(""),large=(d.large_files||[]).map(x=>'<li>'+esc(x.path)+' · '+esc(x.size)+'</li>').join(""),notes=(d.notes||[]).map(x=>'<li>'+esc(x)+'</li>').join("");box.innerHTML='<div class="row-meta">仓库：'+esc(d.repository)+'@'+esc(d.branch)+' · 检查时间：'+esc(formatTime(d.checked_at))+' · 文件树对象：'+esc(d.tree_object_count)+'</div><div class="meta-grid">'+stats.map(x=>'<div class="meta-item"><span>'+esc(x[0])+'</span><b>'+esc(x[1])+'</b></div>').join("")+'</div><div class="detail-section"><h3>检查结论</h3>'+findings+'</div><div class="detail-section"><h3>文件类型分布</h3><div class="tags">'+extensions+'</div></div>'+(dups?'<div class="detail-section"><h3>同名文件组（不等同于内容重复）</h3><ul class="quality-list">'+dups+'</ul></div>':'')+(unmapped?'<div class="detail-section"><h3>未归类文件预览</h3><ul class="quality-list">'+unmapped+'</ul></div>':'')+(large?'<div class="detail-section"><h3>超大文件预览</h3><ul class="quality-list">'+large+'</ul></div>':'')+'<div class="detail-section"><h3>解释说明</h3><ul class="path-list">'+notes+'</ul></div>';exportBtn.disabled=false;exportBtn.onclick=()=>{const blob=new Blob([JSON.stringify(d,null,2)],{type:"application/json;charset=utf-8"}),url=URL.createObjectURL(blob),a=document.createElement("a");a.href=url;a.download="hf_fisheries_repository_quality_"+new Date().toISOString().slice(0,10)+".json";a.click();setTimeout(()=>URL.revokeObjectURL(url),1000);toast("体检报告已导出")}}catch(err){box.innerHTML='<div class="detail-note">仓库体检失败：'+esc(err.message||String(err))+'</div>'}};
+  const load=async(refresh=false)=>{const box=wrap.querySelector(".quality-live"),exportBtn=wrap.querySelector(".quality-export");box.innerHTML='<div class="loading">正在检查仓库清单…</div>';exportBtn.disabled=true;try{const d=await j("/api/sidebar/datasets/quality"+(refresh?"?refresh=true":""));if(!wrap.isConnected)return;const stats=[["实际文件",d.file_count],["数据总量",formatBytes(d.total_size_bytes)],["零字节文件",d.zero_byte_count],["同名文件组",d.duplicate_basename_group_count],["未归类文件",d.unmapped_file_count],["≥1 GB 文件",d.large_file_count]],extensions=Object.entries(d.extension_counts||{}).map(([k,v])=>'<span class="tag">'+esc(k)+' · '+esc(v)+'</span>').join(""),findings=(d.findings||[]).map(x=>'<div class="finding '+esc(x.severity)+'"><b>'+esc(x.title)+'</b><p>'+esc(x.detail)+'</p></div>').join("")||'<div class="finding info"><b>未发现清单级异常</b><p>仍建议继续进行文件内部字段和缺失值质检。</p></div>',dups=(d.duplicate_groups||[]).map(x=>'<li><b>'+esc(x.basename)+'</b> · '+esc(x.count)+' 个路径<br>'+esc((x.paths||[]).join("；"))+'</li>').join(""),unmapped=(d.unmapped_files||[]).map(x=>'<li>'+esc(x)+'</li>').join(""),large=(d.large_files||[]).map(x=>'<li>'+esc(x.path)+' · '+esc(x.size)+'</li>').join(""),notes=(d.notes||[]).map(x=>'<li>'+esc(x)+'</li>').join("");box.innerHTML='<div class="row-meta">仓库：'+esc(d.repository)+'@'+esc(d.branch)+' · 检查时间：'+esc(formatTime(d.checked_at))+' · 文件树对象：'+esc(d.tree_object_count)+'</div><div class="meta-grid">'+stats.map(x=>'<div class="meta-item"><span>'+esc(x[0])+'</span><b>'+esc(x[1])+'</b></div>').join("")+'</div><div class="detail-section"><h3>检查结论</h3>'+findings+'</div><div class="detail-section"><h3>文件类型分布</h3><div class="tags">'+extensions+'</div></div>'+(dups?'<div class="detail-section"><h3>同名文件组（不等同于内容重复）</h3><ul class="quality-list">'+dups+'</ul></div>':'')+(unmapped?'<div class="detail-section"><h3>未归类文件预览</h3><ul class="quality-list">'+unmapped+'</ul></div>':'')+(large?'<div class="detail-section"><h3>超大文件预览</h3><ul class="quality-list">'+large+'</ul></div>':'')+'<div class="detail-section"><h3>解释说明</h3><ul class="path-list">'+notes+'</ul></div>';exportBtn.disabled=false;exportBtn.onclick=()=>{const blob=new Blob([JSON.stringify(d,null,2)],{type:"application/json;charset=utf-8"});saveBlobWithProgress(blob,"hf_fisheries_repository_quality_"+new Date().toISOString().slice(0,10)+".json",{title:"正在导出仓库体检报告"});toast("体检报告已导出")}}catch(err){box.innerHTML='<div class="detail-note">仓库体检失败：'+esc(err.message||String(err))+'</div>'}};
   wrap.querySelector(".quality-refresh").onclick=()=>load(true);load()
 }
 function openMetadataAudit(){
   document.querySelector(".drawer-backdrop")?.remove();const wrap=document.createElement("div");wrap.className="drawer-backdrop";
   wrap.innerHTML='<aside class="detail-drawer" role="dialog" aria-modal="true" aria-label="元数据审计"><div class="drawer-head"><div><h2>数据集元数据审计</h2><p>核对核心盘点字段是否由实时接口或文件树提供</p></div><button class="drawer-close" aria-label="关闭">×</button></div><div class="metadata-audit-live"><div class="loading">正在审计元数据…</div></div><div class="card-actions"><button class="view-btn audit-refresh">↻ 重新审计</button><button class="view-btn audit-export" disabled>↓ 导出审计 CSV</button></div></aside>';
   document.body.appendChild(wrap);const close=()=>wrap.remove();wrap.querySelector(".drawer-close").onclick=close;wrap.onclick=e=>{if(e.target===wrap)close()};
-  const load=async(refresh=false)=>{const box=wrap.querySelector(".metadata-audit-live"),exportBtn=wrap.querySelector(".audit-export");box.innerHTML='<div class="loading">正在审计元数据…</div>';exportBtn.disabled=true;try{const d=await j("/api/sidebar/datasets/metadata-audit"+(refresh?"?refresh=true":"")),summary=d.summary||{},records=d.records||[],labels=DATASET_META_LABELS,rows=records.map(x=>{const c=x.completeness||{},missing=(c.missing_fields||[]).map(v=>labels[v]||v).join("、")||"无",pending=(c.pending_fields||[]).map(v=>labels[v]||v).join("、")||"无";return '<tr><td>'+esc(x.group)+'</td><td><b>'+esc(x.name)+'</b><br><span class="dataset-zh">'+esc(x.name_zh||"")+'</span></td><td>'+esc(datasetStatusLabel(x.status))+'</td><td>'+esc(c.score??0)+'%<br><span class="row-meta">'+esc(c.present_count||0)+' / '+esc(c.expected_count||0)+'</span></td><td>'+esc(missing)+'</td><td>'+esc(pending)+'</td><td>'+esc(x.action||"")+'</td></tr>'}).join("");box.innerHTML='<div class="row-meta">审计时间：'+esc(formatTime(d.checked_at))+'</div><div class="summary-grid"><div class="summary-card"><strong>'+esc(summary.dataset_count||0)+'</strong><span>审计数据源</span></div><div class="summary-card"><strong>'+esc(summary.average_score||0)+'%</strong><span>可审计元数据平均完整度</span></div><div class="summary-card"><strong>'+esc(summary.incomplete_count||0)+'</strong><span>仍有可审计字段缺失</span></div></div><div class="compare-wrap"><table class="compare-table"><thead><tr><th>数据平面</th><th>数据源</th><th>状态</th><th>完整度</th><th>缺失字段</th><th>待文件级核验</th><th>建议动作</th></tr></thead><tbody>'+rows+'</tbody></table></div><div class="detail-note">'+esc((d.notes||[]).join("；"))+'</div>';exportBtn.disabled=false;exportBtn.onclick=()=>{const csvRows=[["数据平面","英文名称","中文名称","接入状态","可审计元数据完整度(%)","已返回字段","缺失字段","待文件级核验","建议动作","审计时间"],...records.map(x=>[x.group,x.name,x.name_zh||"",datasetStatusLabel(x.status),x.completeness?.score??0,(x.completeness?.present_fields||[]).map(v=>labels[v]||v).join(";"),(x.completeness?.missing_fields||[]).map(v=>labels[v]||v).join(";"),(x.completeness?.pending_fields||[]).map(v=>labels[v]||v).join(";"),x.action||"",d.checked_at||""])],csv=csvRows.map(row=>row.map(v=>'"'+String(v??"").replace(/"/g,'""')+'"').join(",")).join("\r\n"),blob=new Blob(["\ufeff"+csv],{type:"text/csv;charset=utf-8"}),url=URL.createObjectURL(blob),a=document.createElement("a");a.href=url;a.download="marine_metadata_audit_"+new Date().toISOString().slice(0,10)+".csv";a.click();setTimeout(()=>URL.revokeObjectURL(url),1000);toast("元数据审计表已导出")}}catch(err){box.innerHTML='<div class="detail-note">元数据审计失败：'+esc(err.message||String(err))+'</div>'}};
+  const load=async(refresh=false)=>{const box=wrap.querySelector(".metadata-audit-live"),exportBtn=wrap.querySelector(".audit-export");box.innerHTML='<div class="loading">正在审计元数据…</div>';exportBtn.disabled=true;try{const d=await j("/api/sidebar/datasets/metadata-audit"+(refresh?"?refresh=true":"")),summary=d.summary||{},records=d.records||[],labels=DATASET_META_LABELS,rows=records.map(x=>{const c=x.completeness||{},missing=(c.missing_fields||[]).map(v=>labels[v]||v).join("、")||"无",pending=(c.pending_fields||[]).map(v=>labels[v]||v).join("、")||"无";return '<tr><td>'+esc(x.group)+'</td><td><b>'+esc(x.name)+'</b><br><span class="dataset-zh">'+esc(x.name_zh||"")+'</span></td><td>'+esc(datasetStatusLabel(x.status))+'</td><td>'+esc(c.score??0)+'%<br><span class="row-meta">'+esc(c.present_count||0)+' / '+esc(c.expected_count||0)+'</span></td><td>'+esc(missing)+'</td><td>'+esc(pending)+'</td><td>'+esc(x.action||"")+'</td></tr>'}).join("");box.innerHTML='<div class="row-meta">审计时间：'+esc(formatTime(d.checked_at))+'</div><div class="summary-grid"><div class="summary-card"><strong>'+esc(summary.dataset_count||0)+'</strong><span>审计数据源</span></div><div class="summary-card"><strong>'+esc(summary.average_score||0)+'%</strong><span>可审计元数据平均完整度</span></div><div class="summary-card"><strong>'+esc(summary.incomplete_count||0)+'</strong><span>仍有可审计字段缺失</span></div></div><div class="compare-wrap"><table class="compare-table"><thead><tr><th>数据平面</th><th>数据源</th><th>状态</th><th>完整度</th><th>缺失字段</th><th>待文件级核验</th><th>建议动作</th></tr></thead><tbody>'+rows+'</tbody></table></div><div class="detail-note">'+esc((d.notes||[]).join("；"))+'</div>';exportBtn.disabled=false;exportBtn.onclick=()=>{const csvRows=[["数据平面","英文名称","中文名称","接入状态","可审计元数据完整度(%)","已返回字段","缺失字段","待文件级核验","建议动作","审计时间"],...records.map(x=>[x.group,x.name,x.name_zh||"",datasetStatusLabel(x.status),x.completeness?.score??0,(x.completeness?.present_fields||[]).map(v=>labels[v]||v).join(";"),(x.completeness?.missing_fields||[]).map(v=>labels[v]||v).join(";"),(x.completeness?.pending_fields||[]).map(v=>labels[v]||v).join(";"),x.action||"",d.checked_at||""])],csv=csvRows.map(row=>row.map(v=>'"'+String(v??"").replace(/"/g,'""')+'"').join(",")).join("\r\n"),blob=new Blob(["\ufeff"+csv],{type:"text/csv;charset=utf-8"});saveBlobWithProgress(blob,"marine_metadata_audit_"+new Date().toISOString().slice(0,10)+".csv",{title:"正在导出元数据审计表"});toast("元数据审计表已导出")}}catch(err){box.innerHTML='<div class="detail-note">元数据审计失败：'+esc(err.message||String(err))+'</div>'}};
   wrap.querySelector(".audit-refresh").onclick=()=>load(true);load()
 }
 async function renderDatasets(force=false){
@@ -906,7 +905,7 @@ function openServiceDiagnostics(data,appState){
   document.body.appendChild(wrap);const close=()=>wrap.remove();wrap.querySelector(".drawer-close").onclick=close;wrap.onclick=e=>{if(e.target===wrap)close()};
   const payload={detected_at:data.updated_at,app_version:appState.app_version||null,diagnostic:d,marine:marine,huggingface:hf};
   wrap.querySelector(".service-copy-report").onclick=async()=>{const text='服务诊断 '+(d.status||'-')+'；健康 '+(d.healthy_count??'-')+'/'+(d.check_count??'-')+'；平均响应 '+(d.average_response_ms??'-')+' ms；失败：'+((d.failed||[]).join('、')||'无')+'；慢响应：'+((d.slow||[]).join('、')||'无');try{await navigator.clipboard.writeText(text);toast("诊断摘要已复制")}catch{toast("浏览器不允许自动复制")}};
-  wrap.querySelector(".service-download-report").onclick=()=>{const blob=new Blob([JSON.stringify(payload,null,2)],{type:"application/json;charset=utf-8"}),a=document.createElement("a");a.href=URL.createObjectURL(blob);a.download="marine-service-diagnostic-"+new Date().toISOString().replace(/[:.]/g,"-")+".json";a.click();setTimeout(()=>URL.revokeObjectURL(a.href),1000)};
+  wrap.querySelector(".service-download-report").onclick=()=>{const blob=new Blob([JSON.stringify(payload,null,2)],{type:"application/json;charset=utf-8"});saveBlobWithProgress(blob,"marine-service-diagnostic-"+new Date().toISOString().replace(/[:.]/g,"-")+".json",{title:"正在导出服务诊断报告"})};
 }
 
 
@@ -943,7 +942,7 @@ async function runUnifiedQueryPreview(){
 async function renderServices(){
   const root=$("workspaceInner");
   root.innerHTML='<div class="view-head"><div><h1>数据服务</h1><p>统一查询 Ocean / Tuna / Squid，并实时检查底层数据服务状态。</p></div><button id="refreshServices" class="view-btn">↻ 立即检测</button></div>'+
-    '<div class="unified-query-card"><div><b>统一智能查询 · P1</b><p>用一句话描述时间、区域、物种和变量；系统先识别应该查询 Ocean、Tuna、Squid 中的哪些数据。</p></div><textarea id="unifiedQueryText" rows="3" placeholder="例如：查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL"></textarea><div class="uq-actions"><button id="unifiedQueryRun" class="view-btn primary">分析并预览</button></div><div id="unifiedQueryResult"></div></div>'+
+    '<div class="unified-query-card"><div><b>统一智能查询</b><p>用一句话描述时间、区域、物种和变量；系统先识别应该查询 Ocean、Tuna、Squid 中的哪些数据。</p></div><textarea id="unifiedQueryText" rows="3" placeholder="例如：查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL"></textarea><div class="uq-actions"><button id="unifiedQueryRun" class="view-btn primary">分析并预览</button></div><div id="unifiedQueryResult"></div></div>'+
     '<div class="loading">正在检测服务…</div>';
   $("refreshServices").onclick=renderServices;
   if($("unifiedQueryRun"))$("unifiedQueryRun").onclick=runUnifiedQueryPreview;
@@ -960,7 +959,7 @@ async function renderServices(){
     ];
     const diag='<div class="service-diagnostic"><div><span>综合状态</span><b>'+esc(d.status||"-")+'</b></div><div><span>健康检查</span><b>'+esc((d.healthy_count??"-")+" / "+(d.check_count??"-"))+'</b></div><div><span>平均响应</span><b>'+esc(d.average_response_ms==null?"-":d.average_response_ms+" ms")+'</b></div><div><span>慢响应</span><b>'+esc((d.slow||[]).length+" 项")+'</b></div></div><div class="service-actions"><button id="serviceDiagnostics" class="view-btn primary">查看诊断详情</button></div>';
     root.innerHTML='<div class="view-head"><div><h1>数据服务 <span style="font-size:11px;opacity:.6">v'+esc(APP_VERSION)+'</span></h1><p>最后检测：'+esc(formatTime(data.updated_at))+' · '+esc(d.hint||"")+'</p></div><div style="display:flex;gap:8px;flex-wrap:wrap"><button id="serviceDiagnosticsTop" class="view-btn primary">查看诊断详情</button><button id="refreshServices" class="view-btn">↻ 立即检测</button></div></div>'+
-      '<div class="unified-query-card"><div><b>统一智能查询 · P1</b><p>自然语言 → 数据域识别 → 参数解析 → Ocean / Tuna / Squid 实时目录预览。当前阶段不自动下载大文件。</p></div><textarea id="unifiedQueryText" rows="3" placeholder="例如：查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL"></textarea><div class="uq-actions"><button id="unifiedQueryRun" class="view-btn primary">分析并预览</button></div><div id="unifiedQueryResult"></div></div>'+diag+rows.map(x=>'<div class="service-row"><div class="service-head"><b>'+esc(x.name)+(x.ms!=null?'<span class="service-latency">'+esc(x.ms)+' ms</span>':'')+'</b>'+statusBadge(x.ok)+'</div><div class="row-detail">'+esc(x.detail)+'</div></div>').join("");
+      '<div class="unified-query-card"><div><b>统一智能查询</b><p>自然语言 → 数据域识别 → 参数解析 → Ocean / Tuna / Squid 实时目录预览。当前阶段不自动下载大文件。</p></div><textarea id="unifiedQueryText" rows="3" placeholder="例如：查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL"></textarea><div class="uq-actions"><button id="unifiedQueryRun" class="view-btn primary">分析并预览</button></div><div id="unifiedQueryResult"></div></div>'+diag+rows.map(x=>'<div class="service-row"><div class="service-head"><b>'+esc(x.name)+(x.ms!=null?'<span class="service-latency">'+esc(x.ms)+' ms</span>':'')+'</b>'+statusBadge(x.ok)+'</div><div class="row-detail">'+esc(x.detail)+'</div></div>').join("");
     $("refreshServices").onclick=renderServices;$("serviceDiagnostics").onclick=()=>openServiceDiagnostics(data,appState);$("serviceDiagnosticsTop").onclick=()=>openServiceDiagnostics(data,appState);if($("unifiedQueryRun"))$("unifiedQueryRun").onclick=runUnifiedQueryPreview;
   }catch(err){
     root.innerHTML='<div class="view-head"><div><h1>数据服务</h1><p>状态检测失败。</p></div><button id="refreshServices" class="view-btn">重试</button></div><div class="empty-view"><b>无法完成检测</b>'+esc(err.message||String(err))+'</div>';
@@ -979,8 +978,8 @@ function taskProgressHtml(task){
   return '<div class="task-progress"><span style="width:100%"></span></div>'
 }
 function downloadTaskResult(task){
-  const blob=new Blob([JSON.stringify(task,null,2)],{type:"application/json;charset=utf-8"}),url=URL.createObjectURL(blob),a=document.createElement("a");
-  a.href=url;a.download="task_"+(task.task_id||"result")+".json";a.click();setTimeout(()=>URL.revokeObjectURL(url),1000);toast("任务结果已导出")
+  const blob=new Blob([JSON.stringify(task,null,2)],{type:"application/json;charset=utf-8"});
+  saveBlobWithProgress(blob,"task_"+(task.task_id||"result")+".json",{title:"正在导出任务结果"});toast("任务结果已导出")
 }
 function taskResultHtml(result){
   result=result||{};const blocks=[];
@@ -1173,20 +1172,193 @@ $("new").onclick=newConversation;
 $("clear").onclick=()=>{if(S.length&&confirm("清空全部最近对话？")){S=[];save();newConversation();hist();toast("最近对话已清空")}};
 $("refresh").onclick=()=>{status();toast("正在刷新服务状态")};
 if($("accountBtn"))$("accountBtn").onclick=e=>{e.stopPropagation();accountMenu()};
+
+function ensureDownloadProgressUi(){
+  let wrap=$("downloadProgressOverlay");
+  if(wrap)return wrap;
+  wrap=document.createElement("div");
+  wrap.id="downloadProgressOverlay";
+  wrap.className="download-progress-overlay";
+  wrap.innerHTML='<div class="download-progress-card" role="dialog" aria-modal="true">'+
+    '<div class="download-progress-head"><div><b id="downloadProgressTitle">正在下载</b><span id="downloadProgressState">正在建立连接…</span></div><button id="downloadProgressClose" class="download-progress-close" type="button" title="隐藏">×</button></div>'+
+    '<div class="download-progress-track"><div id="downloadProgressBar" class="download-progress-bar"></div></div>'+
+    '<div class="download-progress-meta"><span id="downloadProgressAmount">0 B</span><span id="downloadProgressSpeed">—</span><span id="downloadProgressElapsed">0s</span></div>'+
+    '<div id="downloadProgressHint" class="download-progress-hint">下载期间可以继续查看当前页面。</div>'+
+    '<div class="download-progress-actions"><button id="downloadProgressCancel" class="view-btn" type="button">取消下载</button></div>'+
+    '</div>';
+  document.body.appendChild(wrap);
+  $("downloadProgressClose").onclick=()=>wrap.classList.remove("show");
+  return wrap;
+}
+let ACTIVE_DOWNLOAD_CONTROLLER=null;
+
+function triggerBrowserSave(url,filename){
+  const a=document.createElement("a");
+  a.href=url;
+  a.download=filename||"download";
+  a.dataset.downloadBypass="1";
+  a.style.display="none";
+  document.body.appendChild(a);
+  a.click();
+  setTimeout(()=>a.remove(),0);
+}
+
+function downloadFetchUrl(sourceUrl){
+  const u=new URL(sourceUrl,location.href);
+  if(u.protocol==="blob:"||u.protocol==="data:"||u.origin===location.origin)return u.href;
+  return "/api/download/proxy?url="+encodeURIComponent(u.href);
+}
+
+function saveBlobWithProgress(blob,filename="download",options={}){
+  const overlay=ensureDownloadProgressUi(),bar=$("downloadProgressBar");
+  overlay.classList.add("show");
+  bar.classList.remove("indeterminate","error");bar.classList.add("done");bar.style.width="100%";
+  $("downloadProgressTitle").textContent=options.title||("正在保存 "+filename);
+  $("downloadProgressState").textContent="本地文件已生成";
+  $("downloadProgressAmount").textContent=formatBytes(blob.size||0);
+  $("downloadProgressSpeed").textContent="本地生成";
+  $("downloadProgressElapsed").textContent="<1s";
+  $("downloadProgressHint").textContent="文件已在浏览器中生成，无需等待网络传输。";
+  $("downloadProgressCancel").disabled=true;
+  $("downloadProgressCancel").textContent="已完成";
+  const obj=URL.createObjectURL(blob);
+  triggerBrowserSave(obj,filename);
+  setTimeout(()=>URL.revokeObjectURL(obj),3000);
+  return true;
+}
+
+async function downloadWithProgress(url,filename="download",options={}){
+  const overlay=ensureDownloadProgressUi();
+  const title=$("downloadProgressTitle"),state=$("downloadProgressState"),bar=$("downloadProgressBar");
+  const amount=$("downloadProgressAmount"),speed=$("downloadProgressSpeed"),elapsed=$("downloadProgressElapsed"),hint=$("downloadProgressHint"),cancel=$("downloadProgressCancel");
+  const controller=new AbortController();
+  ACTIVE_DOWNLOAD_CONTROLLER=controller;
+  const started=performance.now();
+  let received=0,lastBytes=0,lastTick=started,lastChunkAt=started,total=0,finished=false;
+  overlay.classList.add("show");
+  bar.classList.remove("indeterminate","done","error");
+  bar.style.width="0%";
+  title.textContent=options.title||("正在下载 "+filename);
+  state.textContent="正在建立连接…";
+  amount.textContent="0 B";speed.textContent="—";elapsed.textContent="0s";
+  hint.textContent="正在连接数据服务；收到数据后会显示实时进度。";
+  cancel.disabled=false;cancel.textContent="取消下载";
+  cancel.onclick=()=>controller.abort();
+
+  const timer=setInterval(()=>{
+    const now=performance.now(),secs=Math.max(1,(now-started)/1000);
+    elapsed.textContent=Math.floor(secs)+"s";
+    const dt=Math.max(.25,(now-lastTick)/1000),delta=received-lastBytes;
+    if(delta>=0)speed.textContent=delta?formatBytes(delta/dt)+"/s":"0 B/s";
+    lastBytes=received;lastTick=now;
+    if(!finished && now-lastChunkAt>15000){
+      state.textContent="15 秒未收到新数据";
+      hint.textContent="连接仍未结束，可能是服务器正在准备文件或网络较慢；可以继续等待或取消。";
+    }
+  },1000);
+
+  try{
+    const sourceUrl=new URL(url,location.href).href;
+    const fetchUrl=downloadFetchUrl(sourceUrl);
+    const resp=await fetch(fetchUrl,{headers:authHeaders(options.headers||{}),signal:controller.signal});
+    if(!resp.ok)throw Error(await resp.text());
+    total=Number(resp.headers.get("content-length")||0);
+    state.textContent=total?"正在传输":"正在传输（服务器未提供总大小）";
+    if(!total)bar.classList.add("indeterminate");
+    hint.textContent=total?"正在接收数据，可以根据百分比判断进度。":"正在接收数据；虽然无法计算百分比，但已下载字节和速度会持续更新。";
+
+    if(!resp.body || !resp.body.getReader){
+      const blob=await resp.blob();
+      received=blob.size;
+      amount.textContent=formatBytes(received);
+      bar.classList.remove("indeterminate");bar.style.width="100%";
+      const obj=URL.createObjectURL(blob);
+      triggerBrowserSave(obj,filename);
+      setTimeout(()=>URL.revokeObjectURL(obj),3000);
+    }else{
+      const reader=resp.body.getReader(),chunks=[];
+      while(true){
+        const {done,value}=await reader.read();
+        if(done)break;
+        if(value){
+          chunks.push(value);received+=value.byteLength;lastChunkAt=performance.now();
+          amount.textContent=total?(formatBytes(received)+" / "+formatBytes(total)):formatBytes(received);
+          if(total){
+            const pct=Math.min(100,received/total*100);
+            bar.style.width=pct.toFixed(1)+"%";
+            state.textContent="正在传输 "+pct.toFixed(0)+"%";
+          }else{
+            state.textContent="正在传输 · 已接收 "+formatBytes(received);
+          }
+        }
+      }
+      const blob=new Blob(chunks,{type:resp.headers.get("content-type")||"application/octet-stream"});
+      const obj=URL.createObjectURL(blob);
+      triggerBrowserSave(obj,filename);
+      setTimeout(()=>URL.revokeObjectURL(obj),3000);
+    }
+    finished=true;
+    bar.classList.remove("indeterminate","error");bar.classList.add("done");bar.style.width="100%";
+    state.textContent="下载完成";
+    hint.textContent="文件已传输完成并交给浏览器保存。";
+    cancel.disabled=true;cancel.textContent="已完成";
+    toast("下载完成");
+    return true;
+  }catch(err){
+    finished=true;
+    bar.classList.remove("indeterminate","done");bar.classList.add("error");
+    if(err?.name==="AbortError"){
+      state.textContent="下载已取消";hint.textContent="已停止当前传输。";
+    }else{
+      const sourceUrl=String(url||"");
+      const isExternal=(()=>{try{return new URL(sourceUrl,location.href).origin!==location.origin}catch(_){return false}})();
+      if(isExternal && options.nativeFallback!==false){
+        state.textContent="已交给浏览器下载";
+        hint.textContent="该外部站点不允许平台读取传输字节，因此无法显示精确百分比；已改用浏览器原生下载。";
+        bar.classList.remove("error","indeterminate");bar.classList.add("done");bar.style.width="100%";
+        triggerBrowserSave(sourceUrl,filename);
+        toast("外部下载已交给浏览器");
+        cancel.disabled=true;cancel.textContent="浏览器接管";
+        return true;
+      }
+      state.textContent="下载失败";hint.textContent=String(err.message||err).slice(0,300);
+      toast("下载失败："+(err.message||String(err)));
+    }
+    cancel.disabled=true;cancel.textContent="已停止";
+    return false;
+  }finally{
+    clearInterval(timer);
+    ACTIVE_DOWNLOAD_CONTROLLER=null;
+  }
+}
+
 document.addEventListener("click",e=>{
-  const a=e.target.closest("a.download");
-  if(!a || !USER_ID) return;
+  const a=e.target.closest("a");
+  if(!a || a.dataset.downloadBypass==="1" || !USER_ID)return;
+
+  const href=String(a.getAttribute("href")||"").trim();
+  if(!href)return;
+  let u;
+  try{u=new URL(href,location.href)}catch(_){return}
+
+  const path=u.pathname.toLowerCase();
+  const looksDownload=(
+    a.classList.contains("download") ||
+    a.hasAttribute("download") ||
+    a.dataset.download==="1" ||
+    /\/download(?:\/|$)/.test(path) ||
+    /\.(?:csv|tsv|json|zip|xlsx?|nc|netcdf|parquet|geojson|tif|tiff)(?:$|\?)/i.test(u.href)
+  );
+  if(!looksDownload)return;
 
   if(SETTINGS.confirmDownload && !confirm("确认下载这个数据文件？")){
     e.preventDefault();
     return;
   }
+  e.preventDefault();
 
-  let filename="";
-  try{
-    const u=new URL(a.href);
-    filename=(u.pathname.split("/").pop()||"").slice(0,180);
-  }catch(_){}
+  let filename=(a.getAttribute("download")||u.pathname.split("/").pop()||"download").slice(0,180);
+  filename=filename||"download";
 
   fetch("/api/usage",{
     method:"POST",
@@ -1195,12 +1367,11 @@ document.addEventListener("click",e=>{
     body:JSON.stringify({
       user_id:USER_ID,
       event_type:"download_clicked",
-      detail:{
-        filename:filename,
-        href:String(a.href||"").slice(0,1000)
-      }
+      detail:{filename,href:u.href.slice(0,1000)}
     })
   }).catch(()=>{});
+
+  downloadWithProgress(u.href,filename,{title:"正在下载 "+filename});
 });
 
 document.querySelectorAll(".domain-card").forEach(x=>{if(!x.getAttribute("onclick"))x.addEventListener("click",e=>{if(e.target.closest("button"))return;openDomainPanel(x.dataset.domain)})});

static/js/project-package.js

@@ -176,7 +176,14 @@ async function renderProjectPackage(){
         const skip=skipped.length?'<div class="detail-note" style="margin-top:8px">另有 '+esc(skipped.length)+' 项未加入，可在 ZIP 的 manifest.json 查看原因。</div>':'';
         box.innerHTML='<div class="package-manifest">'+(rows||'<div class="detail-note">没有已加入文件。</div>')+'</div>'+skip;
       };
-      $("packageDownload").onclick=async()=>{const btn=$("packageDownload");btn.disabled=true;btn.textContent="下载中…";try{const resp=await fetch(r.download_url,{headers:authHeaders()});if(!resp.ok)throw Error(await resp.text());const blob=await resp.blob(),url=URL.createObjectURL(blob),a=document.createElement("a");a.href=url;a.download="project_data_package.zip";a.click();setTimeout(()=>URL.revokeObjectURL(url),2000);toast("项目数据包已下载")}catch(err){toast("下载失败："+(err.message||String(err)))}finally{btn.disabled=false;btn.textContent="↓ 下载 ZIP"}};
+      $("packageDownload").onclick=async()=>{
+        const btn=$("packageDownload");btn.disabled=true;btn.textContent="下载中…";
+        try{
+          await downloadWithProgress(r.download_url,"project_data_package.zip",{title:"正在下载项目数据包"});
+        }finally{
+          btn.disabled=false;btn.textContent="↓ 下载 ZIP";
+        }
+      };
     }catch(err){const status=$("packageBuildStatus");if(status)status.outerHTML='<div class="empty-view"><b>打包失败</b>'+esc(err.message||String(err))+'</div>'}
     finally{b.disabled=false;b.textContent="生成所选 ZIP"}
   };

tests/test_download_progress_v391.py

@@ -0,0 +1,27 @@
+
+import pathlib
+ROOT=pathlib.Path(__file__).resolve().parents[1]
+
+def test_version_391():
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
+
+def test_p1_label_removed():
+    js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
+    assert "统一智能查询 · P1" not in js
+    assert "统一智能查询" in js
+
+def test_download_progress_manager_present():
+    js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
+    assert "function downloadWithProgress" in js
+    assert "content-length" in js
+    assert "15 秒未收到新数据" in js
+    assert "ACTIVE_DOWNLOAD_CONTROLLER" in js
+
+def test_project_package_uses_progress_manager():
+    js=(ROOT/"static"/"js"/"project-package.js").read_text(encoding="utf-8")
+    assert 'downloadWithProgress(r.download_url,"project_data_package.zip"' in js
+
+def test_progress_css_present():
+    css=(ROOT/"static"/"css"/"app.css").read_text(encoding="utf-8")
+    assert ".download-progress-overlay" in css
+    assert ".download-progress-bar.indeterminate" in css

tests/test_history_sidebar_v373.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_373():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_project_history_backend():
     route=(ROOT/"routes"/"project_package.py").read_text(encoding="utf-8")

tests/test_p0_finish_v380.py

@@ -3,7 +3,7 @@ import pathlib, re, subprocess, shutil
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_380():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_chat_runtime_extracted():
     ui=(ROOT/"ui_server.py").read_text(encoding="utf-8")

tests/test_p0_phase2_v371.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_frontend_feature_modules_exist():
     html=(ROOT/"app.html").read_text(encoding="utf-8")

tests/test_p0_phase3_v372.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_372():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_route_modules_exist():
     for name in ("datasets.py","user_state.py","project_package.py","data_health.py"):

tests/test_quality_center_v362.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT = pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_371():
-    assert (ROOT / "VERSION").read_text(encoding="utf-8").strip() == "3.9.0"
+    assert (ROOT / "VERSION").read_text(encoding="utf-8").strip() == "3.9.2"
 
 def test_native_health_backend():
     text = (ROOT / "routes" / "data_health.py").read_text(encoding="utf-8")

tests/test_release_stability.py

@@ -7,7 +7,7 @@ def test_version_is_single_source():
     version = (ROOT / "VERSION").read_text(encoding="utf-8").strip()
     ui = (ROOT / "ui_server.py").read_text(encoding="utf-8")
     html = (ROOT / "app.html").read_text(encoding="utf-8")
-    assert version == "3.9.0"
+    assert version == "3.9.2"
     assert 'with_name("VERSION")' in ui
     assert "__APP_VERSION__" in html
 

tests/test_runtime_hotfix_v376.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_376():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_no_stray_async_before_sidebar_toggle():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_sidebar_collapse_v374.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_374():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_sidebar_toggle_markup():
     html=(ROOT/"app.html").read_text(encoding="utf-8")

tests/test_sidebar_partial_collapse_v375.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_375():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_sidebar_order_and_groups():
     html=(ROOT/"app.html").read_text(encoding="utf-8")

tests/test_unified_download_manager_v392.py

@@ -0,0 +1,38 @@
+
+import pathlib
+ROOT=pathlib.Path(__file__).resolve().parents[1]
+
+def test_version_392():
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
+
+def test_download_proxy_route_registered():
+    route=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")
+    ui=(ROOT/"ui_server.py").read_text(encoding="utf-8")
+    assert '"/api/download/proxy"' in route
+    assert "register_download_routes(app, globals())" in ui
+    assert "external download host is not allowlisted" in route
+
+def test_frontend_all_downloads_use_manager():
+    js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
+    assert "function downloadFetchUrl" in js
+    assert '"/api/download/proxy?url="' in js
+    assert "function saveBlobWithProgress" in js
+    assert "looksDownload" in js
+    assert "downloadWithProgress(u.href,filename" in js
+
+def test_local_exports_use_manager():
+    js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
+    for name in (
+        "squid_workspace_backup_",
+        "marine_dataset_comparison_",
+        "marine_dataset_live_inventory_",
+        "hf_fisheries_repository_quality_",
+        "marine_metadata_audit_",
+        "marine-service-diagnostic-",
+    ):
+        assert name in js
+    assert js.count("saveBlobWithProgress(")>=7
+
+def test_project_package_still_uses_manager():
+    pp=(ROOT/"static"/"js"/"project-package.js").read_text(encoding="utf-8")
+    assert 'downloadWithProgress(r.download_url,"project_data_package.zip"' in pp

tests/test_unified_query_v390.py

@@ -4,7 +4,7 @@ from services.unified_query import plan_unified_query
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_390():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_joint_squid_environment_plan():
     p=plan_unified_query("查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL")
@@ -32,6 +32,7 @@ def test_endpoint_registered_in_source():
 
 def test_frontend_has_unified_query():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
-    assert "统一智能查询 · P1" in js
+    assert "统一智能查询" in js
+    assert "统一智能查询 · P1" not in js
     assert "runUnifiedQueryPreview" in js
     assert "/api/query/preview" in js

tests/test_v381_navigation_ocean_intent.py

@@ -3,7 +3,7 @@ import pathlib, ast
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_381():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.0"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="3.9.2"
 
 def test_recent_conversation_switches_to_chat():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

ui_server.py

@@ -27,6 +27,7 @@ from routes.datasets import register_datasets_routes
 from routes.project_package import register_project_package_routes
 from routes.chat import register_chat_routes
 from routes.unified_query import register_unified_query_routes
+from routes.downloads import register_download_routes
 from services.chat_runtime import init_chat_runtime
 
 from fisheries_hf import (
@@ -3182,5 +3183,6 @@ async def sidebar_tasks(request: Request):
 stream_chat, harness_stream_chat, dispatch_chat_stream = init_chat_runtime(globals())
 register_chat_routes(app, globals())
 register_unified_query_routes(app, globals())
+register_download_routes(app, globals())
 
 HTML = Path(__file__).with_name("app.html").read_text(encoding="utf-8")