单品立减

一、功能说明

1、单品立减促销活动属于商家店铺可直接发布的促销活动。

2、同一个商家在同一时间段内只允许创建一个单品立减促销活动。

3、商家在发布单品立减活动时，可以选择店铺全部商品参与，也可以选择部分商品参与。

选择全部商品参与时，商家新创建了一个商品，那么这个商品也会自动参与到这个活动中。

4、单品立减活动开始后，不允许修改和删除活动信息。

5、对于参与单品立减促销活动的商品，用户购买商品享受的优惠可以叠加，如下：

例：参与活动的商品A单价为100元，活动规则是满100元立减2元。

购买数量(件)	应支付金额(元)	实支付金额(元)	优惠金额(元)
1	100	98	2
2	200	196	4
3	300	294	6
4	400	392	8

二、数据库设计

1、表结构设计

单品立减促销活动表—es_minus

字段名	类型与长度	说明
minus_id	bigint(20)	主键ID
single_reduction_value	decimal(20,2)	单品立减金额
start_time	bigint(20)	活动开始时间(存放的是以秒为单位的时间戳)
start_time_str	varchar(50)	活动开始时间(格式为2020-10-29 08:00:00)，此字段属预留字段暂时无用
end_time	bigint(20)	活动结束时间(存放的是以秒为单位的时间戳)
end_time_str	varchar(50)	活动结束时间(格式为2020-10-29 08:00:00))，此字段属预留字段暂时无用
title	varchar(50)	活动标题(名称)
range_type	int(1)	商品参与活动的方式，1：全部商品，2：部分商品
disabled	int(1)	活动是否停用(删除)，0：否，1：是
description	longtext	活动说明(描述/简介)
seller_id	bigint(20)	活动所属商家ID(关联商家店铺表--es_shop)

2、表关联说明

单品立减促销活动表(es_minus)	促销活动商品表(es_promotion_goods)
minus_id	activity_id
无字段，促销类型值为MINUS	promotion_type

三、缓存设计

1、商家在发布单品立减促销活动时，在将促销活动信息入库的同时，也会将信息放入缓存中。

缓存key值为：{STOREID_MINUS_KEY}活动ID。

缓存value值为：MinusDO.java这个实体对象信息。

2、单品立减促销活动脚本引擎

• 脚本引擎缓存结构：

  单品立减促销活动的促销脚本引擎缓存结构有两种：

  • 当发布活动时，如果选择的是全部商品参与，那么存放的是店铺级别的缓存结构。
  • 当发布活动时，如果选择的是部分商品参与，那么存放的是SKU级别的缓存结构。

• 脚本引擎生成和删除时机：

  • 生成：活动开始时生成。
  • 删除：活动结束时删除。

关于促销脚本引擎缓存结构可参考《促销活动脚本引擎生成架构》这篇文档。

四、代码设计

1、接口调用流程图

2、相关代码展示

以新增单品立减活动为例

• API代码--MinusSellerController

  @RestController
  @RequestMapping("/seller/promotion/minus")
  @Api(description = "单品立减相关API")
  @Validated
  public class MinusSellerController {
    
    @ApiOperation(value   = "添加单品立减", response = MinusVO.class)
      @ApiImplicitParam(name = "minus", value = "单品立减信息", required = true, dataType = "MinusVO", paramType = "body")
      @PostMapping
      public MinusVO add(@ApiIgnore @Valid @RequestBody MinusVO minus) {
          PromotionValid.paramValid(minus.getStartTime(),minus.getEndTime(),
                                minus.getRangeType(),minus.getGoodsList());
          // 获取当前登录的店铺ID
          Seller seller = UserContext.getSeller();
          Long sellerId = seller.getSellerId();
          minus.setSellerId(sellerId);
          this.minusManager.add(minus);
          return minus;
      }
  }

