如何基于Firestore与Google Cloud实现每日重置的无间隙分支连续订单号

核心思路 #

要实现无间隙、按区域每日重置的订单号，核心是借助Firestore事务+区域日期维度的计数器文档，保证多服务器并发场景下的原子性操作，避免断号或重复。同时在同一个事务流程中完成订单号生成、订单写入、目标集合同步三个关键步骤。

关键设计点 #

• 单独维护daily_counters集合，每个文档ID采用{区域ID}_{YYYY-MM-DD}格式（如us-west_2024-05-20），存储对应区域当日的最新订单序号。
• 利用Firestore事务的原子特性，在同一事务内完成：读取计数器→递增序号→生成订单号→写入订单文档→同步到指定第三方集合。
• 每日自动重置逻辑：因文档ID包含日期，次日会自动创建新的计数器文档，序号自然从1开始。

代码实现（Node.js示例） #

基于Firebase Admin SDK编写核心逻辑：

1. 初始化Admin SDK #

const admin = require('firebase-admin');
admin.initializeApp({
  credential: admin.credential.applicationDefault()
});
const db = admin.firestore();

2. 核心事务函数 #

async function generateDailyOrderNumber(regionId, orderData, targetCollection) {
  const today = new Date().toISOString().split('T')[0]; // 格式化日期为YYYY-MM-DD
  const counterDocId = `${regionId}_${today}`;
  const counterRef = db.collection('daily_counters').doc(counterDocId);

  // 启动Firestore事务，确保所有操作原子性执行
  const result = await db.runTransaction(async (transaction) => {
    const counterDoc = await transaction.get(counterRef);
    let currentSeq = 1;

    if (counterDoc.exists) {
      currentSeq = counterDoc.data().current_seq + 1;
    }

    // 自定义订单号格式，示例：区域缩写+日期+补位序号
    const orderNumber = `${regionId.slice(0,2).toUpperCase()}${today.replace(/-/g,'')}${String(currentSeq).padStart(5,'0')}`;

    // 1. 更新计数器文档
    transaction.set(counterRef, { current_seq: currentSeq }, { merge: true });

    // 2. 写入主订单集合（假设集合名为`orders`）
    const orderRef = db.collection('orders').doc();
    transaction.set(orderRef, {
      ...orderData,
      order_number: orderNumber,
      region: regionId,
      created_at: admin.firestore.FieldValue.serverTimestamp()
    });

    // 3. 同步写入指定的第三方集合
    const targetRef = db.collection(targetCollection).doc(orderRef.id);
    transaction.set(targetRef, {
      order_number: orderNumber,
      order_id: orderRef.id,
      region: regionId,
      synced_at: admin.firestore.FieldValue.serverTimestamp()
    });

    return { orderNumber, orderId: orderRef.id };
  });

  return result;
}

3. 调用示例 #

async function createOrder() {
  try {
    const orderData = {
      customer_id: 'user_123',
      total_amount: 99.99,
      items: [{ name: 'Product A', quantity: 1 }]
    };
    // 生成us-west区域订单，并同步到`order_sync`集合
    const result = await generateDailyOrderNumber('us-west', orderData, 'order_sync');
    console.log(`生成订单：${result.orderNumber}，订单ID：${result.orderId}`);
  } catch (error) {
    console.error('生成订单失败：', error);
  }
}

createOrder();

实现技巧与注意事项 #

• 并发冲突处理：Firestore事务会自动重试并发冲突的请求，确保序号不会重复或跳过，无需额外编写冲突处理逻辑。
• 旧计数器清理：可通过Cloud Functions定时触发（每日凌晨），删除N天前的计数器文档以节省存储：

exports.cleanOldCounters = functions.pubsub.schedule('0 0 * * *').timeZone('UTC').onRun(async (context) => {
  const cutoffDate = new Date();
  cutoffDate.setDate(cutoffDate.getDate() - 7); // 删除7天前的计数器
  const cutoffStr = cutoffDate.toISOString().split('T')[0];

  const countersSnapshot = await db.collection('daily_counters').get();
  const batch = db.batch();

  countersSnapshot.forEach(doc => {
    const docDate = doc.id.split('_')[1];
    if (docDate < cutoffStr) {
      batch.delete(doc.ref);
    }
  });

  await batch.commit();
  console.log(`清理了${countersSnapshot.size}个旧计数器文档`);
});

• 热点文档优化：若某区域单日订单量极大，计数器文档可能成为性能热点。可考虑按小时拆分计数器（如us-west_2024-05-20_14），但会增加逻辑复杂度，大部分场景下单日单区域订单量不会触发该问题。
• 订单号格式自定义：可根据业务需求调整格式，比如增加业务前缀、调整序号位数，确保可读性与唯一性。

内容的提问来源于stack exchange，提问作者Omar Dulaimi