商品

SKU

3.补偿同步更新

库存缓存

2聚合数据

都会抛异常

SPU-列表

有/没有库存了

2记录变更流水

列表页

下单

店铺

SKU-基础

1存储变更

订单

binlog

同步模块

订单退款

同步保障模块

异步通知 事件 元素

操作

销售统计数据

限速消费

普通

详情页

SKU-stock

id  name balance contract_id 

1校验流水

类目

售罄/库存增时 上锁处理

schedule

kafka

分类

product cluster

load

SKU-price

SKU-sale

实时同步???

分享商品

id spu_id init_sale_num init_view_num really_sale_num really_view_num

底层源数据层

id  p_id  name  desc  level 

定时同步

3 异步更新

2创建异构补偿任务

后台列表库存策略

商品新增/修改

async

order cluster

商户聚合分类

trans logic

mysql

SPU

3双删缓存

C列表库存检验策略

  埋点上报

结算

分销策略配置

库存模块

成功回调

SPU-time

获取商品详情富文本

同步任务表

3 异构策略

归档

分享

SPU-Time

列表推荐

wf

2恢复库存

获取店铺信息

商家基本

检索

ID 映射

id spu_id sku_stock

1扣减库存

1.获取待同步任务

OLTP

获取套餐列表

列表查询

数据异构层

离线

OLAP

SKU-价格

isomer

后台商品异构模块

SKU-库存

C端

1.商品基础数据SPU基础数据存储变更SKU数据存储自动上下架库存基础数据销售基础数据SKU价格SPU分享**************************************************************2.商品异构层异步逻辑模板库层变更通知异构层略模块-接口定义库层变更通知异构层略模块-逻辑实现**************************************************************3.同步保障模块同步层略补偿dao同步补偿job数据组装统一接口定义商品列表检索的数据组装逻辑实现**************************************************************4.es数据检索es存储数据定义es数据新增逻辑es数据变更逻辑es数据同步策略-上下架数据需要删除新增es检索逻辑**************************************************************5.列表页分类聚合模块聚合dao层聚合cache层**************************************************************6.库存模块库存查询逻辑商品校验逻辑库存扣减逻辑库存变更逻辑库存恢复逻辑**************************************************************7.销量统计销量统计模块销量定时汇总**************************************************************8.商品推荐**************************************************************9.API接口商品列表页API商品列表页的分类接口商品页的推荐API接口

Client    API

后台列表异构表

下单 虚拟商品ID

1更新

id  sale_begin  sale_end

抢购

返回缓存

id title desc pics pics_two

恢复

MQ

数据变更

3双删

列表筛选

B端后台展现

下单/取消

库存源

BI

根据订单生成分销流水

展现

原始数据mysql

返回检索结果

获取销售统计数据

id  relatedId type money status source_orderid operator create_time

时效性控制频率

后台列表异构逻辑

销售策略

支付

商户分类维护

ETL

id  class_one class_two pics   pics  buy_notice  stat 

消息适配层

2.组装

库存变更流水

id spu_id  shangjia_id name desc end_time  code_num

商品套餐

搜索引擎

视图数据redis

JOB

id spu_id price_one price_two price_three price_four 

发起充值

现在异构数据只关心有误库存

数据仓库

标记完成

商品维护

聚合缓存

下单扣减库存

SKU-price-分销

维护商品

分享信息

SKU-销售

聚合列表

商品分类聚模块

  ES

2记录流水

列表搜索

SPU-share

销量/浏览量

筛选分类

查询

获取商品基本详情

2缓存不在生成缓存

SKU-basic

基础商品

列表展现

拼团

B端

catelog

流水聚合

商品销售统计模块

1查询库存缓存

查询库存

3 异构变更事件

写入缓存

hive

详情富文本

补偿恢复库存 订单ID

C列表检索模块

付款

库存

任务完成

异构层

订单扣款

基于流水增量变更账户余额1.发起充值 新增充值中的流水2.成功回调 变更充值中账户流水id   账户金额变更3.订单扣款 新建扣款流水 账户金额变更4.订单退款 新建退款流水 账户金额变更

更新库存

分销

完成

商品基本

source

回调

analyze

SPU-basic

Redis