第4章.商品管理
作者:互联网
第4章 商品管理
学习目标
-
能够使用开源算法snowflake生成分布式id
-
完成新增和修改商品功能
-
完成商品审核和上下架功能
-
完成删除与还原商品功能
1. 分布式ID生成解决方案
1.1 分布式ID生成解决方案
1.1.1 UUID
常见的方式。可以利用数据库也可以利用程序生成,一般来说全局唯一。
优点:
1)简单,代码方便。
2)生成ID性能非常好,基本不会有性能问题。
3)全局唯一,在遇见数据迁移,系统数据合并,或者数据库变更等情况下,可以从容应对。
缺点:
1)没有排序,无法保证趋势递增。
2)UUID往往是使用字符串存储,查询的效率比较低。
3)存储空间比较大,如果是海量数据库,就需要考虑存储量的问题。
4)传输数据量大
5)不可读。
1.1.2 Redis
当使用数据库来生成ID性能不够要求的时候,我们可以尝试使用Redis来生成ID。这主要依赖于Redis是单线程的,所以也可以用生成全局唯一的ID。可以用Redis的原子操作 INCR和INCRBY来实现。
优点:
1)不依赖于数据库,灵活方便,且性能优于数据库。
2)数字ID天然排序,对分页或者需要排序的结果很有帮助。
缺点:
1)如果系统中没有Redis,还需要引入新的组件,增加系统复杂度。
2)需要编码和配置的工作量比较大。
3)网络传输造成性能下降。
1.1.3 开源算法snowflake
snowflake是Twitter开源的分布式ID生成算法,结果是一个long型的ID。其核心思想是:使用41bit作为毫秒数,10bit作为机器的ID(5个bit是数据中心,5个bit的机器ID),12bit作为毫秒内的流水号(意味着每个节点在每毫秒可以产生 4096 个 ID),最后还有一个符号位,永远是0
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-ieOgTuTR-1620310115903)(image/4-2.png)]
我们在《畅购》系统中采用的就是开源算法snowflake
1.2 snowflake快速入门
1.2.1 快速入门
(1)新建工程,将资料/工具类下的IdWorker.java拷贝到工程中。
(2)编写代码
IdWorker idWorker=new IdWorker(1,1);
for(int i=0;i<10000;i++){
long id = idWorker.nextId();
System.out.println(id);
}
1.2.2 配置分布式ID生成器
(1)IdWorker.java拷贝到changgou_common工程com.changgou.util包中
(2)changgou_service_goods的application.yml添加配置
workerId: 0
datacenterId: 0
(3)修改GoodsApplication,增加代码
@Value("${workerId}")
private Integer workerId;
@Value("${datacenterId}")
private Integer datacenterId;
@Bean
public IdWorker idWorker(){
return new IdWorker(workerId,datacenterId);
}
2 新增和修改商品
2.1 概念与表结构分析
2.1.1 SPU与SKU概念
SPU = Standard Product Unit (标准产品单位)
-
概念 : SPU 是商品信息聚合的最小单位,是一组可复用、易检索的标准化信息的集合,该集合描述了一个产品的特性。
-
通俗点讲,属性值、特性相同的货品就可以称为一个 SPU
例如:华为P30 就是一个 SPU
SKU=stock keeping unit( 库存量单位)
-
SKU 即库存进出计量的单位, 可以是以件、盒、托盘等为单位。
-
SKU 是物理上不可分割的最小存货单元。在使用时要根据不同业态,不同管理模式来处理。
-
在服装、鞋类商品中使用最多最普遍。
例如:华为P30 红色 64G 就是一个 SKU
2.1.2 表结构分析
tb_spu 表 (SPU表)
字段名称 | 字段含义 | 字段类型 | 字段长度 | 备注 |
---|---|---|---|---|
id | 主键 | VARCHAR | ||
sn | 货号 | VARCHAR | ||
name | SPU名 | VARCHAR | ||
caption | 副标题 | VARCHAR | ||
brand_id | 品牌ID | INT | ||
category1_id | 一级分类 | INT | ||
category2_id | 二级分类 | INT | ||
category3_id | 三级分类 | INT | ||
template_id | 模板ID | INT | ||
freight_id | 运费模板id | INT | ||
image | 图片 | VARCHAR | ||
images | 图片列表 | VARCHAR | ||
sale_service | 售后服务 | VARCHAR | ||
introduction | 介绍 | TEXT | ||
spec_items | 规格列表 | VARCHAR | ||
para_items | 参数列表 | VARCHAR | ||
sale_num | 销量 | INT | ||
comment_num | 评论数 | INT | ||
is_marketable | 是否上架 | CHAR | ||
is_enable_spec | 是否启用规格 | CHAR | ||
is_delete | 是否删除 | CHAR | ||
status | 审核状态 | CHAR |
tb_sku 表(SKU商品表)
字段名称 | 字段含义 | 字段类型 | 字段长度 | 备注 |
---|---|---|---|---|
id | 商品id | VARCHAR | ||
sn | 商品条码 | VARCHAR | ||
name | SKU名称 | VARCHAR | ||
price | 价格(分) | INT | ||
num | 库存数量 | INT | ||
alert_num | 库存预警数量 | INT | ||
image | 商品图片 | VARCHAR | ||
images | 商品图片列表 | VARCHAR | ||
weight | 重量(克) | INT | ||
create_time | 创建时间 | DATETIME | ||
update_time | 更新时间 | DATETIME | ||
spu_id | SPUID | BIGINT | ||
category_id | 类目ID | INT | ||
category_name | 类目名称 | VARCHAR | ||
brand_name | 品牌名称 | VARCHAR | ||
spec | 规格 | VARCHAR | ||
sale_num | 销量 | INT | ||
comment_num | 评论数 | INT | ||
status | 商品状态 1-正常,2-下架,3-删除 | CHAR |
2.2 实现思路
前端传递给后端的数据格式 是一个spu对象和sku列表组成的对象。
{
"spu": {
"name": "这个是商品名称",
"caption": "这个是副标题",
"brandId": 1115,
"category1Id": 558,
"category2Id": 559,
"category3Id": 560,
"freightId": 10,
"image": "http://www.changgou.com/image/1.jpg",
"images": "http://www.changgou.com/image/1.jpg,http://www.changgou.com/image/2.jpg",
"introduction": "这个是商品详情,html代码",
"paraItems": "{'出厂年份':'2019','赠品':'充电器'}",
"saleService": "七天包退,闪电退货",
"sn": "020102331",
"specItems": "{'颜色':['红','绿'],'机身内存':['64G','8G']}",
"templateId": 42
},
"skuList": [{
"sn": "10192010292",
"num": 100,
"alertNum": 20,
"price": 900000,
"spec": "{'颜色':'红','机身内存':'64G'}",
"image": "http://www.changgou.com/image/1.jpg",
"images": "http://www.changgou.com/image/1.jpg,http://www.changgou.com/image/2.jpg",
"status": "1",
"weight": 130
},
{
"sn": "10192010293",
"num": 100,
"alertNum": 20,
"price": 600000,
"spec": "{'颜色':'蓝','机身内存':'128G'}",
"image": "http://www.changgou.com/image/1.jpg",
"images": "http://www.changgou.com/image/1.jpg,http://www.changgou.com/image/2.jpg",
"status": "1",
"weight": 130
}
]
}
这里我们需要定义一个Goods实体对前端传过来的参数进行封装:
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-LnbjaZSX-1620310115906)(C:\Users\gao\AppData\Roaming\Typora\typora-user-images\1574418879507.png)]
2.3 代码实现
2.3.1 SPU与SKU列表的保存
代码实现:
(1)changgou_service_goods_api工程创建组合实体类Goods
/**
* 商品组合实体类
*/
public class Goods implements Serializable {
private Spu spu;
private List<Sku> skuList;
public Spu getSpu() {
return spu;
}
public void setSpu(Spu spu) {
this.spu = spu;
}
public List<Sku> getSkuList() {
return skuList;
}
public void setSkuList(List<Sku> skuList) {
this.skuList = skuList;
}
}
(2)changgou_service_goods工程SpuService新增方法add(Goods goods)
/***
* 新增
* @param goods
*/
void add(Goods goods);
(3)changgou_service_goods工程SpuServiceImpl实现此方法
@Autowired
private CategoryMapper categoryMapper;
@Autowired
private SkuMapper skuMapper;
@Autowired
private BrandMapper brandMapper;
@Autowired
private IdWorker idWorker;
/**
* 保存商品 SPU+SKU列表
* @param goods 商品组合实体类
*/
@Transactional
@Override
public void add(Goods goods) {
Spu spu = goods.getSpu();
long spuId = idWorker.nextId();
spu.setId(String.valueOf(spuId));
spu.setIsDelete("0");
spu.setIsMarketable("0");
spu.setStatus("0");
spuMapper.insertSelective(spu);
//保存sku集合数据到数据库
saveSkuList(goods);
}
/**
* 保存sku列表
* @param goods
*/
private void saveSkuList(Goods goods){
//获取spu对象
Spu spu = goods.getSpu();
//当前日期
Date date = new Date();
//获取品牌对象
Brand brand = brandMapper.selectByPrimaryKey(spu.getBrandId());
//获取分类对象
Category category = categoryMapper.selectByPrimaryKey(spu.getCategory3Id());
//获取sku集合对象
List<Sku> skuList = goods.getSkuList();
if (skuList != null) {
for (Sku sku : skuList) {
//设置sku主键ID
sku.setId(String.valueOf(idWorker.nextId()));
//设置sku规格
if (sku.getSpec() == null || "".equals(sku.getSpec())) {
sku.setSpec("{}");
}
//设置sku名称(商品名称 + 规格)
String name = spu.getName();
//将规格json字符串转换成Map
Map<String, String> specMap = JSON.parseObject(sku.getSpec(), Map.class);
if (specMap != null && specMap.size() > 0) {
for(String value : specMap.values()){
name += " "+ value;
}
}
sku.setName(name);//名称
sku.setSpuId(spu.getId());//设置spu的ID
sku.setCreateTime(date);//创建日期
sku.setUpdateTime(date);//修改日期
sku.setCategoryId(category.getId());//商品分类ID
sku.setCategoryName(category.getName());//商品分类名称
sku.setBrandName(brand.getName());//品牌名称
skuMapper.insertSelective(sku);//插入sku表数据
}
}
}
(3)修改SpuController的add方法
/***
* 新增数据
* @param goods
* @return
*/
@PostMapping
public Result add(@RequestBody Goods goods){
spuService.add(goods);
return new Result(true,StatusCode.OK,"添加成功");
}
2.3.2 品牌与分类关联
实现思路:
将分类ID与SPU的品牌ID 一起插入到tb_category_brand表中
(1)创建实体类
@Table(name="tb_category_brand")
public class CategoryBrand implements Serializable {
@Id
private Integer categoryId;
@Id
private Integer brandId;
public Integer getCategoryId() {
return categoryId;
}
public void setCategoryId(Integer categoryId) {
this.categoryId = categoryId;
}
public Integer getBrandId() {
return brandId;
}
public void setBrandId(Integer brandId) {
this.brandId = brandId;
}
}
这个表是联合主键,所以templateId和brandId都有@Id注解
(2)新建数据访问接口
public interface CategoryBrandMapper extends Mapper<CategoryBrand> {
}
(3)SpuServiceImpl引入
@Autowired
private CategoryBrandMapper categoryBrandMapper;
(4)修改SpuServiceImpl的saveSkuList方法,添加分类与品牌之间的关联, 修改后代码如下:
private void saveSkuList(Goods goods) {
//获取spu对象
Spu spu = goods.getSpu();
//当前日期
Date date = new Date();
//获取品牌对象
Brand brand = brandMapper.selectByPrimaryKey(spu.getBrandId());
//获取分类对象
Category category = categoryMapper.selectByPrimaryKey(spu.getCategory3Id());
/**
* 添加分类与品牌之间的关联
*/
CategoryBrand categoryBrand = new CategoryBrand();
categoryBrand.setBrandId(spu.getBrandId());
categoryBrand.setCategoryId(spu.getCategory3Id());
int count = categoryBrandMapper.selectCount(categoryBrand);
//判断是否有这个品牌和分类的关系数据
if(count == 0) {
//如果没有关系数据则添加品牌和分类关系数据
categoryBrandMapper.insert(categoryBrand);
}
//获取sku集合对象
List<Sku> skuList = goods.getSkuList();
if (skuList != null) {
for (Sku sku : skuList) {
//设置sku主键ID
sku.setId(String.valueOf(idWorker.nextId()));
//设置sku规格
if (sku.getSpec() == null || "".equals(sku.getSpec())) {
sku.setSpec("{}");
}
//设置sku名称(商品名称 + 规格)
String name = spu.getName();
//将规格json字符串转换成Map
Map<String, String> specMap = JSON.parseObject(sku.getSpec(), Map.class);
if (specMap != null && specMap.size() > 0) {
for(String value : specMap.values()){
name += " "+ value;
}
}
sku.setName(name);//名称
sku.setSpuId(spu.getId());//设置spu的ID
sku.setCreateTime(date);//创建日期
sku.setUpdateTime(date);//修改日期
sku.setCategoryId(category.getId());//商品分类ID
sku.setCategoryName(category.getName());//商品分类名称
sku.setBrandName(brand.getName());//品牌名称
skuMapper.insertSelective(sku);//插入sku表数据
}
}
}
2.3.3 根据ID查询商品
需求:根据id 查询SPU和SKU列表 ,显示效果如下:
{
"spu": {
"brandId": 8557,
"caption": "111",
"category1Id": 558,
"category2Id": 559,
"category3Id": 560,
"commentNum": 0,
"freightId": 0,
"id": 149187842867993,
"image": "",
"images": "[{\"color\":\"银白色\",\"url\":\"//img11.360buyimg.com/n7/jfs/t30040/100/1290632710/208879/1f7e2225/5cdd0d92Nb78895a6.jpg\"}]",
"introduction": "这是测试手机数据",
"isDelete": 0,
"isEnableSpec": "0",
"isMarketable": "0",
"name": "黑马智能手机",
"paraItems": "",
"saleNum": 0,
"saleService": "",
"sn": "",
"specItems": "{\"颜色\":[\"金色\",\"黑色\",\"蓝色\"],\"版本\":[\"6GB+64GB\"]}",
"status": "0",
"templateId": 42
},
"skuList": [{
"alertNum": 100,
"commentNum": 0,
"image": "https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp",
"images": "https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp",
"num": 100,
"price": 90000,
"saleNum": 0,
"sn": "",
"spec": "{'颜色': '蓝色'}",
"status": "1",
"weight": 10
},{
"alertNum": 100,
"commentNum": 0,
"image": "https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp",
"images": "https://m.360buyimg.com/mobilecms/s720x720_jfs/t22642/312/2563982615/103706/1398b13d/5b865bb3N0409f0d0.jpg!q70.jpg.webp",
"num": 100,
"price": 80000,
"saleNum": 0,
"sn": "",
"spec": "{'颜色': '黑色'}",
"status": "1",
"weight": 10
}
]
}
代码实现:
(1)changgou_service_goods工程SpuService新增方法定义
/**
* 根据ID查询商品
* @param id
* @return
*/
public Goods findGoodsById(String id);
(2)changgou_service_goods工程SpuServiceImpl实现此方法
/**
* 根据ID查询商品
* @param id
* @return
*/
public Goods findGoodsById(String id){
//查询spu
Spu spu = spuMapper.selectByPrimaryKey(id);
//查询SKU 列表
Example example=new Example(Sku.class);
Example.Criteria criteria = example.createCriteria();
criteria.andEqualTo("spuId",id);
List<Sku> skuList = skuMapper.selectByExample(example);
//封装,返回
Goods goods=new Goods();
goods.setSpu(spu);
goods.setSkuList(skuList);
return goods;
}
(3)修改SpuController的findById方法
@GetMapping("/{id}")
public Result findById(@PathVariable String id){
Goods goods = spuService.findGoodsById(id);
return new Result(true,StatusCode.OK,"查询成功",goods);
}
2.3.4 保存修改
(1)changgou_service_goods工程SpuService新增方法定义
/***
* 修改数据
* @param spu
*/
void update(Goods goods);
(2)changgou_service_goods工程SpuServiceImpl实现此方法
@Override
public void update(Goods goods ) {
//取出spu部分
Spu spu = goods.getSpu();
spuMapper.updateByPrimaryKey(spu);
//删除原sku列表
Example example=new Example(Sku.class);
Example.Criteria criteria = example.createCriteria();
criteria.andEqualTo("spuId",spu.getId());
skuMapper.deleteByExample(example);
saveSkuList(goods);//保存sku列表
}
(3)修改SpuController的update方法
/***
* 修改数据
* @param goods
* @param id
* @return
*/
@PutMapping(value="/{id}")
public Result update(@RequestBody Goods goods,@PathVariable String id){
spuService.update(goods);
return new Result(true,StatusCode.OK,"修改成功");
}
3 商品审核与上下架
3.1 需求分析
商品新增后,审核状态为0(未审核),默认为下架状态。
审核商品,需要校验是否是被删除的商品,如果未删除则修改审核状态为1,并自动上架
下架商品,需要校验是否是被删除的商品,如果未删除则修改上架状态为0
上架商品,需要审核状态为1,如果为1,则更改上下架状态为1
3.2 实现思路
(1)按照ID查询SPU信息
(2)判断修改审核、上架下架状态
(3)保存SPU
3.3 代码实现
3.3.1 商品审核
需要校验是否是被删除的商品,如果未删除则修改审核状态为1,并自动上架
(1)SpuService新增方法
/**
* 审核
* @param id
*/
public void audit(String id);
(2)SpuServiceImpl实现方法
@Transactional
public void audit(String id) {
//查询spu对象
Spu spu = spuMapper.selectByPrimaryKey(id);
if (spu == null){
throw new RuntimeException("当前商品不存在");
}
//判断当前spu是否处于删除状态
if ("1".equals(spu.getIsDelete())){
throw new RuntimeException("当前商品处于删除状态");
}
//不处于删除状态,修改审核状态为1,上下架状态为1
spu.setStatus("1");
spu.setIsMarketable("1");
//执行修改操作
spuMapper.updateByPrimaryKeySelective(spu);
}
(2)SpuController新增方法
/**
* 审核
* @param id
* @return
*/
@PutMapping("/audit/{id}")
public Result audit(@PathVariable String id){
spuService.audit(id);
return new Result();
}
3.3.2 下架商品
校验是否是被删除的商品,如果未删除则修改上架状态为0
(1)SpuService新增方法
/**
* 下架商品
* @param id
*/
public void pull(String id);
(2)SpuServiceImpl实现方法
@Transactional
public void pull(String id) {
//查询spu
Spu spu = spuMapper.selectByPrimaryKey(id);
if (spu == null){
throw new RuntimeException("当前商品不存在");
}
//判断当前商品是否处于删除状态
if ("1".equals(spu.getIsDelete())){
throw new RuntimeException("当前商品处于删除状态");
}
//商品处于未删除状态的话,则修改上下架状态为已下架(0)
spu.setIsMarketable("0");
spuMapper.updateByPrimaryKeySelective(spu);
}
(2)SpuController新增方法
/**
* 下架
* @param id
* @return
*/
@PutMapping("/pull/{id}")
public Result pull(@PathVariable String id){
spuService.pull(id);
return new Result();
}
3.3.3 上架商品
必须是通过审核的商品才能上架
(1)SpuService新增方法
/**
* 上架商品
* @param id
*/
public void put(String id);
(2)SpuServiceImpl 实现此方法
/**
* 上架商品
* @param id
*/
@Override
public void put(String id) {
Spu spu = spuMapper.selectByPrimaryKey(id);
if(!spu.getStatus().equals("1")){
throw new RuntimeException("未通过审核的商品不能上架!");
}
spu.setIsMarketable("1");//上架状态
spuMapper.updateByPrimaryKeySelective(spu);
}
(3)SpuController新增方法
/**
* 上架
* @param id
* @return
*/
@PutMapping("/put/{id}")
public Result put(@PathVariable String id){
spuService.put(id);
return new Result();
}
4 删除与还原商品
4.1 需求分析
商品列表中的删除商品功能,并非真正的删除(物理删除),而是采用逻辑删除将删除标记的字段设置为1.
在回收站中有还原商品的功能,将删除标记的字段设置为0
在回收站中有删除商品的功能,是真正的物理删除,将数据从数据库中删除掉。
4.2 实现思路
商品列表中的删除商品,执行逻辑删除,修改spu表is_delete字段为1
商品回收站中的还原商品,修改spu表is_delete字段为0
商品回收站中的删除商品,执行delete操作,进行物理删除
4.3 代码实现
4.3.1 逻辑删除商品
修改SpuServiceImpl的delete方法
/**
* 删除
* @param id
*/
@Override
public void delete(String id){
Spu spu = spuMapper.selectByPrimaryKey(id);
//检查是否下架的商品
if(!spu.getIsMarketable().equals("0")){
throw new RuntimeException("必须先下架再删除!");
}
spu.setIsDelete("1");//删除
spu.setStatus("0");//未审核
spuMapper.updateByPrimaryKeySelective(spu);
}
4.3.2 还原被删除的商品
(1)SpuService新增方法
/**
* 恢复数据
* @param id
*/
public void restore(String id);
(2)SpuServiceImpl实现此方法
/**
* 恢复数据
* @param id
*/
@Override
public void restore(String id) {
Spu spu = spuMapper.selectByPrimaryKey(id);
//检查是否删除的商品
if(!spu.getIsDelete().equals("1")){
throw new RuntimeException("此商品未删除!");
}
spu.setIsDelete("0");//未删除
spu.setStatus("0");//未审核
spuMapper.updateByPrimaryKeySelective(spu);
}
(3)SpuController新增方法
/**
* 恢复数据
* @param id
* @return
*/
@PutMapping("/restore/{id}")
public Result restore(@PathVariable String id){
spuService.restore(id);
return new Result();
}
4.3.3 物理删除商品
判断必须逻辑删除商品才能物理删除
(1)SpuService 新增方法
/**
* 物理删除
* @param id
*/
public void realDelete(String id);
(2)SpuServiceImpl 实现方法
@Override
public void realDelete(String id) {
Spu spu = spuMapper.selectByPrimaryKey(id);
//检查是否删除的商品
if(!spu.getIsDelete().equals("1")){
throw new RuntimeException("此商品未删除!");
}
spuMapper.deleteByPrimaryKey(id);
}
(3)SpuController新增方法
/**
* 物理删除
* @param id
* @return
*/
@DeleteMapping("/realDelete/{id}")
public Result realDelete(@PathVariable String id){
spuService.realDelete(id);
return new Result();
}
标签:sku,goods,删除,管理,spu,public,商品,id 来源: https://blog.csdn.net/happy_de_goudan/article/details/116464487