关于java:用-Java-写一个抽奖功能太秀了～

12次阅读

共计 6195 个字符，预计需要花费 16 分钟才能阅读完成。

我的项目开发中常常会有抽奖这样的营销流动的需要，例如：积分大转盘、刮刮乐、老虎机等等多种形式，其实后盾的实现办法是一样的，本文介绍一种罕用的抽奖实现办法。

整个抽奖过程包含以下几个方面：

奖品
奖品池
抽奖算法
奖品限度
奖品发放

奖品包含奖品、奖品概率和限度、奖品记录。

奖品表：

CREATE TABLE `points_luck_draw_prize` (`id` bigint(20) NOT NULL AUTO_INCREMENT,
  `name` varchar(50) DEFAULT NULL COMMENT '奖品名称',
  `url` varchar(50) DEFAULT NULL COMMENT '图片地址',
  `value` varchar(20) DEFAULT NULL,
  `type` tinyint(4) DEFAULT NULL COMMENT '类型 1: 红包 2: 积分 3: 体验金 4: 谢谢惠顾 5: 自定义',
  `status` tinyint(4) DEFAULT NULL COMMENT '状态',
  `is_del` bit(1) DEFAULT NULL COMMENT '是否删除',
  `position` int(5) DEFAULT NULL COMMENT '地位',
  `phase` int(10) DEFAULT NULL COMMENT '期数',
  `create_time` datetime DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=164 DEFAULT CHARSET=utf8mb4 COMMENT='奖品表';

奖品概率限度表：

CREATE TABLE `points_luck_draw_probability` (`id` bigint(20) NOT NULL AUTO_INCREMENT,
  `points_prize_id` bigint(20) DEFAULT NULL COMMENT '奖品 ID',
  `points_prize_phase` int(10) DEFAULT NULL COMMENT '奖品期数',
  `probability` float(4,2) DEFAULT NULL COMMENT '概率',
  `frozen` int(11) DEFAULT NULL COMMENT '商品抽中后的冷冻次数',
  `prize_day_max_times` int(11) DEFAULT NULL COMMENT '该商品平台每天最多抽中的次数',
  `user_prize_month_max_times` int(11) DEFAULT NULL COMMENT '每位用户每月最多抽中该商品的次数',
  `create_time` datetime DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=114 DEFAULT CHARSET=utf8mb4 COMMENT='抽奖概率限度表';

奖品记录表：

CREATE TABLE `points_luck_draw_record` (`id` bigint(20) NOT NULL AUTO_INCREMENT,
  `member_id` bigint(20) DEFAULT NULL COMMENT '用户 ID',
  `member_mobile` varchar(11) DEFAULT NULL COMMENT '中奖用户手机号',
  `points` int(11) DEFAULT NULL COMMENT '耗费积分',
  `prize_id` bigint(20) DEFAULT NULL COMMENT '奖品 ID',
  `result` smallint(4) DEFAULT NULL COMMENT '1: 中奖 2: 未中奖',
  `month` varchar(10) DEFAULT NULL COMMENT '中奖月份',
  `daily` date DEFAULT NULL COMMENT '中奖日期（不包含工夫）',
  `create_time` datetime DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3078 DEFAULT CHARSET=utf8mb4 COMMENT='抽奖记录表';

奖品池是依据奖品的概率和限度组装成的抽奖用的池子。次要包含奖品的总池值和每个奖品所占的池值（分为开始值和完结值）两个维度。

奖品的总池值：所有奖品池值的总和。
每个奖品的池值：算法能够变通，罕用的有以下两种形式：
- 奖品的概率 *10000（保障是整数）
- 奖品的概率 10000 奖品的残余数量

奖品池 bean：

public class PrizePool implements Serializable{
    /**
     * 总池值
     */
    private int total;
    /**
     * 池中的奖品
     */
    private List<PrizePoolBean> poolBeanList;
}

池中的奖品 bean:

public class PrizePoolBean implements Serializable{
    /**
     * 数据库中实在奖品的 ID
     */
    private Long id;
    /**
     * 奖品的开始池值
     */
    private int begin;
    /**
     * 奖品的完结池值
     */
    private int end;
}

奖品池的组装代码：

/**
     * 获取超级大富翁的奖品池
     * @param zillionaireProductMap 超级大富翁奖品 map
     * @param flag true: 有现金  false: 无现金
     * @return
     */
    private PrizePool getZillionairePrizePool(Map<Long, ActivityProduct> zillionaireProductMap, boolean flag) {
        // 总的奖品池值
        int total = 0;
        List<PrizePoolBean> poolBeanList = new ArrayList<>();
        for(Entry<Long, ActivityProduct> entry : zillionaireProductMap.entrySet()){ActivityProduct product = entry.getValue();
            // 无现金奖品池，过滤掉类型为现金的奖品
            if(!flag && product.getCategoryId() == ActivityPrizeTypeEnums.XJ.getType()){continue;}
            // 组装奖品池奖品
            PrizePoolBean prizePoolBean = new PrizePoolBean();
            prizePoolBean.setId(product.getProductDescriptionId());
            prizePoolBean.setBengin(total);
            total = total + product.getEarnings().multiply(new BigDecimal("10000")).intValue();
            prizePoolBean.setEnd(total);
            poolBeanList.add(prizePoolBean);
        }

        PrizePool prizePool = new PrizePool();
        prizePool.setTotal(total);
        prizePool.setPoolBeanList(poolBeanList);
        return prizePool;
    }

整个抽奖算法为:

随机奖品池总池值以内的整数
循环比拟奖品池中的所有奖品，随机数落到哪个奖品的池区间即为哪个奖品中奖。

抽奖代码：

public static PrizePoolBean getPrize(PrizePool prizePool){
        // 获取总的奖品池值
        int total = prizePool.getTotal();
        // 获取随机数
        Random rand=new Random();
        int random=rand.nextInt(total);
        // 循环比拟奖品池区间
        for(PrizePoolBean prizePoolBean : prizePool.getPoolBeanList()){if(random >= prizePoolBean.getBengin() && random < prizePoolBean.getEnd()){return prizePoolBean;}
        }
        return null;
    }

理论抽奖中对一些比拟大的奖品往往有数量限度，比方：某某奖品一天最多被抽中 5 次、某某奖品每位用户只能抽中一次。。等等相似的限度，对于这样的限度咱们分为两种状况来区别对待：

限度的奖品比拟少，通常不多于 3 个：这种状况咱们能够再组装奖品池的时候就把不符合条件的奖品过滤掉，这样抽中的奖品都是符合条件的。例如，在下面的超级大富翁抽奖代码中，咱们规定现金奖品一天只能被抽中 5 次，那么咱们能够依据判断条件别离组装出有现金的奖品和没有现金的奖品。
限度的奖品比拟多，这样如果要采纳第一种形式，就会导致组装奖品十分繁琐，性能低下，咱们能够采纳抽中奖品后校验抽中的奖品是否符合条件，如果不符合条件则返回一个固定的奖品即可。

奖品发放能够采纳工厂模式进行发放：不同的奖品类型走不同的奖品发放处理器，示例代码如下：

奖品发放：

/**
     * 异步散发奖品
     * @param prizeList
     * @throws Exception
     */
    @Async("myAsync")
    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
    public Future<Boolean> sendPrize(Long memberId, List<PrizeDto> prizeList){
        try {for(PrizeDto prizeDto : prizeList){
                // 过滤掉谢谢惠顾的奖品
                if(prizeDto.getType() == PointsLuckDrawTypeEnum.XXHG.getType()){continue;}
                // 依据奖品类型从工厂中获取奖品发放类
                SendPrizeProcessor sendPrizeProcessor = sendPrizeProcessorFactory.getSendPrizeProcessor(PointsLuckDrawTypeEnum.getPointsLuckDrawTypeEnumByType(prizeDto.getType()));
                if(ObjectUtil.isNotNull(sendPrizeProcessor)){
                    // 发放奖品
                    sendPrizeProcessor.send(memberId, prizeDto);
                }
            }
            return new AsyncResult<>(Boolean.TRUE);
        }catch (Exception e){
            // 奖品发放失败则记录日志
            saveSendPrizeErrorLog(memberId, prizeList);
            LOGGER.error("积分抽奖发放奖品出现异常", e);
            return new AsyncResult<>(Boolean.FALSE);
        }
    }

工厂类：

@Component
public class SendPrizeProcessorFactory implements ApplicationContextAware{
    private ApplicationContext applicationContext;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext = applicationContext;}

    public SendPrizeProcessor getSendPrizeProcessor(PointsLuckDrawTypeEnum typeEnum){String processorName = typeEnum.getSendPrizeProcessorName();
        if(StrUtil.isBlank(processorName)){return null;}
        SendPrizeProcessor processor = applicationContext.getBean(processorName, SendPrizeProcessor.class);
        if(ObjectUtil.isNull(processor)){throw new RuntimeException("没有找到名称为【" + processorName + "】的发送奖品处理器");
        }
        return processor;
    }
}

奖品发放类举例：

/**
 * 红包奖品发放类
 */
@Component("sendHbPrizeProcessor")
public class SendHbPrizeProcessor implements SendPrizeProcessor{private Logger LOGGER = LoggerFactory.getLogger(SendHbPrizeProcessor.class);
    @Resource
    private CouponService couponService;
    @Resource
    private MessageLogService messageLogService;

    @Override
    public void send(Long memberId, PrizeDto prizeDto) throws Exception {
        // 发放红包
        Coupon coupon = couponService.receiveCoupon(memberId, Long.parseLong(prizeDto.getValue()));
        // 发送站内信
        messageLogService.insertActivityMessageLog(memberId,
            "你参加积分抽大奖流动抽中的" + coupon.getAmount() + "元理财红包已到账，谢谢参加",
            "积分抽大奖中奖告诉");
        // 输入 log 日志
        LOGGER.info(memberId + "在积分抽奖中抽中的" + prizeDto.getPrizeName() + "曾经发放！");
    }
}

原文链接：https://blog.csdn.net/wang258…

版权申明：本文为 CSDN 博主「秦霜」的原创文章，遵循 CC 4.0 BY-SA 版权协定，转载请附上原文出处链接及本申明。

近期热文举荐：

1.1,000+ 道 Java 面试题及答案整顿 (2022 最新版)

2. 劲爆！Java 协程要来了。。。

3.Spring Boot 2.x 教程，太全了！

4. 别再写满屏的爆爆爆炸类了，试试装璜器模式，这才是优雅的形式！！

5.《Java 开发手册（嵩山版）》最新公布，速速下载！

感觉不错，别忘了顺手点赞 + 转发哦！

正文完

java

发表至： java

2022-03-09

0

关于java:spring-data-jpa-分页下标改成1不生效问题排查

Cassandra-JAVA客户端是如何做到高性能高并发的

关于java:Java基础15数据结构和泛型

关于java:APPLICATION-FAILED-TO-START

关于java:重新认识访问者模式从实践到本质

关于java:用-Java-写一个抽奖功能太秀了～

概述

奖品

奖品包含奖品、奖品概率和限度、奖品记录。

奖品池

抽奖算法

奖品限度

奖品发放

站内搜索