商品中心—1.B端建品和C端缓存的技术文档

大纲
1.商品中心的专业术语
2.商品中心的基本业务系统
3.商品中心整体架构设计以及运行流程
4.商品B端—商品编码生成逻辑
5.商品B端—商品核心数据模型
6.商品B端—转换建品请求数据为商品模型数据
7.商品B端—商品建品时商品编号补全与审核配置
8.商品B端—商品审核前的草稿数据保存逻辑
9.商品B端—不需审核的建品流程持久化逻辑
10.商品B端—审核工单分页列表和商品草稿查询
11.商品B端—商品审核时的敏感字段diff计算逻辑
12.商品B端—对草稿中的商品进行审核的逻辑
13.商品B端—商品属性+买手+品类的数据维护
14.商品C端—通用缓存读写组件的实现逻辑
15.商品C端—接口代码实现逻辑
 
1.商品中心的专业术语
一.ITEM
商品售卖展示单位，仅⽤于销售时展示使⽤。
 
二.SKU
SKU是Stock Keeping Unit(库存单位)，即库存进出计量的单位。可以是以件、盒、托盘等为单位，如：iPhoneX + ⿊⾊ + 256G。
 
三.SPU
SPU是Standard Product Unit标准化产品单元，是对某一类标准产品的共同特征属性的描述。SPU是商品信息聚合的最⼩单位，如：iPhoneX就是SPU。SPU的出现是为了满足在叶子类目下对商品进行进一步抽象的需求。比如手机就是叶子类目，虽然可以添加苹果手机或者华为手机这样的类目，但这样添加就比较麻烦了，可能会导致类目树就会变得非常庞大。所以SPU是一个介于叶子类目和商品之间的概念，是对类目的细化。因此SPU通常由"后台类目 + 关键属性"唯一确定。
 
四.CSPU
CSPU也就是子标准化产品单元，即SPU的细分，Child SPU。CSPU通常由"后台类目 + 关键属性 + 销售属性"唯一确定。比如手机类型下，品牌和型号这两个属性可以确定一个SPU，但还不能确定一个CSPU，需要额外的销售属性才能确定一个CSPU。以苹果手机为例，品牌是iPhone、型号是X、颜色为黑色、存储为256G，两个关键属性是品牌和型号，两个销售属性为颜色和存储。
 

五.运营品类
运营品类是⼀种抽象的概念，例如：运动裤、⼿机。每一个商品都会有所属的品类，比如iPhone X这个SPU会属于手机这个品类。不同的电商平台会对品类进行不同的划分，手机品类在有的平台是一级品类，在有的平台是电子产品品类的子品类。
 
六.前台类⽬
多级品类可以构成前台类⽬，例如：男T恤 + 男短裤可归属到男装类⽬。电商网站首页里，左侧都会有一颗类目树，这个类目树就是前台类目。
 
七.SKU规格
⽤来区分单品的主要指标。例如⼿机商品由颜⾊、内存两种规格区分单品，每个规格有多个可选值。从每个规格选出一个值，拼凑起来的组合就可以唯一确定一款商品SKU。颜色规格：白色、黑色、粉色、天蓝色；内存：128G、256G、512G。
 
八.原料商品
只采购不销售的商品，只有采购属性如包材或原材料，例如：吸管、开瓶器。
 
九.普通商品
⼜采购⼜销售的商品，有库存和销售属性。
 
十.组套商品
不采购只销售的商品，共享库存和销售属性，例如：原料商品 + 普通商品组合为⼀个商品。开瓶器是原料商品，红酒是普通商品，开瓶器 + 红酒就是一个组套商品。开瓶器不能单卖但需要采购，用户购买红酒时不用关注开瓶器，开瓶器会和红酒打包在一起进行展示和售卖。
 
十一.虚拟商品
不采购只销售，只有虚拟库存，只有销售属性，例如：会员卡、虚拟卡、购物卡、游戏点卡。这些虚拟商品没有必要去进行采购，用户支付后也不需要履约签收。用户完成对虚拟商品的支付后，商品直接可以展示在用户的会员中心里。
 
十二.售卖区
商品可以在哪⾥卖，售卖范围配置：按城市配置、按卖家组配置。有的商品只能在部分城市可以售卖，部分城市是没法售卖的。在某些区域里，商品的库存不好发货，可能会显示该区域无货。
 
