| | |
| | | if (Objects.isNull(dto.getId())) { |
| | | this.save(goodsSku); |
| | | } else { |
| | | GoodsSku goodsSkuOrg = this.getById(dto.getId()); |
| | | if (StringUtils.isNull(goodsSkuOrg)) { |
| | | throw new ServiceException("商品不存在"); |
| | | } |
| | | this.updateById(goodsSku); |
| | | } |
| | | |
| | |
| | | .like(StringUtils.isNotEmpty(goodsSkuName), GoodsSku::getSkuName, goodsSkuName) |
| | | .list(); |
| | | } |
| | | |
| | | /** |
| | | * 扣减商品库存 |
| | | * |
| | | * @param goodsSkuId 商品SKU ID |
| | | * @param auctionStock 拍卖库存 |
| | | */ |
| | | @Override |
| | | public void deductStock(Long goodsSkuId, Integer auctionStock) { |
| | | GoodsSku goodsSku = this.getById(goodsSkuId); |
| | | if (StringUtils.isNull(goodsSku)) { |
| | | throw new ServiceException("商品不存在"); |
| | | } |
| | | if (goodsSku.getStock() < auctionStock) { |
| | | throw new ServiceException("库存不足"); |
| | | } |
| | | // 更新商品库存 |
| | | this.lambdaUpdate().set(GoodsSku::getStock, goodsSku.getStock() - auctionStock) |
| | | .ge(GoodsSku::getStock, auctionStock).eq(GoodsSku::getId, goodsSku.getId()) |
| | | .update(); |
| | | } |
| | | |
| | | @Override |
| | | public void returningStock(Long goodsSkuId, Integer auctionStock) { |
| | | GoodsSku goodsSku = this.getById(goodsSkuId); |
| | | if (StringUtils.isNull(goodsSku)) { |
| | | throw new ServiceException("商品不存在"); |
| | | } |
| | | // 更新商品库存 |
| | | this.lambdaUpdate() |
| | | .set(auctionStock > 0, GoodsSku::getStock, goodsSku.getStock() + auctionStock) |
| | | .eq(GoodsSku::getId, goodsSku.getId()) |
| | | .update(); |
| | | } |
| | | } |