hyreal-gen-pic/server/routes/reports.js

'use strict';

// 数据采集与智能分析路由：同步任务、数据湖查询/聚合/导出、经营周报 HTML、智能问数

const { sendJson, readBody } = require('../util.js');
const { ASK_CLIENT_CODES } = require('../middleware.js');
const { makeChatCfg } = require('../context.js');
const naposService = require('../../napos-service.js');
const nlQuery = require('../../nl-query.js');
const reportHtml = require('../../report-html.js');

function register(app, ctx) {
  // 不限方法（保持拆分前行为：该路由未做方法检查）
  app.any('/api/reports/status', async ({ res }) => {
    const napos = await naposService.naposStatus();
    sendJson(res, 200, { napos, entities: naposService.store.listEntities() });
  });

  // ---------- 智能问数（NL2Query，对话模型驱动） ----------

  app.post('/api/reports/ask', async ({ req, res }) => {
    const body = await readBody(req);
    const entity = body.entity || (naposService.store.listEntities()[0] || {}).key;
    if (!entity) { const e = new Error('暂无数据主体，请先完成一次同步'); e.code = 'ASK_NO_ENTITY'; throw e; }
    try {
      const result = await nlQuery.ask({ q: body.q, entity, cfg: makeChatCfg(ctx), svc: naposService, history: Array.isArray(body.history) ? body.history : undefined });
      sendJson(res, 200, result);
    } catch (e) {
      // 参数类错误码 → 400（错误边界统一处理），其余（模型/网络失败）保持 502
      if (!ASK_CLIENT_CODES.has(e.code)) e.status = 502;
      throw e;
    }
  });

  app.get('/api/reports/report-html', async ({ res, query }) => {
    const entity = query.entity || (naposService.store.listEntities()[0] || {}).key;
    if (!entity) {
      res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
      return res.end('<meta charset="utf-8"><body style="font-family:sans-serif;padding:40px">暂无数据主体，请先在「数据报表」完成一次同步。</body>');
    }
    const range = nlQuery.lakeDateRange(entity, naposService);
    const from = /^\d{8}$/.test(query.from || '') ? query.from : range.from;
    const to = /^\d{8}$/.test(query.to || '') ? query.to : range.to;
    const html = reportHtml.buildReportHtml({ entity, from, to });
    res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
    return res.end(html);
  });

  app.get('/api/reports/entities', async ({ res }) => {
    sendJson(res, 200, { entities: naposService.store.listEntities() });
  });

  // 同步历史（数据采集页「同步历史」面板）
  app.get('/api/reports/syncs', async ({ res, query }) => {
    const entity = query.entity || (naposService.store.listEntities()[0] || {}).key;
    if (!entity) { sendJson(res, 200, { runs: [] }); return; }
    sendJson(res, 200, { entity, runs: naposService.store.loadSyncLogs(entity) });
  });

  // 数据中台：本地湖全景（主体覆盖、行数分布、最近同步/推送），供中台页渲染
  app.get('/api/reports/lake', async ({ res }) => {
    const store = naposService.store;
    const entities = store.listEntities().map((e) => {
      const rows = store.loadRows(e.key);
      const byScope = { company: 0, chain: 0, shop: 0, summary: 0 };
      let from = '';
      let to = '';
      for (const r of rows) {
        if (byScope[r.scope] != null) byScope[r.scope] += 1;
        if (r.date && (!from || r.date < from)) from = r.date;
        if (r.date && r.date > to) to = r.date;
      }
      const lastSync = (store.loadSyncLogs(e.key)[0] || null);
      return {
        key: e.key, name: e.name, shopCount: e.shopCount || 0, chainCount: e.chainCount || 0,
        rows: rows.length, byScope, coverage: rows.length ? { from, to } : null,
        lastSync: lastSync ? { at: lastSync.at || null, from: lastSync.from || null, to: lastSync.to || null, ok: !lastSync.cancelled && !lastSync.failed } : null,
        lastPush: ctx.aitable ? ctx.aitable.lastPushInfo(e.key) : null,
      };
    });
    const totalRows = entities.reduce((s, e) => s + e.rows, 0);
    const coverage = entities.filter((e) => e.coverage).map((e) => e.coverage);
    sendJson(res, 200, {
      lakeDir: store.LAKE_DIR,
      entities, totalRows,
      coverage: coverage.length ? { from: coverage.map((c) => c.from).sort()[0], to: coverage.map((c) => c.to).sort().pop() } : null,
      aitable: {
        enabled: !!(ctx.config.aitable && ctx.config.aitable.enabled),
        operatorConfigured: !!(ctx.config.aitable && ctx.config.aitable.operatorId),
      },
    });
  });

  app.get('/api/reports/tree', async ({ res, query }) => {
    try {
      const tree = await naposService.fetchTree({ refresh: query.refresh === '1' });
      sendJson(res, 200, {
        merchant: tree.merchant, chains: tree.chains,
        shops: tree.shops.map((s) => ({ shopId: String(s.shopId), shopName: s.shopName, chainId: s.chainId ? String(s.chainId) : '', chainName: s.chainName || '', busyLevel: s.busyLevel || null })),
        entity: tree.entity,
      });
    } catch (e) {
      // 取数通道不可达属于上游失败，保持 502
      e.status = 502;
      throw e;
    }
  });

  app.get('/api/reports/columns', async ({ res }) => {
    sendJson(res, 200, { columns: naposService.REPORT_COLUMNS });
  });

  app.post('/api/reports/sync', async ({ req, res }) => {
    const body = await readBody(req);
    const entityPromise = naposService.runSync({
      from: body.from, to: body.to,
      scope: body.scope || 'all',
      chainId: body.chainId || '',
      shopIds: Array.isArray(body.shopIds) ? body.shopIds : undefined,
    }).catch((e) => {
      // 同步失败也要让自动推送保持静默，但保留日志
      ctx.logs.pushSystemLog(`同步结束（失败）：${e.message || e}`, 'warn');
      return null;
    });
    // 同步完成后：若启用钉钉 AI 表格，自动把增量推上云端（失败不影响本地同步结果）
    entityPromise.then(async (snap) => {
      if (!snap || !snap.entity || !(ctx.config.aitable && ctx.config.aitable.enabled)) return;
      try {
        const r = await ctx.aitable.pushLake(snap.entity.key);
        ctx.logs.pushSystemLog(`AI 表格推送完成：新增 ${r.created} 行、更新 ${r.updated} 行`, 'success');
      } catch (e) {
        ctx.logs.pushSystemLog(`AI 表格推送失败：${e.message || e}`, 'error');
      }
    });
    return sendJson(res, 200, { ok: true, ...naposService.syncSnapshot() });
  });

  // ---------- 钉钉 AI 表格（在线主档案/共享层） ----------

  app.post('/api/reports/aitable/test', async ({ res }) => {
    const r = await ctx.aitable.testConnection();
    sendJson(res, 200, r);
  });

  app.post('/api/reports/aitable/push', async ({ req, res }) => {
    const body = await readBody(req);
    const entity = body.entity || (naposService.store.listEntities()[0] || {}).key;
    if (!entity) { const e = new Error('暂无数据主体，请先完成一次同步'); e.code = 'AITABLE_NO_ENTITY'; e.status = 400; throw e; }
    const r = await ctx.aitable.pushLake(entity, { force: !!body.force });
    ctx.logs.pushSystemLog(`AI 表格推送完成：新增 ${r.created} 行、更新 ${r.updated} 行`, 'success');
    sendJson(res, 200, r);
  });

  app.post('/api/reports/aitable/pull', async ({ req, res }) => {
    const body = await readBody(req);
    const r = await ctx.aitable.pullLake(body.entity);
    const accounts = (r.accounts || []).map((a) => `${a.account}（新增${a.added}/更新${a.updated}）`).join('、');
    ctx.logs.pushSystemLog(`AI 表格拉取完成：${r.pulled} 行 ${accounts}`, 'success');
    sendJson(res, 200, r);
  });

  app.get('/api/reports/aitable/status', async ({ res, query }) => {
    const entity = query.entity || (naposService.store.listEntities()[0] || {}).key || '';
    sendJson(res, 200, {
      enabled: !!(ctx.config.aitable && ctx.config.aitable.enabled),
      configured: !!(ctx.config.aitable && ctx.config.aitable.baseId && ctx.config.aitable.sheetName && ctx.config.aitable.appKey),
      lastPush: entity ? ctx.aitable.lastPushInfo(entity) : null,
    });
  });

  app.get('/api/reports/sync/status', async ({ res }) => {
    sendJson(res, 200, naposService.syncSnapshot());
  });

  app.post('/api/reports/sync/cancel', async ({ res }) => {
    sendJson(res, 200, naposService.requestSyncCancel());
  });

  app.get('/api/reports/daily', async ({ res, query }) => {
    sendJson(res, 200, naposService.queryReport({
      entity: query.entity, from: query.from, to: query.to,
      shopId: query.shopId,
      shops: query.shops ? query.shops.split(',').filter(Boolean) : undefined,
      scope: query.scope || 'shop', q: query.q,
    }));
  });

  app.get('/api/reports/aggregate', async ({ res, query }) => {
    sendJson(res, 200, naposService.aggregateReport({
      entity: query.entity, from: query.from, to: query.to,
      group: query.group || 'shop',
      shops: query.shops ? query.shops.split(',').filter(Boolean) : undefined,
    }));
  });

  app.get('/api/reports/export', async ({ res, query }) => {
    const group = query.group === 'date' ? 'date' : (query.group === 'shop' ? 'shop' : null);
    let rows;
    if (group) {
      const agg = naposService.aggregateReport({ entity: query.entity, from: query.from, to: query.to, group });
      rows = agg.rows;
    } else {
      const daily = naposService.queryReport({
        entity: query.entity, from: query.from, to: query.to,
        shopId: query.shopId,
        shops: query.shops ? query.shops.split(',').filter(Boolean) : undefined,
        scope: query.scope || 'shop', q: query.q,
      });
      rows = daily.rows;
    }
    const columns = naposService.REPORT_COLUMNS;
    const csv = naposService.rowsToCsv(columns, rows);
    res.writeHead(200, {
      'Content-Type': 'text/csv; charset=utf-8',
      'Content-Disposition': `attachment; filename="report-${query.entity || 'all'}-${query.from || ''}-${query.to || ''}.csv"`,
    });
    return res.end(csv);
  });

  app.get('/api/reports/syncs', async ({ res, query }) => {
    const key = naposService.store.sanitizeKey(query.entity);
    sendJson(res, 200, { runs: naposService.store.loadSyncLogs(key) });
  });

  app.del('/api/reports/data', async ({ res, query }) => {
    if (!query.entity) return sendJson(res, 400, { error: '缺少 entity 参数' });
    naposService.store.deleteEntityData(query.entity);
    ctx.logs.pushSystemLog(`数据报表：已清除主体 ${query.entity} 的本地数据`, 'warn');
    sendJson(res, 200, { ok: true });
  });
}

module.exports = { register };