从建设到运营，
陪伴企业成长的
AI 驱动的 IT 伙伴

1. 1
2. 2
3. 3
4. 4
5. 5
6. 6
7. 7
8. 8
9. 9
10. 10
11. 11
12. 12
13. 13
14. 14
15. 15
16. 16
17. 17
18. 18
19. 19
20. 20
21. 21
22. 22
23. 23
24. 24

// services/erp/sync/orders.ts
export const Order = z.object({
  id: z.string().uuid(),
  sku: z.string().regex(/^[A-Z]{3}-\d{4}$/),
  qty: z.number().int().positive(),
  channel: z.enum(["web", "app", "b2b"]),
});
 
export async function* syncOrders<T extends z.infer<typeof Order>>(
  source: AsyncIterable<unknown>,
  { batch = 500, signal }: SyncOptions = {},
): AsyncGenerator<SyncResult<T>, void, undefined> {
  const buffer: T[] = [];
  for await (const raw of source) {
    if (signal?.aborted) return;
    const row = Order.safeParse(raw);
    if (!row.success) { yield { ok: false, issues: row.error.issues }; continue; }
    if (buffer.push(row.data as T) < batch) continue;
    yield await withRetry(() => commit(buffer.splice(0)), {
      attempts: 5,
      delay: (n) => Math.min(2 ** n * 200, 8_000),
    });
  }
}