分布式电商项目四十四：发布商品功能-保存商品信息

发布商品功能-保存商品信息

本章编写保存商品信息接口，在发布商品功能的最后，需要保存商品信息，对应前端接口：

对应接口文档：

19、新增商品
POST
/product/spuinfo/save
请求参数
{"spuName": "Apple XR","spuDescription": "Apple XR","catalogId": 225,"brandId": 12,"weight": 0.048,"publishStatus": 0,"decript": ["https://gulimall-hello.oss-cn-beijing.aliyuncs.com/2019-11-22//66d30b3f-e02f-48b1-8574-e18fdf454a32_f205d9c99a2b4b01.jpg"],"images": ["https://gulimall-hello.oss-cn-beijing.aliyuncs.com/2019-11-22//dcfcaec3-06d8-459b-8759-dbefc247845e_5b5e74d0978360a1.jpg", "https://gulimall-hello.oss-cn-beijing.aliyuncs.com/2019-11-22//5b15e90a-a161-44ff-8e1c-9e2e09929803_749d8efdff062fb0.jpg"],"bounds": {"buyBounds": 500,"growBounds": 6000},"baseAttrs": [{"attrId": 7,"attrValues": "aaa;bb","showDesc": 1}, {"attrId": 8,"attrValues": "2019","showDesc": 0}],"skus": [{"attr": [{"attrId": 9,"attrName": "颜色","attrValue": "黑色"}, {"attrId": 10,"attrName": "内存","attrValue": "6GB"}],"skuName": "Apple XR 黑色 6GB","price": "1999","skuTitle": "Apple XR 黑色 6GB","skuSubtitle": "Apple XR 黑色 6GB","images": [{"imgUrl": "https://gulimall-hello.oss-cn-beijing.aliyuncs.com/2019-11-22//dcfcaec3-06d8-459b-8759-dbefc247845e_5b5e74d0978360a1.jpg","defaultImg": 1}, {"imgUrl": "https://gulimall-hello.oss-cn-beijing.aliyuncs.com/2019-11-22//5b15e90a-a161-44ff-8e1c-9e2e09929803_749d8efdff062fb0.jpg","defaultImg": 0}],"descar": ["黑色", "6GB"],"fullCount": 5,"discount": 0.98,"countStatus": 1,"fullPrice": 1000,"reducePrice": 10,"priceStatus": 0,"memberPrice": [{"id": 1,"name": "aaa","price": 1998.99}]}, {"attr": [{"attrId": 9,"attrName": "颜色","attrValue": "黑色"}, {"attrId": 10,"attrName": "内存","attrValue": "12GB"}],"skuName": "Apple XR 黑色 12GB","price": "2999","skuTitle": "Apple XR 黑色 12GB","skuSubtitle": "Apple XR 黑色 6GB","images": [{"imgUrl": "","defaultImg": 0}, {"imgUrl": "","defaultImg": 0}],"descar": ["黑色", "12GB"],"fullCount": 0,"discount": 0,"countStatus": 0,"fullPrice": 0,"reducePrice": 0,"priceStatus": 0,"memberPrice": [{"id": 1,"name": "aaa","price": 1998.99}]}, {"attr": [{"attrId": 9,"attrName": "颜色","attrValue": "白色"}, {"attrId": 10,"attrName": "内存","attrValue": "6GB"}],"skuName": "Apple XR 白色 6GB","price": "1998","skuTitle": "Apple XR 白色 6GB","skuSubtitle": "Apple XR 黑色 6GB","images": [{"imgUrl": "","defaultImg": 0}, {"imgUrl": "","defaultImg": 0}],"descar": ["白色", "6GB"],"fullCount": 0,"discount": 0,"countStatus": 0,"fullPrice": 0,"reducePrice": 0,"priceStatus": 0,"memberPrice": [{"id": 1,"name": "aaa","price": 1998.99}]}, {"attr": [{"attrId": 9,"attrName": "颜色","attrValue": "白色"}, {"attrId": 10,"attrName": "内存","attrValue": "12GB"}],"skuName": "Apple XR 白色 12GB","price": "2998","skuTitle": "Apple XR 白色 12GB","skuSubtitle": "Apple XR 黑色 6GB","images": [{"imgUrl": "","defaultImg": 0}, {"imgUrl": "","defaultImg": 0}],"descar": ["白色", "12GB"],"fullCount": 0,"discount": 0,"countStatus": 0,"fullPrice": 0,"reducePrice": 0,"priceStatus": 0,"memberPrice": [{"id": 1,"name": "aaa","price": 1998.99}]}]
}
分页数据响应数据
{"msg": "success","code": 0
}

由于商品信息的sku会有多种组合，所以保存的商品信息是一个很长的列表。
如果手动写VO来接受这些信息会比较麻烦，推荐使用json格式化网站，对请求的JSON文件进行java实体类的转化：
将前端请求的json文件进行复制：

