商品中心—4.商品属性与状态流转的技术文档

大纲
1.商品属性库系统简介
2.商品属性库系统数据库设计
3.商品属性库系统对品类添加属性
4.商品属性库系统添加属性值与属性组
5.商品属性库系统添加属性模版及模版内容
6.查询属性库系统数据相关接口
7.商品属性库系统与商品M端系统对接
8.商品状态变更流转架构设计与实现
9.商品状态变更流转的策略模式实现
10.商品状态变更流转的具体策略实现
 
1.商品属性库系统简介
(1)属性分类
(2)属性模版
(3)属性组
(4)属性库运行流程
 
(1)属性分类
为了⽅便管理商品，可以将属性分为三类：
 
一.基础属性
商品的通⽤属性，例如名称、品牌、品类等。
 
二.销售属性
商品的销售价格属性，不同销售属性的商品，其销售价会有所不同，例如⼿机的颜⾊、内存等。
 
三.搜索属性
商品搜索的属性，例如名称、品牌、品类等。
 
(2)属性模版
为了提⾼效率，合理化运营，会将商品的属性与品类绑定到⼀起。品类是以树形结构来管理的。既然属性与品类绑定在⼀起，为避免重复添加属性，会将每级品类的公共属性抽取出来作为⼀个属性模板。后期关联商品查询时，可以将属性最终展示在商品下⾯。

(3)属性组
由于商品的属性很多，为了⽅便⽤户浏览和数据⽐对，需要对属性进⾏分组管理。
 
一.电子产品属性组

二.汽车属性组

(4)属性库运行流程
一.创建属性库数据

二.查询属性库数据

三.商品对接属性库

 
2.商品属性库系统数据库设计
(1)属性相关表的关系
(2)属性相关表的详情
 
(1)属性相关表的关系
属性表管理：attribute management，简称atm。

一个品类会关联一个属性模版，一个属性模版里会有多个属性组或多个属性，一个属性组里会有多个属性，一个属性里会有多个属性值。
 
(2)属性相关表的详情
一.属性表
二.属性可选值表
三.属性组表
四.属性模板表
五.属性模板内容表
六.标品商品属性值表
 
一.属性表

1. create table if not exists atm_attribute_info (
2.     id int(10) auto_increment comment '主键' primary key,
3.     category_id int(10) default null comment '品类id',
4.     attribute_name varchar(128) not null comment '属性名称',
5.     attribute_code varchar(128) null comment '属性编码',
6.     attribute_type varchar(128) not null comment '属性类型，格式为json数组(1-基础属性，2-销售属性，3-搜索属性，null-其他属性)',
7.     attribute_input_type int not null comment '属性值的输⼊⽅式(1-⽤户⾃⼰输⼊，2-单选下拉框，3-多选下拉框，4-⽇期)',
8.     attribute_comment varchar(128) default null comment '属性说明',
9.     del_flag tinyint(1) default 0 not null comment '删除标记(1-有效，0-删除)',
10.     create_user int not null comment '创建⼈',
11.     create_time datetime default CURRENT_TIMESTAMP not null comment '创建时间',
12.     update_user int not null comment '更新⼈',
13.     update_time datetime default CURRENT_TIMESTAMP not null comment '修改时间'
14. ) comment '属性表';

复制代码

例如添加三个属性：品牌、颜色、版本。

二.属性可选值表

1. create table if not exists atm_attribute_value (
2.     id int(10) auto_increment comment '主键' primary key,
3.     attribute_id int(10) not null comment '属性id',
4.     attribute_value varchar(128) not null comment '属性值',
5.     sort int not null comment '排序序号',
6.     del_flag tinyint(1) default 0 not null comment '删除标记(1-有效，0-删除)',
7.     create_user int not null comment '创建⼈',
8.     create_time datetime default CURRENT_TIMESTAMP not null comment '创建时间',
9.     update_user int not null comment '更新⼈',
10.     update_time datetime default CURRENT_TIMESTAMP not null comment '修改时间'
11. ) comment '属性值表';

复制代码

例如给颜色属性添加了3个可选值：红色、黄色、蓝色。例如给版本属性添加了3个可选值：公开版、无线耳机套装、智能手表套装。

三.属性组表

1. create table if not exists atm_attribute_group (
2.     id int(10) auto_increment comment '主键' primary key,
3.     category_id int(10) default null comment '品类id',
4.     group_name varchar(128) not null comment '属性组名称',
5.     del_flag tinyint(1) default 0 not null comment '删除标记(1-有效，0-删除)',
6.     create_user int not null comment '创建⼈',
7.     create_time datetime default CURRENT_TIMESTAMP not null comment '创建时间',
8.     update_user int not null comment '更新⼈',
9.     update_time datetime default CURRENT_TIMESTAMP not null comment '修改时间'
10. ) comment '属性组表';

