商品多视图

datacenter-canal-channelcenter-sharding

BaseSourceListSapConsumer

OutputSinkEvent(ES)

主要逻辑获取created_by != 'new'， 分页1000先删后写：base_supplier_product_purchase_info_sap，删除中间表数据：mid_supplier_product_purchase_info保存备份表数据：bak_supplier_product_purchase_info

主数据中心yh-rme-srm-datacenter

消费

主要逻辑获取process_flag=0 and created_by != 'new'， 分页300region_code + product_code重复的数据剔除，只保留创建时间最大的一条按大区分组，过滤非上线大区，非上线大区数据保存error_msg_info写base_region_product_sap， 删除中间表数据，保存备份表数据：mid_base_region_product_bak发MQ消息：font color=\"#e74f4c\

写大区商品表

发布事件

new_base_supplier_product_purchase_info_sap_v1（new_base_supplier_product_purchase_info_sap）

canal

Kafka

es

mid_supplier_product_purchase_info

处理

mid_base_product_info

BaseSupplierProductPurchaseInfoSapConsumer

OutputSinkEvent(REDIS)

/v1/sourceList/getFromDBByConditions

md_bsl_v1（md_bsl_alias）

监听

base_supplier_product_purchase_info_sap

syncShopProductNumCollectionConsumeImpl

select *from data_distribute_viewwhere source_table = 'base_product_info_sap'and source_database = 'yh_srm_productcenter_test';

渠道中心数据同步yh-rme-srm-channel-sync

test_Canal-Source-List

topic：SIT-YH-RME-SRM-KFPT-SYNC-INVOICE-REQUISITION-GOODS-BASEINFOtag：PRODUCT_INFO

base_product_info_sap_alias

datacenter-sharding-region-product

base_source_list_sap（base_source_list_sap_alias）

BaseProductShopSapConsumer

test_Canal-Product-Info

sap -> channelcenter: 下发门店商品数据

base_region_product_sap（base_region_product_sap_alias）

品类数据才需要

下发商品数据

OutputDispatcherEvent

暂无

同步商品基本信息变动数据

渠道中心yh-rme-srm-channelcenter

RocketMQ

任务：BaseSourceListSapJob

product_center_bspp__${供应商+采购组织}

base_source_list_sap

主要逻辑获取and process_flag = 0 and created_by != 'new'， 分页250将location_code + product_code + inside_supplier_code重复的数据剔除，只保留创建时间最大的一条获取商品基础信息及门店档案信息：/product_info/product_code表：font color=\"#e74f4c\

任务：syncBaseSupplierProductPurchaseInfoJob

select *from sync_module_field_conf cwhere is_delete = 0AND c.topic = 'datacenter-productcenter-topic'AND c.tag = 'base_product_info_sap'AND c.sys_code = 'yh-rme-srm-productcenter';

BaseRegionProductSapConsumer

/v1/baseSupplierProductPurchaseInfoSap/getFromDBByConditions

sap -> productcenter: 下发商品数据

md_bps_alias（md_bps_v1）

md_bpi_alias

sap -> channelcenter: 下发大区商品数据

mid_base_product_shop

test_new_base_supplier_product_purchase_info_sap

INSERT

任务：BaseProductShopSapJob

处理下发数据

redis

md_brp_v1（md_brp_alias）

product_center_bsl_${locationCode}

同步冗余字段

baseProductShopSapHandle

sap -> channelcenter: 下发商品货源数据

prod-同步

SAP

主要逻辑span style=\"font-size:inherit;\

test_Canal-Region-Product

下发商品货源

处理标签绑定关系

商品中心查询yh-rme-srm-productcenter-query

1、/v1/locationProduct/getFromDBByConditions -- base_product_shop_sap_${shopCode}

product_center_brp_${shopCode}

发消息

商品中心yh-rme-srm-productcenter

写货源表(看步骤10)

base_product_shop_sap（base_product_shop_sap_alias）

只消费新增类型消息分档逻辑，同步个单量：1.启用关系同步，禁用删除删除；2.子母品都必须存在分档记录；3.只考虑门店（开业），不考虑物流

写商品门店表

datacenter-productcenter-topic

任务：BaseProductInfoSapJob

开放平台回调YH-CALLBACK-GROUP-SIT%SIT-YH-RME-SRM-KFPT-SYNC-INVOICE-REQUISITION-GOODS-BASEINFO

发送

category_label_bind_info

取消息中的table、database、查询data_distribute_view取Handle（baseProductInfoSapHandle）组装DispatchMessageDTO取基本信息表- 商品中心：/product_info/selectBaseProductInfoByCode取虚拟编码- 商品中-新品引入单/productApplyOrder/getProductVirtualCode取码表：SALETAXCODE-销项税率组装BaseProductInfoSapDTO，赋值DispatchMessageDTO.NewField缓存数据BaseProductInfoSapDTO发送消息：topic：datacenter-productcenter-topic，tag：base_product_info_sap数据clean处理环节：取配置表需要清除的表default.clean.support.tables--- base_product_shop_sap---base_brand_info存在第9步条件下，同步至ES：change_record_alias添加下发日志-distribute_record

datacenter-channelcenter-sharding-topicbase_product_shop_sap_tag

base_product_info_sap

base_product_shop_sap

mid_base_region_product

下发采信数据

infoListenConsumeImpl

下发大区商品

datacenter-canal-productInfo-sap

product_center_bpis

sap -> channelcenter: 下发采信视图数据

写货源表

BaseProductInfoSapConsumer

写

product_center_bps_${shopCode}

任务：RegionProductSapJob

mid_base_source_list

base_region_product_sap

test_Canal-Product-Shop

datacenter-channelcenter-sharding-topicbase_region_product_sap_tag