仓库会分成两种：微仓和大仓，微仓就是微型的小仓库，大仓就是大型的大仓库。大仓可以辐射很大一片区域的发货，仓库容量很大，里面可以放很多商品。微仓也叫前置仓，在一个城市里，可以设置微仓。可以将该城市经常购买的，库存量消耗比较大的商品，放到多个微仓里。这样距离消费者就会更近一些，发货也可以更快一些。
 
十三.卖家类型
类型一：⾃营，类型二：POP。自营就是商品是由平台自己来采购、入仓、售卖，POP(Platform Open Plan)意思是平台开放计划，POP就是第三方卖家入驻平台开店售卖自己的商品。
 
十四.商品状态
可售：商品配置了售卖区并且状态为可售
可补：商品可售且微仓可补货状态
可采：商品可售且⼤仓可采货状态
准备上架：建品后为此状态，表示可采和可补
试销上架：上架状态，表示处于试销阶段
上架：正式上架售卖
预下架：售完不展示商品，表示不可采和可补
下架：不可采和不可补
停售：永久下架，已淘汰
 
十五.商品价格
商城价：⾮会员⽤户购买商品的价格
会员价：会员⽤户购买的价格
营销价：促销活动价
秒杀价：秒杀活动价格，⼀⼝价
 
2.商品中心的基本业务系统
(1)商品基础服务
(2)商品类型与采购销售之间的关系
(3)商品中心的业务系统
 
(1)商品基础服务
服务一：提供从建品到下架期间可采可补可售管理的商品全流程服务
 
服务二：对商品基本信息、品牌信息、运营品类、前台类⽬、仓配信息、标签信息、品控信息、销售信息、推⼴信息等进⾏精细化管理与运营
 
服务三：通过权限收敛，可以很好把控并记录⽤户操作⾏为，使流程更加规范
 
服务四：通过提效⼯具，业务⽅可以批量处理商品相关⼯作，降低⼈⼒成本
 
(2)商品类型与采购销售之间的关系

(3)商品中心的业务系统
商品中心的系统主要会分为两类：一个是面向B端，一个是面向C端。面向B端的系统，主要由公司运营来使用，对商品进行精细化管理。面向C端的系统，则会对C端用户提供各种商品浏览和查询的接口。
 
一.价格中心系统
商品价格管理，提供全流程价格管控和分析。⽀持功能：价格查询、价格设置、审核流程、历史价格查询与趋势分析等。
 
二.商品卖家系统
商品售卖⽅，这⾥将卖家定义为卖家树，⽤户可以定位到多个卖家。商品基于卖家售卖，⽤户在当前覆盖的区域内可浏览到相应卖家的商品。将多个卖家合并为⼀个⼤的卖家称为卖家组，也称为售卖区，售卖区之间的逻辑处理称为售卖区管理(可售区域)。
 
三.商品⽣命周期系统
商品的状态分为：准备上架、试销上架、上架、预下架、下架、停售。为了更好的管理商品，需要对商品进⾏⼀套⽣命周期管理。⽤于考核商品，降低滞销率、资⾦成本以及影响商品的可采可补逻辑。
 
四.商品库存系统
商品库存需要分卖家设置，卖家 + 商品 + 库存关系定位具体商品库存数量。
 
五.商品标签系统
需要打上特殊标签的商品，例如：爆款，后台进⾏标签 + 标签组 + 商品管理。
 
六.属性库系统
商品关联的属性，涉及四种属性：关键属性、销售属性、⾮关键属性、导购属性。
 
七.商品品控系统
把控商品质量，在商品⼊库前进⾏取样检测，给出质检报告。合格商品允许⼊库，不合格商品不允许⼊库。将可售卖商品关联上质检报告，展示给⽤户。
 
3.商品中心整体架构设计以及运行流程
(1)商品中心整体架构
(2)商品新建编辑流程
 
(1)商品中心整体架构

(2)商品新建编辑流程

1. //商品服务
2. @DubboService(version = "1.0.0", interfaceClass = ProductApi.class, retries = 0)
3. public class ProductApiImpl implements ProductApi {
4.     @Autowired
5.     private ProductService productService;
7.     //建品/编辑商品接口
8.     @Override
9.     public JsonResult<ProductDTO> product(ProductRequest request) {
10.         try {
11.             ProductDTO productDTO = productService.product(request);
12.             return JsonResult.buildSuccess(productDTO);
13.         } catch (ProductBizException e) {
14.             log.error("biz error: request={}", JSON.toJSONString(request), e);
15.             return JsonResult.buildError(e.getErrorCode(), e.getErrorMsg());
16.         } catch (Exception e) {
17.             log.error("system error: request={}", JSON.toJSONString(request), e);
18.             return JsonResult.buildError(e.getMessage());
19.         }
20.     }
21.     ...
22. }

