ホテル・式場の宴会場の仮押さえを、順位と期限つきでシステムにする。婚礼と一般宴会の取り合い、分割して使う宴会場、転換の時間、2番手の繰り上げを、同時の申込のテストまで

-- 売る単位の部屋（全体・分割した部屋）
CREATE TABLE rooms (id TEXT PRIMARY KEY, name TEXT NOT NULL);
-- 部屋がふさぐ区画。「A」は A1 と A2 の両方をふさぐ
CREATE TABLE room_parts (room_id TEXT NOT NULL REFERENCES rooms(id), part TEXT NOT NULL,
                         PRIMARY KEY (room_id, part));
CREATE TABLE holds (
  id         INTEGER PRIMARY KEY,           -- 小さいほど先に押さえた
  room_id    TEXT NOT NULL REFERENCES rooms(id),
  date       TEXT NOT NULL,                 -- 開催日（日本時間の日付）
  start_min  INTEGER NOT NULL,              -- 開始（その日の0時からの分）
  end_min    INTEGER NOT NULL,              -- 終了（同上）
  kind       TEXT NOT NULL,                 -- wedding（婚礼）/ banquet（一般宴会）
  customer   TEXT NOT NULL,
  status     TEXT NOT NULL DEFAULT 'tentative', -- tentative / confirmed / released / expired
  expires_at INTEGER                        -- 1番手の返事の期限（UTCのミリ秒）。2番手は NULL
);
-- 送る連絡の控え（担当者・お客様へ）。確定した後に別の処理が送る
CREATE TABLE outbox (id INTEGER PRIMARY KEY, hold_id INTEGER NOT NULL, kind TEXT NOT NULL);

// hold.mjs（抜粋）。区画が1つでも重なり、転換の時間を含めて時間が重なる、生きている押さえ
export const BUFFER_MIN = 60; // 前後の宴会との間に空ける転換の時間（分）

const CONFLICTS = `
  SELECT DISTINCT h.id, h.status FROM holds h
  JOIN room_parts mine  ON mine.room_id = :room
  JOIN room_parts other ON other.room_id = h.room_id AND other.part = mine.part
  WHERE h.date = :date
    AND h.status IN ('tentative', 'confirmed')
    AND h.start_min < :end + ${BUFFER_MIN}
    AND h.end_min + ${BUFFER_MIN} > :start`;

// 押さえ h より前に入った、重なる仮押さえの数 + 1 が、h の順位
export function rankOf(db, h) {
  const ahead = conflicts(db, { room: h.room_id, date: h.date, start: h.start_min, end: h.end_min })
    .filter((c) => c.id < h.id && c.status === "tentative").length;
  return ahead + 1;
}

// hold.mjs（抜粋）
export const MAX_RANK = 2; // 受ける仮押さえは2番手まで
export const HOLD_DAYS = { wedding: 7, banquet: 3 }; // 1番手になってから返事を待つ日数（例）

// 2番手以下で、前の押さえが無くなった押さえを1番手にし、期限を付ける
function promote(db, now) {
  const waiting = db.prepare("SELECT * FROM holds WHERE status = 'tentative' AND expires_at IS NULL ORDER BY id").all();
  const promoted = [];
  for (const h of waiting) {
    if (rankOf(db, h) !== 1) continue;
    db.prepare("UPDATE holds SET expires_at = ? WHERE id = ?").run(now + HOLD_DAYS[h.kind] * DAY, h.id);
    db.prepare("INSERT INTO outbox (hold_id, kind) VALUES (?, 'promoted')").run(h.id);
    promoted.push(h.customer);
  }
  return promoted;
}

// 仮押さえを申し込む
export function requestHold(db, { room, date, start, end, kind, customer, now }) {
  return tx(db, () => {
    if (kind === "banquet" && isWeekend(date) && daysUntil(date, now) > BANQUET_OPEN_DAYS)
      return { ok: false, reason: "土日の一般宴会は、まだ受け付けていない日付" };
    const cs = conflicts(db, { room, date, start, end });
    if (cs.some((c) => c.status === "confirmed")) return { ok: false, reason: "本予約あり" };
    const rank = cs.length + 1; // 重なる仮押さえはすべて、これより前に入ったもの
    if (rank > MAX_RANK) return { ok: false, reason: `${rank}番手になるため受けない` };
    const expires = rank === 1 ? now + HOLD_DAYS[kind] * DAY : null;
    const { id } = db
      .prepare(`INSERT INTO holds (room_id, date, start_min, end_min, kind, customer, expires_at)
                VALUES (?, ?, ?, ?, ?, ?, ?) RETURNING id`)
      .get(room, date, start, end, kind, customer, expires);
    return { ok: true, id, rank };
  });
}

