是
基础信息为null?
userType是机构？
查询用户下的ta流程
Merchant系统
插入表数据
监听用户修改行为获取span lang=\"EN-US\
发送 X1 mq
font color=\"#323232\
查询TA账号是否销户？
merchant账户信息为null？
开始
更新表数据
Async
根据userId查询机构基础信息
出现修改行为发送MQ
否
转发merchant MQ
addX3Record逻辑
根据ta账号等信息查询X1表是否已存在该用户？
主键冲突抛出DelayException延迟消费继续抛出mq消息
处理Ta账户X1上报逻辑
Cif查询用户信息
处理Ta账户X3上报逻辑
Ta账户列表去重
消费失败重试抛出DelayException延迟消费继续抛出mq消息
中登反洗钱上报总流程
结束
监听用户修改行为获取userId和modifyTime和userType
根据userId查询机构投资人信息
异常
CIF系统
处理Ta账户上报逻辑
分页查询TA的所有存量用户，每页100条？
根据merchant账户id获取Ta账号列表
调用失败
merchant系统
Merchant
比较x1数据必填字段是否完整？
TA的所有升级的存量用户条数
cifClient.queryInvestorInfocom.qiangungun.cif.service.facade.CifOrgInfoCoreQueryService#queryInvestorInfo
是否已经报备过？
batchNo随机生成
主键冲突
比较x1数据必填字段是否改变？
遍历Ta账号列表
通过userid获取merchant账户信息
存量Ta
根据mq中modifyTime计算交易日-即上报日tradeDate
传入userId，userType，modifyTime
curl发送mq
根据用户id查询CIF用户信息CIFUserInfoExtService.getUserInfoExtension
出现新增Ta行为发送MQ
根据mq中workdate计算交易日-即上报日tradeDate
cifClient.queryInstitutionBaseInfocom.qiangungun.cif.service.facade.CifOrgInfoCoreQueryService#queryOrgBaseInfo
