客户端增加扣减库存

src/main/java/com/chaozhanggui/system/cashierservice/dao/TbProductSkuMapper.java

@@ -29,4 +29,8 @@ public interface TbProductSkuMapper {
     TbProductSkuWithBLOBs selectByProduct(@Param("productId") Integer productId);
 
     void updateByskuId(@Param("productSkuId") Integer productSkuId,@Param("num") Integer num);
+
+    void updateByskuIdSub(@Param("skuId")Integer skuId, @Param("num")Integer num);
+
+    void updateStockNum(@Param("skuId") Integer skuId, @Param("num") Integer num);
 }

src/main/java/com/chaozhanggui/system/cashierservice/service/DutyService.java

@@ -13,10 +13,12 @@ import com.chaozhanggui.system.cashierservice.sign.CodeEnum;
 import com.chaozhanggui.system.cashierservice.sign.Result;
 import com.chaozhanggui.system.cashierservice.util.*;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.amqp.rabbit.annotation.RabbitHandler;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import redis.clients.jedis.Jedis;
 
 import java.math.BigDecimal;
 import java.util.*;
@@ -44,6 +46,9 @@ public class DutyService {
     private TbProductSkuMapper productSkuMapper;
     @Autowired
     private CloudPrinterService cloudPrinterService;
+    @Autowired
+    private RedisUtil redisUtil;
+
     @Transactional(rollbackFor = Exception.class)
     public void exect(String message) {
         try {
@@ -95,7 +100,8 @@ public class DutyService {
                             shopUserDutyDetail.setProductId(orderDetail.getProductId());
                             shopUserDutyDetail.setProductName(orderDetail.getProductName());
                             detaiList.add(shopUserDutyDetail);
-                            productSkuMapper.updateByskuId(orderDetail.getProductSkuId(),orderDetail.getNum());
+//                            productSkuMapper.updateByskuId(orderDetail.getProductSkuId(), orderDetail.getNum());
+                            subInventory(shopId,orderDetail.getProductSkuId(),orderDetail.getNum());
                         }
                         if (detaiList.size() > 0) {
                             shopUserDutyDetailMapper.batchInsert(detaiList);
@@ -135,7 +141,8 @@ public class DutyService {
                                 detaiList.add(shopUserDutyDetail);
 
                             }
-                            productSkuMapper.updateByskuId(orderDetail.getProductSkuId(),orderDetail.getNum());
+//                            productSkuMapper.updateByskuId(orderDetail.getProductSkuId(), orderDetail.getNum());
+                            subInventory(shopId,orderDetail.getProductSkuId(),orderDetail.getNum());
                         }
                         if (detaiList.size() > 0) {
                             shopUserDutyDetailMapper.batchInsert(detaiList);
@@ -275,4 +282,14 @@ public class DutyService {
             e.getMessage();
         }
     }
+
+    private void subInventory(Integer shopId, Integer skuId, Integer num) {
+        String result = redisUtil.seckill(RedisCst.PRODUCT + shopId.toString() + ":" + skuId.toString(), num.toString());
+        TbProductSku tbProductSku = productSkuMapper.selectByPrimaryKey(skuId);
+        if (num > tbProductSku.getStockNumber()) {
+            productSkuMapper.updateStockNum(skuId,num);
+        } else {
+            productSkuMapper.updateByskuIdSub(skuId, num);
+        }
+    }
 }

src/main/java/com/chaozhanggui/system/cashierservice/util/RedisCst.java

@@ -13,4 +13,5 @@ public class RedisCst {
     public static final String ONLINE_USER = "ONLINE:USER";
     public static final String CART = "CZG:CART:";
 
+    public static final Object PRODUCT = "PRODUCT:";
 }

src/main/java/com/chaozhanggui/system/cashierservice/util/RedisUtil.java

@@ -577,4 +577,43 @@ public class RedisUtil {
         }
         return 0L ;
     }
+
+    String secKillScript =  "local prodid=KEYS[1];\r\n" +
+            "local usernum=KEYS[2];\r\n" +
+            "local num= redis.call(\"get\" ,prodid);\r\n" +
+            "if tonumber(num)<tonumber(usernum) then \r\n" +
+            "   return 0;\r\n" +
+            "end\r\n" +
+            "if tonumber(num)<=0 then \r\n" +
+            "   return 0;\r\n" +
+            "else \r\n" +
+            "   redis.call(\"DECRBY\",prodid,tonumber(usernum));\r\n" +
+            "end\r\n" +
+            "return 1";
+    public String seckill(String key,String num) {
+        Jedis jedis = null;
+        try {
+            if (StringUtils.isEmpty(key)) {
+                return REDIS_FAILED+"";
+            }
+            // 从jedis池中获取一个jedis实例
+            jedis = pool.getResource();
+            if (database!=0) {
+                jedis.select(database);
+            }
+            Object result = jedis.eval(secKillScript, Arrays.asList( key,num), new ArrayList<>());
+            String reString = String.valueOf(result);
+            return reString;
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            // 释放对象池，即获取jedis实例使用后要将对象还回去
+            // 释放对象池，即获取jedis实例使用后要将对象还回去
+            if (jedis != null) {
+                jedis.close();
+            }
+        }
+        return REDIS_FAILED+"";
+    }
 }

src/main/resources/mapper/TbProductSkuMapper.xml

@@ -336,6 +336,12 @@
     <update id="updateByskuId">
       update tb_product_sku set real_sales_number = real_sales_number + #{num} where id = #{productSkuId}
     </update>
+  <update id="updateByskuIdSub">
+     update tb_product_sku set stock_number = stock_number - #{num},real_sales_number = real_sales_number + #{num} where id = #{skuId}
+  </update>
+  <update id="updateStockNum" parameterType="java.lang.Integer">
+     update tb_product_sku set stock_number = 0 ,real_sales_number = real_sales_number + #{num} where id = #{skuId}
+  </update>
 
   <select id="selectByShopIdAndProductIdAndSpec" resultMap="ResultMapWithBLOBs">
     select * from tb_product_sku where shop_id=#{shopId} and product_id=#{productId}