| | |
|---|
| | | import com.ruoyi.system.api.domain.dto.AuctionGoodsListDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.AuctionGoodsListPageDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.GoodsStockUpdDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.ListStatusDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.MemberAuctionSalesroomDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.OrderDTO; |
|---|
| | | import com.ruoyi.system.api.domain.dto.RefundDTO; |
|---|
| | |
|---|
| | | .eq(StringUtils.isNotNull(query.getStartStatus()), AuctionGoods::getStartStatus, |
|---|
| | | query.getStartStatus()) |
|---|
| | | .page(new Page<>(query.getPageCurr(), query.getPageSize())); |
|---|
| | | return PageDTO.of(page, MgtAuctionGoodsVO.class); |
|---|
| | | if (StringUtils.isEmpty(page.getRecords())) { |
|---|
| | | return PageDTO.empty(page.getTotal(), page.getPages()); |
|---|
| | | } |
|---|
| | | // 查询商品信息 |
|---|
| | | Set<Long> goodsIdList = page.getRecords().stream().map(AuctionGoods::getGoodsSkuId) |
|---|
| | | .collect(Collectors.toSet()); |
|---|
| | | List<GoodsSku> data = goodsSkuClient.getGoodsListByIds(goodsIdList, SecurityConstants.INNER) |
|---|
| | | .getData(); |
|---|
| | | PageDTO<MgtAuctionGoodsVO> pageDTO = PageDTO.of(page, |
|---|
| | | MgtAuctionGoodsVO.class); |
|---|
| | | if (StringUtils.isNotEmpty(data)) { |
|---|
| | | Map<Long, GoodsSku> goodsSkuMap = data.stream() |
|---|
| | | .collect(Collectors.toMap(GoodsSku::getId, e -> e)); |
|---|
| | | for (MgtAuctionGoodsVO mgtAuctionGoodsVO : pageDTO.getList()) { |
|---|
| | | GoodsSku goodsSku = goodsSkuMap.get(mgtAuctionGoodsVO.getGoodsSkuId()); |
|---|
| | | if (StringUtils.isNotNull(goodsSku)) { |
|---|
| | | mgtAuctionGoodsVO.setGoodsSkuName(goodsSku.getSkuName()); |
|---|
| | | mgtAuctionGoodsVO.setSpec(goodsSku.getSpec()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return pageDTO; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | log.info("===================>发送websocket通知，消息体{}", msg); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 下架/上架 拍卖商品 |
|---|
| | | * |
|---|
| | | * @param dto 商品上下架状态对象 |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public void updStatus(ListStatusDTO dto) { |
|---|
| | | AuctionGoods auctionGoods = this.getById(dto.getId()); |
|---|
| | | if (StringUtils.isNull(auctionGoods)) { |
|---|
| | | throw new ServiceException("拍卖商品不存在"); |
|---|
| | | } |
|---|
| | | auctionGoods.setListingStatus(dto.getListingStatus()); |
|---|
| | | this.updateById(auctionGoods); |
|---|
| | | } |
|---|
| | | } |
|---|
