1. 业务流程概述
2. 系统流程图
整体交易-履约-售后主流程（简化视图）
flowchart LR
A[用户渠道 Web/App/小程序/直播] --> B[购物车/结算]
B --> C{风控预检}
C -- 低风险 --> D[提交订单]
C -- 高风险 --> C1[二次校验/拦截] -->|失败| X[终止/人工复核]
D --> E[库存预占]
D --> F[支付发起(组合支付)]
F --> G{支付结果}
G -- 成功 --> H[库存实占(确认)]
H --> I[订单拆分(商家/仓/温控)]
I --> J[WMS拣货/称重/打包/出库]
J --> K[TMS承运商/面单/轨迹]
K --> L{签收}
L -- 部分签收 --> L1[部分发货继续履约]
L -- 全部签收 --> M[完成/进入售后窗口]
G -- 失败/超时 --> R[释放库存预占]
M --> N[售后申请(仅退/退货/换货)]
N --> O[逆向物流/质检/入库]
O --> P[退款/换货出库]
P --> Q[结算与对账/发票]
订单状态机
stateDiagram-v2
[*] --> CREATED : 提交订单/预占成功
CREATED --> PENDING_PAY : 等待支付
PENDING_PAY --> PAID : 支付成功/实占确认
PENDING_PAY --> CANCELLED : 超时未支付/风控拦截
PAID --> SPLIT : 按商家/仓/温控拆单
SPLIT --> FULFILLING : 下发WMS
FULFILLING --> PARTIALLY_SHIPPED : 部分包裹出库
PARTIALLY_SHIPPED --> SHIPPED : 全部出库
SHIPPED --> DELIVERED : 全部签收
DELIVERED --> COMPLETED : 售后期届满
PAID --> CLOSED : 全额退款（未发货）
CREATED --> CLOSED : 预占失败/回滚
CANCELLED --> [*]
COMPLETED --> [*]
CLOSED --> [*]
支付状态机（组合支付示意）
stateDiagram-v2
[*] --> INITIATED : 下单后发起
INITIATED --> PENDING : 跳转/调起三方
PENDING --> SUCCESS : 回调校验通过
PENDING --> FAILED : 回调失败/签名不通过
SUCCESS --> PARTIAL_REFUND : 部分退款
SUCCESS --> REFUNDED : 全额退款
FAILED --> CANCELLED
REFUNDED --> [*]
CANCELLED --> [*]
库存占用状态机
stateDiagram-v2
[*] --> PRE_RESERVED : 提交订单
PRE_RESERVED --> CONFIRMED : 支付成功
PRE_RESERVED --> RELEASED : 超时/取消/失败
CONFIRMED --> DEDUCTED : 出库扣减
RELEASED --> [*]
DEDUCTED --> [*]
履约（包裹维度）
stateDiagram-v2
[*] --> TO_PICK
TO_PICK --> PICKING
PICKING --> PACKED
PACKED --> OUTBOUND
OUTBOUND --> IN_TRANSIT
IN_TRANSIT --> DELIVERY_ATTEMPT
DELIVERY_ATTEMPT --> DELIVERED
DELIVERY_ATTEMPT --> EXCEPTION : 拒收/破损
EXCEPTION --> CLAIMS : 判责理赔
DELIVERED --> [*]
CLAIMS --> [*]
售后状态机
stateDiagram-v2
[*] --> APPLIED
APPLIED --> APPROVED : 自动/人工审核通过
APPLIED --> REJECTED
APPROVED --> AWAIT_RETURN : 需要退货
AWAIT_RETURN --> RETURN_IN_TRANSIT
RETURN_IN_TRANSIT --> QC_CHECK
QC_CHECK --> REFUND_APPROVED
QC_CHECK --> REFUND_REJECTED
REFUND_APPROVED --> REFUNDED
APPROVED --> EXCHANGE_FULFILL : 换货出库
REFUNDED --> [*]
EXCHANGE_FULFILL --> [*]
REJECTED --> [*]
结算/对账状态机（商家维度）
stateDiagram-v2
[*] --> STATEMENT_GENERATED
STATEMENT_GENERATED --> MERCHANT_CONFIRMED
MERCHANT_CONFIRMED --> PAID_OUT
STATEMENT_GENERATED --> ADJUSTED : 售后逆向调账
PAID_OUT --> CLOSED
CLOSED --> [*]
3. 功能模块说明
-
用户与会员中心
- 职责：统一用户ID、登录/SSO、设备指纹、会员等级与权益、积分、余额账户
- 交互：与价格中心（会员价）、风控（设备、黑名单）、支付（余额）、消息推送
- 数据：用户、会员等级、权益规则、账户余额、设备指纹
-
商品与目录（PIM）
- 职责：SPU/SKU、多规格、类目、属性、媒体、区域可售规则、上下架
- 交互：价格中心（价格计算）、库存服务（展示库存）、搜索服务、OMS（下单校验可售）
- 数据：SKU主数据、可售区域、温控属性、重量/体积
-
价格与促销中心
- 职责：实时/离线价格、促销（折扣/满减/满赠/阶梯）、优惠券、会员价、叠加/排他规则、分摊
- 交互：购物车/结算（试算）、订单（锁价/价单）、结算（促销分摊）、数据仓库（价格快照）
- 数据：价目表、促销规则、优惠券模板与实例、价单快照
-
购物车与结算
- 职责：购物车合单/分组、库存试探、配送时效、运费试算、发票要素、风控预检、试算接口
- 交互：价格中心、库存服务、地址服务、风控引擎、OMS
- 数据：购物车项、结算上下文（券/活动/地址/时效）
-
风控引擎
- 职责：设备指纹/黑名单/规则引擎/模型评分；下单前、支付前校验；策略（阈值、限频、二次校验）
- 交互：OMS/支付网关；用户中心（设备/历史）、数据仓库（特征）、消息（风险事件）
- 数据：规则、名单、风险事件、交易画像
-
订单中心（OMS）
- 职责：订单写入、状态机、拆单（商家/仓/温控）、包裹维度履约、部分发货、合单签收、售后窗口
- 交互：库存服务（预占/确认/释放）、支付网关、WMS/TMS、售后、结算、消息总线、发票
- 数据：主订单、子订单、包裹、物流单、价单快照、发票信息
-
库存与分配服务
- 职责：库存模型（可售/锁定/物理）、多仓逻辑、区域库存、预占->实占->扣减、释放、超卖防控、热点SKU保护
- 交互：OMS、WMS（出入库）、PIM（SKU属性）、TMS（干线/同城策略）
- 数据：仓-货位-批次库存、预占记录、调拨与盘点
-
支付网关
- 职责：统一对接第三方（微信/支付宝/银行卡等）、组合支付编排（余额+三方）、回调验签、退款
- 交互：OMS（支付状态）、财务（对账）、风控（支付前校验）
- 数据：支付订单、分账信息、交易流水、对账明细
-
履约（WMS/TMS集成层）
- 职责：WMS波次拣货、称重、打包、出库；TMS承运商选择、电子面单、轨迹回传；同城即时/干线路由
- 交互：OMS、库存服务、承运商、隐私号服务、理赔系统
- 数据：拣货任务、包裹重量、面单号、轨迹事件、签收记录
-
售后与客服
- 职责：RMA流程（仅退/退货/换货）、逆向物流、质检、退款/补发、证据流与仲裁、工单联动
- 交互：OMS、支付网关（退款）、WMS（退回入库）、客服工单、价格中心（分摊回退）
- 数据：售后单、退货单、证据存储、质检记录
-
结算与对账
- 职责：支付渠道日对账；平台-商家账期结算（佣金、促销分摊、运费、逆向调账）；发票开具
- 交互：支付网关、OMS/售后（明细）、商家中心、电子发票服务、数据仓库
- 数据：对账单、差异清单、结算单、发票抬头/明细
-
特殊场景能力
- 预售：定金锁资格/配额、尾款支付窗口、逾期释放；发货节点基于备货期
- 拼团：开团/参团、成团判定、失败自动退款；库存按成团扣减策略可配置
- 虚拟商品：码池管理、发码服务、自动交付与补码；无需物流
- 跨境：身份与清关资料采集、电子面单报关要素、跨境税费计算
-
基础设施与平台
- API网关、服务注册/配置、消息总线（Kafka/Pulsar 类）、任务调度、文件存储（证据/面单/发票PDF）、监控告警、审计与合规
- 数据仓库与实时数仓：指标口径、ODS/DWD/DWS、用户/商品/交易/履约主题域
4. 数据流程分析
flowchart LR
U[前台] -->|checkout/submit| O[OMS]
O -->|reserve| S[库存服务]
O -->|initiate| P[支付网关]
P -->|callback(event)| O
O -->|confirm| S
O -->|split&fulfill| W[WMS]
W -->|ship_event| O
O -->|waybill/track| T[TMS]
T -->|track_event| O
O -->|notify| M[消息推送]
O -->|fact| DW[数据仓库]
AF[售后] --> P
AF --> W
AF --> O
P --> RZ[对账/结算]
O --> RZ
-
关键领域数据模型（高层）
- 用户：user_id, level, device_fingerprint, balance
- 商品SKU：sku_id, spu_id, attrs, region_rules, temp_ctrl, weight, volume
- 价格：price_list_id, sku_id, base_price, promo_rules, member_price, coupon_applications, price_snapshot
- 订单：order_id, buyer_id, merchant_id, address, invoice, delivery_time, status, price_snapshot_id, risk_score
- 子订单/包裹：sub_order_id, warehouse_id, temp_ctrl, package_id, logistics_no, weight
- 库存：warehouse_id, sku_id, on_hand, available, pre_reserved, locked, batch
- 支付：pay_order_no, order_id, pay_channel, amount, status, refund_status
- 售后：rma_id, type, reason, evidence_refs, status, qc_result, refund_amount
- 对账/结算：channel_stmt_id, merchant_stmt_id, fees, promo_apportion, logistics_fee, adjustments
- 事件：event_id, type, entity_id, payload, occurred_at
-
事件清单（建议主题命名，关键消费方）
- order.created/order.paid/order.split/order.shipped/order.delivered/order.completed/order.cancelled（DW、消息推送、风控回溯、推荐）
- payment.initiated/payment.succeeded/payment.failed/payment.refunded（对账、OMS）
- inventory.reserved/inventory.confirmed/inventory.released（OMS、DW）
- fulfillment.picking/packed/shipped（OMS、客服、DW）
- logistics.tracking.updated/delivered/exception（OMS、客服）
- aftersale.applied/approved/rejected/refunded/exchange.shipped（对账、DW、消息）
- settlement.statement.generated/paid/adjusted（DW、商家中心）
-
幂等与一致性策略
- 业务幂等键
- 下单：clientOrderNo（客户端生成），配合用户ID + 幂等窗口；服务端返回相同order_id
- 支付：outTradeNo（每次发起唯一），组合支付各子交易单独outTradeNo
- 退款：outRefundNo 唯一
- 接口级幂等：要求 Idempotency-Key header + 去重表（幂等窗口TTL）
- 事件幂等：事件event_id全局唯一，消费者侧记录已处理offset或event_id去重表
- 库存原子性：单SKU使用Redis原子脚本/内存队列处理预占扣减；跨SKU用分段锁；强一致需要本地事务 + Outbox
- 分布式一致性
- 订单-库存-支付采用Saga编排：步骤（预占库存 -> 发起支付 -> 支付成功确认实占；失败补偿释放库存）
- Outbox/事务消息：订单/支付写本地库与Outbox同事务，消息总线异步投递，消费者幂等处理
- 回滚场景
- 支付回调失败/超时：OMS延时任务触发释放预占；回调重试并校验签名与金额
- 部分退款：订单维持完成/发货状态，价单与结算明细记录逆向分摊
-
接口契约草案（节选示例，字段可扩展）
- 结算试算
- POST /checkout/preview
- 请求：user_id, items[{sku_id, qty}], address_id, coupon_ids[], delivery_time_window, invoice_req
- 响应：items_price, promo_detail[], shipping_fee, pay_amount, delivery_options[], invoice_options, risk_flag
- 提交订单
- POST /orders with Idempotency-Key
- 请求：client_order_no, user_id, items[{sku_id, qty, price_snap_id}], address, delivery, invoice, coupon_ids, balance_pay_amount
- 响应：order_id, pay_order_no, payable_amount, pay_channels[], reserve_result
- 支付发起
- POST /payments/initiate
- 请求：pay_order_no, channel, amount, subject, return_url, notify_url, split_info?
- 响应：pay_params（跳转/唤起参数），out_trade_no
- 支付回调（网关->平台）
- POST /payments/callback
- 请求：out_trade_no, pay_order_no, status, paid_amount, pay_time, sign
- 响应：200/重复处理返回OK（幂等）
- 库存接口
- POST /inventory/reserve: order_id, items[{sku_id, qty, warehouse_strategy_ctx}]
- POST /inventory/confirm: order_id
- POST /inventory/release: order_id, reason
- 履约与物流
- POST /wms/fulfill/push: sub_order_id, sku_list, address, remark
- POST /wms/callback/pack/ship: package_id, weight, logistics_no, ship_time
- POST /tms/callback/track: logistics_no, status, location, time
- 售后
- POST /aftersales/apply: order_id/sub_order_id, type, items, reason, evidence[]
- POST /refunds/initiate: pay_order_no/out_trade_no, amount, out_refund_no
- POST /refunds/callback: out_refund_no, status, amount, time, sign
- 结算与发票
- GET /settlements/merchant/{id}/statements?period=
- POST /invoice/issue: order_id, invoice_type, title, tax_no, email
-
订单拆单与仓配分配策略（要点）
- 拆单维度：商家 -> 仓库 -> 温控（常温/冷藏/冷冻） -> 时效
- 多仓选择：最近库存优先、成本模型（运费/税费/处理成本）、同城即时可用性
- 部分发货：子订单/包裹独立履约与状态；签收后再触发下一批
- 合单签收：多个包裹到齐且签收成功后，订单聚合状态进入DELIVERED
-
特殊场景数据流
- 预售（定金/尾款）
- 下单1：定金支付成功 -> 锁资格（或锁配额，不占物理库存）-> 待尾款窗口
- 尾款期：支付成功 -> 转实占库存 -> 进入履约；逾期未付 -> 资格释放，定金退还/违约金策略可配置
- 拼团
- 开团事件 -> 团状态pending；参团成功计数 -> 成团事件 -> 统一推动支付/履约
- 未成团截止 -> 自动退款 -> 释放预占（如预占）
- 虚拟商品
- 支付成功 -> 码池锁定与发码 -> 短信/站内信通知；失败补码策略重试
- 跨境
- 下单时收集身份证/清关资料 -> 出库前生成报关要素 -> TMS报关接口 -> 放行后发运
5. 技术建议
-
容量与扩展性（需压测校准）
- 峰值估算（示例，按日活与大促倍率预估，后续以压测确认）
- PV：> 50k QPS 峰值
- 结算试算：3–5k QPS
- 下单创建：1–2k QPS
- 支付回调：1–3k QPS 短时尖峰
- 扩展手段
- 水平扩展：无状态服务多副本 + HPA；热点SKU隔离队列
- 数据分片：订单库按时间 + buyer_id/merchant_id hash 分库分表；库存按SKU/仓分片
- 缓存：SKU与价格缓存（Redis/本地缓存），预热 + 双写一致性（延时淘汰）；库存读缓存 + 写穿透到存储
- 异步解耦：事件总线（Kafka/Pulsar 类）承载支付/物流/售后事件；下单链路最小化同步调用
- 搜索与明细查询采用CQRS：写库与读索引（ES/ClickHouse）分离
- 静态资源/CDN与页面降级（大促模板化页面、静态化部分详情）
- 流量整形：排队/令牌桶/动态限流；秒杀或预售使用资格令牌
-
高并发库存与防超卖
- 预占基于Redis原子Lua或库存微服务内存队列 + 顺序日志；落地MySQL/存储的最终一致校对任务
- 热点SKU分片与隔离队列，限流到可售库存上限；展示库存做“可见度控制”（不暴露真实库存）
- 异常补偿：对账任务扫描订单与库存差异，自动修正/告警
-
价格与促销性能
- 规则编译与缓存（规则AST预编译）；热促销局部重算；券核销占位（下单时锁券）
- 价单快照在下单冻结，避免事后重算偏差
-
支付与对账安全
- 回调验签、重复回调幂等；金额与订单状态交叉校验
- 渠道日对账自动比对差异清单；分账与担保交易按商家合规要求配置
- 敏感信息脱敏与密钥管理（KMS）
-
风控与合规
- 规则+模型组合，实时评分在下单与支付前执行；高风险触发二次验证（短信/人脸）
- 黑名单/设备指纹/频控统一服务；回溯样本入数仓用于模型训练
- 合规：用户隐私、电子发票、跨境报关、电话隐私号
-
可观测性与稳定性
- 指标：链路SLO（下单P99、支付回调延迟、WMS响应、TMS轨迹延迟）、错误率、库存差异率
- 全链路Tracing（OpenTelemetry）、结构化日志与审计
- 混沌工程演练：支付回调延迟、库存服务降级、WMS回调丢失等
-
数据仓库与指标
- 主题域：用户、商品、交易、履约、售后、财务
- 指标：转化漏斗（曝光->加购->结算->支付）、客单价、履约时效（下单->出库->签收）、拒收率、售后率、库存周转天数
- 实时流：支付成功、出库、签收、退款 实时宽表，用于运营看板
-
上线里程碑（建议）
- 里程碑0（2–3周）：详细方案评审与原型（下单-库存-支付-履约主链路），事件总线与幂等基线
- 里程碑1（4–6周）：MVP自营场景上线：商品/价格、购物车/结算、OMS、库存预占/实占、支付、WMS/TMS对接、基础售后（仅退款），对账初版；性能压测1
- 里程碑2（4周）：Marketplace与拆单/分仓、全面售后（退货/换货）、结算与发票、客服工单联动；性能压测2与大促演练
- 里程碑3（3–4周）：预售（定金/尾款）、拼团、虚拟发码、同城即时配送；风控增强
- 里程碑4（3周）：跨境清关、合规模块、商家结算优化、促销分摊完善；灰度与稳定性提升
- 每阶段交付：接口契约文档、状态机说明、集成联调用例、回归测试报告、压测与容量报告、运行手册与应急预案
-
测试与演练建议
- 场景用例矩阵：组合支付、部分发货、逆向退款、预售尾款超时、拼团失败退款、物流异常签收
- 压测：读写分离、热点SKU、长尾SKU、回调风暴；幂等正确性验证
- 演练：消息丢失/乱序、支付回调延迟、库存服务降级、WMS回调失败重试
-
部署与数据
- 多活/同城双活优先读一致、写入通过幂等与消息重试保障；跨AZ部署
- 关键库（订单、支付、库存）采用主从 + 半同步，读写隔离
- 版本发布：灰度/金丝雀；开关开闭环（活动/价格/库存策略可动态切换）
- 数据治理：主数据管理（商品、商家、仓库）、口径与标签管理
以上方案覆盖“下单-支付-仓配-售后”全链路与特殊场景，提供状态机、模块边界、数据/事件流与幂等策略、接口草案、容量与上线里程碑。后续可根据具体业务规模与合规要求，细化技术选型与性能目标，并通过压测与灰度逐步达成大促稳定目标。