复制代码

 
4.商品B端—商品编码生成逻辑

1. //商品编码
2. @Service
3. public class ProductNoManagerImpl implements ProductNoManager {
4.     //6位序列号
5.     private static final int width = 6;
7.     @Autowired
8.     private ProductAutoNoMapper productAutoNoMapper;
10.     //生成商品编码
11.     @Override
12.     public String generateProductNo(Integer sourceType) {
13.         ProductTypeEnum productTypeEnum = ProductTypeEnum.getByCode(sourceType);
14.         if (productTypeEnum == null) {
15.             throw new ProductBizException(ProductErrorCodeEnum.PARAM_ERROR);
16.         }
17.         return getProductNo(productTypeEnum.getValue());
18.     }
20.     //获取组装后的商品编码，商品的prefixNo是100000
21.     private String getProductNo(String prefixNo) {
22.         //有一张ProductAutoNo表专门用于生成商品ID
23.         //分库分表也可以利用此来实现基于数据库的内存缓存分段的发号器
24.         ProductAutoNoDO productAutoNoDO = new ProductAutoNoDO();
25.         productAutoNoMapper.insert(productAutoNoDO);
26.         Long autoNo = productAutoNoDO.getId();//获取自增ID
27.         return prefixNo + IDUtils.genId(autoNo, width);//数字混淆算法
28.     }
29. }

复制代码

 
5.商品B端—商品核心数据模型

1. //建品/编辑商品请求入参
2. @Data
3. public class ProductRequest implements Serializable {
4.     //商品基本信息
5.     private ItemBaseRequest itemBaseRequest;
6.     //存储信息
7.     private ItemStorageRequest itemStorageRequest;
8.     //品控信息
9.     private ShelfLifeRequest shelfLifeRequest;
10.     //图文信息
11.     private List<ItemVideoImgRequest> itemVideoImgRequestList;
12.     //销售信息
13.     private ItemSaleRequest itemSaleRequest;
14.     //推广信息
15.     private ItemPopularizeRequest itemPopularizeRequest;
16.     //操作人
17.     @NotNull(message = "操作人[operateUser]不能为空")
18.     private Integer operatorUser;
20.     //商品基本信息
21.     @Data
22.     public static class ItemBaseRequest implements Serializable {
23.         //商品ID
24.         private String itemId;
25.         //商品名称
26.         private String itemName;
27.         //渠道（1-每日生鲜、2-美团、3-饿了么、4-淘鲜达、5-招商银行）
28.         private Integer channel;
29.         //卖家类型（1-自营、2-POP）
30.         private Integer sellerType;
31.         //商品状态
32.         private Integer itemStatus;
33.         //商品类型
34.         private Integer itemType;
35.         //品牌ID
36.         private Integer brandId;
37.         //产地ID
38.         private Integer producingAreaId;
39.         //成本价（单位：分）
40.         private Integer basePrice;
41.         //末级品类ID
42.         private Integer lastCategoryId;
43.         //一级品类ID
44.         private Integer oneCategoryId;
45.         //二级品类ID
46.         private Integer twoCategoryId;
47.         //三级品类ID
48.         private Integer threeCategoryId;
49.     }
51.     //存储信息
52.     @Data
53.     public static class ItemStorageRequest implements Serializable {
54.         //存储条件
55.         private Integer storeConditionType;
56.         //ITEM维度规格值（多个规格集合）：key=颜色，value=蓝色；key=颜色，value=红色；key=内存，value=128g；key=内存，value=256g
57.         private List<ProductSpcesValue> productSpcesValueList;
58.     }
60.     //规格信息
61.     @Data
62.     public static class ProductSpcesValue implements Serializable {
63.         //规格关键字
64.         private String key;
65.         //规格值
66.         private String value;
67.         //排序
68.         private Integer sort;
69.     }
71.     //品控信息
72.     @Data
73.     public static class ShelfLifeRequest implements Serializable {
75.     //保质期（单位：小时）
76.     private Integer shelfLife;
77.         //Map<key=保质期类型，value=保质期时间(单位：小时)>：acceptLife 允收期，shelfLife 货架期
78.         private Map<String, Integer> shelfLifeMap;
79.     }
81.     //图文信息
82.     @Data
83.     public static class ItemVideoImgRequest implements Serializable {
84.         //内容类型（1-主图，2-轮播图、3-详情图、4-视频）
85.         private Integer contentType;
86.         //链接地址
87.         private String contentUrl;
88.         //排序（正整数，数字越小越靠前）
89.         private Integer contentSort;
90.     }
92.     //销售信息
93.     @Data
94.     public static class ItemSaleRequest implements Serializable {
95.         //sku信息
96.         private List<SkuInfoRequest> skuInfoRequestList;
97.     }
99.     //sku信息
100.     @Data
101.     public static class SkuInfoRequest implements Serializable {
102.         //商品itemId
103.         private String itemId;
104.         //商品skuId
105.         private String skuId;
106.         //商品SKU名称
107.         private String skuName;
108.         //商城价
109.         private Integer basePrice;
110.         //会员价
111.         private Integer vipPrice;
112.         //商品分级（ABC标签，运营归类处理）
113.         private Integer skuGrade;
114.         //69码，条形码
115.         private String barCode;
116.         //SKU维度规格值（单个）：key=颜色，value=蓝色；key=内存，value=128g
117.         private List<ProductSpcesValue> productSpcesValueList;
118.         //sku匹配的spu信息
119.         private Long cspuId;
120.     }
122.     //推广信息
123.     @Data
124.     public static class ItemPopularizeRequest implements Serializable {
125.         //推荐语
126.         private String recommend;
127.         //亮点
128.         private List<HighlightsRequest> highlightsRequestList;
129.         //卖点
130.         private List<SellingPointRequest> sellingPointRequestList;
131.         //质检报告
132.         private List<QualityControlRequest> qualityControlRequestList;
133.     }
135.     //亮点
136.     @Data
137.     public static class HighlightsRequest implements Serializable {
138.         //亮点文案
139.         private String highlights;
140.         //排序（正整数，数字越小越靠前）
141.         private Integer sort;
142.     }
144.     //卖点
145.     @Data
146.     public static class SellingPointRequest implements Serializable {
147.         //卖点文案
148.         private String sellingPoint;
149.         //排序（正整数，数字越小越靠前）
150.         private Integer sort;
151.     }
153.     //质检报告
154.     @Data
155.     public static class QualityControlRequest implements Serializable {
156.         //商品skuId
157.         private String skuId;
158.         //质检报告名称
159.         private String qcName;
160.         //材料图片链接
161.         private String qcImgUrl;
162.         //排序（正整数，数字越小越靠前）
163.         private Integer qcSort;
164.     }
165. }

