商品价格同步与下单冲突解决方案
目录
一、整体技术方案：保障价格实时同步 + 并发价格不一致兜底处理
一、第一部分：确保价格变更准确、及时同步到分销部 & 外部分销商（美团）
1. 架构分层梳理
2. 价格同步整体方案（推 + 拉结合，兼顾实时 + 兜底）
（1）实时主动推送（核心，保障及时性）
（2）定时轮询兜底（防消息丢失、推送失败，保障数据准确性）
（3）缓存设计（加速查询，避免 DB 压力）
（4）数据约束（防脏数据）
二、第二部分：页面旧价停留、下单时价格已更新的冲突场景优雅处理
场景复现
分层解决方案（从前端 → 分销服务 → 下单链路，逐级处理）
方案原则
1. 前端层：提前预警 + 页面自动刷新（前置规避）
2. 下单链路：核心校验 + 分场景优雅兜底（分销服务核心逻辑）
场景 1：差价较小、用户停留时间短（主流场景）
场景 2：差价较大、用户停留久（敏感场景）
场景 3：极端情况（价格回滚 / 临时促销撤销、并发改价）
3. 技术增强：下单请求防篡改 & 价格凭证
4. 补充：美团侧配合规则（外部渠道约定）
三、全链路异常告警 & 监控（保障长期稳定）
四、方案总结（精简落地版）
一、整体技术方案：保障价格实时同步 + 并发价格不一致兜底处理
结合微服务架构、内外 API 对接、异步同步、分布式一致性、下单链路防错两大核心问题，分价格同步架构、页面 & 下单时序冲突兜底两部分落地，兼顾实时性、最终一致性、业务优雅容错。
一、第一部分：确保价格变更准确、及时同步到分销部 & 外部分销商（美团）
1. 架构分层梳理
- 主站服务：商品源数据（官方售价）维护入口
- 分销微服务：存储渠道专属分销价、对接所有外部渠道（美团等）
- 外部渠道：美团（通过分销服务开放的 API 拉取 / 推送价格）
2. 价格同步整体方案（推 + 拉结合，兼顾实时 + 兜底）
（1）实时主动推送（核心，保障及时性）
采用事件驱动架构，替代单纯定时轮询，做到价格变更秒级感知。
主站商品价格变更事件发布运营修改官方价 / 渠道分销价时，主站服务完成 DB 落库后，立即发布消息到消息队列（RocketMQ/Kafka），消息体包含： 商品 ID、新旧官方价、渠道 ID（美团）、新旧分销价、变更时间戳、版本号。
- 消息投递：事务消息，保证「DB 更新成功 ↔ 消息发布成功」，杜绝漏发、重复发。
分销微服务消费事件分销服务作为消费者监听队列：
- 消费成功：更新本地分销价数据库 + 分布式缓存（Redis）；
- 消费失败：开启重试机制 + 死信队列，人工兜底排查，保证数据最终一致。
- 增加版本号 / 时间戳幂等：防止消息重复消费导致价格错乱。
分销服务主动推送给外部渠道（美团）分销服务本地价格更新完成后，调用美团开放 API 实时推送最新价格：
- 调用模式：同步调用 + 超时控制，记录调用日志、返回结果；
- 推送失败（网络 / 美团接口异常）：本地缓存失败任务，延时重试（阶梯重试：1s/5s/30s），重试耗尽进入异常工单告警。
（2）定时轮询兜底（防消息丢失、推送失败，保障数据准确性）
纯推送存在网络、MQ 故障风险，增加兜底补偿机制：
- 分销服务定时（如 5 分钟）主动拉取主站商品价格全量 / 增量数据，对比本地库存价格，不一致则强制更新并重新推送给美团。
- 美团侧也做双向兜底：美团定时调用分销 API 拉取最新价格，覆盖页面展示。
（3）缓存设计（加速查询，避免 DB 压力）
- 全量价格数据写入Redis 分布式缓存，设置合理过期时间；
- 价格变更时主动淘汰 / 更新对应 Key，所有内外查询优先走缓存；
- 缓存增加本地二级缓存（Caffeine），进一步降低 RT 与 Redis 压力，二级缓存短时效（10s）自动刷新。
（4）数据约束（防脏数据）
- 数据库层面：商品 + 渠道联合唯一索引，一条商品对应一个渠道仅一条价格记录；
- 所有价格变更操作加分布式锁（Redisson），防止高并发下多人同时改价导致覆盖；
- 价格变更全链路日志留痕（操作人、时间、新旧值、上下游调用结果），便于问题追溯。
二、第二部分：页面旧价停留、下单时价格已更新的冲突场景优雅处理
场景复现
用户美团页面加载旧价 100 元→ 停留在页面未操作 → 期间主站改价为 95/93 元，价格未及时同步到美团页面 → 用户后续点击下单。 核心矛盾：前端展示价 ≠ 服务端真实结算价，需兼顾用户体验、资金安全、业务规则。
分层解决方案（从前端 → 分销服务 → 下单链路，逐级处理）
方案原则
- 最终以服务端价格为准（资金安全第一，绝对不允许按过期旧价结算）；
- 交互优雅，减少用户反感，不粗暴直接报错；
- 区分轻度延迟、严重延迟两种场景差异化处理。
1. 前端层：提前预警 + 页面自动刷新（前置规避）
页面价格动态轮询美团商品页前端定时（15~30s）调用分销查询价格接口，自动刷新页面售价。 优点：大部分短停留用户，页面会自动更新为新价，从源头避免问题。
价格标签显性提示若检测到价格变动，页面增加轻量提示：
商品价格已更新，当前售价XX元，弱化突兀感。
2. 下单链路：核心校验 + 分场景优雅兜底（分销服务核心逻辑）
用户发起下单请求时，所有价格校验、结算、库存均以分销服务端实时价格为准，分 3 种场景处理：
场景 1：差价较小、用户停留时间短（主流场景）
处理逻辑：静默按新价结算 + 后台日志记录
- 前端下单请求到达分销服务，服务端拉取实时最新分销价（Redis+DB 双校验）；
- 直接按新价 93 元生成订单、扣款项；
- 前端展示：
商品价格已更新，本次下单按最新价格结算，正常完成下单。 - 适用：差价小、旺季常规改价，用户接受度高。
场景 2：差价较大、用户停留久（敏感场景）
处理逻辑：拦截下单 + 友好弹窗引导
- 分销服务对比「用户页面携带的展示价」和「服务端实时价」，差价超过阈值（如≥2 元）时，拒绝直接下单；
- 前端弹出标准提示文案：
温馨提示：该商品价格已发生变动，当前售价为 XX 元，请确认后重新下单。
- 自动刷新页面价格，用户确认后重新提交订单。
- 优势：避免用户因差价过大产生投诉，体验最优。
场景 3：极端情况（价格回滚 / 临时促销撤销、并发改价）
处理逻辑：订单锁定 + 人工 / 自动补偿
- 下单时服务端加订单预锁，锁定当前瞬时价格，防止下单过程中价格再次变动；
- 若出现价格反复波动，返回
商品状态变动，请稍后重试，引导用户稍后操作； - 已生成异常差价订单：后台统一标记，走售后补差 / 退款流程，配合客服兜底。
3. 技术增强：下单请求防篡改 & 价格凭证
- 前端传给分销服务时，页面展示价格做签名（Sign），服务端校验签名合法性，防止恶意篡改低价下单；
- 下单接口强制不信任前端传的价格，服务端强制查源价，前端价格仅做展示，不参与结算。
4. 补充：美团侧配合规则（外部渠道约定）
和美团约定接口规则：
- 美团下单接口禁止使用页面缓存价格，必须实时调用分销接口获取结算价；
- 双方约定价格同步最大容忍延迟，超时未同步自动告警。
三、全链路异常告警 & 监控（保障长期稳定）
- 监控指标：价格同步延迟、MQ 消费堆积、对外 API 推送失败率、价格不一致订单量；
- 告警机制：延迟超时、调用失败、异常订单触发短信 / 钉钉告警；
- 定时对账：每日凌晨主站、分销、美团三方价格数据自动对账，输出差异报表。
四、方案总结（精简落地版）
- 价格同步：以MQ 事件推送为主、定时拉取兜底，配合 Redis 缓存、分布式锁、消息幂等，实现价格秒级同步至分销及美团，保证准确及时；
- 页面 & 下单冲突：前端定时刷新价格做前置规避；下单强制以服务端实时价格为准，按差价大小分别做「静默结算」或「弹窗提醒重下单」，兼顾资金安全与用户体验；
- 全链路加日志、监控、对账、告警，形成完整闭环。