트렌드 리포트 1단계 구현 가이드 — 24시간 안에 첫 푸시

const SOURCES = [
  { name: 'GWI',         url: 'https://globalwellnessinstitute.org/feed/' },
  { name: 'GWS Trends',  url: 'https://www.globalwellnesssummit.com/feed/' },
  { name: 'Vogue Korea', url: 'https://www.vogue.co.kr/feed/' },
  { name: 'Elle Korea',  url: 'https://www.elle.co.kr/rss/all.xml' },
  { name: 'W Korea',     url: 'https://www.wkorea.com/feed/' },
  { name: 'Bazaar Korea',url: 'https://www.harpersbazaar.co.kr/feed/' },
  { name: 'Well+Good',   url: 'https://www.wellandgood.com/feed/' },
  { name: 'Goop',        url: 'https://goop.com/feed/' },
  { name: 'Longevity',   url: 'https://longevity.technology/feed/' },
  { name: '롱블랙',      url: 'https://www.longblack.co/feed' },
];

const P = PropertiesService.getScriptProperties();
const NOTION = { token: P.getProperty('NOTION_TOKEN'), db: P.getProperty('NOTION_DB_ID') };
const CLAUDE = { key: P.getProperty('ANTHROPIC_API_KEY'), model: 'claude-haiku-4-5-20251001' };
const TG = { token: P.getProperty('TELEGRAM_TOKEN'), chat: P.getProperty('TELEGRAM_CHAT_ID') };

function fetchAndClassify() {
  const seen = new Set(loadRecentUrls()); // 중복 방지
  const picked = [];

  for (const src of SOURCES) {
    try {
      const xml = UrlFetchApp.fetch(src.url, { muteHttpExceptions: true }).getContentText();
      const doc = XmlService.parse(xml);
      const items = doc.getRootElement().getDescendants()
        .map(e => e.asElement && e.asElement()).filter(Boolean)
        .filter(e => e.getName() === 'item' || e.getName() === 'entry');
      for (const it of items.slice(0, 5)) {
        const title = (it.getChildText('title') || '').trim();
        const link  = it.getChildText('link') || (it.getChild('link')?.getAttribute('href')?.getValue() || '');
        if (!title || !link || seen.has(link)) continue;
        picked.push({ title, url: link, source: src.name });
      }
    } catch (e) { Logger.log('fail ' + src.name + ' ' + e); }
  }

  // Claude로 분류 + 점수 + 요약 (배치)
  const classified = classifyBatch(picked);

  for (const r of classified) addToNotion(r);

  Logger.log('fetched ' + classified.length);
}

function classifyBatch(items) {
  if (!items.length) return [];
  const prompt = `다음 기사들을 SQNC(웰니스 큐레이션) 관점에서 분류해주세요.
카테고리: 리트릿 / F&B / 공간 / 문화·체험 / 기타
score는 SQNC 독자에게 얼마나 흥미로운지 1~10.

JSON 배열만 반환:
[{"title":"...", "category":"리트릿", "score":7, "summary":"한 줄"}]

기사들:
` + items.map((x, i) => `${i+1}. ${x.title}`).join('\n');

  const res = UrlFetchApp.fetch('https://api.anthropic.com/v1/messages', {
    method: 'post',
    contentType: 'application/json',
    headers: { 'x-api-key': CLAUDE.key, 'anthropic-version': '2023-06-01' },
    payload: JSON.stringify({
      model: CLAUDE.model,
      max_tokens: 2000,
      messages: [{ role: 'user', content: prompt }]
    }),
    muteHttpExceptions: true,
  });
  const json = JSON.parse(res.getContentText());
  const text = json.content?.[0]?.text || '[]';
  const arr  = JSON.parse(text.match(/\[[\s\S]*\]/)?.[0] || '[]');
  return items.map((it, i) => ({ ...it, ...(arr[i] || {}) }));
}

function addToNotion(r) {
  UrlFetchApp.fetch('https://api.notion.com/v1/pages', {
    method: 'post',
    contentType: 'application/json',
    headers: { 'Authorization': 'Bearer ' + NOTION.token, 'Notion-Version': '2022-06-28' },
    payload: JSON.stringify({
      parent: { database_id: NOTION.db },
      properties: {
        Title:    { title: [{ text: { content: r.title.slice(0, 200) } }] },
        URL:      { url: r.url },
        Source:   { select: { name: r.source } },
        Category: { select: { name: r.category || '기타' } },
        Score:    { number: r.score || 5 },
        Summary:  { rich_text: [{ text: { content: (r.summary || '').slice(0, 1900) } }] },
        Status:   { select: { name: 'candidate' } },
        FetchedAt:{ date: { start: new Date().toISOString() } },
      }
    }),
    muteHttpExceptions: true,
  });
}

