Java實(shí)現(xiàn)抽獎(jiǎng)功能
本文實(shí)例為大家分享了Java實(shí)現(xiàn)抽獎(jiǎng)功能的具體代碼,供大家參考,具體內(nèi)容如下
1 概述
項(xiàng)目開發(fā)中經(jīng)常會(huì)有抽獎(jiǎng)這樣的營銷活動(dòng)的需求,例如:積分大轉(zhuǎn)盤、刮刮樂、老虎機(jī)等等多種形式,其實(shí)后臺(tái)的實(shí)現(xiàn)方法是一樣的,本文介紹一種常用的抽獎(jiǎng)實(shí)現(xiàn)方法。
整個(gè)抽獎(jiǎng)過程包括以下幾個(gè)方面:
- 獎(jiǎng)品
- 獎(jiǎng)品池
- 抽獎(jiǎng)算法
- 獎(jiǎng)品限制
- 獎(jiǎng)品發(fā)放
2 獎(jiǎng)品
獎(jiǎng)品包括獎(jiǎng)品、獎(jiǎng)品概率和限制、獎(jiǎng)品記錄。
獎(jiǎng)品表:
CREATE TABLE `points_luck_draw_prize` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `name` varchar(50) DEFAULT NULL COMMENT '獎(jiǎng)品名稱', `url` varchar(50) DEFAULT NULL COMMENT '圖片地址', `value` varchar(20) DEFAULT NULL, `type` tinyint(4) DEFAULT NULL COMMENT '類型1:紅包2:積分3:體驗(yàn)金4:謝謝惠顧5:自定義', `status` tinyint(4) DEFAULT NULL COMMENT '狀態(tài)', `is_del` bit(1) DEFAULT NULL COMMENT '是否刪除', `position` int(5) DEFAULT NULL COMMENT '位置', `phase` int(10) DEFAULT NULL COMMENT '期數(shù)', `create_time` datetime DEFAULT NULL, `update_time` datetime DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=164 DEFAULT CHARSET=utf8mb4 COMMENT='獎(jiǎng)品表';
獎(jiǎng)品概率限制表:
CREATE TABLE `points_luck_draw_probability` ( `id` bigint(20) NOT NULL AUTO_INCREMENT, `points_prize_id` bigint(20) DEFAULT NULL COMMENT '獎(jiǎng)品ID', `points_prize_phase` int(10) DEFAULT NULL COMMENT '獎(jiǎng)品期數(shù)', `probability` float(4,2) DEFAULT NULL COMMENT '概率', `frozen` int(11) DEFAULT NULL COMMENT '商品抽中后的冷凍次數(shù)', `prize_day_max_times` int(11) DEFAULT NULL COMMENT '該商品平臺(tái)每天最多抽中的次數(shù)', `user_prize_month_max_times` int(11) DEFAULT NULL COMMENT '每位用戶每月最多抽中該商品的次數(shù)', `create_time` datetime DEFAULT NULL, `update_time` datetime DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=114 DEFAULT CHARSET=utf8mb4 COMMENT='抽獎(jiǎng)概率限制表';
獎(jiǎng)品記錄表:
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 '中獎(jiǎng)用戶手機(jī)號(hào)', `points` int(11) DEFAULT NULL COMMENT '消耗積分', `prize_id` bigint(20) DEFAULT NULL COMMENT '獎(jiǎng)品ID', `result` smallint(4) DEFAULT NULL COMMENT '1:中獎(jiǎng) 2:未中獎(jiǎng)', `month` varchar(10) DEFAULT NULL COMMENT '中獎(jiǎng)月份', `daily` date DEFAULT NULL COMMENT '中獎(jiǎng)日期(不包括時(shí)間)', `create_time` datetime DEFAULT NULL, `update_time` datetime DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=3078 DEFAULT CHARSET=utf8mb4 COMMENT='抽獎(jiǎng)記錄表';
3 獎(jiǎng)品池
獎(jiǎng)品池是根據(jù)獎(jiǎng)品的概率和限制組裝成的抽獎(jiǎng)用的池子。主要包括獎(jiǎng)品的總池值和每個(gè)獎(jiǎng)品所占的池值(分為開始值和結(jié)束值)兩個(gè)維度。
- 獎(jiǎng)品的總池值:所有獎(jiǎng)品池值的總和。
- 每個(gè)獎(jiǎng)品的池值:算法可以變通,常用的有以下兩種方式 :
1)、獎(jiǎng)品的概率*10000(保證是整數(shù))
2)、獎(jiǎng)品的概率10000獎(jiǎng)品的剩余數(shù)量
獎(jiǎng)品池bean:
public class PrizePool implements Serializable{
/**
* 總池值
*/
private int total;
/**
* 池中的獎(jiǎng)品
*/
private List<PrizePoolBean> poolBeanList;
}
池中的獎(jiǎng)品bean:
public class PrizePoolBean implements Serializable{
/**
* 數(shù)據(jù)庫中真實(shí)獎(jiǎng)品的ID
*/
private Long id;
/**
* 獎(jiǎng)品的開始池值
*/
private int begin;
/**
* 獎(jiǎng)品的結(jié)束池值
*/
private int end;
}
獎(jiǎng)品池的組裝代碼:
/**
* 獲取超級(jí)大富翁的獎(jiǎng)品池
* @param zillionaireProductMap 超級(jí)大富翁獎(jiǎng)品map
* @param flag true:有現(xiàn)金 false:無現(xiàn)金
* @return
*/
private PrizePool getZillionairePrizePool(Map<Long, ActivityProduct> zillionaireProductMap, boolean flag) {
//總的獎(jiǎng)品池值
int total = 0;
List<PrizePoolBean> poolBeanList = new ArrayList<>();
for(Entry<Long, ActivityProduct> entry : zillionaireProductMap.entrySet()){
ActivityProduct product = entry.getValue();
//無現(xiàn)金獎(jiǎng)品池,過濾掉類型為現(xiàn)金的獎(jiǎng)品
if(!flag && product.getCategoryId() == ActivityPrizeTypeEnums.XJ.getType()){
continue;
}
//組裝獎(jiǎng)品池獎(jiǎng)品
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;
}
4 抽獎(jiǎng)算法
整個(gè)抽獎(jiǎng)算法為:
1. 隨機(jī)獎(jiǎng)品池總池值以內(nèi)的整數(shù)
2. 循環(huán)比較獎(jiǎng)品池中的所有獎(jiǎng)品,隨機(jī)數(shù)落到哪個(gè)獎(jiǎng)品的池區(qū)間即為哪個(gè)獎(jiǎng)品中獎(jiǎng)。
抽獎(jiǎng)代碼:
public static PrizePoolBean getPrize(PrizePool prizePool){
//獲取總的獎(jiǎng)品池值
int total = prizePool.getTotal();
//獲取隨機(jī)數(shù)
Random rand=new Random();
int random=rand.nextInt(total);
//循環(huán)比較獎(jiǎng)品池區(qū)間
for(PrizePoolBean prizePoolBean : prizePool.getPoolBeanList()){
if(random >= prizePoolBean.getBengin() && random < prizePoolBean.getEnd()){
return prizePoolBean;
}
}
return null;
}
5 獎(jiǎng)品限制
實(shí)際抽獎(jiǎng)中對(duì)一些比較大的獎(jiǎng)品往往有數(shù)量限制,比如:某某獎(jiǎng)品一天最多被抽中5次、某某獎(jiǎng)品每位用戶只能抽中一次。。等等類似的限制,對(duì)于這樣的限制我們分為兩種情況來區(qū)別對(duì)待:
1. 限制的獎(jiǎng)品比較少,通常不多于3個(gè):這種情況我們可以再組裝獎(jiǎng)品池的時(shí)候就把不符合條件的獎(jiǎng)品過濾掉,這樣抽中的獎(jiǎng)品都是符合條件的。例如,在上面的超級(jí)大富翁抽獎(jiǎng)代碼中,我們規(guī)定現(xiàn)金獎(jiǎng)品一天只能被抽中5次,那么我們可以根據(jù)判斷條件分別組裝出有現(xiàn)金的獎(jiǎng)品和沒有現(xiàn)金的獎(jiǎng)品。
2. 限制的獎(jiǎng)品比較多,這樣如果要采用第一種方式,就會(huì)導(dǎo)致組裝獎(jiǎng)品非常繁瑣,性能低下,我們可以采用抽中獎(jiǎng)品后校驗(yàn)抽中的獎(jiǎng)品是否符合條件,如果不符合條件則返回一個(gè)固定的獎(jiǎng)品即可。
6 獎(jiǎng)品發(fā)放
獎(jiǎng)品發(fā)放可以采用工廠模式進(jìn)行發(fā)放:不同的獎(jiǎng)品類型走不同的獎(jiǎng)品發(fā)放處理器,示例代碼如下:
獎(jiǎng)品發(fā)放:
/**
* 異步分發(fā)獎(jiǎng)品
* @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){
//過濾掉謝謝惠顧的獎(jiǎng)品
if(prizeDto.getType() == PointsLuckDrawTypeEnum.XXHG.getType()){
continue;
}
//根據(jù)獎(jiǎng)品類型從工廠中獲取獎(jiǎng)品發(fā)放類
SendPrizeProcessor sendPrizeProcessor = sendPrizeProcessorFactory.getSendPrizeProcessor(
PointsLuckDrawTypeEnum.getPointsLuckDrawTypeEnumByType(prizeDto.getType()));
if(ObjectUtil.isNotNull(sendPrizeProcessor)){
//發(fā)放獎(jiǎng)品
sendPrizeProcessor.send(memberId, prizeDto);
}
}
return new AsyncResult<>(Boolean.TRUE);
}catch (Exception e){
//獎(jiǎng)品發(fā)放失敗則記錄日志
saveSendPrizeErrorLog(memberId, prizeList);
LOGGER.error("積分抽獎(jiǎng)發(fā)放獎(jiǎng)品出現(xiàn)異常", 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 + "】的發(fā)送獎(jiǎng)品處理器");
}
return processor;
}
}
獎(jiǎng)品發(fā)放類舉例:
/**
* 紅包獎(jiǎng)品發(fā)放類
*/
@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 {
// 發(fā)放紅包
Coupon coupon = couponService.receiveCoupon(memberId, Long.parseLong(prizeDto.getValue()));
//發(fā)送站內(nèi)信
messageLogService.insertActivityMessageLog(memberId,
"你參與積分抽大獎(jiǎng)活動(dòng)抽中的" + coupon.getAmount() + "元理財(cái)紅包已到賬,謝謝參與",
"積分抽大獎(jiǎng)中獎(jiǎng)通知");
//輸出log日志
LOGGER.info(memberId + "在積分抽獎(jiǎng)中抽中的" + prizeDto.getPrizeName() + "已經(jīng)發(fā)放!");
}
}
以上就是本文的全部內(nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
淺析Java如何優(yōu)雅的設(shè)計(jì)接口狀態(tài)碼和異常
HTTP協(xié)議里定義了一系列的狀態(tài)碼用來表明請(qǐng)求的狀態(tài),如常用的200表示請(qǐng)求正常,404表示請(qǐng)求的資源不存在,所以本文就來和大家討論一下如何優(yōu)雅的設(shè)計(jì)接口狀態(tài)碼和異常,感興趣的可以了解下2024-03-03
Java IO流之原理分類與節(jié)點(diǎn)流文件操作詳解
流(Stream)是指一連串的數(shù)據(jù)(字符或字節(jié)),是以先進(jìn)先出的方式發(fā)送信息的通道,數(shù)據(jù)源發(fā)送的數(shù)據(jù)經(jīng)過這個(gè)通道到達(dá)目的地,按流向區(qū)分為輸入流和輸出流2021-10-10
淺談java多線程 join方法以及優(yōu)先級(jí)方法
下面小編就為大家?guī)硪黄獪\談java多線程 join方法以及優(yōu)先級(jí)方法。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-01-01
基于Transactional事務(wù)的使用以及注意說明
這篇文章主要介紹了Transactional事務(wù)的使用以及注意說明,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-07-07
Java中的LinkedHashMap及LRU緩存機(jī)制詳解
這篇文章主要介紹了Java中的LinkedHashMap及LRU緩存機(jī)制詳解,LinkedHashMap繼承自HashMap,它的多種操作都是建立在HashMap操作的基礎(chǔ)上的,同HashMap不同的是,LinkedHashMap維護(hù)了一個(gè)Entry的雙向鏈表,保證了插入的Entry中的順序,需要的朋友可以參考下2023-09-09
SpringBoot排除不需要的自動(dòng)配置類DataSourceAutoConfiguration問題
這篇文章主要介紹了SpringBoot排除不需要的自動(dòng)配置類DataSourceAutoConfiguration問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-07-07
SpringMVC中利用@InitBinder來對(duì)頁面數(shù)據(jù)進(jìn)行解析綁定的方法
本篇文章主要介紹了SpringMVC中利用@InitBinder來對(duì)頁面數(shù)據(jù)進(jìn)行解析綁定的方法,非常具有實(shí)用價(jià)值,需要的朋友可以參考下2018-03-03

