Lazada广州基础信息改造方案

### 当前流程梳理
 目前Lazada分类是通过mps-product-allproducer项目定时器每隔5天循环lazada所有站点依次丢入香港服务器mps-lazada-product进行同步。在mps-lazada-product项目中会查出所有mdc_sc_app中的云环境进行多应用同步，通过查出的分类数据丢入到RabbitMq 推送到php广州服务器进行消费并保存到erp表。

### 基础信息关联
Lazada平台的基础信息分为分类、分类属性、品牌等。这些基础信息都只与站点相关，与店铺数据无关，站点不同，基础信息不同。

### 改造流程简介
mps-product-allproducer ->  mps-lazada-product ->RocketMq -> mdc-lazada-product -> erp 基础信息表

### 改造接口
>同步分类：  LazadaCategoryConsumer

>同步分类属性： LazadaCategoryAttrConsumer

>同步品牌：LazadaBrandConsumer

### 数据库
需要操作public/private-tidb-kandeng 连接中mabang-publishlazada库中的db_category、db_category_attribute、db_category_brand数据表

### 平台获取到的分类数据结构
```json
{
	"code": "0",
	"data": [{
		"category_id": 6588,
		"children": [{
			"category_id": 7436,
			"var": true,
			"name": "Socks",
			"leaf": true
		}, {
			"category_id": 7435,
			"var": true,
			"name": "Underwear",
			"leaf": true
		}],
		"var": true,
		"name": "Socks \u0026 Tights",
		"leaf": false
	}],
	"request_id": "0ba2887315178178017221014"
}
```

###   方案一
 erp数据库：分类表、分类属性、品牌表新增version字段，用于判断同一批次的信息以便于进行数据比对删除

（香港）mps-lazada-product：推送的消息体中增加版本号version 用于判断当前站点同一批次的消息。
 增加最后一批标识用于判断当前批次分类是否推送完成
 推送消息MqType改为rocketmq

（广州）mps-lazada-product： 解析香港服务推送过来的数据->转换成数据库对象->当前站点保存并更新数据->判断是否最后一批数据->删除出当前版本以外的所有分类。（公私有云都要开接口处理）

### 方案二

#### 前言
经过调研，当前香港服务推送的数据格式是把每个lazada的一级大类目下面所有的子类目转换成一个list字符串进行推送。

香港）mps-lazada-product：推送的消息体中增加1个业务字段
rootId：当前推送类目的顶级类目

广州）mdc-lazada-product：接收的消息体中增加2个业务字段
1. rootId：当前推送类目的顶级类目，字段还作为redis 缓存中的键。站点_rootId.

2. parentId:需要同步的父级类目，用于在查询数据库时的条件参数，查询到当前parentId对应的分类以及下层的所有类目。也是在redis缓存的树结构中作为子类目树进行过滤.

#### 改造细节
主要针对广州服务器
增加redis服务进行缓存，主要作用是为了方便以后新增接口时根据指定分类进行数据同步时以站点_rootId 作为键，每个键对应存的是一级类目对应的类目树
1. 每次消费时接收到数据时去redis中找出对应键中顶层分类树。
2. 再根据parentId过滤出顶层分类树下的子分类树，
3. 进行parentId层级的子分类树替换，形成新的分类树，
4.替换掉redis中缓存的分类树，
5.以parentId 作为数据库的查询条件，递归查询出当前parentId下的所有分类（包括当前分类）进行删除。
6.把新的类目树插入到数据库中

当redis中未找到对应的数据时

1. 以parentId作为查询条件去数据库递归找到当前分类下的所有分类（包括parentId）。
2.删除以上的数据
3.接口消费到的数据存入到数据库
4.并形成新的分类树放入到redis缓存中。