From 820237d63e4e3390b668a46df5bd1f28821cc140 Mon Sep 17 00:00:00 2001
From: GYJ <1157756119@qq.com>
Date: Tue, 30 Jul 2024 11:29:31 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=95=86=E5=93=81=20?=
 =?UTF-8?q?=E5=A1=AB=E5=85=85=E9=A2=84=E8=AD=A6=E5=80=BC=E5=AD=97=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../repository/product/TbProductRepository.java      |  4 ++++
 .../impl/productimpl/TbProductServiceImpl.java       | 12 ++++++++++++
 2 files changed, 16 insertions(+)

diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java
index aa50c29b..01e2ae64 100644
--- a/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java
+++ b/eladmin-system/src/main/java/cn/ysk/cashier/repository/product/TbProductRepository.java
@@ -58,4 +58,8 @@ public interface TbProductRepository extends JpaRepository<TbProduct, Integer>,
 
     @Query("select product from TbProduct product where product.id=:id and product.shopId=:shopId")
     TbProduct selectByShopIdAndId(Integer id, String shopId);
+
+    @Query("select product from TbProduct product where product.shopId=:shopId")
+    List<TbProduct> selectByShopId(String shopId);
+
 }
diff --git a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/TbProductServiceImpl.java b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/TbProductServiceImpl.java
index 566b0e5b..9e181f3d 100644
--- a/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/TbProductServiceImpl.java
+++ b/eladmin-system/src/main/java/cn/ysk/cashier/service/impl/productimpl/TbProductServiceImpl.java
@@ -373,6 +373,7 @@ public class TbProductServiceImpl implements TbProductService {
                 }
             }
         }
+
         TbProduct save = tbProductRepository.save(product);
         if (save.getId() == null) {
             throw new BadRequestException("添加商品失败");
@@ -381,6 +382,16 @@ public class TbProductServiceImpl implements TbProductService {
         tbProductRepository.save(save);
         //sku
         if (resources.getSkuList() != null) {
+            Integer warnLine = 0;
+            List<TbProduct> productList = tbProductRepository.selectByShopId(resources.getShopId());
+            if (!productList.isEmpty()) {
+                TbProduct p = productList.get(0);
+                List<TbProductSku> productSkus = tbProductSkuRepository.searchSku(p.getId().toString());
+                if (!productSkus.isEmpty()) {
+                    warnLine = productSkus.get(0).getWarnLine();
+                }
+            }
+
             List<TbProductSku> skuList = new ArrayList<>();
             for (TbProductSku sku : resources.getSkuList()) {
                 sku.setProductId(String.valueOf(save.getId()));
@@ -388,6 +399,7 @@ public class TbProductServiceImpl implements TbProductService {
                 sku.setCreatedAt(Instant.now().toEpochMilli());
                 sku.setUpdatedAt(Instant.now().toEpochMilli());
                 sku.setIsGrounding(1);
+                sku.setWarnLine(warnLine);
                 skuList.add(sku);
             }
             List<TbProductSku> tbProductSkus = tbProductSkuRepository.saveAll(skuList);