微服务实战——平台属性

平台属性

中间表复杂业务

1. /**
2. * 获取分类规格参数（模糊查询）
3. *
4. * @param params
5. * @param catelogId
6. * @param type type="base"时查询基础属性，type="sale"时查询销售属性
7. * @return
8. */
9. @Override
10. public PageUtils listByCatelogId(Map<String, Object> params, Long catelogId, String type) {
12.     String key = (String) params.get("key");
13.     QueryWrapper<AttrEntity> wrapper = new QueryWrapper<>();
15.     // 1.判断参数中是否存在检索关键字key
16.     if(!StringUtils.isEmpty(key)){
17.         wrapper.and((obj) -> {
18.             obj.eq("attr_id", key)
19.                     .or().like("attr_name", key)
20.                     .or().like("value_select", key);
21.         });
22.     }
24.     // 2.判断参数中是否存在catelogId
25.     // 2.1.查询全部
26.     if(catelogId != 0){
27.         wrapper.eq("catelog_id", catelogId);
28.     }
29.     IPage<AttrEntity> page = this.page(
30.             new Query<AttrEntity>().getPage(params),
31.             wrapper.eq("attr_type", "base".equalsIgnoreCase(type) ? 1 : 0)
32.     );
34.     PageUtils pageUtils = new PageUtils(page);
36.     // 3.封装成AttrRespVO
37.     List<AttrRespVo> respVos = page.getRecords().stream().map((attrEntity) -> {
38.         AttrRespVo attrRespVo = new AttrRespVo();
39.         BeanUtils.copyProperties(attrEntity, attrRespVo);
40.         // 3.1.得到所属分类名
41.         CategoryEntity categoryEntity = categoryService.getById(attrEntity.getCatelogId());
42.         if(categoryEntity != null){
43.             attrRespVo.setCatelogName(categoryEntity.getName());
44.         }
46.         // 3.2.得到所属分组名
47.         if (ATTR_TYPE_BASE.getMsg().equalsIgnoreCase(type)) {
48.             AttrAttrgroupRelationEntity relationEntity = relationService.query().eq("attr_id", attrEntity.getAttrId()).one();
49.             if(relationEntity != null){
50.                 AttrGroupEntity attrGroupEntity = attrGroupService.getById(relationEntity.getAttrGroupId());
51.                 attrRespVo.setGroupName(attrGroupEntity.getAttrGroupName());
52.             }
53.         }
55.         return attrRespVo;
56.     }).collect(Collectors.toList());
58.     pageUtils.setList(respVos);
60.     return pageUtils;
61. }

复制代码

批量删除

1. /**
2. * 删除属性与分组的关联关系
3. * DELETE FROM pms_attr_attrgroup_relation
4. * WHERE (( attr_id = 1 and attr_group_id = 1) OR ( attr_id = 2 and attr_group_id = 3))
5. */
6. @Override
7. public void deleteRelation(List<AttrGroupRelationVo> voList) {
9.     // 1.获取
10.     List<AttrAttrgroupRelationEntity> relationEntities = voList.stream().map(attrGroupRelationVo -> {
11.         AttrAttrgroupRelationEntity relationEntity = new AttrAttrgroupRelationEntity();
12.         relationEntity.setAttrId(attrGroupRelationVo.getAttrId());
13.         relationEntity.setAttrGroupId(attrGroupRelationVo.getAttrGroupId());
14.         return relationEntity;
15.     }).collect(Collectors.toList());
17.     // 2.批量删除
18.     relationDao.deleteBatchRelation(relationEntities);
19. }

复制代码

1. <!--    DELETE FROM pms_attr_attrgroup_relation
2. WHERE (( attr_id = 1 and attr_group_id = 1) OR ( attr_id = 2 and attr_group_id = 3))-->
3. <delete id="deleteBatchRelation">
4.     DELETE FROM `pms_attr_attrgroup_relation` WHERE
5.     <foreach collection="relationEntities" item="item" separator=" OR ">
6.         ( attr_id = #{item.attrId} AND attr_group_id = #{item.attrGroupId})
7.     </foreach>
8. </delete>

复制代码

中间表复杂业务

1. /**
2. * 获取属性分组没有关联的其他属性
3. */
4. @Override
5. public PageUtils listNoRelationAttr(Map<String, Object> params, Long attrgroupId) {
7.     // 1.获取分类id
8.     Long catelogId = this.query().eq("attr_group_id", attrgroupId).one().getCatelogId();
10.     // 2.获取当前分类下的其他分组id集合
11.     List<Long> groupIds = this.list(new QueryWrapper<AttrGroupEntity>()
12.                     .eq("catelog_id", catelogId))
13.             .stream()
14.             .map(AttrGroupEntity::getAttrGroupId)
15.             .collect(Collectors.toList());;
17.     // 3.获取其他分组关联的属性id集合
18.     List<Long> attrIds = relationService.list(new QueryWrapper<AttrAttrgroupRelationEntity>()
19.                     .in("attr_group_id", groupIds))
20.             .stream()
21.             .map(AttrAttrgroupRelationEntity::getAttrId)
22.             .collect(Collectors.toList());
24.     // 4.剔除其他分组关联的属性
25.     QueryWrapper<AttrEntity> wrapper = new QueryWrapper<AttrEntity>()
26.             .eq("catelog_id", catelogId)
27.             .ne("value_type", ATTR_TYPE_BASE.getCode());
28.     if(attrIds != null && attrIds.size() > 0){
29.         wrapper.notIn("attr_id", attrIds);
30.     }
31.    
32.     // 5.判断key
33.     String key = (String) params.get("key");
34.     if(!StringUtils.isEmpty(key)){
35.         wrapper.and((obj) -> {
36.             obj.eq("attr_id", key)
37.                     .or().like("attr_name", key)
38.                     .or().like("value_select", key);
39.         });
40.     }
42.     IPage<AttrEntity> page = attrService.page(new Query<AttrEntity>().getPage(params), wrapper);
43.     return new PageUtils(page);
44. }

复制代码