场次B-100元
uid_02
Split_Event
消费者组（根据积压自动调整消费数量）
分摊服务
场次D-100元
1月1日 10点退课
1月1日 8点调整
调整
场次D-80元
1月1日 11点教辅寄回
教辅回寄
Job1
场次A-80元
业务线
队列清单
已上课
1月1日 9点上课
退课
上课事件
未上课
时间线
首次分摊课程1
Queue_uid01_product1
扫库
场次A-100元
教辅回寄调整（侵入业务）
课程集合
队列数据拆解器（数据排序、归类）
场次减40
课程3
课程列表
1月1日 7点上课
课程1
Queue_uid01_product4
确收服务
根据事件时间排序
场次C-100元
为什么不是订单和场次？订单：粒度太粗，还需要转换场次：如果在课程纬度上有事件不太好处理，教辅回寄就是例子100条
consumer1
事件通知
消课确收单
1 号
场次C-80元
串行消费
确收服务确收单生成流程
正常购课消课
调整确收单
教辅
5 号
课程聚合服务
课程2
uid_01
Job2
consumer2
2 号
工厂模式
调整确收&新确收
3 号
Queue_uid01_product3
退课调整（侵入业务）
并行消费
生成计划单类型
确收服务触发流程
课程id或者其他的商品id
适配器
场次B-80元
4 号
1、查询数据库获取数据
普通订单
确收服务业务流程
课程1发生了调整
Queue_uid01_product2
