lami-shequn/backend/scripts/audit-risk-kit/audit-coverage.ts

/**
 * 风险预警覆盖审计脚本
 *
 * 用法: cp .env.example .env → 编辑 .env → npx tsx audit-coverage.ts
 * 输出: audit-risk-YYYY-MM-DD.html（浏览器打开）
 *
 * 分析内容:
 *   1. 查询指定时间段内所有文本消息
 *   2. 查询所有 RiskEvent（同期已有预警）
 *   3. 查询所有 RiskKeyword（启用中的关键词）
 *   4. 关键词匹配命中但无预警的消息 → 漏报
 *   5. AI 评审漏报消息的风险等级
 *   6. 可视化 HTML 报告
 */

import 'dotenv/config';
import Parse from './parse-client.js';
import * as fs from 'fs';
import * as path from 'path';
import { fileURLToPath } from 'url';

const __dirname = path.dirname(fileURLToPath(import.meta.url));

/* ======================== 配置 ======================== */

const GUID = process.env.QIWE_GUID || '';

const AI_KEY = process.env.DEEPSEEK_API_KEY || '';
const AI_URL = process.env.DEEPSEEK_API_URL || 'https://api.deepseek.com/v1/chat/completions';
const AI_MODEL = process.env.DEEPSEEK_MODEL || 'deepseek-chat';
const AI_ENABLED = AI_KEY && AI_KEY !== 'sk-xxx';

// 默认审计最近 7 天，可通过环境变量覆盖
const DATE_RANGE = {
  start: new Date(process.env.AUDIT_START || (() => { const d = new Date(); d.setDate(d.getDate() - 8); d.setHours(0, 0, 0, 0); return d.toISOString(); })()),
  end: new Date(process.env.AUDIT_END || (() => { const d = new Date(); d.setHours(23, 59, 59, 999); return d.toISOString(); })()),
};

/* ======================== 类型 ======================== */

interface KeywordInfo {
  word: string;
  category: string;
  severity: 'high' | 'medium' | 'low';
}

interface MsgInfo {
  id: string;
  roomId: string;
  senderName: string;
  content: string;
  timestamp: Date;
}

interface RiskEventInfo {
  id: string;
  groupId: string;
  keywords: string[];
  severity: string;
  title: string;
  description: string;
  createdAt: Date;
}

interface MissedAlert {
  roomId: string;
  roomName: string;
  messages: MsgInfo[];
  matchedKeywords: string[];
  maxSeverity: string;
  reason: string;
}

/* ======================== 数据查询 ======================== */

async function fetchAllData() {
  console.log('[审计] 查询数据...\n');

  const [allMessages, riskEvents, keywords, allGroups] = await Promise.all([
    (async () => {
      const q = new Parse.Query('Message');
      q.greaterThanOrEqualTo('timestamp', DATE_RANGE.start);
      q.lessThanOrEqualTo('timestamp', DATE_RANGE.end);
      q.containedIn('msgType', [0, 2, 13, 29]);
      q.notEqualTo('content', '');
      q.select(['roomId', 'senderName', 'content', 'timestamp', 'msgType']);
      q.limit(200000);
      q.ascending('timestamp');
      const rows = await q.find({ useMasterKey: true }) as any[];
      return rows.map(r => ({
        id: r.id,
        roomId: (r.get('roomId') as string) || '',
        senderName: (r.get('senderName') as string) || '',
        content: (r.get('content') as string) || '',
        timestamp: r.get('timestamp') as Date,
      })) as MsgInfo[];
    })(),

    (async () => {
      const q = new Parse.Query('RiskEvent');
      q.greaterThanOrEqualTo('createdAt', DATE_RANGE.start);
      q.lessThanOrEqualTo('createdAt', DATE_RANGE.end);
      q.select(['groupId', 'keywords', 'severity', 'title', 'description', 'createdAt']);
      q.limit(5000);
      const rows = await q.find({ useMasterKey: true }) as any[];
      return rows.map(r => ({
        id: r.id,
        groupId: (r.get('groupId') as string) || '',
        keywords: (r.get('keywords') as string[]) || [],
        severity: (r.get('severity') as string) || '',
        title: (r.get('title') as string) || '',
        description: (r.get('description') as string) || '',
        createdAt: r.get('createdAt') as Date,
      })) as RiskEventInfo[];
    })(),

    (async () => {
      const q = new Parse.Query('RiskKeyword');
      q.equalTo('enabled', true);
      q.select(['word', 'category', 'severity']);
      q.limit(5000);
      const rows = await q.find({ useMasterKey: true }) as any[];
      return rows.map((r: any) => ({
        word: r.get('word') as string,
        category: r.get('category') as string,
        severity: r.get('severity') as string,
      })) as KeywordInfo[];
    })(),

    (async () => {
      const q = new Parse.Query('GroupChat');
      q.select(['roomId', 'roomName']);
      q.limit(5000);
      const rows = await q.find({ useMasterKey: true }) as any[];
      const map = new Map<string, string>();
      for (const r of rows) {
        map.set((r.get('roomId') as string) || '', (r.get('roomName') as string) || '未知群');
      }
      return map;
    })(),
  ]);

  console.log(`  Message: ${allMessages.length} | RiskEvent: ${riskEvents.length} | RiskKeyword: ${keywords.length} | GroupChat: ${allGroups.size}`);
  return { allMessages, riskEvents, keywords, allGroups };
}

