ops.js 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708
  1. 'use strict';
  2. // 店铺运营页:上传人工统计表 → 按学校/店铺/日期看指标矩阵或卡片。
  3. // 数据来自 /api/ops/*;原件存服务端存储(默认本地 SQLite),页面只做展示与上传。
  4. (function () {
  5. const $ = (id) => document.getElementById(id);
  6. const META = {
  7. order_cnt: { label: '订单量', type: 'int' },
  8. revenue: { label: '营收', type: 'money' },
  9. exposure: { label: '曝光量', type: 'int' },
  10. click_rate: { label: '进店转化率', type: 'rate' },
  11. };
  12. const ALL_METRICS = Object.keys(META);
  13. const DEFAULT_METRICS = ALL_METRICS.slice();
  14. function loadJSON(key, fallback) {
  15. try {
  16. const raw = localStorage.getItem(key);
  17. if (!raw) return fallback;
  18. const v = JSON.parse(raw);
  19. return Array.isArray(v) && v.length ? v.filter((x) => ALL_METRICS.includes(x)) : fallback;
  20. } catch {
  21. return fallback;
  22. }
  23. }
  24. const state = {
  25. inited: false,
  26. loading: false,
  27. summary: null,
  28. data: null,
  29. schools: null, // null = 全选
  30. metrics: loadJSON('ops.metrics', DEFAULT_METRICS),
  31. view: localStorage.getItem('ops.view') === 'cards' ? 'cards' : 'table',
  32. from: '',
  33. to: '',
  34. upload: { files: [], busy: false },
  35. };
  36. function esc(value) {
  37. const div = document.createElement('div');
  38. div.textContent = String(value == null ? '' : value);
  39. return div.innerHTML;
  40. }
  41. function ymdToInput(ymd) {
  42. const s = String(ymd || '');
  43. return /^\d{8}$/.test(s) ? `${s.slice(0, 4)}-${s.slice(4, 6)}-${s.slice(6, 8)}` : '';
  44. }
  45. function inputToYmd(value) {
  46. return String(value || '').replace(/-/g, '');
  47. }
  48. function shortDate(ymd) {
  49. const s = String(ymd || '');
  50. return /^\d{8}$/.test(s) ? `${Number(s.slice(4, 6))}.${Number(s.slice(6, 8))}` : s;
  51. }
  52. function fmtValue(value, metric) {
  53. if (value === null || value === undefined) return '–';
  54. const n = Number(value);
  55. if (!Number.isFinite(n)) return '–';
  56. if (META[metric].type === 'rate') return (n * 100).toFixed(1) + '%';
  57. if (META[metric].type === 'money') return n.toLocaleString('zh-CN', { minimumFractionDigits: 2, maximumFractionDigits: 2 });
  58. return n.toLocaleString('zh-CN');
  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. params.set('metrics', state.metrics.join(','));
  97. const { res, body } = await api('/api/ops/rows?' + params.toString());
  98. state.loading = false;
  99. if (!res.ok) {
  100. state.data = null;
  101. state.error = (body && (body.detail || body.error)) || `HTTP ${res.status}`;
  102. } else {
  103. state.data = body;
  104. state.error = null;
  105. }
  106. renderBody();
  107. }
  108. // ---------- 工具条 ----------
  109. function renderBar() {
  110. const bar = $('opsBar');
  111. if (!bar) return;
  112. const summary = state.summary;
  113. if (!summary || !summary.enabled || !summary.rowCount) {
  114. bar.innerHTML = '';
  115. return;
  116. }
  117. const schools = summary.schools || [];
  118. const chosen = state.schools === null ? new Set(schools.map((s) => s.name)) : state.schools;
  119. bar.innerHTML = `
  120. <div class="ops-bar">
  121. <div class="ops-bar-group">
  122. <span class="ops-bar-label">学校</span>
  123. <div class="ops-chips" id="opsSchoolChips">
  124. ${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('')}
  125. </div>
  126. </div>
  127. <div class="ops-bar-group">
  128. <span class="ops-bar-label">日期</span>
  129. <input type="date" class="ops-input" id="opsFrom" value="${ymdToInput(state.from)}">
  130. <span class="ops-tilde">~</span>
  131. <input type="date" class="ops-input" id="opsTo" value="${ymdToInput(state.to)}">
  132. </div>
  133. <div class="ops-bar-group">
  134. <span class="ops-bar-label">指标</span>
  135. <div class="ops-chips" id="opsMetricChips">
  136. ${ALL_METRICS.map((k) => `<button type="button" class="ops-chip${state.metrics.includes(k) ? ' on' : ''}" data-metric="${k}">${META[k].label}</button>`).join('')}
  137. </div>
  138. </div>
  139. </div>`;
  140. renderHeaderTools();
  141. bar.querySelectorAll('[data-school]').forEach((btn) => {
  142. btn.addEventListener('click', () => {
  143. const name = btn.dataset.school;
  144. const current = state.schools === null ? new Set(schools.map((s) => s.name)) : new Set(state.schools);
  145. if (current.has(name)) current.delete(name); else current.add(name);
  146. state.schools = current.size === schools.length ? null : current;
  147. if (!current.size) state.schools = new Set();
  148. renderBar();
  149. loadRows();
  150. });
  151. });
  152. bar.querySelectorAll('[data-metric]').forEach((btn) => {
  153. btn.addEventListener('click', () => {
  154. const key = btn.dataset.metric;
  155. if (state.metrics.includes(key)) {
  156. if (state.metrics.length === 1) return; // 至少保留一个指标
  157. state.metrics = state.metrics.filter((k) => k !== key);
  158. } else {
  159. state.metrics = ALL_METRICS.filter((k) => key === k || state.metrics.includes(k));
  160. }
  161. localStorage.setItem('ops.metrics', JSON.stringify(state.metrics));
  162. renderBar();
  163. renderBody();
  164. });
  165. });
  166. $('opsFrom').addEventListener('change', (e) => { state.from = inputToYmd(e.target.value); loadRows(); });
  167. $('opsTo').addEventListener('change', (e) => { state.to = inputToYmd(e.target.value); loadRows(); });
  168. }
  169. function renderHeaderTools() {
  170. const el = $('opsHeaderTools');
  171. if (!el) return;
  172. const summary = state.summary;
  173. if (!summary || !summary.enabled || !summary.rowCount) {
  174. el.innerHTML = '';
  175. return;
  176. }
  177. el.innerHTML = `<div class="ops-seg" id="opsViewSeg">
  178. <button type="button" data-mode="table" class="${state.view === 'table' ? 'on' : ''}">报表</button>
  179. <button type="button" data-mode="cards" class="${state.view === 'cards' ? 'on' : ''}">卡片</button>
  180. </div>
  181. <button type="button" class="btn btn-ghost btn-small" id="opsExport">导出 CSV</button>`;
  182. el.querySelectorAll('#opsViewSeg [data-mode]').forEach((btn) => {
  183. btn.addEventListener('click', () => {
  184. state.view = btn.dataset.mode;
  185. localStorage.setItem('ops.view', state.view);
  186. renderHeaderTools();
  187. renderBody();
  188. });
  189. });
  190. $('opsExport').addEventListener('click', () => {
  191. const params = new URLSearchParams();
  192. if (state.from) params.set('from', state.from);
  193. if (state.to) params.set('to', state.to);
  194. if (state.schools !== null && state.schools.size) params.set('schools', [...state.schools].join(','));
  195. params.set('metrics', state.metrics.join(','));
  196. window.open('/api/ops/export?' + params.toString(), '_blank');
  197. });
  198. }
  199. // ---------- 内容区 ----------
  200. function renderBody() {
  201. const body = $('opsBody');
  202. if (!body) return;
  203. const summary = state.summary;
  204. if (!summary) {
  205. body.innerHTML = '<div class="empty-hint"><p>正在加载…</p></div>';
  206. return;
  207. }
  208. if (!summary.enabled) {
  209. const reasonText = {
  210. 'storage-not-configured': '未配置存储(config.json → storage)',
  211. 'storage-unreachable': '存储连接失败',
  212. 'pg-not-installed': '未安装 pg 依赖',
  213. 'sqlite-unavailable': '当前 Node 版本不支持内置 SQLite(需要 22.5+)',
  214. }[summary.reason] || '存储不可用';
  215. body.innerHTML = `
  216. <div class="empty-hint ops-empty">
  217. <p>店铺运营数据暂不可用</p>
  218. <small>${esc(reasonText)}${summary.detail ? ':' + esc(summary.detail) : ''}</small>
  219. <button type="button" class="btn btn-ghost btn-small" id="opsRetry" style="margin-top:14px">重试</button>
  220. </div>`;
  221. $('opsRetry').addEventListener('click', () => init(true));
  222. return;
  223. }
  224. if (!summary.rowCount) {
  225. const platformRows = Number(summary.platformRowCount) || 0;
  226. body.innerHTML = platformRows > 0
  227. ? `<div class="empty-hint ops-empty">
  228. <p>已导入 ${platformRows} 行平台明细</p>
  229. <small>平台全字段数据已入库(可在「导入记录」查看原件与行数);<br>上报人工统计表后,这里会显示指标矩阵</small>
  230. <button type="button" class="btn btn-primary btn-small" id="opsEmptyUpload" style="margin-top:14px">上传文件</button>
  231. </div>`
  232. : `<div class="empty-hint ops-empty">
  233. <p>还没有店铺运营数据</p>
  234. <small>上传商家后台导出的人工统计表(.xlsx),解析后按学校 / 店铺 / 日期查看</small>
  235. <button type="button" class="btn btn-primary btn-small" id="opsEmptyUpload" style="margin-top:14px">上传文件</button>
  236. </div>`;
  237. $('opsEmptyUpload').addEventListener('click', openUpload);
  238. return;
  239. }
  240. if (state.error) {
  241. body.innerHTML = `<div class="empty-hint ops-empty"><p>数据加载失败</p><small>${esc(state.error)}</small>
  242. <button type="button" class="btn btn-ghost btn-small" id="opsReload" style="margin-top:14px">重试</button></div>`;
  243. $('opsReload').addEventListener('click', loadRows);
  244. return;
  245. }
  246. if (state.loading && !state.data) {
  247. body.innerHTML = '<div class="empty-hint"><p>正在加载…</p></div>';
  248. return;
  249. }
  250. if (state.schools !== null && state.schools.size === 0) {
  251. body.innerHTML = '<div class="empty-hint ops-empty"><p>请至少选择一个学校</p></div>';
  252. return;
  253. }
  254. if (!state.data) return;
  255. body.innerHTML = state.view === 'cards' ? renderCards(state.data) : renderTables(state.data);
  256. }
  257. function formatCell(shop, metric, date) {
  258. const series = shop.series[metric] || {};
  259. const value = Object.prototype.hasOwnProperty.call(series, date) ? series[date] : null;
  260. const quality = (shop.quality || {})[date];
  261. const warn = quality && quality.length
  262. ? `<span class="ops-warn" title="${esc('解析标记:' + quality.join('、'))}">⚠</span>`
  263. : '';
  264. return `<td class="ops-num${value == null ? ' ops-null' : ''}">${fmtValue(value, metric)}${warn}</td>`;
  265. }
  266. function subtotalRow(group, metric, dates) {
  267. const cells = dates.map((date) => {
  268. if (metric === 'click_rate') {
  269. let weight = 0;
  270. let acc = 0;
  271. for (const shop of group.shops) {
  272. const exposure = (shop.series.exposure || {})[date];
  273. const rate = (shop.series.click_rate || {})[date];
  274. if (typeof exposure === 'number' && exposure > 0 && typeof rate === 'number') {
  275. weight += exposure;
  276. acc += rate * exposure;
  277. }
  278. }
  279. return `<td class="ops-num ops-subtotal">${weight > 0 ? fmtValue(acc / weight, metric) : '–'}</td>`;
  280. }
  281. let sum = 0;
  282. let seen = false;
  283. for (const shop of group.shops) {
  284. const v = (shop.series[metric] || {})[date];
  285. if (typeof v === 'number') { sum += v; seen = true; }
  286. }
  287. return `<td class="ops-num ops-subtotal">${seen ? fmtValue(sum, metric) : '–'}</td>`;
  288. }).join('');
  289. return `<tr class="ops-subtotal-row"><td class="ops-shop-cell">${esc(group.school)} · 小计</td>${cells}</tr>`;
  290. }
  291. function renderTables(data) {
  292. const dates = data.dates || [];
  293. const metrics = state.metrics.filter((m) => META[m]);
  294. if (!metrics.length) return '<div class="empty-hint"><p>请至少选择一个指标</p></div>';
  295. return metrics.map((metric) => {
  296. const head = `<tr><th class="ops-shop-col">店铺</th>${dates.map((d) => `<th class="ops-date-col">${shortDate(d)}</th>`).join('')}</tr>`;
  297. const rows = data.groups.map((group) => {
  298. const schoolRow = `<tr class="ops-school-row"><td class="ops-shop-cell" colspan="${dates.length + 1}">${esc(group.school)}<em>${group.shops.length} 家</em></td></tr>`;
  299. const shopRows = group.shops.map((shop) => `<tr>
  300. <td class="ops-shop-cell" title="${esc(shop.shopName)}">${esc(shop.shopName)}${
  301. shop.status && shop.status !== '已上线' ? `<span class="badge badge-muted ops-status">${esc(shop.status)}</span>` : ''
  302. }</td>
  303. ${dates.map((d) => formatCell(shop, metric, d)).join('')}
  304. </tr>`).join('');
  305. return schoolRow + shopRows + subtotalRow(group, metric, dates);
  306. }).join('');
  307. const shopCount = data.groups.reduce((n, g) => n + g.shops.length, 0);
  308. return `<section class="ops-block">
  309. <div class="ops-block-head"><h2>${META[metric].label}</h2><span>${shopCount} 家门店 · ${dates.length} 天</span></div>
  310. <div class="ops-table-wrap">
  311. <table class="ops-table">
  312. <thead>${head}</thead>
  313. <tbody>${rows}</tbody>
  314. </table>
  315. </div>
  316. </section>`;
  317. }).join('');
  318. }
  319. function sparkline(shop, metric, dates) {
  320. const values = dates.map((d) => {
  321. const v = (shop.series[metric] || {})[d];
  322. return typeof v === 'number' ? v : null;
  323. });
  324. const nums = values.filter((v) => v != null);
  325. if (nums.length < 2) return '';
  326. const min = Math.min(...nums);
  327. const max = Math.max(...nums);
  328. const span = max - min || 1;
  329. const w = 160;
  330. const h = 34;
  331. const step = w / Math.max(values.length - 1, 1);
  332. const points = [];
  333. values.forEach((v, i) => {
  334. if (v == null) return;
  335. const x = (i * step).toFixed(1);
  336. const y = (h - ((v - min) / span) * (h - 6) - 3).toFixed(1);
  337. points.push(`${x},${y}`);
  338. });
  339. return `<svg class="ops-spark" viewBox="0 0 ${w} ${h}" preserveAspectRatio="none" aria-hidden="true"><polyline points="${points.join(' ')}" /></svg>`;
  340. }
  341. function renderCards(data) {
  342. const dates = data.dates || [];
  343. const metric = state.metrics[0];
  344. return `<div class="ops-cards">${data.groups.map((group) => `
  345. <section class="ops-card-group">
  346. <h3>${esc(group.school)}</h3>
  347. <div class="ops-card-grid">
  348. ${group.shops.map((shop) => `
  349. <article class="ops-card">
  350. <div class="ops-card-head">
  351. <span class="ops-card-name" title="${esc(shop.shopName)}">${esc(shop.shopName)}</span>
  352. ${shop.status && shop.status !== '已上线' ? `<span class="badge badge-muted">${esc(shop.status)}</span>` : ''}
  353. </div>
  354. <div class="ops-card-metrics">
  355. ${state.metrics.map((m) => `<div class="ops-card-metric"><span>${META[m].label}</span><b>${m === 'click_rate' ? fmtValue(avgRate(shop, dates), m) : fmtValue(shop.totals && shop.totals[m], m)}</b></div>`).join('')}
  356. </div>
  357. ${sparkline(shop, metric, dates)}
  358. </article>`).join('')}
  359. </div>
  360. </section>`).join('')}</div>`;
  361. }
  362. function avgRate(shop, dates) {
  363. let weight = 0;
  364. let acc = 0;
  365. for (const date of dates) {
  366. const exposure = (shop.series.exposure || {})[date];
  367. const rate = (shop.series.click_rate || {})[date];
  368. if (typeof exposure === 'number' && exposure > 0 && typeof rate === 'number') {
  369. weight += exposure;
  370. acc += rate * exposure;
  371. }
  372. }
  373. return weight > 0 ? acc / weight : null;
  374. }
  375. // ---------- 上传 ----------
  376. async function refreshSchoolOptions() {
  377. const select = $('opsSchool');
  378. if (!select) return;
  379. // 已登记学校(校区地图里的学校注册表,含内置)
  380. const registered = [];
  381. try {
  382. const { res, body } = await api('/api/schools');
  383. if (res.ok) {
  384. for (const school of (body && body.schools) || []) {
  385. if (!school || !school.name) continue;
  386. registered.push({
  387. name: school.name,
  388. hint: [school.province, school.city].filter(Boolean).join(' · '),
  389. });
  390. }
  391. }
  392. } catch { /* 注册表取不到时回落到运营数据里的学校 */ }
  393. // 运营数据中出现过、但还没登记的学校
  394. const registeredNames = new Set(registered.map((x) => x.name));
  395. const fromOps = ((state.summary && state.summary.schools) || [])
  396. .map((x) => x.name)
  397. .filter((name) => name && !registeredNames.has(name));
  398. select.innerHTML = '<option value="">自动(读取表格里的「学校名称」列)</option>'
  399. + (registered.length
  400. ? `<optgroup label="已登记学校">${registered.map((x) => `<option value="${esc(x.name)}">${esc(x.name)}${x.hint ? '(' + esc(x.hint) + ')' : ''}</option>`).join('')}</optgroup>`
  401. : '')
  402. + (fromOps.length
  403. ? `<optgroup label="运营数据中的学校">${fromOps.map((name) => `<option value="${esc(name)}">${esc(name)}</option>`).join('')}</optgroup>`
  404. : '')
  405. + '<option value="__custom">手动输入…</option>';
  406. select.value = '';
  407. const custom = $('opsSchoolCustom');
  408. if (custom) {
  409. custom.value = '';
  410. custom.hidden = true;
  411. }
  412. }
  413. function selectedSchool() {
  414. const select = $('opsSchool');
  415. if (!select) return '';
  416. if (select.value === '__custom') return String(($('opsSchoolCustom') || {}).value || '').trim();
  417. return select.value;
  418. }
  419. function fileKey(f) {
  420. return f.name + '|' + f.size + '|' + (f.lastModified || 0);
  421. }
  422. function addFiles(fileList) {
  423. for (const f of Array.from(fileList || [])) {
  424. if (!/\.xlsx$/i.test(f.name)) continue;
  425. const key = fileKey(f);
  426. if (state.upload.files.some((x) => fileKey(x.file) === key)) continue;
  427. state.upload.files.push({ file: f, status: 'pending', message: '' });
  428. }
  429. renderFileList();
  430. }
  431. function renderFileList() {
  432. const box = $('opsFileList');
  433. if (!box) return;
  434. if (!state.upload.files.length) {
  435. box.innerHTML = '';
  436. return;
  437. }
  438. box.innerHTML = state.upload.files.map((item, i) => {
  439. const cls = item.status === 'error' ? 'ops-error'
  440. : item.status === 'done' ? 'ops-done-text'
  441. : item.status === 'duplicate' ? 'ops-muted' : '';
  442. const msg = item.message ? `<em class="${cls}">${esc(item.message)}</em>` : '';
  443. const removable = item.status !== 'uploading';
  444. return `<div class="ops-file-item">
  445. <span class="ops-file-name2" title="${esc(item.file.name)}">${esc(item.file.name)}</span>
  446. <span class="ops-file-size">${(item.file.size / 1024).toFixed(0)} KB</span>
  447. ${msg}
  448. ${removable ? `<button type="button" class="ops-file-del" data-idx="${i}" title="移除">×</button>` : ''}
  449. </div>`;
  450. }).join('');
  451. box.querySelectorAll('[data-idx]').forEach((btn) => {
  452. btn.addEventListener('click', () => {
  453. const i = Number(btn.dataset.idx);
  454. if (state.upload.files[i] && state.upload.files[i].status === 'uploading') return;
  455. state.upload.files.splice(i, 1);
  456. renderFileList();
  457. });
  458. });
  459. }
  460. async function openUpload() {
  461. const modal = $('opsUploadModal');
  462. if (!modal) return;
  463. state.upload.files = [];
  464. renderFileList();
  465. $('opsUploadResult').innerHTML = '';
  466. $('opsYear').value = String(new Date().getFullYear());
  467. await refreshSchoolOptions();
  468. if ($('opsForce')) $('opsForce').checked = false;
  469. $('opsUploadStart').disabled = false;
  470. modal.hidden = false;
  471. }
  472. function closeUpload() {
  473. const modal = $('opsUploadModal');
  474. if (modal) modal.hidden = true;
  475. }
  476. function readFileBase64(file) {
  477. return new Promise((resolve, reject) => {
  478. const reader = new FileReader();
  479. reader.onload = () => {
  480. const text = String(reader.result || '');
  481. resolve(text.slice(text.indexOf(',') + 1));
  482. };
  483. reader.onerror = () => reject(reader.error || new Error('读取文件失败'));
  484. reader.readAsDataURL(file);
  485. });
  486. }
  487. async function doUpload(forceOverride) {
  488. const items = state.upload.files;
  489. const result = $('opsUploadResult');
  490. if (!items.length) {
  491. result.innerHTML = '<span class="ops-error">请先选择 .xlsx 文件(可一次选多个)</span>';
  492. return;
  493. }
  494. if (items.length > 30) {
  495. result.innerHTML = '<span class="ops-error">一次最多 30 个文件</span>';
  496. return;
  497. }
  498. const year = Number($('opsYear').value) || new Date().getFullYear();
  499. const school = selectedSchool();
  500. const force = !!(forceOverride || ($('opsForce') && $('opsForce').checked));
  501. $('opsUploadStart').disabled = true;
  502. result.innerHTML = '<span class="ops-muted">正在逐个解析并入库…</span>';
  503. let okCount = 0;
  504. let skipCount = 0;
  505. let failCount = 0;
  506. for (const item of items) {
  507. if (item.status === 'done') continue;
  508. item.status = 'uploading';
  509. item.message = '导入中…';
  510. renderFileList();
  511. try {
  512. const base64 = await readFileBase64(item.file);
  513. const { res, body } = await api('/api/ops/upload', {
  514. method: 'POST',
  515. headers: { 'Content-Type': 'application/json' },
  516. body: JSON.stringify({ fileName: item.file.name, contentBase64: base64, year, school, force }),
  517. });
  518. if (res.status === 409) {
  519. item.status = 'duplicate';
  520. item.message = '已导入过(跳过)';
  521. skipCount += 1;
  522. } else if (!res.ok) {
  523. const detail = body && (body.detail ? body.error + ':' + body.detail : body.error);
  524. item.status = 'error';
  525. item.message = detail || ('失败 HTTP ' + res.status);
  526. failCount += 1;
  527. } else {
  528. const r = body.report || {};
  529. item.status = 'done';
  530. if (r.kind === 'platform-export') {
  531. const parts = ['新增 ' + r.newRows + ' 行'];
  532. if (r.identicalRows) parts.push('已存在 ' + r.identicalRows + ' 行');
  533. if (r.conflictRows) parts.push('冲突 ' + r.conflictRows + ' 行');
  534. item.message = parts.join(' · ');
  535. } else {
  536. item.message = r.rows + ' 行 · ' + r.shops + ' 家';
  537. }
  538. okCount += 1;
  539. }
  540. } catch (e) {
  541. item.status = 'error';
  542. item.message = e.message || String(e);
  543. failCount += 1;
  544. }
  545. renderFileList();
  546. }
  547. const parts = ['成功 ' + okCount + ' 个'];
  548. if (skipCount) parts.push('跳过 ' + skipCount + ' 个(已导入过)');
  549. if (failCount) parts.push('失败 ' + failCount + ' 个');
  550. result.innerHTML = `<div class="${failCount ? 'ops-error' : 'ops-ok'}">${parts.join(',')}${
  551. skipCount && !force ? '<br><small>已存在的文件可勾选下方「覆盖已导入的文件」后重新导入</small>' : ''
  552. }</div>`;
  553. $('opsUploadStart').disabled = false;
  554. if (okCount) {
  555. state.from = '';
  556. state.to = '';
  557. state.schools = null;
  558. await init(true);
  559. }
  560. }
  561. // ---------- 导入记录 ----------
  562. async function openRecords() {
  563. const modal = $('opsRecordsModal');
  564. if (!modal) return;
  565. modal.hidden = false;
  566. const list = $('opsRecordsList');
  567. list.innerHTML = '<div class="ops-muted" style="padding:16px">加载中…</div>';
  568. const { res, body } = await api('/api/ops/uploads');
  569. if (!res.ok) {
  570. list.innerHTML = `<div class="ops-error" style="padding:16px">${esc((body && (body.detail || body.error)) || ('HTTP ' + res.status))}</div>`;
  571. return;
  572. }
  573. const uploads = (body && body.uploads) || [];
  574. if (!uploads.length) {
  575. list.innerHTML = '<div class="ops-muted" style="padding:16px">还没有导入记录</div>';
  576. return;
  577. }
  578. list.innerHTML = `<table class="data-table">
  579. <thead><tr><th>文件名</th><th>上传时间</th><th>行数</th><th>门店</th><th>警告</th><th class="col-actions">操作</th></tr></thead>
  580. <tbody>${uploads.map((u) => `<tr>
  581. <td>${esc(u.originalName)}</td>
  582. <td>${esc(new Date(u.uploadedAt).toLocaleString('zh-CN'))}</td>
  583. <td>${u.rows || 0}</td>
  584. <td>${u.shops || 0}</td>
  585. <td>${u.warningCount || 0}</td>
  586. <td class="col-actions">
  587. <a class="btn btn-ghost btn-small" href="/api/ops/uploads/${esc(u.id)}/file">下载原件</a>
  588. <button type="button" class="btn btn-ghost btn-small" data-reparse="${esc(u.id)}">重新解析</button>
  589. </td>
  590. </tr>`).join('')}</tbody>
  591. </table>`;
  592. list.querySelectorAll('[data-reparse]').forEach((btn) => {
  593. btn.addEventListener('click', async () => {
  594. btn.disabled = true;
  595. btn.textContent = '解析中…';
  596. const { res, body: rep } = await api(`/api/ops/uploads/${btn.dataset.reparse}/reparse`, { method: 'POST' });
  597. btn.disabled = false;
  598. btn.textContent = '重新解析';
  599. if (!res.ok) {
  600. alert((rep && (rep.detail || rep.error)) || '重新解析失败');
  601. return;
  602. }
  603. await init(true);
  604. });
  605. });
  606. }
  607. // ---------- 初始化 ----------
  608. async function init(force) {
  609. if (state.inited && !force) return;
  610. state.inited = true;
  611. await loadSummary();
  612. renderBar();
  613. renderHeaderTools();
  614. renderBody();
  615. if (state.summary && state.summary.enabled && state.summary.rowCount) await loadRows();
  616. }
  617. function bindOnce() {
  618. const uploadBtn = $('btnOpsUpload');
  619. if (uploadBtn) uploadBtn.addEventListener('click', openUpload);
  620. const recordsBtn = $('btnOpsRecords');
  621. if (recordsBtn) recordsBtn.addEventListener('click', openRecords);
  622. const start = $('opsUploadStart');
  623. if (start) start.addEventListener('click', () => doUpload(false));
  624. const cancel = $('opsUploadCancel');
  625. if (cancel) cancel.addEventListener('click', closeUpload);
  626. const closeBtn = $('opsUploadClose');
  627. if (closeBtn) closeBtn.addEventListener('click', closeUpload);
  628. const schoolSelect = $('opsSchool');
  629. if (schoolSelect) {
  630. schoolSelect.addEventListener('change', () => {
  631. const custom = $('opsSchoolCustom');
  632. if (!custom) return;
  633. custom.hidden = schoolSelect.value !== '__custom';
  634. if (!custom.hidden) custom.focus();
  635. });
  636. }
  637. const file = $('opsFile');
  638. if (file) {
  639. file.addEventListener('change', () => {
  640. addFiles(file.files);
  641. file.value = '';
  642. });
  643. }
  644. const drop = $('opsDrop');
  645. if (drop) {
  646. ['dragover', 'dragenter'].forEach((ev) => drop.addEventListener(ev, (e) => { e.preventDefault(); drop.classList.add('on'); }));
  647. ['dragleave', 'drop'].forEach((ev) => drop.addEventListener(ev, (e) => { e.preventDefault(); drop.classList.remove('on'); }));
  648. drop.addEventListener('drop', (e) => {
  649. if (!e.dataTransfer || !e.dataTransfer.files) return;
  650. addFiles(e.dataTransfer.files);
  651. });
  652. drop.addEventListener('click', () => { const input = $('opsFile'); if (input) input.click(); });
  653. }
  654. const recordsClose = $('opsRecordsClose');
  655. if (recordsClose) recordsClose.addEventListener('click', () => { $('opsRecordsModal').hidden = true; });
  656. }
  657. window.shanOpsInit = function () {
  658. bindOnce();
  659. init(false);
  660. };
  661. })();