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/MemberAuctionCollectionServiceImpl.java | 60 +++++++++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 55 insertions(+), 5 deletions(-) diff --git a/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/MemberAuctionCollectionServiceImpl.java b/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/MemberAuctionCollectionServiceImpl.java index 343e525..552c596 100644 --- a/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/MemberAuctionCollectionServiceImpl.java +++ b/ruoyi-modules/ruoyi-auction/src/main/java/com/ruoyi/auction/service/impl/MemberAuctionCollectionServiceImpl.java @@ -4,7 +4,9 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ruoyi.auction.domain.AuctionBidRecord; import com.ruoyi.auction.domain.MemberAuctionCollection; +import com.ruoyi.auction.mapper.AuctionBidRecordMapper; import com.ruoyi.auction.mapper.AuctionGoodsMapper; import com.ruoyi.auction.mapper.MemberAuctionCollectionMapper; import com.ruoyi.auction.service.IMemberAuctionCollectionService; @@ -19,6 +21,7 @@ import com.ruoyi.system.api.domain.vo.AuctionGoodsListVO; import com.ruoyi.system.api.feignClient.GoodsSkuClient; import java.util.ArrayList; +import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.stream.Collectors; @@ -41,13 +44,16 @@ @Resource private AuctionGoodsMapper auctionGoodsMapper; + @Resource + private AuctionBidRecordMapper auctionBidRecordMapper; + @Override public void saveAuctionCollection(AuctionCollectionDTO auctionCollectionDTO) { - if (auctionCollectionDTO.getMemberId()!=null) { + if (auctionCollectionDTO.getMemberId()==null) { throw new ServiceException("用户ID不能为空"); } - if (auctionCollectionDTO.getState()!=null) { + if (auctionCollectionDTO.getState()==null) { throw new ServiceException("类型不能为空"); } @@ -85,17 +91,42 @@ } AuctionGoodsListPageDTO auctionGoodsListPageDTO=new AuctionGoodsListPageDTO(); auctionGoodsListPageDTO.setGoodsSkuIdList(goodsSkuIdList); + Set<Long> goodsSkuIdList1 = new HashSet<>(); + if (StringUtils.isNotEmpty(goodsSkuIdList)){ + for (Long i:goodsSkuIdList){ + 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){ + goodsSkuIdList1.add(a.getId()); + } + + } + + } + Page<AuctionGoodsListVO> page = new Page<>(); page.setSize(auctionCollectionDTO.getPageSize()); page.setCurrent(auctionCollectionDTO.getPageCurr()); - LambdaQueryWrapper< MemberAuctionCollection> wrapper= Wrappers.lambdaQuery(); - wrapper.in( MemberAuctionCollection::getTargetId, goodsSkuIdList); + LambdaQueryWrapper<MemberAuctionCollection> wrapper= Wrappers.lambdaQuery(); + wrapper.eq(MemberAuctionCollection::getMemberId,auctionCollectionDTO.getMemberId()); + if (StringUtils.isNotEmpty(auctionCollectionDTO.getGoodsSkuName())){ + if (goodsSkuIdList1.size()>0){ + wrapper.in(MemberAuctionCollection::getTargetId,goodsSkuIdList1); + }else{ + goodsSkuIdList1=new HashSet<>(); + goodsSkuIdList1.add(0L); + wrapper.in(MemberAuctionCollection::getTargetId,goodsSkuIdList1); + } + } + wrapper.orderByDesc(MemberAuctionCollection::getCreateTime); List<MemberAuctionCollection> list = this.list(wrapper); List<AuctionGoodsListVO> auctionGoodsVOS=new ArrayList<>(); for (MemberAuctionCollection auctionCollection:list){ - AuctionGoods auctionGoods = auctionGoodsMapper.selectById(auctionCollection.getId()); + AuctionGoods auctionGoods = auctionGoodsMapper.selectById(auctionCollection.getTargetId()); AuctionGoodsListVO auctionGoodsVO=new AuctionGoodsListVO(); auctionGoodsVO.setAuctionStock(auctionGoods.getAuctionStock()); auctionGoodsVO.setGoodsSkuId(auctionGoods.getId()); @@ -106,9 +137,28 @@ GoodsSku goodsSkuOne = goodsSkuClient.getGoodsSkuOne(auctionGoods.getGoodsSkuId(), SecurityConstants.INNER).getData(); auctionGoodsVO.setUnit(goodsSkuOne.getUnit()); auctionGoodsVO.setSpec(goodsSkuOne.getSpec()); + auctionGoodsVO.setIsCollection(2); auctionGoodsVO.setSpecUnit(goodsSkuOne.getSpecUnit()); auctionGoodsVO.setGoodsSkuName(goodsSkuOne.getSkuName()); auctionGoodsVO.setCoverPic(goodsSkuOne.getCoverPic()); + + + LambdaQueryWrapper<AuctionBidRecord> wrapper1=Wrappers.lambdaQuery(); + wrapper1.eq(AuctionBidRecord::getMemberId,auctionCollectionDTO.getMemberId()); + wrapper1.eq(AuctionBidRecord::getAuctionType,1); + wrapper1.eq(AuctionBidRecord::getTargetId,auctionGoods.getId()); + wrapper1.eq(AuctionBidRecord::getDelFlag,0); + AuctionBidRecord list1 = auctionBidRecordMapper.selectOne(wrapper1); + if (list1!=null){ + if (list1.getStatus().getCode()==2){ + auctionGoodsVO.setIsStatus(2); + }else{ + auctionGoodsVO.setIsStatus(1); + } + }else{ + auctionGoodsVO.setIsStatus(1); + } + auctionGoodsVOS.add(auctionGoodsVO); } -- Gitblit v1.7.1