update:购物车判断

fengliang
1 parent 63ecec86
Showing 2 changed files with 32 additions and 1 deletions
etrade-order/src/main/java/com/diligrp/etrade/order/service/impl/ShopCartImpl.java
etrade-order/src/main/resources/com/diligrp/etrade/dao/mapper/shopCart/ShopCartMapper.xml
@@ -16,12 +16,15 @@ import com.diligrp.etrade.order.service.IShopCartMessageService;
 import com.diligrp.etrade.order.service.IShopCartService;
 import com.diligrp.etrade.order.type.ShopCartMessageCheckFlag;
 import com.diligrp.etrade.order.type.ShopCartMessageProductState;
+import com.diligrp.etrade.order.util.NumberTransform;
 import com.diligrp.etrade.shop.domain.response.ProductDetailVo;
 import com.diligrp.etrade.shop.domain.response.ProductListVo;
 import com.diligrp.etrade.shop.domain.response.ProductPresetVo;
 import com.diligrp.etrade.shop.domain.response.ShopVo;
+import com.diligrp.etrade.shop.model.Stock;
 import com.diligrp.etrade.shop.service.ProductService;
 import com.diligrp.etrade.shop.service.ShopService;
+import com.diligrp.etrade.shop.service.StockService;
 import com.diligrp.etrade.shop.type.ProductAuditState;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -31,6 +34,7 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.Assert;
 import org.springframework.util.CollectionUtils;
  
+import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -56,6 +60,9 @@ public class ShopCartImpl implements IShopCartService {
     @Autowired
     private ProductService productService;
  
+    @Autowired
+    private StockService stockService;
+
  
     /**
      * 购物车列表
@@ -229,6 +236,8 @@ public class ShopCartImpl implements IShopCartService {
         List<ShopCartMessage> shopCartMessages = shopCartMessageService.findList(shopCartMessageDtoQuery);
         //商品信息不存在，则新增商品信息
         if (CollectionUtils.isEmpty(shopCartMessages)) {
+            //效验最大最大数量
+            checkMaxProductWeight(shopCartMessageDto,null);
             AssertUtils.isTrue(count < 50L, "购物车商品数量不能超过50");
             shopCartMessageDto.setShopCartId(shopCart.getId());
             shopCartMessageService.saveShopCartMessage(shopCartMessageDto);
@@ -236,9 +245,30 @@ public class ShopCartImpl implements IShopCartService {
         }
         //存在相同商品信息，对商品信息进行更新操作
         ShopCartMessage shopCartMessageOld = shopCartMessages.get(0);
+        //效验最大数量
+        checkMaxProductWeight(shopCartMessageDto,shopCartMessageOld);
         shopCartMessageService.updateByOld(shopCartMessageOld, shopCartDto.getShopCartMessageDto(),shopCartDto.getBo());
     }
  
+    private void checkMaxProductWeight(ShopCartMessageDto shopCartMessageDto, ShopCartMessage shopCartMessageOld) {
+        if(shopCartMessageDto == null){
+            return ;
+        }
+        List<Stock> stocks = stockService.listByProductIds(Collections.singletonList(shopCartMessageDto.getProductId()));
+        if(CollectionUtils.isEmpty(stocks)){
+            throw new OrderException(OrderErrorCode.PARAM_ERROR,"该商品暂无库存");
+        }
+        if(shopCartMessageOld!=null){
+            if(stocks.get(0).getStock().multiply(NumberTransform.ONE_HUNDERD).compareTo(new BigDecimal(shopCartMessageOld.getWeight()+shopCartMessageDto.getWeight()))<0){
+                throw new OrderException(OrderErrorCode.PARAM_ERROR,"该宝贝不能购买更多哦~");
+            }
+        }else{
+            if(stocks.get(0).getStock().compareTo(new BigDecimal(shopCartMessageDto.getWeight()))<0){
+                throw new OrderException(OrderErrorCode.PARAM_ERROR,"该宝贝不能购买更多哦~");
+            }
+        }
+    }
+
  
     @Transactional(rollbackFor = Exception.class)
     @Override
@@ -63,7 +63,7 @@
                scm.number,
                scm.unit_amount,
                scm.unit_amount as prePrice,
-               scm.unit_weight,
+               case when scm.weight > st.stock*100 then  st.stock*100  else scm.weight end as weight,
                scm.weight,
                scm.amount,
                scm.type,
@@ -75,6 +75,7 @@
                scm.created_time as createdTime
         from shop_cart s
                  left join shop_cart_message scm
+                left join stock st
                            on s.id = scm.shop_cart_id
         where s.customer_id = #{customerId,jdbcType=BIGINT}
           and s.market_id = #{marketId,jdbcType=BIGINT}