GASで商品レビューをAIで分析し
改善点を自動抽出する方法

// スクリプトプロパティにAPIキーを保存しておく（コードに直書きしない）
// 「プロジェクトの設定」→「スクリプト プロパティ」で CLAUDE_API_KEY を登録
function getApiKey() {
  const key = PropertiesService
    .getScriptProperties()
    .getProperty("CLAUDE_API_KEY");
  if (!key) {
    throw new Error("CLAUDE_API_KEY が未設定です。スクリプトプロパティに登録してください。");
  }
  return key;
}

// Claude API（Messages API）を呼び出す共通関数
// userText には分析用のプロンプト、systemText には役割・出力形式の指示を渡す
function callClaude(systemText, userText) {
  const url = "https://api.anthropic.com/v1/messages";
  const payload = {
    model: "claude-sonnet-4-5",
    max_tokens: 2000,
    system: systemText,
    messages: [{ role: "user", content: userText }],
  };

  const options = {
    method: "post",
    contentType: "application/json",
    headers: {
      "x-api-key": getApiKey(),
      "anthropic-version": "2023-06-01",
    },
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  };

  const res = UrlFetchApp.fetch(url, options);
  const code = res.getResponseCode();
  if (code !== 200) {
    throw new Error("Claude APIエラー: " + code + " / " + res.getContentText());
  }

  const body = JSON.parse(res.getContentText());
  // Messages APIは content 配列の最初のテキストブロックに本文が入る
  return body.content[0].text;
}

// レビューをまとめて渡し、改善点をJSON配列で受け取るプロンプトを組み立てる
const THEMES = ["品質", "配送・梱包", "価格", "サイズ・仕様", "接客・対応", "その他"];

function buildPrompt(reviews) {
  const list = reviews
    .map((r, i) => (i + 1) + ". " + String(r).replace(/\n/g, " "))
    .join("\n");

  return [
    "以下は当社商品のレビューです。各レビューから改善につながる不満点を抽出してください。",
    "",
    "# ルール",
    "- テーマは次から必ず1つ選ぶ: " + THEMES.join(" / "),
    "- レビュー本文に書かれていないことは推測しない",
    "- 好意的なだけで不満がないレビューは結果に含めない",
    "- 改善点は具体的な動詞で1文にまとめる（例: 梱包材を厚手に変更する）",
    "",
    "# 出力形式（JSON配列のみ。前後に説明文を付けない）",
    '[{"index":1,"theme":"配送・梱包","point":"改善点","quote":"根拠となった一節"}]',
    "",
    "# レビュー",
    list,
  ].join("\n");
}

// AIの返答からJSON部分だけを安全に取り出す
// 前後に説明文が混ざっても [ ... ] の範囲を切り出して解析する
function parseJsonArray(text) {
  const start = text.indexOf("[");
  const end = text.lastIndexOf("]");
  if (start === -1 || end === -1) {
    throw new Error("JSON配列が見つかりませんでした: " + text);
  }
  return JSON.parse(text.substring(start, end + 1));
}

// レビュー列を10件ずつ分析し、改善点シートに書き出す
function analyzeReviews() {
  const ss = SpreadsheetApp.getActive();
  const src = ss.getSheetByName("レビュー");     // A:レビュー本文, B:処理済みフラグ
  const out = ss.getSheetByName("改善点");        // 抽出結果の出力先
  const values = src.getDataRange().getValues();

  const system = "あなたはECサイトの品質改善担当です。指定されたJSON形式のみで回答します。";
  const BATCH = 10;
  const buffer = [];   // {rowNumber, text}
  const results = [];

  for (let i = 1; i < values.length; i++) {   // 1行目はヘッダー
    const text = values[i][0];
    const done = values[i][1];
    if (!text || done) continue;               // 空行・処理済みはスキップ

    buffer.push({ rowNumber: i + 1, text: text });

    if (buffer.length === BATCH || i === values.length - 1) {
      flushBatch(buffer, system, src, out, results);
      buffer.length = 0;
      Utilities.sleep(1000);                   // レート制限に配慮して間隔を空ける
    }
  }

  Logger.log(results.length + "件の改善点を抽出しました");
}

// 1バッチ分をAPIに送り、結果を書き込む（リトライ付き）
function flushBatch(buffer, system, src, out, results) {
  const reviews = buffer.map((b) => b.text);
  const prompt = buildPrompt(reviews);

  let items;
  for (let attempt = 1; attempt <= 3; attempt++) {
    try {
      items = parseJsonArray(callClaude(system, prompt));
      break;
    } catch (e) {
      if (attempt === 3) throw e;
      Utilities.sleep(attempt * 2000);         // 2s→4sと待って再試行
    }
  }

  items.forEach((item) => {
    const src2 = buffer[item.index - 1];       // index は1始まり
    const rowNo = src2 ? src2.rowNumber : "";
    out.appendRow([new Date(), rowNo, item.theme, item.point, item.quote]);
    results.push(item);
  });

  // 送った行を処理済みにする（B列に true）
  buffer.forEach((b) => src.getRange(b.rowNumber, 2).setValue(true));
}

// 改善点シートをテーマ別に集計し、多い順に並べる
function summarizeByTheme() {
  const out = SpreadsheetApp.getActive().getSheetByName("改善点");
  const rows = out.getDataRange().getValues().slice(1); // ヘッダー除外

  const counts = {};
  rows.forEach((row) => {
    const theme = row[2];                      // C列=テーマ
    if (!theme) return;
    counts[theme] = (counts[theme] || 0) + 1;
  });

  const ranking = Object.keys(counts)
    .map((theme) => ({ theme: theme, count: counts[theme] }))
    .sort((a, b) => b.count - a.count);

  ranking.forEach((r) => Logger.log(r.theme + ": " + r.count + "件"));
  return ranking;
}

// 毎週月曜の朝に自動でレビュー分析を実行する
function createWeeklyTrigger() {
  ScriptApp.newTrigger("analyzeReviews")
    .timeBased()
    .onWeekDay(ScriptApp.WeekDay.MONDAY)
    .atHour(7)
    .create();
}