填写好包名和类名之后就能够生产Java实体类，之后下载代码放入到VO包中即可：

导入之后的代码格式：

/*** Copyright 2020 bejson.com */
package com.lastingwar.mall.product.vo;
import java.util.List;/*** Auto-generated: 2020-06-07 14:13:14** @author bejson.com (i@bejson.com)* @website http://www.bejson.com/java2pojo/*/
public class SpuSaveVo {private String spuName;private String spuDescription;private int catalogId;private int brandId;private int weight;private int publishStatus;private List<String> decript;private List<String> images;private Bounds bounds;private List<BaseAttrs> baseAttrs;private List<Skus> skus;public void setSpuName(String spuName) {this.spuName = spuName;}public String getSpuName() {return spuName;}public void setSpuDescription(String spuDescription) {this.spuDescription = spuDescription;}public String getSpuDescription() {return spuDescription;}public void setCatalogId(int catalogId) {this.catalogId = catalogId;}public int getCatalogId() {return catalogId;}public void setBrandId(int brandId) {this.brandId = brandId;}public int getBrandId() {return brandId;}public void setWeight(int weight) {this.weight = weight;}public int getWeight() {return weight;}public void setPublishStatus(int publishStatus) {this.publishStatus = publishStatus;}public int getPublishStatus() {return publishStatus;}public void setDecript(List<String> decript) {this.decript = decript;}public List<String> getDecript() {return decript;}public void setImages(List<String> images) {this.images = images;}public List<String> getImages() {return images;}public void setBounds(Bounds bounds) {this.bounds = bounds;}public Bounds getBounds() {return bounds;}public void setBaseAttrs(List<BaseAttrs> baseAttrs) {this.baseAttrs = baseAttrs;}public List<BaseAttrs> getBaseAttrs() {return baseAttrs;}public void setSkus(List<Skus> skus) {this.skus = skus;}public List<Skus> getSkus() {return skus;}}

注意，这里面的属性都是按照默认使用最多的属性，和我们的要求不符合，需要把ID字段统一修改为long型，带小数的统一改为BigDecimal避免精度的丢失。

之后根据请求地址，来修改controller响应，将原先的/save响应修改为保存SpuSaveVo类：

    /*** 保存商品信息，携带大量信息*/@RequestMapping("/save")//@RequiresPermissions("product:spuinfo:save")public R save(@RequestBody SpuSaveVo vo){//spuInfoService.save(spuInfo);spuInfoService.saveSpuInfo(vo);return R.ok();}

