予約の前日リマインドをLINEで送る仕組みを、Cloudflare WorkersのCron TriggersとD1で作る。送る対象の抽出、先に送信中にする二重送信の対策、X-Line-Retry-Keyでの再試行、失敗の記録、UTCと日本時間

{
  "name": "visit-reminder",
  "main": "src/index.js",
  "compatibility_date": "2026-10-01",
  "triggers": {
    // Cron Triggers は UTC。9:00 UTC = 日本時間 18:00、10:00 UTC = 19:00（失敗分の再試行）
    "crons": ["0 9 * * *", "0 10 * * *"]
  },
  "d1_databases": [
    { "binding": "DB", "database_name": "visit-reminder", "database_id": "00000000-0000-0000-0000-000000000000" }
  ],
  "vars": {
    "LINE_API_BASE": "https://api.line.me",
    "CHANGE_URL_BASE": "https://example.com/reservations/"
  }
}

const JST_OFFSET_MS = 9 * 60 * 60 * 1000; // 日本は UTC+9（夏時間なし）

/** UTC のミリ秒 → 日本時間の日付 'YYYY-MM-DD'（days 日後） */
export function jstDate(ms, days = 0) {
  return new Date(ms + JST_OFFSET_MS + days * 86_400_000).toISOString().slice(0, 10);
}

$ node tz-check.mjs
2026-10-08T09:00:00Z  JSTの今日=2026-10-08  JSTの明日=2026-10-09  （UTCで計算した明日=2026-10-09）
2026-10-08T14:59:00Z  JSTの今日=2026-10-08  JSTの明日=2026-10-09  （UTCで計算した明日=2026-10-09）
2026-10-08T15:00:00Z  JSTの今日=2026-10-09  JSTの明日=2026-10-10  （UTCで計算した明日=2026-10-09）
2026-10-31T09:00:00Z  JSTの今日=2026-10-31  JSTの明日=2026-11-01  （UTCで計算した明日=2026-11-01）

-- 予約（日時は日本時間で持つ）
CREATE TABLE IF NOT EXISTS reservations (
  id TEXT PRIMARY KEY,
  customer_name TEXT NOT NULL,
  line_user_id TEXT,                               -- LINE とつながっていなければ NULL
  line_reminder_consent INTEGER NOT NULL DEFAULT 0, -- 1 = リマインドを LINE で受け取ることに同意
  visit_date TEXT NOT NULL,                        -- 'YYYY-MM-DD'（日本時間）
  visit_time TEXT NOT NULL,                        -- 'HH:MM'（日本時間）
  status TEXT NOT NULL DEFAULT 'booked'            -- booked / cancelled
);
CREATE INDEX IF NOT EXISTS idx_reservations_visit ON reservations (visit_date, status);

-- 送信の記録。1つの予約に「前日のリマインド」は1行だけ
CREATE TABLE IF NOT EXISTS reminder_sends (
  reservation_id TEXT NOT NULL,
  kind TEXT NOT NULL,              -- 'day_before'
  status TEXT NOT NULL,            -- sending / sent / retry / failed
  retry_key TEXT NOT NULL,         -- X-Line-Retry-Key。同じ送信の再試行では同じ値を使う
  attempts INTEGER NOT NULL DEFAULT 1,
  http_status INTEGER,
  line_request_id TEXT,
  error TEXT,
  claimed_at TEXT NOT NULL,        -- 送信中にした時刻（UTC の ISO 形式）
  sent_at TEXT,
  PRIMARY KEY (reservation_id, kind)
);

SELECT r.id, r.customer_name, r.line_user_id, r.visit_date, r.visit_time,
       s.status AS send_status, s.attempts, s.retry_key
  FROM reservations r
  LEFT JOIN reminder_sends s ON s.reservation_id = r.id AND s.kind = ?1
 WHERE r.visit_date = ?2                -- 日本時間の明日
   AND r.status = 'booked'              -- キャンセル済みは除く
   AND r.line_user_id IS NOT NULL       -- LINE とつながっている
   AND r.line_reminder_consent = 1      -- LINE で受け取ることに同意している
   AND (s.reservation_id IS NULL                            -- まだ送っていない
        OR (s.status = 'retry' AND s.attempts < ?3)         -- 送り直せる失敗
        OR (s.status = 'sending' AND s.claimed_at < ?4))    -- 送信中のまま止まった
 ORDER BY r.visit_time, r.id