复制代码

 
6.商品B端—转换建品请求数据为商品模型数据
前端的建品请求数据比较复杂，需要和后端的商品模型数据匹配起来，所以需要进行数据转换。这种数据转换，通常会用Builder模式来实现。

1. @Service
2. public class ProductServiceImpl implements ProductService {
3.     ...
4.     //建品/编辑商品
5.     @Transactional(rollbackFor = Exception.class)
6.     @Override
7.     @ParamsValidate
8.     public ProductDTO product(ProductRequest productRequest) {
9.         //入参检查
10.         checkProductRequestParam(productRequest);
11.         //商品数据处理
12.         ProductDTO productDTO = handleProduct(productRequest);
13.         //返回商品信息
14.         return productDTO;
15.     }
17.     //建品/编辑商品入参检查
18.     private void checkProductRequestParam(ProductRequest productRequest) {
19.         ParamCheckUtil.checkObjectNonNull(productRequest);
20.         //商品基本信息
21.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
22.         ParamCheckUtil.checkObjectNonNull(itemBaseRequest);
23.         //存储信息
24.         ProductRequest.ItemStorageRequest itemStorageRequest = productRequest.getItemStorageRequest();
25.         ParamCheckUtil.checkObjectNonNull(itemStorageRequest);
26.         //品控信息
27.         ProductRequest.ShelfLifeRequest shelfLifeRequest = productRequest.getShelfLifeRequest();
28.         ParamCheckUtil.checkObjectNonNull(shelfLifeRequest);
29.         //图文信息
30.         List<ProductRequest.ItemVideoImgRequest> itemVideoImgRequestList = productRequest.getItemVideoImgRequestList();
31.         ParamCheckUtil.checkObjectNonNull(itemVideoImgRequestList);
32.         //销售信息
33.         ProductRequest.ItemSaleRequest itemSaleRequest = productRequest.getItemSaleRequest();
34.         ParamCheckUtil.checkObjectNonNull(itemSaleRequest);
35.         //推广信息
36.         ProductRequest.ItemPopularizeRequest itemPopularizeRequest = productRequest.getItemPopularizeRequest();
37.         ParamCheckUtil.checkObjectNonNull(itemPopularizeRequest);
38.     }
40.     //商品数据处理
41.     private ProductDTO handleProduct(ProductRequest productRequest) {
42.         //构建商品的全量信息
43.         FullProductData fullProductData = buildProduct(productRequest);
44.         //是否构建填充 itemId
45.         Boolean createFlag = whetherBuildProductItemId(fullProductData);
46.         //判断是否需要审核，根据配置的sku或者item或者品类信息，如果需要审核，只处理草稿表中的数据，正式表中的数据不动
47.         if (productAuditRepository.needAudit(fullProductData, createFlag)) {
48.             //需要审核，则正式表中的数据不变更，只新增草稿表记录
49.             FullDraftData fullDraftData = buildDraft(fullProductData, AuditTypeEnum.GOODS.getCode());
50.             //保存草稿信息
51.             productAuditRepository.saveDraft(fullDraftData);
52.             return new ProductDTO(null, null);
53.         }
54.         //如果不需要审核，则保存商品信息
55.         this.saveOrUpdateDBProduct(fullProductData, createFlag);
56.         //发送消息通知订阅方
57.         sendUpdateProductMessage(fullProductData);
58.         //返回商品返回结果
59.         return new ProductDTO(fullProductData.getItemInfoDO().getItemId(), buildProductSkuIds(fullProductData));
60.     }
62.     //前端建品请求数据到后端商品数据模型的转换
63.     private FullProductData buildProduct(ProductRequest productRequest) {
64.         ProductBuilder productBuilder = new ProductBuilder(productRequest);
65.         FullProductData fullProductData = productBuilder.buildItemInfo()
66.             .buildItemShelfLife()
67.             .buildItemVideoImgList()
68.             .buildSkuInfoList()
69.             .buildSkuBarCodeRelationList()
70.             .buildCspuSkuRelation()
71.             .buildAttributeExtend()
72.             .buildQualityControl()
73.             .build();
74.         return fullProductData;
75.     }
76.     ...
77. }
79. //全量商品数据
80. @Data
81. @NoArgsConstructor
82. @AllArgsConstructor
83. public class FullProductData {
84.     //ITEM信息
85.     private ItemInfoDO itemInfoDO;
86.     //保质期信息
87.     private ItemShelfLifeDO itemShelfLifeDO;
88.     //视频图片信息
89.     private List<ItemVideoImgDO> itemVideoImgDOList;
90.     //SKU信息
91.     private List<SkuInfoDO> skuInfoDOList;
92.     //69码关系
93.     private List<SkuBarCodeRelationDO> skuBarCodeRelationDOList;
94.     //CSPU与SKU关系
95.     private List<CspuSkuRelationDO> cspuSkuRelationDOList;
96.     //ITEM或SKU扩展属性
97.     private AttributeExtendDO attributeExtendDO;
98.     //品控信息
99.     private List<QualityControlDO> qualityControlDOList;
101.     public FullProductData(ItemInfoDO itemInfoDO, List<SkuInfoDO> skuInfoDOList) {
102.         this.itemInfoDO = itemInfoDO;
103.         this.skuInfoDOList = skuInfoDOList;
104.     }
105. }
107. //全量商品数据
108. public class ProductBuilder {
109.     //商品入参
110.     private ProductRequest productRequest;
111.     //全量商品数据
112.     private FullProductData fullProductData;
114.     public ProductBuilder(ProductRequest productRequest) {
115.         this.productRequest = productRequest;
116.         this.fullProductData = new FullProductData();
117.     }
119.     public ProductBuilder buildItemInfo() {
120.         ItemInfoDO itemInfoDO = new ItemInfoDO();
121.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
122.         itemInfoDO.setItemId(itemBaseRequest.getItemId());
123.         itemInfoDO.setItemName(itemBaseRequest.getItemName());
124.         ...
125.         fullProductData.setItemInfoDO(itemInfoDO);
126.         return this;
127.     }
129.     public ProductBuilder buildItemShelfLife() {
130.         ItemShelfLifeDO itemShelfLifeDO = new ItemShelfLifeDO();
131.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
132.         ProductRequest.ShelfLifeRequest shelfLifeRequest = productRequest.getShelfLifeRequest();
133.         itemShelfLifeDO.setItemId(itemBaseRequest.getItemId());
134.         itemShelfLifeDO.setShelfLifeContent(JSON.toJSONString(shelfLifeRequest.getShelfLife()));
135.         itemShelfLifeDO.setDelFlag(DelFlagEnum.EFFECTIVE.getCode());
136.         ...
137.         fullProductData.setItemShelfLifeDO(itemShelfLifeDO);
138.         return this;
139.     }
141.     public ProductBuilder buildItemVideoImgList() {
142.         List<ItemVideoImgDO> itemVideoImgDOList = new ArrayList<>(16);
143.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
144.         List<ProductRequest.ItemVideoImgRequest> itemVideoImgRequestList = productRequest.getItemVideoImgRequestList();
145.         for (ProductRequest.ItemVideoImgRequest itemVideoImgRequest : itemVideoImgRequestList) {
146.             ItemVideoImgDO itemVideoImgDO = new ItemVideoImgDO();
147.             itemVideoImgDO.setItemId(itemBaseRequest.getItemId());
148.             ...
149.             itemVideoImgDOList.add(itemVideoImgDO);
150.         }
151.         fullProductData.setItemVideoImgDOList(itemVideoImgDOList);
152.         return this;
153.     }
155.     public ProductBuilder buildSkuInfoList() {
156.         List<SkuInfoDO> skuInfoDOList = new ArrayList<>(16);
157.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
158.         List<ProductRequest.SkuInfoRequest> skuInfoRequestList = productRequest.getItemSaleRequest().getSkuInfoRequestList();
159.         for (ProductRequest.SkuInfoRequest skuInfoRequest : skuInfoRequestList) {
160.             SkuInfoDO skuInfoDO = new SkuInfoDO();
161.             skuInfoDO.setItemId(skuInfoRequest.getItemId());
162.             skuInfoDO.setSkuId(skuInfoRequest.getSkuId());
163.             skuInfoDO.setSkuName(skuInfoRequest.getSkuName());
164.             ...
165.             skuInfoDOList.add(skuInfoDO);
166.         }
167.         fullProductData.setSkuInfoDOList(skuInfoDOList);
168.         return this;
169.     }
171.     public ProductBuilder buildSkuBarCodeRelationList() {
172.         List<SkuBarCodeRelationDO> skuBarCodeRelationDOList = new ArrayList<>(16);
173.         List<ProductRequest.SkuInfoRequest> skuInfoRequestList = productRequest.getItemSaleRequest().getSkuInfoRequestList();
174.         for (ProductRequest.SkuInfoRequest skuInfoRequest : skuInfoRequestList) {
175.             SkuBarCodeRelationDO skuBarCodeRelationDO = new SkuBarCodeRelationDO();
176.             skuBarCodeRelationDO.setSkuId(skuInfoRequest.getSkuId());
177.             skuBarCodeRelationDO.setBarCode(skuInfoRequest.getBarCode());
178.             ...
179.             skuBarCodeRelationDOList.add(skuBarCodeRelationDO);
180.         }
181.         fullProductData.setSkuBarCodeRelationDOList(skuBarCodeRelationDOList);
182.         return this;
183.     }
185.     public ProductBuilder buildCspuSkuRelation() {
186.         List<CspuSkuRelationDO> cspuSkuRelationDOList = new ArrayList<>(16);
187.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
188.         List<ProductRequest.SkuInfoRequest> skuInfoRequestList = productRequest.getItemSaleRequest().getSkuInfoRequestList();
189.         for (ProductRequest.SkuInfoRequest skuInfoRequest : skuInfoRequestList) {
190.             CspuSkuRelationDO cspuSkuRelationDO = new CspuSkuRelationDO();
191.             cspuSkuRelationDO.setSkuId(skuInfoRequest.getSkuId());
192.             cspuSkuRelationDO.setCspuId(skuInfoRequest.getCspuId());
193.             ...
194.             cspuSkuRelationDOList.add(cspuSkuRelationDO);
195.         }
196.         fullProductData.setCspuSkuRelationDOList(cspuSkuRelationDOList);
197.         return this;
198.     }
200.     public ProductBuilder buildAttributeExtend() {
201.         AttributeExtendDO attributeExtendDO = new AttributeExtendDO();
202.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
203.         ProductRequest.ItemPopularizeRequest itemPopularizeRequest = productRequest.getItemPopularizeRequest();
204.         attributeExtendDO.setParticipateId(itemBaseRequest.getItemId());
205.         ...
206.         fullProductData.setAttributeExtendDO(attributeExtendDO);
207.         return this;
208.     }
210.     public ProductBuilder buildQualityControl() {
211.         List<QualityControlDO> qualityControlDOList = new ArrayList<>(16);
212.         ProductRequest.ItemBaseRequest itemBaseRequest = productRequest.getItemBaseRequest();
213.         ProductRequest.ItemPopularizeRequest itemPopularizeRequest = productRequest.getItemPopularizeRequest();
214.         List<ProductRequest.QualityControlRequest> qualityControlRequestList = itemPopularizeRequest.getQualityControlRequestList();
215.         for (ProductRequest.QualityControlRequest qualityControlRequest : qualityControlRequestList) {
216.             QualityControlDO qualityControlDO = new QualityControlDO();
217.             qualityControlDO.setItemId(itemBaseRequest.getItemId());
218.             qualityControlDO.setSkuId(qualityControlRequest.getSkuId());
219.             ...
220.             qualityControlDOList.add(qualityControlDO);
221.         }
222.         fullProductData.setQualityControlDOList(qualityControlDOList);
223.         return this;
224.     }
226.     public FullProductData build() {
227.         return this.fullProductData;
228.     }
229. }

