feat(Product): 优化商品详情页相关商品推荐逻辑

- 新增 subCate 方法获取产品子分类 - 在获取相关产品时，优先按关联度排序 - 当相关产品不足 10 个时，补充同子分类的产品- 优化了相关产品的推荐算法，提高推荐的准确性和多样性

feat(Product): 优化商品详情页相关商品推荐逻辑
- 新增 subCate 方法获取产品子分类 - 在获取相关产品时，优先按关联度排序 - 当相关产品不足 10 个时，补充同子分类的产品- 优化了相关产品的推荐算法，提高推荐的准确性和多样性
曾国涛
1 parent 7a48845c
Showing 1 changed file with 37 additions and 2 deletions
shop/src/main/java/com/canrd/shop/service/impl/ProductServiceImpl.java
@@ -86,6 +86,20 @@ public class ProductServiceImpl extends ServiceImpl&lt;ProductMapper, ProductDO&gt; im
     @Autowired
     private IJournalService journalService;
+
+    public List<ProductCategoryDO> subCate(String productId){
+        List<Productcategoryrelation> list = productCategoryRelationService.lambdaQuery()
+                .eq(Productcategoryrelation::getProductId, productId)
+                .list();
+        List<String> categoryIds = list.stream().map(Productcategoryrelation::getCategoryId).collect(Collectors.toList());
+        List<ProductCategoryDO> categoryDOS = categoryService.lambdaQuery()
+                .in(ProductCategoryDO::getId, categoryIds)
+                .list();
+        Set<String> parentIds = categoryDOS.stream().map(ProductCategoryDO::getParentId).collect(Collectors.toSet());
+        List<ProductCategoryDO> collect = categoryDOS.stream().filter(cate -> !parentIds.contains(cate.getId())).collect(Collectors.toList());
+        return collect;
+    }
+
     /**
      * 通过ID查询单条数据
      * <p>
@@ -190,12 +204,13 @@ public class ProductServiceImpl extends ServiceImpl&lt;ProductMapper, ProductDO&gt; im
         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));
+        productVO.setRelatedProductIds(new ArrayList<>());
         if(CollUtil.isNotEmpty(cateId2Relevance)) {
             QueryWrapper<ProductDO> objectQueryWrapper = new QueryWrapper<ProductDO>()
                     .eq("ismarketable",true)
@@ -210,7 +225,27 @@ public class ProductServiceImpl extends ServiceImpl&lt;ProductMapper, ProductDO&gt; im
                     .distinct()
                     .limit(10)
                     .collect(Collectors.toList());
-            productVO.setRelatedProductIds(relatedProductIds);
+            productVO.getRelatedProductIds().addAll(relatedProductIds);
+        }
+        if(productVO.getRelatedProductIds().size()<10){
+            List<ProductCategoryDO> productCategoryDOS = subCate(productQueryVO.getId());
+            List<String> cateIds = productCategoryDOS.stream()
+                    .map(ProductCategoryDO::getId)
+                    .collect(Collectors.toList());
+            List<String> collect = productCategoryRelationService.lambdaQuery()
+                    .select(Productcategoryrelation::getProductId)
+                    .in(Productcategoryrelation::getCategoryId, cateIds)
+                    .notIn(Productcategoryrelation::getProductId,productVO.getRelatedProductIds())
+                    .list().stream()
+                    .map(Productcategoryrelation::getProductId)
+                    .collect(Collectors.toList());
+            List<String> records = this.lambdaQuery()
+                    .in(ProductDO::getId, collect)
+                    .eq(ProductDO::getIsmarketable, true)
+                    .select(ProductDO::getId)
+                    .page(new Page<>(1, 10 - productVO.getRelatedProductIds().size())).getRecords().stream()
+                    .map(ProductDO::getId).collect(Collectors.toList());
+            productVO.getRelatedProductIds().addAll(records);
         }
 //        List<JournalCategoryRelation> journalCategoryRelations = journalCategoryService.lambdaQuery()