/* ======================== 覆盖分析 ======================== */

function analyzeCoverage(
  allMessages: MsgInfo[],
  riskEvents: RiskEventInfo[],
  keywords: KeywordInfo[],
  groupMap: Map<string, string>,
) {
  const msgsByRoom = new Map<string, MsgInfo[]>();
  for (const m of allMessages) {
    if (!m.roomId) continue;
    const arr = msgsByRoom.get(m.roomId);
    if (arr) arr.push(m);
    else msgsByRoom.set(m.roomId, [m]);
  }

  const alertedRoomIds = new Set(riskEvents.map(e => e.groupId));
  const alertedKeywords = new Set(riskEvents.flatMap(e => e.keywords));

  const missedAlerts: MissedAlert[] = [];

  for (const [roomId, msgs] of msgsByRoom) {
    const hitMap = new Map<string, { msgs: MsgInfo[]; kw: KeywordInfo }>();
    for (const msg of msgs) {
      for (const kw of keywords) {
        if (msg.content.includes(kw.word)) {
          if (hitMap.has(kw.word)) {
            hitMap.get(kw.word)!.msgs.push(msg);
          } else {
            hitMap.set(kw.word, { msgs: [msg], kw });
          }
        }
      }
    }
    if (hitMap.size === 0) continue;

    const hitWords = [...hitMap.keys()];
    const missedWords = hitWords.filter(w => !alertedKeywords.has(w));
    const alertedWords = hitWords.filter(w => alertedKeywords.has(w));

    if (missedWords.length > 0) {
      const allMissedMsgs: MsgInfo[] = [];
      for (const w of missedWords) {
        const entry = hitMap.get(w);
        if (entry) allMissedMsgs.push(...entry.msgs);
      }
      const uniqueMsgs = [...new Map(allMissedMsgs.map(m => [m.id, m])).values()]
        .sort((a, b) => a.timestamp.getTime() - b.timestamp.getTime());

      const severities = missedWords.map(w => hitMap.get(w)?.kw.severity || 'low');
      const maxSeverity = severities.includes('high') ? 'high'
        : severities.includes('medium') ? 'medium' : 'low';

      const hasAlert = alertedRoomIds.has(roomId);
      let reason: string;
      if (!hasAlert && alertedWords.length === 0) {
        reason = '该群无任何预警记录，所有关键词命中均未触发预警';
      } else if (!hasAlert) {
        reason = `该群无预警记录；命中关键词: [${hitWords.join(', ')}]，其中 [${alertedWords.join(', ')}] 在其他群触发过预警`;
      } else {
        reason = `该群有预警但未覆盖以下关键词: [${missedWords.join(', ')}]`;
      }

      missedAlerts.push({
        roomId,
        roomName: groupMap.get(roomId) || `未知群(${roomId})`,
        messages: uniqueMsgs.slice(0, 30),
        matchedKeywords: missedWords,
        maxSeverity,
        reason,
      });
    }
  }

  const sevOrder = { high: 0, medium: 1, low: 2 };
  missedAlerts.sort((a, b) => sevOrder[a.maxSeverity as keyof typeof sevOrder] - sevOrder[b.maxSeverity as keyof typeof sevOrder]);

  const trulyMissedKeywords = keywords.filter(kw => !alertedKeywords.has(kw.word));

  return {
    missedAlerts,
    trulyMissedKeywords,
    stats: {
      totalMessages: allMessages.length,
      totalRiskEvents: riskEvents.length,
      totalKeywords: keywords.length,
      triggeredKeywords: alertedKeywords.size,
      untriggeredKeywords: keywords.length - alertedKeywords.size,
      coverageRate: keywords.length > 0 ? ((alertedKeywords.size / keywords.length) * 100).toFixed(1) : '0',
      missedGroups: missedAlerts.length,
      highCount: missedAlerts.filter(a => a.maxSeverity === 'high').length,
      mediumCount: missedAlerts.filter(a => a.maxSeverity === 'medium').length,
      lowCount: missedAlerts.filter(a => a.maxSeverity === 'low').length,
      trulyMissedCount: trulyMissedKeywords.length,
    },
  };
}