复制代码

例如添加一个属性组：基本属性组。

四.属性模板表

1. create table atm_attribute_template (
2.     id int auto_increment comment '主键' primary key,
3.     template_name varchar(128) not null comment '属性模板名称',
4.     category_id int not null comment '品类id',
5.     del_flag tinyint(1) default 0 not null comment '删除标记(1-有效，0-删除)',
6.     create_user int not null comment '创建⼈',
7.     create_time datetime default CURRENT_TIMESTAMP not null comment '创建时间',
8.     update_user int not null comment '更新⼈',
9.     update_time datetime default CURRENT_TIMESTAMP not null comment '修改时间'
10. ) comment '属性模板表';

复制代码

例如添加一个属性模版：智能手机模版；

五.属性模板内容表

1. create table atm_attribute_template_content (
2.     id int auto_increment comment '主键' primary key,
3.     template_id int not null comment '属性模板id',
4.     group_id int null comment '属性组id',
5.     attribute_id int not null comment '属性id',
6.     participant_type int not null comment '参与类型(1-表示该属性是放到item上的，2-表示该属性是放到sku上的)',
7.     sort int null comment '排序序号',
8.     del_flag tinyint(1) default 0 not null comment '删除标记(1-有效，0-删除)',
9.     create_user int not null comment '创建⼈',
10.     create_time datetime default CURRENT_TIMESTAMP not null comment '创建时间',
11.     update_user int not null comment '更新⼈',
12.     update_time datetime default CURRENT_TIMESTAMP not null comment '修改时间'
13. ) comment '模板内容表';

复制代码

例如给智能⼿机模板配置三个属性，同时指定每个属性所属的属性组，分别为品牌属性(⽆属性组)、颜⾊属性和版本属性(属于基本属性组)。另外配置品牌属性放到item上，颜⾊和版本属性放到sku上，而且属性组的顺序分别是品牌、颜⾊、版本。

六.标品商品属性值表

1. create table atm_item_sku_attribute_value (
2.     id int auto_increment comment '主键' primary key,
3.     participant_id varchar(64) not null comment '标品id或商品id',
4.     participant_type int not null comment '参与类型(1-表示该属性是放到item上的，2-表示该属性是放到sku上的)',
5.     template_id int not null comment '模板id',
6.     group_id int null comment '属性组id',
7.     attribute_id int not null comment '属性id',
8.     attribute_value varchar(128) not null comment '属性值',
9.     sort int not null comment '排序序号',
10.     del_flag tinyint(1) default 0 not null comment '删除标记(1-有效，0-删除)',
11.     create_user int not null comment '创建⼈',
12.     create_time datetime default CURRENT_TIMESTAMP not null comment '创建时间',
13.     update_user int not null comment '更新⼈',
14.     update_time datetime default CURRENT_TIMESTAMP not null comment '修改时间'
15. ) comment '标品商品属性值表';

复制代码

例如item为111的标品，关联了品牌属性，值为华为。sku为222的商品关联了颜⾊属性(红色)，版本属性(公开版)。sku为333的商品关联了颜⾊属性(黄色)，版本属性(⽆线⽿机套装)。sku为444的商品关联了颜⾊属性(蓝色)，版本属性(智能⼿表套装)。

 
3.商品属性库系统对品类添加属性

1. //属性管理相关操作API
2. @DubboService(version = "1.0.0", interfaceClass = AttributeApi.class, retries = 0)
3. public class AttributeApiImpl implements AttributeApi {
4.     @Autowired
5.     private AttributeService attributeService;
6.    
7.     //添加属性接口
8.     @Override
9.     public JsonResult saveAttribute(AttributeInfoRequest request) {
10.         AttributeInfoResultDTO attributeResultV2DTO = attributeService.saveAttributeInfo(request);
11.         return JsonResult.buildSuccess(attributeResultV2DTO);
12.     }
13.     ...
14. }
16. //新增/编辑属性请求入参
17. @Data
18. public class AttributeInfoRequest implements Serializable {
19.     //品类id
20.     private Long categoryId;
21.     //属性名称
22.     private String attributeName;
23.     //属性编码
24.     private String attributeCode;
25.     //属性类型
26.     private String attributeType;
27.     //属性值的输入方式
28.     private Integer attributeInputType;
29.     //属性说明
30.     private String attributeComment;
31.     //操作人
32.     @NotNull(message = "操作人[operateUser]不能为空")
33.     private Integer operateUser;
34. }
36. //属性管理相关操作API
37. @Service
38. public class AttributeServiceImpl implements AttributeService {
39.     @Autowired
40.     private AttributeRepository attributeRepository;
41.    
42.     //添加属性
43.     @Override
44.     public AttributeInfoResultDTO saveAttributeInfo(AttributeInfoRequest request) {
45.         //入参检查
46.         checkAttributeInfoRequest(request);
47.         //保存属性
48.         Long attributeId = attributeRepository.saveAttributeInfo(request);
49.         return new AttributeInfoResultDTO(attributeId, true);
50.     }
51.     ...
52. }
54. @Repository
55. public class AttributeRepository {
56.     @Resource
57.     private AttributeInfoMapper attributeInfoMapper;
58.     ...
59.    
60.     //保存属性信息
61.     public Long saveAttributeInfo(AttributeInfoRequest request) {
62.         AttributeInfoDO attributeInfoDO = attributeConverter.convertAttributeInfoDO(request);
63.         attributeInfoDO.initCommon();
64.         attributeInfoMapper.insert(attributeInfoDO);
65.         return attributeInfoDO.getId();
66.     }
67.     ...
68. }