之后创建方法，实现方法saveSpuInfo，注意这个方法需要保存很多内容，所以给方法添加事务注解：
**首先保存spu的基本信息，**对应数据库pms_spu_info表格，没有saveBaseSpuInfo这个方法，需要新建编写，这个方法由于内容和实体类对应，所以直接使用保存即可：

    @Transactional@Overridepublic void saveSpuInfo(SpuSaveVo vo) {//1、保存spu基本信息 pms_spu_infoSpuInfoEntity infoEntity = new SpuInfoEntity();BeanUtils.copyProperties(vo,infoEntity);infoEntity.setCreateTime(new Date());infoEntity.setUpdateTime(new Date());this.saveBaseSpuInfo(infoEntity);

创建和实现方法saveBaseSpuInfo：

    @Overridepublic void saveBaseSpuInfo(SpuInfoEntity infoEntity) {this.baseMapper.insert(infoEntity);}

之后保存Spu的描述图片 pms_spu_info_desc

        //2、保存Spu的描述图片 pms_spu_info_descList<String> decript = vo.getDecript();SpuInfoDescEntity descEntity = new SpuInfoDescEntity();descEntity.setSpuId(infoEntity.getId());descEntity.setDecript(String.join(",", decript));spuInfoDescService.saveSpuInfoDesc(descEntity);

需要创建实现saveSpuInfoDesc方法：

    @Overridepublic void saveSpuInfoDesc(SpuInfoDescEntity descEntity) {this.baseMapper.insert(descEntity);}

然后保存spu的图片集 pms_spu_images

        //3、保存spu的图片集 pms_spu_imagesList<String> images = vo.getImages();imagesService.saveImages(infoEntity.getId(), images);

创建和实现方法saveImages：

    @Overridepublic void saveImages(Long id, List<String> images) {if(images == null || images.size() == 0){}else{List<SpuImagesEntity> collect = images.stream().map(img -> {SpuImagesEntity spuImagesEntity = new SpuImagesEntity();spuImagesEntity.setSpuId(id);spuImagesEntity.setImgUrl(img);return spuImagesEntity;}).collect(Collectors.toList());this.saveBatch(collect);}}

再然后保存spu的规格参数;pms_product_attr_value

        //4、保存spu的规格参数;pms_product_attr_valueList<BaseAttrs> baseAttrs = vo.getBaseAttrs();List<ProductAttrValueEntity> collect = baseAttrs.stream().map(attr -> {ProductAttrValueEntity valueEntity = new ProductAttrValueEntity();valueEntity.setAttrId(attr.getAttrId());AttrEntity id = attrService.getById(attr.getAttrId());valueEntity.setAttrName(id.getAttrName());valueEntity.setAttrValue(attr.getAttrValues());valueEntity.setQuickShow(attr.getShowDesc());valueEntity.setSpuId(infoEntity.getId());return valueEntity;}).collect(Collectors.toList());attrValueService.saveProductAttr(collect);

创建实现方法saveProductAttr：

    @Overridepublic void saveProductAttr(List<ProductAttrValueEntity> collect) {this.saveBatch(collect);}

这一步保存当前spu对应的所有sku信息

  //5、保存当前spu对应的所有sku信息；
List<Skus> skus = vo.getSkus();if (skus != null && skus.size() > 0) {skus.forEach(item -> {String defaultImg = "";for (Images image : item.getImages()) {if (image.getDefaultImg() == 1) {defaultImg = image.getImgUrl();}}//    private String skuName;//    private BigDecimal price;//    private String skuTitle;//    private String skuSubtitle;SkuInfoEntity skuInfoEntity = new SkuInfoEntity();BeanUtils.copyProperties(item, skuInfoEntity);skuInfoEntity.setBrandId(infoEntity.getBrandId());skuInfoEntity.setCatalogId(infoEntity.getCatalogId());skuInfoEntity.setSaleCount(0L);skuInfoEntity.setSpuId(infoEntity.getId());skuInfoEntity.setSkuDefaultImg(defaultImg);//5.1）、sku的基本信息；pms_sku_infoskuInfoService.saveSkuInfo(skuInfoEntity);Long skuId = skuInfoEntity.getSkuId();List<SkuImagesEntity> imagesEntities = item.getImages().stream().map(img -> {SkuImagesEntity skuImagesEntity = new SkuImagesEntity();skuImagesEntity.setSkuId(skuId);skuImagesEntity.setImgUrl(img.getImgUrl());skuImagesEntity.setDefaultImg(img.getDefaultImg());return skuImagesEntity;}).filter(entity -> {//返回true就是需要，false就是剔除return !StringUtils.isEmpty(entity.getImgUrl());}).collect(Collectors.toList());//5.2）、sku的图片信息；pms_sku_imageskuImagesService.saveBatch(imagesEntities);//TODO 没有图片路径的无需保存List<Attr> attr = item.getAttr();List<SkuSaleAttrValueEntity> skuSaleAttrValueEntities = attr.stream().map(a -> {SkuSaleAttrValueEntity attrValueEntity = new SkuSaleAttrValueEntity();BeanUtils.copyProperties(a, attrValueEntity);attrValueEntity.setSkuId(skuId);return attrValueEntity;}).collect(Collectors.toList());//5.3）、sku的销售属性信息：pms_sku_sale_attr_valueskuSaleAttrValueService.saveBatch(skuSaleAttrValueEntities);// //5.4）、sku的优惠、满减等信息；gulimall_sms->sms_sku_ladder\sms_sku_full_reduction\sms_member_price// 需要进行跨库保存SkuReductionTo skuReductionTo = new SkuReductionTo();BeanUtils.copyProperties(item, skuReductionTo);skuReductionTo.setSkuId(skuId);if (skuReductionTo.getFullCount() > 0 || skuReductionTo.getFullPrice().compareTo(new BigDecimal("0")) == 1) {R r1 = couponFeignService.saveSkuReduction(skuReductionTo);if (r1.getCode() != 0) {log.error("远程保存sku优惠信息失败");}}});

之后实现方法：saveSkuInfo：

    @Overridepublic void saveSkuInfo(SkuInfoEntity skuInfoEntity) {this.baseMapper.insert(skuInfoEntity);}

sku的优惠、满减等信息：gulimall_sms>sms_sku_ladder\sms_sku_full_reduction\sms_member_price这个信息的保存需要进行跨库的操作（下一章完成）。

PS:在进行图片保存的时候，有一个图片关联表的主键不是自增的，需要在实体类上添加注解

来到对应的实体类：

package com.lastingwar.mall.product.entity;import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;import java.io.Serializable;
import java.util.Date;
import lombok.Data;/*** spu信息介绍* * @author yhm* @email 403627000@qq.com* @date 2020-05-29 16:37:08*/
@Data
@TableName("pms_spu_info_desc")
public class SpuInfoDescEntity implements Serializable {private static final long serialVersionUID = 1L;/*** 商品id*/@TableId(type = IdType.INPUT)private Long spuId;/*** 商品介绍*/private String decript;}

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！