Deploy v4.5.0 platform reliability

FIX_REPORT_v4.5.0.md

@@ -0,0 +1,18 @@
+# v4.5.0 平台可靠性整合修复
+
+本版针对《鱿鱼数据平台功能测试排查报告》的四项已定位问题，以及 v4.4.2
+多任务实测中的“多任务路由优先级/上下文串扰/并行过程不可验证”问题进行整合修复。
+
+## 已处理
+1. 数据中心按实时 Hugging Face 仓库成员关系展示来源，Squid 不再只看 category=squid；
+   实时文件数直接采用 squid_file_count/tuna_file_count，避免来源匹配重复计数。
+2. Ocean 单文件导出不再让浏览器直连上游/ngrok 地址，统一进入 `/api/download/jobs`
+   管理下载链路；批量 Ocean 下载继续沿用既有代理、Range、重试和链接刷新。
+3. 连续追问扩展到深度、水深、米层、图层、层位和变量；结构化上下文新增 layer。
+4. 新增 `services/region_registry.py`，命名海域通过平台固定映射解析；
+   显式经纬度优先，结构化上下文会回显实际 bbox 和映射来源。
+5. 多任务解析支持“任务1：...”格式；显式多任务在前端先拆分，再让每个独立子会话
+   自行进入 Ocean/Fisheries/普通 Agent 路由。
+6. 每个子任务线程独立、history 为空；原始多任务请求只作为共享指代解析材料，
+   并通过 `[TARGET_CHILD_TASK]` 明确限制目标，降低兄弟任务上下文串扰。
+7. 多任务面板增加实时并发数、单任务耗时、墙钟耗时、串行估算和加速比。

README.md

@@ -10,7 +10,7 @@ pinned: false
 
 # Global Marine Foundation Data Agent
 
-Current UI release: **v4.4.2**.
+Current UI release: **v4.5.0**.
 
 
 ## v3.4.0 稳定性重构（第一阶段）

VERSION

@@ -1 +1 @@
-4.4.2
+4.5.0

routes/datasets.py

@@ -55,6 +55,14 @@ async def sidebar_datasets(request: Request, refresh: bool = False):
             "size_bytes": sum(item["size_bytes"] for item in matched),
             "examples": [item["path"] for item in matched[:4]],
             "matched_aliases": matched_aliases,