复制代码

 
4.商品属性库系统添加属性值与属性组
(1)添加可选的属性值
(2)添加属性组
 
(1)添加可选的属性值

1. //属性管理相关操作API
2. @DubboService(version = "1.0.0", interfaceClass = AttributeApi.class, retries = 0)
3. public class AttributeApiImpl implements AttributeApi {
4.     ...
5.     @Autowired
6.     private AttributeService attributeService;
7.    
8.     //给属性添加可选的属性值接口
9.     @Override
10.     public JsonResult saveAttributeValue(List list) {
11.         AttributeValueResultDTO attributeValueResultDTO = attributeService.saveAttributeValues(list);
12.         return JsonResult.buildSuccess(attributeValueResultDTO);
13.     }
14.     ...
15. }
17. //属性管理相关操作API
18. @Service
19. public class AttributeServiceImpl implements AttributeService {
20.     @Autowired
21.     private AttributeRepository attributeRepository;
22.     ...
23.    
24.     //批量给属性添加可选的属性值
25.     @Override
26.     public AttributeValueResultDTO saveAttributeValues(List list) {
27.         attributeRepository.saveAttributeValues(list);
28.         return new AttributeValueResultDTO(true);
29.     }
30.     ...
31. }
33. //属性库
34. @Repository
35. public class AttributeRepository {
36.     @Resource
37.     private AttributeValueMapper attributeValueV2Mapper;
38.     ...
39.    
40.     //批量保存属性值
41.     public void saveAttributeValues(List list) {
42.         //先删
43.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
44.         queryWrapper.eq(AttributeValueDO::getAttributeId, list.get(0).getAttributeId());
45.         attributeValueV2Mapper.delete(queryWrapper);
46.         //后保存
47.         List attributeValueDOS = attributeConverter.convertAttributeValueV2DOList(list);
48.         attributeValueDOS.forEach(e -> {
49.             e.setUpdateUser(list.get(0).getOperateUser());
50.             e.initCommon();
51.         });
52.         Integer count = attributeValueV2Mapper.insertBatch(attributeValueDOS);
53.         if (count <= 0) {
54.             throw new ProductBizException(CommonErrorCodeEnum.SQL_ERROR);
55.         }
56.     }
57.     ...
58. }

复制代码

 
7.商品属性库系统与商品M端系统对接

1. //属性管理相关操作API
2. @DubboService(version = "1.0.0", interfaceClass = AttributeApi.class, retries = 0)
3. public class AttributeApiImpl implements AttributeApi {
4.     ...
5.     @Autowired
6.     private AttributeService attributeService;
7.    
8.     //添加属性组接口
9.     @Override
10.     public JsonResult saveAttributeGroup(AttributeGroupRequest request) {
11.         AttributeGroupResultDTO attributeGroupResultDTO = attributeService.saveAttributeGroup(request);
12.         return JsonResult.buildSuccess(attributeGroupResultDTO);
13.     }
14.     ...
15. }
17. //属性管理相关操作API
18. @Service
19. public class AttributeServiceImpl implements AttributeService {
20.     @Autowired
21.     private AttributeRepository attributeRepository;
22.     ...
23.    
24.     //添加属性组接口
25.     @Override
26.     public AttributeGroupResultDTO saveAttributeGroup(AttributeGroupRequest request) {
27.         //入参检查
28.         checkAttributeGroupRequest(request);
29.         Long groupId = attributeRepository.saveAttributeGroup(request);
30.         return new AttributeGroupResultDTO(groupId, true);
31.     }
32.     ...
33. }
35. //属性库
36. @Repository
37. public class AttributeRepository {
38.     @Resource
39.     private AttributeGroupMapper attributeGroupMapper;
40.     ...
41.    
42.     //保存属性组
43.     public Long saveAttributeGroup(AttributeGroupRequest request) {
44.         AttributeGroupDO attributeGroupDO = attributeConverter.convertAttributeGroupDO(request);
45.         attributeGroupDO.initCommon();
46.         attributeGroupMapper.insert(attributeGroupDO);
47.         return attributeGroupDO.getId();
48.     }
49.     ...
50. }

