From 78698a4a6731054bd9e5bc397cf9aba4764aa763 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期五, 24 五月 2024 18:17:19 +0800
Subject: [PATCH] 提交【管理后台】 商城管理-团购管理-立即结束 接口

---
 ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillServiceImpl.java |   10 ++++++++++
 1 files changed, 10 insertions(+), 0 deletions(-)

diff --git a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillServiceImpl.java b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillServiceImpl.java
index af7e470..fb901b3 100644
--- a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillServiceImpl.java
+++ b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillServiceImpl.java
@@ -4,6 +4,7 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.common.core.constant.CacheConstants;
 import com.ruoyi.common.core.enums.StartStatusEnum;
+import com.ruoyi.common.core.exception.ServiceException;
 import com.ruoyi.common.core.utils.StringUtils;
 import com.ruoyi.common.core.utils.page.BeanUtils;
 import com.ruoyi.common.core.utils.page.PageDTO;
@@ -60,6 +61,15 @@
         this.saveBatch(goodsSeckills);
 
         for (GoodsSeckill goodsSeckill : goodsSeckills) {
+            GoodsSku goodsSku = goodsSkuService.getById(goodsSeckill.getGoodsSkuId());
+            if (StringUtils.isNull(goodsSku)) {
+                throw new ServiceException("商品不存在");
+            }
+            Integer seckillStock = goodsSeckill.getSeckillStock();
+            goodsSkuService.lambdaUpdate()
+                    .set(GoodsSku::getStock, goodsSku.getStock() - seckillStock)
+                    .ge(GoodsSku::getStock, seckillStock)
+                    .eq(GoodsSku::getId, goodsSku.getId());
             asyncMethodService.seckillScheduleTask(goodsSeckill);
         }
     }

--
Gitblit v1.7.1