大纲进度

finally：解锁

消费kafka

从维护的list中获取到所有的大纲id

调用B端接口，outlineApi.getOutlineInversePath，维护一个list<（需计算的大纲节点，所有大纲子节点list）的对象>的结构

检测redis中是否有洗数据标志位，如果存在，阻塞，且2秒重新获取一次

聚合统计

整个流程的异常，进binlog_consummer_error_log表

洗数据，且不需进行检测学生锁状态

大纲进度优化方案：数据一致

调用B端接口vpsContentDetailGroupApi.query接口 获取到大纲下绑定的题组，去判断未分题提交状态的判定

取消息ans_item_id集合回item_source_outline表查大纲

学生查询answer表

提交ack结束

从维护的list中遍历并forkjoin异步处理，对处理的大纲+学生加锁

持久化

加锁 放置洗数据标志位

处理异常表数据为已处理

洗数据方案：学生维度

不存在了

检测是否含有大纲+学生维度的锁，如果有，1秒获取一次

binlog

ans_item表kafka消息