From fc8b51f40e71aa09bb49f407c1e9f68ac94ceb58 Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期一, 29 七月 2024 18:51:32 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionBrowseRecordServiceImpl.java | 99 +++++++++++++++++++++++++++++++++++-------------- 1 files changed, 70 insertions(+), 29 deletions(-) diff --git a/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionBrowseRecordServiceImpl.java b/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionBrowseRecordServiceImpl.java index e731039..e9f0336 100644 --- a/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionBrowseRecordServiceImpl.java +++ b/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/AuctionBrowseRecordServiceImpl.java @@ -27,6 +27,7 @@ import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.ArrayList; +import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.stream.Collectors; @@ -65,16 +66,15 @@ LocalDateTime newTime7 = now.minusDays(7); LambdaQueryWrapper<AuctionBrowseRecord> wrapper3= Wrappers.lambdaQuery(); wrapper3.eq(AuctionBrowseRecord::getDelFlag,0); - wrapper3.eq(AuctionBrowseRecord::getTargetId,auctionGoodsListDTO.getGoodsSkuId()); + wrapper3.eq(AuctionBrowseRecord::getBrowseType,1); wrapper3.eq(AuctionBrowseRecord::getMemberId,auctionGoodsListDTO.getMemberId()); wrapper3.ge(AuctionBrowseRecord::getCreateTime, newTime7) .le(AuctionBrowseRecord::getCreateTime, now); - + Set<Long> goodsSkuIdList = new HashSet<>(); List<AuctionBrowseRecord> list = this.list(wrapper3); - Set<Long> goodsSkuIdList = null; - goodsSkuIdList = list.stream().map(AuctionBrowseRecord::getTargetId) - .collect(Collectors.toSet()); - + for (AuctionBrowseRecord auctionBrowseRecord:list){ + goodsSkuIdList.add(auctionBrowseRecord.getTargetId()); + } Set<Long> goodsSkuIdList1 = null; if (StringUtils.isNotEmpty(auctionGoodsListDTO.getGoodsSkuName())) { List<GoodsSku> goodsSku = goodsSkuClient.getGoodsByName(auctionGoodsListDTO.getGoodsSkuName(), @@ -83,19 +83,46 @@ goodsSkuIdList1 = goodsSku.stream().map(GoodsSku::getId) .collect(Collectors.toSet()); } - Set<Long> goodsSkuIdList2 =null; - if (goodsSkuIdList1.size()==0){ - goodsSkuIdList.retainAll(goodsSkuIdList1); - goodsSkuIdList2=goodsSkuIdList; - }else { + + Set<Long> goodsSkuIdList3 =new HashSet<>(); + if (StringUtils.isNotEmpty(goodsSkuIdList1)){ + for (Long i:goodsSkuIdList1){ + LambdaQueryWrapper<AuctionGoods> wrapper= Wrappers.lambdaQuery(); + wrapper.eq(AuctionGoods::getGoodsSkuId,i); + wrapper.eq(AuctionGoods::getDelFlag,0); + List<AuctionGoods> auctionGoods = auctionGoodsMapper.selectList(wrapper); + for (AuctionGoods a:auctionGoods){ + goodsSkuIdList3.add(a.getId()); + } + + } + + } + Set<Long> goodsSkuIdList2 =new HashSet<>(); + if (StringUtils.isNotEmpty(auctionGoodsListDTO.getGoodsSkuName())) { + if (goodsSkuIdList3.size() > 0) { + goodsSkuIdList2 = goodsSkuIdList.stream() + .filter(goodsSkuIdList3::contains) + .collect(Collectors.toSet()); + } else { + goodsSkuIdList2.add(0L);; + } + }else{ goodsSkuIdList2=goodsSkuIdList; } + + Page<AuctionGoodsListVO> page = new Page<>(); page.setSize(auctionGoodsListDTO.getPageSize()); page.setCurrent(auctionGoodsListDTO.getPageCurr()); AuctionGoodsListPageDTO auctionGoodsListPageDTO=new AuctionGoodsListPageDTO(); - auctionGoodsListPageDTO.setGoodsSkuIdList(goodsSkuIdList2); - List<AuctionGoods> auctionGoodsPgeList = auctionGoodsMapper.getAuctionGoodsPgeList(page, auctionGoodsListPageDTO); + if (goodsSkuIdList2.size()>0){ + auctionGoodsListPageDTO.setGoodsSkuIdList(goodsSkuIdList2); + }else{ + goodsSkuIdList2.add(0L); + auctionGoodsListPageDTO.setGoodsSkuIdList(goodsSkuIdList2); + } + List<AuctionGoods> auctionGoodsPgeList = auctionGoodsMapper.getAuctionGoodsPgeList1(page, auctionGoodsListPageDTO); List<AuctionGoodsListVO> auctionGoodsVOS=new ArrayList<>(); for (AuctionGoods auctionGoods:auctionGoodsPgeList){ AuctionGoodsListVO auctionGoodsVO=new AuctionGoodsListVO(); @@ -127,8 +154,8 @@ LambdaQueryWrapper<AuctionBrowseRecord> wrapper3= Wrappers.lambdaQuery(); wrapper3.eq(AuctionBrowseRecord::getDelFlag,0); - wrapper3.eq(AuctionBrowseRecord::getTargetId,MemberAuctionSalesroomDTO.getAuctionSalesroomId()); wrapper3.eq(AuctionBrowseRecord::getMemberId,MemberAuctionSalesroomDTO.getMemberId()); + wrapper3.eq(AuctionBrowseRecord::getBrowseType,2); wrapper3.ge(AuctionBrowseRecord::getCreateTime, newTime7) .le(AuctionBrowseRecord::getCreateTime, now); @@ -136,30 +163,44 @@ Set<Long> goodsSkuIdList = null; goodsSkuIdList = list.stream().map(AuctionBrowseRecord::getTargetId) .collect(Collectors.toSet()); - Page<WdMemberAuctionSalesroomVO> page = new Page<>(); + Page<AuctionSalesroom> page = new Page<>(); page.setSize(MemberAuctionSalesroomDTO.getPageSize()); page.setCurrent(MemberAuctionSalesroomDTO.getPageCurr()); MemberAuctionSalesroomWdDTO memberAuctionSalesroomWdDTO=new MemberAuctionSalesroomWdDTO(); - memberAuctionSalesroomWdDTO.setGoodsSkuIdList(goodsSkuIdList); + if (goodsSkuIdList.size()>0){ + memberAuctionSalesroomWdDTO.setGoodsSkuIdList(goodsSkuIdList); + }else{ + goodsSkuIdList=new HashSet<>(); + goodsSkuIdList.add(0L); + memberAuctionSalesroomWdDTO.setGoodsSkuIdList(goodsSkuIdList); + } memberAuctionSalesroomWdDTO.setSalesroomName(MemberAuctionSalesroomDTO.getSalesroomName()); - List<AuctionSalesroom> auctionSalesroomList=auctionSalesroomMapper.pageMemberAuctionSalesroomWdList(page,memberAuctionSalesroomWdDTO); - List<WdMemberAuctionSalesroomVO> List=new ArrayList<>(); - for (AuctionSalesroom auctionSalesroom:auctionSalesroomList){ - WdMemberAuctionSalesroomVO memberAuctionSalesroomVO=new WdMemberAuctionSalesroomVO(); - memberAuctionSalesroomVO.setSalesroomName(auctionSalesroom.getSalesroomName()); - memberAuctionSalesroomVO.setDescription(auctionSalesroom.getDescription()); - memberAuctionSalesroomVO.setStatus(auctionSalesroom.getStatus().getCode()); - memberAuctionSalesroomVO.setSalesroomId(auctionSalesroom.getId()); - memberAuctionSalesroomVO.setCoverPic(auctionSalesroom.getCoverPic()); + Page<AuctionSalesroom> auctionSalesroomList=auctionSalesroomMapper.pageMemberAuctionSalesroomWdList(page,memberAuctionSalesroomWdDTO); + PageDTO<WdMemberAuctionSalesroomVO> wdMemberAuctionSalesroomVOPageDTO = PageDTO.of(auctionSalesroomList, WdMemberAuctionSalesroomVO.class); + List<WdMemberAuctionSalesroomVO> list1 = wdMemberAuctionSalesroomVOPageDTO.getList(); + for (WdMemberAuctionSalesroomVO auctionSalesroom:list1){ + auctionSalesroom.setSalesroomName(auctionSalesroom.getSalesroomName()); + auctionSalesroom.setDescription(auctionSalesroom.getDescription()); + auctionSalesroom.setStatus(auctionSalesroom.getStatus()); + auctionSalesroom.setSalesroomId(auctionSalesroom.getId()); + auctionSalesroom.setId(auctionSalesroom.getId()); + auctionSalesroom.setCoverPic(auctionSalesroom.getCoverPic()); MemberAuctionSalesroomDTO memberAuctionSalesroomDTO1=new MemberAuctionSalesroomDTO(); memberAuctionSalesroomDTO1.setAuctionSalesroomId(auctionSalesroom.getId()); memberAuctionSalesroomDTO1.setMemberId(MemberAuctionSalesroomDTO.getMemberId()); List<OrderAuctionBond> data1 = orderClient.getOrderAuctionBondList1(memberAuctionSalesroomDTO1, SecurityConstants.INNER).getData(); - memberAuctionSalesroomVO.setBondTime(data1.get(0).getCreateTime()); - List.add(memberAuctionSalesroomVO); + if (data1.size()>0){ + auctionSalesroom.setIsBond(2); + }else{ + auctionSalesroom.setIsBond(1); + } + MemberAuctionSalesroomDTO memberAuctionSalesroomDTO2=new MemberAuctionSalesroomDTO(); + memberAuctionSalesroomDTO2.setAuctionSalesroomId(auctionSalesroom.getId()); + List<OrderAuctionBond> data2 = orderClient.getOrderAuctionBondList1(memberAuctionSalesroomDTO2, SecurityConstants.INNER).getData(); + auctionSalesroom.setBondNum(data2.size()); + auctionSalesroom.setBond(auctionSalesroom.getBond()); } - page.setRecords(List); - return PageDTO.of(page); + return wdMemberAuctionSalesroomVOPageDTO; } } -- Gitblit v1.7.1