WordPress│本文の内容を要約してXにポストする方法│スレッド形式対応・OAuth2対応・ChatGPT連携

add_action('init', function () {
    if (isset($_GET['download_csv']) && current_user_can('manage_options')) {
        export_posts_to_csv();
    }
});

function export_posts_to_csv() {
    $args = [
        'post_type' => 'post',
        'posts_per_page' => -1,
        'post_status' => 'publish',
        'has_password' => false
    ];
    $posts = get_posts($args);

    header('Content-Type: text/csv; charset=UTF-8');
    header('Content-Disposition: attachment; filename="posts_export.csv"');
    header('Pragma: no-cache');
    header('Expires: 0');

    $output = fopen('php://output', 'w');
    fwrite($output, chr(0xEF) . chr(0xBB) . chr(0xBF)); // BOM

    fputcsv($output, ['タイトル', 'URL', '本文']);

    foreach ($posts as $post) {
        if (stripos($post->post_content, 'codoc') !== false) { continue; }
        $title = $post->post_title;
        $url = get_permalink($post->ID);
        $content = strip_tags($post->post_content);
        $content = preg_replace('/\s+/', ' ', $content); // 改行・空白除去
        fputcsv($output, array_map(function ($cell) {
            return preg_match('/^[=+@\-\t\r]/', $cell) ? "'" . $cell : $cell;
        }, [$title, $url, $content]));
    }

    fclose($output);
    exit;
}

https://motoki-design.co.jp/wordpress/csv-export/?download_csv=1

// カスタムメニュー追加
function onOpen() {
  const ui = SpreadsheetApp.getUi();
  ui.createMenu("AI要約")
    .addItem("SNS向け投稿文を作成（D列）", "generateSocialPost")
    .addToUi();
}

// D列：X向け投稿文
function generateSocialPost() {
  const sheet = SpreadsheetApp.getActiveSpreadsheet().getSheetByName("シート1");
  const apiKey = PropertiesService.getScriptProperties().getProperty("ACCESS_TOKEN");
  const lastRow = sheet.getLastRow();

  for (let i = 2; i <= lastRow; i++) {
    const body = sheet.getRange(i, 3).getValue();
    const postText = sheet.getRange(i, 4).getValue();

    if (body && !postText) {
      const prompt = `
以下の文章をもとに、Web制作初心者でもわかるようにX（旧Twitter）向けの投稿文を作ってください。

【ルール】
- 難しい言葉は避ける
- 絵文字やハッシュタグはOK
- 140文字以内にこだわらなくていい
- 読んだ人が記事を見たくなるように！

文章：
${body}
      `.trim();

      const result = callChatGPT(apiKey, prompt);
      sheet.getRange(i, 4).setValue(result);
      Utilities.sleep(1500);
    }
  }
}

function callChatGPT(apiKey, prompt) {
  const payload = {
    model: "gpt-4o",
    messages: [{ role: "user", content: prompt }],
    temperature: 0.7
  };

  const options = {
    method: "post",
    contentType: "application/json",
    headers: { Authorization: "Bearer " + apiKey },
    payload: JSON.stringify(payload),
    muteHttpExceptions: true
  };

  const res = UrlFetchApp.fetch("https://api.openai.com/v1/chat/completions", options);
  const status = res.getResponseCode();
  if (status < 200 || status >= 300) throw new Error("OpenAI HTTP " + status);
  const json = JSON.parse(res.getContentText());
  const choice = json.choices?.[0];
  const text = choice?.message?.content;
  if (choice?.finish_reason !== "stop" || typeof text !== "string" || !text.trim()) {
    throw new Error("要約が正常に完了していません。D列には保存しません。");
  }
  return text.trim();
}

私は、自社で運営しているWordPressブログの記事を、X（旧Twitter）アカウントに自動投稿する目的でTwitter APIを使用します。  
具体的には、記事本文をスプレッドシートにまとめ、ChatGPT APIを活用してわかりやすい短文（要約）を生成し、それをXへ1日1件投稿します。  
投稿内容はすべて自社オリジナルの記事に限定し、再配信・分析・再販売・DM送信・フォロー操作などは一切行いません。  
純粋に情報発信を効率化することを目的とした非侵襲的な利用です。  
この用途の範囲内でのみAPIを利用し、ポリシーや利用規約を厳守いたします。

