pirate消息流转梳理

并单

是

组-订单订单包批量取消

该组订单全都已终结

否

是众包？

调度推荐？

组-pirate高级分配订单

单-pirate订单被抢

单-task订单resend

组或单

是否存在？

塞缓存

组-pirate组订单被重复抢

组订单？

订单存在，状态-0

单-调度派单推荐消息

单-调度已被派出消息

单-订单订单取消

是resend？

通知骑手

组-task组订单resend

缓存（骑手-订单关系）强推荐单A. 骑手的强推荐单列表pirate:ro:rider:{riderId} value是订单id集合 B. 骑手的调度强推荐单列表pirate:dro:rider:{riderId} value是订单id集合

单-调度第一次派单失败（抢派混合）

清缓存（orderId）

通知骑手#骑手通知间隔控制A. 常规单pirate:ogn:rider:{riderId} value是时间戳，过期时间可配，3分钟只通知key失效的骑手

单-订单订单创建（非抢派混合）

单-pirate订单被重复抢

塞缓存（orderId）获取其中一单已通知的骑手集合（old）新找到的骑手集合（new）清除old相关的缓存，塞new相关缓存

单-pirate高级分配订单

并单调度接口-并单，获取订单集合将订单集合设置一样的outterGroup

组-订单组订单创建

是组消息？

outterGroup是dwd开头？

查找骑手按照DispatchAbleTm从小到大排序调度接口-查找骑手集合

满足强推荐规则？满足同城强交互强推荐规则/满足饿了么长距离强推荐规则/是调度兜底强推荐

单-调度兜底强推荐消息

缓存（组订单）A. 组id与组订单id的对应关系pirate:go:mp:GROUP-{outterGroup} value是订单id集合

组-订单组订单取消

按照outterGroup

清缓存（outterGroup）

组-调度派单推荐消息

单-调度人工派单

缓存

outterGroup是dwd开头

塞缓存（outterGroup）

组-pirate组订单被抢

组-订单订单包批量转单

单-订单订单转单

有outterGroup

通知骑手#骑手通知间隔控制A. 强推荐单pirate:rogn:rider:{riderId} value是时间戳，过期时间可配，3分钟只通知key失效的骑手

缓存（骑手-订单关系）常规单A. 当前订单推送给了哪些快递员，当订单被接了以后会删除pirate:o:ptr:{orderIdOrGroupId} value是骑手id集合B. 快递员待抢单列表pirate:r:rol:n:{riderId} value是订单id集合C. 快递员待抢单列表(驻店)pirate:r:rol:z:{riderId} value是订单id集合D. 快递员待抢单列表(任务)pirate:r:rol:t:{riderId} value是订单id集合