-
-
-
+const OFFICIAL_DATASET_IDS = ['daily', 'valuation', 'moneyflow', 'auction', 'index_daily', 'limit_events', 'popularity', 'dragon_tiger', 'sector_daily', 'stocks'];
+const DATASET_NAME = {
+ daily: '日K', valuation: '估值', moneyflow: '资金流', auction: '竞价', index_daily: '指数日K',
+ limit_events: '涨停池', popularity: '人气榜', dragon_tiger: '龙虎榜', sector_daily: '题材板块', stocks: '股票主档',
+};
+
+/* =====================================================================
+ 总览页
+ ===================================================================== */
+function buildOverviewVM() {
+ const ov = RAW.overview || {};
+ const eod = ov.eod_status || {};
+ const rev = ov.revision_status || {};
+ const pubsByDs = {};
+ (ov.publications || []).forEach((p) => { pubsByDs[p.dataset] = p; });
+ const batchByDs = {};
+ ((RAW.batches && RAW.batches.batches) || []).forEach((b) => { if (!batchByDs[b.dataset] || b.started_at > batchByDs[b.dataset].started_at) batchByDs[b.dataset] = b; });
+ const hidx = healthIndex();
+ const totalOfficial = OFFICIAL_DATASET_IDS.length;
+ const publishedCount = OFFICIAL_DATASET_IDS.filter((id) => pubsByDs[id] && pubsByDs[id].state === 'published').length;
+ const anomalyCount = (ov.anomalies || []).length;
+ const recentCalls = ov.recent_calls || [];
+ const successRate = recentCalls.length ? (recentCalls.filter((c) => c.ok).length / recentCalls.length * 100) : null;
+
+ // 主站回退页面：主源异常且备源健康 → 判定为“回退中”的 provisional 数据集
+ let fallbackPages = 0;
+ (RAW.lineage && RAW.lineage.items || []).forEach((it) => {
+ if (it.tier !== 'provisional' || !it.backup_source) return;
+ const rows = it.live_provider_health || [];
+ const primaryProv = (it.providers || [])[0];
+ const backupProv = (it.providers || [])[1];
+ const primaryState = worstBucket(rows.filter((r) => r.provider === primaryProv).map((r) => bucketOf(r.state)));
+ const backupState = worstBucket(rows.filter((r) => r.provider === backupProv).map((r) => bucketOf(r.state)));
+ if ((primaryState === 'fail' || primaryState === 'degrade' || primaryState === 'slow') && backupState === 'ok') fallbackPages += 1;
+ });
+
+ const datasetCards = OFFICIAL_DATASET_IDS.map((id) => {
+ const pub = pubsByDs[id];
+ const batch = batchByDs[id];
+ let bucket = 'plan', note = '';
+ if (pub) {
+ bucket = pub.state === 'published' ? 'ok' : (pub.state === 'degraded' ? 'degrade' : 'fail');
+ note = pub.published_at ? hm(pub.published_at) : '';
+ } else if (batch) {
+ bucket = batch.state === 'failed' ? 'fail' : (batch.state === 'staged' ? 'review' : 'plan');
+ note = batch.error ? esc(batch.error) : '';
+ }
+ const rows = (batch && batch.rows_out) || (pub && pub.rows_out) || null;
+ return { id, name: DATASET_NAME[id] || id, bucket, time: note && !batch?.error ? note : '', rows, err: batch && batch.error ? batch.error : '' };
+ });
+
+ // 实时观察层：eastmoney / tencent 的真实 provider_health 行
+ const catalogByProv = {};
+ (RAW.catalog && RAW.catalog.items || []).forEach((it) => { catalogByProv[it.provider] = it; });
+ const observers = [];
+ ['eastmoney', 'tencent'].forEach((prov) => {
+ const rows = hidx[prov] || [];
+ const cat = catalogByProv[prov];
+ rows.forEach((row) => {
+ const iface = (cat && cat.interfaces.find((i) => i.interface === row.interface)) || {};
+ observers.push({
+ name: iface.capability || row.interface,
+ provider: prov,
+ interface: row.interface,
+ lastOk: row.last_ok_at,
+ lat: row.last_latency_ms,
+ bucket: bucketOf(row.state),
+ note: row.last_error || row.last_fallback_reason || '',
+ });
+ });
+ });
+
+ // 主站影响：lineage() 条目按 known_consumers 展开
+ const siteImpact = [];
+ (RAW.lineage && RAW.lineage.items || []).forEach((it) => {
+ const rows = it.live_provider_health || [];
+ const bucket = it.tier === 'official'
+ ? (it.publication ? (it.publication.state === 'published' ? 'ok' : (it.publication.state === 'degraded' ? 'degrade' : 'fail')) : (rows.length ? worstBucket(rows.map((r) => bucketOf(r.state))) : 'plan'))
+ : (rows.length ? worstBucket(rows.map((r) => bucketOf(r.state))) : 'off');
+ const note = rows.find((r) => r.last_error)?.last_error || rows.find((r) => r.last_fallback_reason)?.last_fallback_reason || '';
+ (it.known_consumers || []).forEach((c) => {
+ siteImpact.push({ page: c, dataset: it.dataset, bucket, note });
+ });
+ });
+ const okPages = siteImpact.filter((s) => s.bucket === 'ok').length;
+
+ // 今晚时间线：真实 jobs() 定义 + job_runs
+ const jobDefs = (RAW.jobs && RAW.jobs.jobs || []).filter((j) => j.at !== 'manual');
+ const runsByJob = {};
+ ((RAW.jobs && RAW.jobs.runs) || []).forEach((r) => { (runsByJob[r.job_id] = runsByJob[r.job_id] || []).push(r); });
+ const timeline = jobDefs.map((j) => {
+ const runs = (runsByJob[j.id] || []).slice().sort((a, b) => (a.id < b.id ? 1 : -1));
+ const latest = runs[0];
+ let st = 'wait';
+ if (latest) st = latest.state === 'ok' ? 'done' : (latest.state === 'failed' ? 'fail' : 'wait');
+ return { t: (j.at.split('-')[0] || j.at).slice(0, 5), label: j.title, state: st, jobId: j.id };
+ });
+
+ // 待处理异常：批次失败/停滞 + 主源连续失败 + 未配置授权源
+ const incidents = [];
+ (ov.anomalies || []).forEach((b) => {
+ incidents.push({ sev: 'fail', tag: b.state, title: `${DATASET_NAME[b.dataset] || b.dataset} ${b.state === 'failed' ? '失败' : '停滞'}`, meta: `${b.error ? esc(b.error) : '无错误详情'} · 批次 ${b.batch_id}`, dataset: b.dataset });
+ });
+ if (eod.state === 'waiting_upstream' || eod.state === 'cutoff_failed') {
+ incidents.push({ sev: eod.state === 'cutoff_failed' ? 'fail' : 'slow', tag: eod.state, title: eod.state === 'cutoff_failed' ? '盘后批已截止失败' : '等待上游重试', meta: `已试 ${eod.attempts || 0} 次${(eod.missing_datasets || []).length ? ' · 缺 ' + eod.missing_datasets.join(',') : ''}`, dataset: (eod.missing_datasets || [])[0] || '' });
+ }
+ Object.keys(hidx).forEach((prov) => {
+ const bad = (hidx[prov] || []).filter((r) => (r.consec_failures || 0) > 0 && bucketOf(r.state) === 'fail');
+ if (bad.length) incidents.push({ sev: 'fail', tag: prov, title: `${prov} 部分接口连续失败`, meta: bad.map((r) => `${r.interface}×${r.consec_failures}`).join(' · '), provider: prov });
+ });
+ const ifindCat = catalogByProv.ifind;
+ if (ifindCat && !(ifindCat.credential && ifindCat.credential.configured)) {
+ incidents.push({ sev: 'off', tag: '未配置', title: 'iFinD · 授权源未启用', meta: '凭证未配置 · 功能隐藏 · 配置后启用', provider: 'ifind' });
+ }
+
+ return {
+ trade_date: ov.trade_date, session_phase: ov.session_phase, eod, rev,
+ publishedCount, totalOfficial, anomalyCount, successRate,
+ fallbackPages, datasetCards, observers, siteImpact, okPages, timeline, incidents,
+ };
+}
+
+function heroHtml(vm) {
+ const anomalyTxt = vm.anomalyCount ? `
${vm.anomalyCount} 项异常` : `
无异常`;
+ const tags = [];
+ if (vm.eod.state === 'waiting_upstream') tags.push(tagHtml('amb', `
等待上游 · 已试 ${vm.eod.attempts || 0} 次`));
+ if (vm.rev.state === 'waiting_review') tags.push(tagHtml('cy', '复核 · 待发布'));
+ const subParts = [];
+ if (vm.eod.attempts) subParts.push(`已试
${vm.eod.attempts} 次`);
+ if (vm.eod.next_retry_at) subParts.push(`下次重试
${hm(vm.eod.next_retry_at)}`);
+ if ((vm.eod.missing_datasets || []).length) subParts.push(`缺
${esc(vm.eod.missing_datasets.join(','))}`);
+ if (vm.rev.window) subParts.push(`复核窗口
${esc(vm.rev.window)}`);
+ return `
` +
+ `
` +
+ `
${vm.anomalyCount ? '部分异常' : '整体可用'}·${anomalyTxt}
` +
+ `
${tags.join('')}
` +
+ (subParts.length ? `
${subParts.join('|')}
` : '') +
+ `
` +
+ `
` +
+ kpiHtml('已发布数据集', `${vm.publishedCount}/${vm.totalOfficial}`, null) +
+ kpiHtml('今日调用成功率', vm.successRate == null ? '—' : `${vm.successRate.toFixed(1)}%`, null, 'mint', vm.successRate != null) +
+ kpiHtml('主站回退页面', `${vm.fallbackPages} 页`, null, vm.fallbackPages ? 'amb' : 'txt') +
+ kpiHtml('EOD 尝试', `${vm.eod.attempts || 0} 次`, '上限 5 · 23:30 止', vm.eod.attempts ? 'rd' : 'txt') +
+ `
`;
+}
+function datasetStripHtml(vm) {
+ return `
${vm.datasetCards.map((d) => {
+ const ring = d.bucket === 'fail' ? 'fail' : d.bucket === 'degrade' ? 'slow' : d.bucket === 'review' ? 'review' : '';
+ let note = '';
+ if (d.time) note += `
${esc(d.time)} · `;
+ if (d.rows) note += `
${Number(d.rows).toLocaleString('en-US')} 行`;
+ if (d.err) note += `
${esc(d.err)}`;
+ if (!d.time && !d.rows && !d.err) note = '
今日尚未发布';
+ return `
` +
+ `
${esc(d.name)}${pillHtml(d.bucket)}
` +
+ `
${note}
` +
+ `
`;
+ }).join('')}
`;
+}
+function observatoryHtml(vm) {
+ const legendByProv = { eastmoney: 'EM 东财', tencent: 'TX 腾讯' };
+ const right = `
${Object.keys(legendByProv).map((p) => `${ledHtml('ok')}${legendByProv[p]}`).join('')}`;
+ const rows = vm.observers.length ? vm.observers.map((o) => `
` +
+ `| ${esc(o.name)} | ` +
+ `${o.provider === 'eastmoney' ? '东方财富' : '腾讯行情'} | ` +
+ `${ageHtml(o.lastOk)} | ` +
+ `${latHtml(o.lat, o.bucket !== 'ok')} | ` +
+ `${pillHtml(o.bucket)}${o.note ? `${esc(o.note)}` : ''} | ` +
+ `
`).join('') : `
| 尚无真实观测记录（等待首次探测/调用） |
`;
+ const body = `
| 观察项 | 当前来源 | 最近成功 | 延迟 | 状态 · 备注 |
|---|
${rows}
`;
+ return panelHtml('实时观察层', right, body, false);
+}
+function siteImpactHtml(vm) {
+ const right = `
${vm.okPages} 项正常 · ${vm.siteImpact.length - vm.okPages} 项待关注`;
+ const rows = vm.siteImpact.length ? vm.siteImpact.map((s) => `
` +
+ `| ${esc(s.page)} | ` +
+ `${pillHtml(s.bucket)} | ` +
+ `${s.note ? esc(s.note) : '—'} | ` +
+ ` | ` +
+ `
`).join('') : `
| 尚无血缘记录 |
`;
+ return panelHtml('主站影响', right, `
`, false);
+}
+function timelineHtml(vm) {
+ const nodes = vm.timeline;
+ if (!nodes.length) return panelHtml('今晚时间线', '', '
暂无可展示的调度任务
', true);
+ const W = 560, H = 150, x0 = 34, x1 = W - 30, y = 75;
+ const step = (x1 - x0) / Math.max(1, nodes.length - 1);
+ const X = (i) => x0 + i * step;
+ const now = new Date();
+ const nowMinutes = now.getHours() * 60 + now.getMinutes();
+ const toMin = (t) => { const [h, m] = t.split(':').map(Number); return h * 60 + (m || 0); };
+ let nowX = X(0);
+ for (let i = 0; i < nodes.length - 1; i++) {
+ const a = toMin(nodes[i].t), b = toMin(nodes[i + 1].t);
+ if (nowMinutes >= a && nowMinutes <= b && b > a) { nowX = X(i) + (X(i + 1) - X(i)) * ((nowMinutes - a) / (b - a)); break; }
+ if (nowMinutes < toMin(nodes[0].t)) { nowX = X(0); break; }
+ if (nowMinutes > toMin(nodes[nodes.length - 1].t)) { nowX = X(nodes.length - 1); }
+ }
+ let s = `
`;
+ const right = `
现在 ${p2(now.getHours())}:${p2(now.getMinutes())} · SCHEDULER.PY`;
+ return panelHtml('今晚时间线', right, s, false);
+}
+function incidentsHtml(vm) {
+ if (!vm.incidents.length) return panelHtml('待处理异常', tagHtml('mint', '0 OPEN'), '
当前无待处理异常
', true);
+ const cards = vm.incidents.map((it) => {
+ const tag = it.sev === 'fail' ? tagHtml('rd', esc(it.tag)) : it.sev === 'slow' ? tagHtml('amb', esc(it.tag)) : tagHtml('dashed', esc(it.tag));
+ return `
${tag}` +
+ `
` +
+ `
${esc(it.title)}
` +
+ `
${esc(it.meta)}
` +
+ `
` +
+ `
` +
+ `
`;
+ }).join('');
+ return panelHtml('待处理异常', tagHtml('rd', vm.incidents.length + ' OPEN'), `
${cards}
`, true);
+}
+function overviewHtml() {
+ const vm = buildOverviewVM();
+ return `
${heroHtml(vm)}${datasetStripHtml(vm)}` +
+ `
${observatoryHtml(vm)}${siteImpactHtml(vm)}
` +
+ `
${timelineHtml(vm)}${incidentsHtml(vm)}
`;
+}
+
+/* =====================================================================
+ 数据源配置页
+ ===================================================================== */
+const srcUiState = {};
+function buildSourcesVM() {
+ const catalog = (RAW.catalog && RAW.catalog.items) || [];
+ const legacy = {};
+ (RAW.sources && RAW.sources.items || []).forEach((it) => { legacy[it.provider] = it; });
+ const hidx = healthIndex();
+ const cidx = callsIndex();
+ const active = catalog.filter((c) => c.role !== 'reserved');
+ const reserved = catalog.filter((c) => c.role === 'reserved');
+ const totalIfaces = active.reduce((n, c) => n + c.interfaces.length, 0);
+ const usedIfaces = active.reduce((n, c) => n + c.interfaces.filter((i) => (hidx[c.provider] || []).some((h) => h.interface === i.interface)).length, 0);
+ const cards = active.map((c) => {
+ const leg = legacy[c.provider] || {};
+ const legState = (leg.health && (leg.health.state || leg.health.status)) || null;
+ const rows = hidx[c.provider] || [];
+ const worst = rows.length ? worstBucket(rows.map((r) => bucketOf(r.state))) : (legState ? bucketOf(legState) : 'off');
+ const cred = c.credential || {};
+ const lastCall = (cidx[c.provider] || [])[0];
+ if (!(c.provider in srcUiState)) srcUiState[c.provider] = { open: true, probing: false, probeResult: null };
+ const ifaceRows = c.interfaces.map((i) => {
+ const h = rows.find((r) => r.interface === i.interface);
+ return {
+ api: i.interface, use: i.capability,
+ ok: h ? (h.last_ok_at ? hm(h.last_ok_at) : '—') : '—',
+ lat: h ? h.last_latency_ms : null,
+ st: h ? bucketOf(h.state) : 'off',
+ err: h && h.state !== 'ok' ? (h.last_error || h.last_fallback_reason || '') : '',
+ };
+ });
+ return {
+ id: c.provider, name: c.label, role: c.role, tag: c.credential_key ? 'licensed' : 'free',
+ bucket: worst, credential: cred, usedCount: ifaceRows.filter((r) => r.st !== 'off').length, totalCount: ifaceRows.length,
+ lastProbe: lastCall ? `${hm(lastCall.created_at)} · ${lastCall.ok ? `✓ ${lastCall.latency_ms}ms` : `× ${lastCall.error || 'ERROR'}`}` : '—',
+ latency: rows.length ? (rows.map((r) => r.last_latency_ms).filter((v) => v != null)[0] || null) : null,
+ error: rows.find((r) => r.last_error)?.last_error || '',
+ ifaceRows,
+ };
+ });
+ return { cards, reserved, totalIfaces, usedIfaces };
+}
+function sourceCardHtml(card) {
+ const ui = srcUiState[card.id];
+ const ringStyle = card.bucket === 'fail' ? 'border-color:rgba(248,113,113,.35)' :
+ card.bucket === 'degrade' ? 'border-color:rgba(251,191,36,.25)' :
+ card.bucket === 'slow' ? 'border-color:rgba(251,191,36,.3)' :
+ card.bucket === 'off' ? 'border-style:dashed;border-color:#243152' : '';
+ const ledSt = HEALTH[card.bucket].led;
+ // source_catalog.py：credential_key 为空的来源（eastmoney/tencent 等公开
+ // 接口）真实语义是"无需凭证"而非"已配置"，两者都体现为 configured:true，
+ // 靠 note 字段区分，这里必须原样展示 note，不能一律折叠成"已配置"。
+ const credBadge = card.credential.note ? card.credential.note :
+ card.credential.configured ? `已配置${card.credential.last4 ? ' · ' + card.credential.last4 : ''}` : '未配置';
+ const badges = [credBadge, card.role];
+ let h = `
`;
+ h += `` +
+ ledHtml(ledSt, card.bucket === 'fail') +
+ `${esc(card.name)}` +
+ `${esc(card.tag)}` +
+ pillHtml(card.bucket) +
+ `${badges.map((b) => tagHtml(card.bucket === 'off' ? 'dashed' : 'dim', esc(b))).join('')}` +
+ `` +
+ `` +
+ `` +
+ ``;
+ h += `` +
+ `接口 ${card.usedCount}/${card.totalCount} 在用` +
+ `|最后探测 ${esc(card.lastProbe)}` +
+ `|延迟 ${latHtml(card.latency)}` +
+ (card.error ? `|最近错误 ${esc(card.error)}` : `|无最近错误`) +
+ `
`;
+ if (ui.open && card.ifaceRows.length) {
+ h += `` +
+ `
| 接口 | 用途 | 最近成功 | 延迟 | 状态 |
|---|
` +
+ card.ifaceRows.map((it) => `` +
+ `| ${esc(it.api)} | ` +
+ `${esc(it.use)} | ` +
+ `${esc(it.ok)} | ` +
+ `${latHtml(it.lat)} | ` +
+ `${pillHtml(it.st)}${it.err ? `${esc(it.err)}` : ''} | ` +
+ `
`).join('') + `
`;
+}
+function sourcesHtml() {
+ const vm = buildSourcesVM();
+ const alerts = [];
+ vm.cards.forEach((c) => {
+ if (c.bucket === 'fail') alerts.push(`
${ledHtml('fail', true)}${esc(c.name)} 故障${c.error ? ' · ' + esc(c.error) : ''}`);
+ else if (c.bucket === 'degrade' || c.bucket === 'slow') alerts.push(`
${ledHtml('slow')}${esc(c.name)} 降级/延迟`);
+ });
+ return `
` +
+ `
` +
+ `数据源 ${vm.cards.length} 路 · 接口 ${vm.usedIfaces}/${vm.totalIfaces} 在用` +
+ alerts.join('') +
+ `` +
+ `凭证安全存储 · 探测只读 · 不影响盘中链路` +
+ `
` +
+ `
${vm.cards.map(sourceCardHtml).join('')}
` +
+ `
${vm.reserved.map((r) => `
${ledHtml('off')}${esc(r.label)}${tagHtml('dashed', '预留位 · 未接入')}
`).join('')}
` +
+ `
`;
+}
+function renderSourceCards() {
+ const el = $('srcCards');
+ if (!el) return;
+ const vm = buildSourcesVM();
+ el.innerHTML = vm.cards.map(sourceCardHtml).join('');
+}
+
+/* =====================================================================
+ 数据血缘页
+ ===================================================================== */
+function pageNameOf(consumer) {
+ const idx = consumer.indexOf('(');
+ return (idx > 0 ? consumer.slice(0, idx) : consumer).trim();
+}
+const linFilter = { onlyBad: false, src: '全部', q: '' };
+let linHover = null;
+let GW = 1500, GH = 286;
+const gpos = {};
+const adj = { sd: new Map(), ds: new Map(), dp: new Map(), pd: new Map() };
+function adjAdd(m, k, v) { if (!m.has(k)) m.set(k, new Set()); m.get(k).add(v); }
+
+function buildLineageVM() {
+ const items = (RAW.lineage && RAW.lineage.items) || [];
+ const PROV_LABEL = { tushare: 'Tushare', eastmoney: '东方财富', tencent: '腾讯行情', ifind: 'iFinD' };
+ const srcState = {};
+ const dsState = {};
+ const pageState = {};
+ const pageDatasets = {};
+ const edgesSD = [];
+ const edgesDP = [];
+ const rows = [];
+ items.forEach((it) => {
+ const rowsHealth = it.live_provider_health || [];
+ let bucket;
+ if (it.tier === 'official') {
+ bucket = it.publication ? (it.publication.state === 'published' ? 'ok' : (it.publication.state === 'degraded' ? 'degrade' : 'fail')) : (rowsHealth.length ? worstBucket(rowsHealth.map((r) => bucketOf(r.state))) : 'plan');
+ } else {
+ bucket = rowsHealth.length ? worstBucket(rowsHealth.map((r) => bucketOf(r.state))) : 'off';
+ }
+ dsState[it.dataset] = bucket;
+ (it.providers || []).forEach((p) => {
+ srcState[p] = worstBucket([srcState[p] || 'ok', ...rowsHealth.filter((r) => r.provider === p).map((r) => bucketOf(r.state))]);
+ edgesSD.push([p, it.dataset]);
+ });
+ const consumers = it.known_consumers || [];
+ const pages = [...new Set(consumers.map(pageNameOf))];
+ pages.forEach((pg) => {
+ pageState[pg] = worstBucket([pageState[pg] || 'ok', bucket]);
+ edgesDP.push([it.dataset, pg]);
+ (pageDatasets[pg] = pageDatasets[pg] || []).push(it);
+ });
+ const lat = rowsHealth.map((r) => r.last_latency_ms).find((v) => v != null);
+ const ok = it.tier === 'official' && it.publication ? it.publication.published_at : (rowsHealth.find((r) => r.last_ok_at) || {}).last_ok_at;
+ rows.push({
+ page: pages.join(' / ') || '—', item: consumers.join(' / '), dataset: it.dataset,
+ via: `${it.primary_source}${it.backup_source ? ' → ' + it.backup_source : ''}`,
+ role: it.backup_source ? '主/备' : (it.tier === 'licensed' ? '主（授权）' : '主（无备）'),
+ ok: ok ? hm(ok) : '—', lat, st: bucket,
+ note: rowsHealth.find((r) => r.last_error)?.last_error || rowsHealth.find((r) => r.last_fallback_reason)?.last_fallback_reason || (it.publication && it.publication.state !== 'published' ? '未正式发布' : ''),
+ });
+ });
+ const sources = Object.keys(srcState).map((id) => ({ id, name: PROV_LABEL[id] || id, st: srcState[id] }));
+ const datasets = Object.keys(dsState).map((id) => ({ id, st: dsState[id] }));
+ const pages = Object.keys(pageState).map((id) => ({ id, name: id, st: pageState[id] }));
+ return { sources, datasets, pages, edgesSD, edgesDP, rows };
+}
+
+function spread(n, y0, y1) { return Array.from({ length: n }, (_, i) => (n === 1 ? (y0 + y1) / 2 : y0 + (i / (n - 1)) * (y1 - y0))); }
+function layoutGraph(vm) {
+ const wide = (window.innerWidth || 1440) > 1100;
+ GW = wide ? 1500 : 1000; GH = wide ? 286 : 560;
+ vm.sources.forEach((s, i) => { gpos['s:' + s.id] = { x: wide ? 80 : 60, y: spread(vm.sources.length, wide ? 60 : 90, wide ? 232 : 500)[i] }; });
+ vm.datasets.forEach((d, i) => { gpos['d:' + d.id] = { x: wide ? 700 : 480, y: spread(vm.datasets.length, wide ? 30 : 45, wide ? 264 : 525)[i] }; });
+ vm.pages.forEach((p, i) => { gpos['p:' + p.id] = { x: wide ? 1400 : 930, y: spread(vm.pages.length, wide ? 26 : 30, wide ? 276 : 540)[i] }; });
+}
+function linkPath(p1, p2) { const mx = (p1.x + p2.x) / 2; return `M ${p1.x} ${p1.y} C ${mx} ${p1.y}, ${mx} ${p2.y}, ${p2.x} ${p2.y}`; }
+const stColorOf = (b) => (HEALTH[b] || HEALTH.off).color;
+
+function lineageGraphHtml(vm) {
+ layoutGraph(vm);
+ adj.sd.clear(); adj.ds.clear(); adj.dp.clear(); adj.pd.clear();
+ vm.edgesSD.forEach(([s, d]) => { adjAdd(adj.sd, s, d); adjAdd(adj.ds, d, s); });
+ vm.edgesDP.forEach(([d, p]) => { adjAdd(adj.dp, d, p); adjAdd(adj.pd, p, d); });
+ let h = `
悬停节点 · 追踪上下游链路
`;
+ return h;
+}
+function activeSetCalc(hover, vm) {
+ if (!hover) return null;
+ const set = new Set([hover]);
+ const isSrc = vm.sources.some((s) => s.id === hover);
+ const isDs = vm.datasets.some((d) => d.id === hover);
+ if (isSrc) { (adj.sd.get(hover) || new Set()).forEach((d) => { set.add(d); (adj.dp.get(d) || new Set()).forEach((p) => set.add(p)); }); }
+ else if (isDs) { (adj.ds.get(hover) || new Set()).forEach((s) => set.add(s)); (adj.dp.get(hover) || new Set()).forEach((p) => set.add(p)); }
+ else { (adj.pd.get(hover) || new Set()).forEach((d) => { set.add(d); (adj.ds.get(d) || new Set()).forEach((s) => set.add(s)); }); }
+ return set;
+}
+function applyLinHover(vm) {
+ const act = activeSetCalc(linHover, vm);
+ const isSrcHov = vm.sources.some((s) => s.id === linHover);
+ document.querySelectorAll('#linSvg path[data-link]').forEach((p) => {
+ const a = p.dataset.a, b = p.dataset.b;
+ const shown = !act || (act.has(a) && act.has(b));
+ let hot = false;
+ if (act && act.has(a) && act.has(b)) hot = isSrcHov ? (a === linHover ? true : (adj.sd.get(linHover) || new Set()).has(a)) : true;
+ p.setAttribute('stroke-width', hot ? 1.8 : 1);
+ p.setAttribute('stroke-opacity', shown ? (act ? 0.85 : (p.dataset.kind === 'sd' ? 0.28 : 0.22)) : 0.05);
+ });
+ document.querySelectorAll('#linSvg g[data-nid]').forEach((g) => {
+ const id = g.dataset.nid, kind = g.dataset.gkind;
+ const dimmed = act && !act.has(id);
+ g.setAttribute('opacity', dimmed ? (kind === 'src' ? 0.3 : 0.25) : 1);
+ if (kind !== 'src') { const t = g.querySelector('text'); if (t) t.setAttribute('fill', act && act.has(id) ? '#e8f1ff' : '#8b9bb4'); }
+ });
+ const hint = $('linHint');
+ if (hint) hint.textContent = linHover ? `FOCUS: ${linHover} · 高亮上下游链路` : '悬停节点 · 追踪上下游链路';
+}
+function setLinHover(id, vm) { linHover = id; applyLinHover(vm); }
+function linRowsData(vm) {
+ return vm.rows.filter((r) => {
+ if (linFilter.onlyBad && !['fail', 'slow', 'degrade', 'off', 'review', 'plan'].includes(r.st)) return false;
+ if (linFilter.src !== '全部' && !r.via.includes({ Tushare: 'tushare', 东方财富: 'eastmoney', 腾讯: 'tencent', iFinD: 'ifind' }[linFilter.src] || '')) return false;
+ if (linFilter.q && !(r.page + r.item + r.dataset + r.via).toLowerCase().includes(linFilter.q.toLowerCase())) return false;
+ return true;
+ });
+}
+function renderLinRows(vm) {
+ const body = $('linBody'), cnt = $('linCount'), bodyN = $('linBodyN');
+ if (!body) return;
+ const rows = linRowsData(vm);
+ if (cnt) cnt.textContent = `${rows.length}/${vm.rows.length} 行`;
+ const cls = (st) => st === 'fail' ? 'row-fail' : st === 'degrade' || st === 'slow' ? 'row-slow' : st === 'off' ? 'row-off' : '';
+ body.innerHTML = rows.map((r) => `
` +
+ `| ${esc(r.page)} | ` +
+ `${esc(r.item)} | ` +
+ `${esc(r.dataset)} | ` +
+ `${esc(r.via)} | ` +
+ `${esc(r.role)} | ` +
+ `${esc(r.ok)} | ` +
+ `${latHtml(r.lat)} | ` +
+ `${pillHtml(r.st)}${r.note ? `${esc(r.note)}` : ''} | ` +
+ `
`).join('') || `
| 无匹配记录 · 调整筛选条件 |
`;
+ if (bodyN) bodyN.innerHTML = rows.map((r) => `
` +
+ `| ${esc(r.page)}${esc(r.item)} | ` +
+ `${esc(r.dataset)} | ` +
+ `${esc(r.via)} | ` +
+ `${esc(r.ok)}${r.lat != null ? r.lat + 'ms' : '—'} | ` +
+ `${pillHtml(r.st)}${r.note ? `${esc(r.note)}` : ''} | ` +
+ `
`).join('') || `
| 无匹配记录 · 调整筛选条件 |
`;
+}
+function lineageHtml() {
+ const vm = buildLineageVM();
+ const anomalyPages = new Set();
+ vm.rows.forEach((r) => { if (r.st === 'fail') (r.page || '').split(' / ').forEach((p) => anomalyPages.add(p)); });
+ const html = `
` +
+ `
` +
+ `血缘地图` +
+ `${vm.sources.length} 源 → ${vm.datasets.length} 数据集 → ${vm.pages.length} 页面` +
+ `${ledHtml('ok')}健康${ledHtml('slow')}慢/降级${ledHtml('fail')}失败${ledHtml('plan')}计划${ledHtml('off')}未配置` +
+ `` +
+ (anomalyPages.size ? tagHtml('rd', `${[...anomalyPages][0]} 断链影响 ${anomalyPages.size} 页`) : tagHtml('mint', '暂无断链影响')) +
+ `
` +
+ `
` +
+ `
` +
+ `
`;
+ window.__linVM = vm;
+ return html;
+}
+
+/* =====================================================================
+ 页面路由 / 顶栏 / EVENT TAPE / 抽屉 / 危险操作弹层
+ ===================================================================== */
+const mainEl = $('mainEl');
+function pageFromHash() {
+ const h = location.hash.replace('#', '');
+ return ['overview', 'sources', 'lineage'].includes(h) ? h : 'overview';
+}
+function renderPage(p) {
+ state.page = p;
+ mainEl.dataset.page = p;
+ document.querySelectorAll('[data-nav]').forEach((b) => b.classList.toggle('act', b.dataset.nav === p));
+ if (p === 'overview') mainEl.innerHTML = overviewHtml();
+ else if (p === 'sources') mainEl.innerHTML = sourcesHtml();
+ else {
+ mainEl.innerHTML = lineageHtml();
+ renderLinRows(window.__linVM);
+ applyLinHover(window.__linVM);
+ const svg = $('linSvg');
+ if (svg) svg.addEventListener('mouseleave', () => setLinHover(null, window.__linVM));
+ fitLineageTable();
+ }
+ updatePhaseTag();
+}
+window.addEventListener('hashchange', () => renderPage(pageFromHash()));
+document.querySelectorAll('[data-nav]').forEach((b) => b.addEventListener('click', () => { location.hash = b.dataset.nav; }));
+let resizeT = null;
+window.addEventListener('resize', () => {
+ clearTimeout(resizeT);
+ resizeT = setTimeout(() => { if (state.page === 'lineage') renderPage('lineage'); }, 180);
+});
+
+/* HEL-529: 血缘详情表随真实数据集数量（当前 17 条，非打样假设的 13 条）
+ 动态撑高；宽档（>1100px，覆盖 1920×920/1440×900 验收位）给表格容器一个
+ 基于剩余可视高度计算的 max-height + 内部滚动，保证整页 scrollHeight
+ 始终 <= clientHeight（硬性验收项），同时全部行仍可在容器内滚动查看。
+ 窄档（<=1100px）保持原有整页纵向滚动，不设上限。 */
+function fitLineageTable() {
+ const wrap = document.querySelector('.lin-scroll');
+ const tape = document.querySelector('.tape');
+ if (!wrap || !tape) return;
+ wrap.style.maxHeight = '';
+ if (window.innerWidth <= 1100) return;
+ const tapeTop = tape.getBoundingClientRect().top;
+ const wrapTop = wrap.getBoundingClientRect().top;
+ const mainPadBottom = parseFloat(getComputedStyle(mainEl).paddingBottom) || 0;
+ const avail = tapeTop - wrapTop - mainPadBottom - 4;
+ if (avail > 0) wrap.style.maxHeight = Math.floor(avail) + 'px';
+}
+
+function updatePhaseTag() {
+ const ov = RAW.overview;
+ if (!ov) return;
+ $('phaseTag').innerHTML = `${ledHtml('rev', true)} ${esc(ov.session_phase || '')}`;
+}
+
+mainEl.addEventListener('click', (e) => {
+ const pb = e.target.closest('[data-probe]');
+ if (pb) { doProbe(pb.dataset.probe); return; }
+ const tg = e.target.closest('[data-toggle]');
+ if (tg) { const ui = srcUiState[tg.dataset.toggle]; if (ui) { ui.open = !ui.open; renderSourceCards(); } return; }
+ const goto = e.target.closest('[data-goto-lineage]');
+ if (goto) { linFilter.q = ''; location.hash = 'lineage'; return; }
+ const inc = e.target.closest('[data-incident-action]');
+ if (inc) { openOpsDrawer('release', { dataset: inc.dataset.dataset, provider: inc.dataset.provider }); return; }
+ if (e.target.closest('#linBad')) {
+ linFilter.onlyBad = !linFilter.onlyBad;
+ renderLinRows(window.__linVM);
+ const btn = $('linBad');
+ btn.classList.toggle('on', linFilter.onlyBad);
+ btn.innerHTML = `${ledHtml(linFilter.onlyBad ? 'fail' : 'plan')} 只看异常`;
+ return;
+ }
+});
+mainEl.addEventListener('change', (e) => { if (e.target.id === 'linSel') { linFilter.src = e.target.value.split('· ')[1] || '全部'; renderLinRows(window.__linVM); } });
+mainEl.addEventListener('input', (e) => { if (e.target.id === 'linQ') { linFilter.q = e.target.value; renderLinRows(window.__linVM); } });
+mainEl.addEventListener('mouseover', (e) => { const g = e.target.closest('g[data-nid]'); if (g) setLinHover(g.dataset.nid, window.__linVM); });
+
+async function doProbe(id) {
+ const ui = srcUiState[id];
+ if (!ui || ui.probing) return;
+ ui.probing = true;
+ renderSourceCards();
+ try { await api(`/admin/api/sources/${id}/probe`, { method: 'POST', body: '{}' }); } catch (err) { toast(err.message, 'err'); }
+ ui.probing = false;
+ await refreshQuiet();
+ renderSourceCards();
+}
+
+/* ---------- EVENT TAPE：真实事件差量渲染 ---------- */
+const tapeSeen = { call: 0, provCall: 0, audit: 0, job: 0, first: true };
+function tapeEventsFromRaw() {
+ const evs = [];
+ ((RAW.overview && RAW.overview.recent_calls) || []).forEach((c) => { if (c.id > tapeSeen.call) evs.push({ ts: c.created_at, src: 'tushare', msg: c.endpoint, ok: c.ok, ms: c.latency_ms, sortId: 'c' + c.id }); });
+ ((RAW.providers && RAW.providers.recent_calls) || []).forEach((c) => { if (c.id > tapeSeen.provCall) evs.push({ ts: c.fetched_at, src: c.provider, msg: c.interface, ok: c.status === 'ok', ms: c.latency_ms, sortId: 'p' + c.id }); });
+ ((RAW.audit && RAW.audit.items) || []).forEach((a) => { if (a.id > tapeSeen.audit) evs.push({ ts: a.created_at, src: 'hub_admin', msg: `${a.action} ${a.target || ''}`.trim(), ok: true, sortId: 'a' + a.id }); });
+ ((RAW.jobs && RAW.jobs.runs) || []).forEach((r) => { if (r.id > tapeSeen.job) evs.push({ ts: r.finished_at || r.started_at, src: 'scheduler', msg: `${r.job_id} ${r.state}`, ok: r.state !== 'failed', sortId: 'j' + r.id }); });
+ const maxOf = (arr, key) => arr.reduce((m, x) => Math.max(m, x[key] || 0), 0);
+ tapeSeen.call = Math.max(tapeSeen.call, maxOf((RAW.overview && RAW.overview.recent_calls) || [], 'id'));
+ tapeSeen.provCall = Math.max(tapeSeen.provCall, maxOf((RAW.providers && RAW.providers.recent_calls) || [], 'id'));
+ tapeSeen.audit = Math.max(tapeSeen.audit, maxOf((RAW.audit && RAW.audit.items) || [], 'id'));
+ tapeSeen.job = Math.max(tapeSeen.job, maxOf((RAW.jobs && RAW.jobs.runs) || [], 'id'));
+ return evs;
+}
+let tapeBuf = [];
+function updateTape() {
+ const evs = tapeEventsFromRaw();
+ if (tapeSeen.first) { tapeSeen.first = false; return; } // 首次加载只建基线，不补播历史事件
+ if (!evs.length) return;
+ tapeBuf = tapeBuf.concat(evs).slice(-16);
+ const html = tapeBuf.map((e) => `
${esc(hm(e.ts))}${esc(e.src)}${esc(e.msg)}` +
+ (e.ok ? `✓${e.ms ? ` ${e.ms}ms` : ''}` : '× 失败') +
+ `///`).join('');
+ $('tapeA').innerHTML = html; $('tapeB').innerHTML = html;
+}
+
+/* ---------- 抽屉：调度任务 / 盘后发布 / 审计 ---------- */
+let drawerTab = 'jobs';
+function openOpsDrawer(tab, ctx) {
+ drawerTab = tab || 'jobs';
+ drawerCtx = ctx || {};
+ $('drawerMask').classList.add('open');
+ renderDrawer();
+}
+function closeOpsDrawer() { $('drawerMask').classList.remove('open'); }
+let drawerCtx = {};
+$('drawerClose').addEventListener('click', closeOpsDrawer);
+$('drawerMask').addEventListener('click', (e) => { if (e.target.id === 'drawerMask') closeOpsDrawer(); });
+$('opsBtn').addEventListener('click', () => openOpsDrawer('jobs', {}));
+$('drawerTabs').addEventListener('click', (e) => {
+ const b = e.target.closest('[data-dtab]');
+ if (!b) return;
+ drawerTab = b.dataset.dtab;
+ renderDrawer();
+});
+function renderDrawer() {
+ $('drawerTabs').querySelectorAll('[data-dtab]').forEach((b) => b.classList.toggle('act', b.dataset.dtab === drawerTab));
+ $('drawerSub').textContent = { jobs: '既有调度手动触发', release: '盘后发布 / 回滚 / 补数', audit: '操作审计日志' }[drawerTab] || '';
+ if (drawerTab === 'jobs') renderDrawerJobs();
+ else if (drawerTab === 'release') renderDrawerRelease();
+ else renderDrawerAudit();
+}
+function renderDrawerJobs() {
+ const jobs = (RAW.jobs && RAW.jobs.jobs) || [];
+ const runs = (RAW.jobs && RAW.jobs.runs) || [];
+ const runsByJob = {};
+ runs.forEach((r) => { (runsByJob[r.job_id] = runsByJob[r.job_id] || []).push(r); });
+ $('drawerBody').innerHTML = `
+
-
当前映射
- ${table(["数据集", "活跃批次", "上一批次", "状态", "发布时间", "操作"], data.publications.map((row) => [
- esc(row.dataset), esc(row.active_batch), esc(row.prev_batch), esc(row.state), esc(row.published_at),
- row.prev_batch ? `
` : "-",
- ]))}
-
批次
- ${table(["batch_id", "数据集", "状态", "行数", "错误"], data.batches.map((row) => [
- esc(row.batch_id), esc(row.dataset), esc(row.state), row.rows_out ?? "", esc(row.error),
- ]))}
- `;
+
+
最近运行（最新 20 条）
+
| ID | 任务 | 状态 | 开始 | 结束 | 错误 |
|---|
+ ${runs.slice(0, 20).map((r) => `| ${r.id} | ${esc(r.job_id)} | ${pillHtml(bucketOf(r.state))} | ${esc(r.started_at || '')} | ${esc(r.finished_at || '')} | ${esc(r.error || '')} |
`).join('') || '| 暂无运行记录 |
'}
+
+
`;
+ $('drawerBody').querySelectorAll('[data-run]').forEach((btn) => {
+ btn.addEventListener('click', async () => {
+ const dateInput = $('drawerBody').querySelector(`[data-run-date="${btn.dataset.run}"]`);
+ try {
+ await api(`/admin/api/jobs/${btn.dataset.run}/run`, { method: 'POST', body: JSON.stringify({ trade_date: (dateInput && dateInput.value) || '' }) });
+ toast('已触发：' + btn.dataset.run, 'ok');
+ await refreshQuiet(); renderDrawer();
+ } catch (err) { toast(err.message, 'err'); }
+ });
+ });
+}
+function renderDrawerRelease() {
+ const date = drawerCtx.date || today();
+ $('drawerBody').innerHTML = `
+
+
+
+
`;
+ $('relLoad').addEventListener('click', async () => { drawerCtx.date = $('relDate').value; await loadRelease(); });
+ $('relBackfill').addEventListener('click', () => openDangerModal('backfill', { dataset: drawerCtx.dataset || '', date: drawerCtx.date || date }));
+ loadRelease();
+}
+async function loadRelease() {
+ const date = drawerCtx.date || today();
+ let data;
+ try { data = await api(`/admin/api/batches?date=${encodeURIComponent(date)}`); } catch (err) { toast(err.message, 'err'); return; }
+ $('relBody').innerHTML = `
+
发布映射
+
| 数据集 | 活跃批次 | 上一批次 | 状态 | 发布时间 | 操作 |
|---|
+ ${data.publications.map((row) => `| ${esc(row.dataset)} | ${esc(row.active_batch)} | ${esc(row.prev_batch || '')} | ${pillHtml(bucketOf(row.state))} | ${esc(row.published_at || '')} |
+ ${row.prev_batch ? `` : '—'} |
`).join('') || '| 当日暂无发布记录 |
'}
+
+
批次
+
| batch_id | 数据集 | 状态 | 行数 | 错误 |
|---|
+ ${data.batches.map((row) => `| ${esc(row.batch_id)} | ${esc(row.dataset)} | ${pillHtml(bucketOf(row.state))} | ${row.rows_out ?? ''} | ${esc(row.error || '')} |
`).join('') || '| 当日暂无批次 |
'}
+
`;
+ $('relBody').querySelectorAll('[data-rollback]').forEach((btn) => btn.addEventListener('click', () => openDangerModal('rollback', { dataset: btn.dataset.rollback, date })));
+}
+function renderDrawerAudit() {
+ const items = (RAW.audit && RAW.audit.items) || [];
+ $('drawerBody').innerHTML = `
| 时间 | 操作者 | 动作 | 对象 | 详情 |
|---|
+ ${items.map((row) => `| ${esc(row.created_at)} | ${esc(row.actor)} | ${esc(row.action)} | ${esc(row.target || '')} | ${esc(row.detail || '')} |
`).join('') || '| 暂无审计记录 |
'}
+
`;
}
-async function dangerous(kind, dataset) {
- const date = ($("rel-date") && $("rel-date").value) || "";
- const ds = dataset || prompt("数据集（daily/valuation/moneyflow/auction/stocks→A组整批；index_daily→B组；或 reference）", "daily");
- if (!ds) return;
- const password = prompt("二次确认：输入管理密码");
- if (!password) return;
- const confirmWord = `${ds}:${date}`;
- const typed = prompt(`请输入确认词：${confirmWord}`);
- const path = kind === "rollback" ? "/admin/api/rollback" : "/admin/api/backfill";
- await api(path, {
- method: "POST",
- body: JSON.stringify({ dataset: ds, trade_date: date, password, confirm: typed }),
- });
- render();
+/* ---------- 危险操作确认弹层（回滚 / 补数） ---------- */
+let dangerCtx = null;
+function openDangerModal(kind, ctx) {
+ dangerCtx = { kind, ...ctx };
+ const word = `${ctx.dataset}:${ctx.date}`;
+ $('modalTitle').textContent = kind === 'rollback' ? '确认回滚' : '确认补数';
+ $('modalDesc').textContent = kind === 'rollback'
+ ? `将把 ${ctx.dataset} 在 ${ctx.date} 的发布回退到上一批次，需管理密码与确认词。`
+ : `将对 ${ctx.dataset || '（请先在发布列表选择数据集）'} 于 ${ctx.date} 重新补数并发布，需管理密码与确认词。`;
+ $('modalConfirmWord').textContent = word;
+ $('modalPassword').value = ''; $('modalConfirm').value = ''; $('modalErr').textContent = '';
+ $('modalMask').classList.add('open');
+}
+$('modalCancel').addEventListener('click', () => $('modalMask').classList.remove('open'));
+$('modalMask').addEventListener('click', (e) => { if (e.target.id === 'modalMask') $('modalMask').classList.remove('open'); });
+$('modalOk').addEventListener('click', async () => {
+ if (!dangerCtx) return;
+ const password = $('modalPassword').value;
+ const confirm = $('modalConfirm').value;
+ const path = dangerCtx.kind === 'rollback' ? '/admin/api/rollback' : '/admin/api/backfill';
+ try {
+ await api(path, { method: 'POST', body: JSON.stringify({ dataset: dangerCtx.dataset, trade_date: dangerCtx.date, password, confirm }) });
+ $('modalMask').classList.remove('open');
+ toast('操作成功', 'ok');
+ await refreshQuiet();
+ if (state.page === 'overview') renderPage('overview');
+ if (drawerTab === 'release') loadRelease();
+ } catch (err) {
+ $('modalErr').textContent = err.message;
+ }
+});
+
+/* ---------- toast ---------- */
+let toastT = null;
+function toast(msg, kind) {
+ const el = $('toastEl');
+ el.textContent = msg;
+ el.className = 'toast show' + (kind ? ' ' + kind : '');
+ clearTimeout(toastT);
+ toastT = setTimeout(() => { el.classList.remove('show'); }, 3200);
+}
+
+/* ================= 顶栏：时钟 / 减少动态 / 主题 ================= */
+function updateClock() {
+ const now = new Date();
+ $('ckD').textContent = `${now.getFullYear()}-${p2(now.getMonth() + 1)}-${p2(now.getDate())}`;
+ $('ckH').textContent = p2(now.getHours());
+ $('ckM').textContent = p2(now.getMinutes());
+ $('ckS').textContent = p2(now.getSeconds());
+}
+function applyCalm(on) {
+ state.calm = on;
+ $('appRoot').classList.toggle('reduce-motion', on);
+ $('calmBtn').textContent = on ? '恢复动态' : '减少动态';
+ $('calmBtn').classList.toggle('on', on);
+}
+$('calmBtn').addEventListener('click', () => applyCalm(!state.calm));
+if (window.matchMedia) {
+ const mq = window.matchMedia('(prefers-reduced-motion: reduce)');
+ const syncMq = () => { if (mq.matches && !state.calm) applyCalm(true); };
+ syncMq();
+ mq.addEventListener ? mq.addEventListener('change', syncMq) : mq.addListener(syncMq);
+}
+
+/* ================= 轮询：拉取真实数据、驱动渲染、可见性/网络门禁 ================= */
+const Poller = (() => {
+ let timer = null;
+ let running = false;
+ const INTERVAL = 4000;
+ async function tick() {
+ if (!running) return;
+ try {
+ await fetchAll();
+ updateTape();
+ if (state.page === 'overview') mainEl.innerHTML = overviewHtml();
+ else if (state.page === 'sources') renderSourceCards();
+ else if (state.page === 'lineage') { /* 血缘图交互态复杂，仅在用户操作或下次轮询后整体重绘一次 */ mainEl.innerHTML = lineageHtml(); renderLinRows(window.__linVM); applyLinHover(window.__linVM); fitLineageTable(); }
+ updatePhaseTag();
+ setNetOk(true);
+ } catch (err) {
+ setNetOk(false);
+ }
+ }
+ function setNetOk(ok) {
+ $('liveSpan').style.opacity = ok ? '1' : '.35';
+ }
+ function scheduleNext() { timer = setTimeout(async () => { await tick(); scheduleNext(); }, INTERVAL); }
+ return {
+ async start() {
+ if (running) return;
+ running = true;
+ await tick();
+ scheduleNext();
+ },
+ stop() { running = false; if (timer) clearTimeout(timer); timer = null; },
+ isRunning() { return running; },
+ };
+})();
+
+function resetTapeBaselines() {
+ // 恢复轮询时静默重建基线，不补播暂停期间错过的事件。
+ tapeSeen.call = tapeSeen.provCall = tapeSeen.audit = tapeSeen.job = Number.MAX_SAFE_INTEGER;
+ tapeSeen.first = true;
+}
+document.addEventListener('visibilitychange', () => {
+ if (document.hidden) { Poller.stop(); }
+ else if (!$('appRoot').hidden) { resetTapeBaselines(); Poller.start(); }
+});
+window.addEventListener('offline', () => { Poller.stop(); $('liveSpan').style.opacity = '.35'; });
+window.addEventListener('online', () => { if (!$('appRoot').hidden && !document.hidden) { resetTapeBaselines(); Poller.start(); } });
+
+async function refreshQuiet() {
+ try { await fetchAll(); } catch {}
+}
+
+/* ================= 启动 ================= */
+async function startApp() {
+ setInterval(updateClock, 1000);
+ updateClock();
+ await fetchAll();
+ tapeSeen.first = true;
+ renderPage(pageFromHash());
+ await Poller.start();
}
boot();
diff --git a/xiaobai-datahub/admin/index.html b/xiaobai-datahub/admin/index.html
index b7eb893..a9493c2 100644
--- a/xiaobai-datahub/admin/index.html
+++ b/xiaobai-datahub/admin/index.html
@@ -1,16 +1,18 @@
-
-
-
xiaobai-datahub 管理后台
-
+
+
+
小白复盘 · 数据中枢
+
-
-
+
+
+
+
数据中枢
- 内网管理后台，用于查看源状态、调度和盘后发布批次。
+ 内网管理后台 · 运行总览 / 数据源配置 / 数据血缘。
+
-
+
+
修改初始密码
+ 首次登录需先设置新密码才能进入。
-
-
-
- xiaobai-datahub
-
-
-
-
-
-
-
-
+
+
+
+
危险操作确认
+
+
+
+
+
+
+
+
+
+