复制代码

 
8.商品状态变更流转架构设计
(1)状态流转策略表
(2)商品状态变更流向图
(3)接口实现流程图
 
(1)状态流转策略表

1. //属性管理相关操作API
2. @DubboService(version = "1.0.0", interfaceClass = AttributeApi.class, retries = 0)
3. public class AttributeApiImpl implements AttributeApi {
4.     ...
5.     @Autowired
6.     private AttributeService attributeService;
7.    
8.     //添加属性模板接口
9.     @Override
10.     public JsonResult saveAttributeTemplate(AttributeTemplateRequest request) {
11.         AttributeTemplateResultDTO attributeTemplateResultDTO = attributeService.saveAttributeTemplate(request);
12.         return JsonResult.buildSuccess(attributeTemplateResultDTO);
13.     }
14.    
15.     //给模板添加模板内容接口
16.     @Override
17.     public JsonResult saveAttributeTemplateContents(List list) {
18.         AttributeTemplateContentResultDTO attributeTemplateContentResultDTO = attributeService.saveAttributeTemplateContents(list);
19.         return JsonResult.buildSuccess(attributeTemplateContentResultDTO);
20.     }
21.     ...
22. }
24. //属性管理相关操作API
25. @Service
26. public class AttributeServiceImpl implements AttributeService {
27.     @Autowired
28.     private AttributeRepository attributeRepository;
29.     ...
30.    
31.     //添加属性模板接口
32.     @Override
33.     public AttributeTemplateResultDTO saveAttributeTemplate(AttributeTemplateRequest request) {
34.         //入参检查
35.         checkAttributeTemplateRequest(request);
36.         Long templteId = attributeRepository.saveAttributeTemplate(request);
37.         return new AttributeTemplateResultDTO(templteId, true);
38.     }
39.    
40.     //添加属性模板内容接口
41.     @Override
42.     public AttributeTemplateContentResultDTO saveAttributeTemplateContents(List list) {
43.         //入参检查
44.         checkAttributeTemplateContentRequest(list);
45.         attributeRepository.saveAttributeTemplateContents(list);
46.         return new AttributeTemplateContentResultDTO(true);
47.     }
48.     ...
49. }
51. //属性库
52. @Repository
53. public class AttributeRepository {
54.     @Resource
55.     private AttributeTemplateMapper attributeTemplateMapper;
56.    
57.     @Resource
58.     private AttributeTemplateContentMapper attributeTemplateContentMapper;
59.     ...
60.    
61.     //保存属性模板
62.     public Long saveAttributeTemplate(AttributeTemplateRequest request) {
63.         AttributeTemplateDO attributeTemplateDO = attributeConverter.convertAttributeTemplateDO(request);
64.         attributeTemplateDO.initCommon();
65.         attributeTemplateMapper.insert(attributeTemplateDO);
66.         return attributeTemplateDO.getId();
67.     }
68.    
69.     //保存属性模板内容
70.     public void saveAttributeTemplateContents(List list) {
71.         //先删
72.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
73.         queryWrapper.eq(AttributeTemplateContentDO::getTemplateId, list.get(0).getTemplateId());
74.         attributeTemplateContentMapper.delete(queryWrapper);
75.         //后保存
76.         List attributeTemplateContentDOS = attributeConverter.convertAttributeTemplateContentDOList(list);
77.         attributeTemplateContentDOS.forEach(e -> {
78.             e.setUpdateUser(list.get(0).getOperateUser());
79.             e.initCommon();
80.         });
81.         Integer count = attributeTemplateContentMapper.insertBatch(attributeTemplateContentDOS);
82.         if (count <= 0) {
83.             throw new ProductBizException(CommonErrorCodeEnum.SQL_ERROR);
84.         }
85.     }
86.     ...
87. }

复制代码

(2)商品状态变更流向图
说明：严格按照箭头方向执行，除了可重新上架，其他状态变更均不可逆。

(3)接口实现流程图

 
9.商品状态变更流转的策略模式实现
具体实现在商品M端系统：
一.验证⼊参必填(商品ID和变更状态)
二.验证商品是否存在，停售状态禁⽌变更状态
三.获取状态流转策略表，根据商品的当前状态和变更状态获取配置的映射策略类的实例名称
四.实现关于每个状态变更的具体逻辑