复制代码

 
7.商品B端—商品建品时商品编号补全与审核配置

1. @Service
2. public class ProductServiceImpl implements ProductService {
3.     ...
4.     //建品/编辑商品
5.     @Transactional(rollbackFor = Exception.class)
6.     @Override
7.     @ParamsValidate
8.     public ProductDTO product(ProductRequest productRequest) {
9.         //入参检查
10.         checkProductRequestParam(productRequest);
11.         //商品数据处理
12.         ProductDTO productDTO = handleProduct(productRequest);
13.         //返回商品信息
14.         return productDTO;
15.     }
16.     ...
18.     //商品数据处理
19.     private ProductDTO handleProduct(ProductRequest productRequest) {
20.         //构建商品的全量信息
21.         FullProductData fullProductData = buildProduct(productRequest);
22.         //是否构建填充itemId
23.         Boolean createFlag = whetherBuildProductItemId(fullProductData);
24.         //判断是否需要审核，根据配置的sku或者item或者品类信息，如果需要审核，只处理草稿表中的数据，正式表中的数据不动
25.         if (productAuditRepository.needAudit(fullProductData, createFlag)) {
26.             //需要审核，则正式表中的数据不变更，只新增草稿表记录
27.             FullDraftData fullDraftData = buildDraft(fullProductData, AuditTypeEnum.GOODS.getCode());
28.             //保存草稿信息
29.             productAuditRepository.saveDraft(fullDraftData);
30.             return new ProductDTO(null, null);
31.         }
32.         //如果不需要审核，则保存商品信息
33.         this.saveOrUpdateDBProduct(fullProductData, createFlag);
34.         //发送消息通知订阅方
35.         sendUpdateProductMessage(fullProductData);
36.         //返回商品返回结果
37.         return new ProductDTO(fullProductData.getItemInfoDO().getItemId(), buildProductSkuIds(fullProductData));
38.     }
40.     //是否需要构建商品的ItemId
41.     private Boolean whetherBuildProductItemId(FullProductData fullProductData) {
42.         //ITEM信息
43.         ItemInfoDO itemInfoDO = fullProductData.getItemInfoDO();
44.         //新增
45.         if (StringUtils.isEmpty(itemInfoDO.getItemId())) {
46.             //保质期
47.             ItemShelfLifeDO itemShelfLifeDO = fullProductData.getItemShelfLifeDO();
48.             //生成Item的Id
49.             String itemId = createItemId();
50.             //赋值itemId
51.             itemInfoDO.setItemId(itemId);
52.             itemShelfLifeDO.setItemId(itemId);
53.             //SKU信息
54.             List<SkuInfoDO> skuInfoDOList = fullProductData.getSkuInfoDOList();
55.             for (SkuInfoDO skuInfoDO : skuInfoDOList) {
56.                 //对每个SKU也生成ID
57.                 String skuId = productNoManager.generateProductNo(ProductTypeEnum.SKU.getCode());
58.                 skuInfoDO.setSkuId(skuId);
59.                 skuInfoDO.setItemId(itemId);
60.             }
61.             //视频图片
62.             List<ItemVideoImgDO> itemVideoImgDOList = fullProductData.getItemVideoImgDOList();
63.             for (ItemVideoImgDO itemVideoImgDO : itemVideoImgDOList) {
64.                 itemVideoImgDO.setItemId(itemId);
65.             }
66.             //属性扩展
67.             AttributeExtendDO attributeExtendDO = fullProductData.getAttributeExtendDO();
68.             attributeExtendDO.setParticipateId(itemInfoDO.getItemId());
69.             attributeExtendDO.setParticipateType(ProductTypeEnum.ITEM.getCode());
70.             return true;
71.         }
72.         return false;
73.     }
75.     //创建ItemId
76.     private String createItemId() {
77.         String itemId = productNoManager.generateProductNo(ProductTypeEnum.ITEM.getCode());
78.         return itemId;
79.     }
80.     ...
81. }
83. //商品审核 资源管理
84. @Repository
85. public class ProductAuditRepository {
86.     ...
87.     //验证是否需要审核
88.     public Boolean needAudit(FullProductData fullProductData, Boolean createFlag) {
89.         ItemInfoDO itemInfoDO = fullProductData.getItemInfoDO();
90.         Integer count = 0;
91.         if (!createFlag) {
92.             //1.首先判断 商品审核内容配置表 中是否有对应的skuId
93.             List<String> skuIds = fullProductData.getSkuInfoDOList().stream().map(SkuInfoDO::getSkuId).collect(Collectors.toList());
94.             count = countByCustomIds(skuIds, AuditCustomTypeEnum.SKU);
95.             if (count > 0) {
96.                 return true;
97.             }
98.             //2.是否有对应的item
99.             count = countByCustomIds(Collections.singletonList(itemInfoDO.getItemId()), AuditCustomTypeEnum.ITEM);
100.             if (count > 0) {
101.                 return true;
102.             }
103.         }
104.         //3.验证是否有对应的categoryId
105.         List<Integer> categoryIds = Arrays.asList(itemInfoDO.getFirstCategoryId(), itemInfoDO.getSecondCategoryId(), itemInfoDO.getThirdCategoryId());
106.         count = countByCustomIds(categoryIds, AuditCustomTypeEnum.CATEGORY);
107.         //当商品审核内容配置表中有相应的品类数据，则需要审核，否则不需要审核
108.         return count > 0;
109.     }
110.     ...
111. }