/** 送る前に「送信中」の行を書いて、この予約を自分の担当にする。取れたら retry key を返す */
async function claim(env, r, nowIso) {
  if (r.send_status == null) {
    const retryKey = crypto.randomUUID();
    const res = await env.DB.prepare(
      `INSERT INTO reminder_sends (reservation_id, kind, status, retry_key, attempts, claimed_at)
       VALUES (?1, ?2, 'sending', ?3, 1, ?4)
       ON CONFLICT (reservation_id, kind) DO NOTHING`,
    )
      .bind(r.id, KIND, retryKey, nowIso)
      .run();
    return res.meta.changes === 1 ? retryKey : null;
  }
  // 再試行：読んだときと同じ状態・回数のときだけ更新する（同時に動いた別の実行と取り合わない）
  const res = await env.DB.prepare(
    `UPDATE reminder_sends
        SET status = 'sending', attempts = attempts + 1, claimed_at = ?1
      WHERE reservation_id = ?2 AND kind = ?3 AND status = ?4 AND attempts = ?5`,
  )
    .bind(nowIso, r.id, KIND, r.send_status, r.attempts)
    .run();
  // retry key は最初の送信と同じものを使う。LINE が受け付け済みなら 409 が返り、二重には届かない
  return res.meta.changes === 1 ? r.retry_key : null;
}

{"cron":"0 9 * * *","target":"2026-10-09","candidates":5,"sent":1,"retry":1,"failed":1,"skipped":2}
{"cron":"0 9 * * *","target":"2026-10-09","candidates":5,"sent":0,"retry":2,"failed":0,"skipped":3}

async function pushReminder(env, r, retryKey) {
  let res;
  try {
    res = await fetch(`${env.LINE_API_BASE}/v2/bot/message/push`, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        Authorization: `Bearer ${env.LINE_CHANNEL_ACCESS_TOKEN}`,
        'X-Line-Retry-Key': retryKey,
      },
      body: JSON.stringify({ to: r.line_user_id, messages: [{ type: 'text', text: reminderText(r, env) }] }),
      signal: AbortSignal.timeout(10_000),
    });
  } catch (e) {
    // タイムアウト・通信の失敗：LINE に届いたかどうか分からないので、同じ retry key で後で送り直す
    return { status: 'retry', httpStatus: null, error: `${e.name}: ${e.message}` };
  }
  const requestId = res.headers.get('x-line-request-id');
  if (res.ok) return { status: 'sent', httpStatus: res.status, requestId };
  if (res.status === 409) {
    // 同じ retry key の送信を LINE がすでに受け付けている＝前回の送信は届いていた
    return { status: 'sent', httpStatus: 409, requestId: res.headers.get('x-line-accepted-request-id') };
  }
  const body = (await res.text()).slice(0, 500);
  if (res.status >= 500) return { status: 'retry', httpStatus: res.status, requestId, error: body };
  // 400・401・403・429 など：同じ内容で送り直しても通らないので止め、人が見る
  return { status: 'failed', httpStatus: res.status, requestId, error: body };
}

function reminderText(r, env) {
  const [, m, d] = r.visit_date.split('-').map(Number);
  return [
    `${r.customer_name} 様`,
    `明日 ${m}月${d}日 ${r.visit_time} からのご予約のお知らせです。`,
    `日時の変更・キャンセルはこちらから：${env.CHANGE_URL_BASE}${encodeURIComponent(r.id)}`,
  ].join('\n');
}

async function record(env, reservationId, o, nowIso) {
  // 再試行の回数を使い切った 'retry' は 'failed' にして止める
  const row = await env.DB.prepare(
    `UPDATE reminder_sends
        SET status = CASE WHEN ?1 = 'retry' AND attempts >= ?8 THEN 'failed' ELSE ?1 END,
            http_status = ?2, line_request_id = ?3, error = ?4,
            sent_at = CASE WHEN ?1 = 'sent' THEN ?5 ELSE sent_at END
      WHERE reservation_id = ?6 AND kind = ?7
      RETURNING status`,
  )
    .bind(o.status, o.httpStatus ?? null, o.requestId ?? null, o.error ?? null, nowIso, reservationId, KIND, MAX_ATTEMPTS)
    .first();
  return row.status;
}

// 予約の前日リマインドを LINE の push で送る Worker（Cron Triggers で起動）
const KIND = 'day_before';
const MAX_ATTEMPTS = 3; // 500・タイムアウトのときの最大の試行回数
const STUCK_MS = 10 * 60 * 1000; // 「送信中」のまま10分たったものは、途中で止まったとみなす
const JST_OFFSET_MS = 9 * 60 * 60 * 1000; // 日本は UTC+9（夏時間なし）