1. //属性管理相关操作API
2. @DubboService(version = "1.0.0", interfaceClass = AttributeApi.class, retries = 0)
3. public class AttributeApiImpl implements AttributeApi {
4.     ...
5.     @Autowired
6.     private AttributeService attributeService;
7.    
8.     //属性分页查询接口
9.     @Override
10.     public JsonResult<PageResult> pageAttributeInfo(QueryAttributeInfoRequest request) {
11.         PageResult pageResult = attributeService.pageAttributeInfo(request);
12.         return JsonResult.buildSuccess(pageResult);
13.     }
14.    
15.     //根据属性id查询属性及可选的属性值
16.     @Override
17.     public JsonResult<List> queryAttributeValueByAttributeId(Long attributeId) {
18.         List attributeValueDTOS = attributeService.queryAttributeValueByAttributeId(attributeId);
19.         return JsonResult.buildSuccess(attributeValueDTOS);
20.     }
21.    
22.     //属性组分页查询接口
23.     @Override
24.     public JsonResult<PageResult> pageAttributeGroup(QueryAttributeGroupRequest request) {
25.         PageResult pageResult = attributeService.pageAttributeGroup(request);
26.         return JsonResult.buildSuccess(pageResult);
27.     }
28.    
29.     //属性模板分页查询接口
30.     @Override
31.     public JsonResult<PageResult> pageAttributeTemplate(QueryAttributeTemplateRequest request) {
32.         PageResult pageResult = attributeService.pageAttributeTemplate(request);
33.         return JsonResult.buildSuccess(pageResult);
34.     }
35.    
36.     //根据模板id查询模板内容接口
37.     @Override
38.     public JsonResult<List> queryAttributeTemplateContentByTemplateId(Long templateId) {
39.         List attributeTemplateContentDTOS = attributeService.queryAttributeTemplateContentByTemplateId(templateId);
40.         return JsonResult.buildSuccess(attributeTemplateContentDTOS);
41.     }
42.     ...
43. }
45. //属性管理相关操作API
46. @Service
47. public class AttributeServiceImpl implements AttributeService {
48.     @Autowired
49.     private AttributeRepository attributeRepository;
50.    
51.     //分页查询属性
52.     @Override
53.     public PageResult pageAttributeInfo(QueryAttributeInfoRequest request) {
54.         return attributeRepository.pageAttributeInfo(request);
55.     }
56.    
57.     //根据属性id查询属性及可选的属性值
58.     @Override
59.     public List queryAttributeValueByAttributeId(Long attributeId) {
60.         if (attributeId == null || attributeId < 0) {
61.             return null;
62.         }
63.         return attributeRepository.queryAttributeValueByAttributeId(attributeId);
64.     }
65.    
66.     //分页查询属性组
67.     @Override
68.     public PageResult pageAttributeGroup(QueryAttributeGroupRequest request) {
69.         return attributeRepository.pageAttributeGroup(request);
70.     }
71.    
72.     //分页查询属性模板
73.     @Override
74.     public PageResult pageAttributeTemplate(QueryAttributeTemplateRequest request) {
75.         return attributeRepository.pageAttributeTemplate(request);
76.     }
77.    
78.     //根据属性模板id查询属性模板的内容
79.     @Override
80.     public List queryAttributeTemplateContentByTemplateId(Long templateId) {
81.         if (templateId == null || templateId < 0) {
82.             return null;
83.         }
84.         return attributeRepository.queryAttributeTemplateContentByTemplateId(templateId);
85.     }
86.     ...
87. }
89. //属性库
90. @Repository
91. public class AttributeRepository {
92.     @Resource
93.     private AttributeGroupMapper attributeGroupMapper;
94.    
95.     //分页查询属性
96.     public PageResult pageAttributeInfo(QueryAttributeInfoRequest request) {
97.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
98.         if (request.getCategoryId() != null && request.getCategoryId() > 0) {
99.             queryWrapper.eq(AttributeInfoDO::getCategoryId, request.getCategoryId());
100.         }
101.         if (StringUtils.isNotBlank(request.getAttributeName())) {
102.             queryWrapper.like(AttributeInfoDO::getAttributeName, request.getAttributeName());
103.         }
104.         if (StringUtils.isNotBlank(request.getAttributeCode())) {
105.             queryWrapper.like(AttributeInfoDO::getAttributeCode, request.getAttributeCode());
106.         }
107.         if (request.getAttributeType() != null) {
108.             queryWrapper.eq(AttributeInfoDO::getAttributeType, request.getAttributeType());
109.         }
110.         if (request.getAttributeInputType() != null) {
111.             queryWrapper.eq(AttributeInfoDO::getAttributeInputType, request.getAttributeInputType());
112.         }
113.         Page page = new Page<>(request.getPageNum(), request.getPageSize());
114.         Page pageResult = attributeInfoMapper.selectPage(page, queryWrapper);
115.         return attributeConverter.convertAttributeInfoDTOPageResult(pageResult);
116.     }
117.    
118.     //根据属性id查询属性值
119.     public List queryAttributeValueByAttributeId(Long attributeId) {
120.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
121.         queryWrapper.eq(AttributeValueDO::getAttributeId, attributeId);
122.         List attributeValueDOS = attributeValueV2Mapper.selectList(queryWrapper);
123.         return attributeConverter.convertAttributeValueV2DTOList(attributeValueDOS);
124.     }
125.    
126.     //分页查询属性组
127.     public PageResult pageAttributeGroup(QueryAttributeGroupRequest request) {
128.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
129.         if (request.getCategoryId() != null && request.getCategoryId() > 0) {
130.             queryWrapper.eq(AttributeGroupDO::getCategoryId, request.getCategoryId());
131.         }
132.         if (StringUtils.isNotBlank(request.getGroupName())) {
133.             queryWrapper.like(AttributeGroupDO::getGroupName, request.getGroupName());
134.         }
135.         Page page = new Page<>(request.getPageNum(), request.getPageSize());
136.         Page pageResult = attributeGroupMapper.selectPage(page, queryWrapper);
137.         return attributeConverter.convertAttributeGroupDTOPageResult(pageResult);
138.     }
139.    
140.     //分页查询属性模板
141.     public PageResult pageAttributeTemplate(QueryAttributeTemplateRequest request) {
142.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
143.         if (request.getCategoryId() != null && request.getCategoryId() > 0) {
144.             queryWrapper.eq(AttributeTemplateDO::getCategoryId, request.getCategoryId());
145.         }
146.         if (StringUtils.isNotBlank(request.getTemplateName())) {
147.             queryWrapper.like(AttributeTemplateDO::getTemplateName, request.getTemplateName());
148.         }
149.         Page page = new Page<>(request.getPageNum(), request.getPageSize());
150.         Page pageResult = attributeTemplateMapper.selectPage(page, queryWrapper);
151.         return attributeConverter.convertAttributeTemplateDTOPageResult(pageResult);
152.     }
153.    
154.     //根据属性模板id查询属性模板内容
155.     public List queryAttributeTemplateContentByTemplateId(Long templateId) {
156.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
157.         queryWrapper.eq(AttributeTemplateContentDO::getTemplateId, templateId);
158.         List attributeTemplateContentDOS = attributeTemplateContentMapper.selectList(queryWrapper);
159.         return attributeConverter.convertAttributeTemplateContentDTOList(attributeTemplateContentDOS);
160.     }   
161.     ...
162. }