复制代码

 
8.商品B端—商品审核前的草稿数据保存逻辑
[code]@Servicepublic class ProductServiceImpl implements ProductService {    ...    //建品/编辑商品    @Transactional(rollbackFor = Exception.class)    @Override    @ParamsValidate    public ProductDTO product(ProductRequest productRequest) {        //入参检查        checkProductRequestParam(productRequest);        //商品数据处理        ProductDTO productDTO = handleProduct(productRequest);        //返回商品信息        return productDTO;    }    ...    //商品数据处理    private ProductDTO handleProduct(ProductRequest productRequest) {        //构建商品的全量信息        FullProductData fullProductData = buildProduct(productRequest);        //是否构建填充itemId        Boolean createFlag = whetherBuildProductItemId(fullProductData);        //判断是否需要审核，根据配置的sku或者item或者品类信息，如果需要审核，只处理草稿表中的数据，正式表中的数据不动        if (productAuditRepository.needAudit(fullProductData, createFlag)) {            //需要审核，则正式表中的数据不变更，只新增草稿表记录            FullDraftData fullDraftData = buildDraft(fullProductData, AuditTypeEnum.GOODS.getCode());            //保存草稿信息            productAuditRepository.saveDraft(fullDraftData);            return new ProductDTO(null, null);        }        //如果不需要审核，则保存商品信息        this.saveOrUpdateDBProduct(fullProductData, createFlag);        //发送消息通知订阅方        sendUpdateProductMessage(fullProductData);        //返回商品返回结果        return new ProductDTO(fullProductData.getItemInfoDO().getItemId(), buildProductSkuIds(fullProductData));    }    ...    //根据商品数据构建商品草稿数据    private FullDraftData buildDraft(FullProductData fullProductData, Integer auditType) {        ProductDraftBuilder productDraftBuilder = new ProductDraftBuilder(fullProductData);        FullDraftData fullDraftData = productDraftBuilder.buildDraftMain(auditType)            .buildDraftImgList()            .build();        return fullDraftData;    }    ...}//商品审核 资源管理@Repositorypublic class ProductAuditRepository {    ...    //保存草稿信息    public void saveDraft(FullDraftData fullDraftData) {        //1.保存工单信息        AuditInfoDO auditInfoDO = saveAudit(fullDraftData);        //2.保存工单审核历史信息        saveAuditHistory(auditInfoDO);        //3.保存草稿信息        saveDraftMain(fullDraftData, auditInfoDO.getId());        //4.保存草稿图片信息        saveDraftImgBatch(fullDraftData);    }    //保存工单信息    private AuditInfoDO saveAudit(FullDraftData fullDraftData) {        AuditInfoDO auditInfoDO = auditConverter.converterDO(fullDraftData.getDraftMainDO());        auditInfoDO.initCommon();        int count = auditInfoMapper.insert(auditInfoDO);        if (count