多门店打印的集中管理方案

const res = await fetch('https://api.printbase.cloud/v1/printers', {
  headers: { Authorization: `Bearer ${process.env.PRINTBASE_API_KEY}` },
});
const printers = await res.json();
// [{ id, code, computer_id, name: "Gprinter GP-80250", status: "online",
//    capabilities: ["pdf", "raw"] }, ...]

create table store_printers (
  store_id      text not null,        -- SH-001
  role          text not null,        -- receipt | kitchen | label
  printer_code  bigint not null,      -- 1000123
  fallback_code bigint,               -- 同店备用机，可空
  primary key (store_id, role)
);

async function printForStore(storeId, role, doc) {
  const target = await db.getStorePrinter(storeId, role);
  if (!target) throw new Error(`${storeId} 没有配置 ${role} 打印机`);

  return sendJob(target.printer_code, doc, { storeId, role });
}

async function sendJob(printerCode, doc, meta) {
  const res = await fetch('https://api.printbase.cloud/v1/print-jobs', {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${process.env.PRINTBASE_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      printer_code: printerCode,
      content_type: doc.type,        // 'raw' 走 ESC/POS、ZPL；'pdf' 走文档
      content: doc.bytes.toString('base64'),
      copies: doc.copies ?? 1,
    }),
  });

  const job = await res.json();
  await db.recordPrintJob({ ...meta, jobId: job.id, printerCode });
  return job;
}

await printForStore('SH-001', 'receipt', renderReceipt(order));   // 小票
await printForStore('SH-001', 'kitchen', renderKitchenTicket(order)); // 后厨单

// POST /hooks/printbase —— 验签细节见文档
async function handleEvent(event) {
  const fresh = await db.markEventSeen(event.id);   // 幂等，按事件 ID 去重
  if (!fresh) return;

  const { job_id, status, reason_code, printer_name, computer_name } = event.data;
  const job = await db.findPrintJob(job_id);        // 拿回 storeId / role

  if (status === 'completed') {
    return db.markPrinted(job_id);
  }

  if (reason_code === 'PRINTER_OFFLINE' || reason_code === 'PRINT_ERROR') {
    const fallback = await db.getFallbackPrinter(job.storeId, job.role);
    if (fallback) {
      await sendJob(fallback, await db.reloadDoc(job_id), job);  // 切备用机
      return alertStore(job.storeId, `主${job.role}机异常，已切备用机`);
    }
  }

  await alertStore(
    job.storeId,
    `${printer_name}（${computer_name}）打印失败：${reason_code}`
  );
}

// 每天 08:30 跑一次，开门前
const printers = await listPrinters();
const expected = await db.allStorePrinters();          // 台账里应该在的

const offline = expected.filter((e) => {
  const p = printers.find((x) => x.code === e.printer_code);
  return !p || p.status !== 'online';
});

if (offline.length) {
  await notifyOps(
    offline.map((o) => `${o.store_id} / ${o.role}`).join('\n')
  );
}