超时时间暂为1分钟
监听流程开始
开始
因外部平台接口要求 每次请求商品数据有上限；京东为50；饿了么为100;
京东kafka监听
第二阶段
【京东kafka监听】是否暂停
商品库存集合数据超时监听
第一阶段
【待处理队列】toDoQueue 是否低于阀值（避免数据过多处理不过来）
判断业态门店 商品库存数据集合 是否到达上限；
是
饿了么kafka监听
外部平台
暂停 【京东kafka监听】 直到待处理队列达到重启阀值（目前为队列的一半）
结束
否
解析返回数据
监听kafka topic:stock-emj-push 库存变更消息数据
接口返回 限流错误；处理数据A1重新放入队列并 开启【暂停处理队列消息】1分钟后开关过期
存在数据
什么都不做；等待新kafka消息进池 使超过上限；或者该数据超时
数据【待处理队列】toDoQueue监听
发送给到家Emj
是否库存消息处理上限;（以防止消息接收过多引起内存问题）
组装外部平台接口数据；例如外部平台门店编码，外部平台商品编码等
循环处理
查询【外部平台商品表】只有表里的商品 才进行 库存同步操作
到达上限则放入【待处理队列】toDoQueue
生成kafka topic:stock-emj-push 库存变更消息数据
监听线程 每分钟 扫描 【数据缓冲池】；数据在池时间是否超时
接口返回成功或失败；记录成功及失败记录及原因
门店商品库存变更
不存在数据
到家Emj
解析组装数据；以业态门店为key 放入数据缓冲池；并记录key生成时间以便对超时数据做过期处理
放入【待处理队列】toDoQueue
外部平台库存增量同步
暂停或重启 【kafka监听】
流程处理类似 京东流程 篇幅有限 参考京东；
外部平台库存批量同步接口服务
返回
....... 略
美团kafka监听
用平台编码及到家业态门店数据，查询 【外部平台门店关系表】；是否存在关系
调用
【京东kafka监听】重启
是否【暂停处理队列消息】
库存中台