function loadRecentUrls() {
  // 최근 7일 적재된 URL 가져와 중복 방지
  const res = UrlFetchApp.fetch(`https://api.notion.com/v1/databases/${NOTION.db}/query`, {
    method: 'post',
    contentType: 'application/json',
    headers: { 'Authorization': 'Bearer ' + NOTION.token, 'Notion-Version': '2022-06-28' },
    payload: JSON.stringify({ page_size: 100, sorts: [{ property: 'FetchedAt', direction: 'descending' }] }),
    muteHttpExceptions: true,
  });
  const j = JSON.parse(res.getContentText());
  return (j.results || []).map(p => p.properties?.URL?.url).filter(Boolean);
}

function pushDailyDigest() {
  const since = new Date(Date.now() - 24*3600*1000).toISOString();
  const res = UrlFetchApp.fetch(`https://api.notion.com/v1/databases/${NOTION.db}/query`, {
    method: 'post', contentType: 'application/json',
    headers: { 'Authorization': 'Bearer ' + NOTION.token, 'Notion-Version': '2022-06-28' },
    payload: JSON.stringify({
      filter: { and: [
        { property: 'Status',    select:   { equals: 'candidate' } },
        { property: 'FetchedAt', date:     { on_or_after: since } },
        { property: 'Score',     number:   { greater_than_or_equal_to: 6 } },
      ]},
      sorts: [{ property: 'Score', direction: 'descending' }],
      page_size: 7,
    }),
  });
  const rows = JSON.parse(res.getContentText()).results || [];
  if (!rows.length) return;

  const lines = rows.map((p, i) => {
    const t = p.properties?.Title?.title?.[0]?.plain_text || '';
    const u = p.properties?.URL?.url || '';
    const c = p.properties?.Category?.select?.name || '';
    return `${i+1}. [${c}] ${t}\n${u}`;
  });
  const text = `☀️ 오늘의 큐레이션 후보 (${rows.length})\n\n` + lines.join('\n\n');
  sendTelegram(text);
}

function sendTelegram(text) {
  UrlFetchApp.fetch(`https://api.telegram.org/bot${TG.token}/sendMessage`, {
    method: 'post',
    payload: { chat_id: TG.chat, text: text, disable_web_page_preview: 'true' },
    muteHttpExceptions: true,
  });
}

function generateMonthlyReport() { generateReport(30, '월간'); }
function generateQuarterlyReport() { generateReport(90, '분기'); }

function generateReport(days, label) {
  const since = new Date(Date.now() - days*24*3600*1000).toISOString();
  const res = UrlFetchApp.fetch(`https://api.notion.com/v1/databases/${NOTION.db}/query`, {
    method: 'post', contentType: 'application/json',
    headers: { 'Authorization': 'Bearer ' + NOTION.token, 'Notion-Version': '2022-06-28' },
    payload: JSON.stringify({
      filter: { and: [
        { property: 'Status', select: { equals: 'published' } },
        { property: 'FetchedAt', date: { on_or_after: since } },
      ]},
      page_size: 100,
    }),
  });
  const rows = JSON.parse(res.getContentText()).results || [];
  const bullets = rows.map(p => `- [${p.properties?.Category?.select?.name || ''}] ${p.properties?.Title?.title?.[0]?.plain_text || ''} — ${p.properties?.Summary?.rich_text?.[0]?.plain_text || ''}`).join('\n');

  const prompt = `SQNC(한국 웰니스 큐레이션) 관점에서 지난 ${label}의 핵심 흐름을 정리하고 다음 ${label}을 예측해주세요.

지난 기간 큐레이션 목록:
${bullets}

다음 형식으로:
## 핵심 흐름 5
1. ...

## 카테고리별 변화 (리트릿/F&B/공간/문화·체험)
- ...

## 다음 ${label} 예측 3
1. ...`;

  const r = UrlFetchApp.fetch('https://api.anthropic.com/v1/messages', {
    method: 'post', contentType: 'application/json',
    headers: { 'x-api-key': CLAUDE.key, 'anthropic-version': '2023-06-01' },
    payload: JSON.stringify({ model: 'claude-sonnet-4-6', max_tokens: 3000, messages: [{ role:'user', content: prompt }] }),
  });
  const text = JSON.parse(r.getContentText()).content?.[0]?.text || '(생성 실패)';
  sendTelegram(`📊 ${label} 리포트 초안\n\n` + text);
}