复制代码

 
10.商品状态变更流转的具体策略实现
(1)商品试销上架的实现
(2)商品上架与预下架状态流转实现
(3)商品下架和停售状态流转实现
(4)流转到上架的状态变更
 
(1)商品试销上架的实现
一.商品试销上架时对前端销售数据校验

1. //商品属性相关操作API
2. @DubboService(version = "1.0.0", interfaceClass = ItemSkuAttributeApi.class, retries = 0)
3. public class ItemSkuAttributeApiImpl implements ItemSkuAttributeApi {
4.     @Autowired
5.     private ItemSkuAttributeService itemSkuAttributeService;
6.    
7.     //保存标品和商品属性接口
8.     @Override
9.     public JsonResult<ItemSkuAttributeValueResultDTO> saveItemSkuAttributeValue(List<ItemSkuAttributeValueRequest> list) {
10.         ItemSkuAttributeValueResultDTO itemSkuAttributeValueResultDTO = itemSkuAttributeService.saveItemSkuAttributeValue(list);
11.         return JsonResult.buildSuccess(itemSkuAttributeValueResultDTO);
12.     }
13.    
14.     //根据商品id品类id查询聚合商品属性值接口
15.     @Override
16.     public JsonResult<List<SkuAttributeValueDTO>> queryItemSkuAttributeValueList(QueryItemSkuAttributeValueRequest request) {
17.         List<SkuAttributeValueDTO> skuAttributeValueDTOS = itemSkuAttributeService.queryItemSkuAttributeValueList(request);
18.         return JsonResult.buildSuccess(skuAttributeValueDTOS);
19.     }
20.    
21.     //根据属性查询条件搜索商品接口
22.     @Override
23.     public JsonResult<List<String>> querySkuIdsByAttribute(QuerySkuIdsByAttributeRequest request) {
24.         List<String> skuIds = itemSkuAttributeService.querySkuIdsByAttributes(request);
25.         return JsonResult.buildSuccess(skuIds);
26.     }
27. }
29. //商品属性相关操作API
30. @Service
31. public class ItemSkuAttributeServiceImpl implements ItemSkuAttributeService {
32.     @Autowired
33.     private AttributeRepository attributeRepository;
34.    
35.     //保存标品和商品属性
36.     @Override
37.     public ItemSkuAttributeValueResultDTO saveItemSkuAttributeValue(List<ItemSkuAttributeValueRequest> list) {
38.         //入参检查
39.         checkItemSkuAttributeValueRequest(list);
40.         attributeRepository.saveItemSkuAttributeValue(list);
41.         return new ItemSkuAttributeValueResultDTO(true);
42.     }
43.    
44.     //根据商品id类目id查询聚合商品属性值接口
45.     @Override
46.     public List<SkuAttributeValueDTO> queryItemSkuAttributeValueList(QueryItemSkuAttributeValueRequest request) {
47.         //1.根据skuId和itemId查询出商品所有的属性
48.         List<ItemSkuAttributeValueDTO> itemSkuAttributeValueDTOS = attributeRepository.queryItemSkuAttributeValueList(request);
49.         //2.找出使用这个sku使用的是哪个模板
50.         Long templateId = itemSkuAttributeValueDTOS.get(0).getTemplateId();
51.         //3.查询出模板内容
52.         List attributeTemplateContentDTOS = attributeRepository.queryAttributeTemplateContentByTemplateId(templateId);
53.         //4.查询出相关的属性组
54.         List<Long> groupIds = attributeTemplateContentDTOS.stream()
55.             .map(AttributeTemplateContentDTO::getGroupId)
56.             .filter(Objects::nonNull)
57.             .collect(Collectors.toList());
58.         List groupDTOS = attributeRepository.queryGroups(groupIds);
59.         Map<Long, String> groupIdAndNameMap = groupDTOS.stream().collect(Collectors.toMap(AttributeGroupDTO::getId, AttributeGroupDTO::getGroupName));
60.         //5.查询出相关的属性
61.         List<Long> attributeIds = attributeTemplateContentDTOS.stream()
62.             .map(AttributeTemplateContentDTO::getAttributeId)
63.             .collect(Collectors.toList());
64.         List attributeInfoDTOS = attributeRepository.queryAttributeInfos(attributeIds);
65.         Map<Long, String> attributeIdAndNameMap = attributeInfoDTOS.stream().collect(Collectors.toMap(AttributeInfoDTO::getId, AttributeInfoDTO::getAttributeName));
66.         //6.拼装结果
67.         return buildSkuAttributeValueDTOS(itemSkuAttributeValueDTOS, groupIdAndNameMap, attributeIdAndNameMap);
68.     }
69.    
70.     //根据属性查询条件搜索商品接口
71.     @Override
72.     public List<String> querySkuIdsByAttributes(QuerySkuIdsByAttributeRequest request) {
73.         return attributeRepository.querySkuIdsByAttribute(request);
74.     }
75.     ...
76. }
78. //属性库
79. @Repository
80. public class AttributeRepository {
81.     ...
82.     //保存标品和商品属性
83.     public void saveItemSkuAttributeValue(List<ItemSkuAttributeValueRequest> list) {
84.         //先删
85.         LambdaQueryWrapper<ItemSkuAttributeValueDO> queryWrapper = Wrappers.lambdaQuery();
86.         queryWrapper.eq(ItemSkuAttributeValueDO::getParticipantId, list.get(0).getParticipantId());
87.         itemSkuAttributeValueMapper.delete(queryWrapper);
88.         //后保存
89.         List<ItemSkuAttributeValueDO> itemSkuAttributeValueDOS = attributeConverter.convertItemSkuAttributeValueDOList(list);
90.         itemSkuAttributeValueDOS.forEach(e -> {
91.             e.setUpdateUser(list.get(0).getOperateUser());
92.             e.initCommon();
93.         });
94.         Integer count = itemSkuAttributeValueMapper.insertBatch(itemSkuAttributeValueDOS);
95.         if (count <= 0) {
96.             throw new ProductBizException(CommonErrorCodeEnum.SQL_ERROR);
97.         }
98.     }
99.    
100.     //根据商品id类目id查询聚合商品属性值接口
101.     public List<ItemSkuAttributeValueDTO> queryItemSkuAttributeValueList(QueryItemSkuAttributeValueRequest request) {
102.         LambdaQueryWrapper<ItemSkuAttributeValueDO> queryWrapper = Wrappers.lambdaQuery();
103.         List<String> participantIds = new ArrayList<>();
104.         if (StringUtils.isNotBlank(request.getItemId())) {
105.             participantIds.add(request.getItemId());
106.         }
107.         if (StringUtils.isNotBlank(request.getSkuId())) {
108.             participantIds.add(request.getSkuId());
109.         }
110.         queryWrapper.in(ItemSkuAttributeValueDO::getParticipantId, participantIds.stream().distinct().collect(Collectors.toList()));
111.         List<ItemSkuAttributeValueDO> itemSkuAttributeValueDOS = itemSkuAttributeValueMapper.selectList(queryWrapper);
112.         return attributeConverter.convertItemSkuAttributeValueDTO(itemSkuAttributeValueDOS);
113.     }
114.    
115.     //根据属性模板id查询属性模板内容
116.     public List queryAttributeTemplateContentByTemplateId(Long templateId) {
117.         LambdaQueryWrapper queryWrapper = Wrappers.lambdaQuery();
118.         queryWrapper.eq(AttributeTemplateContentDO::getTemplateId, templateId);
119.         List attributeTemplateContentDOS = attributeTemplateContentMapper
120.             .selectList(queryWrapper);
121.         return attributeConverter.convertAttributeTemplateContentDTOList(attributeTemplateContentDOS);
122.     }
123.    
124.     //根据id批量查询属性组
125.     public List queryGroups(List<Long> groupIds) {
126.         List attributeGroupDOS = attributeGroupMapper.selectBatchIds(groupIds);
127.         return attributeConverter.convertAttributeGroupDTOList(attributeGroupDOS);
128.     }
129.    
130.     //根据id批量查询属性
131.     public List queryAttributeInfos(List<Long> attributeIds) {
132.         List attributeInfoDOS = attributeInfoMapper.selectBatchIds(attributeIds);
133.         return attributeConverter.convertAttributeInfoDTOList(attributeInfoDOS);
134.     }
135.    
136.     //根据属性查询条件搜索商品接口
137.     public List<String> querySkuIdsByAttribute(QuerySkuIdsByAttributeRequest request) {
138.         LambdaQueryWrapper<ItemSkuAttributeValueDO> queryWrapper = Wrappers.lambdaQuery();
139.         for (QuerySkuIdsByAttributeRequest.AttributeCriteria attributeCriteria : request.getAttributeCriterias()) {
140.             queryWrapper.or(wrapper -> wrapper
141.                 .eq(ItemSkuAttributeValueDO::getAttributeId, attributeCriteria.getAttributeId())
142.                 .like(ItemSkuAttributeValueDO::getAttributeValue, attributeCriteria.getAttributeValue())
143.             );
144.         }
145.         List<ItemSkuAttributeValueDO> itemSkuAttributeValueDOS = itemSkuAttributeValueMapper.selectList(queryWrapper);
146.         return itemSkuAttributeValueDOS.stream().map(ItemSkuAttributeValueDO::getParticipantId).collect(Collectors.toList());
147.     }
148.     ...
149. }

