大纲进度
2021-11-01 17:14:58 5 举报消费以及洗数据
作者其他创作
大纲/内容
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消息
0 条评论
下一页
