From 92786986d9e6a48179f5bf8918076bc336f90eff Mon Sep 17 00:00:00 2001 From: liujiang <569804566@qq.com> Date: Fri, 12 Sep 2025 13:25:34 +0800 Subject: [PATCH] =?UTF-8?q?master=EF=BC=9Aapp=E8=8E=B7=E5=8F=96=E5=95=86?= =?UTF-8?q?=E5=93=81=E6=A6=9C=E4=BC=98=E5=8C=96=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xkt/service/impl/WebsiteAPPServiceImpl.java | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java b/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java index 1d99e18a6..89a2cc4ee 100644 --- a/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java +++ b/xkt/src/main/java/com/ruoyi/xkt/service/impl/WebsiteAPPServiceImpl.java @@ -585,13 +585,14 @@ public class WebsiteAPPServiceImpl implements IWebsiteAPPService { @Override @Transactional(readOnly = true) public List getAppCateSubProdSaleList(Long prodCateId) throws IOException { - List cateSaleTop100ProdList = redisCache.getCacheObject(CacheConstants.CATE_TOP_50_SALE_PROD); - if (CollectionUtils.isEmpty(cateSaleTop100ProdList)) { + List cateSaleTop50ProdList = redisCache.getCacheObject(CacheConstants.CATE_TOP_50_SALE_PROD); + if (CollectionUtils.isEmpty(cateSaleTop50ProdList)) { return new ArrayList<>(); } // 某一个具体分类下的商品ID列表 - List prodIdList = cateSaleTop100ProdList.stream().filter(x -> x.getProdCateId().equals(prodCateId)) - .sorted(Comparator.comparing(DailyStoreProdSaleDTO::getCount).reversed()).map(String::valueOf) + List prodIdList = cateSaleTop50ProdList.stream().filter(x -> x.getProdCateId().equals(prodCateId)) + .sorted(Comparator.comparing(DailyStoreProdSaleDTO::getCount).reversed()) + .map(DailyStoreProdSaleDTO::getStoreProdId).map(String::valueOf) .collect(Collectors.toList()); // 构建入参 IndexSearchDTO searchDTO = new IndexSearchDTO(); @@ -617,9 +618,11 @@ public class WebsiteAPPServiceImpl implements IWebsiteAPPService { Map esProdMap = page.getList().stream().collect(Collectors.toMap(ESProductDTO::getStoreProdId, Function.identity())); return prodIdList.stream().filter(x -> ObjectUtils.isNotEmpty(esProdMap.get(x))).map(prodId -> { ESProductDTO esProd = esProdMap.get(prodId); + // 查询档口会员等级 + StoreMember member = this.redisCache.getCacheObject(CacheConstants.STORE_MEMBER + Long.valueOf(esProd.getStoreId())); return BeanUtil.toBean(esProd, APPProdCateSubDTO.class) // 是否为档口会员 - .setMemberLevel(redisCache.getCacheObject(CacheConstants.STORE_MEMBER + esProd.getStoreId())) + .setMemberLevel(ObjectUtils.isNotEmpty(member) ? member.getLevel() : null) // 是否收藏商品 .setCollectProd(finalCollectMap.containsKey(prodId)); }).collect(Collectors.toList());