复制代码

二.商品试销上架时补充扩展属性和变更商品状态
[code]//试销上架状态变更@Service("trialSaleStatus")public class TrialSaleStatusService extends AbstractStatusStrategy {    ...    //填充 试销商品的扩展字段(试销期截止时间)    private void buildAttributeContent(ProductDetailDO productDetailDO) {        //1.只有普通商品或者组套商品才处理扩展信息的变化        if (checkItemType(productDetailDO)) {            //获取试销期截止时间            String trialSaleTime = DateFormatUtil.getDate(dateNum);            //先获取到试销商品的原有扩展字段            AttributeExtendDO attributeExtend = productStatusRepository.getAttributeExtend(productDetailDO.getItemId());            AttributeExtendBO attributeExtendBO = null;            //没有已经存在的扩展信息            if (!Objects.isNull(attributeExtend) || StringUtils.isBlank(attributeExtend.getAttributeContent())) {                attributeExtendBO = new AttributeExtendBO();            } else {                attributeExtendBO = JsonUtil.json2Object(attributeExtend.getAttributeContent(), AttributeExtendBO.class);            }            attributeExtendBO.setTrialSaleTime(trialSaleTime);            //字段存储起来            productDetailDO.setAttributeContent(JSONObject.toJSONString(attributeExtendBO));        }    }        //变更商品的状态    private void updateProduct(ProductDetailDO productDetailDO, ProductStatusRequest productStatusRequest) {        ItemInfoDO itemInfoDO = productConverter.converterDO(productDetailDO);        //更新商品状态        productStatusRepository.updateProductStatus(itemInfoDO, productStatusRequest.getItemStatus());        if (checkItemType(productDetailDO)) {            //更新商品扩展信息            productStatusRepository.updateAttributeExtend(productDetailDO);        }    }    ...}@Repositorypublic class ProductStatusRepository {    ...    //更新商品状态    public void updateProductStatus(ItemInfoDO itemInfoDO, Integer updateItemStatus) {        LambdaUpdateWrapper updateWrapper = Wrappers.lambdaUpdate();        updateWrapper.eq(ItemInfoDO::getItemId, itemInfoDO.getItemId());        updateWrapper.eq(ItemInfoDO::getItemStatus, itemInfoDO.getItemStatus());        updateWrapper.set(ItemInfoDO::getItemStatus, updateItemStatus);        int count = itemInfoMapper.update(updateWrapper.getEntity(), updateWrapper);        if (count