大家好，我是讯享网，很高兴认识大家。

商品系统接口

商城的核心自然是商品，而商品多了以后，肯定要进行分类，并且不同的商品会有不同的品牌信息，我们需要依次去完成：品牌、商品分类、商品的开发。

品牌在系统搭建后，增删改查甚至文件上传都可以正常使用。

接下来完善商品分类及商品功能的增删改查功能。

参考课前资料中的《后台管理系统接口文档.md》

1. 商品分类

数据结构：

CREATE TABLE `pms_category` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '分类id', `name` char(50) DEFAULT NULL COMMENT '分类名称', `parent_id` bigint(20) DEFAULT NULL COMMENT '父分类id', `status` tinyint(4) DEFAULT NULL COMMENT '是否显示[0-不显示，1显示]', `sort` int(11) DEFAULT NULL COMMENT '排序', `icon` char(255) DEFAULT NULL COMMENT '图标地址', `unit` char(50) DEFAULT NULL COMMENT '计量单位', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1433 DEFAULT CHARSET=utf8mb4 COMMENT='商品三级分类'; 

讯享网

因为商品分类会有层级关系，因此这里我们加入了parent_id字段，对本表中的其它分类进行自关联。

讯享网

查看控制台，浏览器会发出如下请求

参照接口文档，开发接口

1.1. CategoryController

请求地址：parent/{parentId}，因为/pms/category已经配置在CategoryController上

请求方式：GET

请求参数：parentId

响应：ResponseVO<List<CategoryEntity>>

给CategoryController添加一个查询方法：

讯享网@ApiOperation("根据父id查询分类") @GetMapping("parent/{parentId}") public ResponseVo<List<CategoryEntity>> queryCategory(@PathVariable("parentId")Long parentId){ 
    List<CategoryEntity> categoryEntityList = this.categoryService.queryCategory(parentId); return ResponseVo.ok(categoryEntityList); } 

1.2. CategoryService

在CategoryService接口中添加接口方法

List<CategoryEntity> queryCategory(Long parentId); 

在CategoryServiceImpl实现类中实现该方法：

讯享网private CategoryMapper categoryMapper; @Override public List<CategoryEntity> queryCategory(Long parentId) { 
    // 构造查询条件 QueryWrapper<CategoryEntity> wrapper = new QueryWrapper<>(); // 如果parentId为-1，说明用户没有传该字段，查询所有 if (parentId != -1){ 
    wrapper.eq("parent_id", parentId); } return this.categoryMapper.selectList(wrapper); } 

1.3. 重启测试

1.4. 根据父节点查询

新增商品时，先根据parentId=0查询一级节点，选择一级分类后，需要根据父节点查询子节点。

2. 商品信息

2.1. SPU和SKU设计

SPU：Standard Product Unit （标准产品单位） ，一组具有共同属性的商品集

SKU：Stock Keeping Unit（库存量单位），SPU商品集因具体特性不同而细分的每个商品

以图为例来看：

• 本页的 华为Mate10 就是一个商品集（SPU）
• 因为颜色、内存等不同，而细分出不同的Mate10，如亮黑色128G版。（SKU）

可以看出：

• SPU是一个抽象的商品集概念，为了方便后台的管理。
• SKU才是具体要销售的商品，每一个SKU的价格、库存可能会不一样，用户购买的是SKU而不是SPU

表结构设计：

