用 Java 写了一个抽奖功能，年会抽奖靠它了！
Posted Java技术栈
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了用 Java 写了一个抽奖功能，年会抽奖靠它了！相关的知识，希望对你有一定的参考价值。
点击关注公众号，Java干货及时送达
概述
项目开发中经常会有抽奖这样的营销活动的需求，例如：积分大转盘、刮刮乐、老虎机等等多种形式，其实后台的实现方法是一样的，本文介绍一种常用的抽奖实现方法。
整个抽奖过程包括以下几个方面：
奖品
奖品池
抽奖算法
奖品限制
奖品发放
奖品
奖品包括奖品、奖品概率和限制、奖品记录。
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='抽奖记录表';奖品池
奖品池是根据奖品的概率和限制组装成的抽奖用的池子。主要包括奖品的总池值和每个奖品所占的池值（分为开始值和结束值）两个维度。最新面试题整理好了，点击Java面试库小程序在线刷题。
public class PrizePool implements Serializable
/**
* 总池值
*/
private int total;
/**
* 池中的奖品
*/
private List<PrizePoolBean> poolBeanList;
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;
抽奖算法
整个抽奖算法为:
随机奖品池总池值以内的整数
循环比较奖品池中的所有奖品，随机数落到哪个奖品的池区间即为哪个奖品中奖。
推荐一个 Spring Boot 基础教程及实战示例：
https://github.com/javastacks/spring-boot-best-practice
抽奖代码：
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次、某某奖品每位用户只能抽中一次。。等等类似的限制，对于这样的限制我们分为两种情况来区别对待：
奖品发放
奖品发放可以采用工厂模式进行发放：不同的奖品类型走不同的奖品发放处理器，示例代码如下：
/**
* 异步分发奖品
* @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/wang258533488/article/details/78901303
版权声明：本文为CSDN博主「秦霜」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
Spring Boot 3.0 M1 发布，正式弃用 Java 8
关注Java技术栈看更多干货
获取 Spring Boot 实战笔记！
以上是关于用 Java 写了一个抽奖功能，年会抽奖靠它了！的主要内容，如果未能解决你的问题，请参考以下文章