/** UTC のミリ秒 → 日本時間の日付 'YYYY-MM-DD'（days 日後） */
export function jstDate(ms, days = 0) {
  return new Date(ms + JST_OFFSET_MS + days * 86_400_000).toISOString().slice(0, 10);
}

export default {
  async scheduled(controller, env, ctx) {
    const result = await runReminders(env, controller.scheduledTime);
    console.log(JSON.stringify({ cron: controller.cron, ...result }));
  },
};

export async function runReminders(env, nowMs) {
  const target = jstDate(nowMs, 1); // 明日（日本時間）
  const nowIso = new Date(nowMs).toISOString();
  const stuckBefore = new Date(nowMs - STUCK_MS).toISOString();

  // 送る対象：明日・予約中・LINE の ID あり・同意あり、かつ
  // 「まだ送っていない」か「再試行できる失敗」か「送信中のまま止まったもの」
  const { results: targets } = await env.DB.prepare(
    `SELECT r.id, r.customer_name, r.line_user_id, r.visit_date, r.visit_time,
            s.status AS send_status, s.attempts, s.retry_key
       FROM reservations r
       LEFT JOIN reminder_sends s ON s.reservation_id = r.id AND s.kind = ?1
      WHERE r.visit_date = ?2
        AND r.status = 'booked'
        AND r.line_user_id IS NOT NULL
        AND r.line_reminder_consent = 1
        AND (s.reservation_id IS NULL
             OR (s.status = 'retry' AND s.attempts < ?3)
             OR (s.status = 'sending' AND s.claimed_at < ?4))
      ORDER BY r.visit_time, r.id`,
  )
    .bind(KIND, target, MAX_ATTEMPTS, stuckBefore)
    .all();

  const counts = { target, candidates: targets.length, sent: 0, retry: 0, failed: 0, skipped: 0 };
  for (const r of targets) {
    const retryKey = await claim(env, r, nowIso);
    if (!retryKey) {
      counts.skipped++; // ほかの実行が先に取った
      continue;
    }
    const outcome = await pushReminder(env, r, retryKey);
    const status = await record(env, r.id, outcome, nowIso);
    counts[status]++;
  }
  return counts;
}

/** 送る前に「送信中」の行を書いて、この予約を自分の担当にする。取れたら retry key を返す */
async function claim(env, r, nowIso) {
  if (r.send_status == null) {
    const retryKey = crypto.randomUUID();
    const res = await env.DB.prepare(
      `INSERT INTO reminder_sends (reservation_id, kind, status, retry_key, attempts, claimed_at)
       VALUES (?1, ?2, 'sending', ?3, 1, ?4)
       ON CONFLICT (reservation_id, kind) DO NOTHING`,
    )
      .bind(r.id, KIND, retryKey, nowIso)
      .run();
    return res.meta.changes === 1 ? retryKey : null;
  }
  // 再試行：読んだときと同じ状態・回数のときだけ更新する（同時に動いた別の実行と取り合わない）
  const res = await env.DB.prepare(
    `UPDATE reminder_sends
        SET status = 'sending', attempts = attempts + 1, claimed_at = ?1
      WHERE reservation_id = ?2 AND kind = ?3 AND status = ?4 AND attempts = ?5`,
  )
    .bind(nowIso, r.id, KIND, r.send_status, r.attempts)
    .run();
  // retry key は最初の送信と同じものを使う。LINE が受け付け済みなら 409 が返り、二重には届かない
  return res.meta.changes === 1 ? r.retry_key : null;
}

function reminderText(r, env) {
  const [, m, d] = r.visit_date.split('-').map(Number);
  return [
    `${r.customer_name} 様`,
    `明日 ${m}月${d}日 ${r.visit_time} からのご予約のお知らせです。`,
    `日時の変更・キャンセルはこちらから：${env.CHANGE_URL_BASE}${encodeURIComponent(r.id)}`,
  ].join('\n');
}

async function pushReminder(env, r, retryKey) {
  let res;
  try {
    res = await fetch(`${env.LINE_API_BASE}/v2/bot/message/push`, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        Authorization: `Bearer ${env.LINE_CHANNEL_ACCESS_TOKEN}`,
        'X-Line-Retry-Key': retryKey,
      },
      body: JSON.stringify({ to: r.line_user_id, messages: [{ type: 'text', text: reminderText(r, env) }] }),
      signal: AbortSignal.timeout(10_000),
    });
  } catch (e) {
    // タイムアウト・通信の失敗：LINE に届いたかどうか分からないので、同じ retry key で後で送り直す
    return { status: 'retry', httpStatus: null, error: `${e.name}: ${e.message}` };
  }
  const requestId = res.headers.get('x-line-request-id');
  if (res.ok) return { status: 'sent', httpStatus: res.status, requestId };
  if (res.status === 409) {
    // 同じ retry key の送信を LINE がすでに受け付けている＝前回の送信は届いていた
    return { status: 'sent', httpStatus: 409, requestId: res.headers.get('x-line-accepted-request-id') };
  }
  const body = (await res.text()).slice(0, 500);
  if (res.status >= 500) return { status: 'retry', httpStatus: res.status, requestId, error: body };
  // 400・401・403・429 など：同じ内容で送り直しても通らないので止め、人が見る
  return { status: 'failed', httpStatus: res.status, requestId, error: body };
}