-- spu表 -- CREATE TABLE `pms_spu` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '商品id', `name` varchar(200) DEFAULT NULL COMMENT '商品名称', `category_id` bigint(20) DEFAULT NULL COMMENT '所属分类id', `brand_id` bigint(20) DEFAULT NULL COMMENT '品牌id', `publish_status` tinyint(4) DEFAULT NULL COMMENT '上架状态[0 - 下架，1 - 上架]', `create_time` datetime DEFAULT NULL COMMENT '创建时间', `update_time` datetime DEFAULT NULL COMMENT '更新时间', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='spu信息'; -- 商品描述表 -- CREATE TABLE `pms_spu_desc` ( `spu_id` bigint(20) NOT NULL COMMENT '商品id', `decript` longtext COMMENT '商品介绍', PRIMARY KEY (`spu_id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='spu信息介绍'; -- sku表 -- CREATE TABLE `pms_sku` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'skuId', `spu_id` bigint(20) DEFAULT NULL COMMENT 'spuId', `name` varchar(255) DEFAULT NULL COMMENT 'sku名称', `category_id` bigint(20) DEFAULT NULL COMMENT '所属分类id', `brand_id` bigint(20) DEFAULT NULL COMMENT '品牌id', `default_image` varchar(255) DEFAULT NULL COMMENT '默认图片', `title` varchar(255) DEFAULT NULL COMMENT '标题', `subtitle` varchar(2000) DEFAULT NULL COMMENT '副标题', `price` decimal(18,4) DEFAULT NULL COMMENT '价格', `weight` int(20) DEFAULT NULL COMMENT '重量（克）', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='sku信息'; -- sku图片表 -- CREATE TABLE `pms_sku_images` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `sku_id` bigint(20) DEFAULT NULL COMMENT 'sku_id', `url` varchar(255) DEFAULT NULL COMMENT '图片地址', `sort` int(11) DEFAULT NULL COMMENT '排序', `default_status` int(11) DEFAULT NULL COMMENT '默认图[0 - 不是默认图，1 - 是默认图]', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='sku图片'; 

2.2. 规格参数设计

商品规格参数有以下特点：

• 规格参数都有分组
• 同一类SPU（三级分类，如手机）的规格参数名是统一的。例如：iphone X，galaxy S10等。
• 同一spu，有些规格参数值是不变的，如：摄像头像素、摄像头数量等；而有些规格参数的值，会随着你选择的sku发生变化，如：内存、机身颜色、存储等。
• 有些规格参数需要作为sku选项（销售属性），例如：机身颜色、存储、版本等
• 有些规格参数需要参与检索（检索属性），例如：屏幕尺寸、分辨率、操作系统等
• 有些规格参数需要快速展示在商品介绍的上方

综上，表设计如下：

讯享网-- 规格参数分组（属性分组） CREATE TABLE `pms_attr_group` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '分组id', `name` char(20) DEFAULT NULL COMMENT '组名', `sort` int(11) DEFAULT NULL COMMENT '排序', `icon` varchar(255) DEFAULT NULL COMMENT '组图标', `category_id` bigint(20) DEFAULT NULL COMMENT '所属分类id', `remark` varchar(255) DEFAULT NULL COMMENT '备注', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='属性分组'; -- 规格参数表 CREATE TABLE `pms_attr` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '属性id', `name` char(30) DEFAULT NULL COMMENT '属性名', `search_type` tinyint(4) DEFAULT NULL COMMENT '是否需要检索[0-不需要，1-需要]', `icon` varchar(255) DEFAULT NULL COMMENT '属性图标', `value_select` char(255) DEFAULT NULL COMMENT '可选值列表[用逗号分隔]', `type` tinyint(4) DEFAULT NULL COMMENT '属性类型[0-销售属性，1-基本属性，2-既是销售属性又是基本属性]', `enable` bigint(20) DEFAULT NULL COMMENT '启用状态[0 - 禁用，1 - 启用]', `show_desc` tinyint(4) DEFAULT NULL COMMENT '快速展示【是否展示在介绍上；0-否 1-是】，在sku中仍然可以调整', `category_id` bigint(20) DEFAULT NULL COMMENT '所属分类', `group_id` bigint(20) DEFAULT NULL COMMENT '规格分组id', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='商品属性'; -- 通用规格参数值表 CREATE TABLE `pms_spu_attr_value` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `spu_id` bigint(20) DEFAULT NULL COMMENT '商品id', `attr_id` bigint(20) DEFAULT NULL COMMENT '属性id', `attr_name` varchar(200) DEFAULT NULL COMMENT '属性名', `attr_value` varchar(200) DEFAULT NULL COMMENT '属性值', `sort` int(11) DEFAULT NULL COMMENT '顺序', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='spu属性值'; -- 销售规格参数值表 CREATE TABLE `pms_sku_attr_value` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT 'id', `sku_id` bigint(20) DEFAULT NULL COMMENT 'sku_id', `attr_id` bigint(20) DEFAULT NULL COMMENT 'attr_id', `attr_name` varchar(200) DEFAULT NULL COMMENT '销售属性名', `attr_value` varchar(200) DEFAULT NULL COMMENT '销售属性值', `sort` int(11) DEFAULT NULL COMMENT '顺序', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='sku销售属性&值'; 

2.3. 规格属性查询

2.3.1. 查询规格分组

查看控制台，对应的发送了3个请求：

其中有一个是查询分组。结合接口文档：

请求地址：category/{cid}，Controller上已经标记了/pms/attrgroup

请求方式：GET

请求参数：一些基本分页条件已经封装到PageParamVo，然后有一个占位符参数（商品分类：225）

正确响应：ResponseVo<PageResultVO>

AttrGroupController中添加Controller方法：

@ApiOperation("根据三级分类id查询") @GetMapping("category/{cid}") public ResponseVo<List<AttrGroupEntity>> queryByCidPage(@PathVariable("cid")Long cid){ 
    List<AttrGroupEntity> groupEntities = this.attrGroupService.list(new QueryWrapper<AttrGroupEntity>().eq("category_id", cid)); return ResponseVo.ok(groupEntities); } 

测试效果：

2.3.2. 查询分组下的规格参数

点击属性分组下的维护关联关系，可以查看该分组下的所有属性，并可以添加、删除关联关系。

参考接口文档：

请求地址：group/{gid}，已经在AttrController上配置/pms/attr

请求方式：GET

请求参数：gid

正确响应：Response<List>

AttrController添加方法：

讯享网@GetMapping("group/{gid}") @ApiOperation("分页查询") public ResponseVo<List<AttrEntity>> queryAttrsByGid(@PathVariable("gid")Long gid){ 
    List<AttrEntity> attrEntities = this.attrService.list(new QueryWrapper<AttrEntity>().eq("group_id", gid)); return ResponseVo.ok(attrEntities); } 

测试：

2.4. 商品查询

2.4.1. 查询商品列表

查看控制台：

结合接口文档

请求地址：category/{categoryId}，SpuInfoController类上的路径是/pms/spuinfo

请求方式：GET

请求参数：PageParamVo+ categoryId

正确响应：ResponseVo

SpuInfoController添加方法：

@ApiOperation("spu商品信息查询") @GetMapping("category/{categoryId}") public ResponseVo<PageResultVo> querySpuInfo(PageParamVo pageParamVo, @PathVariable("categoryId")Long categoryId){ 
    PageResultVo pageResultVo = this.spuService.querySpuInfo(pageParamVo, categoryId); return ResponseVo.ok(pageResultVo); } 

SpuInfoService接口方法：

讯享网PageResultVo querySpuInfo(PageParamVo pageParamVo, Long categoryId); 

SpuInfoServiceImpl实现类实现该方法：

@Override public PageResultVo querySpuInfo(PageParamVo pageParamVo, Long categoryId) { 
    // 封装查询条件 QueryWrapper<SpuEntity> wrapper = new QueryWrapper<>(); // 如果分类id不为0，要根据分类id查，否则查全部 if (categoryId != 0){ 
    wrapper.eq("category_id", categoryId); } // 如果用户输入了检索条件，根据检索条件查 String key = pageParamVo.getKey(); if (StringUtils.isNotBlank(key)){ 
    wrapper.and(t -> t.like("name", key).or().like("id", key)); } return new PageResultVo(this.page(pageParamVo.getPage(), wrapper)); } 

测试：

2.4.2. 查询SPU下的SKU

找到库存管理下的商品库存

点击一个商品的库存维护：

结合接口文档：

请求地址：spu/{spuId}

请求方式：GET

请求参数：spuId

正确响应：Resp<List<SkuEntity>>

给SkuInfoController添加方法：

讯享网/ * 根据spuId查询sku列表 */ @GetMapping("spu/{spuId}") @ApiOperation("根据spuId查询sku列表") public ResponseVo<List<SkuEntity>> list(@PathVariable("spuId")Long spuId){ 
    List<SkuEntity> skuEntities = skuService.list(new QueryWrapper<SkuEntity>().eq("spu_id", spuId)); return ResponseVo.ok(skuEntities); } 

测试：

2.4.3. 查询SKU的库存信息

sku列表中的库存维护

参照接口文档：

请求地址：/sku/{skuId} 在gmall-wms系统的WareSkuController中已经配置了/wms/waresku/

请求方式：GET

请求参数：skuId

正确响应：ResponseVo<List<WareSkuEntity>>

WareSkuController添加方法：

@ApiOperation("根据skuId查询库存信息") @GetMapping("sku/{skuId}") public ResponseVo<List<WareSkuEntity>> queryWareSkuBySkuId(@PathVariable("skuId")Long skuId){ 
    List<WareSkuEntity> wareSkuEntities = this.wareSkuService.list(new QueryWrapper<WareSkuEntity>().eq("sku_id", skuId)); return ResponseVo.ok(wareSkuEntities); } 

测试：

2.5. 商品新增

点击添加spu按钮，跳转到新增spu页面

填写完表单，点击下一步

进入录入spu属性信息，但是没有显示spu属性（即规格参数）。

2.5.1. 查询分类下的分组及其规格参数

当添加商品时，应该根据用户选择的商品分类，显示不同规格参数名，让用户填写对应的参数值。上图控制台发送的这个请求，就是根据分类id查询分组及组下的属性，并动态生成一个表单，让用户填写参数值

参照接口文档：

请求地址：/withattrs/{catId}

请求方式：GET

请求参数：catId

正确响应：ResponseVo<List<?>>

这里的响应数据比AttrGroupEntity多出来一个字段，就是组下的属性列表attrEntities。所以要给AttrGroupEntity扩展一个字段，有两种扩展方式：

1. 直接在AttrGroupEntity中添加一个字段attrEntities
2. 编写一个扩展类GroupVo继承AttrGroupEntity，然后扩展一个attrEntities

推荐使用第二种方式，因为AttrGroupEntity作为一个基础实体类和数据库操作密切相关，很多人都会用到。

GroupVo实体类：

AttrGroupController添加方法：

讯享网@ApiOperation("根据三级分类id查询分组及组下的规格参数") @GetMapping("/withattrs/{catId}") public ResponseVo<List<GroupVo>> queryByCid(@PathVariable("catId")Long cid){ 
    List<GroupVo> groupVos = this.attrGroupService.queryByCid(cid); return ResponseVo.ok(groupVos); } 

AttrGroupService的接口方法：

List<GroupVo> queryByCid(Long cid); 

AttrGroupServiceImpl实现类实现接口方法：

讯享网@Override public List<GroupVo> queryByCid(Long cid) { 
    // 查询所有的分组 List<AttrGroupEntity> attrGroupEntities = this.list(new QueryWrapper<AttrGroupEntity>().eq("category_id", cid)); // 查询出每组下的规格参数 return attrGroupEntities.stream().map(attrGroupEntity -> { 
    GroupVo groupVo = new GroupVo(); BeanUtils.copyProperties(attrGroupEntity, groupVo); // 查询规格参数，只需查询出每个分组下的通用属性就可以了（不需要销售属性） List<AttrEntity> attrEntities = this.attrMapper.selectList(new QueryWrapper<AttrEntity>().eq("group_id", attrGroupEntity.getId()).eq("type", 1)); groupVo.setAttrEntities(attrEntities); return groupVo; }).collect(Collectors.toList()); } 

测试：

2.5.2. 查询分类下的销售属性

点击“下一步”进入第三步，页面没有数据。查看控制台发送了查询请求：

参照接口文档：

请求地址：category/{cid}?type=0&searchType=1

请求方式：GET

请求参数：cid, type, searchType

正确响应：ResponseVo<List<AttrEntity>>

AttrController:

@GetMapping("category/{cid}") @ApiOperation("分类查询") public ResponseVo<List<AttrEntity>> queryAttrsByCid(@PathVariable("cid")Long cid, @RequestParam(value = "type", required = false)Integer type, @RequestParam(value = "searchType", required = false) Integer searchType){ 
    List<AttrEntity> attrEntities = this.attrService.queryAttrsByCid(cid, type, searchType); return ResponseVo.ok(attrEntities); } 

AttrService:

讯享网List<AttrEntity> queryAttrsByCid(Long cid, Integer type, Integer searchType); 

AttrServiceImpl:

@Override public List<AttrEntity> queryAttrsByCid(Long cid, Integer type, Integer searchType) { 
    QueryWrapper<AttrEntity> queryWrapper = new QueryWrapper<>(); // 分类id如果为0，查询所有分类的规格参数 if (cid != 0) { 
    queryWrapper.eq("category_id", cid); } // 如果参数类型不为空 if (type != null) { 
    queryWrapper.eq("type", type); } // 如果参数类型不为空 if (searchType != null) { 
    queryWrapper.eq("search_type", searchType); } return this.list(queryWrapper); } 

2.5.3. 为页面提交的数据构建数据模型

每个sku都可以再次展开，sku基本信息，优惠信息，以及图片上传

最后点击确定，显示保存成功！？查看数据库你会发现它只保存了spu的基本信息。

查看控制台，可以看到：

提交的数据非常复杂，如下：

讯享网{ 
    "name": "华为mate30pro", "brandId": 2, "categoryId": 225, "publishStatus": 1, "spuImages": ["https://ggmall.oss-cn-shanghai.aliyuncs.com/2020-03-20/2e3c0156-a8a5-4ae2-8e5d-efa95_eda8c4cf (1).jpg", "https://ggmall.oss-cn-shanghai.aliyuncs.com/2020-03-20/41af1ab5-6625-4ef3-8991-ddece4933fe8_eda8c4cf (1).jpg"], "baseAttrs": [{ 
    "id": 1, "name": "上市年份", "valueSelected": ["2019"] }, { 
    "id": 2, "name": "产品名称", "valueSelected": ["HUAWEI Mate 30"] }, { 
    "id": 6, "name": "CPU品牌", "valueSelected": ["麒麟"] }, { 
    "id": 7, "name": "CPU型号", "valueSelected": ["麒麟990 5G"] }, { 
    "id": 8, "name": "分辨率", "valueSelected": ["FHD+ 2340×1080 像素"] }, { 
    "id": 9, "name": "屏幕尺寸", "valueSelected": ["7"] }], "skus": [{ 
    "attr_3": "黑色", "price": "5000", "stock": 0, "growBounds": "2000", "buyBounds": "1000", "work": [1, 0, 1, 0], "fullCount": "2", "discount": "90", "fullPrice": "5000", "reducePrice": "500", "fullAddOther": 1, "images": ["https://ggmall.oss-cn-shanghai.aliyuncs.com/2020-03-20/dd-93a3-4d9a-8c8d-ce5f5e5e1904_eda8c4cf (1).jpg", "https://ggmall.oss-cn-shanghai.aliyuncs.com/2020-03-20/01f785b4-b984-4246-8724-5a1d2c423fd0_e9ad9735fc3f0686.jpg"], "name": "华为mate30pro 黑色,8G,256G", "title": "华为 HUAWEI Mate 30 5G 麒麟990 4000万超感光徕卡影像双超级快充8GB+256GB亮黑色5G全网通游戏手机", "subTitle": "华为mate30pro 黑色,8G,256G", "weight": "500", "attr_4": "8G", "attr_5": "256G", "ladderAddOther": 1, "subtitle": "【直降500元！到手价4999元！享12期免息！低至13.7元/天】双4000万徕卡电影四摄；Mate30直降500元享12期》", "saleAttrs": [{ 
    "attrId": "3", "attrValue": "黑色" }, { 
    "attrId": "4", "attrValue": "8G" }, { 
    "attrId": "5", "attrValue": "256G" }] }, { 
    "attr_3": "黑色", "price": "6000", "stock": 0, "growBounds": "1000", "buyBounds": "1000", "work": [1, 0, 1, 0], "fullCount": "3", "discount": "80", "fullPrice": "6000", "reducePrice": "2000", "fullAddOther": 1, "images": ["https://ggmall.oss-cn-shanghai.aliyuncs.com/2020-03-20/7cf5c7d2-f9a2-4767-8e90-d41b67a5ffd2_e9ad9735fc3f0686.jpg", "https://ggmall.oss-cn-shanghai.aliyuncs.com/2020-03-20/8e7189ce-5043-4d4c-8a8b-ee451_cca298ae79 (1).jpg"], "name": "华为mate30pro 黑色,8G,512G", "title": "华为 HUAWEI Mate 30 5G 麒麟990 4000万超感光徕卡影像双超级快充8GB+128GB亮黑色5G全网通游戏手机", "subTitle": "华为mate30pro 黑色,8G,512G", "weight": "510", "attr_4": "8G", "attr_5": "512G", "ladderAddOther": 1, "subtitle": "【直降500元！到手价4499元！享12期免息！低至12.3元/天】双4000万徕卡电影四摄；Mate30直降500元享12期》", "saleAttrs": [{ 
    "attrId": "3", "attrValue": "黑色" }, { 
    "attrId": "4", "attrValue": "8G" }, { 
    "attrId": "5", "attrValue": "512G" }] }] } 

由于提交的是json数据，所以只能通过一个对象来进行接收，这就需要咱们来构建一个VO对象。涉及的表肯定也不只spu一张表。

这么复杂的数据结构，我们一层层的剥茧抽丝式的查看：

2.5.2.1. 先看json数据的最外层

对应pms_spu表的信息，还多了三个字段：spuImages、baseAttrs、skus。也就是说需要对SpuInfoEntity进行扩展。首选可以确定这三个字段是集合，因为值都有方括号。

创建SpuVO对象：

内容如下：

/ * spuInfo扩展对象 * 包含：spuInfo基本信息、spuImages图片信息、baseAttrs基本属性信息、skus信息 */ @Data public class SpuVO extends SpuInfoEntity { 
    // 图片信息 private List<?> spuImages; // 基本属性信息 private List<?> baseAttrs; // sku信息 private List<?> skus; } 

接下来就分析这三个集合中，都是什么数据类型的数据。

2.5.2.2. spuImages

首先spuImages很简单，就是字符串数组：

也就是说，SpuInfoVO对象是这样的：

讯享网/ * spu扩展对象 * 包含：spu基本信息、spuImages图片信息、baseAttrs基本属性信息、skus信息 */ @Data public class SpuVO extends SpuInfoEntity { 
    // 图片信息 private List<String> spuImages; // 基本属性信息 private List<?> baseAttrs; // sku信息 private List<?> skus; } 

2.5.2.3. baseAttrs

对应的表是pms_spu_attr_value，对应的实体类是SpuAttrValueEntity

注意：attrValue的值在实体类中是String，而传过来时参数名是valueSelected，值为集合类型。

所以，必须扩展SpuAttrValueEntity类：

重写setter方法，因为参数接收时的本质是调用setter方法接收的：

public class SpuAttrValueVo extends SpuAttrValueEntity { 
    public void setValueSelected(List<Object> valueSelected){ 
    // 如果接受的集合为空，则不设置 if (CollectionUtils.isEmpty(valueSelected)){ 
    return; } this.setAttrValue(StringUtils.join(valueSelected, ",")); } } 

现在SpuInfoVO中的第二参数的集合泛型也搞定了：

讯享网@Data public class SpuVo extends SpuEntity { 
    // 图片信息 private List<String> spuImages; // 基本属性信息 private List<SpuAttrValueVo> baseAttrs; // sku信息 private List<?> skus; } 

2.5.2.4. skus

一部分字段对应的是pms_sku这张表，对应的实体类是SkuEntity。

images这个字段保存到pms_sku_images这张表。

一部分字段对应的是sms_sku_bounds表，对应的实体类是gmall-sms服务中的SkuBoundsEntity

一部分字段对应的表是sms_sku_full_reduction，对应的实体类是gmall-sms微服务中的SkuFullReductionEntity

一部分字段对应的表是sms_sku_ladder，对应的实体类是gmall-sms微服务的SkuLadderEntity

最后一个字段就是saleAttrs，对应的是pms_sku_attr_value，实体类是List<SkuAttrValueEntity>

由于java是单继承，所以这里只能选择一个继承，其他的字段在从对应的实体类中copy过来。这里选择扩展SkuEntity这个实体类：（注意：带下划线的字段为垃圾字段，不用接收）

内容如下：

@Data public class SkuVo extends SkuEntity { 
    private List<String> images; // 积分活动 private BigDecimal growBounds; private BigDecimal buyBounds; / * 优惠生效情况[1111（四个状态位，从右到左）; * 0 - 无优惠，成长积分是否赠送; * 1 - 无优惠，购物积分是否赠送; * 2 - 有优惠，成长积分是否赠送; * 3 - 有优惠，购物积分是否赠送【状态位0：不赠送，1：赠送】] */ private List<Integer> work; // 满减活动 private BigDecimal fullPrice; private BigDecimal reducePrice; private Integer fullAddOther; private Integer fullCount; private BigDecimal discount; / * 是否叠加其他优惠[0-不可叠加，1-可叠加] */ private Integer addOther; private List<SkuAttrValueEntity> saleAttrs; } 

最终的SpuVO：

讯享网@Data public class SpuVo extends SpuEntity { 
    // 图片信息 private List<String> spuImages; // 基本属性信息 private List<SpuAttrValueVo> baseAttrs; // sku信息 private List<SkuVo> skus; } 

2.5.3. 完成SPU新增功能

SpuController：改造之前的新增方法

/ * 保存 */ @PostMapping @ApiOperation("保存") public ResponseVo<Object> save(@RequestBody SpuVo spuVo){ 
    spuService.bigSave(spuVo); return ResponseVo.ok(); } 

SpuService接口添加方法：

讯享网void bigSave(SpuVo spu); 

SpuServiceImpl实现类实现新增方法：

@Autowired private SpuDescMapper descMapper; @Autowired private SpuAttrValueService baseService; @Override public void bigSave(SpuVo spuVo) { 
    /// 1.保存spu相关 // 1.1. 保存spu基本信息 spu_info spuVo.setPublishStatus(1); // 默认是已上架 spuVo.setCreateTime(new Date()); spuVo.setUpdateTime(spuVo.getCreateTime()); // 新增时，更新时间和创建时间一致 this.save(spuVo); Long spuId = spuVo.getId(); // 获取新增后的spuId // 1.2. 保存spu的描述信息 spu_info_desc SpuDescEntity spuInfoDescEntity = new SpuDescEntity(); // 注意：spu_info_desc表的主键是spu_id,需要在实体类中配置该主键不是自增主键 spuInfoDescEntity.setSpuId(spuId); // 把商品的图片描述，保存到spu详情中，图片地址以逗号进行分割 spuInfoDescEntity.setDecript(StringUtils.join(spuVo.getSpuImages(), ",")); this.descMapper.insert(spuInfoDescEntity); // 1.3. 保存spu的规格参数信息 List<SpuAttrValueVo> baseAttrs = spuVo.getBaseAttrs(); if (!CollectionUtils.isEmpty(baseAttrs)) { 
    List<SpuAttrValueEntity> spuAttrValueEntities = baseAttrs.stream().map(spuAttrValueVO -> { 
    spuAttrValueVO.setSpuId(spuId); spuAttrValueVO.setSort(0); return spuAttrValueVO; }).collect(Collectors.toList()); this.baseService.saveBatch(spuAttrValueEntities); } /// 2. 保存sku相关信息 // 2.1. 保存sku基本信息 // 2.2. 保存sku图片信息 // 2.3. 保存sku的规格参数（销售属性） // 3. 保存营销相关信息，需要远程调用gmall-sms // 3.1. 积分优惠 // 3.2. 满减优惠 // 3.3. 数量折扣 } 

注意：SpuDescEntity对象的主键需要设置为手动设置，无法手动设置。

测试效果：3张表的值均可正常插入

2.5.4. 完成SKU新增功能

继续完善SpuServiceImpl实现类新增方法：

讯享网@Autowired private SpuDescMapper descMapper; @Autowired private SpuAttrValueService baseService; @Autowired private SkuMapper skuMapper; @Autowired private SkuImagesService skuImagesService; @Autowired private SkuAttrValueService skuAttrValueService; @Override public void bigSave(SpuVo spuVo) { 
    /// 1.保存spu相关 // 1.1. 保存spu基本信息 spu_info spuVo.setPublishStatus(1); // 默认是已上架 spuVo.setCreateTime(new Date()); spuVo.setUpdateTime(spuVo.getCreateTime()); // 新增时，更新时间和创建时间一致 this.save(spuVo); Long spuId = spuVo.getId(); // 获取新增后的spuId // 1.2. 保存spu的描述信息 spu_info_desc SpuDescEntity spuInfoDescEntity = new SpuDescEntity(); // 注意：spu_info_desc表的主键是spu_id,需要在实体类中配置该主键不是自增主键 spuInfoDescEntity.setSpuId(spuId); // 把商品的图片描述，保存到spu详情中，图片地址以逗号进行分割 spuInfoDescEntity.setDecript(StringUtils.join(spuVo.getSpuImages(), ",")); this.descMapper.insert(spuInfoDescEntity); // 1.3. 保存spu的规格参数信息 List<SpuAttrValueVo> baseAttrs = spuVo.getBaseAttrs(); if (!CollectionUtils.isEmpty(baseAttrs)) { 
    List<SpuAttrValueEntity> spuAttrValueEntities = baseAttrs.stream().map(spuAttrValueVO -> { 
    spuAttrValueVO.setSpuId(spuId); spuAttrValueVO.setSort(0); return spuAttrValueVO; }).collect(Collectors.toList()); this.baseService.saveBatch(spuAttrValueEntities); } /// 2. 保存sku相关信息 List<SkuVo> skuVos = spuVo.getSkus(); if (CollectionUtils.isEmpty(skuVos)){ 
    return; } skuVos.forEach(skuVo -> { 
    // 2.1. 保存sku基本信息 SkuEntity skuEntity = new SkuEntity(); BeanUtils.copyProperties(skuVo, skuEntity); // 品牌和分类的id需要从spuInfo中获取 skuEntity.setBrandId(spuVo.getBrandId()); skuEntity.setCatagoryId(spuVo.getCategoryId()); // 获取图片列表 List<String> images = skuVo.getImages(); // 如果图片列表不为null，则设置默认图片 if (!CollectionUtils.isEmpty(images)){ 
    // 设置第一张图片作为默认图片 skuEntity.setDefaultImage(skuEntity.getDefaultImage()==null ? images.get(0) : skuEntity.getDefaultImage()); } skuEntity.setSpuId(spuId); this.skuMapper.insert(skuEntity); // 获取skuId Long skuId = skuEntity.getId(); // 2.2. 保存sku图片信息 if (!CollectionUtils.isEmpty(images)){ 
    String defaultImage = images.get(0); List<SkuImagesEntity> skuImageses = images.stream().map(image -> { 
    SkuImagesEntity skuImagesEntity = new SkuImagesEntity(); skuImagesEntity.setDefaultStatus(StringUtils.equals(defaultImage, image) ? 1 : 0); skuImagesEntity.setSkuId(skuId); skuImagesEntity.setSort(0); skuImagesEntity.setUrl(image); return skuImagesEntity; }).collect(Collectors.toList()); this.skuImagesService.saveBatch(skuImageses); } // 2.3. 保存sku的规格参数（销售属性） List<SkuAttrValueEntity> saleAttrs = skuVo.getSaleAttrs(); saleAttrs.forEach(saleAttr -> { 
    // 设置属性名，需要根据id查询AttrEntity saleAttr.setSort(0); saleAttr.setSkuId(skuId); }); this.skuAttrValueService.saveBatch(saleAttrs); // 3. 保存营销相关信息，需要远程调用gmall-sms // 3.1. 积分优惠 // 3.2. 满减优惠 // 3.3. 数量折扣 }); } 

测试：sku相关的3张表保存成功

2.5.5. sms提供营销保存接口

SkuVo中剩余没有保存的字段都是营销信息的字段，需要把这些数据传输给营销系统，接下来首先创建一个数据模型

在gmall-sms中添加VO对象

内容如下：营销信息 + skuId

@Data public class SkuSaleVo { 
    private Long skuId; // 积分活动 private BigDecimal growBounds; private BigDecimal buyBounds; / * 优惠生效情况[1111（四个状态位，从右到左）; * 0 - 无优惠，成长积分是否赠送; * 1 - 无优惠，购物积分是否赠送; * 2 - 有优惠，成长积分是否赠送; * 3 - 有优惠，购物积分是否赠送【状态位0：不赠送，1：赠送】] */ private List<Integer> work; // 满减活动 private BigDecimal fullPrice; private BigDecimal reducePrice; private Integer fullAddOther; private Integer fullCount; private BigDecimal discount; / * 是否叠加其他优惠[0-不可叠加，1-可叠加] */ private Integer addOther; } 

在SkuBoundsController中添加方法：

讯享网@ApiOperation("新增sku的营销信息") @PostMapping("/skusale/save") public ResponseVo<Object> saveSkuSaleInfo(@RequestBody SkuSaleVo skuSaleVo){ 
    this.skuBoundsService.saveSkuSaleInfo(skuSaleVo); return ResponseVo.ok(null); } 

给SkuBoundsService接口添加方法：

void saveSkuSaleInfo(SkuSaleVo skuSaleVo); 

给SkuBoundsServiceImpl实现类添加实现方法：

讯享网@Autowired private SkuFullReductionMapper skuFullReductionMapper; @Autowired private SkuLadderMapper skuLadderMapper; @Override public void saveSkuSaleInfo(SkuSaleVo skuSaleVo) { 
    // 3.1. 积分优惠 SkuBoundsEntity skuBoundsEntity = new SkuBoundsEntity(); BeanUtils.copyProperties(skuSaleVo, skuBoundsEntity); // 数据库保存的是整数0-15，页面绑定是0000-1111 List<Integer> work = skuSaleVo.getWork(); if (!CollectionUtils.isEmpty(work)){ 
    skuBoundsEntity.setWork(work.get(0) * 8 + work.get(1) * 4 + work.get(2) * 2 + work.get(3)); } this.save(skuBoundsEntity); // 3.2. 满减优惠 SkuFullReductionEntity skuFullReductionEntity = new SkuFullReductionEntity(); BeanUtils.copyProperties(skuSaleVo, skuFullReductionEntity); skuFullReductionEntity.setAddOther(skuSaleVo.getFullAddOther()); this.skuFullReductionMapper.insert(skuFullReductionEntity); // 3.3. 数量折扣 SkuLadderEntity skuLadderEntity = new SkuLadderEntity(); BeanUtils.copyProperties(skuSaleVo, skuLadderEntity); this.skuLadderMapper.insert(skuLadderEntity); } 

2.5.6. pms调用营销保存接口

feign的玩法分以下三步：

1. 引入openfeign的启动器，已添加
2. 在引导类上添加@EnableFeignClients
3. 编写feign接口

在gmall-pms的引导类（GmallPmsApplication）上添加@EnableFeignClients注解

添加SkuSaleVo实体类和GmallSmsClient接口

SkuSaleVo的内容参照gmall-sms中的SkuSaleVo的内容

GmallSmsClient的内容：

@FeignClient("sms-service") public interface GmallSmsClient { 
    @PostMapping("/sms/skubounds/skusale/save") public ResponseVo<Object> saveSkuSaleInfo(@RequestBody SkuSaleVo skuSaleVo); } 

完成商品新增：

讯享网@Autowired private SpuDescMapper descMapper; @Autowired private SpuAttrValueService baseService; @Autowired private SkuMapper skuMapper; @Autowired private SkuImagesService skuImagesService; @Autowired private SkuAttrValueService skuAttrValueService; @Autowired private GmallSmsClient smsClient; @Override public void bigSave(SpuVo spuVo) { 
    /// 1.保存spu相关 // 1.1. 保存spu基本信息 spu_info Long spuId = saveSpu(spuVo); // 1.2. 保存spu的描述信息 spu_info_desc saveSpuDesc(spuVo, spuId); // 1.3. 保存spu的规格参数信息 saveBaseAttr(spuVo, spuId); /// 2. 保存sku相关信息 saveSku(spuVo, spuId); } private void saveSku(SpuVo spuVo, Long spuId) { 
    List<SkuVo> skuVos = spuVo.getSkus(); if (CollectionUtils.isEmpty(skuVos)){ 
    return; } skuVos.forEach(skuVo -> { 
    // 2.1. 保存sku基本信息 SkuEntity skuEntity = new SkuEntity(); BeanUtils.copyProperties(skuVo, skuEntity); // 品牌和分类的id需要从spuInfo中获取 skuEntity.setBrandId(spuVo.getBrandId()); skuEntity.setCatagoryId(spuVo.getCategoryId()); // 获取图片列表 List<String> images = skuVo.getImages(); // 如果图片列表不为null，则设置默认图片 if (!CollectionUtils.isEmpty(images)){ 
    // 设置第一张图片作为默认图片 skuEntity.setDefaultImage(skuEntity.getDefaultImage()==null ? images.get(0) : skuEntity.getDefaultImage()); } skuEntity.setSpuId(spuId); this.skuMapper.insert(skuEntity); // 获取skuId Long skuId = skuEntity.getId(); // 2.2. 保存sku图片信息 if (!CollectionUtils.isEmpty(images)){ 
    String defaultImage = images.get(0); List<SkuImagesEntity> skuImageses = images.stream().map(image -> { 
    SkuImagesEntity skuImagesEntity = new SkuImagesEntity(); skuImagesEntity.setDefaultStatus(StringUtils.equals(defaultImage, image) ? 1 : 0); skuImagesEntity.setSkuId(skuId); skuImagesEntity.setSort(0); skuImagesEntity.setUrl(image); return skuImagesEntity; }).collect(Collectors.toList()); this.skuImagesService.saveBatch(skuImageses); } // 2.3. 保存sku的规格参数（销售属性） List<SkuAttrValueEntity> saleAttrs = skuVo.getSaleAttrs(); saleAttrs.forEach(saleAttr -> { 
    // 设置属性名，需要根据id查询AttrEntity saleAttr.setSort(0); saleAttr.setSkuId(skuId); }); this.skuAttrValueService.saveBatch(saleAttrs); // 3. 保存营销相关信息，需要远程调用gmall-sms SkuSaleVo skuSaleVo = new SkuSaleVo(); BeanUtils.copyProperties(skuVo, skuSaleVo); skuSaleVo.setSkuId(skuId); this.smsClient.saveSkuSaleInfo(skuSaleVo); }); } private void saveBaseAttr(SpuVo spuVo, Long spuId) { 
    List<SpuAttrValueVo> baseAttrs = spuVo.getBaseAttrs(); if (!CollectionUtils.isEmpty(baseAttrs)) { 
    List<SpuAttrValueEntity> spuAttrValueEntities = baseAttrs.stream().map(spuAttrValueVO -> { 
    spuAttrValueVO.setSpuId(spuId); spuAttrValueVO.setSort(0); return spuAttrValueVO; }).collect(Collectors.toList()); this.baseService.saveBatch(spuAttrValueEntities); } } private void saveSpuDesc(SpuVo spuVo, Long spuId) { 
    SpuDescEntity spuInfoDescEntity = new SpuDescEntity(); // 注意：spu_info_desc表的主键是spu_id,需要在实体类中配置该主键不是自增主键 spuInfoDescEntity.setSpuId(spuId); // 把商品的图片描述，保存到spu详情中，图片地址以逗号进行分割 spuInfoDescEntity.setDecript(StringUtils.join(spuVo.getSpuImages(), ",")); this.descMapper.insert(spuInfoDescEntity); } private Long saveSpu(SpuVo spuVo) { 
    spuVo.setPublishStatus(1); // 默认是已上架 spuVo.setCreateTime(new Date()); spuVo.setUpdateTime(spuVo.getCreateTime()); // 新增时，更新时间和创建时间一致 this.save(spuVo); return spuVo.getId(); } 

3. feign的**实践

以上的这些代码直接从营销微服务中拷贝而来，完全一致。差别就是没有方法的具体实现。大家觉得这样有没有问题？

而FeignClient代码遵循SpringMVC的风格，因此与商品微服务的Controller完全一致。这样就存在一定的问题：

• 代码冗余。尽管不用写实现，只是写接口，但服务调用方要写与服务controller一致的代码，有几个消费者就要写几次。另外DTO对象，在每个需要feign的工程里面都要维护一份。
• 增加开发成本。调用方还得清楚知道接口的路径，才能编写正确的FeignClient。

解决方案：

• 我们的服务提供方不仅提供实体类，还要提供api接口声明
• 调用方不用自己编写接口方法声明，直接继承提供方给的Api接口即可

第一步：服务的提供方在gmall-sms-interface中提供API接口，并编写接口声明：

第二步：在调用方gmall-pms中编写FeignClient，但不要写方法声明了，直接继承gmall-sms-interface提供的api接口：

3.1. 服务提供方添加接口工程

服务提供方需要创建接口工程：

工程结构如下：

pom.xml中的内容：

xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns='http://maven.apache.org/POM/4.0.0' xmlns:xsi="'http://www.w3.org/2001/XMLSchema-instance' xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <artifactId>gmall</artifactId> <groupId>com.atguigu</groupId> <version>0.0.1-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>gmall-sms-interface</artifactId> <dependencies> <dependency> <groupId>com.atguigu</groupId> <artifactId>gmall-common</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-webmvc</artifactId> <version>5.2.4.RELEASE</version> </dependency> </dependencies> </project> 

SkuSaleVo的内容跟之前没有变化，只是移动到接口工程了

讯享网@Data public class SkuSaleVO { 
    private Long skuId; // 积分活动 private BigDecimal growBounds; private BigDecimal buyBounds; / * 优惠生效情况[1111（四个状态位，从右到左）; * 0 - 无优惠，成长积分是否赠送; * 1 - 无优惠，购物积分是否赠送; * 2 - 有优惠，成长积分是否赠送; * 3 - 有优惠，购物积分是否赠送【状态位0：不赠送，1：赠送】] */ private List<Integer> work; // 满减活动 private BigDecimal fullPrice; private BigDecimal reducePrice; private Integer fullAddOther; private Integer fullCount; private BigDecimal discount; / * 是否叠加其他优惠[0-不可叠加，1-可叠加] */ private Integer addOther; } 

SkuSaleApi接口：

public interface GmallSmsApi { 
    @PostMapping("/sms/skubounds/skusale/save") public Resp<Object> saveSkuSaleInfo(@RequestBody SkuSaleVO skuSaleVO); } 

3.2. 服务提供方微服务

只要引入接口工程，重新到一下包即可

讯享网<dependency> <groupId>com.atguigu</groupId> <artifactId>gmall-sms-interface</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> 

之前微服务中定义的Vo可以删掉了：

3.3. 服务消费方

也需要依赖营销的接口工程即可：

<dependency> <groupId>com.atguigu</groupId> <artifactId>gmall-sms-interface</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> 

也不需要自己定义Vo了，另外GmallSmsClient内容变的及其简单：

讯享网@FeignClient("sms-service") public interface GmallSmsClient extends GmallSmsApi { 
    } 

3.4. 小结

/dependencies>

 SkuSaleVo的内容跟之前没有变化，只是移动到接口工程了 ```java @Data public class SkuSaleVO { private Long skuId; // 积分活动 private BigDecimal growBounds; private BigDecimal buyBounds; / * 优惠生效情况[1111（四个状态位，从右到左）; * 0 - 无优惠，成长积分是否赠送; * 1 - 无优惠，购物积分是否赠送; * 2 - 有优惠，成长积分是否赠送; * 3 - 有优惠，购物积分是否赠送【状态位0：不赠送，1：赠送】] */ private List<Integer> work; // 满减活动 private BigDecimal fullPrice; private BigDecimal reducePrice; private Integer fullAddOther; private Integer fullCount; private BigDecimal discount; / * 是否叠加其他优惠[0-不可叠加，1-可叠加] */ private Integer addOther; } 

SkuSaleApi接口：

讯享网public interface GmallSmsApi { 
    @PostMapping("/sms/skubounds/skusale/save") public Resp<Object> saveSkuSaleInfo(@RequestBody SkuSaleVO skuSaleVO); } 

3.2. 服务提供方微服务

只要引入接口工程，重新到一下包即可

<dependency> <groupId>com.atguigu</groupId> <artifactId>gmall-sms-interface</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> 

之前微服务中定义的Vo可以删掉了：

[外链图片转存中…(img-uVz8Bah8-46)]

3.3. 服务消费方

[外链图片转存中…(img-d5UmXNzr-47)]

也需要依赖营销的接口工程即可：

讯享网<dependency> <groupId>com.atguigu</groupId> <artifactId>gmall-sms-interface</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency> 

也不需要自己定义Vo了，另外GmallSmsClient内容变的及其简单：

@FeignClient("sms-service") public interface GmallSmsClient extends GmallSmsApi { 
    } 

3.4. 小结