异步数据同步与对账试单

这是一个只使用虚构数据的可验收样例，用来证明按任务交付时的基本工程边界。它不会访问网络、数据库或真实客户文件，也不会修改输入目录。

English summary: a standard-library Python demo for idempotent CSV event ingestion, conflict quarantine, latest-state reconciliation, retry scheduling, terminal-error isolation, and machine-readable run summaries. All included records are synthetic.

能解决什么

• 合并多个来源的订单事件；
• 用 event_id 做幂等去重；
• 相同 event_id 内容冲突时隔离，不猜测覆盖；
• 按 updated_at 生成每个订单的当前状态；
• 对可重试错误生成指数退避队列；
• 把永久错误、重试耗尽和字段错误写入异常表；
• 输出结构化运行汇总，便于监控或接入后续流程。

运行

python .\sync_orders.py
python -m unittest -v .\test_sync_orders.py

输入约定

每个 CSV 必须包含：

event_id, order_id, updated_at, customer_code, amount, status, sync_result, retry_count

• updated_at 必须为带时区的 ISO 8601 时间；
• status 可为 pending、paid、refunded、cancelled；
• sync_result 可为 ok、retryable_error、permanent_error；
• 示例中的客户编号、订单号、金额均为虚构。

输出

• event_log.csv：通过校验的唯一事件；
• current_orders.csv：每个订单的最新状态；
• duplicates.csv：内容完全一致的重复事件；
• retry_queue.csv：尚未超过重试上限的任务；
• exceptions.csv：字段错误、冲突、永久错误和重试耗尽；
• run_summary.json：本次运行的聚合计数。

正式试单时，先书面确认字段映射、幂等键、冲突规则、重试上限、验收样例和数据授权；本样例不代表客户真实业务规则。

付费定制

如果需要把相同边界应用到已有 CSV、Excel 导出、内部 API 或固定报表流程，可先提交脱敏需求和验收样例：

https://excel-local-tools.liuqi985181210.chatgpt.site/#inquiry

开始前会书面确认数据授权、输入输出、异常规则、交付时间和一次性费用；不接收未经授权的真实客户文件。