外卖小程序对接的订单同步架构:从门店小票到美团饿了么的消息链路设计

简介: 2026 年再回看外卖小程序对接,真正难的从来不是“能不能把美团的单拉进来”,而是订单进来之后那一条看不见的消息链路:门店小票什么时候打、状态怎么在自家系统和平台之间双向流转、每天打烊后两边的账怎么对平。一次重复推送就可能让后厨出两份餐,一次对账遗漏就会让商家以为漏了单。这篇不聊选型,只聊工程——把订单表设计、幂等处理、消息队列解耦、小票图片存储、通知触达和定时对账这几块拆开,说清楚每一块的结构和一致性要求。存储侧我们用 RDS 承载订单业务数据,门店小票这类图片文件放 OSS,订单状态变动的通知走短信服务,每天的对账跑在函数计算上。

一、订单表怎么设计:一张主表加流水

订单主表记一笔外卖订单的当前状态,流水表记它经历过的每一次状态变更。只留主表不留流水,后面排查“这单到底卡在哪一步”时就两眼一抹黑。

order_main: id, channel(meituan/eleme), channel_order_no,

store_id, amount, status, created_at, updated_at

order_event: id, order_id, from_status, to_status,

payload(JSON), occurred_at

channel_order_no 是平台那边的订单号,和自家 order_id 双轨对应。这一列要建唯一索引——同一个平台订单号无论被推送多少次,在主表里只能落一条记录,这是后面幂等的地基。

二、幂等处理:重复推送是常态不是例外

平台推送新单、推送状态变更,都可能因为网络超时而重试。你的回调接口如果不做幂等,同一笔单就会被建两次。

做法很直接:收到推送先按 channel_order_no 查主表,已存在就跳过创建、只补事件流水;不存在才插入主表。整个“查—插”放在一个事务里,靠那个唯一索引兜底。

on_order_push(payload):
no = payload.channel_order_no
if exists(order_main, no):
write_event(no, payload); return 'duplicate_ok'
insert_order_main(payload) -- 唯一索引冲突即说明已被并发插入

状态回写同理:把“待接单→已接单”这条转换做成条件更新,只有当库里当前状态确实是待接单时才翻过去,重复的旧状态推送不会把已经出餐的单又改回待接单。

三、消息队列解耦:别在回调里干重活

平台的回调接口要求你几毫秒内返回成功,不然它会一直重推。所以回调里只做一件事:验签、落一条原始消息到队列,立刻返回成功。真正的解析、建单、打小票、通知,全部异步消费。

这样做的好处是把“对平台负责”和“对业务负责”拆成两段。平台只等你确认收到,慢一点的业务处理不影响它的重试判断。消费失败的消息进重试队列,超过次数进死信队列人工介入,不会因为一次抖动就丢单。

四、小票图片:别把二进制塞进数据库

后厨要打的小票、用户的支付凭证截图、餐品打包照片,这些都是文件,不进 RDS。业务表只存一个文件标识,真正的文件放对象存储:

order_receipt: order_id, oss_key, uploaded_at

上传成功后把 oss_key 写回订单,库里不存图片字节

小票机出单时按 oss_key 去取图片,打完即焚。订单量一大,把图片字节塞数据库会让 RDS 的备份和查询都变慢,这是早期最容易犯的错。

五、通知触达:状态变更给商家和顾客发条短信

新单进来、骑手到店、订单完成这几个关键节点,要让商家和顾客及时知道。通知别自己养通道,统一走短信服务:业务系统只在状态翻转时发一条消息,由短信服务按报备好的模板发出,不占业务服务的资源。通知和主流程解耦——短信发失败了不能反过来让订单回滚。

六、对账机制:每天打烊后跑一遍

白天订单实时流转,晚上要做一次对账:自家系统里今天每个渠道的订单数、金额,和平台侧导出来的流水,逐笔勾稽。对不上的单子挂异常表,第二天人工核查。

这种按日跑的批处理很适合放在函数计算上:定个每天打烊后的触发器,扫当天已完结订单聚合出每个渠道的总数和总额,和平台流水比对,生成对账差异报告。平时不占常驻机器,到点拉起、算完释放。

daily_reconcile():
for ch in [meituan, eleme]:
ours = agg(order_main, ch, today)
theirs = import_channel_file(ch, today)
diff = compare(ours, theirs)

if diff: write_exception_report(diff)

七、适用规模与技术局限

主表加事件流水、回调幂等、队列异步、文件对象化、定时对账,这一套足够支撑单店到几十家连锁门店的外卖对接,工程重心在一致性和可对账,而不是复杂的营销玩法。

边界也要说清楚。日订单到十万级以上,order_event 这种流水表要按时间分片,别和主表挤在一起;多渠道多门店时订单主表要挂门店标识做隔离;对账涉及金额,差异处理要留全量操作痕迹,谁、什么时候、把哪笔单调成了什么样,都能追。规模没到之前别过早分库,先把幂等和对账做扎实,这两件事才是这类系统的命门。

几个常被问到的点

问:为什么回调里不能直接建单?答:回调要秒级返回,建单、打小票、通知链路长,一旦卡住平台会疯狂重推。落队列异步化,回调只管确认收到。