function logRedirectUri() {
  Logger.log("Redirect URI（Callback URL）:");
  Logger.log(OAuth2.getRedirectUri());
}

function main() {
  const service = getService();
  if (service.hasAccess()) {
    Logger.log("Already authorized");
  } else {
    const authorizationUrl = service.getAuthorizationUrl();
    Logger.log('Open the following URL and re-run the script: %s', authorizationUrl);
  }
}

function getService() {
  const props = PropertiesService.getScriptProperties();
  const id = props.getProperty("CLIENT_ID");
  const secret = props.getProperty("CLIENT_SECRET");
  if (!id || !secret) throw new Error("Xのクライアント設定がありません");
  return OAuth2.createService("WazaX")
    .setAuthorizationBaseUrl("https://x.com/i/oauth2/authorize")
    .setTokenUrl("https://api.x.com/2/oauth2/token")
    .setClientId(id)
    .setClientSecret(secret)
    .setCallbackFunction("authCallback")
    .setPropertyStore(PropertiesService.getUserProperties())
    .setCache(CacheService.getUserCache())
    .setLock(LockService.getUserLock())
    .setScope("tweet.read tweet.write users.read offline.access")
    .setTokenHeaders({Authorization: "Basic " + Utilities.base64Encode(id + ":" + secret)})
    .generateCodeVerifier();
}
function authCallback(request) {
  const ok = getService().handleCallback(request);
  return HtmlService.createHtmlOutput(ok ? "認証しました。この画面を閉じてください。" : "認証されませんでした。");
}

1B7FSrk5Zi6L1rSxxTDgDEUsPzlukDsi4KGuTMorsTQHhGBzBkMun4iDF

function postXThread() {
  const lock = LockService.getScriptLock();
  if (!lock.tryLock(1000)) return;
  try {
    const sheet = SpreadsheetApp.getActiveSpreadsheet().getSheetByName("シート1");
    if (!sheet) throw new Error("シート1がありません");
    const data = sheet.getDataRange().getValues();
    const service = getService();
    if (!service.hasAccess()) throw new Error("実行ユーザーのX認証が必要です");
    for (let i = 1; i < data.length; i++) {
      const [title, url, body, postText, postedDate, firstId, secondId, state] = data[i];
      if (postedDate || state !== "READY") continue;
      if (typeof postText !== "string" || !postText.trim() || !/^https:\/\//.test(String(url))) {
        throw new Error("本文またはURLを確認してください");
      }
      const row = i + 1;
      let parentId = String(firstId || "");
      const ids = [String(firstId || ""), String(secondId || "")];
      if (ids[1] && !ids[0]) throw new Error("投稿IDの組合せを確認してください");
      const texts = [postText.trim(), `${title} ${url}`.trim()];
      for (let j = 0; j < 2; j++) {
        if (ids[j]) continue;
        sheet.getRange(row, 8).setValue("SENDING_" + (j + 1));
        SpreadsheetApp.flush();
        // 送信後に応答・保存が失敗した場合も、自動では再送しない。
        const payload = {text: texts[j]};
        if (parentId) payload.reply = {in_reply_to_tweet_id: parentId};
        const response = UrlFetchApp.fetch("https://api.x.com/2/tweets", {
          method: "post", contentType: "application/json",
          headers: {Authorization: "Bearer " + service.getAccessToken()},
          payload: JSON.stringify(payload), muteHttpExceptions: true
        });
        const status = response.getResponseCode();
        if (status < 200 || status >= 300) throw new Error("X HTTP " + status + ": 投稿状況を手動確認してください");
        const result = JSON.parse(response.getContentText());
        const id = result.data?.id;
        if (typeof id !== "string" || !/^\d+$/.test(id)) throw new Error("投稿IDを確認できません");
        sheet.getRange(row, 6 + j).setNumberFormat("@").setValue(id);
        SpreadsheetApp.flush();
        parentId = id;
      }
      sheet.getRange(row, 5).setValue(new Date()).setNumberFormat("yyyy/MM/dd HH:mm");
      sheet.getRange(row, 8).setValue("DONE");
      SpreadsheetApp.flush();
      return;
    }
  } finally {
    lock.releaseLock();
  }
}