Cron, Queues và việc chạy nền

# wrangler.toml
[triggers]
crons = [
  "0 1 * * *",      # 01:00 UTC = 08:00 gio Viet Nam — bao cao sang
  "*/15 * * * *",   # moi 15 phut — dong bo
  "0 17 * * 0"      # 00:00 thu Hai gio VN — don dep hang tuan
]

export default {
  async fetch(request, env, ctx) { /* ... */ },

  async scheduled(event, env, ctx) {
    switch (event.cron) {
      case "0 1 * * *":    return baoCaoSang(env);
      case "*/15 * * * *": return dongBo(env);
      case "0 17 * * 0":   return donDepTuan(env);
    }
  },
};

npx wrangler dev --test-scheduled
# cửa sổ khác:
curl "http://localhost:8787/__scheduled?cron=0+1+*+*+*"

async function dongBo(env) {
  // 1. KHÓA — tránh hai lượt chồng nhau khi lượt trước chạy quá lâu
  const dangChay = await env.CAU_HINH.get("dong-bo:dang-chay");
  if (dangChay && Date.now() - +dangChay < 10 * 60 * 1000) {
    console.log("Bo qua: luot truoc dang chay");
    return;
  }
  await env.CAU_HINH.put("dong-bo:dang-chay", String(Date.now()), { expirationTtl: 900 });

  try {
    // 2. TỪNG MẺ — không bao giờ xử lý cả bảng một lần
    const { results } = await env.DB.prepare(
      "SELECT id, du_lieu FROM hang_doi WHERE trang_thai = 'cho' ORDER BY id LIMIT 50"
    ).all();

    for (const r of results) {
      try {
        await guiDiNoiKhac(r.du_lieu);
        // 3. GHI KẾT QUẢ NGAY từng dòng, không đợi hết vòng lặp
        await env.DB.prepare("UPDATE hang_doi SET trang_thai='xong' WHERE id=?").bind(r.id).run();
      } catch (e) {
        await env.DB.prepare(
          "UPDATE hang_doi SET so_lan_loi = so_lan_loi + 1, loi_cuoi = ? WHERE id = ?"
        ).bind(String(e.message).slice(0, 200), r.id).run();
      }
    }
  } finally {
    // 4. LUÔN mở khóa, kể cả khi lỗi
    await env.CAU_HINH.delete("dong-bo:dang-chay");
  }
}

CREATE TABLE hang_doi (
  id          INTEGER PRIMARY KEY AUTOINCREMENT,
  loai        TEXT NOT NULL,              -- 'zalo' | 'email' | 'sheet'
  du_lieu     TEXT NOT NULL,              -- JSON
  trang_thai  TEXT NOT NULL DEFAULT 'cho',-- cho | dang | xong | loi
  so_lan_loi  INTEGER NOT NULL DEFAULT 0,
  loi_cuoi    TEXT,
  gui_sau     TEXT,                       -- mốc giờ sớm nhất được gửi
  tao_luc     TEXT NOT NULL DEFAULT (datetime('now'))
);
CREATE INDEX idx_hd_cho ON hang_doi(trang_thai, gui_sau);

[[queues.producers]]
queue = "viec-nen"
binding = "HANG_DOI"

[[queues.consumers]]
queue = "viec-nen"
max_batch_size = 10
max_retries = 3
dead_letter_queue = "viec-hong"

// đẩy việc vào
await env.HANG_DOI.send({ loai: "gui-email", donId: 42 });

// xử lý
export default {
  async queue(batch, env) {
    for (const msg of batch.messages) {
      try { await xuLy(msg.body, env); msg.ack(); }
      catch (e) { msg.retry(); }         // tự thử lại, quá số lần thì sang hàng đợi chết
    }
  },
};