GAS×WordPressで自動投稿を実現する― しずかなニュースの開発記録

<?php
/**
 * Plugin Name: GAS Pull Auto Publisher (Draft Only, Minimal)
 */
if (!defined('ABSPATH')) exit;

/** ===== 設定 ===== */
define('GAS_PULL_FEED', 'https://script.google.com/macros/s/*******/exec?token=*******'); //
define('GAS_PULL_DEFAULT_ID', '1');                         // ← 投稿設定シートの既定ID列（B列=1）
define('GAS_PULL_META_KEY', '_external_id');
define('GAS_LOG_ENDPOINT', 'https://script.google.com/macros/s/*******/exec'); // ← /exec に修正
define('GAS_TOKEN', 'tkn_5zX8hJq2LmR9vTnY');

/** ===== ロギング（GASのスプレシートへ） ===== */
function gas_log($level, $message, $context = []) {
    $payload = [
        'token'   => GAS_TOKEN,
        'level'   => $level,
        'message' => $message,
        'context' => $context,
    ];
    wp_remote_post(GAS_LOG_ENDPOINT, [
        'timeout' => 10,
        'headers' => ['Content-Type' => 'application/json'],
        'body'    => wp_json_encode($payload),
    ]);
}

/** ===== 取得URL作成（?id= の付与） ===== */
function gas_build_feed_url($id_param = null) {
    $id = $id_param !== null && $id_param !== '' ? $id_param : GAS_PULL_DEFAULT_ID;
    // すでに token は入っている前提。id を追加する
    return add_query_arg(['id' => $id], GAS_PULL_FEED);
}

/** ===== 取得＆反映ロジック（下書き既定） ===== */
function gas_pull_run_once($override_id = null) {
    $feed_url = gas_build_feed_url($override_id);

    $res = wp_remote_get($feed_url, ['timeout' => 20]);
    if (is_wp_error($res)) { gas_log('ERROR', 'wp_remote_get error', ['err'=>$res->get_error_message(), 'url'=>$feed_url]); return; }

    $items = json_decode(wp_remote_retrieve_body($res), true);
    if (!is_array($items)) { gas_log('ERROR','invalid json', ['body'=>wp_remote_retrieve_body($res)]); return; }

    foreach ($items as $it) {
        $ext_id = isset($it['id']) ? sanitize_text_field($it['id']) : '';
        if (!$ext_id) { gas_log('WARN','skip: no id'); continue; }

        // ====== 本文整形（保険つき）======
        $raw = isset($it['content']) ? (string) $it['content'] : '';
        $clean_content = wp_kses_post($raw);
        // ====== 本文整形ここまで ======

        // 受け取り可能な追加フィールド
        $incoming_status = isset($it['status']) ? sanitize_key($it['status']) : '';
        $incoming_type   = isset($it['type'])   ? sanitize_key($it['type'])   : 'post'; // ← post/page を想定
        $incoming_slug   = isset($it['slug'])   ? sanitize_title($it['slug'])  : '';

        $allowed_status = ['draft','publish','pending','future','private'];
        if (!in_array($incoming_status, $allowed_status, true)) {
            $incoming_status = 'draft';
        }
        if ($incoming_type !== 'page' && $incoming_type !== 'post') {
            $incoming_type = 'post';
        }

        // 既存検索（post/page両方見に行く）
        $q = new WP_Query([
            'post_type'   => 'any',
            'meta_key'    => GAS_PULL_META_KEY,
            'meta_value'  => $ext_id,
            'post_status' => ['draft','publish','future','pending','private']
        ]);

        $postarr = [
            'post_title'   => wp_kses_post($it['title'] ?? '(no title)'),
            'post_content' => $clean_content,
            'post_status'  => $incoming_status,
            'post_type'    => $incoming_type,
        ];

        if ($q->have_posts()) {
            // 既存更新
            $postarr['ID'] = $q->posts[0]->ID;

            // スラッグが来ていれば更新（不要ならこの行をコメントアウト）
            if ($incoming_slug) {
                $postarr['post_name'] = $incoming_slug;
            }

            $post_id = wp_update_post($postarr, true);
            if (is_wp_error($post_id)) {
                gas_log('ERROR','update failed', ['err'=>$post_id->get_error_message(), 'ext_id'=>$ext_id]);
            } else {
                gas_log('INFO','updated', ['id'=>$post_id, 'ext_id'=>$ext_id, 'type'=>$incoming_type, 'status'=>$incoming_status]);
            }
        } else {
            // 新規挿入
            if ($incoming_slug) {
                $postarr['post_name'] = $incoming_slug;
            }
            $post_id = wp_insert_post($postarr, true);
            if (!is_wp_error($post_id) && $post_id) {
                update_post_meta($post_id, GAS_PULL_META_KEY, $ext_id);
                gas_log('INFO','inserted', ['id'=>$post_id, 'ext_id'=>$ext_id, 'type'=>$incoming_type, 'status'=>$incoming_status]);
            } else {
                gas_log('ERROR','insert failed', ['err'=>is_wp_error($post_id)?$post_id->get_error_message():$post_id, 'ext_id'=>$ext_id]);
            }
        }
    }
}

