No
是
日志数据库，表为：[Log_UserCapitalChangeMsg]
DB（fh_logs）
结束
事物处理
是否有消息
添加记录
②
①
存储资金变动消息到数据库，状态标记为10
push
监听
获取用户信息计算用户结余信息
否
通过API推送资金变动消息
根据消息Id检查日志库是否存在已消费？
yes
存储资金变动消息到数据库，状态标记为0
监控未进入队列的消息日志重新进入队列
MQ
将消息放入队列
存储到Mq
监听消费资金消息系统
API接收资金变动消息
更新（添加）消息日志状态为【已消费】（1000）
③
添加结余记录并更
用户资金结余表：[Ks_UserCapitalChange]
按区间监控未成功进入队列的消息
查询
④
exchange=Capital.Change.Msgqueue=Capital.Change.Msg.Balance模式：fanout
融合资金变动消息为新的结余信息
是否有记录
更新
监听消息队列
根据用户Id获取用户最新的一条结余记录
获取最新结余记录的结余信息