+            "repository_domains": sorted({
+                str(item.get("repository_domain") or "")
+                for item in matched if item.get("repository_domain")
+            }),
+            "file_count_by_repository": {
+                domain: sum(1 for item in matched if item.get("repository_domain")==domain)
+                for domain in ("tuna","squid")
+            },
             "metadata": {
                 "repository": "、".join(sorted({
                     item.get("repository", "") for item in matched

services/context_compressor.py

@@ -19,6 +19,8 @@ import re
 from datetime import date
 from typing import Any
 
+from services.region_registry import resolve_region, format_bbox
+
 from sidebar_catalog import (
     HF_SOURCE_ALIASES,
     OCEAN_CATALOG,
@@ -62,6 +64,7 @@ EXTRA_VARIABLE_ALIASES = {
     "海温": "sst",
     "海面高度": "zos",
     "海面高度异常": "zos",
+    "ssh": "zos",
     "叶绿素": "chl",
     "溶解氧": "o2",
     "混合层深度": "mlotst",
@@ -354,6 +357,9 @@ def _extract_region_text(text: str) -> str:
 
 def extract_depth(text: str) -> str:
     q = str(text or "")
+    layer_depth=re.search(r"([0-9]+(?:\.[0-9]+)?\s*(?:米|m|dbar|db))\s*层",q,re.IGNORECASE)
+    if layer_depth:
+        return layer_depth.group(1).strip()
     match = DEPTH_RE.search(q)
     if match:
         return match.group(1).strip()
@@ -369,6 +375,16 @@ def extract_depth(text: str) -> str:
     return ""
 
 
+def extract_layer(text: str) -> str:
+    q=str(text or "")
+    m=re.search(r"(?:第\s*)?(\d{1,3})\s*(?:层|layer)",q,re.IGNORECASE)
+    if m:
+        return m.group(1)
+    if re.search(r"(?:图层|层位|layer)",q,re.IGNORECASE):
+        return "unspecified"
+    return ""
+
+
 def extract_request_spec(text: Any) -> dict[str, Any]:
     """Extract the stable data-request fields from one user message."""
     source_text = _clean_text(text)
@@ -419,7 +435,9 @@ def extract_request_spec(text: Any) -> dict[str, Any]:
 
     variables = _dedupe(ocean_variables + fishery_variables)
     region = _extract_region_text(source_text)
+    region_info = resolve_region(source_text) or (resolve_region(region) if region else None)
     depth = extract_depth(source_text)
+    layer = extract_layer(source_text)
     date_text = _extract_date_text(source_text)
     output_format = extract_format(source_text)
 
@@ -428,8 +446,15 @@ def extract_request_spec(text: Any) -> dict[str, Any]:
         "dataset": dataset_parts,
         "dataset_origin": dataset_origin,
         "variables": variables,
-        "region": region,
+        "region": (
+            region
+            if (region_info or {}).get("source")=="explicit_coordinates" and region
+            else ((region_info or {}).get("name") or region)
+        ),
+        "region_bbox": (region_info or {}).get("bbox") or {},
+        "region_source": (region_info or {}).get("source") or "",
         "depth": depth,
+        "layer": layer,
         "date": date_text,
         "format": output_format,
         "raw_request": source_text[:2000],
@@ -496,8 +521,13 @@ def merge_request_spec(
             spec["variables"] = new_vars
     if parsed.get("region"):
         spec["region"] = _merge_region(spec.get("region", ""), parsed["region"])
+        if parsed.get("region_bbox"):
+            spec["region_bbox"] = dict(parsed["region_bbox"])
+            spec["region_source"] = parsed.get("region_source") or ""
     if parsed.get("depth"):
         spec["depth"] = parsed["depth"]
+    if parsed.get("layer"):
+        spec["layer"] = parsed["layer"]
     if parsed.get("date"):
         spec["date"] = parsed["date"]
     if parsed.get("format"):
@@ -531,8 +561,14 @@ def render_request_spec(
         lines.append(f"变量：{'、'.join(spec['variables'])}")
     if spec.get("region"):
         lines.append(f"区域：{spec['region']}")
+    if spec.get("region_bbox") and spec.get("region_source")!="explicit_coordinates":
+        bbox_text=format_bbox(spec.get("region_bbox"))
+        if bbox_text:
+            lines.append(f"平台本次固定经纬度范围：{bbox_text}（{spec.get('region_source') or 'registry'}）")
     if spec.get("depth"):
         lines.append(f"深度：{spec['depth']}")
+    if spec.get("layer"):
+        lines.append(f"图层：{spec['layer']}")
     if spec.get("date"):
         lines.append(f"日期/时间：{spec['date']}")
     if spec.get("format"):
@@ -543,7 +579,7 @@ def render_request_spec(
         spec.get(key)
         for key in (
             "domain", "dataset", "variables", "region",
-            "depth", "date", "format",
+            "depth", "layer", "date", "format",
         )
     )
     if include_raw and spec.get("raw_request") and not has_structured:
@@ -633,7 +669,7 @@ def build_request_spec_from_messages(
             parsed.get(key)
             for key in (
                 "domain", "dataset", "variables", "region",
-                "depth", "date", "format",
+                "depth", "layer", "date", "format",
             )
         )
         if has_data:

services/ocean_batch.py

@@ -12,6 +12,8 @@ from pathlib import Path
 from typing import Any
 from urllib.parse import urlparse
 
+from services.region_registry import resolve_region
+
 import httpx
 
 VARIABLE_MAP={
@@ -25,21 +27,6 @@ VARIABLE_MAP={
     "vo":{"source":"cmems_physics","variable":"vo","label":"VO"},
 }
 
-# Named-region defaults used only when the user does not provide explicit
-# coordinates. Keep these conservative and visible in the task metadata.
-NAMED_OCEAN_REGIONS=(
-    {
-        "name":"西北太平洋",
-        "aliases":("西北太平洋","northwest pacific","north-west pacific","nw pacific"),
-        "bbox":{"lon_min":120.0,"lon_max":180.0,"lat_min":0.0,"lat_max":60.0},
-    },
-    {
-        "name":"西北太平洋中纬度",
-        "aliases":("西北太平洋中纬度","northwest pacific mid-latitude"),
-        "bbox":{"lon_min":120.0,"lon_max":160.0,"lat_min":20.0,"lat_max":50.0},
-    },
-)
-
 def _daterange(start:date,end:date):
     cur=start
     while cur<=end:
@@ -62,30 +49,14 @@ def _parse_date_range(prompt:str):
     return None
 
 def _parse_bbox(prompt:str):
-    raw=str(prompt or "")
-    q=raw.upper().replace("°","")
-    # Explicit coordinates always win over named-region defaults.
-    q=q.replace("–","-").replace("—","-").replace("至","-")
-    mlon=re.search(r"(-?\d+(?:\.\d+)?)\s*E\s*-\s*(-?\d+(?:\.\d+)?)\s*E",q)
-    mlat=re.search(r"(-?\d+(?:\.\d+)?)\s*N\s*-\s*(-?\d+(?:\.\d+)?)\s*N",q)
-    if mlon and mlat:
-        xs=sorted((float(mlon.group(1)),float(mlon.group(2))))
-        ys=sorted((float(mlat.group(1)),float(mlat.group(2))))
-        return {
-            "bbox":{"lon_min":xs[0],"lon_max":xs[1],"lat_min":ys[0],"lat_max":ys[1]},
-            "region_name":"自定义经纬度范围",
-            "region_source":"explicit_coordinates",
-        }
-
-    low=raw.lower()
-    for item in NAMED_OCEAN_REGIONS:
-        if any(alias.lower() in low for alias in item["aliases"]):
-            return {
-                "bbox":dict(item["bbox"]),
-                "region_name":item["name"],
-                "region_source":"named_region_default",
-            }
-    return None
+    resolved=resolve_region(prompt)
+    if not resolved:
+        return None
+    return {
+        "bbox":dict(resolved["bbox"]),
+        "region_name":resolved["name"],
+        "region_source":resolved["source"],
+    }
 
 def _parse_variables(prompt:str):
     low=str(prompt or "").lower()

services/region_registry.py

@@ -0,0 +1,86 @@
+from __future__ import annotations
+
+import re
+from typing import Any
+
+# Platform-standard named regions.
+# These are deterministic UI/query defaults, not claims that a fishery
+# convention boundary is a simple rectangle. Explicit user coordinates always
+# override these defaults. Each mapping is surfaced to the user for review.
+REGIONS = (
+    {
+        "name": "西北太平洋",
+        "aliases": ("西北太平洋", "northwest pacific", "north-west pacific", "nw pacific"),
+        "bbox": {"lon_min": 120.0, "lon_max": 180.0, "lat_min": 0.0, "lat_max": 60.0},
+        "scope": "platform_standard",
+    },
+    {
+        "name": "西太平洋",
+        "aliases": ("西太平洋", "western pacific", "west pacific"),
+        "bbox": {"lon_min": 120.0, "lon_max": 180.0, "lat_min": -30.0, "lat_max": 30.0},
+        "scope": "platform_standard",
+    },
+    {
+        "name": "西北太平洋中纬度",
+        "aliases": ("西北太平洋中纬度", "northwest pacific mid-latitude"),
+        "bbox": {"lon_min": 120.0, "lon_max": 160.0, "lat_min": 20.0, "lat_max": 50.0},
+        "scope": "platform_standard",
+    },
+    {
+        "name": "南海",
+        "aliases": ("南海", "south china sea"),
+        "bbox": {"lon_min": 105.0, "lon_max": 121.0, "lat_min": 3.0, "lat_max": 25.0},
+        "scope": "platform_standard",
+    },
+    {
+        "name": "东海",
+        "aliases": ("东海", "east china sea"),
+        "bbox": {"lon_min": 117.0, "lon_max": 131.0, "lat_min": 23.0, "lat_max": 34.0},
+        "scope": "platform_standard",
+    },
+)
+
+def _explicit_bbox(text: str) -> dict[str, Any] | None:
+    raw = str(text or "")
+    q = raw.upper().replace("°", "").replace("–", "-").replace("—", "-").replace("至", "-")
+    mlon = re.search(r"(-?\d+(?:\.\d+)?)\s*E\s*-\s*(-?\d+(?:\.\d+)?)\s*E", q)
+    mlat = re.search(r"(-?\d+(?:\.\d+)?)\s*N\s*-\s*(-?\d+(?:\.\d+)?)\s*N", q)
+    if not (mlon and mlat):
+        return None
+    xs = sorted((float(mlon.group(1)), float(mlon.group(2))))
+    ys = sorted((float(mlat.group(1)), float(mlat.group(2))))
+    return {
+        "name": "自定义经纬度范围",
+        "bbox": {"lon_min": xs[0], "lon_max": xs[1], "lat_min": ys[0], "lat_max": ys[1]},
+        "source": "explicit_coordinates",
+    }
+
+def resolve_region(text: str) -> dict[str, Any] | None:
+    explicit = _explicit_bbox(text)
+    if explicit:
+        return explicit
+    low = str(text or "").lower()
+    # Longest alias first prevents “西北太平洋” from being swallowed by a
+    # shorter future alias such as “太平洋”.
+    matches = []
+    for item in REGIONS:
+        for alias in item["aliases"]:
+            if alias.lower() in low:
+                matches.append((len(alias), item))
+    if not matches:
+        return None
+    item = sorted(matches, key=lambda x: -x[0])[0][1]
+    return {
+        "name": item["name"],
+        "bbox": dict(item["bbox"]),
+        "source": item.get("scope") or "platform_standard",
+    }
+
+def format_bbox(bbox: dict[str, Any] | None) -> str:
+    bbox = bbox or {}
+    if not all(k in bbox for k in ("lon_min","lon_max","lat_min","lat_max")):
+        return ""
+    return (
+        f"{bbox['lon_min']}°E–{bbox['lon_max']}°E, "
+        f"{bbox['lat_min']}°N–{bbox['lat_max']}°N"
+    )

static/js/app.js

@@ -755,8 +755,17 @@ const DOMAIN_PROMPTS={
 let DOMAIN_CACHE=null;
 function domainSources(data,domain){
   if(domain==="ocean")return (data.ocean?.sources||[]).map(x=>({...x,group:"Ocean"}));
-  const cat=domain==="tuna"?"tuna":"squid";
-  return (data.fisheries?.sources||[]).filter(x=>x.category===cat||String(x.query_prompt||"").toLowerCase().includes(domain));
+  const sources=data.fisheries?.sources||[];
+  // Dataset-center membership follows the actual live repository inventory,
+  // not only the semantic category. This keeps FAO / Sea Around Us / RAM /
+  // GFW / VIIRS visible when those sources physically exist in squid_dataset.
+  return sources.filter(x=>{
+    const domains=Array.isArray(x.repository_domains)?x.repository_domains:[];
+    if(domains.includes(domain))return true;
+    if(domain==="tuna"&&x.category==="tuna")return true;
+    if(domain==="squid"&&x.category==="squid")return true;
+    return false;
+  });
 }
 async function refreshHomeDomains(force=false){
   try{
@@ -781,12 +790,14 @@ async function openDomainPanel(domain){
   overlay.classList.remove("hidden");panel.innerHTML='<div class="loading">正在读取实时数据目录…</div>';
   try{
     const data=DOMAIN_CACHE||await refreshHomeDomains(false),sources=domainSources(data,domain),available=sources.filter(x=>datasetAvailable(x.status));
-    const files=domain==="ocean"?"—":sources.reduce((a,x)=>a+Number(x.file_count||0),0);
-    const size=domain==="ocean"?"实时接口":formatBytes(sources.reduce((a,x)=>a+Number(x.size_bytes||0),0));
+    const files=domain==="ocean"?"—":Number(domain==="tuna"?data.fisheries?.tuna_file_count:data.fisheries?.squid_file_count)||0;
+    const size=domain==="ocean"?"实时接口":formatBytes(
+      sources.reduce((a,x)=>a+Number((x.file_count_by_repository||{})[domain]?x.size_bytes||0:0),0)
+    );
     const repoKey=domain==="tuna"?data.fisheries?.repositories?.tuna:(domain==="squid"?data.fisheries?.repositories?.squid:"");
     const repoError=repoKey?(data.fisheries?.repository_errors?.[repoKey]||""):"";
     const sourceHtml=(repoError?('<div class="detail-note"><b>仓库读取失败：</b>'+esc(repoError)+'</div>'):"")+ (sources.slice(0,12).map(x=>'<div class="domain-source"><b>'+esc(x.name)+(x.name_zh?' · '+esc(x.name_zh):'')+'</b><small>'+esc(datasetStatusLabel(x.status))+(x.file_count!==undefined?' · '+esc(x.file_count)+' 个文件':'')+(x.variables?.length?' · '+esc(x.variables.length)+' 个变量':'')+'</small></div>').join("")||'<div class="empty-view">当前没有可显示的数据源。</div>');
-    $("domainPanel").innerHTML='<div class="domain-head"><div><h2>'+names[domain][0]+'</h2><p>'+names[domain][1]+' · 实时状态，不再使用静态占位数字</p></div><button class="domain-close" aria-label="关闭">×</button></div><div class="domain-summary"><div class="domain-stat"><strong>'+sources.length+'</strong><span>数据来源</span></div><div class="domain-stat"><strong>'+available.length+'</strong><span>当前已接入</span></div><div class="domain-stat"><strong>'+esc(domain==="ocean"?size:String(files)+" 文件")+'</strong><span>'+(domain==="ocean"?'数据服务':'实时文件')+'</span></div></div><div class="domain-sources">'+sourceHtml+'</div><div class="domain-actions"><button id="domainBrowse" class="view-btn primary">打开完整数据集目录</button><button id="domainQuery" class="view-btn">在对话中查询</button><button id="domainRefresh" class="view-btn">↻ 刷新实时数据</button></div>';
+    $("domainPanel").innerHTML='<div class="domain-head"><div><h2>'+names[domain][0]+'</h2><p>'+names[domain][1]+' · 实时仓库文件树口径；综合统计/观测来源只要实际入库也会显示</p></div><button class="domain-close" aria-label="关闭">×</button></div><div class="domain-summary"><div class="domain-stat"><strong>'+sources.length+'</strong><span>数据来源</span></div><div class="domain-stat"><strong>'+available.length+'</strong><span>当前已接入</span></div><div class="domain-stat"><strong>'+esc(domain==="ocean"?size:String(files)+" 文件")+'</strong><span>'+(domain==="ocean"?'数据服务':'实时文件')+'</span></div></div><div class="domain-sources">'+sourceHtml+'</div><div class="domain-actions"><button id="domainBrowse" class="view-btn primary">打开完整数据集目录</button><button id="domainQuery" class="view-btn">在对话中查询</button><button id="domainRefresh" class="view-btn">↻ 刷新实时数据</button></div>';
     $("domainPanel").querySelector(".domain-close").onclick=closeDomainPanel;
     $("domainBrowse").onclick=()=>{closeDomainPanel();openDatasetsForDomain(domain)};
     $("domainQuery").onclick=()=>{closeDomainPanel();goChat(DOMAIN_PROMPTS[domain])};
@@ -1523,8 +1534,11 @@ function attachOceanSingleExportCard(A,prompt,answer){
     '<div class="ocean-batch-counts"><span>✓ 完成 <b>1</b></span><span>↻ 执行中 <b>0</b></span><span>… 等待 <b>0</b></span><span>! 失败 <b>0</b></span></div>'+
     '<div class="ocean-batch-meta">'+esc(label)+' · '+esc(tag)+' · '+esc(name)+'</div>'+
     '<div class="ocean-batch-message">'+esc(request||"文件已生成，可开始下载。")+'</div>'+
-    '<div class="ocean-batch-actions"><a class="view-btn primary download" data-download="1" href="'+esc(urls[0])+'" download="'+esc(name)+'" data-filename="'+esc(name)+'">↓ 下载文件</a></div>';
+    '<div class="ocean-batch-actions"><button class="view-btn primary" data-ocean-managed-download>↓ 通过平台下载</button></div>'+
+    '<div class="detail-note">下载会统一经过平台代理任务，浏览器不直接访问学校/ngrok 临时地址；支持进度、鉴权与 Range 能力检测。</div>';
   A.q.parentNode.insertBefore(card,A.m);
+  const btn=card.querySelector("[data-ocean-managed-download]");
+  if(btn)btn.onclick=()=>downloadWithProgress(urls[0],name,{title:"正在下载 "+name});
   return true;
 }
 
@@ -1533,18 +1547,23 @@ function parseParallelTasks(prompt){
   const text=String(prompt||"").trim();
   if(!SETTINGS.multiTaskAuto)return null;
   if(/先.{0,18}(再|然后|之后)|基于(前|上)一个|完成.*后再/i.test(text))return null;
-  if(!/(同时|分别|并行|多个任务|以下任务|这几项)/i.test(text))return null;
-  const lines=text.split(/\r?\n/);
+  if(!/(同时|分别|并行|多个任务|以下\s*\d*\s*个?.*任务|这几项)/i.test(text))return null;
   const tasks=[];
+  const lines=text.split(/\r?\n/);
   for(const line of lines){
-    const m=line.match(/^\s*(?:任务\s*)?(?:\d+[\.\、\)]|[-*])\s*(.+?)\s*$/);
-    if(m&&m[1].length>=3)tasks.push(m[1]);
+    // Supports “任务1：...”, “任务 1: ...”, “1. ...”, “1、...”.
+    const m=line.match(/^\s*(?:任务\s*)?(\d+)\s*(?:[\.、\):：）]|\-\s*)\s*(.+?)\s*$/);
+    if(m&&m[2].length>=3)tasks.push(m[2]);
   }
   if(tasks.length<2){
-    const parts=text.split(/[；;]/).map(x=>x.trim()).filter(Boolean);
-    if(parts.length>=2&&parts.length<=6)return parts.slice(0,6);
-    return null;
+    const rx=/(?:^|[\n；;])\s*(?:任务\s*)?\d+\s*(?:[\.、\):：）])\s*([\s\S]*?)(?=(?:\n|[；;])\s*(?:任务\s*)?\d+\s*(?:[\.、\):：）])|$)/g;
+    let match;
+    while((match=rx.exec(text))!==null){
+      const task=String(match[1]||"").trim();
+      if(task.length>=3)tasks.push(task);
+    }
   }
+  if(tasks.length<2)return null;
   return tasks.slice(0,6);
 }
 function newMultitaskRequestId(){
@@ -1557,13 +1576,13 @@ function createParallelTaskBoard(tasks,requestId){
   const box=document.createElement("div");box.className="parallel-board";
   box.dataset.requestId=requestId;
   box.innerHTML='<div class="parallel-head"><div><b>多任务并行执行</b><small>'+tasks.length+' 个独立子任务 · 独立会话并行 · '+esc(requestId)+'</small></div><strong>0 / '+tasks.length+'</strong></div>'+
-    '<div class="parallel-overview"><span>执行策略 <b>parallel / child-session</b></span><span>总耗时 <b data-parallel-wall>0.0s</b></span><span>串行估算 <b data-parallel-serial>—</b></span></div>'+
+    '<div class="parallel-overview"><span>执行策略 <b>parallel / child-session</b></span><span>当前并发 <b data-parallel-active>0 / '+tasks.length+'</b></span><span>总耗时 <b data-parallel-wall>0.0s</b></span><span>串行估算 <b data-parallel-serial>—</b></span></div>'+
     '<div class="parallel-grid">'+tasks.map((t,i)=>'<div class="parallel-task" data-parallel-index="'+i+'"><div class="parallel-task-title"><span>'+(i+1)+'</span><b>'+esc(t)+'</b><em data-task-elapsed>0.0s</em></div><div class="parallel-task-state">等待启动</div><div class="parallel-task-result"></div></div>').join("")+'</div>';
   body.appendChild(box);r.appendChild(body);$("msgs").appendChild(r);
   $("chat").scrollTop=$("chat").scrollHeight;
-  return{root:r,box,body,requestId,started:performance.now()};
+  return{root:r,box,body,requestId,started:performance.now(),active:0,total:tasks.length};
 }
-async function runParallelChild(prompt,index,board){
+async function runParallelChild(prompt,index,board,originalPrompt){
   const card=board.box.querySelector('[data-parallel-index="'+index+'"]');
   const state=card.querySelector(".parallel-task-state"),resultEl=card.querySelector(".parallel-task-result");
   const elapsedEl=card.querySelector("[data-task-elapsed]");
@@ -1571,6 +1590,9 @@ async function runParallelChild(prompt,index,board){
   const started=performance.now();
   let timer=setInterval(()=>{elapsedEl.textContent=((performance.now()-started)/1000).toFixed(1)+"s"},250);
   state.textContent="正在创建子会话…";card.classList.add("running");
+  board.active=(board.active||0)+1;
+  const activeEl=board.box.querySelector("[data-parallel-active]");
+  if(activeEl)activeEl.textContent=board.active+" / "+board.total;
   try{
     const tx=await j("/api/threads",{method:"POST",body:JSON.stringify({user_id:USER_ID})});
     state.textContent="Agent 正在处理…";
@@ -1578,7 +1600,14 @@ async function runParallelChild(prompt,index,board){
     headers["X-Multitask-Request-ID"]=board.requestId;
     headers["X-Multitask-Task-ID"]=taskId;
     headers["X-Multitask-Mode"]="parallel-child-session";
-    const r=await fetch("/api/chat",{method:"POST",headers,body:JSON.stringify({thread_id:tx.thread_id,prompt:promptWithDisplayPreferences(prompt),user_id:USER_ID,upload_ids:[]})});
+    const childPrompt=
+      "[MULTITASK_CHILD]\n"+
+      "你只执行下面指定的一个子任务。兄弟任务的结果不能作为本任务上下文，也不要汇总其他任务。\n"+
+      "原始多任务请求仅用于解析‘同一区域/同一月份/上述条件’等共享指代；若目标子任务已经给出明确参数，以目标子任务为准。\n"+
+      "[ORIGINAL_MULTI_REQUEST]\n"+originalPrompt+"\n[/ORIGINAL_MULTI_REQUEST]\n"+
+      "[TARGET_CHILD_TASK]\n"+prompt+"\n[/TARGET_CHILD_TASK]\n"+
+      "[/MULTITASK_CHILD]";
+    const r=await fetch("/api/chat",{method:"POST",headers,body:JSON.stringify({thread_id:tx.thread_id,prompt:promptWithDisplayPreferences(childPrompt),user_id:USER_ID,upload_ids:[],history:[]})});
     if(!r.ok)throw Error(await r.text());
     const rd=r.body.getReader(),dec=new TextDecoder();let buf="",answer="",failed="";
     while(true){
@@ -1605,6 +1634,9 @@ async function runParallelChild(prompt,index,board){
   }finally{
     clearInterval(timer);timer=null;
     elapsedEl.textContent=((performance.now()-started)/1000).toFixed(1)+"s";
+    board.active=Math.max(0,(board.active||1)-1);
+    const activeEl=board.box.querySelector("[data-parallel-active]");
+    if(activeEl)activeEl.textContent=board.active+" / "+board.total;
   }
 }
 async function sendParallelTasks(originalPrompt,tasks){
@@ -1617,7 +1649,7 @@ async function sendParallelTasks(originalPrompt,tasks){
   const serialEl=board.box.querySelector("[data-parallel-serial]");
   const wallTimer=setInterval(()=>{wallEl.textContent=((performance.now()-board.started)/1000).toFixed(1)+"s"},250);
   let finished=0;
-  const promises=tasks.map((task,i)=>runParallelChild(task,i,board).then(x=>{finished++;counter.textContent=finished+" / "+tasks.length;return x}));
+  const promises=tasks.map((task,i)=>runParallelChild(task,i,board,originalPrompt).then(x=>{finished++;counter.textContent=finished+" / "+tasks.length;return x}));
   const results=await Promise.all(promises);
   clearInterval(wallTimer);
   const wall=(performance.now()-board.started)/1000;

tests/test_chat_lifecycle_progress_v393.py

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

tests/test_download_progress_v391.py

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

tests/test_download_resilience_v422.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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_refresh_route_registered():
     t=(ROOT/"routes"/"ocean_batch.py").read_text(encoding="utf-8")

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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_project_history_backend():
     route=(ROOT/"routes"/"project_package.py").read_text(encoding="utf-8")

tests/test_large_download_jobs_v400.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_400():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_download_job_backend():
     route=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

tests/test_merged_health_v433.py

@@ -3,7 +3,7 @@ from services.ocean_batch import parse_ocean_batch_request
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_merged_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_ocean_month_batch_survives_merge():
     p=parse_ocean_batch_request("查询 2002 年 8 月西北太平洋的 SST 数据，并导出为 CSV 文件供我下载")

tests/test_multitask_observability_v442.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_frontend_sends_multitask_trace_headers():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_ocean_batch_downloads_v420.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_420():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_manifest_has_filename_and_sizes():
     svc=(ROOT/"services"/"ocean_batch.py").read_text(encoding="utf-8")

tests/test_ocean_batch_routing_v421.py

@@ -4,7 +4,7 @@ from services.ocean_batch import parse_ocean_batch_request
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_421():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_exact_user_month_query_routes_to_batch():
     p=parse_ocean_batch_request("查询 2002 年 8 月西北太平洋的 SST 数据，并导出为 CSV 文件供我下载")
@@ -16,7 +16,7 @@ def test_exact_user_month_query_routes_to_batch():
     assert p["variables"]==["sst"]
     assert p["format"]=="csv"
     assert p["region_name"]=="西北太平洋"
-    assert p["region_source"]=="named_region_default"
+    assert p["region_source"]=="platform_standard"
     assert p["bbox"]=={"lon_min":120.0,"lon_max":180.0,"lat_min":0.0,"lat_max":60.0}
 
 def test_explicit_coordinates_override_named_region():

tests/test_ocean_batch_v410.py

@@ -4,7 +4,7 @@ from services.ocean_batch import parse_ocean_batch_request
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_410():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_month_three_variable_batch_plan():
     p=parse_ocean_batch_request("查询并导出 2002 年 8 月西北太平洋 120°E–140°E、20°N–40°N 的 SST、SSH、CHL 数据，并打包下载")

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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_route_modules_exist():
     for name in ("datasets.py","user_state.py","project_package.py","data_health.py"):

tests/test_platform_reliability_v450.py

@@ -0,0 +1,65 @@
+from pathlib import Path
+from services.context_compressor import extract_request_spec, merge_request_spec, render_request_spec
+from services.region_registry import resolve_region
+from services.ocean_batch import parse_ocean_batch_request
+
+ROOT=Path(__file__).resolve().parents[1]
+
+def test_version():
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
+
+def test_squid_center_uses_repository_membership():
+    js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
+    api=(ROOT/"routes"/"datasets.py").read_text(encoding="utf-8")
+    assert "repository_domains" in api
+    assert "file_count_by_repository" in api
+    assert "domains.includes(domain)" in js
+    assert "squid_file_count" in js
+    assert "实时仓库文件树口径" in js
+
+def test_single_ocean_export_forces_managed_proxy():
+    js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
+    assert "data-ocean-managed-download" in js
+    assert "downloadWithProgress(urls[0],name" in js
+    assert "浏览器不直接访问学校/ngrok" in js
+
+def test_followup_depth_layer_context():
+    base=merge_request_spec(None,"查询2002年8月西北太平洋 SST，导出 CSV",revision=False)
+    updated=merge_request_spec(base,"其中200米层的",revision=True)
+    assert updated.get("depth")
+    rendered=render_request_spec(updated)
+    assert "200" in rendered
+    assert "SST" in rendered or "sst" in rendered.lower()
+    assert "2002" in rendered
+    assert "西北太平洋" in rendered
+
+def test_layer_is_structured():
+    p=extract_request_spec("还是这个区域，第5层，换成SSH")
+    assert p["layer"]=="5"
+    assert "zos" in p["variables"]
+
+def test_region_is_deterministic():
+    a=resolve_region("查询西太平洋 SST")
+    b=resolve_region("再查询一次西太平洋 SSH")
+    assert a==b
+    assert a["bbox"]=={"lon_min":120.0,"lon_max":180.0,"lat_min":-30.0,"lat_max":30.0}
+
+def test_explicit_bbox_overrides_registry():
+    x=resolve_region("西太平洋 130°E-140°E 20°N-30°N")
+    assert x["source"]=="explicit_coordinates"
+    assert x["bbox"]["lon_min"]==130.0
+
+def test_batch_uses_registry():
+    p=parse_ocean_batch_request("查询2002年8月西北太平洋 SST 并导出 CSV")
+    assert p is not None
+    assert p["region_name"]=="西北太平洋"
+    assert p["bbox"]["lat_max"]==60.0
+
+def test_multitask_parser_accepts_task_colon_and_isolates_context():
+    js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")
+    assert "任务\\s*)?(\\d+)" in js
+    assert "[MULTITASK_CHILD]" in js
+    assert "[TARGET_CHILD_TASK]" in js
+    assert "history:[]" in js
+    assert "data-parallel-active" in js
+    assert "runParallelChild(task,i,board,originalPrompt)" in js

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() == "4.4.2"
+    assert (ROOT / "VERSION").read_text(encoding="utf-8").strip() == "4.5.0"
 
 def test_native_health_backend():
     text = (ROOT / "routes" / "data_health.py").read_text(encoding="utf-8")

tests/test_quality_trust_v361.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version_current():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_quality_confidence_is_now_native_api_metric():
     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 == "4.4.2"
+    assert version == "4.5.0"
     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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_sidebar_order_and_groups():
     html=(ROOT/"app.html").read_text(encoding="utf-8")

tests/test_smart_progress_avatar_sync_v441.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_simple_chat_hides_progress_until_needed():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_sse_heartbeat_v401.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_401():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_chat_has_independent_heartbeat_wrapper():
     route=(ROOT/"routes"/"chat.py").read_text(encoding="utf-8")

tests/test_ui_avatar_multitask_v440.py

@@ -2,7 +2,7 @@ from pathlib import Path
 ROOT=Path(__file__).resolve().parents[1]
 
 def test_version():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_assistant_avatar_removed_user_avatar_customizable():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

tests/test_unified_download_manager_v392.py

@@ -3,7 +3,7 @@ import pathlib
 ROOT=pathlib.Path(__file__).resolve().parents[1]
 
 def test_version_392():
-    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_download_proxy_route_registered():
     route=(ROOT/"routes"/"downloads.py").read_text(encoding="utf-8")

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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_joint_squid_environment_plan():
     p=plan_unified_query("查询 2002 年 8 月西北太平洋柔鱼记录，并匹配 SST、SSH、CHL")

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()=="4.4.2"
+    assert (ROOT/"VERSION").read_text(encoding="utf-8").strip()=="4.5.0"
 
 def test_recent_conversation_switches_to_chat():
     js=(ROOT/"static"/"js"/"app.js").read_text(encoding="utf-8")

ui_server.py

@@ -1765,7 +1765,8 @@ def _looks_like_data_parameter(prompt: str) -> bool:
         r"(?:19|20)\d{2}年|\d{1,2}月|\d{1,2}日|"
         r"(?:19|20)\d{2}-\d{2}-\d{2}|"
         r"[0-9.]+(?:°|[ew])|[0-9.]+[ewns]|"
-        r"经度|纬度|海域|区域|范围|变量|数据源|输出格式|日期|时间|年份|月份",
+        r"经度|纬度|海域|区域|范围|变量|数据源|输出格式|日期|时间|年份|月份|"
+        r"深度|水深|层位|图层|第\d+层|\d+(?:\.\d+)?米层|surface|layer",
         q,
     ):
         return True
@@ -1776,7 +1777,7 @@ def _looks_like_data_parameter(prompt: str) -> bool:
             "ssrd","strd","tp","thetao","mlotst","zos","spco2","era5","cmems",
             "oisst","occci","netcdf","geotiff","tiff","csv","xlsx","json",
             "柔鱼","鱿鱼","squid","金枪鱼","tuna","捕捞","努力量","cpue",
-            "biomass","下载","导出","数据",
+            "biomass","下载","导出","数据","深度","水深","米层","图层","层位","surface","layer",
         )
     )