GASで問い合わせフォームの
スパム投稿をAIで自動判定して弾く方法

// スクリプトプロパティにAPIキーを保存（初回に一度だけ実行）
function saveApiKey() {
  PropertiesService.getScriptProperties()
    .setProperty("ANTHROPIC_API_KEY", "sk-ant-xxxxxxxx");
}

// APIキーを取り出すヘルパー
function getApiKey() {
  const key = PropertiesService.getScriptProperties()
    .getProperty("ANTHROPIC_API_KEY");
  if (!key) throw new Error("APIキーが未設定です。saveApiKeyを先に実行してください。");
  return key;
}

// 1件の投稿をスパム判定する。戻り値は { score, isSpam, reason }
function judgeSpam(entry) {
  const apiKey = getApiKey();

  const system = [
    "あなたは日本語の問い合わせフォームのスパム判定担当です。",
    "以下の投稿がスパムかどうかを判定してください。",
    "スパムとみなす例:",
    "- SEO対策・被リンク・集客などの営業/宣伝",
    "- 本文と無関係な外部URLや連絡先の羅列",
    "- 意味の通らない文字列や機械翻訳的な不自然な日本語",
    "- 同一内容の大量送信を狙った定型文",
    "正当な問い合わせ（見積もり相談・仕事の依頼・質問など）はスパムではありません。",
    "迷った場合は正当な問い合わせ側に倒し、スコアを低めにしてください。",
    "必ず次のJSONだけを返す: " +
      '{"score": 0〜100の整数, "reason": "判定理由を20字程度で"}',
    "scoreはスパムらしさ。100に近いほどスパムの確信が高い。",
  ].join("\n");

  const userText =
    "お名前: " + (entry.name || "（空）") + "\n" +
    "メール: " + (entry.email || "（空）") + "\n" +
    "本文:\n" + (entry.body || "（空）");

  const payload = {
    model: "claude-sonnet-4-5",
    max_tokens: 200,
    system: system,
    messages: [{ role: "user", content: userText }],
  };

  const res = UrlFetchApp.fetch("https://api.anthropic.com/v1/messages", {
    method: "post",
    contentType: "application/json",
    headers: {
      "x-api-key": apiKey,
      "anthropic-version": "2023-06-01",
    },
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  });

  const json = JSON.parse(res.getContentText());
  const text = json.content[0].text;
  const parsed = JSON.parse(text);

  const score = Math.max(0, Math.min(100, Number(parsed.score)));
  return {
    score: score,
    isSpam: score >= 70, // しきい値は運用に合わせて調整
    reason: String(parsed.reason || ""),
  };
}

// フォーム送信トリガーから呼ぶ。回答シートに判定列を書き込む
function onFormSubmit(e) {
  const sheet = SpreadsheetApp.getActive().getSheetByName("回答");
  const row = e.range.getRow();

  // フォームの質問順に合わせて列番号を調整する
  const entry = {
    name: e.values[1],  // B列: お名前
    email: e.values[2], // C列: メール
    body: e.values[3],  // D列: お問い合わせ本文
  };

  const result = judgeSpam(entry);

  // E列にスコア、F列に判定、G列に理由を記録
  sheet.getRange(row, 5).setValue(result.score);
  sheet.getRange(row, 6).setValue(result.isSpam ? "スパム" : "正常");
  sheet.getRange(row, 7).setValue(result.reason);

  if (result.isSpam) {
    moveToSpamSheet(sheet, row);
  }
}

// スパム判定された行を「スパム」シートへ隔離する（削除はしない）
function moveToSpamSheet(sheet, row) {
  const ss = SpreadsheetApp.getActive();
  let spam = ss.getSheetByName("スパム");
  if (!spam) spam = ss.insertSheet("スパム");

  const lastCol = sheet.getLastColumn();
  const values = sheet.getRange(row, 1, 1, lastCol).getValues();
  spam.appendRow(values[0]);

  // 元シートからは行を削除して受信箱をきれいに保つ
  sheet.deleteRow(row);
}

// 過去の回答をまとめて再判定する。10件ずつ1回のリクエストで送る
function rejudgeAllPending() {
  const sheet = SpreadsheetApp.getActive().getSheetByName("回答");
  const data = sheet.getDataRange().getValues();
  const rows = data.slice(1); // ヘッダー除く

  const targets = [];
  rows.forEach((r, i) => {
    if (r[5]) return; // F列（判定）が空の行だけ処理
    targets.push({ rowNo: i + 2, name: r[1], email: r[2], body: r[3] });
  });

  for (let i = 0; i < targets.length; i += 10) {
    const chunk = targets.slice(i, i + 10);
    const results = judgeSpamBatch(chunk);
    results.forEach((result, j) => {
      const rowNo = chunk[j].rowNo;
      sheet.getRange(rowNo, 5).setValue(result.score);
      sheet.getRange(rowNo, 6).setValue(result.score >= 70 ? "スパム" : "正常");
      sheet.getRange(rowNo, 7).setValue(result.reason);
    });
    Utilities.sleep(1000); // レート制限対策に少し待つ
  }
}

// 複数件を1回のリクエストで判定し、配列で受け取る
function judgeSpamBatch(entries) {
  const apiKey = getApiKey();

  const system =
    "各投稿がスパムか判定し、次のJSON配列だけを返す: " +
    '[{"index":番号,"score":0〜100,"reason":"20字程度"}]。' +
    "SEO営業・宣伝・無関係なURL羅列・不自然な日本語はスパム。" +
    "正当な相談や依頼はスパムではない。迷えば低スコアにする。";

  const list = entries
    .map((e, i) =>
      "#" + i + " 名前:" + (e.name || "空") +
      " 本文:" + String(e.body || "").slice(0, 400)
    )
    .join("\n");

  const payload = {
    model: "claude-sonnet-4-5",
    max_tokens: 1024,
    system: system,
    messages: [{ role: "user", content: list }],
  };

  const res = UrlFetchApp.fetch("https://api.anthropic.com/v1/messages", {
    method: "post",
    contentType: "application/json",
    headers: { "x-api-key": apiKey, "anthropic-version": "2023-06-01" },
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  });

  const text = JSON.parse(res.getContentText()).content[0].text;
  const arr = JSON.parse(text);

  // index順に整列して返す（欠けた場合はスコア0=正常扱い）
  return entries.map((_, i) => {
    const hit = arr.find((a) => Number(a.index) === i);
    const score = hit ? Math.max(0, Math.min(100, Number(hit.score))) : 0;
    return { score: score, reason: hit ? String(hit.reason || "") : "判定なし" };
  });
}

// フォーム送信トリガーを設定（初回に一度だけ実行）
function createFormTrigger() {
  const ss = SpreadsheetApp.getActive();
  ScriptApp.newTrigger("onFormSubmit")
    .forSpreadsheet(ss)
    .onFormSubmit()
    .create();
}

// 取りこぼしの再判定を毎日実行したい場合
function createDailyRejudgeTrigger() {
  ScriptApp.newTrigger("rejudgeAllPending")
    .timeBased()
    .everyDays(1)
    .atHour(4)
    .create();
}