From e27185d424ee14e0390b67d975e54dba68bc76dd Mon Sep 17 00:00:00 2001
From: paulGao <paulgao0831@gmail.com>
Date: Tue, 1 Mar 2022 11:49:35 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=9C=AA=E5=BC=80=E5=A7=8B?=
 =?UTF-8?q?=E7=9A=84=E7=A7=92=E6=9D=80=E6=B4=BB=E5=8A=A8=E4=BF=AE=E6=94=B9?=
 =?UTF-8?q?=E6=97=B6=EF=BC=8C=E5=85=88=E6=B7=BB=E5=8A=A0=E7=A7=92=E6=9D=80?=
 =?UTF-8?q?=E5=95=86=E5=93=81=E5=90=8E=E4=BF=AE=E6=94=B9=E6=97=B6=E9=97=B4?=
 =?UTF-8?q?=E6=97=B6=EF=BC=8C=E7=A7=92=E6=9D=80=E6=B4=BB=E5=8A=A8=E5=95=86?=
 =?UTF-8?q?=E5=93=81=E6=97=B6=E9=97=B4=E6=B2=A1=E6=9C=89=E6=94=B9=E5=8F=98?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/SeckillApplyService.java          |  9 +++++
 .../serviceimpl/SeckillApplyServiceImpl.java  | 37 +++++++++++++++++++
 .../serviceimpl/SeckillServiceImpl.java       | 19 ++++++++++
 3 files changed, 65 insertions(+)

diff --git a/framework/src/main/java/cn/lili/modules/promotion/service/SeckillApplyService.java b/framework/src/main/java/cn/lili/modules/promotion/service/SeckillApplyService.java
index 99b60133..8d67dd74 100644
--- a/framework/src/main/java/cn/lili/modules/promotion/service/SeckillApplyService.java
+++ b/framework/src/main/java/cn/lili/modules/promotion/service/SeckillApplyService.java
@@ -1,6 +1,7 @@
 package cn.lili.modules.promotion.service;
 
 import cn.lili.common.vo.PageVO;
+import cn.lili.modules.promotion.entity.dos.Seckill;
 import cn.lili.modules.promotion.entity.dos.SeckillApply;
 import cn.lili.modules.promotion.entity.dto.search.SeckillSearchParams;
 import cn.lili.modules.promotion.entity.vos.SeckillApplyVO;
@@ -97,4 +98,12 @@ public interface SeckillApplyService extends IService<SeckillApply> {
      */
     void updateSeckillApplyQuantity(String seckillId, String skuId, Integer quantity);
 
+    /**
+     * 更新秒杀活动时间
+     *
+     * @param seckill 秒杀活动
+     * @return 是否更新成功
+     */
+    boolean updateSeckillApplyTime(Seckill seckill);
+
 }
\ No newline at end of file
diff --git a/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillApplyServiceImpl.java b/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillApplyServiceImpl.java
index a421e9e6..66071234 100644
--- a/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillApplyServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillApplyServiceImpl.java
@@ -185,6 +185,7 @@ public class SeckillApplyServiceImpl extends ServiceImpl<SeckillApplyMapper, Sec
         if (!promotionGoodsList.isEmpty()) {
             PromotionGoodsSearchParams searchParams = new PromotionGoodsSearchParams();
             searchParams.setStoreId(storeId);
+            searchParams.setPromotionType(PromotionTypeEnum.SECKILL.name());
             searchParams.setSkuIds(promotionGoodsList.stream().map(PromotionGoods::getSkuId).collect(Collectors.toList()));
             promotionGoodsService.deletePromotionGoods(searchParams);
             //初始化促销商品
@@ -207,6 +208,7 @@ public class SeckillApplyServiceImpl extends ServiceImpl<SeckillApplyMapper, Sec
      * @param id        id
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void removeSeckillApply(String seckillId, String id) {
         Seckill seckill = this.seckillService.getById(seckillId);
         if (seckill == null) {
@@ -243,6 +245,41 @@ public class SeckillApplyServiceImpl extends ServiceImpl<SeckillApplyMapper, Sec
         this.update(updateWrapper);
     }
 
+    /**
+     * 更新秒杀活动时间
+     *
+     * @param seckill 秒杀活动
+     * @return 是否更新成功
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public boolean updateSeckillApplyTime(Seckill seckill) {
+        boolean result = false;
+        List<PromotionGoods> promotionGoodsList = new ArrayList<>();
+        LambdaQueryWrapper<SeckillApply> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(SeckillApply::getSeckillId, seckill.getId());
+        List<SeckillApply> list = this.list(queryWrapper);
+        for (SeckillApply seckillApply : list) {
+            //获取参与活动的商品信息
+            GoodsSku goodsSku = goodsSkuService.getGoodsSkuByIdFromCache(seckillApply.getSkuId());
+            //获取促销商品
+            PromotionGoods promotionGoods = this.setSeckillGoods(goodsSku, seckillApply, seckill);
+            promotionGoodsList.add(promotionGoods);
+        }
+        //保存促销活动商品信息
+        if (!promotionGoodsList.isEmpty()) {
+            PromotionGoodsSearchParams searchParams = new PromotionGoodsSearchParams();
+            searchParams.setPromotionType(PromotionTypeEnum.SECKILL.name());
+            searchParams.setSkuIds(promotionGoodsList.stream().map(PromotionGoods::getSkuId).collect(Collectors.toList()));
+            promotionGoodsService.deletePromotionGoods(searchParams);
+            //初始化促销商品
+            PromotionTools.promotionGoodsInit(promotionGoodsList, seckill, PromotionTypeEnum.SECKILL);
+            result = promotionGoodsService.saveBatch(promotionGoodsList);
+            this.seckillService.updateEsGoodsSeckill(seckill, list);
+        }
+        return result;
+    }
+
     /**
      * 检查秒杀活动申请列表参数信息
      *
diff --git a/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillServiceImpl.java b/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillServiceImpl.java
index 7d9619db..8b092527 100644
--- a/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/promotion/serviceimpl/SeckillServiceImpl.java
@@ -131,12 +131,31 @@ public class SeckillServiceImpl extends AbstractPromotionsServiceImpl<SeckillMap
         }
     }
 
+    /**
+     * 通用促销更新
+     * 调用顺序:
+     * 1. checkStatus 检查促销状态
+     * 2. checkPromotions 检查促销参数
+     * 3. saveOrUpdate 保存促销信息
+     * 4. updatePromotionGoods 更新促销商品信息
+     * 5. updateEsGoodsIndex 更新商品索引促销信息
+     *
+     * @param promotions 促销信息
+     * @return 是否更新成功
+     */
+    @Override
+    public boolean updatePromotions(Seckill promotions) {
+        seckillApplyService.updateSeckillApplyTime(promotions);
+        return super.updatePromotions(promotions);
+    }
+
     /**
      * 更新商品索引限时抢购信息
      *
      * @param seckill 限时抢购信息
      */
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public void updateEsGoodsSeckill(Seckill seckill, List<SeckillApply> seckillApplies) {
         if (seckillApplies != null && !seckillApplies.isEmpty()) {
             // 更新促销范围