/* ======================== AI 评审 ======================== */

async function aiReviewMissedAlert(alert: MissedAlert): Promise<string> {
  if (!AI_ENABLED) return 'AI 未启用';

  const samples = alert.messages.slice(0, 15).map(m => {
    const t = m.timestamp;
    const time = t ? `${String(t.getHours()).padStart(2, '0')}:${String(t.getMinutes()).padStart(2, '0')}` : '';
    return `[${time}] ${m.senderName || '未知'}: ${m.content}`;
  }).join('\n');

  const prompt = `你是拉迷家居（全屋定制）的风险审核员。以下群聊消息命中了风险关键词 [${alert.matchedKeywords.join(', ')}]，但系统未触发预警。

请判断：1.这些消息是否有真实风险？2.风险等级？3.简要理由（≤80字）

群: ${alert.roomName}
命中词: ${alert.matchedKeywords.join(', ')}
消息样本:
${samples}

回复 JSON: {"hasRisk":true/false,"severity":"high"/"medium"/"low"/"none","reason":"≤80字"}`;

  try {
    const res = await fetch(AI_URL, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json', Authorization: `Bearer ${AI_KEY}` },
      body: JSON.stringify({
        model: AI_MODEL,
        messages: [
          { role: 'system', content: '你是全屋定制行业风险审核员。只回复 JSON，不含 markdown。' },
          { role: 'user', content: prompt },
        ],
        temperature: 0.2,
        max_tokens: 256,
      }),
    });
    if (!res.ok) return `AI 调用失败: ${res.status}`;
    const json = await res.json() as any;
    const content = json?.choices?.[0]?.message?.content || '';
    const match = content.match(/\{[\s\S]*\}/);
    if (match) {
      const p = JSON.parse(match[0]);
      const label = p.hasRisk ? `⚠ 有风险(${p.severity})` : '✅ 无风险';
      return `${label} | ${p.reason || ''}`;
    }
    return `AI 响应异常: ${content.slice(0, 100)}`;
  } catch (err: any) {
    return `AI 错误: ${err.message}`;
  }
}

/* ======================== HTML 报告生成 ======================== */

function escapeHtml(s: string): string {
  return s.replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;').replace(/"/g, '&quot;');
}

function sevBadge(s: string): string {
  const m: Record<string, string> = { high: '高危', medium: '中危', low: '低危' };
  return `<span class="badge badge-${s}">${m[s] || s}</span>`;
}

function sevIcon(s: string): string {
  return s === 'high' ? '🔴' : s === 'medium' ? '🟡' : '🟢';
}

function categoryCn(c: string): string {
  const m: Record<string, string> = {
    complaint: '投诉', quality: '质量', sensitive: '敏感', legal: '法律',
    competitor: '竞品', price: '价格', negative: '负面', installation: '安装',
  };
  return m[c] || c;
}