/** ===== WP-Cron （有効化時: 5分後に1回、以後60分ごと） ===== */
register_activation_hook(__FILE__, function(){
    if (!wp_next_scheduled('gas_pull_cron_hook')) {
        add_filter('cron_schedules', function($s){ $s['hourly_custom'] = ['interval'=>3600,'display'=>__('Every 60 Minutes')]; return $s; });
        wp_schedule_event(time()+300, 'hourly_custom', 'gas_pull_cron_hook');
    }
});
register_deactivation_hook(__FILE__, function(){
    $ts = wp_next_scheduled('gas_pull_cron_hook');
    if ($ts) wp_unschedule_event($ts, 'gas_pull_cron_hook');
});
add_filter('cron_schedules', function($s){ $s['hourly_custom'] = ['interval'=>3600,'display'=>__('Every 60 Minutes')]; return $s; });
add_action('gas_pull_cron_hook', function(){ gas_pull_run_once(null); });

/** ===== 手動実行（URLで叩ける） ===== */
/* 例:
   https://example.com/?gas_pull_run=1&key=tkn_5zX8hJq2LmR9vTnY       ← 既定ID
   https://example.com/?gas_pull_run=1&key=tkn_5zX8hJq2LmR9vTnY&id=2  ← この回だけID=2
*/
add_action('init', function(){
    if (isset($_GET['gas_pull_run']) && isset($_GET['key']) && $_GET['key'] === GAS_TOKEN) {
        $id = isset($_GET['id']) ? sanitize_text_field($_GET['id']) : null;
        gas_pull_run_once($id);
        nocache_headers();
        header('Content-Type: text/plain; charset=utf-8');
        echo 'GAS pull executed. (id=' . ($id ?: GAS_PULL_DEFAULT_ID) . ')';
        exit;
    }
});

/**
 * exportArticlesHtml（kwd対応版）
 * - 投稿シートを読み込み、WP本文HTMLを生成
 *
 * 投稿シート列
 *   B:タイトル
 *   C:要約
 *   D:媒体
 *   E:URL
 *   F:kwd_en
 *   G:kwd_jp
 *   H:kwd_desc
 *   I:title_en
 */
function exportArticlesHtml() {
  const SHEET_NAME = '投稿';
  const HEADER_ROW = 1;
  const START_ROW  = HEADER_ROW + 1;

  const ss = SpreadsheetApp.getActive();
  const sh = ss.getSheetByName(SHEET_NAME);
  if (!sh) throw new Error(`シートが見つかりません: ${SHEET_NAME}`);

  const lastRow = sh.getLastRow();
  if (lastRow < START_ROW) return '';

  // B〜I（8列）を取得（列B=2）
  const values = sh.getRange(START_ROW, 2, lastRow - HEADER_ROW, 8).getValues();

  // 整形
  const items = values
    .map(([title, summary, source, url, kw_en, kw_jp, kw_desc,title_en]) => ({
      title:   String(title   || '').trim(),
      summary: String(summary || '').trim(),
      source:  String(source  || '').trim(),
      url:     String(url     || '').trim(),
      kw_en:   String(kw_en   || '').trim(),
      kw_jp:   String(kw_jp   || '').trim(),
      kw_desc: String(kw_desc || '').trim(),
      title_en: String(title_en || '').trim(),

    }))
    .filter(r => r.title && r.url);

  // HTML エスケープ
  const esc = s => String(s)
    .replaceAll('&','&amp;')
    .replaceAll('<','&lt;')
    .replaceAll('>','&gt;')
    .replaceAll('"','&quot;')
    .replaceAll("'",'&#39;');

  // 件数
  const header = `<p class="news-count">件数：${items.length}</p>`;

  // 記事単位HTML
  const rows = items.map((it, idx) => {
    const title  = esc(it.title);
    const source = esc(it.source);
    const url    = esc(it.url);
    const title_en    = esc(it.title_en);

    const summaryHtml = esc(it.summary).replace(/\n/g, '<br>');

    // --- ✅キーワード表示 ---
    let kwHtml = '';
    if (it.kw_en || it.kw_jp || it.kw_desc) {
      kwHtml = `
    <div class="news-keywords">
      ${it.kw_en   ? `<p><strong>Keyword(EN):</strong> ${esc(it.kw_en)} （${esc(it.kw_jp)}）</p>` : ''}
      ${it.kw_desc ? `<p><small>${esc(it.kw_desc)}</small></p>` : ''}
    </div>`;
    }

    return `
<article class="news-card" aria-label="記事 ${idx + 1}">
  <h2 class="news-title">${title}</h2>
  <b>${title_en}</b>
  ${source ? `<div class="news-meta">引用元：<a href="${url}" target="_blank" rel="noopener noreferrer">${esc(source)}</a></div>` : ''}
  ${summaryHtml ? `<p class="news-summary">${summaryHtml}</p>` : ''}
  ${kwHtml}
</article>`;
  }).join('\n');

  const content = header + '\n' + rows;
  Logger.log(content);

  return content;
}