async function record(env, reservationId, o, nowIso) {
  // 再試行の回数を使い切った 'retry' は 'failed' にして止める
  const row = await env.DB.prepare(
    `UPDATE reminder_sends
        SET status = CASE WHEN ?1 = 'retry' AND attempts >= ?8 THEN 'failed' ELSE ?1 END,
            http_status = ?2, line_request_id = ?3, error = ?4,
            sent_at = CASE WHEN ?1 = 'sent' THEN ?5 ELSE sent_at END
      WHERE reservation_id = ?6 AND kind = ?7
      RETURNING status`,
  )
    .bind(o.status, o.httpStatus ?? null, o.requestId ?? null, o.error ?? null, nowIso, reservationId, KIND, MAX_ATTEMPTS)
    .first();
  return row.status;
}

// LINE Messaging API の push を真似る手元のサーバー（本物の LINE には送らない）
// 宛先の userId で返し方を変える。受け付けた retry key を覚えて、同じ key には 409 を返す
import { createServer } from 'node:http';
import { appendFileSync } from 'node:fs';
import { randomUUID } from 'node:crypto';

const accepted = new Map(); // retry key → 受け付けたときの request id
const seen = new Map(); // userId → 届いた回数
const log = (o) => appendFileSync('mock-requests.jsonl', JSON.stringify(o) + '\n');

createServer(async (req, res) => {
  let raw = '';
  for await (const c of req) raw += c;
  const body = JSON.parse(raw || '{}');
  const key = req.headers['x-line-retry-key'];
  const to = body.to;
  const n = (seen.get(to) ?? 0) + 1;
  seen.set(to, n);
  const requestId = randomUUID();
  const reply = (status, json = {}, headers = {}) => {
    log({ at: new Date().toISOString(), to, retryKey: key, n, status, auth: req.headers.authorization === 'Bearer test-token' });
    res.writeHead(status, { 'Content-Type': 'application/json', 'x-line-request-id': requestId, ...headers });
    res.end(JSON.stringify(json));
  };
  if (req.url !== '/v2/bot/message/push') return reply(404, { message: 'Not found' });
  if (accepted.has(key)) {
    return reply(409, { message: 'The retry key is already accepted' }, { 'x-line-accepted-request-id': accepted.get(key) });
  }
  if (to === 'U_500once' && n === 1) return reply(500, { message: 'Internal server error' });
  if (to === 'U_500always') return reply(500, { message: 'Internal server error' });
  if (to === 'U_429') return reply(429, { message: 'You have reached your monthly limit.' });
  accepted.set(key, requestId);
  if (to === 'U_slow' && n === 1) {
    // 受け付けたが、応答が12秒返らない（Worker 側は10秒で打ち切る）
    await new Promise((r) => setTimeout(r, 12_000));
  }
  return reply(200, { sentMessages: [{ id: String(Date.now()) }] });
}).listen(8790, () => console.log('mock LINE on :8790'));

LINE_CHANNEL_ACCESS_TOKEN=test-token
LINE_API_BASE=http://127.0.0.1:8790

npx wrangler d1 execute visit-reminder --local --file=schema.sql
npx wrangler d1 execute visit-reminder --local --file=seed.sql   # 上の表の8件
node mock-line.mjs &
npx wrangler dev --test-scheduled --port 8788

# 2026-10-08 09:00 UTC（日本時間18:00）として起こす
curl "http://localhost:8788/cdn-cgi/local/scheduled?cron=0+9+*+*+*&time=1791450000000"

{"cron":"0 9 * * *","target":"2026-10-09","candidates":4,"sent":1,"retry":2,"failed":1,"skipped":0}
{"cron":"0 10 * * *","target":"2026-10-09","candidates":3,"sent":3,"retry":0,"failed":0,"skipped":0}
{"cron":"0 9 * * *","target":"2026-10-09","candidates":0,"sent":0,"retry":0,"failed":0,"skipped":0}