function generateHTML(
  stats: ReturnType<typeof analyzeCoverage>['stats'],
  missedAlerts: MissedAlert[],
  aiReviews: string[],
  riskEvents: RiskEventInfo[],
  trulyMissedKeywords: KeywordInfo[],
  queryMs: number,
  totalMs: number,
): string {
  const genTime = new Date().toLocaleString('zh-CN');
  const dateLabel = `${DATE_RANGE.start.toLocaleDateString('zh-CN')} ~ ${DATE_RANGE.end.toLocaleDateString('zh-CN')}`;

  // 概览卡片
  const cards = `
    <div class="card card-blue"><div class="card-num">${stats.totalMessages.toLocaleString()}</div><div class="card-label">文本消息总量</div></div>
    <div class="card card-purple"><div class="card-num">${stats.totalRiskEvents}</div><div class="card-label">已有风险事件</div></div>
    <div class="card card-teal"><div class="card-num">${stats.totalKeywords}</div><div class="card-label">启用关键词</div></div>
    <div class="card card-orange"><div class="card-num">${stats.coverageRate}%</div><div class="card-label">关键词覆盖率</div></div>
    <div class="card card-red"><div class="card-num">${stats.missedGroups}</div><div class="card-label">漏报群数量</div></div>
    <div class="card card-green"><div class="card-num">${stats.trulyMissedCount}</div><div class="card-label">未覆盖关键词</div></div>
  `;

  // 已触发预警
  let alertSection = '';
  if (riskEvents.length > 0) {
    const rows = riskEvents.map(e => `
      <tr>
        <td><span class="badge badge-${e.severity}">${e.severity}</span></td>
        <td>${escapeHtml(e.title)}</td>
        <td>${(e.keywords || []).map(k => `<code>${escapeHtml(k)}</code>`).join(' ')}</td>
        <td>${escapeHtml(e.description?.slice(0, 60) || '')}</td>
        <td class="time-cell">${e.createdAt ? new Date(e.createdAt).toLocaleString('zh-CN') : ''}</td>
      </tr>`).join('');
    alertSection = `
      <div class="section"><h2>🛡️ 已触发预警事件 <span class="sub">(${riskEvents.length} 条)</span></h2>
        <div class="table-wrap"><table>
          <thead><tr><th>严重度</th><th>标题</th><th>关键词</th><th>描述</th><th>时间</th></tr></thead>
          <tbody>${rows}</tbody>
        </table></div></div>`;
  } else {
    alertSection = `<div class="section"><h2>🛡️ 已触发预警事件</h2><div class="empty">该期间无风险事件</div></div>`;
  }

  // 漏报详情
  let missedSection = '';
  if (missedAlerts.length === 0) {
    missedSection = `<div class="section"><h2>🔍 漏报检查</h2><div class="empty success">✅ 未发现漏报</div></div>`;
  } else {
    const realRisky = aiReviews.filter(r => r.includes('有风险')).length;
    const safeCount = aiReviews.filter(r => r.includes('无风险')).length;

    let cardsHtml = '';
    for (let i = 0; i < missedAlerts.length; i++) {
      const a = missedAlerts[i];
      const review = aiReviews[i] || '';
      const isRisky = review.includes('有风险');
      const border = a.maxSeverity === 'high' ? '#e74c3c' : a.maxSeverity === 'medium' ? '#f39c12' : '#3498db';
      const bg = a.maxSeverity === 'high' ? '#fff5f5' : a.maxSeverity === 'medium' ? '#fffdf0' : '#f8faff';

      const sampleRows = a.messages.slice(0, 5).map(m => {
        const t = m.timestamp;
        const time = t ? `${t.getMonth() + 1}/${t.getDate()} ${String(t.getHours()).padStart(2, '0')}:${String(t.getMinutes()).padStart(2, '0')}` : '';
        return `<tr><td class="time-cell">${time}</td><td>${escapeHtml(m.senderName || '未知')}</td><td class="msg-cell">${escapeHtml(m.content.length > 120 ? m.content.slice(0, 120) + '...' : m.content)}</td></tr>`;
      }).join('');

      const kwTags = a.matchedKeywords.map(k => `<span class="kw-tag">${sevIcon(a.maxSeverity)} ${escapeHtml(k)}</span>`).join('');

      cardsHtml += `
      <div class="missed-card" style="border-left:4px solid ${border};background:${bg}">
        <div class="missed-header">
          <span class="missed-title">${i + 1}. ${escapeHtml(a.roomName)}</span>
          <span>${sevBadge(a.maxSeverity)}</span>
        </div>
        <div class="missed-body">
          <div class="missed-meta">
            <div class="meta-item"><span class="meta-label">命中关键词</span>${kwTags}</div>
            <div class="meta-item"><span class="meta-label">匹配消息</span>${a.messages.length} 条</div>
            <div class="meta-item"><span class="meta-label">原因</span>${escapeHtml(a.reason)}</div>
          </div>
          ${review ? `<div class="ai-review ${isRisky ? 'ai-risky' : 'ai-safe'}">🤖 AI 评审：${escapeHtml(review)}</div>` : ''}
          <details class="msg-details">
            <summary>📋 消息样本（点击展开）</summary>
            <div class="table-wrap mini-table"><table>
              <thead><tr><th>时间</th><th>发送者</th><th>内容</th></tr></thead>
              <tbody>${sampleRows}</tbody>
            </table></div>
          </details>
        </div>
      </div>`;
    }

    missedSection = `
      <div class="section"><h2>🔍 漏报详情 <span class="sub">(${missedAlerts.length} 个群)</span></h2>
        <div class="missed-summary">
          <span class="chip chip-red">⚠️ AI 确认有风险: ${realRisky} 个</span>
          <span class="chip chip-green">✅ AI 确认无风险: ${safeCount} 个</span>
          <span class="chip chip-gray">未评审: ${missedAlerts.length - realRisky - safeCount} 个</span>
        </div>
        <div class="missed-list">${cardsHtml}</div>
      </div>`;
  }

  // 未覆盖关键词云
  let kwSection = '';
  if (trulyMissedKeywords.length > 0) {
    const sevOrder = { high: 0, medium: 1, low: 2 };
    const sorted = [...trulyMissedKeywords].sort((a, b) => sevOrder[a.severity] - sevOrder[b.severity]);
    const tags = sorted.map(k => `<span class="kw-chip kw-${k.severity}">${k.word}<span class="kw-cat">${categoryCn(k.category)}</span></span>`).join('\n');
    const hi = sorted.filter(k => k.severity === 'high').length;
    const md = sorted.filter(k => k.severity === 'medium').length;
    const lo = sorted.filter(k => k.severity === 'low').length;

    kwSection = `
      <div class="section"><h2>📚 从未触发预警的关键词 <span class="sub">(${trulyMissedKeywords.length} 个)</span></h2>
        <div class="kw-stats-bar">
          <div class="kw-stat kw-stat-high"><span>${hi}</span> 高危</div>
          <div class="kw-stat kw-stat-med"><span>${md}</span> 中危</div>
          <div class="kw-stat kw-stat-low"><span>${lo}</span> 低危</div>
        </div>
        <div class="kw-cloud">${tags}</div>
        <p class="hint">这些关键词在审计期间被消息命中，但从未在任何群触发过预警。</p>
      </div>`;
  }

  // 管理建议
  const suggestions = `
    <div class="section"><h2>💡 管理建议</h2>
      <div class="suggestion-grid">
        <div class="sugg-card sugg-high">
          <div class="sugg-title">🔴 高优先级</div>
          <ul>
            <li>将「定金/订金/优惠」等促销词从预警列表移除或降级为"仅记录"</li>
            <li>质量词（脱胶/开裂/变形/发霉/装错/色差）提高权重，命中即报</li>
          </ul>
        </div>
        <div class="sugg-card sugg-med">
          <div class="sugg-title">🟡 中优先级</div>
          <ul>
            <li>精简关键词库：181 → 60~80 个高质量词</li>
            <li>同一群短时间内命中多个低价关键词 → 聚合升级预警</li>
          </ul>
        </div>
        <div class="sugg-card sugg-low">
          <div class="sugg-title">🟢 持续改进</div>
          <ul>
            <li>每周运行本审计脚本，跟踪漏报趋势</li>
            <li>建立"关键词→预警→确认→反馈"闭环</li>
            <li>竞品类关键词命中频次统计，作为市场情报</li>
          </ul>
        </div>
      </div>
    </div>`;

  return `<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1.0">
<title>拉迷风险预警覆盖审计 — ${dateLabel}</title>
<style>
*,*::before,*::after{box-sizing:border-box;margin:0;padding:0}
body{font-family:-apple-system,BlinkMacSystemFont,"Segoe UI","PingFang SC","Microsoft YaHei","Helvetica Neue",sans-serif;background:#f0f2f5;color:#1a1a2e;line-height:1.6}
.hero{background:linear-gradient(135deg,#0f0c29 0%,#1a1a2e 40%,#16213e 100%);color:#fff;padding:40px 48px;position:relative;overflow:hidden}
.hero::after{content:'';position:absolute;top:-50%;right:-10%;width:400px;height:400px;background:radial-gradient(circle,rgba(231,76,60,.15),transparent 70%);border-radius:50%}
.hero h1{font-size:26px;font-weight:700;position:relative;z-index:1}
.hero .subtitle{font-size:14px;color:#8892b0;margin-top:6px;position:relative;z-index:1}
.hero .meta{font-size:12px;color:#5a6785;margin-top:4px;position:relative;z-index:1}
.container{max-width:1100px;margin:0 auto;padding:28px 24px}
.overview-grid{display:grid;grid-template-columns:repeat(auto-fit,minmax(150px,1fr));gap:16px;margin-bottom:36px}
.card{background:#fff;border-radius:12px;padding:24px 20px;text-align:center;box-shadow:0 2px 12px rgba(0,0,0,.06);transition:transform .15s}
.card:hover{transform:translateY(-2px)}
.card-num{font-size:36px;font-weight:800;line-height:1.2}
.card-label{font-size:13px;color:#7f8c8d;margin-top:6px}
.card-blue .card-num{color:#2980b9} .card-purple .card-num{color:#8e44ad}
.card-teal .card-num{color:#16a085} .card-orange .card-num{color:#e67e22}
.card-red .card-num{color:#e74c3c} .card-green .card-num{color:#27ae60}
.section{margin-bottom:36px}
.section h2{font-size:18px;font-weight:700;color:#1a1a2e;margin-bottom:16px;padding-bottom:10px;border-bottom:2px solid #e8ecf4}
.sub{font-size:13px;color:#95a5a6;font-weight:400}
.empty{padding:40px;text-align:center;color:#95a5a6;background:#fff;border-radius:10px}
.empty.success{color:#27ae60;background:#eafaf1}
.hint{font-size:13px;color:#95a5a6;margin-top:12px;line-height:1.6}
.badge{font-size:11px;font-weight:700;padding:3px 10px;border-radius:12px;color:#fff;white-space:nowrap}
.badge-high{background:#e74c3c} .badge-medium{background:#f39c12} .badge-low{background:#3498db}
.table-wrap{overflow-x:auto;background:#fff;border-radius:10px;box-shadow:0 2px 8px rgba(0,0,0,.04)}
table{width:100%;border-collapse:collapse;font-size:13px}
thead th{background:#f8f9fb;padding:12px 14px;text-align:left;font-weight:600;color:#555;font-size:12px;text-transform:uppercase;letter-spacing:.5px;border-bottom:2px solid #e8ecf4}
tbody td{padding:10px 14px;border-bottom:1px solid #f0f2f5;vertical-align:top}
tbody tr:hover{background:#f8f9fb}
.time-cell{white-space:nowrap;color:#95a5a6;font-size:12px}
.msg-cell{max-width:400px;word-break:break-all}
code{background:#f0f2f5;padding:1px 6px;border-radius:3px;font-size:12px;color:#e74c3c}
.missed-summary{display:flex;gap:12px;flex-wrap:wrap;margin-bottom:18px}
.chip{font-size:13px;padding:6px 14px;border-radius:20px;font-weight:600}
.chip-red{background:#fde8e8;color:#c0392b} .chip-green{background:#e8f8f5;color:#1e8449} .chip-gray{background:#f0f2f5;color:#7f8c8d}
.missed-list{display:flex;flex-direction:column;gap:14px}
.missed-card{border-radius:10px;overflow:hidden;box-shadow:0 2px 8px rgba(0,0,0,.04)}
.missed-header{display:flex;justify-content:space-between;align-items:center;padding:14px 18px;background:rgba(0,0,0,.02);border-bottom:1px solid rgba(0,0,0,.05)}
.missed-title{font-size:15px;font-weight:700}
.missed-body{padding:16px 18px}
.missed-meta{display:flex;flex-direction:column;gap:8px;margin-bottom:10px}
.meta-item{font-size:13px} .meta-label{font-weight:600;color:#555;margin-right:8px}
.kw-tag{display:inline-block;background:#f0f2f5;padding:2px 10px;border-radius:12px;font-size:12px;margin-right:4px;margin-bottom:2px}
.ai-review{font-size:13px;padding:10px 14px;border-radius:8px;margin:10px 0}
.ai-risky{background:#fde8e8;border:1px solid #f5c6cb;color:#721c24}
.ai-safe{background:#e8f8f5;border:1px solid #b7e4cf;color:#155724}
.msg-details{margin-top:8px} .msg-details summary{font-size:13px;color:#3498db;cursor:pointer;font-weight:600}
.kw-stats-bar{display:flex;gap:12px;margin-bottom:14px}
.kw-stat{padding:6px 16px;border-radius:8px;font-size:13px;font-weight:600}
.kw-stat span{font-size:20px;font-weight:800}
.kw-stat-high{background:#fde8e8;color:#c0392b} .kw-stat-med{background:#fef5e7;color:#d68910} .kw-stat-low{background:#eaf2f8;color:#2980b9}
.kw-cloud{display:flex;flex-wrap:wrap;gap:8px;background:#fff;padding:18px;border-radius:10px;box-shadow:0 2px 8px rgba(0,0,0,.04)}
.kw-chip{display:inline-flex;align-items:center;gap:6px;padding:5px 12px;border-radius:16px;font-size:13px;font-weight:600}
.kw-high{background:#fde8e8;color:#c0392b} .kw-medium{background:#fef5e7;color:#d68910} .kw-low{background:#eaf2f8;color:#2980b9}
.kw-cat{font-size:10px;opacity:.7;font-weight:400}
.suggestion-grid{display:grid;grid-template-columns:repeat(auto-fit,minmax(300px,1fr));gap:16px}
.sugg-card{padding:20px;border-radius:10px;box-shadow:0 2px 8px rgba(0,0,0,.04)}
.sugg-title{font-size:15px;font-weight:700;margin-bottom:10px}
.sugg-card ul{padding-left:18px} .sugg-card li{font-size:13px;margin-bottom:8px;line-height:1.6}
.sugg-high{background:#fff5f5;border:1px solid #fecaca}
.sugg-med{background:#fffdf0;border:1px solid #fde68a}
.sugg-low{background:#f5f9ff;border:1px solid #bfdbfe}
.footer{text-align:center;padding:20px;color:#95a5a6;font-size:12px}
@media(max-width:768px){.hero{padding:24px}.container{padding:16px}.overview-grid{grid-template-columns:repeat(3,1fr);gap:10px}.card{padding:16px 10px}.card-num{font-size:26px}.suggestion-grid{grid-template-columns:1fr}}
@media print{body{background:#fff}.hero{background:#1a1a2e!important;-webkit-print-color-adjust:exact}.missed-card{break-inside:avoid;border:1px solid #ddd}}
</style>
</head>
<body>
<div class="hero">
  <h1>🛡️ 风险预警覆盖审计报告</h1>
  <div class="subtitle">审计期间：${dateLabel}（${Math.ceil((DATE_RANGE.end.getTime() - DATE_RANGE.start.getTime()) / 86400000)} 天）&nbsp;|&nbsp; 全屋定制 · 拉迷家居</div>
  <div class="meta">生成时间：${genTime} &nbsp;|&nbsp; 查询耗时：${queryMs}ms &nbsp;|&nbsp; 总耗时：${totalMs}ms &nbsp;|&nbsp; AI：${AI_ENABLED ? `DeepSeek(${AI_MODEL})` : '未启用'}</div>
</div>
<div class="container">
  <div class="overview-grid">${cards}</div>
  ${alertSection}
  ${missedSection}
  ${kwSection}
  ${suggestions}
  <div class="footer">拉迷家居 · 风险预警覆盖审计 · 自动生成</div>
</div>
</body>
</html>`;
}