问:重复推送为什么不会建两次单?答:平台订单号唯一索引加事务,查到已存在就只补事件流水,重复请求天然幂等。

问:小票为什么不放数据库?答:图片字节会拖慢 RDS 备份与查询,对象存储更便宜且自带冗余,库里只存文件标识。

相关文章
|
24天前
|
缓存 自然语言处理 搜索推荐
多语言外贸网站的国际化架构:URL设计、hreflang信号与静态资源多区域加速的工程实践
2026 年再看多语言外贸网站,容易被低估的往往不是翻译工作量,而是国际化架构本身——URL 怎么设计搜索引擎才分得清语种、翻译后的静态资源怎么在多区域就近加速、hreflang 信号上线后怎么持续校验不退化。这篇不聊选型,只聊工程:把一个面向多语种市场的站点,从 URL 骨架、hreflang 双通道、静态资源多区域分发,到线上巡检这几块拆清楚,说清楚每一块在云上怎么落地。 一、URL 设计:子目录为主,权重收拢 多语种站点的 URL 结构有国家顶级域名、子域名、子目录三种。工程上对大多数团队,子目录是默认起点:example.
|
28天前
|
负载均衡 关系型数据库 MySQL
CRM 线索到商机的数据模型设计:五表关系、线索去重与分配引擎的工程实践
2026 年再回看自己前几年搭过的几套 CRM,踩过的坑几乎都不在功能列表上,而在底层数据模型。同一个客户被三个销售反复跟、销售离职客户资产跟着走、官网留资谁也不知道——这些问题表面是流程问题,根子是线索、客户、联系人几张表的关系没设计对。这篇把我这几年在线索到商机这条链路上的表结构、去重、分配和埋点做法整理一遍,顺便交代一下落到云上时怎么对接,给要自己搭、或者要评审供应商方案的同行做个参考。
|
10天前
|
小程序 网络安全 数据安全/隐私保护
做问卷报名小程序要多少钱?表单收集小程序从选型到上线的完整攻略
问卷、报名、投票类表单小程序的价格从几百到上万都有,差别在表单能力、数据量、支付核销和品牌定制。本文按模板、SaaS、定制三条路线拆解价格构成,并给出按场景选型的完整建议。
|
1月前
|
存储 人工智能 供应链
企业 AI 最大的问题,不是数据不足,而是数据没有业务语义
本文探讨企业AI落地的核心瓶颈:非数据量不足,而是缺乏统一语义体系。指出业务模型的基础是“语义”——需明确定义客户、产品等业务对象及其关系,构建可被AI理解的业务世界,实现从数据记录到业务推理的关键跃迁。
107 3
|
28天前
|
存储 关系型数据库 Serverless
B2B2C 多商户商城的分润结算模型:商户入驻、订单分账与佣金引擎的工程实践
2026 年再回看 B2B2C 多商户商城,技术团队最容易低估的部分,往往不是前台开店、装修、上架这些看得见的功能,而是藏在订单背后的分润结算。一旦平台上的商户从几家涨到几十上百家,新订单进来时佣金该算给谁、什么时候结算、商户提现怎么和总账对平,任何一处不一致都会变成客诉和资金纠纷。 这篇不聊选型,只聊工程:把一个多商户平台拆成商户入驻审核流、商户隔离数据模型、订单分账与佣金引擎、定时结算这四块
|
22天前
|
存储 人工智能 自然语言处理
Semantic Kernel智能化应用框架实践:打通大模型提示词、函数调用与Agent开发链路24.6
Semantic Kernel(SK)是开源的轻量级大模型编排框架,统一管理提示词、原生函数、向量记忆与智能规划,支持.NET/Python/Java,深度集成Azure,强调语义与原生函数统一调度,降低AI应用开发复杂度。
119 2
|
25天前
|
人工智能 运维 安全
什么是AI时代被需要的程序员?会把经验 “翻译“ 给AI的人,开始涨价
本文探讨程序员在AI落地中的真实困境:不缺认知,缺的是将AI融入日常研发的能力。从学习边界、工程经验迁移到组织协同,剖析技术负责人如何跨越“知道”与“做到”的鸿沟。提出FDE与OPC新角色,强调“AI商”——把经验翻译成AI可执行规则的能力,才是AI时代工程师的核心竞争力。(239字)
128 3
|
3月前
|
人工智能 DataWorks 调度
DataWorks AI 助理盯公告,关键变更不漏看
阿里云DataWorks公告AI助理,自动拉取RSS、按关键词筛选并解析影响面,精准推送至IM群,实现关键变更近实时触达,减少团队信息差。
281 1
|
3月前
|
存储 人工智能 缓存
阿里云 ES AI 引擎版:面向 Agent 场景,为亿级租户、千亿规模向量设计的搜索引擎
基于 OSS 的无状态多租户搜索方案:全文、向量混合检索,亿级租户、千亿级向量,成本只与活跃数据线性相关,完全兼容 Elasticsearch 生态。 亿级租户 · 千亿级向量 · 毫秒级查询 · OSS 唯一持久存储 · Agentic Engine
456 0