• 新增单品立减活动业务层代码--MinusManagerImpl

  @Service
  public class MinusManagerImpl extends AbstractPromotionRuleManagerImpl implements MinusManager {
    
      @Override
      @Transactional(propagation = Propagation.REQUIRED,
                     rollbackFor = {RuntimeException.class,
                                    Exception.class, ServiceException.class})
      public  MinusVO  add(MinusVO minusVO)   {
          //检测开始时间和结束时间
          PromotionValid.paramValid(minusVO.getStartTime(),minusVO.getEndTime(),1,null);
          this.verifyTime(minusVO.getStartTime(),minusVO.getEndTime(),
                          PromotionTypeEnum.MINUS,null);
  
          //初步形成商品的DTO列表
          List<PromotionGoodsDTO> goodsDTOList = new ArrayList<>();
          //是否是全部商品参与
          if(minusVO.getRangeType() == 1){
              PromotionGoodsDTO goodsDTO = new PromotionGoodsDTO();
              goodsDTO.setGoodsId(-1L);
              goodsDTO.setSkuId(-1L);
              goodsDTO.setGoodsName("全部商品");
              goodsDTO.setThumbnail("path");
              goodsDTOList.add(goodsDTO);
              minusVO.setGoodsList(goodsDTOList);
          }
          //检测活动规则
          this.verifyRule(minusVO.getGoodsList());
  
          MinusDO minusDO = new MinusDO();
          BeanUtils.copyProperties(minusVO,minusDO);
          minusMapper.insert(minusDO);
  
          // 获取活动Id
          Long minusId = minusDO.getMinusId();
          minusDO.setMinusId(minusId);
          minusVO.setMinusId(minusId);
  
          PromotionDetailDTO detailDTO = new PromotionDetailDTO();
          detailDTO.setStartTime(minusVO.getStartTime());
          detailDTO.setEndTime(minusVO.getEndTime());
          detailDTO.setActivityId(minusVO.getMinusId());
          detailDTO.setPromotionType(PromotionTypeEnum.MINUS.name());
          detailDTO.setTitle(minusVO.getTitle());
  
          //将活动商品入库
          this.promotionGoodsManager.add(minusVO.getGoodsList(),detailDTO);
  
          String minusKey = PromotionCacheKeys.getMinusKey(minusId);
          cache.put(minusKey, minusDO);
  
          //启用延时任务创建促销活动脚本信息
          PromotionScriptMsg promotionScriptMsg = new PromotionScriptMsg();
          promotionScriptMsg.setPromotionId(minusId);
          promotionScriptMsg.setPromotionName(minusDO.getTitle());
          promotionScriptMsg.setPromotionType(PromotionTypeEnum.MINUS);
          promotionScriptMsg.setOperationType(ScriptOperationTypeEnum.CREATE);
          promotionScriptMsg.setEndTime(minusDO.getEndTime());
          String uniqueKey = "{TIME_TRIGGER_" + PromotionTypeEnum.MINUS.name() 
            + "}_" + minusId;
          timeTrigger.add(TimeExecute.SELLER_PROMOTION_SCRIPT_EXECUTER, 
                          promotionScriptMsg, minusDO.getStartTime(), uniqueKey);
  
          return minusVO;
      }
  }

