优惠券系统-第一章-系统设计

优惠券系统介绍

优惠券在很多系统会用到，本文结合项目实战谈谈优惠券系统怎么做。分为四个章节，第一个章节只介绍优惠券的设计，在第二章介绍优惠券的领取与补券，第三章设计一个类似京东的领券中心、活动中心，第四章聊聊优惠券使用。

优惠券整体流程图

优惠券整体流程使用流程如下图所示。注：下面这个图来自网络。

如上图所示，优惠券是先新建，然后由系统领导或者财务相关人员审核通过，再绑定活动发放出去。实际使用情况一般是运营小姐姐发邮件申请活动，审批通过后开发小哥哥直接配置线上活动，没有审批这个环节，这个环节比较简单，后面就不多介绍了。

优惠券设计

优惠券的设计原则就是尽量使单独的业务分割开来，首先就可以想到优惠券本身是一张表，我们叫做coupon_base,其次还需要一张用户表与优惠券的关联表，来记录用户与优惠券的关系叫做coupon_user，这里为了解耦业务，如果过多信息(比如用户)放在coupon_base上，后面表会无法控制的变大。

有了这两个表讨论一个问题，就是优惠券肯定是每个用户领完后有自己的券，所以量会很大。那么优惠券是先生成后给用户领取，还是用户领取的时候给用户生成呢？肯定是先生成后给用户领取，因为用户领取是一个高并发的操作，不宜做过多的业务逻辑进去，尽量简化用户领券的逻辑，简化成一个步骤最好，那就是从提前生成的"券池"中拿一个券SN号即可。

选择了将券生成后给用户领，每次配券只需要配一个券的模板，指定券的数量，然后开始生成，就需要一个模板表。这个表的名字可以是coupon_model或者coupon_act，这里我用的coupon_act。一共三张表，coupon_act记录了优惠券基本，coupon_base保存了生成后的券，coupon_user记录用户和券的关系。如下图所示：

第一张表coupon_act表，里面coupon_num是要生成的券数量，act_status是状态，coupon_money_min是优惠券使用的最低门栏，就是所谓的“满减金额”，订单满coupon_money_min即可减去coupon_value金额。这里注意类型coupon_type如果是“直接券”类型，即可不限制满减，直接抵扣订单金额，可以根据你的业务需求加类型，笔者只用到这两种。

