diff --git a/frontend/src/canvas/VersionsSheet.tsx b/frontend/src/canvas/VersionsSheet.tsx
index 27ce45e3..36e15df5 100644
--- a/frontend/src/canvas/VersionsSheet.tsx
+++ b/frontend/src/canvas/VersionsSheet.tsx
@@ -1,4 +1,4 @@
-import { useEffect, useMemo, useState } from 'react'
+import { useEffect, useMemo, useRef, useState } from 'react'
import { ChevronLeft, History, RotateCcw, ShieldCheck } from 'lucide-react'
import clsx from 'clsx'
import { api } from '../api/client'
@@ -6,6 +6,7 @@ import {
EDIT_LOCK_TEXT, diffGraphs, toFlow, useEditLock, useStudio, type EditLock, type FlowNode, type GraphDiff,
} from '../store/studio'
import { ErrorState, Skeleton, toast } from '../components/ui'
+import { useDatasources } from '../store/catalog'
import { formatDateTime, formatTime } from '../lib/format'
import { CATALOG_DRIFT_TEXT, WORKFLOW_STATUS_LABEL } from '../lib/terms'
import { hintOf } from './shortcuts'
@@ -218,11 +219,15 @@ const DIFF_COLOR = { add: 'var(--ok)', del: 'var(--err)', mod: 'var(--warn)' } a
* 发布时的目录版本:这一版用到的表在发布时是数据目录的第几版,之后改过的标出来——下次从这一版发起正式运行时会
* 提醒「数据目录有变化」,这里先让人看到是哪几张表。
*
+ * 每张表和运行横幅同一个写法:「数据源」中文名(表名)。发布记录里只有数据源名和表名,中文名按数据源的目录清单补
+ * (变了的表服务端带着现在的中文名);取不到清单时只写表名。
+ *
* 两组分开列:SQL 里写着的表在前;Agent 可能查询的表(Agent 绑定了数据源的查询工具,发布时记下数据源中所有有
* 目录的表)在小标题下面。可能涉及的数据源里发布之后新建了目录的表,记录里没有它,按变化里给的补进来(发布时
* 「尚无目录」)
*/
function CatalogVersions({ versions, changes }: { versions: CatalogVersionsRecord; changes: CatalogDriftTable[] }) {
+ const labelOf = useCatalogLabels(versions, changes)
// 老后端给的变化没有 impact:按直接引用
const impactOf = (c: CatalogDriftTable) => (c.impact === 'possible' ? 'possible' : 'direct')
const changed = new Map(changes.map((c) => [`${impactOf(c)}/${c.source}/${c.table}`, c]))
@@ -246,7 +251,9 @@ function CatalogVersions({ versions, changes }: { versions: CatalogVersionsRecor
return (
- {table}
+
+ 「{source}」{CATALOG_DRIFT_TEXT.table(labelOf(source, table) ?? c?.label ?? null, table)}
+
{CATALOG_DRIFT_TEXT.version(v)}
{c && (
@@ -285,6 +292,39 @@ function CatalogVersions({ versions, changes }: { versions: CatalogVersionsRecor
)
}
+/** 数据源 id → 表名 → 中文名。几个版本、几次展开共用,同一个数据源只取一次清单 */
+const labelCache = new Map>>()
+
+/**
+ * 发布记录里各表现在的中文名:按数据源名找到 id(变化里带着 source_id,否则查数据源列表),取那个数据源的目录清单。
+ * 取不到(数据源删了、没权限、断网)就只写表名,不报错——这一栏是附带的说明
+ */
+function useCatalogLabels(versions: CatalogVersionsRecord, changes: CatalogDriftTable[]): (source: string, table: string) => string | null {
+ const { list: sources } = useDatasources()
+ const [labels, setLabels] = useState>>({})
+ const got = useRef(labels)
+ got.current = labels
+ const names = useMemo(() => [...new Set([...Object.keys(versions.direct ?? {}), ...Object.keys(versions.possible ?? {}),
+ ...changes.map((c) => c.source)])], [versions, changes])
+ useEffect(() => {
+ let alive = true
+ for (const name of names) {
+ const id = changes.find((c) => c.source === name && c.source_id)?.source_id ?? sources.find((x) => x.name === name)?.id
+ if (!id || got.current[name]) continue
+ let pending = labelCache.get(id)
+ if (!pending) {
+ pending = api.dataCatalog.list(id).then((d) => Object.fromEntries(d.tables.map((t) => [t.table_name, t.label])))
+ labelCache.set(id, pending)
+ // 清单会变(有人补了中文名):只缓存这一阵子,失败的不缓存
+ pending.then(() => setTimeout(() => labelCache.delete(id), 60_000), () => labelCache.delete(id))
+ }
+ pending.then((m) => { if (alive) setLabels((cur) => ({ ...cur, [name]: m })) }, () => {})
+ }
+ return () => { alive = false }
+ }, [names, changes, sources])
+ return (source, table) => labels[source]?.[table] ?? null
+}
+
/**
* 缩略图:这一版的节点按真实坐标缩进一个小框,类型色填充;恢复后会被拿掉的
* (只在画布上有)画成红色虚框叠在同一个坐标系里,改过配置的描琥珀边
diff --git a/scripts/check-studio.mjs b/scripts/check-studio.mjs
index 50a32d52..78fdeb15 100644
--- a/scripts/check-studio.mjs
+++ b/scripts/check-studio.mjs
@@ -1011,6 +1011,12 @@ await section('分析失败不静默', async () => {
// ================================================================ 5
await section('版本历史:预览、恢复成一次可撤销的改动', async () => {
const { ctx, page, state, errors } = await open()
+ // 发布时的目录版本按横幅的写法列:「数据源」中文名(表名)。中文名从数据源的目录清单补(只读,这里答掉)
+ const catRow = (table, label) => ({ table_name: table, qualified: table, is_view: false, in_schema: true, label, label_status: label ? 'confirmed' : null,
+ kind: null, counts: { proposed: 0, verified: 0, confirmed: label ? 1 : 0, rejected: 0 }, relations: 0, usage: 0, version: 1, updated_at: null, updated_by: null })
+ await page.route(/\/api\/datasources\/src-shop\/catalog$/, (route) => route.fulfill({ json: { system_notes: false, schema_note: null,
+ schema_truncated: false, schema_total: 5, tables: [catRow('parks', '景区'), catRow('visits', '入园记录'), catRow('orders', '订单'),
+ catRow('channels', '渠道'), catRow('gates', null)] } }))
// 记下按版本号取详情的请求:版本历史开着时换工作流,不能拿上一张选中的版本去请求这一张
const asked = []
page.on('request', (r) => {
@@ -1044,6 +1050,12 @@ await section('版本历史:预览、恢复成一次可撤销的改动', async
(await possible.locator('[data-version-catalog-table="gates"]').getAttribute('data-changed')) === 'true'
&& (await possible.locator('[data-version-catalog-table="gates"]').innerText()).includes('尚无目录'))
check('……发布时一张有目录的表都没有的源写一句', possibleText.includes('「crm」发布时还没有目录'), possibleText.replace(/\s+/g, ' '))
+ // 和运行横幅同一个写法:「数据源」中文名(表名);没改过的表也写中文名,没有中文名的只写表名
+ const nameOf = (table) => cat.locator(`[data-version-catalog-table="${table}"] [data-version-catalog-name]`).first().innerText().catch(() => '')
+ check('……每张表写「数据源」中文名(表名),没改过的也写', await until(async () => (await nameOf('parks')) === '「shop」景区(parks)')
+ && (await nameOf('visits')) === '「shop」入园记录(visits)' && (await nameOf('channels')) === '「shop」渠道(channels)',
+ [await nameOf('parks'), await nameOf('visits'), await nameOf('channels')].join(' | '))
+ check('……没有中文名的表只写表名', (await nameOf('gates')) === '「shop」gates', await nameOf('gates'))
await page.locator('ol[aria-label="版本"] > li').nth(2).locator('button').first().click()
await page.waitForTimeout(300)
check('没发布过的版本没有目录版本这一栏', await count(page, '[data-version-catalog]') === 0)