ops.js 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865
  1. 'use strict';
  2. // 店铺运营页:上传人工统计表 → 按学校/店铺/日期看指标矩阵或卡片。
  3. // 数据来自 /api/ops/*;原件存服务端存储(默认本地 SQLite),页面只做展示与上传。
  4. (function () {
  5. const $ = (id) => document.getElementById(id);
  6. const DEFAULT_FIELDS = ['order_cnt', 'revenue', 'exposure', 'click_rate'];
  7. function loadJSON(key, fallback) {
  8. try {
  9. const raw = localStorage.getItem(key);
  10. if (!raw) return fallback;
  11. const value = JSON.parse(raw);
  12. return Array.isArray(value) && value.length ? value : fallback;
  13. } catch {
  14. return fallback;
  15. }
  16. }
  17. const state = {
  18. inited: false,
  19. loading: false,
  20. summary: null,
  21. data: null,
  22. catalog: [],
  23. schools: null, // null = 全选
  24. shops: null, // null = 全部店铺
  25. fields: loadJSON('ops.fields', DEFAULT_FIELDS.slice()),
  26. view: localStorage.getItem('ops.view') === 'cards' ? 'cards' : 'table',
  27. from: '',
  28. to: '',
  29. upload: { files: [], busy: false },
  30. };
  31. function fieldByKey(key) {
  32. return state.catalog.find((f) => f.key === key) || { key, label: key, type: 'int' };
  33. }
  34. function esc(value) {
  35. const div = document.createElement('div');
  36. div.textContent = String(value == null ? '' : value);
  37. return div.innerHTML;
  38. }
  39. function ymdToInput(ymd) {
  40. const s = String(ymd || '');
  41. return /^\d{8}$/.test(s) ? `${s.slice(0, 4)}-${s.slice(4, 6)}-${s.slice(6, 8)}` : '';
  42. }
  43. function inputToYmd(value) {
  44. return String(value || '').replace(/-/g, '');
  45. }
  46. function shortDate(ymd) {
  47. const s = String(ymd || '');
  48. return /^\d{8}$/.test(s) ? `${Number(s.slice(4, 6))}.${Number(s.slice(6, 8))}` : s;
  49. }
  50. function fmtValue(value, type) {
  51. if (value === null || value === undefined || value === '') return '–';
  52. if (type === 'text') return String(value);
  53. const n = Number(value);
  54. if (!Number.isFinite(n)) return String(value);
  55. if (type === 'rate') return (n * 100).toFixed(1) + '%';
  56. if (type === 'money') return n.toLocaleString('zh-CN', { minimumFractionDigits: 2, maximumFractionDigits: 2 });
  57. if (type === 'int') return n.toLocaleString('zh-CN');
  58. return String(value);
  59. }
  60. function selectedSchools() {
  61. if (!state.summary) return [];
  62. const all = state.summary.schools.map((s) => s.name);
  63. return state.schools === null ? all : all.filter((name) => state.schools.has(name));
  64. }
  65. async function api(url, options) {
  66. const res = await fetch(url, options);
  67. const isJson = /application\/json/.test(res.headers.get('content-type') || '');
  68. const body = isJson ? await res.json().catch(() => null) : null;
  69. return { res, body };
  70. }
  71. // ---------- 概览 / 数据 ----------
  72. async function loadSummary() {
  73. const { body } = await api('/api/ops/summary');
  74. state.summary = body || { enabled: false, reason: 'storage-unreachable' };
  75. if (state.summary.enabled && state.summary.coverage) {
  76. if (!state.from) state.from = state.summary.coverage.from;
  77. if (!state.to) state.to = state.summary.coverage.to;
  78. }
  79. return state.summary;
  80. }
  81. async function loadRows() {
  82. if (!state.summary || !state.summary.enabled) return;
  83. if (state.schools !== null && state.schools.size === 0) {
  84. state.data = null;
  85. state.loading = false;
  86. renderBody();
  87. return;
  88. }
  89. state.loading = true;
  90. renderBody();
  91. const params = new URLSearchParams();
  92. if (state.from) params.set('from', state.from);
  93. if (state.to) params.set('to', state.to);
  94. const schools = state.schools === null ? [] : [...state.schools];
  95. if (schools.length && schools.length !== (state.summary.schools || []).length) params.set('schools', schools.join(','));
  96. if (state.shops !== null && state.shops.size) params.set('shops', [...state.shops].join(','));
  97. if (state.fields.length) params.set('fields', state.fields.join(','));
  98. const { res, body } = await api('/api/ops/rows?' + params.toString());
  99. state.loading = false;
  100. if (!res.ok) {
  101. state.data = null;
  102. state.error = (body && (body.detail || body.error)) || `HTTP ${res.status}`;
  103. } else {
  104. state.data = body;
  105. state.error = null;
  106. }
  107. renderBody();
  108. }
  109. // ---------- 工具条 ----------
  110. /** 通用多选下拉:按钮 + 搜索 + 复选列表 + 全选/清空 */
  111. function mountMulti(root, { label, items, selected, allowEmpty, emptyLabel, onChange }) {
  112. const sel = new Set(selected || []);
  113. let keyword = '';
  114. root.innerHTML = `<button type="button" class="ops-multi-btn" aria-expanded="false"></button>
  115. <div class="ops-multi-menu" hidden>
  116. <input type="text" class="ops-multi-search" placeholder="搜索${esc(label)}">
  117. <div class="ops-multi-list"></div>
  118. <div class="ops-multi-foot"><button type="button" data-all>全选</button><button type="button" data-none>清空</button></div>
  119. </div>`;
  120. const btn = root.querySelector('.ops-multi-btn');
  121. const menu = root.querySelector('.ops-multi-menu');
  122. const list = root.querySelector('.ops-multi-list');
  123. const search = root.querySelector('.ops-multi-search');
  124. function refreshButton() {
  125. let text;
  126. if (!sel.size) text = `${label} <em>${emptyLabel || '全部'}</em>`;
  127. else if (sel.size === 1) {
  128. const one = items.find((i) => sel.has(i.key));
  129. text = `${label} <em>${esc(one ? one.label : '1')}</em>`;
  130. } else text = `${label} <em>${sel.size} 项</em>`;
  131. btn.innerHTML = text + '<span class="ops-multi-caret">▾</span>';
  132. }
  133. function renderList() {
  134. const kw = keyword.trim().toLowerCase();
  135. const filtered = items.filter((i) => !kw
  136. || String(i.label).toLowerCase().includes(kw)
  137. || String(i.hint || '').toLowerCase().includes(kw));
  138. list.innerHTML = filtered.length
  139. ? filtered.map((i) => `<label class="ops-multi-item">
  140. <input type="checkbox" value="${esc(i.key)}"${sel.has(i.key) ? ' checked' : ''}>
  141. <span>${esc(i.label)}</span>${i.hint ? `<em>${esc(i.hint)}</em>` : ''}
  142. </label>`).join('')
  143. : '<div class="ops-multi-empty">没有匹配项</div>';
  144. list.querySelectorAll('input[type="checkbox"]').forEach((input) => {
  145. input.addEventListener('change', () => {
  146. if (input.checked) sel.add(input.value);
  147. else sel.delete(input.value);
  148. if (!allowEmpty && !sel.size) {
  149. input.checked = true;
  150. sel.add(input.value);
  151. return;
  152. }
  153. refreshButton();
  154. onChange([...sel]);
  155. });
  156. });
  157. }
  158. btn.addEventListener('click', (e) => {
  159. e.stopPropagation();
  160. const willOpen = menu.hidden;
  161. document.querySelectorAll('.ops-multi-menu').forEach((m) => { m.hidden = true; });
  162. menu.hidden = !willOpen;
  163. btn.setAttribute('aria-expanded', String(willOpen));
  164. if (willOpen) { renderList(); search.focus(); }
  165. });
  166. search.addEventListener('input', () => { keyword = search.value; renderList(); });
  167. root.querySelector('[data-all]').addEventListener('click', () => {
  168. items.forEach((i) => sel.add(i.key));
  169. refreshButton();
  170. renderList();
  171. onChange([...sel]);
  172. });
  173. root.querySelector('[data-none]').addEventListener('click', () => {
  174. sel.clear();
  175. if (!allowEmpty && items[0]) sel.add(items[0].key);
  176. refreshButton();
  177. renderList();
  178. onChange([...sel]);
  179. });
  180. refreshButton();
  181. return { refresh: () => { refreshButton(); renderList(); } };
  182. }
  183. function renderBar() {
  184. const bar = $('opsBar');
  185. if (!bar) return;
  186. const summary = state.summary;
  187. if (!summary || !summary.enabled || !matrixCount(summary)) {
  188. bar.innerHTML = '';
  189. return;
  190. }
  191. const schools = summary.schools || [];
  192. const chosen = state.schools === null ? new Set(schools.map((s) => s.name)) : state.schools;
  193. bar.innerHTML = `
  194. <div class="ops-bar">
  195. <div class="ops-bar-group">
  196. <span class="ops-bar-label">学校</span>
  197. <div class="ops-chips" id="opsSchoolChips">
  198. ${schools.map((s) => `<button type="button" class="ops-chip${chosen.has(s.name) ? ' on' : ''}" data-school="${esc(s.name)}">${esc(s.name)}<em>${s.shopCount}</em></button>`).join('')}
  199. </div>
  200. </div>
  201. <div class="ops-bar-group">
  202. <span class="ops-bar-label">日期</span>
  203. <input type="date" class="ops-input" id="opsFrom" value="${ymdToInput(state.from)}">
  204. <span class="ops-tilde">~</span>
  205. <input type="date" class="ops-input" id="opsTo" value="${ymdToInput(state.to)}">
  206. </div>
  207. <div class="ops-bar-group">
  208. <span class="ops-bar-label">字段</span>
  209. <div class="ops-multi" id="opsFieldPicker"></div>
  210. </div>
  211. <div class="ops-bar-group">
  212. <span class="ops-bar-label">店铺</span>
  213. <div class="ops-multi" id="opsShopPicker"></div>
  214. </div>
  215. </div>`;
  216. renderHeaderTools();
  217. bar.querySelectorAll('[data-school]').forEach((btn) => {
  218. btn.addEventListener('click', () => {
  219. const name = btn.dataset.school;
  220. const current = state.schools === null ? new Set(schools.map((s) => s.name)) : new Set(state.schools);
  221. if (current.has(name)) current.delete(name); else current.add(name);
  222. state.schools = current.size === schools.length ? null : current;
  223. if (!current.size) state.schools = new Set();
  224. renderBar();
  225. loadRows();
  226. });
  227. });
  228. $('opsFrom').addEventListener('change', (e) => { state.from = inputToYmd(e.target.value); loadRows(); });
  229. $('opsTo').addEventListener('change', (e) => { state.to = inputToYmd(e.target.value); loadRows(); });
  230. mountMulti($('opsFieldPicker'), {
  231. label: '字段',
  232. items: state.catalog.map((f) => ({ key: f.key, label: f.label, hint: f.type === 'text' ? '文本' : '' })),
  233. selected: state.fields,
  234. allowEmpty: false,
  235. onChange: (keys) => {
  236. state.fields = keys;
  237. localStorage.setItem('ops.fields', JSON.stringify(keys));
  238. loadRows();
  239. },
  240. });
  241. const shopItems = (summary.shops || []).map((shop) => ({
  242. key: String(shop.key || shop.shopId || ''),
  243. label: shop.shopName || shop.key,
  244. hint: shop.school || '',
  245. })).filter((i) => i.key);
  246. mountMulti($('opsShopPicker'), {
  247. label: '店铺',
  248. items: shopItems,
  249. selected: state.shops ? [...state.shops] : [],
  250. allowEmpty: true,
  251. emptyLabel: '全部',
  252. onChange: (keys) => {
  253. state.shops = keys.length ? new Set(keys) : null;
  254. loadRows();
  255. },
  256. });
  257. }
  258. function matrixCount(summary) {
  259. if (!summary) return 0;
  260. return Number(summary.matrixRowCount != null ? summary.matrixRowCount : summary.rowCount) || 0;
  261. }
  262. function renderHeaderTools() {
  263. const el = $('opsHeaderTools');
  264. if (!el) return;
  265. const summary = state.summary;
  266. if (!summary || !summary.enabled || !matrixCount(summary)) {
  267. el.innerHTML = '';
  268. return;
  269. }
  270. el.innerHTML = `<div class="ops-seg" id="opsViewSeg">
  271. <button type="button" data-mode="table" class="${state.view === 'table' ? 'on' : ''}">报表</button>
  272. <button type="button" data-mode="cards" class="${state.view === 'cards' ? 'on' : ''}">卡片</button>
  273. </div>
  274. <button type="button" class="btn btn-ghost btn-small" id="opsExport">导出 CSV</button>`;
  275. el.querySelectorAll('#opsViewSeg [data-mode]').forEach((btn) => {
  276. btn.addEventListener('click', () => {
  277. state.view = btn.dataset.mode;
  278. localStorage.setItem('ops.view', state.view);
  279. renderHeaderTools();
  280. renderBody();
  281. });
  282. });
  283. $('opsExport').addEventListener('click', () => {
  284. const params = new URLSearchParams();
  285. if (state.from) params.set('from', state.from);
  286. if (state.to) params.set('to', state.to);
  287. if (state.schools !== null && state.schools.size) params.set('schools', [...state.schools].join(','));
  288. if (state.fields.length) params.set('fields', state.fields.join(','));
  289. window.open('/api/ops/export?' + params.toString(), '_blank');
  290. });
  291. }
  292. // ---------- 内容区 ----------
  293. function renderBody() {
  294. const body = $('opsBody');
  295. if (!body) return;
  296. const summary = state.summary;
  297. if (!summary) {
  298. body.innerHTML = '<div class="empty-hint"><p>正在加载…</p></div>';
  299. return;
  300. }
  301. if (!summary.enabled) {
  302. const reasonText = {
  303. 'storage-not-configured': '未配置存储(config.json → storage)',
  304. 'storage-unreachable': '存储连接失败',
  305. 'pg-not-installed': '未安装 pg 依赖',
  306. 'sqlite-unavailable': '当前 Node 版本不支持内置 SQLite(需要 22.5+)',
  307. }[summary.reason] || '存储不可用';
  308. body.innerHTML = `
  309. <div class="empty-hint ops-empty">
  310. <p>店铺运营数据暂不可用</p>
  311. <small>${esc(reasonText)}${summary.detail ? ':' + esc(summary.detail) : ''}</small>
  312. <button type="button" class="btn btn-ghost btn-small" id="opsRetry" style="margin-top:14px">重试</button>
  313. </div>`;
  314. $('opsRetry').addEventListener('click', () => init(true));
  315. return;
  316. }
  317. const matrixRows = matrixCount(summary);
  318. if (!matrixRows) {
  319. const platformRows = Number(summary.platformRowCount) || 0;
  320. body.innerHTML = platformRows > 0
  321. ? `<div class="empty-hint ops-empty">
  322. <p>已导入 ${platformRows} 行平台明细</p>
  323. <small>平台全字段数据已入库(可在「导入记录」查看原件与行数);<br>上报人工统计表后,这里会显示指标矩阵</small>
  324. <button type="button" class="btn btn-primary btn-small" id="opsEmptyUpload" style="margin-top:14px">上传文件</button>
  325. </div>`
  326. : `<div class="empty-hint ops-empty">
  327. <p>还没有店铺运营数据</p>
  328. <small>上传商家后台导出的人工统计表(.xlsx),解析后按学校 / 店铺 / 日期查看</small>
  329. <button type="button" class="btn btn-primary btn-small" id="opsEmptyUpload" style="margin-top:14px">上传文件</button>
  330. </div>`;
  331. $('opsEmptyUpload').addEventListener('click', openUpload);
  332. return;
  333. }
  334. if (state.error) {
  335. body.innerHTML = `<div class="empty-hint ops-empty"><p>数据加载失败</p><small>${esc(state.error)}</small>
  336. <button type="button" class="btn btn-ghost btn-small" id="opsReload" style="margin-top:14px">重试</button></div>`;
  337. $('opsReload').addEventListener('click', loadRows);
  338. return;
  339. }
  340. if (state.loading && !state.data) {
  341. body.innerHTML = '<div class="empty-hint"><p>正在加载…</p></div>';
  342. return;
  343. }
  344. if (state.schools !== null && state.schools.size === 0) {
  345. body.innerHTML = '<div class="empty-hint ops-empty"><p>请至少选择一个学校</p></div>';
  346. return;
  347. }
  348. if (!state.data) return;
  349. body.innerHTML = state.view === 'cards' ? renderCards(state.data) : renderTables(state.data);
  350. if (state.view === 'table') bindRowHover();
  351. }
  352. function cellValue(shop, field, date) {
  353. const series = shop.series[field.key] || {};
  354. return Object.prototype.hasOwnProperty.call(series, date) ? series[date] : null;
  355. }
  356. function metricCell(shop, field, date) {
  357. const value = cellValue(shop, field, date);
  358. const quality = (shop.quality || {})[date];
  359. const warn = quality && quality.length
  360. ? `<span class="ops-warn" title="${esc('解析标记:' + quality.join('、'))}">⚠</span>`
  361. : '';
  362. return `<td class="ops-num${value == null ? ' ops-null' : ''}">${fmtValue(value, field.type)}${warn}</td>`;
  363. }
  364. /** 学校小计:数量/金额求和,比率按曝光加权,文本取第一个非空 */
  365. function subtotalValue(group, field, date) {
  366. if (field.type === 'text') {
  367. for (const shop of group.shops) {
  368. const v = cellValue(shop, field, date);
  369. if (v !== null) return v;
  370. }
  371. return null;
  372. }
  373. if (field.type === 'rate') {
  374. let weight = 0;
  375. let acc = 0;
  376. for (const shop of group.shops) {
  377. const exposure = cellValue(shop, { key: 'exposure' }, date);
  378. const rate = cellValue(shop, field, date);
  379. if (typeof exposure === 'number' && exposure > 0 && typeof rate === 'number') {
  380. weight += exposure;
  381. acc += rate * exposure;
  382. }
  383. }
  384. return weight > 0 ? acc / weight : null;
  385. }
  386. let sum = 0;
  387. let seen = false;
  388. for (const shop of group.shops) {
  389. const v = cellValue(shop, field, date);
  390. if (typeof v === 'number') { sum += v; seen = true; }
  391. }
  392. return seen ? sum : null;
  393. }
  394. function activeFields(data) {
  395. if (data && Array.isArray(data.fields) && data.fields.length) return data.fields;
  396. return state.fields.map((key) => fieldByKey(key));
  397. }
  398. function renderTables(data) {
  399. const fields = activeFields(data);
  400. if (!fields.length) return '<div class="empty-hint"><p>请至少选择一个字段</p></div>';
  401. const dates = data.dates || [];
  402. const colCount = fields.length + 2;
  403. const head = `<tr>
  404. <th class="ops-shop-col">店铺</th>
  405. <th class="ops-date-col">日期</th>
  406. ${fields.map((f) => `<th class="ops-metric-col" title="${esc(f.label)}">${esc(f.label)}</th>`).join('')}
  407. </tr>`;
  408. const body = data.groups.map((group, groupIdx) => {
  409. const schoolRow = `<tr class="ops-school-row"><td colspan="${colCount}">${esc(group.school)}<em>${group.shops.length} 家</em></td></tr>`;
  410. const shopRows = group.shops.map((shop, shopIdx) => {
  411. const shopDates = dates.filter((d) => fields.some((f) => cellValue(shop, f, d) !== null));
  412. const useDates = shopDates.length ? shopDates : dates.slice(0, 1);
  413. const blockKey = `b${groupIdx}-${shopIdx}`;
  414. const alt = shopIdx % 2 === 1 ? ' ops-block-alt' : '';
  415. return useDates.map((date, i) => `<tr data-block="${blockKey}" class="ops-shop-row${i === 0 ? ' ops-block-start' : ''}${alt}">
  416. ${i === 0 ? `<td class="ops-shop-cell" rowspan="${useDates.length}" title="${esc(shop.shopName)}">${esc(shop.shopName)}${
  417. shop.status && shop.status !== '已上线' ? `<span class="badge badge-muted ops-status">${esc(shop.status)}</span>` : ''
  418. }</td>` : ''}
  419. <td class="ops-date-cell">${shortDate(date)}</td>
  420. ${fields.map((f) => metricCell(shop, f, date)).join('')}
  421. </tr>`).join('');
  422. }).join('');
  423. const subtotalDates = dates.filter((d) => group.shops.some((shop) => fields.some((f) => cellValue(shop, f, d) !== null)));
  424. const subtotalRows = subtotalDates.map((date) => `<tr class="ops-subtotal-row">
  425. <td class="ops-subtotal-label" colspan="2">${esc(group.school)} · 小计 · ${shortDate(date)}</td>
  426. ${fields.map((f) => {
  427. const v = subtotalValue(group, f, date);
  428. return `<td class="ops-num ops-subtotal">${v == null ? '–' : fmtValue(v, f.type)}</td>`;
  429. }).join('')}
  430. </tr>`).join('');
  431. return schoolRow + shopRows + subtotalRows;
  432. }).join('');
  433. const shopCount = data.groups.reduce((n, g) => n + g.shops.length, 0);
  434. return `<section class="ops-block">
  435. <div class="ops-block-head"><h2>运营明细</h2><span>${shopCount} 家门店 · ${dates.length} 天 · ${fields.length} 个字段</span></div>
  436. <div class="ops-table-wrap">
  437. <table class="ops-table ops-table-wide">
  438. <thead>${head}</thead>
  439. <tbody>${body}</tbody>
  440. </table>
  441. </div>
  442. </section>`;
  443. }
  444. /** 悬停时整块高亮(同一店铺的多天一起亮),避免分不清行属于哪家店 */
  445. function bindRowHover() {
  446. document.querySelectorAll('.ops-table-wide tbody').forEach((tbody) => {
  447. if (tbody.dataset.hoverBound === '1') return;
  448. tbody.dataset.hoverBound = '1';
  449. const clear = () => tbody.querySelectorAll('tr.ops-hover').forEach((tr) => tr.classList.remove('ops-hover'));
  450. tbody.addEventListener('mouseover', (e) => {
  451. const tr = e.target.closest('tr[data-block]');
  452. if (!tr) return;
  453. if (tr.classList.contains('ops-hover')) return;
  454. clear();
  455. tbody.querySelectorAll(`tr[data-block="${tr.dataset.block}"]`).forEach((row) => row.classList.add('ops-hover'));
  456. });
  457. tbody.addEventListener('mouseleave', clear);
  458. });
  459. }
  460. function sparkline(shop, field, dates) {
  461. const values = dates.map((d) => {
  462. const v = (shop.series[field.key] || {})[d];
  463. return typeof v === 'number' ? v : null;
  464. });
  465. const nums = values.filter((v) => v != null);
  466. if (nums.length < 2) return '';
  467. const min = Math.min(...nums);
  468. const max = Math.max(...nums);
  469. const span = max - min || 1;
  470. const w = 160;
  471. const h = 34;
  472. const step = w / Math.max(values.length - 1, 1);
  473. const points = [];
  474. values.forEach((v, i) => {
  475. if (v == null) return;
  476. const x = (i * step).toFixed(1);
  477. const y = (h - ((v - min) / span) * (h - 6) - 3).toFixed(1);
  478. points.push(`${x},${y}`);
  479. });
  480. return `<svg class="ops-spark" viewBox="0 0 ${w} ${h}" preserveAspectRatio="none" aria-hidden="true"><polyline points="${points.join(' ')}" /></svg>`;
  481. }
  482. function renderCards(data) {
  483. const dates = data.dates || [];
  484. const fields = activeFields(data);
  485. const first = fields[0];
  486. if (!first) return '<div class="empty-hint"><p>请至少选择一个字段</p></div>';
  487. return `<div class="ops-cards">${data.groups.map((group) => `
  488. <section class="ops-card-group">
  489. <h3>${esc(group.school)}</h3>
  490. <div class="ops-card-grid">
  491. ${group.shops.map((shop) => `
  492. <article class="ops-card">
  493. <div class="ops-card-head">
  494. <span class="ops-card-name" title="${esc(shop.shopName)}">${esc(shop.shopName)}</span>
  495. ${shop.status && shop.status !== '已上线' ? `<span class="badge badge-muted">${esc(shop.status)}</span>` : ''}
  496. </div>
  497. <div class="ops-card-metrics">
  498. ${fields.map((f) => `<div class="ops-card-metric"><span>${esc(f.label)}</span><b>${fmtValue(shop.totals ? shop.totals[f.key] : null, f.type)}</b></div>`).join('')}
  499. </div>
  500. ${sparkline(shop, first, dates)}
  501. </article>`).join('')}
  502. </div>
  503. </section>`).join('')}</div>`;
  504. }
  505. // ---------- 上传 ----------
  506. async function refreshSchoolOptions() {
  507. const select = $('opsSchool');
  508. if (!select) return;
  509. // 已登记学校(校区地图里的学校注册表,含内置)
  510. const registered = [];
  511. try {
  512. const { res, body } = await api('/api/schools');
  513. if (res.ok) {
  514. for (const school of (body && body.schools) || []) {
  515. if (!school || !school.name) continue;
  516. registered.push({
  517. name: school.name,
  518. hint: [school.province, school.city].filter(Boolean).join(' · '),
  519. });
  520. }
  521. }
  522. } catch { /* 注册表取不到时回落到运营数据里的学校 */ }
  523. // 运营数据中出现过、但还没登记的学校
  524. const registeredNames = new Set(registered.map((x) => x.name));
  525. const fromOps = ((state.summary && state.summary.schools) || [])
  526. .map((x) => x.name)
  527. .filter((name) => name && !registeredNames.has(name));
  528. select.innerHTML = '<option value="">自动(读取表格里的「学校名称」列)</option>'
  529. + (registered.length
  530. ? `<optgroup label="已登记学校">${registered.map((x) => `<option value="${esc(x.name)}">${esc(x.name)}${x.hint ? '(' + esc(x.hint) + ')' : ''}</option>`).join('')}</optgroup>`
  531. : '')
  532. + (fromOps.length
  533. ? `<optgroup label="运营数据中的学校">${fromOps.map((name) => `<option value="${esc(name)}">${esc(name)}</option>`).join('')}</optgroup>`
  534. : '')
  535. + '<option value="__custom">手动输入…</option>';
  536. select.value = '';
  537. const custom = $('opsSchoolCustom');
  538. if (custom) {
  539. custom.value = '';
  540. custom.hidden = true;
  541. }
  542. }
  543. function selectedSchool() {
  544. const select = $('opsSchool');
  545. if (!select) return '';
  546. if (select.value === '__custom') return String(($('opsSchoolCustom') || {}).value || '').trim();
  547. return select.value;
  548. }
  549. function fileKey(f) {
  550. return f.name + '|' + f.size + '|' + (f.lastModified || 0);
  551. }
  552. function addFiles(fileList) {
  553. for (const f of Array.from(fileList || [])) {
  554. if (!/\.xlsx$/i.test(f.name)) continue;
  555. const key = fileKey(f);
  556. if (state.upload.files.some((x) => fileKey(x.file) === key)) continue;
  557. state.upload.files.push({ file: f, status: 'pending', message: '' });
  558. }
  559. renderFileList();
  560. }
  561. function renderFileList() {
  562. const box = $('opsFileList');
  563. if (!box) return;
  564. if (!state.upload.files.length) {
  565. box.innerHTML = '';
  566. return;
  567. }
  568. box.innerHTML = state.upload.files.map((item, i) => {
  569. const cls = item.status === 'error' ? 'ops-error'
  570. : item.status === 'done' ? 'ops-done-text'
  571. : item.status === 'duplicate' ? 'ops-muted' : '';
  572. const msg = item.message ? `<em class="${cls}">${esc(item.message)}</em>` : '';
  573. const removable = item.status !== 'uploading';
  574. return `<div class="ops-file-item">
  575. <span class="ops-file-name2" title="${esc(item.file.name)}">${esc(item.file.name)}</span>
  576. <span class="ops-file-size">${(item.file.size / 1024).toFixed(0)} KB</span>
  577. ${msg}
  578. ${removable ? `<button type="button" class="ops-file-del" data-idx="${i}" title="移除">×</button>` : ''}
  579. </div>`;
  580. }).join('');
  581. box.querySelectorAll('[data-idx]').forEach((btn) => {
  582. btn.addEventListener('click', () => {
  583. const i = Number(btn.dataset.idx);
  584. if (state.upload.files[i] && state.upload.files[i].status === 'uploading') return;
  585. state.upload.files.splice(i, 1);
  586. renderFileList();
  587. });
  588. });
  589. }
  590. async function openUpload() {
  591. const modal = $('opsUploadModal');
  592. if (!modal) return;
  593. state.upload.files = [];
  594. renderFileList();
  595. $('opsUploadResult').innerHTML = '';
  596. $('opsYear').value = String(new Date().getFullYear());
  597. await refreshSchoolOptions();
  598. if ($('opsForce')) $('opsForce').checked = false;
  599. $('opsUploadStart').disabled = false;
  600. modal.hidden = false;
  601. }
  602. function closeUpload() {
  603. const modal = $('opsUploadModal');
  604. if (modal) modal.hidden = true;
  605. }
  606. function readFileBase64(file) {
  607. return new Promise((resolve, reject) => {
  608. const reader = new FileReader();
  609. reader.onload = () => {
  610. const text = String(reader.result || '');
  611. resolve(text.slice(text.indexOf(',') + 1));
  612. };
  613. reader.onerror = () => reject(reader.error || new Error('读取文件失败'));
  614. reader.readAsDataURL(file);
  615. });
  616. }
  617. async function doUpload(forceOverride) {
  618. const items = state.upload.files;
  619. const result = $('opsUploadResult');
  620. if (!items.length) {
  621. result.innerHTML = '<span class="ops-error">请先选择 .xlsx 文件(可一次选多个)</span>';
  622. return;
  623. }
  624. if (items.length > 30) {
  625. result.innerHTML = '<span class="ops-error">一次最多 30 个文件</span>';
  626. return;
  627. }
  628. const year = Number($('opsYear').value) || new Date().getFullYear();
  629. const school = selectedSchool();
  630. const force = !!(forceOverride || ($('opsForce') && $('opsForce').checked));
  631. $('opsUploadStart').disabled = true;
  632. result.innerHTML = '<span class="ops-muted">正在逐个解析并入库…</span>';
  633. let okCount = 0;
  634. let skipCount = 0;
  635. let failCount = 0;
  636. for (const item of items) {
  637. if (item.status === 'done') continue;
  638. item.status = 'uploading';
  639. item.message = '导入中…';
  640. renderFileList();
  641. try {
  642. const base64 = await readFileBase64(item.file);
  643. const { res, body } = await api('/api/ops/upload', {
  644. method: 'POST',
  645. headers: { 'Content-Type': 'application/json' },
  646. body: JSON.stringify({ fileName: item.file.name, contentBase64: base64, year, school, force }),
  647. });
  648. if (res.status === 409) {
  649. item.status = 'duplicate';
  650. item.message = '已导入过(跳过)';
  651. skipCount += 1;
  652. } else if (!res.ok) {
  653. const detail = body && (body.detail ? body.error + ':' + body.detail : body.error);
  654. item.status = 'error';
  655. item.message = detail || ('失败 HTTP ' + res.status);
  656. failCount += 1;
  657. } else {
  658. const r = body.report || {};
  659. item.status = 'done';
  660. if (r.kind === 'platform-export') {
  661. const parts = ['新增 ' + r.newRows + ' 行'];
  662. if (r.identicalRows) parts.push('已存在 ' + r.identicalRows + ' 行');
  663. if (r.conflictRows) parts.push('冲突 ' + r.conflictRows + ' 行');
  664. item.message = parts.join(' · ');
  665. } else {
  666. item.message = r.rows + ' 行 · ' + r.shops + ' 家';
  667. }
  668. okCount += 1;
  669. }
  670. } catch (e) {
  671. item.status = 'error';
  672. item.message = e.message || String(e);
  673. failCount += 1;
  674. }
  675. renderFileList();
  676. }
  677. const parts = ['成功 ' + okCount + ' 个'];
  678. if (skipCount) parts.push('跳过 ' + skipCount + ' 个(已导入过)');
  679. if (failCount) parts.push('失败 ' + failCount + ' 个');
  680. result.innerHTML = `<div class="${failCount ? 'ops-error' : 'ops-ok'}">${parts.join(',')}${
  681. skipCount && !force ? '<br><small>已存在的文件可勾选下方「覆盖已导入的文件」后重新导入</small>' : ''
  682. }</div>`;
  683. $('opsUploadStart').disabled = false;
  684. if (okCount) {
  685. state.from = '';
  686. state.to = '';
  687. state.schools = null;
  688. await init(true);
  689. }
  690. }
  691. // ---------- 导入记录 ----------
  692. async function openRecords() {
  693. const modal = $('opsRecordsModal');
  694. if (!modal) return;
  695. modal.hidden = false;
  696. const list = $('opsRecordsList');
  697. list.innerHTML = '<div class="ops-muted" style="padding:16px">加载中…</div>';
  698. const { res, body } = await api('/api/ops/uploads');
  699. if (!res.ok) {
  700. list.innerHTML = `<div class="ops-error" style="padding:16px">${esc((body && (body.detail || body.error)) || ('HTTP ' + res.status))}</div>`;
  701. return;
  702. }
  703. const uploads = (body && body.uploads) || [];
  704. if (!uploads.length) {
  705. list.innerHTML = '<div class="ops-muted" style="padding:16px">还没有导入记录</div>';
  706. return;
  707. }
  708. list.innerHTML = `<table class="data-table">
  709. <thead><tr><th>文件名</th><th>上传时间</th><th>行数</th><th>门店</th><th>警告</th><th class="col-actions">操作</th></tr></thead>
  710. <tbody>${uploads.map((u) => `<tr>
  711. <td>${esc(u.originalName)}</td>
  712. <td>${esc(new Date(u.uploadedAt).toLocaleString('zh-CN'))}</td>
  713. <td>${u.rows || 0}</td>
  714. <td>${u.shops || 0}</td>
  715. <td>${u.warningCount || 0}</td>
  716. <td class="col-actions">
  717. <a class="btn btn-ghost btn-small" href="/api/ops/uploads/${esc(u.id)}/file">下载原件</a>
  718. <button type="button" class="btn btn-ghost btn-small" data-reparse="${esc(u.id)}">重新解析</button>
  719. </td>
  720. </tr>`).join('')}</tbody>
  721. </table>`;
  722. list.querySelectorAll('[data-reparse]').forEach((btn) => {
  723. btn.addEventListener('click', async () => {
  724. btn.disabled = true;
  725. btn.textContent = '解析中…';
  726. const { res, body: rep } = await api(`/api/ops/uploads/${btn.dataset.reparse}/reparse`, { method: 'POST' });
  727. btn.disabled = false;
  728. btn.textContent = '重新解析';
  729. if (!res.ok) {
  730. alert((rep && (rep.detail || rep.error)) || '重新解析失败');
  731. return;
  732. }
  733. await init(true);
  734. });
  735. });
  736. }
  737. // ---------- 初始化 ----------
  738. async function loadCatalog() {
  739. const { res, body } = await api('/api/ops/fields');
  740. if (!res.ok || !body || !Array.isArray(body.fields)) return;
  741. state.catalog = body.fields;
  742. const valid = new Set(body.fields.map((f) => f.key));
  743. state.fields = state.fields.filter((k) => valid.has(k));
  744. if (!state.fields.length) state.fields = (body.defaults || []).filter((k) => valid.has(k));
  745. if (!state.fields.length) state.fields = body.fields.slice(0, 4).map((f) => f.key);
  746. }
  747. async function init(force) {
  748. if (state.inited && !force) return;
  749. state.inited = true;
  750. await loadSummary();
  751. await loadCatalog();
  752. renderBar();
  753. renderHeaderTools();
  754. renderBody();
  755. if (state.summary && state.summary.enabled && matrixCount(state.summary)) await loadRows();
  756. }
  757. function bindOnce() {
  758. const uploadBtn = $('btnOpsUpload');
  759. if (uploadBtn) uploadBtn.addEventListener('click', openUpload);
  760. const recordsBtn = $('btnOpsRecords');
  761. if (recordsBtn) recordsBtn.addEventListener('click', openRecords);
  762. const start = $('opsUploadStart');
  763. if (start) start.addEventListener('click', () => doUpload(false));
  764. const cancel = $('opsUploadCancel');
  765. if (cancel) cancel.addEventListener('click', closeUpload);
  766. const closeBtn = $('opsUploadClose');
  767. if (closeBtn) closeBtn.addEventListener('click', closeUpload);
  768. const schoolSelect = $('opsSchool');
  769. if (schoolSelect) {
  770. schoolSelect.addEventListener('change', () => {
  771. const custom = $('opsSchoolCustom');
  772. if (!custom) return;
  773. custom.hidden = schoolSelect.value !== '__custom';
  774. if (!custom.hidden) custom.focus();
  775. });
  776. }
  777. const file = $('opsFile');
  778. if (file) {
  779. file.addEventListener('change', () => {
  780. addFiles(file.files);
  781. file.value = '';
  782. });
  783. }
  784. const drop = $('opsDrop');
  785. if (drop) {
  786. ['dragover', 'dragenter'].forEach((ev) => drop.addEventListener(ev, (e) => { e.preventDefault(); drop.classList.add('on'); }));
  787. ['dragleave', 'drop'].forEach((ev) => drop.addEventListener(ev, (e) => { e.preventDefault(); drop.classList.remove('on'); }));
  788. drop.addEventListener('drop', (e) => {
  789. if (!e.dataTransfer || !e.dataTransfer.files) return;
  790. addFiles(e.dataTransfer.files);
  791. });
  792. drop.addEventListener('click', () => { const input = $('opsFile'); if (input) input.click(); });
  793. }
  794. const recordsClose = $('opsRecordsClose');
  795. if (recordsClose) recordsClose.addEventListener('click', () => { $('opsRecordsModal').hidden = true; });
  796. }
  797. window.shanOpsInit = function () {
  798. bindOnce();
  799. init(false);
  800. };
  801. })();