商品数据修改
上传策略UploadStrategyFactory
网关pos请求DrugAdminForwardApi
匹配失败: 删除原校验记录校验失败: 新增/修改校验记录校验成功: 修改原校验失败记录状态
任务记录表 (机构号-sourceType-sourceId-bizGroup)
通过表名saas_product_baseinfo找到对应处理的DmlProcessor
校验CheckProcessor
定时上传任务
定时任务SupervisionScheduleApi
全量数据BatchProcessor
商品标准模型{\"id\
canal
文件上传UploadFileService
增量数据-canalDmlProcessor
默认上传策略UploadNoneService
根据filter_config配置表达式(SPel)过滤
抽象数据处理入口AbstractDataProcessor
数据转标准化模型
根据generate_config配置的uploadRealTime 决定是否实时上传
上传UploadProcessor
请求转发处理ForwardProcessor
生成GenerateProcessor
接口上传UploadApiService
根据upload_configp配置的uploadType选择对应策略上传
重新校验
canal监听MqConsumer
校验记录表 (机构号-sourceType-sourceId-bizGroup)
根据generate_config配置的unGenerate 决定是否生成任务