/* ======================== 主流程 ======================== */

async function main(): Promise<void> {
  const t0 = Date.now();
  console.log('═══════════════════════════════════════');
  console.log('  风险预警覆盖审计');
  console.log(`  时间: ${DATE_RANGE.start.toLocaleDateString('zh-CN')} ~ ${DATE_RANGE.end.toLocaleDateString('zh-CN')}`);
  console.log(`  AI: ${AI_ENABLED ? `DeepSeek (${AI_MODEL})` : '禁用'}`);
  console.log('═══════════════════════════════════════\n');

  // 1. 查询
  const t1 = Date.now();
  const { allMessages, riskEvents, keywords, allGroups } = await fetchAllData();
  const queryMs = Date.now() - t1;
  console.log(`  查询耗时: ${queryMs}ms\n`);

  // 2. 覆盖分析
  console.log('[审计] 关键词覆盖分析...');
  const { missedAlerts, trulyMissedKeywords, stats } = analyzeCoverage(allMessages, riskEvents, keywords, allGroups);
  console.log(`  漏报群: ${stats.missedGroups}，高危 ${stats.highCount} / 中危 ${stats.mediumCount} / 低危 ${stats.lowCount}`);
  console.log(`  完全未触发预警的关键词: ${stats.trulyMissedCount}\n`);

  // 3. AI 评审（限前 20 个高危/中危）
  console.log('[审计] AI 深度评审漏报...');
  const toReview = missedAlerts.filter(a => a.maxSeverity === 'high' || a.maxSeverity === 'medium').slice(0, 20);
  const aiReviews: string[] = [];
  for (let i = 0; i < toReview.length; i++) {
    const a = toReview[i];
    console.log(`  → AI 评审 ${i + 1}/${toReview.length}: ${a.roomName} (${a.maxSeverity})`);
    const review = await aiReviewMissedAlert(a);
    aiReviews.push(review);
    console.log(`  ← ${review}`);
  }

  const allAiReviews = missedAlerts.map(a => {
    const idx = toReview.indexOf(a);
    return idx >= 0 ? aiReviews[idx] : '（低危，未提交 AI 评审）';
  });

  // 4. HTML 报告
  const totalMs = Date.now() - t0;
  const html = generateHTML(stats, missedAlerts, allAiReviews, riskEvents, trulyMissedKeywords, queryMs, totalMs);

  const dateStr = DATE_RANGE.start.toISOString().slice(0, 10);
  const outputPath = path.resolve(__dirname, `audit-risk-${dateStr}.html`);
  fs.writeFileSync(outputPath, html, 'utf-8');

  console.log(`\n✅ 报告已生成: ${outputPath}`);
  console.log(`   文件大小: ${(Buffer.byteLength(html, 'utf-8') / 1024).toFixed(1)} KB | 总耗时: ${totalMs}ms\n`);

  // 控制台摘要
  console.log('═══════════════════════════════════════');
  console.log('  关键发现');
  console.log('═══════════════════════════════════════');
  console.log(`  关键词覆盖率: ${stats.coverageRate}% (${stats.triggeredKeywords}/${stats.totalKeywords})`);
  console.log(`  完全未覆盖关键词: ${stats.trulyMissedCount}`);
  console.log(`  漏报群: ${stats.missedGroups} (高危 ${stats.highCount} / 中危 ${stats.mediumCount} / 低危 ${stats.lowCount})`);
  if (stats.trulyMissedCount > 0) {
    console.log(`\n  未覆盖关键词 TOP 15:`);
    for (const kw of trulyMissedKeywords.slice(0, 15)) {
      console.log(`    - ${kw.word} (${kw.category}/${kw.severity})`);
    }
  }
  console.log('');
}

main().catch((err) => {
  console.error('[审计] 失败:', err);
  process.exit(1);
});