CREATE TABLE `coupon_act` (`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',`act_sn` varchar(50) NOT NULL COMMENT '活动码',`coupon_name` varchar(255) DEFAULT NULL COMMENT '活动名称',`coupon_desc` varchar(255) DEFAULT NULL COMMENT '活动描述',`act_status` int(11) NOT NULL COMMENT '活动状态 1：未启用 2：已启用 3：已中止 4：已过期 5 生成中',`coupon_num` int(11) NOT NULL DEFAULT '0' COMMENT '优惠券数量',`limit_type` int(4) NOT NULL DEFAULT '0' COMMENT '1 固定时间范围过期，2 领券后固定时间过期',`limit_day` int(4) NOT NULL DEFAULT '0' COMMENT '优惠券限制使用天数:0不限制',`coupon_type` int(11) DEFAULT NULL COMMENT '优惠券类型 1：满减卷 2: 直减券',`coupon_money_min` int(11) DEFAULT NULL COMMENT '最少使用金额 0：不限制(单位：分,依赖coupon_type)',`coupon_money_max` int(11) DEFAULT NULL COMMENT '最大使用金额 0：不限制(单位：分,依赖coupon_type)',`coupon_value` int(11) NOT NULL DEFAULT '0' COMMENT '优惠券面值',`coupon_start_time` datetime DEFAULT NULL COMMENT '优惠券开始时间',`coupon_end_time` datetime DEFAULT NULL COMMENT '优惠券结束时间',`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',PRIMARY KEY (`id`) USING BTREE,UNIQUE KEY `IDXU_coupon_activity_act_sn` (`act_sn`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='优惠券主表';

下面是第二张表coupon_base，记录生成后的券，字段大部分继承自coupon_act(主表，也称之为模板表)。优惠券的coupon_sn号是生成时产生的分布式唯一ID，刚生成完coupon_status状态是1，被领取后是2，已使用与过期是4。coupon_base表还记录领取时间和使用时间。

CREATE TABLE `coupon_base` (`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',`act_sn` varchar(50) NOT NULL COMMENT '活动编号',`coupon_sn` varchar(50) NOT NULL COMMENT '优惠券号',`coupon_name` varchar(255) DEFAULT NULL COMMENT '优惠券名称',`coupon_desc` varchar(255) DEFAULT NULL COMMENT '优惠券描述',`coupon_status` int(11) DEFAULT '1' COMMENT '优惠券状态 1：未领取 2：已领取,未使用  3：已使用 4：已过期 5：已冻结 6：已作废',`coupon_type` int(11) DEFAULT NULL COMMENT '优惠券类型 1：满减卷 2: 直减券',`coupon_money_min` int(11) DEFAULT NULL COMMENT '最少使用金额 0：不限制(单位：分,依赖coupon_type)',`coupon_money_max` int(11) DEFAULT NULL COMMENT '最大使用金额 0：不限制(单位：分,依赖coupon_type)',`coupon_value` int(11) NOT NULL DEFAULT '0' COMMENT '优惠券面值',`coupon_start_time` datetime DEFAULT NULL COMMENT '优惠券开始时间',`coupon_end_time` datetime DEFAULT NULL COMMENT '优惠券结束时间',`draw_time` datetime DEFAULT NULL COMMENT '领取时间',`use_time` datetime DEFAULT NULL COMMENT '使用时间',`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',PRIMARY KEY (`id`) USING BTREE,UNIQUE KEY `unx_coupon_base_sn` (`coupon_sn`),KEY `idx_act_sn_coupon_status` (`act_sn`,`coupon_status`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='优惠券主表';

还有一张表是coupon_user，记录用户领取优惠券的信息，其中biz_source记录用户领券途径，可能是用户参与活动领取，biz_code记录某个活动id号，还一种情况可能是手动给某个用户补偿券，这个字段根据自身需求拓展。

CREATE TABLE `coupon_user` (`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',`coupon_sn` varchar(50) NOT NULL COMMENT '优惠券号',`biz_code` varchar(50) DEFAULT NULL COMMENT '活动来源码',`biz_source` int(11) DEFAULT '0' COMMENT '业务来源：1活动领取,2手动赠送',`user_id` varchar(50) DEFAULT NULL COMMENT '用户ID',`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',PRIMARY KEY (`id`) USING BTREE,KEY `idx_user_id` (`user_id`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户领卷表';

优惠券的生成与装载

优惠券先生成后领取必然有一个问题需要处理就是"领重"问题，防止多个用户同时取得同一个券。我们将生成的券放入redis中，以list存储。每次用户从缓存中取券，我们只将券的SN号放入list队列。并不是全部放入redis，可以一次放几千张，部分代码参见如下。

//生成优惠券代码
public DataTransferObject<Void> startCouponActivity(Integer id) {DataTransferObject<Void> dto = new DataTransferObject();//取得coupon_act中的券模板CouponActivityEntity entity = couponActivityServiceImpl.getCouponActivity(id);try {//防止重复点击keyString sendKey = PromotionCacheConstant.COUPON_PRODUCT_KEY + id;long result = redisOperations.setnx(sendKey,"1");if (result != 1) {return new DataTransferObject("优惠券生成中,请勿操作");}redisOperations.expire(sendKey,PromotionCacheConstant.COUPON_PRODUCT_TIME);//由于生成券耗时，这里用的异步生成taskExecutor.execute(() -> {LogUtil.info(LOGGER,"生成券任务开始执行了,couponActId:{}",entity.getId());List<CouponBaseEntity> allCouponBaseEntityList = Collections.emptyList();try {//修改coupon_act状态，生成中CouponActivityRequest updateEntity = new CouponActivityRequest();updateEntity.setId(entity.getId());updateEntity.setActStatus(CouponActStatusEnum.PRODUCING.getCode());couponActivityServiceImpl.updateCouponActivity(updateEntity);//生成券，这个方法里面就是批量插入allCouponBaseEntityList = couponActivityServiceImpl.startCouponActivity(entity);//生成完毕后，修改coupon_act状态updateEntity.setCouponNum(entity.getCouponNum());updateEntity.setActStatus(CouponActStatusEnum.PRODUCED.getCode());couponActivityServiceImpl.updateCouponActivity(updateEntity);} catch (Exception e) {LogUtil.error(LOGGER,"生成券优惠券活动异常,{}",e);} finally {//删除防止并发的keyredisOperations.del(sendKey);//加载优惠券缓存队列if(!Check.NuNCollection(allCouponBaseEntityList)){couponBaseService.fillCacheCouponSnQueueForCreate(entity.getActSn(), allCouponBaseEntityList);}}});} catch (Exception e) {dto.setErrorMsg("生成券优惠券活动异常");}return dto;}

上面就是生成优惠券的代码，在finally代码块中有“fillCacheCouponSnQueueForCreate”方法就是将生成券加入到缓存中，详细代码见下面。

//将生成的券，加入缓存
public void fillCacheCouponSnQueueForCreate(String actSn, List<CouponBaseEntity> appendList){try{//如果无可用券，放入缓存标志位，用余判断某个券是否用完，不查库，直接查缓存if(Check.NuNCollection(appendList)){redisOperations.set(PromotionCacheConstant.getCacheCouponOverKey(actSn),PromotionCacheConstant.COMMON_LABEL);LogUtil.warn(logger, "可用优惠券已使用完("+actSn+")");return;}//有券，删除keyredisOperations.del(PromotionCacheConstant.getCacheCouponOverKey(actSn));if(!Check.NuNCollection(appendList)){String couponBaseQueueKey = PromotionCacheConstant.getCacheCouponQueueKey(actSn);appendList.parallelStream().forEach(base->{//缓存注意，是两步操作，将每个券的详情放入缓存，再将券号放入list队列，后面当用户领取时，直接从缓存中查券的信息，然后也将缓存删除redisOperations.set(base.getCouponSn(), JsonEntityTransform.Object2Json(base));redisOperations.lpush(couponBaseQueueKey,base.getCouponSn());});}} catch (Exception e){LogUtil.error(logger,"填充优惠券码队列失败，error:{}",e);}}

上面的代码，说明了券的生成和向redis的队列中加载券。下一章介绍优惠券的领取与补券。