From dcec5e01f3aaf679af4eb2f3398a6913f27cde99 Mon Sep 17 00:00:00 2001
From: SongZhang <2064194730@qq.com>
Date: Sat, 6 Jul 2024 16:38:45 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=9B=E5=BB=BA=E8=AE=A2=E5=8D=95=E5=8F=91?=
 =?UTF-8?q?=E9=80=81=E5=BA=93=E5=AD=98=E9=A2=84=E8=AD=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/cashierservice/service/OrderService.java    | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/chaozhanggui/system/cashierservice/service/OrderService.java b/src/main/java/com/chaozhanggui/system/cashierservice/service/OrderService.java
index 80ebd35..67f7141 100644
--- a/src/main/java/com/chaozhanggui/system/cashierservice/service/OrderService.java
+++ b/src/main/java/com/chaozhanggui/system/cashierservice/service/OrderService.java
@@ -234,7 +234,6 @@ public class OrderService {
         redisUtil.saveMessage("SHOP:CODE:SET" + clientType + ":" + shopId + ":" + DateUtils.getDay(),masterId.substring(1,masterId.length()));
 
 
-        CompletableFuture.runAsync(() -> checkWarnLineAndSendMsg(skuWithBLOBs, product, shopInfo, number));
 
         return Result.success(CodeEnum.SUCCESS, masterId);
     }
@@ -244,7 +243,8 @@ public class OrderService {
      *
      * @param productSku sku
      */
-    private void checkWarnLineAndSendMsg(TbProductSku productSku, TbProduct product, TbShopInfo shopInfo, Integer num) {
+    private void checkWarnLineAndSendMsg(TbProductSku productSku, TbProduct product, Integer shopId, Integer num) {
+        TbShopInfo shopInfo = tbShopInfoMapper.selectByPrimaryKey(shopId);
         if (productSku.getWarnLine() == null) {
             return;
         }
@@ -486,6 +486,12 @@ public class OrderService {
         }
         boolean flag = true;
         for (TbCashierCart cashierCart : list) {
+            TbProductWithBLOBs product = tbProductMapper.selectByPrimaryKey(Integer.valueOf(cashierCart.getProductId()));
+            TbProductSkuWithBLOBs skuWithBLOBs = tbProductSkuMapper.selectByPrimaryKey(Integer.valueOf(cashierCart.getSkuId()));
+
+            log.info("下单,开始校验库存预警,购物车id:{}", cashierCart.getId());
+            CompletableFuture.runAsync(() -> checkWarnLineAndSendMsg(skuWithBLOBs, product, Integer.valueOf(cashierCart.getShopId()), cashierCart.getNumber()));
+
             // 已经添加的商品，修改数量
             if (StringUtils.isNotEmpty(cashierCart.getOrderId())) {
                 flag = false;