• 单品立减促销活动脚本生成--PromotionScriptTimeTriggerExecuter

  @Component("promotionScriptTimeTriggerExecuter")
  public class PromotionScriptTimeTriggerExecuter implements TimeTriggerExecuter {
      @Override
      public void execute(Object object) {
  
          PromotionScriptMsg promotionScriptMsg = (PromotionScriptMsg) object;
  
          //如果是促销活动开始
          if (ScriptOperationTypeEnum.CREATE
              .equals(promotionScriptMsg.getOperationType())) {
  
              //创建促销活动脚本
              this.createScript(promotionScriptMsg);
  
              //促销活动开始后，立马设置一个促销活动结束的流程
              promotionScriptMsg.setOperationType(ScriptOperationTypeEnum.DELETE);
              String uniqueKey = "{TIME_TRIGGER_" 
                + promotionScriptMsg.getPromotionType().name() + "}_" 
                + promotionScriptMsg.getPromotionId();
  
              timeTrigger.add(TimeExecute.SELLER_PROMOTION_SCRIPT_EXECUTER,
                              promotionScriptMsg, promotionScriptMsg.getEndTime(),
                              uniqueKey);
  
              this.logger.debug("促销活动[" + promotionScriptMsg.getPromotionName() 
                                + "]开始，id=[" + promotionScriptMsg.getPromotionId() 
                                + "]");
          } else {
  
              //删除缓存中的促销脚本数据
              this.deleteScript(promotionScriptMsg);
  
              this.logger.debug("促销活动[" + promotionScriptMsg.getPromotionName() 
                                + "]结束，id=[" + promotionScriptMsg.getPromotionId() 
                                + "]");
          }
      }
  
      /**
       * 创建促销活动脚本
       * @param promotionScriptMsg 促销活动脚本消息信息
       */
      private void createScript(PromotionScriptMsg promotionScriptMsg) {
          //获取促销活动类型
          PromotionTypeEnum promotionType = promotionScriptMsg.getPromotionType();
  
          //获取促销活动ID
          Long promotionId = promotionScriptMsg.getPromotionId();
  
          //获取促销脚本相关数据
          ScriptVO scriptVO = this.getPromotionScript(promotionId, promotionType.name());
  
          //获取商家ID
          Long sellerId = scriptVO.getSellerId();
          //购物车(店铺)级别缓存key
          String cartCacheKey = CachePrefix.CART_PROMOTION.getPrefix() + sellerId;
          //获取商品参与促销活动的方式 1：全部商品参与，2：部分商品参与
          Integer rangeType = scriptVO.getRangeType();
          //构建促销脚本数据结构
          PromotionScriptVO promotionScriptVO = scriptVO.getPromotionScriptVO();
  
          //如果是全部商品都参与了促销活动
          if (rangeType.intValue() == 1) {
  
              //构建新的促销脚本数据
              List<PromotionScriptVO> scriptList = getScriptList(cartCacheKey,
                                                                 promotionScriptVO);
  
              //将促销脚本数据放入缓存中
              cache.put(cartCacheKey, scriptList);
  
          } else {
              //获取参与促销活动的商品集合
              List<PromotionGoodsDO> goodsList =  scriptVO.getGoodsList();
  
              //批量放入缓存的数据集合
              Map<String, List<PromotionScriptVO>> cacheMap = new HashMap<>();
  
              //循环skuID集合，将脚本放入缓存中
              for (PromotionGoodsDO goods : goodsList) {
  
                  PromotionScriptVO newScript = new PromotionScriptVO();
                  BeanUtil.copyProperties(promotionScriptVO, newScript);
  
                  //缓存key
                  String cacheKey = CachePrefix.SKU_PROMOTION.getPrefix() 
                    + goods.getSkuId();
  
                  //脚本结构中加入商品skuID
                  newScript.setSkuId(goods.getSkuId());
  
                  //构建新的促销脚本数据
                  List<PromotionScriptVO> scriptList = getScriptList(cacheKey, newScript);
  
                  cacheMap.put(cacheKey, scriptList);
              }
  
              //将sku促销脚本数据批量放入缓存中
              cache.multiSet(cacheMap);
  
          }
      }
  
      /**
       * 删除促销活动脚本
       * @param promotionScriptMsg 促销活动脚本消息信息
       */
      private void deleteScript(PromotionScriptMsg promotionScriptMsg) {
          //获取促销活动类型
          PromotionTypeEnum promotionType = promotionScriptMsg.getPromotionType();
  
          //获取促销活动ID
          Long promotionId = promotionScriptMsg.getPromotionId();
  
          if (PromotionTypeEnum.FULL_DISCOUNT.equals(promotionType)) {
              //满减满赠促销活动
              //...省略...
  
          } else if (PromotionTypeEnum.MINUS.equals(promotionType)) {
              //获取单品立减促销活动信息
              MinusVO minusVO = this.promotionGoodsClient.getMinusFromDB(promotionId);
              //初始化缓存中的促销活动脚本信息
              initScriptCache(minusVO.getRangeType(), minusVO.getSellerId(), 
                              promotionId, promotionType.name());
  
          } else if (PromotionTypeEnum.HALF_PRICE.equals(promotionType)) {
              //第二件半价促销活动
              //...省略...
          }
      }
    
      /**
       * 根据促销活动ID和促销活动类型获取促销脚本数据
       * @param promotionId 促销活动id
       * @param promotionType 促销活动类型
       * @return
       */
      private ScriptVO getPromotionScript(Long promotionId, String promotionType) {
  
          ScriptVO scriptVO = new ScriptVO();
  
          if (PromotionTypeEnum.FULL_DISCOUNT.name().equals(promotionType)) {
              //满减满赠促销活动
              //...省略...
  
          } else if (PromotionTypeEnum.MINUS.name().equals(promotionType)) {
  
              //获取单品立减促销活动信息
              MinusVO minusVO = this.promotionGoodsClient.getMinusFromDB(promotionId);
  
              //渲染并读取单品立减促销活动脚本信息
              String script = renderMinusScript(minusVO);
  
              String tips = "单品立减";
  
              //构建促销脚本数据结构
              PromotionScriptVO promotionScriptVO 
                = getScript(script, promotionId, false, promotionType, tips);
  
              scriptVO.setSellerId(minusVO.getSellerId());
              scriptVO.setRangeType(minusVO.getRangeType());
              scriptVO.setPromotionScriptVO(promotionScriptVO);
  
          } else if (PromotionTypeEnum.HALF_PRICE.name().equals(promotionType)) {
              //第二件半价促销活动
              //...省略...
  
          }
  
          //如果是部分商品参与活动，需要查询出参与促销活动的商品skuID集合
          if (scriptVO.getRangeType().intValue() == 2) {
              List<PromotionGoodsDO> goodsList 
                = this.promotionGoodsClient.getPromotionGoods(promotionId, promotionType);
              scriptVO.setGoodsList(goodsList);
          }
  
          return scriptVO;
      }
    
      /**
       * 渲染并读取单品立减促销活动脚本信息
       * @param minusVO 单品立减促销活动信息
       * @return
       */
      private String renderMinusScript(MinusVO minusVO) {
          Map<String, Object> model = new HashMap<>();
  
          Map<String, Object> params = new HashMap<>();
          params.put("startTime", minusVO.getStartTime().toString());
          params.put("endTime", minusVO.getEndTime().toString());
          params.put("singleReductionValue", minusVO.getSingleReductionValue());
  
          model.put("promotionActive", params);
  
          String path = "minus.ftl";
          String script = ScriptUtil.renderScript(path, model);
  
          logger.debug("生成单品立减促销活动脚本：" + script);
  
          return script;
      }
  }

• 单品立减促销活动脚本引擎模板文件--minus.ftl

  <#--
   验证促销活动是否在有效期内
   @param promotionActive 活动信息对象(内置常量)
          .startTime 获取开始时间
          .endTime 活动结束时间
   @param $currentTime 当前时间(变量)
   @returns {boolean}
   -->
  function validTime(){
      if (${promotionActive.startTime} <= $currentTime && $currentTime <= ${promotionActive.endTime}) {
          return true;
      }
      return false;
  }
  
  <#--
   单品立减活动金额计算
   @param promotionActive 单品立减活动信息对象(内置常量)
          .singleReductionValue 立减金额
   @param $sku 商品SKU信息对象(变量)
          .$price 商品SKU单价
          .$num 商品数量
   @returns {*}
   -->
  function countPrice() {
      var resultPrice = ($sku.$price - ${promotionActive.singleReductionValue}) * $sku.$num;
      return resultPrice < 0 ? 0 : resultPrice.toString();
  }