feat(product): 添加产品关联

- 在 ProductVO 中添加 relatedProductIds 字段，用于存储关联产品 ID - 在 ProductServiceImpl 中实现关联产品的查询逻辑 - 使用 category 关系和自定义排序来获取最多 10 个关联产品

feat(product): 添加产品关联
- 在 ProductVO 中添加 relatedProductIds 字段，用于存储关联产品 ID - 在 ProductServiceImpl 中实现关联产品的查询逻辑 - 使用 category 关系和自定义排序来获取最多 10 个关联产品
曾国涛 · boyang
1 parent 38d9ec92
Showing 2 changed files with 32 additions and 0 deletions
shop/src/main/java/com/canrd/shop/module/vo/ProductVO.java
shop/src/main/java/com/canrd/shop/service/impl/ProductServiceImpl.java
@@ -143,4 +143,6 @@ public class ProductVO implements Serializable {
      */
     private List<TickeyTypeVO> ticketTypes;
  
+    private List<String> RelatedProductIds;
+
 }
@@ -117,6 +117,7 @@ public class ProductServiceImpl extends ServiceImpl&lt;ProductMapper, ProductDO&gt; im
             });
             productVO.setProductAttributeList(productAttributeVOS);
         }
+
         // 金额处理
         Boolean productPriceShow = switchControlService.getEnabledByName(SwitchControlConstants.PRODUCT_PRICE_SHOW);
         List<TicketTypeDO> ticketTypeDOS = ticketTypeService.selectByProductId(productDO.getId());
@@ -128,6 +129,35 @@ public class ProductServiceImpl extends ServiceImpl&lt;ProductMapper, ProductDO&gt; im
             productVO.setTicketTypes(typeVOS);
         }
  
+        List<Productcategoryrelation> productcategoryrelations = productCategoryRelationService.lambdaQuery()
+                .eq(Productcategoryrelation::getProductId, productQueryVO.getId())
+                .list();
+        List<String> categoryIds = productcategoryrelations.stream().map(Productcategoryrelation::getCategoryId).collect(Collectors.toList());
+
+        List<EbCategorysRelation> cateRelations = ebCategorysRelationService.lambdaQuery()
+                .in(EbCategorysRelation::getCategoryId, categoryIds)
+                .list();
+
+        Map<String,Integer> relatedCateId2Relevance = cateRelations.stream()
+                .collect(Collectors.toMap(EbCategorysRelation::getRelatedCategoryId, EbCategorysRelation::getRelevance,(a, b) -> a));
+        TreeMap<String, Integer> cateId2Relevance = new TreeMap<>(relatedCateId2Relevance);
+        StringJoiner orderByJoiner = new StringJoiner(" when "," order by case pc.id when "," else 0 end ");
+        cateId2Relevance.forEach((k,v)->orderByJoiner.add("'"+k+"'"+" then "+v));
+        if(CollUtil.isNotEmpty(cateId2Relevance)){
+            QueryWrapper<ProductDO> objectQueryWrapper = new QueryWrapper<ProductDO>()
+                    .in("pc.id", cateId2Relevance.keySet())
+                    .select("distinct p.id","pc.id")
+                    .last(orderByJoiner.toString());
+            List<ProductDO> relatedProducts = this
+                    .list(objectQueryWrapper);
+            List<String> relatedProductIds = relatedProducts.stream()
+                    .map(ProductDO::getId)
+                    .distinct()
+                    .limit(10)
+                    .collect(Collectors.toList());
+            productVO.setRelatedProductIds(relatedProductIds);
+        }
+
         productVO.setPriceShow(productPriceShow);