// 本予約にする。期限内の1番手だけが通る
export function confirm(db, { hold, now }) {
  return tx(db, () => {
    const h = db.prepare("SELECT * FROM holds WHERE id = ? AND status = 'tentative' AND expires_at > ?").get(hold, now);
    if (!h || rankOf(db, h) !== 1) return { ok: false, reason: "1番手ではない、または期限切れ" };
    db.prepare("UPDATE holds SET status = 'confirmed', expires_at = NULL WHERE id = ?").run(hold);
    // 重なっていた仮押さえは外し、外れたことを知らせる
    const lost = conflicts(db, { room: h.room_id, date: h.date, start: h.start_min, end: h.end_min })
      .filter((c) => c.status === "tentative");
    for (const c of lost) {
      db.prepare("UPDATE holds SET status = 'released', expires_at = NULL WHERE id = ?").run(c.id);
      db.prepare("INSERT INTO outbox (hold_id, kind) VALUES (?, 'lost')").run(c.id);
    }
    return { ok: true, released: lost.map((c) => c.id), promoted: promote(db, now) };
  });
}

// 期限を過ぎた1番手を外し、次の押さえを繰り上げる（定期の処理）
export function sweep(db, { now }) {
  return tx(db, () => {
    const expired = db
      .prepare(`UPDATE holds SET status = 'expired' WHERE status = 'tentative' AND expires_at <= ?
                RETURNING id, customer`)
      .all(now);
    for (const e of expired) db.prepare("INSERT INTO outbox (hold_id, kind) VALUES (?, 'expired')").run(e.id);
    return { expired: expired.map((e) => e.customer), promoted: promote(db, now) };
  });
}

// hold.mjs（抜粋）
export const BANQUET_OPEN_DAYS = 90; // 土日の一般宴会は、この日数より先の日付では押さえない（例）
const isWeekend = (date) => [0, 6].includes(new Date(`${date}T00:00:00Z`).getUTCDay());
const daysUntil = (date, now) => (Date.parse(`${date}T00:00:00+09:00`) - now) / DAY;

$ node --test --test-reporter=spec
✔ 同じ部屋・同じ時間は、1番手・2番手まで受けて、3件目は断る (2.274125ms)
✔ 分割した部屋は別々に1番手になれるが、全体の押さえは両方の後ろに付く (4.450875ms)
✔ 転換の60分を空けないと重なりとみなす (1.056875ms)
✔ 本予約にできるのは期限内の1番手だけ。決まったら2番手を外して知らせる (1.1135ms)
✔ 1番手の期限が切れたら、2番手を繰り上げて、その時点から期限を付ける (0.876208ms)
✔ 全体の押さえは、分割の押さえが両方なくなるまで繰り上がらない (0.949ms)
✔ 土日の一般宴会は、90日より先の日付では受けない（婚礼は受ける） (1.016417ms)
ℹ tests 7
ℹ suites 0
ℹ pass 7
ℹ fail 0
ℹ cancelled 0
ℹ skipped 0
ℹ todo 0
ℹ duration_ms 126.506541

素朴な作り
   43回  受けた押さえ8件（順位 1,1,1,1,1,1,1,1）、断った0件
    2回  受けた押さえ8件（順位 1,2,2,2,2,2,2,2）、断った0件
    1回  受けた押さえ7件（順位 1,1,1,1,1,1,2）、断った1件
    2回  受けた押さえ7件（順位 1,1,1,1,1,1,1）、断った1件
    1回  受けた押さえ5件（順位 1,1,1,1,1）、断った3件
    1回  受けた押さえ3件（順位 1,1,1）、断った5件
BEGIN IMMEDIATE の中で数えて書く作り
   50回  受けた押さえ2件（順位 1,2）、断った6件