From 5c6820f602ac40386cbaea8c2c3661eba7132560 Mon Sep 17 00:00:00 2001 From: ThearchyHelios Date: Tue, 6 Oct 2026 16:42:29 +0800 Subject: [PATCH 1/6] =?UTF-8?q?=E8=BF=90=E8=A1=8C=E5=AF=B9=E6=AF=94?= =?UTF-8?q?=E7=9A=84=E9=BB=98=E8=AE=A4=E5=9F=BA=E5=87=86=EF=BC=88GET=20/ap?= =?UTF-8?q?i/runs/{id}/compare/base=EF=BC=89=E5=B8=A6=E4=B8=8A=20previous?= =?UTF-8?q?=EF=BC=9A=E5=9F=BA=E5=87=86=E6=98=AF=E4=B8=8D=E6=98=AF=E7=B4=A7?= =?UTF-8?q?=E6=8C=A8=E7=9D=80=E7=9A=84=E4=B8=8A=E4=B8=80=E6=AC=A1=EF=BC=8C?= =?UTF-8?q?=E5=8F=96=20pick=5Fbase=20=E7=8E=B0=E6=88=90=E7=AE=97=E5=A5=BD?= =?UTF-8?q?=E7=9A=84=E9=82=A3=E4=B8=AA=E5=80=BC=EF=BC=8C=E5=92=8C=E5=AE=9A?= =?UTF-8?q?=E6=97=B6=E4=BB=BB=E5=8A=A1=E8=87=AA=E5=8A=A8=E5=AF=B9=E6=AF=94?= =?UTF-8?q?=E8=AE=B0=E4=B8=8B=E7=9A=84=20previous=20=E5=90=8C=E4=B8=80?= =?UTF-8?q?=E4=B8=AA=E8=AF=AD=E4=B9=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 运行详情「更多」里的入口要按它定叫法：上一次失败、取消、还没结束时，基准是再往前成功的那一次，菜单得和触发历史一样写「与上一次成功的运行对比」，不能一律写「与上一次对比」。测试钉住：同一定时任务、退回同一工作流两种范围里，失败、取消、还没结束、没封存的都算隔着，别的运行类别、别的定时任务、比这次晚发起的不算；上一次失败时运行详情和触发历史拿到同一个基准、同一个 previous；中间那次删掉之后运行详情按现在的记录算成紧挨着的上一次 --- backend/app/api/compare.py | 17 +++++---- backend/tests/test_compare_api.py | 46 ++++++++++++++++++++++++- backend/tests/test_scheduler_compare.py | 11 ++++-- 3 files changed, 64 insertions(+), 10 deletions(-) diff --git a/backend/app/api/compare.py b/backend/app/api/compare.py index 44bf258e..16fbf75f 100644 --- a/backend/app/api/compare.py +++ b/backend/app/api/compare.py @@ -1,11 +1,12 @@ """运行对比：同一个工作流的两次运行按「变化三分法」对照——数据变了、口径变了、还是模板 / SQL 变了（engine/compare.py）。 -GET /api/runs/{run_id}/compare/base：默认拿哪一次来比，{base_run_id, reason, base}。规则在 pick_base，定时任务结束后 -的自动对比（scheduler/auto_compare.py）用的是同一个函数——触发历史里的「与上一次对比」和运行详情里的同名入口必须拿到 -同一个基准，计数才对得上；触发历史里存着的那一份，事后基准不再是这里挑出来的那一次（中间失败的那次被接着运行成功 -了）就不再给出（auto_compare.outdated）。这次运行是定时任务发起的，取同一定时任务、同一工作流、比它先发起的运行里 +GET /api/runs/{run_id}/compare/base：默认拿哪一次来比，{base_run_id, reason, base, previous}。规则在 pick_base，定时 +任务结束后的自动对比（scheduler/auto_compare.py）用的是同一个函数——触发历史里的「与上一次对比」和运行详情里的同名入口 +必须拿到同一个基准，计数才对得上；触发历史里存着的那一份，事后基准不再是这里挑出来的那一次（中间失败的那次被接着运行 +成功了）就不再给出（auto_compare.outdated）。这次运行是定时任务发起的，取同一定时任务、同一工作流、比它先发起的运行里 成功结束并封存的最近一次（reason: same_schedule）；不是、或者同一任务之前没有成功的，取同一工作流、同一运行类别里 -同样条件的最近一次（reason: same_workflow）。找不到 404。 +同样条件的最近一次（reason: same_workflow）。previous 说基准是不是紧挨着的上一次（同自动对比记下的 previous）：不是时 +两个入口都写「与上一次成功的运行对比」。找不到 404。 GET /api/runs/{run_id}/compare?base={base_id}：{target, base, summary, template, metrics, queries, notes}，每个字段 的形状见 engine/compare.py。两次运行都必须已结束、封存且封存核对一致，封存判定照搬证据接口（api/evidence._sealed）： @@ -62,11 +63,13 @@ BASE = "作为基准的运行" @router.get("/{run_id}/compare/base") async def compare_base(run_id: str) -> dict[str, Any]: - """默认拿来对比的那一次运行：{base_run_id, reason: same_schedule | same_workflow, base}。""" + """默认拿来对比的那一次运行：{base_run_id, reason: same_schedule | same_workflow, base, previous}。previous 是 + pick_base 算的「是不是紧挨着的上一次」：运行详情「更多」里的入口按它定叫法（不是时写「与上一次成功的运行对比」）， + 和触发历史里同名的链接（自动对比记下的 previous）说法一致。""" found = await default_base(run_id) if found is None: raise CodedHTTPException(404, NO_BASE_TEXT, NO_BASE) - return {"base_run_id": found.run.id, "reason": found.reason, "base": run_ref(found.run)} + return {"base_run_id": found.run.id, "reason": found.reason, "base": run_ref(found.run), "previous": found.previous} @router.get("/{run_id}/compare") diff --git a/backend/tests/test_compare_api.py b/backend/tests/test_compare_api.py index 2257f070..541f87b7 100644 --- a/backend/tests/test_compare_api.py +++ b/backend/tests/test_compare_api.py @@ -7,7 +7,8 @@ - 对比只读：两次运行的 last_seq、事件、工件引用、工件文件一样不多 - 遮罩列（查询当时记下的、数据源现在设的）的值不出现在结果里 - 默认基准：同一定时任务优先，否则同一工作流、同一运行类别；只挑比这次先发起、成功结束并封存的运行，按发起先后取 - 最近一次（失败、取消的跳过，和定时任务的自动对比挑的是同一次，见 test_scheduler_compare.py） + 最近一次（失败、取消的跳过，和定时任务的自动对比挑的是同一次，见 test_scheduler_compare.py）；previous 说它是不是 + 紧挨着的上一次 - 真跑：同一条 SQL 数据变了是 data_only；只是代进去的日期不同是 params_only，图一样 """ from __future__ import annotations @@ -335,6 +336,49 @@ async def test_the_default_base_follows_launch_order(client): assert (await get(client, f"/api/runs/{waiting}/compare/base"))["base_run_id"] == later +async def test_the_default_base_says_whether_it_is_the_previous_run(client): + """previous：基准是不是紧挨着的上一次，语义同 pick_base——同一范围（同一定时任务，或同一工作流、同一运行类别）里比 + 这次先发起、比基准后发起的运行一次都没有。失败、取消、还没结束、没封存的都算隔着；别的运行类别、别的定时任务（这次 + 是定时任务发起的）、比这次晚发起的不在范围里，不算。运行详情「更多」里的入口按它写「与上一次对比」还是「与上一次 + 成功的运行对比」，和触发历史里同名的链接一个说法""" + day = timedelta(days=1) + + async def pick(run_id: str) -> tuple[str, str, bool]: + body = await get(client, f"/api/runs/{run_id}/compare/base") + return body["base_run_id"], body["reason"], body["previous"] + + # 同一定时任务：紧挨着的上一次就是成功的 + workflow = await new_workflow() + first = await bare(workflow, T0, schedule_id="sched-weekly") + await bare(workflow, T0 + day) # 手动发起的：不在同一定时任务的范围里 + await bare(workflow, T0 + day, schedule_id="sched-daily", status="failed") # 别的定时任务失败的：同上 + second = await bare(workflow, T0 + 2 * day, schedule_id="sched-weekly") + await bare(workflow, T0 + 3 * day, schedule_id="sched-weekly", status="failed") # 比 second 晚发起 + assert await pick(second) == (first, "same_schedule", True) + + # 中间隔着一次没成功的（失败、取消、还没结束、结束了没封存）：基准是再往前成功的那一次，不是紧挨着的上一次 + for between in ({"status": "failed"}, {"status": "cancelled"}, {"status": "running", "sealed": False}, + {"status": "interrupted", "sealed": False}, {"sealed": False}): + workflow = await new_workflow() + first = await bare(workflow, T0, schedule_id="sched-weekly") + await bare(workflow, T0 + day, schedule_id="sched-weekly", **between) + current = await bare(workflow, T0 + 2 * day, schedule_id="sched-weekly") + assert await pick(current) == (first, "same_schedule", False), between + + # 同一工作流、同一运行类别（手动发起的）：别的运行类别不算隔着，同一类别里定时任务发起的失败的那次算 + workflow = await new_workflow() + first = await bare(workflow, T0) + await bare(workflow, T0 + day, run_class="exploratory", status="failed") + second = await bare(workflow, T0 + 2 * day) + assert await pick(second) == (first, "same_workflow", True) + await bare(workflow, T0 + 3 * day, schedule_id="sched-weekly", status="failed") + third = await bare(workflow, T0 + 4 * day) + assert await pick(third) == (second, "same_workflow", False) + # 定时任务的第一次退回同一工作流：隔没隔着按退回的那个范围算 + lone = await bare(workflow, T0 + 5 * day, schedule_id="sched-monthly") + assert await pick(lone) == (third, "same_workflow", True) + + # -------------------------------------------------------------------------- # 真跑：虚构的 SQLite 库，两次运行之间改了数、换了日期参数 # -------------------------------------------------------------------------- diff --git a/backend/tests/test_scheduler_compare.py b/backend/tests/test_scheduler_compare.py index d1bcb71e..1f850159 100644 --- a/backend/tests/test_scheduler_compare.py +++ b/backend/tests/test_scheduler_compare.py @@ -256,6 +256,9 @@ async def test_finished_run_is_compared_with_the_previous_run_of_its_schedule(re items = {f["id"]: f for f in (await client.get(f"/api/schedules/{sid}/fires")).json()["items"]} assert items[fire_id]["compare"] == {"base_run_id": base_id, "summary": SUMMARY, "previous": True} assert items[base_fire]["compare"] is None + # 运行详情的默认基准：同一次、同样是紧挨着的上一次（中间手动的、别的定时任务的两次不在同一定时任务的范围里） + base = (await client.get(f"/api/runs/{target_id}/compare/base")).json() + assert (base["base_run_id"], base["previous"]) == (base_id, True) [listed] = [s for s in (await client.get("/api/schedules")).json()["items"] if s["id"] == sid] assert listed["last_fire"]["id"] == fire_id and listed["last_fire"]["compare"]["base_run_id"] == base_id @@ -321,9 +324,10 @@ async def test_after_a_failed_run_the_base_is_the_last_successful_one(recorder, assert (body["compare"]["base_run_id"], body["compare"]["previous"]) == (first, False) items = {f["id"]: f for f in (await client.get(f"/api/schedules/{sid}/fires")).json()["items"]} assert items[fire_id]["compare"] == {"base_run_id": first, "summary": SUMMARY, "previous": False} - # 运行详情「与上一次对比」的默认基准挑的是同一次（同一个函数）：两个同名入口比的是同一对运行、计数一致 + # 运行详情「与上一次对比」的默认基准挑的是同一次（同一个函数）：两个同名入口比的是同一对运行、计数一致； + # previous 也一样，运行详情的菜单项和触发历史的链接都写「与上一次成功的运行对比」 base = (await client.get(f"/api/runs/{target_id}/compare/base")).json() - assert (base["base_run_id"], base["reason"]) == (first, "same_schedule") + assert (base["base_run_id"], base["reason"], base["previous"]) == (first, "same_schedule", False) async def fires_of(client, sid: str) -> dict[str, dict]: @@ -396,6 +400,9 @@ async def test_a_stored_compare_stays_while_its_base_is_still_the_pick(recorder, assert (await client.delete(f"/api/runs/{second}", params={"force": "true"})).status_code == 204 assert (await fires_of(client, sid))[third_fire]["compare"] == shown assert await default_base_of(client, third) == (first, "same_schedule") + # 运行详情的默认基准按现在的运行记录算：中间那次删掉了，第 1 周就是紧挨着的上一次（菜单写「与上一次对比」， + # 触发历史照当时记下的写「与上一次成功的运行对比」，两句都属实，比的是同一对运行） + assert (await client.get(f"/api/runs/{third}/compare/base")).json()["previous"] is True async def test_without_an_earlier_success_there_is_no_base(recorder, client): From 6514db61183cfd192368321e0c06e9ad8ccf2b9f Mon Sep 17 00:00:00 2001 From: ThearchyHelios Date: Tue, 6 Oct 2026 16:52:30 +0800 Subject: [PATCH 2/6] =?UTF-8?q?=E8=BF=90=E8=A1=8C=E8=AF=A6=E6=83=85?= =?UTF-8?q?=E3=80=8C=E6=9B=B4=E5=A4=9A=E3=80=8D=E9=87=8C=E7=9A=84=E5=AF=B9?= =?UTF-8?q?=E6=AF=94=E5=85=A5=E5=8F=A3=E6=8C=89=E9=BB=98=E8=AE=A4=E5=9F=BA?= =?UTF-8?q?=E5=87=86=E6=98=AF=E4=B8=8D=E6=98=AF=E7=B4=A7=E6=8C=A8=E7=9D=80?= =?UTF-8?q?=E7=9A=84=E4=B8=8A=E4=B8=80=E6=AC=A1=E5=AE=9A=E5=8F=AB=E6=B3=95?= =?UTF-8?q?=EF=BC=9A=E4=B8=8A=E4=B8=80=E6=AC=A1=E5=A4=B1=E8=B4=A5=E3=80=81?= =?UTF-8?q?=E5=8F=96=E6=B6=88=E3=80=81=E8=BF=98=E6=B2=A1=E7=BB=93=E6=9D=9F?= =?UTF-8?q?=E6=97=B6=E5=86=99=E3=80=8C=E4=B8=8E=E4=B8=8A=E4=B8=80=E6=AC=A1?= =?UTF-8?q?=E6=88=90=E5=8A=9F=E7=9A=84=E8=BF=90=E8=A1=8C=E5=AF=B9=E6=AF=94?= =?UTF-8?q?=E3=80=8D=EF=BC=8C=E5=92=8C=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E8=A7=A6=E5=8F=91=E5=8E=86=E5=8F=B2=E9=87=8C=E7=9A=84=E5=90=8C?= =?UTF-8?q?=E5=90=8D=E9=93=BE=E6=8E=A5=E4=B8=80=E5=AD=97=E4=B8=8D=E5=B7=AE?= =?UTF-8?q?=E3=80=81=E7=82=B9=E8=BF=9B=E5=8E=BB=E6=98=AF=E5=90=8C=E4=B8=80?= =?UTF-8?q?=E4=B8=AA=E5=9F=BA=E5=87=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 拿到能对比的运行（已封存、属于已保存的工作流、不在运行中）就预先问一次 compare/base，按答复里的 previous 定叫法；按运行 id 加清单哈希记，失败后接着运行完重新封存了会再问。问到之前这一项只写「正在查找上一次成功的运行…」、不给点：菜单开着时不会先写一个叫法、问到了再换成另一个，也点不到说错了的入口。预先问出错、找不到默认基准都不提示，叫法退回「与上一次对比」，点了照常再问一次、照实说。点了总是再问一次、按那一次的答复跳：详情页可能开了很久，预先问到的基准不一定还是现在的。 类型 RunCompareBase 加 previous（老服务端不给，按 true 算，同 ScheduleFireCompare）；两种叫法放在 RUN_COMPARE_TEXT（menu、menuLastOk），SCHEDULE_TEXT 的 compareLinkLastOk 和 compareLink 一样改成取它的 getter，过时的说明一并改掉。check-compare：夹具里本次的默认基准带 previous: false（和触发历史那一行同一个假定）；上一次失败了、上一次就是成功的两种，运行详情和触发历史两个入口叫法一致、打开同一对运行；预先问的那一次压住时菜单项只写正在查找、问到后直接是最终叫法（记下菜单开着时出现过的每一种状态核对）；预先问出错、找不到基准时不提示、点了照常再问；点了之后对比页不再自己找一遍 --- frontend/src/api/compare.ts | 4 +- frontend/src/lib/terms.ts | 11 +- frontend/src/pages/runs/RunDetailView.tsx | 7 +- frontend/src/pages/runs/compare/entry.tsx | 127 +++++++----- frontend/src/types.ts | 5 + scripts/check-compare.mjs | 231 +++++++++++++++++----- 6 files changed, 279 insertions(+), 106 deletions(-) diff --git a/frontend/src/api/compare.ts b/frontend/src/api/compare.ts index 9d29b2e1..cbcb6b5b 100644 --- a/frontend/src/api/compare.ts +++ b/frontend/src/api/compare.ts @@ -12,8 +12,8 @@ const run = (id: string) => `/runs/${encodeURIComponent(id)}` export const compare = { /** - * 默认的基准：同一定时任务的上一次运行，没有就同一工作流、同一运行类别的上一次。找不到时回 404，ApiError 的 - * message 是给人看的原因 + * 默认的基准：同一定时任务上一次成功并封存的运行，没有就同一工作流、同一运行类别的上一次。previous 说它是不是紧挨着 + * 的上一次（运行详情的菜单项按它定叫法）。找不到时回 404，ApiError 的 message 是给人看的原因 */ base: (runId: string, opts?: RequestOptions) => get(`${run(runId)}/compare/base`, opts), /** diff --git a/frontend/src/lib/terms.ts b/frontend/src/lib/terms.ts index 5c0e6215..ee3a254b 100644 --- a/frontend/src/lib/terms.ts +++ b/frontend/src/lib/terms.ts @@ -3119,10 +3119,10 @@ export const SCHEDULE_TEXT = { get compareLink() { return RUN_COMPARE_TEXT.menu }, /** * 基准不是紧挨着的上一次（上一次失败了、取消了，比的是再往前成功的那一次）时链接上看得见的叫法：触屏没有悬停， - * 键盘聚焦时也不显示 title，只在悬停里说明会让人以为比的就是上一次。运行详情「更多」里的菜单项点之前还不知道基准 - * 是哪一次，这时仍叫「与上一次对比」，两处叫法不同；进了对比页都写「默认基准：同一定时任务上一次成功的运行」 + * 键盘聚焦时也不显示 title，只在悬停里说明会让人以为比的就是上一次。运行详情「更多」里的菜单项按服务端给的 previous + * 用同一个叫法（同为 getter）；进了对比页都写「默认基准：同一定时任务上一次成功的运行」 */ - compareLinkLastOk: '与上一次成功的运行对比', + get compareLinkLastOk() { return RUN_COMPARE_TEXT.menuLastOk }, /** * 悬停写各类指标的个数，和 Webhook 通知里那一行同一个写法（服务端 scheduler/auto_compare.py 的 summary_text）： * 变化三分法的三类总写上，0 个也写；其余各类有才写，次序同对比页；两边都没有指标时不写一串 0 个。只有个数， @@ -3189,8 +3189,11 @@ export const SCHEDULE_TEXT = { export const RUN_COMPARE_TEXT = { title: '运行对比', hint: '把两次运行的指标变化拆成数据、口径、模板与 SQL 三类', - // 入口：运行详情的「更多」菜单 + // 入口：运行详情的「更多」菜单。叫法看服务端给的 previous（基准是不是紧挨着的上一次），和定时任务触发历史里的同名 + // 链接一个说法（SCHEDULE_TEXT.compareLink、compareLinkLastOk 取的就是这两条） menu: '与上一次对比', + /** 上一次失败、取消、还没结束：基准是再往前成功的那一次，不能说成「上一次」 */ + menuLastOk: '与上一次成功的运行对比', menuSealedOnly: '运行结束并封存后才能对比', /** 没有 workflow_id 的运行：画布、问数据里没保存就运行的，或者工作流删掉之后被置空的。服务端只比同一个已保存的工作流 */ menuNoWorkflow: '工作流未保存或已删除，无法对比', diff --git a/frontend/src/pages/runs/RunDetailView.tsx b/frontend/src/pages/runs/RunDetailView.tsx index 271f0ef8..c725563c 100644 --- a/frontend/src/pages/runs/RunDetailView.tsx +++ b/frontend/src/pages/runs/RunDetailView.tsx @@ -63,8 +63,9 @@ export function RunDetailView({ runId, onChange, onDeleted }: { const [feedback, setFeedback] = useState(null) const streamBox = useRef(null) const now = useTicker(60_000) - // 「更多」里的「与上一次对比」：查找基准时的状态在这里挂着，菜单项等拿到运行之后再造（下面有提前返回） - const compareEntry = useCompareEntry() + // 「更多」里的「与上一次对比」：拿到能对比的运行就预先问默认基准（叫法看它是不是紧挨着的上一次），预先查找和点了 + // 之后查找中的状态都在这里挂着，所以放在下面的提前返回之前。live 同下面的 live + const compareItem = useCompareEntry(d.run, d.streaming || isLiveRun(d.run?.status)) useEffect(() => { if (d.state !== 'missing') return @@ -464,7 +465,7 @@ export function RunDetailView({ runId, onChange, onDeleted }: { key: 'copy-link', label: '复制链接', icon: , onSelect: () => void copyText(`${location.origin}/runs/${run.id}`, '链接'), }, - compareEntry(run, live), + compareItem, { key: 'delete', label: '删除记录…', icon: , danger: true, onSelect: () => void remove(), disabled: live || busy === 'delete', diff --git a/frontend/src/pages/runs/compare/entry.tsx b/frontend/src/pages/runs/compare/entry.tsx index f0e55a3e..9a31d140 100644 --- a/frontend/src/pages/runs/compare/entry.tsx +++ b/frontend/src/pages/runs/compare/entry.tsx @@ -1,4 +1,4 @@ -import { useCallback, useEffect, useRef, useState } from 'react' +import { useEffect, useRef, useState } from 'react' import { useNavigate } from 'react-router-dom' import { GitCompareArrows } from 'lucide-react' import { ApiError, api } from '../../../api/client' @@ -16,6 +16,12 @@ export const comparePath = (target: string, base?: string | null) => /** 查找超过这么久才挂「正在查找」的提示：答复快的不闪一下 */ const NOTE_DELAY_MS = 300 +/** + * 预先问到的默认基准。key 是问的哪一次运行的哪一份封存（运行 id + 清单哈希：失败后接着运行完会重新封存，基准可能跟着 + * 变）；previous 为 null 是没问到（找不到默认基准、出错），叫法退回「与上一次对比」，点了照常再问、照实说 + */ +interface Known { key: string; previous: boolean | null } + /** * 运行详情「更多」菜单里的「与上一次对比」。先问服务端默认的基准（同一定时任务上一次成功的运行，没有就同一工作流、 * 同一类别上一次成功的运行；定时任务触发历史里同名的入口由服务端用同一个函数挑，两处比的是同一对运行），找到了再跳到 @@ -23,15 +29,23 @@ const NOTE_DELAY_MS = 300 * 这几种不给点，点了也只会被拒：没封存、还在运行的（对比只认已封存的运行，409）；不属于已保存工作流的——画布、问数据 * 里没保存就运行的，和工作流删掉之后 workflow_id 被置空的（服务端找不到同一工作流的运行，手动选也是 422）。 * - * 菜单点完就收起：查找慢于一眨眼时挂一条提示，接口慢的时候不至于像没反应。离开运行详情（组件卸载）时取消请求、 + * 叫法和触发历史里的链接一致：基准不是紧挨着的上一次（上一次失败、取消、还没结束）时写「与上一次成功的运行对比」。 + * 点之前就得知道，所以拿到能对比的运行就预先问一次（previous）。问到之前这一项只写「正在查找」、不给点：菜单开着时不会 + * 先写一个叫法、问到了再换成另一个，也点不到一个说错了的入口；平常运行一打开就问，人点开菜单时早已问到。预先问不到 + * （找不到默认基准、出错）不提示，叫法退回「与上一次对比」，点了照常再问一次、照实说。 + * + * 点了总是再问一次、按这一次的答复跳：详情页可能开了很久，中间有运行接着跑完、被删掉，基准跟着变，预先问到的不一定还是 + * 现在的。菜单点完就收起：查找慢于一眨眼时挂一条提示，接口慢的时候不至于像没反应。离开运行详情（组件卸载）时取消请求、 * 收起提示，晚到的答复不再把人带去对比页。卸载取消不了全部：地址已经换了、新页面还没画出来（路由按过渡渲染）的那一下 * 答复回来，组件还在，请求也没取消。所以答复回来时再看一眼地址：人已经不在点菜单时的那个运行详情上，就不跳、也不提示。 * - * 写成 hook（返回造菜单项的函数）：运行详情里有提前返回，菜单项本身只能在拿到运行之后造，查找中的状态得在那之前就挂上 + * 写成 hook、在运行详情的提前返回之前调用：预先查找和点了之后查找中的状态都得在拿到运行之前就挂上。run 为空（还在读 + * 运行记录）时交回的这一项不会被画出来 */ -export function useCompareEntry(): (run: Run, live: boolean) => MenuItem { +export function useCompareEntry(run: Run | null, live: boolean): MenuItem { const navigate = useNavigate() const [busy, setBusy] = useState(false) + const [known, setKnown] = useState(null) // 在路上的那一次：stop 收起（或者不再挂出）「正在查找」的提示 const pending = useRef<{ ctrl: AbortController; stop: () => void } | null>(null) useEffect(() => () => { @@ -40,48 +54,67 @@ export function useCompareEntry(): (run: Run, live: boolean) => MenuItem { p?.ctrl.abort() p?.stop() }, []) - return useCallback((run: Run, live: boolean): MenuItem => { - const orphan = !run.workflow_id - const unsealed = live || !run.manifest_hash - return { - key: 'compare', - label: T.menu, - icon: , - disabled: orphan || unsealed || busy, - hint: orphan ? T.menuNoWorkflow : unsealed ? T.menuSealedOnly : busy ? T.menuFinding : undefined, - onSelect: () => { - const ctrl = new AbortController() - // 点菜单时所在的运行详情。只比路径：同一页里换视图、改列表筛选（改查询串）不算离开 - const from = window.location.pathname - const left = () => ctrl.signal.aborted || window.location.pathname !== from - let note: number | null = null - const timer = setTimeout(() => { - note = toast.info(T.menuFinding, { sticky: true, key: `compare-finding:${run.id}` }) - }, NOTE_DELAY_MS) - const stop = () => { - clearTimeout(timer) - if (note != null) toast.dismiss(note) + + const orphan = !run?.workflow_id + const unsealed = live || !run?.manifest_hash + // 能对比的才预先问：不能对比的入口本来就不给点，问了也是 409、422 + const target = run && !orphan && !unsealed ? run.id : null + const key = target ? `${target}:${run?.manifest_hash}` : null + useEffect(() => { + if (!target || !key) return + const ctrl = new AbortController() + api.compare.base(target, { signal: ctrl.signal }).then( + (found) => setKnown({ key, previous: found.previous !== false }), + () => { if (!ctrl.signal.aborted) setKnown({ key, previous: null }) }, + ) + return () => ctrl.abort() + }, [target, key]) + + const resolved = known && known.key === key ? known : null + // 预先问的那一次还没回来：这一项只写正在查找，不先写一个叫法、问到了再换 + const asking = !!key && !resolved + return { + key: 'compare', + label: asking ? T.menuFinding : resolved?.previous === false ? T.menuLastOk : T.menu, + icon: , + disabled: orphan || unsealed || asking || busy, + hint: orphan ? T.menuNoWorkflow : unsealed ? T.menuSealedOnly : busy ? T.menuFinding : undefined, + onSelect: () => { + if (!run || !key) return + const ctrl = new AbortController() + // 点菜单时所在的运行详情。只比路径：同一页里换视图、改列表筛选（改查询串）不算离开 + const from = window.location.pathname + const left = () => ctrl.signal.aborted || window.location.pathname !== from + let note: number | null = null + const timer = setTimeout(() => { + note = toast.info(T.menuFinding, { sticky: true, key: `compare-finding:${run.id}` }) + }, NOTE_DELAY_MS) + const stop = () => { + clearTimeout(timer) + if (note != null) toast.dismiss(note) + } + pending.current = { ctrl, stop } + setBusy(true) + api.compare.base(run.id, { signal: ctrl.signal }).then((found) => { + if (left()) return + // 这一次的答复也定叫法：跳不走（地址没换成）时菜单上写的和刚问到的一致 + setKnown({ key, previous: found.previous !== false }) + const via: CompareVia = { base: found.base_run_id, reason: found.reason } + navigate(comparePath(run.id, found.base_run_id), { state: via }) + }, (e: unknown) => { + if (left()) return + if (e instanceof ApiError && e.kind === 'http' && e.status === 404) { + setKnown({ key, previous: null }) + toast.info(e.message, { action: { label: T.pickManually, onClick: () => navigate(comparePath(run.id)) } }) + } else { + toast.error(e) } - pending.current = { ctrl, stop } - setBusy(true) - api.compare.base(run.id, { signal: ctrl.signal }).then((found) => { - if (left()) return - const via: CompareVia = { base: found.base_run_id, reason: found.reason } - navigate(comparePath(run.id, found.base_run_id), { state: via }) - }, (e: unknown) => { - if (left()) return - if (e instanceof ApiError && e.kind === 'http' && e.status === 404) { - toast.info(e.message, { action: { label: T.pickManually, onClick: () => navigate(comparePath(run.id)) } }) - } else { - toast.error(e) - } - }).finally(() => { - stop() - if (pending.current?.ctrl !== ctrl) return - pending.current = null - setBusy(false) - }) - }, - } - }, [navigate, busy]) + }).finally(() => { + stop() + if (pending.current?.ctrl !== ctrl) return + pending.current = null + setBusy(false) + }) + }, + } } diff --git a/frontend/src/types.ts b/frontend/src/types.ts index 4571b97a..72a7315c 100644 --- a/frontend/src/types.ts +++ b/frontend/src/types.ts @@ -3436,6 +3436,11 @@ export interface RunCompareBase { base_run_id: string reason: RunCompareBaseReason | (string & {}) base: RunCompareRef + /** + * 基准是不是紧挨着的上一次（服务端 pick_base 算的，同触发历史里自动对比的 previous）：上一次失败、取消、还没结束时 + * 为 false，运行详情「更多」里的入口据此写「与上一次成功的运行对比」。老服务端不给，按 true 算 + */ + previous?: boolean } /** diff --git a/scripts/check-compare.mjs b/scripts/check-compare.mjs index d898a447..d742f569 100644 --- a/scripts/check-compare.mjs +++ b/scripts/check-compare.mjs @@ -11,8 +11,9 @@ // 都不能出现对比页）。下一步的提示要和页面上真能做的事对得上：下拉里没有能换的运行就不叫人去上方换，本次的记录 // 不存在时不给注定失败的「重试」。默认基准的说法照服务端的挑法（api/compare.py 的 pick_base）写「上一次成功的运行」 // ——上一次失败了，基准是再往前成功的那一次；定时任务触发历史里的「与上一次对比」和运行详情里的同名入口打开同一对 -// 运行、写同一句来历，基准不是紧挨着的上一次时触发历史上看得见的字写明「上一次成功的运行」；找不到默认基准时标题不说 -// 「没有可作为基准的运行」（失败、取消的照样能手动选），换基准的下拉和基准卡写明哪次失败、取消了。 +// 运行、写同一句来历，基准不是紧挨着的上一次时两处看得见的字都写明「与上一次成功的运行对比」（运行详情一打开就预先问 +// 默认基准，问到之前菜单项不给点，不先写一个叫法再换成另一个；预先问不到时不提示，点了照常再问）；找不到默认基准时 +// 标题不说「没有可作为基准的运行」（失败、取消的照样能手动选），换基准的下拉和基准卡写明哪次失败、取消了。 // // 全部用 page.route 假接口：虚构的「区域销售周报」三次已封存的正式运行和一次没封存的，运行详情、运行列表、 // compare/base、compare、定时任务列表、发起它们的定时任务和触发历史都在浏览器层答掉，别的 GET 放行（外壳要的工作流、 @@ -193,6 +194,9 @@ const FINDING = '正在查找上一次成功的运行' const NO_OTHER = '同一工作流没有其他可换作基准的已封存运行' /** 服务端（api/compare.py 的 NO_BASE_TEXT）找不到默认基准时的原话 */ const NO_BASE_SERVER = '没有找到上一次成功的运行：需要同一工作流、同一运行类别里比这次先发起、成功结束并已封存的运行' +/** 运行详情「更多」里对比入口的两种叫法，和触发历史里的链接一致：基准是紧挨着的上一次时、不是时（上一次失败了） */ +const MENU = '与上一次对比' +const MENU_LAST_OK = '与上一次成功的运行对比' /** * 发起本次和基准的定时任务（RUNS 里的 schedule_id）和它的触发历史：本次那一行带服务端自动对比的计数，基准是 B、不是 @@ -211,6 +215,11 @@ const FIRES = [{ id: FIRE_T, fire_at: day('10-05'), kind: 'scheduled', status: 'started', run_id: T, run_status: 'succeeded', reason: null, notified: [], created_at: day('10-05'), compare: { base_run_id: B, previous: false, summary: SUMMARY }, }] +/** + * compare/base 给本次的答复：基准是 B，不是紧挨着的上一次（previous: false），同触发历史那一行的假定。服务端两处用 + * 同一个函数挑（api/compare.py 的 pick_base），运行详情「更多」里的入口据此和触发历史写同一个叫法 + */ +const BASE_OF_T = { base_run_id: B, reason: 'same_schedule', base: refOf(B), previous: false } // ---------------------------------------------------------------- 假接口 @@ -234,7 +243,7 @@ const RECORD_GONE = { status: 404, json: { detail: '运行记录不存在' } } /** * 默认的假接口。opts.base(runId) / opts.compare(target, base, n) / opts.run(runId, n) / opts.list(workflowId) 可以换掉 * 对应接口的答复（返回 null 的照默认答），返回 {status, json, wait}（wait 是一个 Promise：等它落定再答，用来压住 - * 某一次请求）。不在夹具里的运行一律答 404，不放行到服务端 + * 某一次请求）；opts.fires 换掉触发历史。不在夹具里的运行一律答 404，不放行到服务端 */ function defaults(opts) { return async (method, url, n) => { @@ -251,8 +260,7 @@ function defaults(opts) { let m = p.match(/^\/api\/runs\/([^/]+)\/compare\/base$/) if (m) { if (opts.base) return opts.base(m[1]) - return m[1] === T ? { json: { base_run_id: B, reason: 'same_schedule', base: refOf(B) } } - : { status: 404, json: { detail: NO_BASE_SERVER, code: 'compare_no_base' } } + return m[1] === T ? { json: BASE_OF_T } : { status: 404, json: { detail: NO_BASE_SERVER, code: 'compare_no_base' } } } m = p.match(/^\/api\/runs\/([^/]+)\/compare$/) if (m) { @@ -275,7 +283,7 @@ function defaults(opts) { if (p === '/api/approvals' && url.searchParams.get('run_id')) return { json: [] } // 发起本次的定时任务和它的触发历史（只有直接打开那个定时任务的页面时才用到） if (p === `/api/schedules/${SCHEDULE_ID}`) return { json: SCHEDULE } - if (p === `/api/schedules/${SCHEDULE_ID}/fires`) return { json: { items: FIRES, next_before: null } } + if (p === `/api/schedules/${SCHEDULE_ID}/fires`) return { json: { items: opts.fires ?? FIRES, next_before: null } } // 查找基准期间离开运行详情去的那一页（定时任务列表）：给空的列表，页面落定不靠服务端里有什么 if (p === '/api/schedules') return { json: { items: [] } } return null @@ -363,25 +371,39 @@ const shot = async (page, name) => { // ---------------------------------------------------------------- 检查 +/** 运行详情里问了几次默认基准 */ +const askedBase = (log, run = T) => log.filter((k) => k === `GET /api/runs/${run}/compare/base`).length + await section('从运行详情进入', async () => { const { page, log, blocked, errors } = await open(`/runs/${T}`) await page.locator(`[data-run-detail="${T}"]`).waitFor({ timeout: 10000 }) // 走过的地址（含 pushState / replaceState）：菜单要先问到基准再跳，不能先跳到只带本次的地址、再让对比页去找 const visited = [] page.on('framenavigated', (f) => { if (f === page.mainFrame()) visited.push(f.url()) }) - await page.getByRole('button', { name: '更多操作' }).click() + const more = page.getByRole('button', { name: '更多操作' }) + await more.click() const item = page.locator('[data-menu=compare]') - check('「更多」菜单里有「与上一次对比」，可点', await item.count() === 1 && (await item.innerText()).includes('与上一次对比') - && !(await item.isDisabled())) + await until(async () => await item.count() === 1 && !(await item.isDisabled()), 3000) + // 菜单开合几次：叫法已经定了，不再一开菜单就问一遍 + await page.keyboard.press('Escape') + await more.click() + await page.waitForTimeout(300) + check('打开运行详情就预先问一次默认基准（定菜单的叫法），菜单开合不再问', askedBase(log) === 1, `${askedBase(log)} 次`) + const label = (await item.innerText()).trim() + check('「更多」菜单里有对比入口，可点；基准不是紧挨着的上一次，写「与上一次成功的运行对比」', + await item.count() === 1 && label === MENU_LAST_OK && !(await item.isDisabled()), label) + const clickAt = log.length await item.click() await page.waitForURL((u) => u.pathname === '/runs/compare', { timeout: 8000 }) await settled(page) const url = new URL(page.url()) check('跳到 /runs/compare，带着本次和基准', url.searchParams.get('target') === T && url.searchParams.get('base') === B, url.search) - const iBase = log.indexOf(`GET /api/runs/${T}/compare/base`) - const iCmp = log.indexOf(`GET /api/runs/${T}/compare?base=${B}`) - check('先请求 compare/base，再请求 compare', iBase >= 0 && iCmp > iBase, `${iBase} → ${iCmp}`) - check('compare/base 只请求一次（页面不再自己找一遍）', log.filter((k) => k.startsWith(`GET /api/runs/${T}/compare/base`)).length === 1) + // 点了之后再问一次：详情页可能开了很久，预先问到的基准不一定还是现在的 + const after = log.slice(clickAt) + const iBase = after.indexOf(`GET /api/runs/${T}/compare/base`) + const iCmp = after.indexOf(`GET /api/runs/${T}/compare?base=${B}`) + check('点了之后先请求 compare/base，再请求 compare', iBase >= 0 && iCmp > iBase, `${iBase} → ${iCmp}`) + check('点了之后 compare/base 只请求一次（对比页不再自己找一遍）', askedBase(after) === 1, `${askedBase(after)} 次`) const compareUrls = visited.map((u) => new URL(u)).filter((u) => u.pathname === '/runs/compare') check('菜单问到基准之后才跳，一步到带基准的地址', compareUrls.length >= 1 && compareUrls.every((u) => u.searchParams.get('base') === B), compareUrls.map((u) => u.search).join(' → ')) @@ -398,18 +420,19 @@ const awaySettled = (page) => page.locator('[data-schedules-page="list"] [data-s const NO_BASE = '同一工作流没有其他已封存的正式运行' /** - * 在运行详情里点「与上一次对比」，compare/base 的答复（answer，默认找到 B）先压住不放。交回页面、放行的函数、这一请求 - * 了结的 Promise（答完或者被取消，交回那个请求）、点了之后有没有挂出「正在查找」的提示，和点了之后走过的路径 - * （framenavigated 连 pushState、replaceState 都算）：晚到的答复哪怕只让页面在对比页一闪而过、又被别的跳转盖掉， - * 走过的路径里也留着 + * 在运行详情里点「与上一次对比」，点了之后那一次 compare/base 的答复（answer，默认找到 B）先压住不放；打开详情时预先 + * 问的那一次照常答（同一个答复），菜单项才可点。交回页面、放行的函数、点了之后那一请求了结的 Promise（答完或者被取消， + * 交回那个请求）、点了之后有没有挂出「正在查找」的提示，和点了之后走过的路径（framenavigated 连 pushState、 + * replaceState 都算）：晚到的答复哪怕只让页面在对比页一闪而过、又被别的跳转盖掉，走过的路径里也留着 */ -async function findingBase(answer = { json: { base_run_id: B, reason: 'same_schedule', base: refOf(B) } }) { +async function findingBase(answer = { json: BASE_OF_T }) { let release const gate = new Promise((r) => { release = r }) - const opened_ = await open(`/runs/${T}`, { base: () => ({ ...answer, wait: gate }) }) + let clicked = false + const opened_ = await open(`/runs/${T}`, { base: () => (clicked ? { ...answer, wait: gate } : answer) }) const { page, log } = opened_ const ended = new Promise((resolve) => { - const done = (req) => { if (new URL(req.url()).pathname.endsWith('/compare/base')) resolve(req) } + const done = (req) => { if (clicked && new URL(req.url()).pathname.endsWith('/compare/base')) resolve(req) } page.on('requestfinished', done) page.on('requestfailed', done) }) @@ -417,10 +440,15 @@ async function findingBase(answer = { json: { base_run_id: B, reason: 'same_sche const visited = [] page.on('framenavigated', (f) => { if (f === page.mainFrame()) visited.push(new URL(f.url()).pathname) }) await page.getByRole('button', { name: '更多操作' }).click() - await page.locator('[data-menu=compare]').click() + const item = page.locator('[data-menu=compare]') + // 预先问的那一次答完，菜单项才可点 + await until(async () => !(await item.isDisabled()), 3000) + const asked = askedBase(log) + clicked = true + await item.click() // 菜单点完就收起了：查找期间要有一条看得见的提示，接口慢的时候不像点了没反应 const noted = await until(async () => await page.locator('[data-toast]', { hasText: FINDING }).count() === 1, 3000) - await until(async () => log.includes(`GET /api/runs/${T}/compare/base`), 3000) + await until(async () => askedBase(log) > asked, 3000) return { ...opened_, release, ended, noted, visited } } @@ -505,19 +533,26 @@ await section('未封存的运行：入口不可点并说明原因', async () => } }) -/** 在运行详情里点「更多」→「与上一次对比」，等对比页落定 */ +/** + * 在运行详情里点「更多」→ 对比入口，等对比页落定。交回点之前菜单项上看得见的字（预先问到默认基准、可点之后的叫法）， + * 和这期间菜单项上出现过的每一种「可点 + 字」（菜单开着时叫法换没换过） + */ async function viaMenu(page) { await page.locator(`[data-run-detail="${T}"]`).waitFor({ timeout: 10000 }) await page.getByRole('button', { name: '更多操作' }).click() - await page.locator('[data-menu=compare]').click() + const item = page.locator('[data-menu=compare]') + await until(async () => !(await item.isDisabled()), 3000) + const label = (await item.innerText()).trim() + await item.click() await page.waitForURL((u) => u.pathname === '/runs/compare', { timeout: 8000 }) await settled(page) + return label } await section('默认基准的说法：上一次成功的运行', async () => { // 服务端只挑比本次先发起、成功结束并封存的运行：上一次失败、取消了时基准是再往前成功的那一次，「上一次运行」是错的 for (const [reason, want] of [['same_schedule', REASON], ['same_workflow', REASON_WORKFLOW]]) { - const base = () => ({ json: { base_run_id: B, reason, base: refOf(B) } }) + const base = () => ({ json: { ...BASE_OF_T, reason } }) const menu = await open(`/runs/${T}`, { base }) await viaMenu(menu.page) const fromMenu = (await maybeText(menu.page.locator('[data-compare-reason]'))).trim() @@ -533,31 +568,127 @@ await section('默认基准的说法：上一次成功的运行', async () => { } }) -await section('运行详情与触发历史的「与上一次对比」：同一个基准、同一句来历', async () => { - // 两处的基准由服务端用同一个函数挑（api/compare.py 的 pick_base）：上一次失败了，两处都是再往前成功的 B。两处真的 - // 一致由 backend/tests/test_scheduler_compare.py 守，这里守前端两个入口都原样用服务端给的基准 - const menu = await open(`/runs/${T}`) - await viaMenu(menu.page) - const hist = await open(`/schedules/${SCHEDULE_ID}?tab=history`) - const link = hist.page.locator(`[data-fire-id="${FIRE_T}"] [data-fire-compare]`) - await link.waitFor({ timeout: 10000 }) - const label = (await link.locator('[data-fire-compare-label]').innerText()).trim() - check('触发历史：基准不是紧挨着的上一次，链接上看得见的字写「与上一次成功的运行对比」', label === '与上一次成功的运行对比', label) - await link.click() - await hist.page.waitForURL((u) => u.pathname === '/runs/compare', { timeout: 8000 }) - await settled(hist.page) - const [a, b] = [new URL(menu.page.url()), new URL(hist.page.url())] - check('两个入口打开的是同一对运行（本次和基准都一样）', a.searchParams.get('target') === T && b.searchParams.get('target') === T - && a.searchParams.get('base') === B && b.searchParams.get('base') === B, `${a.search} | ${b.search}`) - const [ra, rb] = [(await maybeText(menu.page.locator('[data-compare-reason]'))).trim(), - (await maybeText(hist.page.locator('[data-compare-reason]'))).trim()] - check('两个入口写的默认基准一字不差：同一定时任务上一次成功的运行', ra === REASON && rb === REASON, `${ra} | ${rb}`) - const tiles = (page) => page.locator('[data-compare-summary] [data-compare-class]').evaluateAll((els) => - els.map((e) => `${e.getAttribute('data-compare-class')}=${e.querySelector('[data-compare-count]')?.textContent?.trim()}`).join(' ')) - const [ta, tb] = [await tiles(menu.page), await tiles(hist.page)] - check('两边的变化摘要一致', !!ta && ta === tb, `${ta} | ${tb}`) - check('没有发出写请求', ![...menu.blocked, ...hist.blocked].length, [...menu.blocked, ...hist.blocked].join('；')) - check('页面没有报错', ![...menu.errors, ...hist.errors].length, [...menu.errors, ...hist.errors].join('；')) +await section('运行详情与触发历史的「与上一次对比」：同一个基准、同一个叫法、同一句来历', async () => { + // 两处的基准和 previous 由服务端用同一个函数挑（api/compare.py 的 pick_base）：上一次失败了，两处都是再往前成功的 B、 + // 都不是紧挨着的上一次。两处真的一致由 backend/tests/test_scheduler_compare.py 守，这里守前端两个入口都原样用服务端 + // 给的基准和 previous：看得见的叫法一样，点进去比的是同一对运行 + for (const [what, previous, want] of [['上一次失败了', false, MENU_LAST_OK], ['上一次就是成功的', true, MENU]]) { + const base = () => ({ json: { ...BASE_OF_T, previous } }) + const fires = FIRES.map((f) => ({ ...f, compare: { ...f.compare, previous } })) + const menu = await open(`/runs/${T}`, { base, fires }) + const menuLabel = await viaMenu(menu.page) + const hist = await open(`/schedules/${SCHEDULE_ID}?tab=history`, { base, fires }) + const link = hist.page.locator(`[data-fire-id="${FIRE_T}"] [data-fire-compare]`) + await link.waitFor({ timeout: 10000 }) + const label = (await link.locator('[data-fire-compare-label]').innerText()).trim() + check(`${what}：运行详情「更多」里的入口和触发历史的链接叫法一致，都写「${want}」`, menuLabel === want && label === want, + `${menuLabel} | ${label}`) + await link.click() + await hist.page.waitForURL((u) => u.pathname === '/runs/compare', { timeout: 8000 }) + await settled(hist.page) + const [a, b] = [new URL(menu.page.url()), new URL(hist.page.url())] + check(`${what}：两个入口打开的是同一对运行（本次和基准都一样）`, a.searchParams.get('target') === T + && b.searchParams.get('target') === T && a.searchParams.get('base') === B && b.searchParams.get('base') === B, + `${a.search} | ${b.search}`) + const [ra, rb] = [(await maybeText(menu.page.locator('[data-compare-reason]'))).trim(), + (await maybeText(hist.page.locator('[data-compare-reason]'))).trim()] + check(`${what}：两个入口写的默认基准一字不差：同一定时任务上一次成功的运行`, ra === REASON && rb === REASON, `${ra} | ${rb}`) + const tiles = (page) => page.locator('[data-compare-summary] [data-compare-class]').evaluateAll((els) => + els.map((e) => `${e.getAttribute('data-compare-class')}=${e.querySelector('[data-compare-count]')?.textContent?.trim()}`).join(' ')) + const [ta, tb] = [await tiles(menu.page), await tiles(hist.page)] + check(`${what}：两边的变化摘要一致`, !!ta && ta === tb, `${ta} | ${tb}`) + check(`${what}：没有发出写请求`, ![...menu.blocked, ...hist.blocked].length, [...menu.blocked, ...hist.blocked].join('；')) + check(`${what}：页面没有报错`, ![...menu.errors, ...hist.errors].length, [...menu.errors, ...hist.errors].join('；')) + for (const c of opened) await c.close().catch(() => {}) + opened.clear() + } +}) + +/** + * 菜单项上出现过的每一种状态（可点与否 + 看得见的字），按先后、去掉相邻重复的。挂在页面上，菜单开合、叫法换了都记下： + * 「先写一个叫法、问到了再换成另一个」要从这里看出来 + */ +async function watchItem(page) { + await page.evaluate(() => { + const seen = [] + window.__compareItem = seen + const look = () => { + const el = document.querySelector('[data-menu=compare]') + if (!el) return + const state = `${el.disabled ? '不可点' : '可点'}：${el.innerText.replace(/\s+/g, ' ').trim()}` + if (seen[seen.length - 1] !== state) seen.push(state) + } + new MutationObserver(look).observe(document.body, { subtree: true, childList: true, characterData: true, attributes: true }) + look() + }) + return () => page.evaluate(() => window.__compareItem ?? []) +} + +await section('菜单的叫法：问到默认基准之前不给点，不先写一个叫法再换成另一个', async () => { + // 预先问的那一次压住：菜单开着时等它，问到之前这一项只写「正在查找」、不给点，问到了直接是最终的叫法 + let release + const gate = new Promise((r) => { release = r }) + const { page, log, errors } = await open(`/runs/${T}`, { base: () => ({ json: BASE_OF_T, wait: gate }), waitUntil: 'load' }) + await page.locator(`[data-run-detail="${T}"]`).waitFor({ timeout: 10000 }) + await until(async () => askedBase(log) === 1, 3000) + const states = await watchItem(page) + await page.getByRole('button', { name: '更多操作' }).click() + const item = page.locator('[data-menu=compare]') + await item.waitFor() + const waiting = (await item.innerText()).replace(/\s+/g, ' ').trim() + check('问到之前打开菜单：这一项不可点，只写正在查找上一次成功的运行，不先写一个叫法', await item.isDisabled() + && waiting.startsWith(FINDING) && !waiting.includes(MENU) && !waiting.includes(MENU_LAST_OK), waiting) + release() + await until(async () => !(await item.isDisabled()), 3000) + const label = (await item.innerText()).trim() + check('问到之后：可点，直接是照基准定的叫法（上一次失败了：「与上一次成功的运行对比」）', label === MENU_LAST_OK, label) + // 菜单开着的整个过程：除了「正在查找」，只出现过最终的叫法，而且出现时就可点 + const seen = await states() + const named = seen.filter((t) => !t.includes(FINDING)) + check('菜单开着的整个过程里叫法没有换过：除了「正在查找」只出现过最终的叫法', named.length === 1 + && named[0] === `可点：${MENU_LAST_OK}`, seen.join(' → ')) + check('预先问只问了一次', askedBase(log) === 1, `${askedBase(log)} 次`) + check('页面没有报错', errors.length === 0, errors.join('；')) +}) + +await section('预先问不到默认基准：不提示，叫法退回「与上一次对比」，点了照常再问', async () => { + // 服务端出错：打开详情时不弹报错（人还没点），点了再问一次，这次问到了就照常跳 + { + let n = 0 + const { page, log, errors } = await open(`/runs/${T}`, { base: () => (++n === 1 + ? { status: 500, json: { detail: '读取运行记录时出错' } } : { json: BASE_OF_T }) }) + await page.locator(`[data-run-detail="${T}"]`).waitFor({ timeout: 10000 }) + await page.getByRole('button', { name: '更多操作' }).click() + const item = page.locator('[data-menu=compare]') + await until(async () => !(await item.isDisabled()), 3000) + const label = (await item.innerText()).trim() + check('预先问出错：不弹报错，入口可点，叫法退回「与上一次对比」', label === MENU + && await page.locator('[data-toast]', { hasText: '读取运行记录时出错' }).count() === 0, label) + await item.click() + await page.waitForURL((u) => u.pathname === '/runs/compare', { timeout: 8000 }) + await settled(page) + check('……点了再问一次，问到了照常跳到对比页', new URL(page.url()).searchParams.get('base') === B && askedBase(log) === 2, + `${page.url()}；问了 ${askedBase(log)} 次`) + check('……页面没有报错', errors.length === 0, errors.join('；')) + } + // 找不到默认基准（404）：打开详情时不提示，点了才说原因、给「手动选择基准」 + { + const { page, log, errors } = await open(`/runs/${T}`, { base: () => ({ status: 404, json: { detail: NO_BASE_SERVER, code: 'compare_no_base' } }) }) + await page.locator(`[data-run-detail="${T}"]`).waitFor({ timeout: 10000 }) + await until(async () => askedBase(log) === 1, 3000) + await page.waitForTimeout(300) + const toast = page.locator('[data-toast]', { hasText: NO_BASE_SERVER }) + const quiet = await toast.count() === 0 + await page.getByRole('button', { name: '更多操作' }).click() + const item = page.locator('[data-menu=compare]') + await until(async () => !(await item.isDisabled()), 3000) + const label = (await item.innerText()).trim() + check('找不到默认基准：打开详情时不提示，入口可点，叫法是「与上一次对比」', quiet && label === MENU, label) + await item.click() + check('……点了再问一次，照实说原因、留在原页', await until(() => toast.count().then((c) => c === 1)) + && askedBase(log) === 2 && new URL(page.url()).pathname === `/runs/${T}`, `问了 ${askedBase(log)} 次`) + check('……页面没有报错', errors.length === 0, errors.join('；')) + } }) await section('两次运行与摘要', async () => { From 0f48bd17c4ce76b018294c502d07825c1114eab0 Mon Sep 17 00:00:00 2001 From: ThearchyHelios Date: Tue, 6 Oct 2026 17:15:52 +0800 Subject: [PATCH 3/6] =?UTF-8?q?=E8=BF=90=E8=A1=8C=E8=AF=A6=E6=83=85?= =?UTF-8?q?=E3=80=8C=E5=B7=A5=E4=BB=B6=E3=80=8D=E9=A1=B5=E7=AD=BE=EF=BC=9A?= =?UTF-8?q?=E5=8F=8C=E7=9B=B2=E5=A4=8D=E7=AE=97=E5=AF=B9=E7=85=A7=E3=80=81?= =?UTF-8?q?=E5=8F=8D=E6=96=B9=E5=AE=A1=E7=A8=BF=E8=AE=B0=E5=BD=95=E3=80=81?= =?UTF-8?q?=E8=B4=A8=E8=AF=A2=E5=9B=9E=E7=AD=94=E5=8D=95=E7=8B=AC=E5=BD=92?= =?UTF-8?q?=E5=88=B0=E3=80=8C=E6=A0=B8=E6=9F=A5=E8=AE=B0=E5=BD=95=E3=80=8D?= =?UTF-8?q?=E4=B8=80=E7=BB=84=EF=BC=9B=E7=AA=84=E5=B1=8F=E4=B8=8A=E8=AF=B4?= =?UTF-8?q?=E6=98=8E=E6=8D=A2=E5=88=B0=E7=AC=AC=E4=BA=8C=E8=A1=8C=EF=BC=8C?= =?UTF-8?q?=E7=AC=AC=E5=87=A0=E4=BB=B6=E5=92=8C=E7=AC=AC=E5=87=A0=E6=AC=A1?= =?UTF-8?q?=E5=B0=9D=E8=AF=95=E5=9C=A8=E6=88=AA=E6=96=AD=E8=8C=83=E5=9B=B4?= =?UTF-8?q?=E5=A4=96=EF=BC=8C=E6=82=AC=E5=81=9C=E5=86=99=E5=85=A8=E8=AF=B4?= =?UTF-8?q?=E6=98=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 分组：以前这三种都算进「证据快照」，那一组的说明却写着「查询、工具调用、知识检索的原始结果」。model.ts 加 artifactGroup（证据快照、核查记录、节点产出三组，按种类分），筛选多一档「核查记录」，件数、悬停说明跟着改：证据快照写上口径卡、报告文档和表结构，核查记录说清装的是什么、核查时执行的查询快照仍归在证据快照。别的种类的归类不变（isEvidence 改成只认证据快照这一组，认不出的种类照旧算证据快照）。口径卡里容器型变量输入的完整值（metric_input）以前露键名，补上名字「指标输入」和说明。 窄屏：以前一行里挤着种类、说明、校验值、大小和时刻，390px 时说明只剩三个字、序号也被截掉。行按列表这一栏的宽度排（容器查询，35rem 以下），窄时说明换到第二行占满整行，第一行留种类、校验值、大小和时刻（时刻和种类对齐）；序号和第几次尝试从被截断的说明里挪出来；按钮的悬停写「打开某种工件：整句说明 #n」。容器设在列表上、不设在整个页签上，查看工件的弹窗（fixed 定位）不落进容器里。新文案放在 terms.ts 的 RUN_ARTIFACTS_TEXT。 新预览用例 ?syn=run-artifacts（虚构的门店周报，22 件，各种工件都有，含封存后追加的长问题质询回答）。check-verify：分组和 isEvidence 的口径、四档筛选的件数和悬停、点各档只剩该组；390px 深浅色下说明都在第二行、被截断的说明看得见至少 200px（以前 0 到 63px）、第几件整个落在行内、时刻在第一行和种类对齐、不横向溢出、对比度。check-inquiry：工件页签的读法改成按 data 属性，质询回答归在核查记录、悬停带整句说明 --- frontend/src/dev/fixtures/run_artifacts.tsx | 89 +++++++++++ frontend/src/lib/terms.ts | 28 ++++ frontend/src/pages/runs/ArtifactsPane.tsx | 75 +++++---- frontend/src/pages/runs/model.ts | 20 ++- scripts/check-inquiry.mjs | 18 ++- scripts/check-verify.mjs | 168 +++++++++++++++++++- 6 files changed, 349 insertions(+), 49 deletions(-) create mode 100644 frontend/src/dev/fixtures/run_artifacts.tsx diff --git a/frontend/src/dev/fixtures/run_artifacts.tsx b/frontend/src/dev/fixtures/run_artifacts.tsx new file mode 100644 index 00000000..a8061bcf --- /dev/null +++ b/frontend/src/dev/fixtures/run_artifacts.tsx @@ -0,0 +1,89 @@ +import { useMemo, useState, type JSX } from 'react' +import { parseServerTime } from '../../lib/format' +import { ArtifactsPane, type ArtifactList } from '../../pages/runs/ArtifactsPane' +import type { RunArtifact } from '../../pages/runs/model' +import { emptyTrace } from '../../run/trace' +import type { GraphSpec, NodeType } from '../../types' + +/** + * 运行详情「工件」页签（pages/runs/ArtifactsPane）的预览用例，scripts/check-verify.mjs 按它检查分组和窄屏。 + * + * - ?syn=run-artifacts：虚构的「门店周报」一次正式运行，各种工件都有：取数节点的查询快照、表结构快照和产出，循环里 + * 逐区汇总的三次产出（第二次是重试），口径卡的指标输入、指标集，写周报的报告文档，双盲复算、反方审稿各自执行的查询 + * 和对照、审稿记录，封存后追加的两条质询回答（一条问题很长）和质询执行的查询。宽窄、深浅色都用这一个，检查脚本换 + * 视口宽度和主题。 + * + * 工件列表直接交给页签（不走接口）；航迹的起止照这次运行的开始、结束时间给：运行期间产出的能跳到航迹里那一刻，封存后 + * 追加的只写时间。点过的跳转记在 data-fixture-moment 上。门店、片区、金额、数据源都是虚构的。 + */ + +const STARTED = '2026-10-05T06:00:00' +const FINISHED = '2026-10-05T06:12:00' + +const NODES: [string, NodeType, string][] = [ + ['pull', 'tool', '拉取门店销量'], + ['summarize', 'llm', '逐区汇总'], + ['caliber', 'metrics', '周报口径'], + ['write', 'report', '写周报'], + ['dual', 'dual_check', '双盲复算'], + ['review', 'challenge', '反方审稿'], +] +const GRAPH: GraphSpec = { + nodes: NODES.map(([id, type, label], i) => ({ id, type, position: { x: i * 220, y: 0 }, data: { label, config: {} } })), + edges: NODES.slice(1).map(([id], i) => ({ source: NODES[i][0], target: id })), +} +const LABELS = Object.fromEntries(NODES.map(([id, , label]) => [id, label])) + +/** 虚构的内容校验值：64 位十六进制，各不相同 */ +const sha = (n: number) => (n * 2654435761 >>> 0).toString(16).padStart(8, '0').repeat(8) +let seq = 0 +const art = (kind: string, node: string | null, at: string, size: number, meta: Record | null = null): RunArtifact => ( + { id: sha(++seq), kind, node_id: node, size, meta, created_at: `2026-10-05T${at}` }) + +/** 质询的问题：服务端只记前 40 字（engine/inquiry.py 的 QUESTION_BRIEF），满 40 字的说明会很长 */ +const LONG_QUESTION = '青禾片区的线上订单是按下单门店还是按收货地址归到片区的？如果按收货地址，跨片区配' + +const RUN_ARTIFACTS: RunArtifact[] = [ + art('schema_snapshot', 'pull', '06:00:05', 3120, { source: '门店库', tables: 3 }), + art('query_snapshot', 'pull', '06:00:10', 18_400, { source: '门店库', tables: ['orders', 'stores'] }), + art('query_snapshot', 'pull', '06:00:20', 2_060, { source: '门店库', tables: ['refunds'] }), + art('node_output', 'pull', '06:00:30', 1_210, { type: 'tool', attempt: 1 }), + art('node_output', 'summarize', '06:01:00', 860, { type: 'llm', attempt: 1 }), + art('node_output', 'summarize', '06:02:00', 910, { type: 'llm', attempt: 2 }), + art('node_output', 'summarize', '06:03:00', 880, { type: 'llm', attempt: 1 }), + art('metric_input', 'caliber', '06:04:00', 5_400, { path: 'vars.region_rows' }), + art('metric_set', 'caliber', '06:04:30', 2_380, { caliber: '周报口径', version: 'v3' }), + art('node_output', 'caliber', '06:04:40', 1_020, { type: 'metrics', attempt: 1 }), + art('report_doc', 'write', '06:05:00', 16_820), + art('node_output', 'write', '06:05:10', 4_310, { type: 'report', attempt: 1 }), + art('query_snapshot', 'dual', '06:06:00', 1_480, { source: '门店库', tables: ['orders'] }), + art('dual_check', 'dual', '06:06:30', 6_920, { metrics: 3 }), + art('node_output', 'dual', '06:07:00', 740, { type: 'dual_check', attempt: 1 }), + art('query_snapshot', 'review', '06:08:00', 1_150, { source: '门店库', tables: ['refunds'] }), + art('query_snapshot', 'review', '06:09:00', 1_330, { source: '门店库', tables: ['orders'] }), + art('challenge', 'review', '06:10:00', 8_640, { report: 'write' }), + art('node_output', 'review', '06:10:30', 690, { type: 'challenge', attempt: 1 }), + // 封存后追加的：审批质询（不挂在节点上） + art('query_snapshot', null, '07:00:00', 1_260, { source: '门店库', tables: ['orders'] }), + art('inquiry_answer', null, '07:01:00', 2_510, { report: 'write', unit: 'u3', question: LONG_QUESTION }), + art('inquiry_answer', null, '07:20:00', 1_940, { report: 'write', unit: 'u5', question: '退货率怎么算的？' }), +] + +function RunArtifacts(): JSX.Element { + const list: ArtifactList = useMemo(() => ({ items: RUN_ARTIFACTS, state: 'ok', error: null, reload: () => undefined }), []) + const trace = useMemo(() => ({ + ...emptyTrace(), phase: 'succeeded' as const, + startedAt: parseServerTime(STARTED)?.getTime(), endedAt: parseServerTime(FINISHED)?.getTime(), + }), []) + const [moment, setMoment] = useState(null) + return ( +
+ (id ? LABELS[id] : undefined)} + onMoment={(at) => setMoment(at)} /> +
+ ) +} + +export const cases: Record JSX.Element> = { + 'run-artifacts': () => , +} diff --git a/frontend/src/lib/terms.ts b/frontend/src/lib/terms.ts index ee3a254b..4dbad10e 100644 --- a/frontend/src/lib/terms.ts +++ b/frontend/src/lib/terms.ts @@ -3397,6 +3397,34 @@ export const RUN_COMPARE_TEXT = { notes: '说明', } +/** + * 运行详情「工件」页签（pages/runs/ArtifactsPane.tsx）：这次运行按内容校验值存下的每一件东西，按节点分组。筛选按 + * pages/runs/model.ts 的 artifactGroup 分三组：证据快照是结论里数字的出处；核查记录是双盲复算、反方审稿、审批质询对 + * 结论的核查与问答，单独一组，不和数字的出处混在一起；节点产出是过程里的中间值。各种工件的名字和说明在 model.ts， + * 后来新加的放在这里（质询回答的在 INQUIRY_TEXT） + */ +export const RUN_ARTIFACTS_TEXT = { + filterGroup: '按类型筛选工件', + filter: { all: '全部', evidence: '证据快照', verify: '核查记录', output: '节点产出' } as Record, + /** 筛选按钮的悬停：这一组装的是什么。核查时执行的查询按种类仍是查询快照，归在证据快照里，要说一声 */ + filterHint: { + evidence: '查询、工具调用、知识检索的原始结果，以及口径卡、报告文档和查询时的表结构：结论里的数字从这里来', + verify: '双盲复算的对照、反方审稿的记录、审批质询的回答：对结论的核查与问答。核查时执行的查询，快照归在证据快照里', + output: '每个节点每执行一次的产出：循环里每一轮都有一件', + } as Record, + /** 同一个节点同一类的第几件：循环里几十件节点产出要分得开 */ + nth: (n: number) => `#${n}`, + attempt: (n: number) => `第 ${n} 次尝试`, + /** 打开一件的悬停写全说明：窄屏、长问题的说明在行上会截断 */ + openTitle: (kind: string, about: string) => `打开${kind}：${about}（读取时按内容校验值重新校验）`, + /** + * 口径卡里容器型变量（vars.*）输入的完整值（engine/nodes/metrics.py 的 metric_input，工件行的 meta 里有 {path}）： + * 推演时拿它还原输入。和口径卡一样归在证据快照 + */ + kindMetricInput: '指标输入', + aboutMetricInput: (path?: string | null) => (path ? `口径卡输入「${path}」的完整值` : '口径卡输入的完整值'), +} + /** * 可验证报告：把一次已封存运行的报告导出成一个 HTML 文件，收件人不连服务也能在浏览器里核对。 * 入口在记录页的封存凭证条上；页面本身的文案在服务端 bundle/verifier.js 里（它是离开系统独立打开的文件） diff --git a/frontend/src/pages/runs/ArtifactsPane.tsx b/frontend/src/pages/runs/ArtifactsPane.tsx index 335b5f6f..4e79503a 100644 --- a/frontend/src/pages/runs/ArtifactsPane.tsx +++ b/frontend/src/pages/runs/ArtifactsPane.tsx @@ -4,12 +4,12 @@ import clsx from 'clsx' import { api } from '../../api/client' import { EmptyState, ErrorState, Skeleton, StatusBadge } from '../../components/ui' import { formatBytes, formatClock, formatDateTime, formatNumber, formatTime, parseServerTime } from '../../lib/format' -import { nodeTypeLabel } from '../../lib/terms' +import { RUN_ARTIFACTS_TEXT as T, nodeTypeLabel } from '../../lib/terms' import { ArtifactViewer } from '../../run/AssistantStream' import { topology } from '../../run/derive' import type { Trace } from '../../run/trace' import type { GraphSpec } from '../../types' -import { artifactDescription, artifactKindLabel, isEvidence, type RunArtifact } from './model' +import { artifactDescription, artifactGroup, artifactKindLabel, type ArtifactGroup, type RunArtifact } from './model' // ------------------------------------------------------------------------- // 数据 @@ -65,22 +65,22 @@ export function useRunArtifacts(runId: string, refreshKey: string): ArtifactList // 页签 // ------------------------------------------------------------------------- -type KindFilter = 'all' | 'evidence' | 'output' -const FILTER_LABEL: Record = { all: '全部', evidence: '证据快照', output: '节点产出' } -const FILTER_HINT: Record = { - all: '', - evidence: '查询、工具调用、知识检索的原始结果：结论里的数字从这里来', - output: '每个节点每执行一次的产出：循环里每一轮都有一件', -} +/** 筛选：全部，或者 model.ts 的三组之一（证据快照、核查记录、节点产出） */ +type KindFilter = 'all' | ArtifactGroup +const FILTERS: readonly KindFilter[] = ['all', 'evidence', 'verify', 'output'] /** 一次循环能有上千件：先列这么多，其余点了再展开 */ const FIRST_ROWS = 300 /** - * 工件：这次运行按内容哈希存下来的每一件东西——查询和工具调用的原始结果、每个 - * 节点每一次的产出。审阅出具物时从这里下钻到证据；打开时按哈希复验。 + * 工件：这次运行按内容哈希存下来的每一件东西——查询和工具调用的原始结果、核查留下的 + * 记录、每个节点每一次的产出。审阅出具物时从这里下钻到证据；打开时按哈希复验。 * * 按节点分组、按执行顺序排，和航迹的泳道同一个顺序。能对上时刻的，一键跳到 * 航迹里它产出的那一刻。 + * + * 每一行按列表这一栏自己的宽度排（容器查询，不看视口：详情区在宽屏上也可能很窄）。窄时 + * 说明换到第二行占满整行，第一行留种类、校验值、大小和时刻；以前挤在一行里，390px + * 宽时说明只剩三个字。序号和第几次尝试放在截断的范围外，按钮的悬停写全说明。 */ export function ArtifactsPane({ list, graph, trace, labelOf, onMoment }: { list: ArtifactList @@ -96,17 +96,17 @@ export function ArtifactsPane({ list, graph, trace, labelOf, onMoment }: { const items = list.items const counts = useMemo(() => { - const c: Record = { all: 0, evidence: 0, output: 0 } + const c: Record = { all: 0, evidence: 0, verify: 0, output: 0 } for (const a of items ?? []) { c.all += 1 - c[isEvidence(a.kind) ? 'evidence' : 'output'] += 1 + c[artifactGroup(a.kind)] += 1 } return c }, [items]) const bytes = useMemo(() => (items ?? []).reduce((n, a) => n + (a.size ?? 0), 0), [items]) const groups = useMemo(() => { - const shown = (items ?? []).filter((a) => filter === 'all' || (filter === 'evidence') === isEvidence(a.kind)) + const shown = (items ?? []).filter((a) => filter === 'all' || artifactGroup(a.kind) === filter) const order = graph ? topology(graph).order : [] const rank = new Map(order.map((id, i) => [id, i])) const byNode = new Map() @@ -144,14 +144,14 @@ export function ArtifactsPane({ list, graph, trace, labelOf, onMoment }: { return (
-
- {(Object.keys(FILTER_LABEL) as KindFilter[]).map((k) => ( +
+ {FILTERS.map((k) => ( ))}
@@ -169,7 +169,9 @@ export function ArtifactsPane({ list, graph, trace, labelOf, onMoment }: {
-
+ {/* 行按这一栏的宽度排（容器查询）。容器设在列表上、不设在整个页签上：查看工件的弹窗挂在页签里、是 fixed 定位， + 早期实现容器查询的浏览器给容器加布局隔离，会把它当成 fixed 元素的定位参照，弹窗就只盖住这一栏 */} +
{groups.map(([nodeId, rows]) => { if (budget <= 0) return null const take = rows.slice(0, budget) @@ -219,7 +221,8 @@ function Group({ nodeId, rows, total, graph, trace, labelOf, t0, t1, onOpen, onM style={{ background: node ? `var(--nt-${node.type}, var(--text-faint))` : 'var(--text-faint)' }} /> {label} {node && {nodeTypeLabel(node.type)}} - {nodeId && label !== nodeId && {nodeId}} + {/* 窄时让给名字：节点 id 是给对照画布用的，名字和类型已经认得出是哪个节点 */} + {nodeId && label !== nodeId && {nodeId}} {state && } {total} 件 @@ -228,32 +231,37 @@ function Group({ nodeId, rows, total, graph, trace, labelOf, t0, t1, onOpen, onM const n = (ordinal.get(a.kind) ?? 0) + 1 ordinal.set(a.kind, n) const kind = artifactKindLabel(a.kind) + const group = artifactGroup(a.kind) + const about = artifactDescription(a.kind, a.meta) const attempt = Number(a.meta?.attempt) const created = parseServerTime(a.created_at ?? null)?.getTime() const at = t0 != null && created != null && created >= t0 && (t1 == null || created <= t1) ? created : null const numbered = (perKind.get(a.kind) ?? 0) > 1 const title = `${label} · ${kind}${numbered ? ` #${n}` : ''}` + // 第几件、第几次尝试：说明再长、截得再短也要看得见，放在截断的范围外 + const extra = [numbered ? T.nth(n) : '', attempt > 1 ? T.attempt(attempt) : ''].filter(Boolean).join(' · ') return ( -
+
{at != null && onMoment ? ( @@ -263,7 +271,8 @@ function Group({ nodeId, rows, total, graph, trace, labelOf, t0, t1, onOpen, onM T+{formatClock(Math.round(at - t0!))} ) : ( - + {formatTime(a.created_at ?? null)} )} diff --git a/frontend/src/pages/runs/model.ts b/frontend/src/pages/runs/model.ts index 2380b144..ddaff0e8 100644 --- a/frontend/src/pages/runs/model.ts +++ b/frontend/src/pages/runs/model.ts @@ -10,7 +10,7 @@ import { RUN_STATUS_ORDER, STATUS, resolveStatus, serverStatusOf, type StatusCode, } from '../../lib/status' import { formatSpan, parseServerTime } from '../../lib/format' -import { INQUIRY_TEXT } from '../../lib/terms' +import { INQUIRY_TEXT, RUN_ARTIFACTS_TEXT } from '../../lib/terms' import { hasPendingApproval } from '../../store/catalog' // ------------------------------------------------------------------------- @@ -336,6 +336,7 @@ export const ARTIFACT_KIND_LABEL: Record = { dual_check: '双盲复算对照', challenge: '反方审稿记录', inquiry_answer: INQUIRY_TEXT.artifactKind, + metric_input: RUN_ARTIFACTS_TEXT.kindMetricInput, } export const artifactKindLabel = (kind: string): string => ARTIFACT_KIND_LABEL[kind] ?? kind @@ -361,12 +362,25 @@ export function artifactDescription(kind: string, meta?: Record | n // 审批质询的回答文档（工件行的 meta 里有 {report, unit, question: 问题的前 40 字}）：不挂在节点上，靠问题认出是哪一条 case 'inquiry_answer': return typeof meta?.question === 'string' && meta.question.trim() ? INQUIRY_TEXT.artifactAbout(meta.question) : INQUIRY_TEXT.artifactAboutNone + // 口径卡里容器型变量输入的完整值（工件行的 meta 里有 {path}） + case 'metric_input': return RUN_ARTIFACTS_TEXT.aboutMetricInput(typeof meta?.path === 'string' ? meta.path : null) default: return '工件' } } -/** 证据：查询、工具、检索的快照。节点产出是过程里的中间值，一次循环就是几十件 */ -export const isEvidence = (kind: string): boolean => kind !== 'node_output' +/** + * 工件页签上的三组：evidence 证据快照（查询、工具、检索的快照，口径卡、报告文档、表结构，结论里的数字从这里来）； + * verify 核查记录（双盲复算、反方审稿、审批质询对结论的核查与问答：不是数字的出处，以前混在证据快照里，和「原始结果」 + * 的说明对不上）；output 节点产出（过程里的中间值，一次循环就是几十件）。按种类分：核查时执行的查询种类仍是查询快照， + * 归在证据快照；认不出的种类也算证据快照，宁可醒目 + */ +export type ArtifactGroup = 'evidence' | 'verify' | 'output' +const VERIFY_KINDS: ReadonlySet = new Set(['dual_check', 'challenge', 'inquiry_answer']) +export const artifactGroup = (kind: string): ArtifactGroup => + kind === 'node_output' ? 'output' : VERIFY_KINDS.has(kind) ? 'verify' : 'evidence' + +/** 证据快照这一组的（见 artifactGroup） */ +export const isEvidence = (kind: string): boolean => artifactGroup(kind) === 'evidence' /** 三种时长写进 title：「总时长 1 分 27 秒 · 执行时长 7.6 s · 等待审批 1 分 14 秒」 */ export function timingTitle(t: RunTiming): string { diff --git a/scripts/check-inquiry.mjs b/scripts/check-inquiry.mjs index cca4fbce..78d73816 100644 --- a/scripts/check-inquiry.mjs +++ b/scripts/check-inquiry.mjs @@ -11,8 +11,8 @@ // 不醒目、409 / 422 不照服务端的中文说明显示（或者问题文字丢了）、Esc 关不掉提问框（或者连带收起了别的、焦点掉到页面上）、 // 已处理的审批和封存了的正式运行还给入口、封存了的探索运行反而没有；同一次运行的几处问答串要对的审批不同、审批列表 // 取不到时后一处一直不列别的审批里问的（头上写着次数，下面一条没有），或者把没能确认的说成「报告其他版本」、不给重试； -// 工件页签里质询的回答只写英文的种类名、截断截在空格上的问题摘要不补省略号、封存后追加的工件给一个跳到运行结束之后的 -// 航迹时刻；窄屏（390px）被撑出横向滚动、浅色主题下看不清。 +// 工件页签里质询的回答只写英文的种类名、不归在「核查记录」、截断截在空格上的问题摘要不补省略号、悬停里没有整句说明、 +// 封存后追加的工件给一个跳到运行结束之后的航迹时刻；窄屏（390px）被撑出横向滚动、浅色主题下看不清。 // // 跑在预览页上：/preview.html?syn=inquiry-*（用例见 frontend/src/dev/fixtures/inquiry.tsx）。夹具在 // frontend/src/dev/fixtures/inquiry.json，报告文档和回答文档是后端 build_catalog + compose_doc 真实组装的（虚构的数据）。 @@ -835,12 +835,12 @@ await section('运行详情「证据」页签：封存了的探索运行有入 await section('运行详情「工件」页签：质询的回答有名字和说明，不出现英文的工件种类名；封存后追加的不给航迹跳转', async () => { const { ctx, page, errors } = await open('inquiry-run-artifacts') await page.locator('[data-run-artifacts] [data-artifact-id]').first().waitFor() - // 每一行：种类（行首的标签）、说明（同一种类有几件时末尾带「#n」，去掉再比）、悬停 + // 每一行：种类（行首的标签）、说明（同一种类有几件时的「#n」另在截断范围外，不在说明里）、悬停、分组 const rows = await page.locator('[data-artifact-id]').evaluateAll((els) => els.map((el) => { const open = el.querySelector('[data-action="artifact-open"]') - const spans = open ? [...open.children] : [] - return { id: el.getAttribute('data-artifact-id'), kind: spans[0]?.textContent?.trim() ?? '', - about: (spans[1]?.textContent ?? '').replace(/\s*#\d+$/, '').trim(), title: open?.getAttribute('title') ?? '' } + return { id: el.getAttribute('data-artifact-id'), kind: el.querySelector('[data-artifact-kind-label]')?.textContent?.trim() ?? '', + about: el.querySelector('[data-artifact-about]')?.textContent?.trim() ?? '', title: open?.getAttribute('title') ?? '', + group: el.getAttribute('data-artifact-class') } })) const answers = fx.run_artifacts.filter((a) => a.kind === 'inquiry_answer').map((a) => rows.find((r) => r.id === a.id)) check('质询的回答：种类写「质询回答」', answers.length === 4 && answers.every((r) => r?.kind === '质询回答'), JSON.stringify(answers)) @@ -864,7 +864,9 @@ await section('运行详情「工件」页签：质询的回答有名字和说 await page.locator(`[data-artifact-id="${doc.id}"] [data-action="artifact-moment"]`).click() const jumped = await page.locator('[data-fixture="inquiry-run-artifacts"]').getAttribute('data-fixture-moment') check('……点报告文档的跳转：到它产出的那一刻', Number(jumped) === Date.parse(`${doc.created_at}Z`), jumped) - check('悬停写「打开质询回答」', answers.every((r) => r?.title.startsWith('打开质询回答')), answers.map((r) => r?.title).join(' / ')) + check('悬停写「打开质询回答」，接着是整句说明（行上截断了也看得全）', answers.every((r) => r?.title.startsWith(`打开质询回答：${r.about}`)), + answers.map((r) => r?.title).join(' / ')) + check('质询回答归在「核查记录」，不算证据快照', answers.every((r) => r?.group === 'verify'), answers.map((r) => r?.group).join('、')) const pane = await text(page.locator('[data-run-artifacts]')) check('工件页签里不出现英文的工件种类名', !/inquiry_answer|report_doc|query_snapshot/.test(pane) && rows.every((r) => !/[a-z_]{4,}/.test(r.kind)), rows.map((r) => r.kind).join('、')) @@ -1531,7 +1533,7 @@ await section('窄屏与深浅色', async () => { const row = `[data-artifact-id="${long.id}"] [data-action="artifact-open"]` await page.locator(row).waitFor() const o = await overflow(page, '[data-run-artifacts]') - const ratios = { kind: await ratioOf(page, `${row} > span:nth-child(1)`), about: await ratioOf(page, `${row} > span:nth-child(2)`) } + const ratios = { kind: await ratioOf(page, `${row} [data-artifact-kind-label]`), about: await ratioOf(page, `${row} [data-artifact-about]`) } check(`390px 工件页签（${theme}）：质询回答的长说明截断、不横向溢出，种类和说明对比度 ≥ 4.5`, o.page <= 0 && o.box <= 0 && ratios.kind >= 4.5 && ratios.about >= 4.5, JSON.stringify({ o, kind: Number(ratios.kind.toFixed(2)), about: Number(ratios.about.toFixed(2)) })) diff --git a/scripts/check-verify.mjs b/scripts/check-verify.mjs index d3c6ca5e..2ab439bd 100644 --- a/scripts/check-verify.mjs +++ b/scripts/check-verify.mjs @@ -22,7 +22,9 @@ // 标出，老工件照旧纯文本； // - 出具缺口：证据页的出具横幅（真的 EvidencePane 里那一个 IssuanceBanner，和问数据、画布右栏同一个）和成果节点印章的 // 悬停说明把双盲复算、反方审稿报上来的缺口另起「核查未通过」「核查未完成」两组，不放在「校验未全部完成」下； -// - 记录页的工件列表：双盲复算对照、反方审稿记录两种工件有名字和说明，不露键名； +// - 记录页的工件列表：双盲复算对照、反方审稿记录两种工件有名字和说明，不露键名；和质询回答一起归在「核查记录」一组， +// 不再算进说明写着「原始结果」的「证据快照」，筛选的件数、悬停说明跟着改；390px 窄屏上说明换到第二行（以前挤在一行里 +// 只剩三个字），第几件、第几次尝试在截断范围外看得见，悬停写全说明； // - 检查器：口径卡、指标、口径说明、盲算模型、相对误差、未采用原流程时、启用，每一项都真的写进节点配置；字段的 // 叫法和服务端校验报错里的（engine/labels.py 的 DUAL_CHECK_FIELD_LABEL）一字不差；选口径卡、盲算模型、启用三态用的是 // 和反方审稿共用的控件（verifyFields.tsx）；盲算模型不藏在高级选项里 @@ -32,8 +34,8 @@ // - 390px 窄屏不横向溢出，深浅色都读得清，键盘能操作。 // // 页面都跑在预览页（/preview.html?syn=…，用例在 frontend/src/dev/fixtures/dual_check.tsx，夹具 dual_check.json 两边 -// 共用）和设置页上，接口一律 page.route 伪造：完整对照的工件、审批回复、设置的读写都在浏览器里答，别的非 GET 拦掉， -// 不碰真实的写接口。文案对照那一节不开浏览器：读 backend/app/api/settings.py、backend/app/engine/labels.py，terms.ts 借 vite +// 共用；工件页签的用例在 run_artifacts.tsx，工件列表直接交给页签）和设置页上，接口一律 page.route 伪造：完整对照的工件、 +// 审批回复、设置的读写都在浏览器里答，别的非 GET 拦掉，不碰真实的写接口。文案对照那一节不开浏览器：读 backend/app/api/settings.py、backend/app/engine/labels.py，terms.ts 借 vite // 转译后直接 import。 // // node scripts/check-verify.mjs @@ -1203,21 +1205,177 @@ await section('记录页的工件列表：双盲复算对照、反方审稿记 const { page, errors } = await preview('dual-check-approval') const got = await page.evaluate(async () => { const m = await import('/src/pages/runs/model.ts') + const kinds = ['dual_check', 'challenge', 'inquiry_answer', 'query_snapshot', 'tool_snapshot', 'retrieval_snapshot', + 'metric_set', 'metric_input', 'report_doc', 'schema_snapshot', 'node_output', 'some_future_kind'] return { dual: m.artifactKindLabel('dual_check'), challenge: m.artifactKindLabel('challenge'), dualDesc: m.artifactDescription('dual_check', { metrics: 2 }), dualBare: m.artifactDescription('dual_check', null), challengeDesc: m.artifactDescription('challenge', { report: 'report' }), - evidence: m.isEvidence('dual_check') && m.isEvidence('challenge'), + input: m.artifactKindLabel('metric_input'), inputDesc: m.artifactDescription('metric_input', { path: 'vars.region_rows' }), + inputBare: m.artifactDescription('metric_input', null), + groups: Object.fromEntries(kinds.map((k) => [k, m.artifactGroup(k)])), + evidence: Object.fromEntries(kinds.map((k) => [k, m.isEvidence(k)])), } }) check('种类：双盲复算对照、反方审稿记录，不露键名', got.dual === '双盲复算对照' && got.challenge === '反方审稿记录', JSON.stringify(got)) check('……说明写清装的是什么：双盲复算带指标个数，没有 meta 的老数据也有一句', got.dualDesc === '双盲复算：2 个指标两边的 SQL、取值与差异说明' && got.dualBare === '双盲复算：两边的 SQL、取值与差异说明' && got.challengeDesc === '反方审稿：每句结论的判断、理由和反方执行的查询', JSON.stringify(got)) - check('……两种都算证据（列表里醒目）', got.evidence) + // 核查记录：双盲复算、反方审稿、审批质询对结论的核查与问答。以前算进「证据快照」，那一组的说明写的是「查询、工具调用、 + // 知识检索的原始结果」，和装的东西对不上。别的种类的归类不变：核查时执行的查询仍是查询快照，认不出的种类宁可醒目 + const want = { dual_check: 'verify', challenge: 'verify', inquiry_answer: 'verify', node_output: 'output' } + const wrong = Object.entries(got.groups).filter(([k, g]) => g !== (want[k] ?? 'evidence')) + check('……双盲复算对照、反方审稿记录、质询回答归在「核查记录」；查询、工具、检索的快照，口径卡、报告文档、表结构仍是证据快照', + wrong.length === 0, JSON.stringify(wrong)) + check('……isEvidence 只认证据快照这一组', Object.entries(got.evidence).every(([k, v]) => v === ((want[k] ?? 'evidence') === 'evidence')), + JSON.stringify(got.evidence)) + check('……口径卡里容器型变量输入的完整值（metric_input）也有名字和说明，不露键名', got.input === '指标输入' + && got.inputDesc === '口径卡输入「vars.region_rows」的完整值' && got.inputBare === '口径卡输入的完整值', JSON.stringify(got)) check('……页面没有报错', errors.length === 0, errors.join('；')) }) +/** 工件页签里每一行：种类、说明、第几件、悬停、分组，和种类标签、说明、第几件、时刻各自的位置 */ +const artifactRows = (page) => page.locator('[data-run-artifacts] [data-artifact-id]').evaluateAll((els) => els.map((el) => { + const rect = (n) => { + if (!n) return null + const r = n.getBoundingClientRect() + return { left: r.left, right: r.right, top: r.top, bottom: r.bottom, width: r.width } + } + const box = (sel) => rect(el.querySelector(sel)) + const about = el.querySelector('[data-artifact-about]') + return { + id: el.getAttribute('data-artifact-id'), group: el.getAttribute('data-artifact-class'), + kind: el.querySelector('[data-artifact-kind-label]')?.textContent?.trim() ?? '', + about: about?.textContent?.trim() ?? '', nth: el.querySelector('[data-artifact-nth]')?.textContent?.trim() ?? '', + title: el.querySelector('[data-action="artifact-open"]')?.getAttribute('title') ?? '', + // 说明看得见的宽度、是否被截断（scrollWidth 比看得见的宽） + visible: about ? Math.round(about.getBoundingClientRect().width) : 0, cut: about ? about.scrollWidth > about.clientWidth + 1 : false, + row: rect(el), chip: box('[data-artifact-kind-label]'), line: box('[data-artifact-about-line]'), + nthBox: box('[data-artifact-nth]'), hash: box('[title^="内容校验值"]'), + when: box('[data-action="artifact-moment"]') ?? box('[data-artifact-time]'), + } +})) + +await section('记录页的工件页签：核查记录单独一组，筛选的件数和说明跟着改', async () => { + // 夹具（frontend/src/dev/fixtures/run_artifacts.tsx）：22 件，证据快照 10 件（查询快照 6、表结构、指标输入、口径卡、 + // 报告文档），核查记录 4 件（双盲复算对照、反方审稿记录、两条质询回答），节点产出 8 件 + const { page, errors } = await preview('run-artifacts') + await page.locator('[data-run-artifacts] [data-artifact-id]').first().waitFor() + const filters = await page.locator('[data-run-artifacts] [data-artifact-kind]').evaluateAll((els) => els.map((el) => ({ + key: el.getAttribute('data-artifact-kind'), text: el.textContent.replace(/\s+/g, ' ').trim(), title: el.getAttribute('title') ?? '', + }))) + check('筛选：全部、证据快照、核查记录、节点产出四档，件数对得上', JSON.stringify(filters.map((f) => f.text)) + === JSON.stringify(['全部 22', '证据快照 10', '核查记录 4', '节点产出 8']), filters.map((f) => f.text).join('、')) + const hint = Object.fromEntries(filters.map((f) => [f.key, f.title])) + check('「核查记录」的悬停说清装的是双盲复算、反方审稿、审批质询，核查时执行的查询在证据快照里', + ['双盲复算', '反方审稿', '审批质询', '证据快照'].every((w) => hint.verify?.includes(w)), hint.verify) + check('「证据快照」的悬停不再只说「原始结果」：口径卡、报告文档、表结构也写上，不提核查', + ['查询', '口径卡', '报告文档', '表结构'].every((w) => hint.evidence?.includes(w)) && !/核查|复算|审稿|质询/.test(hint.evidence ?? ''), + hint.evidence) + const all = await artifactRows(page) + check('「全部」列出 22 件，每件都标了分组', all.length === 22 && all.every((r) => ['evidence', 'verify', 'output'].includes(r.group)), + `${all.length} 件`) + check('种类都是中文，不露键名（metric_input 写「指标输入」）', all.every((r) => r.kind && !/[a-z_]{4,}/.test(r.kind)), + [...new Set(all.map((r) => r.kind))].join('、')) + await page.locator('[data-run-artifacts] [data-artifact-kind="verify"]').click() + const verify = await artifactRows(page) + check('点「核查记录」：只剩双盲复算对照、反方审稿记录、质询回答 4 件', verify.length === 4 && verify.every((r) => r.group === 'verify') + && JSON.stringify([...new Set(verify.map((r) => r.kind))].sort()) === JSON.stringify(['双盲复算对照', '反方审稿记录', '质询回答'].sort()), + verify.map((r) => r.kind).join('、')) + check('……按节点分组：双盲复算、反方审稿各一组，质询回答在「不属于某个节点」', JSON.stringify(await page.locator('[data-run-artifacts] [data-artifact-group]') + .evaluateAll((els) => els.map((e) => e.getAttribute('data-artifact-group')))) === JSON.stringify(['dual', 'review', ''])) + await page.locator('[data-run-artifacts] [data-artifact-kind="evidence"]').click() + const evidence = await artifactRows(page) + check('点「证据快照」：10 件，没有核查记录混在里面（核查时执行的查询快照照旧在这里）', evidence.length === 10 + && evidence.every((r) => r.group === 'evidence') && !evidence.some((r) => /双盲复算对照|反方审稿记录|质询回答/.test(r.kind)) + && evidence.filter((r) => r.kind === '查询快照').length === 6, evidence.map((r) => r.kind).join('、')) + await page.locator('[data-run-artifacts] [data-artifact-kind="output"]').click() + const output = await artifactRows(page) + check('点「节点产出」：8 件，都是节点产出', output.length === 8 && output.every((r) => r.group === 'output' && r.kind === '节点产出'), + output.map((r) => r.kind).join('、')) + await page.locator('[data-run-artifacts] [data-artifact-kind="all"]').click() + // 宽屏一行排下：说明和种类在同一行，第几件紧跟说明 + const wide = await artifactRows(page) + const looped = wide.filter((r) => r.nth) + check('宽屏（1280）：说明和种类在同一行', wide.every((r) => r.line && r.chip && Math.abs(r.line.top - r.chip.top) < 8), + JSON.stringify(wide.filter((r) => !(r.line && r.chip && Math.abs(r.line.top - r.chip.top) < 8)).map((r) => r.kind))) + check('宽屏：逐区汇总的三次产出编了号，重试的那次写明第 2 次尝试', JSON.stringify(looped.filter((r) => r.kind === '节点产出').map((r) => r.nth)) + === JSON.stringify(['#1', '#2 · 第 2 次尝试', '#3']), looped.map((r) => `${r.kind}${r.nth}`).join('、')) + check('宽屏：短的说明不截断', wide.filter((r) => [...r.about].length <= 20).every((r) => !r.cut), + wide.filter((r) => [...r.about].length <= 20 && r.cut).map((r) => r.about).join('、')) + check('悬停写全说明（打开哪一种、装的是什么、第几件）', wide.every((r) => r.title.startsWith(`打开${r.kind}：${r.about}`) + && (!r.nth || r.title.includes(r.nth))), wide.find((r) => !r.title.startsWith(`打开${r.kind}：${r.about}`))?.title) + check('页面没有报错', errors.length === 0, errors.join('；')) +}) + +await section('记录页的工件页签：390px 说明换到第二行，第几件在截断范围外，不横向溢出、深浅色可读', async () => { + for (const theme of ['dark', 'light']) { + const { page, errors } = await preview('run-artifacts', { width: 390, height: 844, theme }) + await page.locator('[data-run-artifacts] [data-artifact-id]').first().waitFor() + const rows = await artifactRows(page) + const o = await page.evaluate(() => { + const doc = document.documentElement + const pane = document.querySelector('[data-run-artifacts]') + const scroller = pane?.querySelector('.overflow-y-auto') + return { page: doc.scrollWidth - doc.clientWidth, pane: pane ? pane.scrollWidth - pane.clientWidth : -1, + list: scroller ? scroller.scrollWidth - scroller.clientWidth : -1 } + }) + check(`390px（${theme}）：页签不横向溢出`, o.page <= 0 && o.pane <= 0 && o.list <= 0, JSON.stringify(o)) + // 说明在种类下面另起一行；以前和种类、校验值、大小、时刻挤在一行，只剩三个字宽（约 35px） + const below = rows.filter((r) => r.line && r.chip && r.line.top >= r.chip.bottom - 1) + check(`390px（${theme}）：每一行的说明都换到种类下面的第二行`, below.length === rows.length, + rows.filter((r) => !below.includes(r)).map((r) => r.kind).join('、')) + const widths = rows.map((r) => r.visible) + const narrowest = rows.filter((r) => r.cut).reduce((m, r) => Math.min(m, r.visible), Infinity) + check(`390px（${theme}）：说明看得见的宽度：被截断的至少 200px，其余整句看得全`, + rows.every((r) => !r.cut || r.visible >= 200), `截断的最窄 ${narrowest === Infinity ? '—' : `${narrowest}px`}；各行 ${widths.join('/')}`) + const long = rows.find((r) => r.kind === '质询回答' && r.about.endsWith('…」的回答')) + check(`390px（${theme}）：长问题的质询回答截断了，悬停里是整句说明`, !!long && long.cut && long.title.includes(long.about), + long ? `${long.visible}px · ${long.title}` : '没找到长问题的那一条') + // 第几件：放在截断范围外，整个落在这一行里、看得见 + const numbered = rows.filter((r) => r.nth) + check(`390px（${theme}）：第几件、第几次尝试都看得见（不在被截断的说明里，不出这一行）`, numbered.length >= 5 + && numbered.every((r) => r.nthBox && r.nthBox.width > 0 && r.nthBox.right <= r.row.right + 0.5 && r.nthBox.left >= r.row.left), + numbered.map((r) => `${r.kind}${r.nth}`).join('、')) + // 第一行：种类、校验值、大小，时刻（或时间）和它们在同一行 + check(`390px（${theme}）：时刻（或时间）留在第一行，和种类对齐`, rows.every((r) => r.when && r.chip + && Math.abs((r.when.top + r.when.bottom) / 2 - (r.chip.top + r.chip.bottom) / 2) <= 4), + JSON.stringify(rows.filter((r) => !(r.when && r.chip && Math.abs((r.when.top + r.when.bottom) / 2 - (r.chip.top + r.chip.bottom) / 2) <= 4)) + .map((r) => [r.kind, r.when, r.chip]).slice(0, 2))) + check(`390px（${theme}）：内容校验值还在第一行`, rows.every((r) => r.hash && r.chip && r.hash.bottom <= r.line.top + 1)) + const c = await page.evaluate(() => { + const base = getComputedStyle(document.body).backgroundColor + const pick = (sel) => { + const el = document.querySelector(sel) + if (!el) return null + let bg = 'rgba(0, 0, 0, 0)' + for (let n = el; n && n !== document.documentElement; n = n.parentElement) { + const v = getComputedStyle(n).backgroundColor + if (v !== 'rgba(0, 0, 0, 0)' && v !== 'transparent') { bg = v; break } + } + return { fg: getComputedStyle(el).color, bg } + } + return { base, kind: pick('[data-artifact-class="verify"] [data-artifact-kind-label]'), + about: pick('[data-artifact-class="verify"] [data-artifact-about]'), nth: pick('[data-artifact-nth]'), + filter: pick('[data-artifact-kind="verify"]') } + }) + for (const key of ['kind', 'about', 'nth', 'filter']) { + const v = c[key] + const ratio = v ? contrast(v.fg, v.bg, c.base) : 0 + check(`${theme}：${({ kind: '种类', about: '说明', nth: '第几件', filter: '「核查记录」筛选' })[key]}对比度 ≥ 4.5`, ratio >= 4.5, + `${ratio.toFixed(2)}（${v?.fg} on ${v?.bg}）`) + } + const bar = await page.locator('[data-run-artifacts] [data-artifact-kind]').evaluateAll((els) => + els.every((el) => { const r = el.getBoundingClientRect(); return r.left >= 0 && r.right <= innerWidth && r.width > 0 })) + check(`390px（${theme}）：四个筛选按钮都在屏幕里`, bar) + await shot(page, `run-artifacts-narrow-${theme}`) + check(`390px（${theme}）：页面没有报错`, errors.length === 0, errors.join('；')) + } + const wide = await preview('run-artifacts', { width: 1280, height: 900, theme: 'light' }) + await wide.page.locator('[data-run-artifacts] [data-artifact-id]').first().waitFor() + await shot(wide.page, 'run-artifacts-wide-light') +}) + // ---------------------------------------------------------------- 检查器与节点卡片 /** From 2a64099cb85d14acfb50f01dade863132ba7faf0 Mon Sep 17 00:00:00 2001 From: ThearchyHelios Date: Tue, 6 Oct 2026 17:24:17 +0800 Subject: [PATCH 4/6] =?UTF-8?q?=E5=AF=B9=E6=AF=94=E9=A1=B5=E6=B2=A1?= =?UTF-8?q?=E5=B8=A6=E8=BF=90=E8=A1=8C=E6=97=B6=E7=9A=84=E8=AF=B4=E6=98=8E?= =?UTF-8?q?=E6=8A=8A=E8=8F=9C=E5=8D=95=E9=A1=B9=E7=9A=84=E4=B8=A4=E7=A7=8D?= =?UTF-8?q?=E5=8F=AB=E6=B3=95=E9=83=BD=E5=86=99=E4=B8=8A=EF=BC=9A=E4=B8=8A?= =?UTF-8?q?=E4=B8=80=E6=AC=A1=E6=B2=A1=E6=9C=89=E6=88=90=E5=8A=9F=E6=97=B6?= =?UTF-8?q?=E8=BF=90=E8=A1=8C=E8=AF=A6=E6=83=85=E7=9A=84=E8=8F=9C=E5=8D=95?= =?UTF-8?q?=E9=87=8C=E5=86=99=E7=9A=84=E6=98=AF=E3=80=8C=E4=B8=8E=E4=B8=8A?= =?UTF-8?q?=E4=B8=80=E6=AC=A1=E6=88=90=E5=8A=9F=E7=9A=84=E8=BF=90=E8=A1=8C?= =?UTF-8?q?=E5=AF=B9=E6=AF=94=E3=80=8D=EF=BC=8C=E8=AF=B4=E6=98=8E=E5=8F=AA?= =?UTF-8?q?=E5=86=99=E3=80=8C=E4=B8=8E=E4=B8=8A=E4=B8=80=E6=AC=A1=E5=AF=B9?= =?UTF-8?q?=E6=AF=94=E3=80=8D=E4=BC=9A=E8=AE=A9=E4=BA=BA=E6=89=BE=E4=B8=8D?= =?UTF-8?q?=E5=88=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit check-compare 跟着核对两种叫法都在 --- frontend/src/lib/terms.ts | 3 ++- scripts/check-compare.mjs | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/frontend/src/lib/terms.ts b/frontend/src/lib/terms.ts index 4dbad10e..22b032c2 100644 --- a/frontend/src/lib/terms.ts +++ b/frontend/src/lib/terms.ts @@ -3240,7 +3240,8 @@ export const RUN_COMPARE_TEXT = { pickGone: (id: string, missing: boolean) => `${id}（${missing ? '记录不存在' : '无法读取'}）`, // 页面状态 noTarget: '未指定要对比的运行', - noTargetHint: '在运行详情的「更多」菜单中选择「与上一次对比」，即可对照本次与上一次成功的运行', + /** 菜单项的两种叫法都写上：上一次没有成功时，菜单里写的是「与上一次成功的运行对比」 */ + noTargetHint: '在运行详情的「更多」菜单中选择「与上一次对比」或「与上一次成功的运行对比」，即可对照本次与上一次成功的运行', toRuns: '前往记录', finding: '正在查找基准运行…', loading: '正在对比两次运行…', diff --git a/scripts/check-compare.mjs b/scripts/check-compare.mjs index d742f569..71cd3326 100644 --- a/scripts/check-compare.mjs +++ b/scripts/check-compare.mjs @@ -1192,7 +1192,8 @@ await section('出错与找不到基准', async () => { const none = await open('/runs/compare') await settled(none.page, 'no-target') - check('什么都没带：说明从哪里进来', (await text(none.page, '[data-compare-page]')).includes('与上一次对比')) + const howTo = await text(none.page, '[data-compare-page]') + check('什么都没带：说明从哪里进来，菜单项的两种叫法都写上', howTo.includes(`「${MENU}」`) && howTo.includes(`「${MENU_LAST_OK}」`), howTo) }) await section('基准运行读不到（删了、链接过期）', async () => { From b8dfbdb3351898cfcbab762f723632040d162667 Mon Sep 17 00:00:00 2001 From: ThearchyHelios Date: Tue, 6 Oct 2026 17:25:07 +0800 Subject: [PATCH 5/6] =?UTF-8?q?=E5=AF=B9=E6=AF=94=E5=85=A5=E5=8F=A3?= =?UTF-8?q?=E7=9A=84=E6=B3=A8=E9=87=8A=E6=8D=A2=E4=B8=AA=E8=AF=B4=E6=B3=95?= =?UTF-8?q?=EF=BC=9A=E3=80=8C=E6=8E=A5=E7=9D=80=E8=B7=91=E5=AE=8C=E3=80=8D?= =?UTF-8?q?=E6=94=B9=E6=88=90=E3=80=8C=E6=8E=A5=E7=9D=80=E8=BF=90=E8=A1=8C?= =?UTF-8?q?=E5=AE=8C=E3=80=8D=EF=BC=8C=E5=92=8C=E7=95=8C=E9=9D=A2=E6=96=87?= =?UTF-8?q?=E6=A1=88=E7=9A=84=E7=94=A8=E8=AF=8D=E4=B8=80=E8=87=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- frontend/src/pages/runs/compare/entry.tsx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/frontend/src/pages/runs/compare/entry.tsx b/frontend/src/pages/runs/compare/entry.tsx index 9a31d140..b455a004 100644 --- a/frontend/src/pages/runs/compare/entry.tsx +++ b/frontend/src/pages/runs/compare/entry.tsx @@ -34,7 +34,7 @@ interface Known { key: string; previous: boolean | null } * 先写一个叫法、问到了再换成另一个，也点不到一个说错了的入口；平常运行一打开就问，人点开菜单时早已问到。预先问不到 * （找不到默认基准、出错）不提示，叫法退回「与上一次对比」，点了照常再问一次、照实说。 * - * 点了总是再问一次、按这一次的答复跳：详情页可能开了很久，中间有运行接着跑完、被删掉，基准跟着变，预先问到的不一定还是 + * 点了总是再问一次、按这一次的答复跳：详情页可能开了很久，中间有运行接着运行完、被删掉，基准跟着变，预先问到的不一定还是 * 现在的。菜单点完就收起：查找慢于一眨眼时挂一条提示，接口慢的时候不至于像没反应。离开运行详情（组件卸载）时取消请求、 * 收起提示，晚到的答复不再把人带去对比页。卸载取消不了全部：地址已经换了、新页面还没画出来（路由按过渡渲染）的那一下 * 答复回来，组件还在，请求也没取消。所以答复回来时再看一眼地址：人已经不在点菜单时的那个运行详情上，就不跳、也不提示。 From 53bb356fae0bc049b6284186d9b136f3619938cb Mon Sep 17 00:00:00 2001 From: ThearchyHelios Date: Tue, 6 Oct 2026 18:25:35 +0800 Subject: [PATCH 6/6] =?UTF-8?q?=E5=A4=8D=E6=A0=B8=E7=AC=AC=201=20=E8=BD=AE?= =?UTF-8?q?=EF=BC=9A=E5=AF=B9=E6=AF=94=E5=85=A5=E5=8F=A3=E9=A2=84=E5=85=88?= =?UTF-8?q?=E9=97=AE=E9=BB=98=E8=AE=A4=E5=9F=BA=E5=87=86=E5=B8=A6=205=20?= =?UTF-8?q?=E7=A7=92=E8=B6=85=E6=97=B6=E3=80=81=E9=97=AE=E5=88=B0=E6=B2=A1?= =?UTF-8?q?=E6=9C=89=E9=BB=98=E8=AE=A4=E5=9F=BA=E5=87=86=E6=97=B6=E5=86=99?= =?UTF-8?q?=E3=80=8C=E9=80=89=E6=8B=A9=E5=9F=BA=E5=87=86=E5=AF=B9=E6=AF=94?= =?UTF-8?q?=E2=80=A6=E3=80=8D=E7=9B=B4=E6=8E=A5=E5=8E=BB=E5=AF=B9=E6=AF=94?= =?UTF-8?q?=E9=A1=B5=E6=89=8B=E5=8A=A8=E9=80=89=E3=80=81=E5=88=87=E5=9B=9E?= =?UTF-8?q?=E9=A1=B5=E9=9D=A2=E6=97=B6=E5=86=8D=E9=97=AE=E4=B8=80=E6=AC=A1?= =?UTF-8?q?=EF=BC=9B=E5=B7=A5=E4=BB=B6=E9=A1=B5=E7=AD=BE=E7=9A=84=E6=82=AC?= =?UTF-8?q?=E5=81=9C=E7=85=A7=E5=AE=9E=E5=86=99=EF=BC=8C320px=20=E6=97=B6?= =?UTF-8?q?=E6=A0=A1=E9=AA=8C=E5=80=BC=E5=92=8C=E5=A4=A7=E5=B0=8F=E4=B8=8D?= =?UTF-8?q?=E5=86=8D=E6=8B=86=E5=BC=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 对比入口（pages/runs/compare/entry.tsx）：预先问 compare/base 卡着不回时 5 秒后按没问到算，叫法退回「与上一次对比」、可点，不再一直停在不可点的「正在查找」；问到没有默认基准（多为工作流的第一次运行）时写「选择基准对比…」，点了直接去只带本次的对比页手动选（对比页自己再找一次），不再写「与上一次对比」、点了再问一遍弹提示；切去别的标签页再切回来时再问一次，问的期间保留原来的叫法、可点，问到不一样才换，问不到不改；更正预先问那段注释的前提（compare/base 不回 409、422，不先问是因为这些入口本来不给点） - 运行详情「工件」页签头的悬停写上证据快照、核查记录和每个节点的产出三组（RUN_ARTIFACTS_TEXT.tabTitle，RunDetailView 只换这一处）；证据快照的悬停不再说「结论里的数字从这里来」，点明含核查、质询时执行的查询；核查记录的悬停用行上的种类名，指明其间执行的查询见「证据快照」；两句都在 45 字内 - 工件行的校验值和大小包在一起排、一起折行，这一栏窄于 22rem 时收起校验值：320px 下大小不再单独折到种类下面，每行仍是两行 - 对比页没带运行时的说明缩成 32 字，不逐个列菜单项的叫法 - 检查：check-compare 补预先问超时、没有默认基准、切回页面再问、点了才发现没有基准后叫法跟着改、工件页签悬停几节；check-verify 改两组悬停的断言、补 320px；check-schedules 的假 compare/base 补上 previous: false（和服务端一致），断言运行详情菜单项与触发历史链接的叫法一字不差 --- frontend/src/lib/terms.ts | 25 ++- frontend/src/pages/runs/ArtifactsPane.tsx | 11 +- frontend/src/pages/runs/RunDetailView.tsx | 4 +- frontend/src/pages/runs/compare/entry.tsx | 68 ++++++-- frontend/src/pages/runs/model.ts | 8 +- scripts/check-compare.mjs | 185 ++++++++++++++++++---- scripts/check-schedules.mjs | 12 +- scripts/check-verify.mjs | 51 ++++-- 8 files changed, 292 insertions(+), 72 deletions(-) diff --git a/frontend/src/lib/terms.ts b/frontend/src/lib/terms.ts index 22b032c2..780367c1 100644 --- a/frontend/src/lib/terms.ts +++ b/frontend/src/lib/terms.ts @@ -3194,6 +3194,8 @@ export const RUN_COMPARE_TEXT = { menu: '与上一次对比', /** 上一次失败、取消、还没结束：基准是再往前成功的那一次，不能说成「上一次」 */ menuLastOk: '与上一次成功的运行对比', + /** 没有默认基准（多为工作流的第一次运行）：没有「上一次」可比，点了去对比页手动选 */ + menuPick: '选择基准对比…', menuSealedOnly: '运行结束并封存后才能对比', /** 没有 workflow_id 的运行：画布、问数据里没保存就运行的，或者工作流删掉之后被置空的。服务端只比同一个已保存的工作流 */ menuNoWorkflow: '工作流未保存或已删除，无法对比', @@ -3240,8 +3242,8 @@ export const RUN_COMPARE_TEXT = { pickGone: (id: string, missing: boolean) => `${id}（${missing ? '记录不存在' : '无法读取'}）`, // 页面状态 noTarget: '未指定要对比的运行', - /** 菜单项的两种叫法都写上：上一次没有成功时，菜单里写的是「与上一次成功的运行对比」 */ - noTargetHint: '在运行详情的「更多」菜单中选择「与上一次对比」或「与上一次成功的运行对比」，即可对照本次与上一次成功的运行', + /** 不逐个列菜单项的叫法（看有没有默认基准、是不是紧挨着的上一次，有三种），只说在哪里打开、默认比的是哪一次 */ + noTargetHint: '可从运行详情的「更多」菜单打开对比，默认以上一次成功的运行为基准', toRuns: '前往记录', finding: '正在查找基准运行…', loading: '正在对比两次运行…', @@ -3400,17 +3402,24 @@ export const RUN_COMPARE_TEXT = { /** * 运行详情「工件」页签（pages/runs/ArtifactsPane.tsx）：这次运行按内容校验值存下的每一件东西，按节点分组。筛选按 - * pages/runs/model.ts 的 artifactGroup 分三组：证据快照是结论里数字的出处；核查记录是双盲复算、反方审稿、审批质询对 - * 结论的核查与问答，单独一组，不和数字的出处混在一起；节点产出是过程里的中间值。各种工件的名字和说明在 model.ts， - * 后来新加的放在这里（质询回答的在 INQUIRY_TEXT） + * pages/runs/model.ts 的 artifactGroup 分三组：证据快照是取数、检索的原始结果和口径卡、报告文档、表结构；核查记录是 + * 双盲复算、反方审稿、审批质询对结论的核查与问答，单独一组；节点产出是过程里的中间值。按种类归组：核查、质询时执行的 + * 查询仍是查询快照，在证据快照里（一次运行里这类查询可能比流程本身的还多），所以证据快照不能说成「结论里的数字都从 + * 这里来」。各种工件的名字和说明在 model.ts，后来新加的放在这里（质询回答的在 INQUIRY_TEXT） */ export const RUN_ARTIFACTS_TEXT = { + /** 运行详情「工件」页签头上的悬停：人先看到的这句要和页签里的三组对得上。清单还没取回来时不写件数 */ + tabTitle: (n?: number | null) => + (n == null ? '本次运行保存的证据、核查记录和产出' : `${n} 件：证据快照、核查记录和每个节点每一次的产出`), filterGroup: '按类型筛选工件', filter: { all: '全部', evidence: '证据快照', verify: '核查记录', output: '节点产出' } as Record, - /** 筛选按钮的悬停：这一组装的是什么。核查时执行的查询按种类仍是查询快照，归在证据快照里，要说一声 */ + /** + * 筛选按钮的悬停：这一组装的是什么。核查、质询时执行的查询按种类仍是查询快照、在证据快照里，两组都要说一声； + * 核查记录这一组列的是行上的种类名（双盲复算对照、反方审稿记录、质询回答） + */ filterHint: { - evidence: '查询、工具调用、知识检索的原始结果，以及口径卡、报告文档和查询时的表结构：结论里的数字从这里来', - verify: '双盲复算的对照、反方审稿的记录、审批质询的回答：对结论的核查与问答。核查时执行的查询，快照归在证据快照里', + evidence: '查询、工具调用、知识检索的原始结果，口径卡、报告文档和表结构；含核查、质询时执行的查询', + verify: '对结论的核查与问答：双盲复算对照、反方审稿记录、质询回答；其间执行的查询见「证据快照」', output: '每个节点每执行一次的产出：循环里每一轮都有一件', } as Record, /** 同一个节点同一类的第几件：循环里几十件节点产出要分得开 */ diff --git a/frontend/src/pages/runs/ArtifactsPane.tsx b/frontend/src/pages/runs/ArtifactsPane.tsx index 4e79503a..59dd881a 100644 --- a/frontend/src/pages/runs/ArtifactsPane.tsx +++ b/frontend/src/pages/runs/ArtifactsPane.tsx @@ -80,7 +80,8 @@ const FIRST_ROWS = 300 * * 每一行按列表这一栏自己的宽度排（容器查询，不看视口：详情区在宽屏上也可能很窄）。窄时 * 说明换到第二行占满整行，第一行留种类、校验值、大小和时刻；以前挤在一行里，390px - * 宽时说明只剩三个字。序号和第几次尝试放在截断的范围外，按钮的悬停写全说明。 + * 宽时说明只剩三个字。序号和第几次尝试放在截断的范围外，按钮的悬停写全说明。再窄 + * （320px 的手机）时收起校验值，每行仍是两行。 */ export function ArtifactsPane({ list, graph, trace, labelOf, onMoment }: { list: ArtifactList @@ -261,8 +262,12 @@ function Group({ nodeId, rows, total, graph, trace, labelOf, t0, t1, onOpen, onM {about} {extra && {extra}} - {a.id.slice(0, 8)} - {formatBytes(a.size)} + {/* 校验值和大小一起排、一起折行：分开时更窄的屏上大小会单独折到种类下面、校验值留在右边。窄于 22rem（320px + 的手机）时收起校验值，第一行才放得下种类和大小；打开后的查看器里写着校验值 */} + + {a.id.slice(0, 8)} + {formatBytes(a.size)} + {at != null && onMoment ? (