Java抽獎?chuàng)屬徦惴?/h1>
更新時間:2020年04月15日 15:28:48 作者:天藍1122
這篇文章主要為大家詳細介紹了Java抽獎?chuàng)屬徦惴?ava實現(xiàn)的抽獎?chuàng)屬徦惴?,用?shù)據(jù)庫行鎖實現(xiàn),支持集群,感興趣的小伙伴們可以參考一下
本文示例為大家分享了Java抽獎?chuàng)屬徦惴ǎ┐蠹覅⒖?,具體內(nèi)容如下
應(yīng)用場景
單件獎品搶購(可限時)
多件獎品按概率中獎(可限時、可不限量)
代碼實現(xiàn)
表結(jié)構(gòu):
--抽獎設(shè)置
create table AWARD_INFO
(
ID NUMBER(11) not null,
ACT_ID NUMBER(11), --活動ID
NUM NUMBER(11), --獎品總量(0為不限量)
REST NUMBER(11), --獎品余量
ODDS NUMBER(11) default 0, --中獎概率
START_DATE DATE, --開始日期(可為空)
END_DATE DATE, --結(jié)束日期(可為空)
PRODUCT_ID NUMBER(11), --獎品ID
STATE NUMBER(5) default 0, --狀態(tài) 0-有效 1-失效
INFO_TYPE NUMBER(5) default 0 --0-正常
);
alter table AWARD_INFO
add constraint PK_AWARD_INFO primary key (ID);
--中獎紀錄
create table AWARD_LOG
(
id number(11),
act_id number(11), --活動ID
get_time date, --中獎時間
product_id number(11), --獎品ID
num number(11) default 1, --中獎數(shù)量
person varchar2(50), --中獎人
info_id number(11), --抽獎設(shè)置ID
state number(5) --狀態(tài) 0-有效 1-失效
);
alter table AWARD_LOG
add constraint PK_AWARD_LOG primary key (ID);
代碼:
public static class AwardResult{
public int ret; //返回結(jié)果
public int logId; //AWARD_LOG id
}
/**
* 抽獎算法
* @param actId 抽獎活動ID
* @param person 抽獎人
* @param productId 獎品ID -1則為該活動ID下所有獎品
* @param excludeId 排除獎品ID -1 則不排除,與productId不能同時>0
* @param checkDate 是否檢查時間
* @return -1 沒有抽獎數(shù)據(jù);-2 獎品已抽完; -3 其他錯誤;>=0 中獎productId; -4 排除id
* @throws Exception
*/
public static AwardResult getAwardFull(int actId, String person, int productId, int[] excludeIds, boolean checkDate) throws SQLException{
AwardResult result = new AwardResult();
Connection conn = JDBC.getConnection();
conn.setAutoCommit(false);
try{
List<Map<String,Object>> rows;
String sql;
String checkDateStr = "";
String baseSql = "select t.id, t.product_id, t.num, t.rest, t.odds, t.info_type from award_info t where t.act_id=? and t.state=0 ";
if(checkDate){
checkDateStr = " and t.start_Date <= sysdate and t.end_Date >= sysdate ";
}
if(productId > 0){//搶購
sql = baseSql + " and t.product_id=? " + checkDateStr + " for update";
rows = JDBC.getRows(sql, new Object[]{actId, productId}, conn);
}else{//活動所有物品抽獎
sql = baseSql + checkDateStr + " for update";
rows = JDBC.getRows(sql, new Object[]{actId}, conn);
}
if(rows.isEmpty()){//沒有抽獎數(shù)據(jù)
log.info("沒有抽獎數(shù)據(jù) actId={} person={} productId={} excludeIds={} checkDate={}", actId, person, productId, excludeIds, checkDate);
conn.commit();
result.ret = -1;
return result;
}
int infoId = -1;
int getProductId = -1;
int num = -1;
int rest = -1;
if(rows.size() == 1){//搶購
num = ((Number)rows.get(0).get("NUM")).intValue();
rest = ((Number)rows.get(0).get("REST")).intValue();
infoId = ((Number)rows.get(0).get("ID")).intValue();
getProductId = ((Number)rows.get(0).get("PRODUCT_ID")).intValue();
}else{//抽獎
int[][] temp = new int[rows.size()][3];
int sum = -1;
int i = 0;
for(int k = 0; k < rows.size(); k++){//設(shè)置獎品池
int odds = ((BigDecimal)rows.get(k).get("ODDS")).intValue();
sum++;
temp[i][0] = sum; //起始值
sum = sum + odds;
temp[i][1] = sum; //結(jié)束值
temp[i][2] = k; //rows index
i++;
}
//抽獎
Random random = new Random();
int r = random.nextInt(sum + 1);
int j = 0;
for(int k = 0; k < i; k++){
if(r >= temp[k][0] && r <= temp[k][1]){
j = k;
break;
}
}
infoId = ((BigDecimal)rows.get(temp[j][2]).get("ID")).intValue();
getProductId = ((BigDecimal)rows.get(temp[j][2]).get("PRODUCT_ID")).intValue();
num = ((Number)rows.get(temp[j][2]).get("NUM")).intValue();
rest = ((Number)rows.get(temp[j][2]).get("REST")).intValue();
}
//判斷是否排除id
if(ArrayUtils.contains(excludeIds, getProductId)){
log.info("是排除ID actId={} person={} productId={} excludeIds={} checkDate={}", actId, person, productId, excludeIds, checkDate);
conn.commit();
result.ret = -4;
return result;
}
//存量不足
if(num > 0 && rest <= 0){
log.info("獎品已清空 actId={} person={} productId={} excludeIds={} checkDate={}", actId, person, productId, excludeIds, checkDate);
JDBC.commit(conn);
result.ret = -2;
return result;
}
//更新獎品記錄
if(num > 0){//非不限量
sql = "update award_info set rest = rest - 1 where id = ?";
JDBC.update(sql, new Object[]{infoId}, conn);
}
//記錄獲獎名單
AwardLog log = new AwardLog();
log.setActId(actId);
log.setNum(1);
log.setPerson(person);
log.setProductId(getProductId);
log.setInfoId(infoId);
Number logId = log.save(conn);
if(logId == null){
throw new SQLException("save award_log error");
}
result.logId = logId.intValue();
conn.commit();
result.ret = getProductId;
return result;
}catch(SQLException e){
log.error("getAward error", e);
conn.rollback();
}finally{
JDBC.close(conn);
}
result.ret = -3;
return result;
}
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
-
解決mybatis中resultType取出數(shù)據(jù)順序不一致的問題
這篇文章主要介紹了解決mybatis中resultType取出數(shù)據(jù)順序不一致的問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教 2022-02-02
-
javascript與jsp發(fā)送請求到servlet的幾種方式實例
本文分別給出了javascript發(fā)送請求到servlet的5種方式實例與
jsp發(fā)送請求到servlet的6種方式實例 2018-03-03
-
Java中List、Set、Map的區(qū)別和實現(xiàn)方式示例代碼
這篇文章主要介紹了Java中List、Set、Map的區(qū)別和實現(xiàn)方式示例代碼,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下 2023-06-06
最新評論
本文示例為大家分享了Java抽獎?chuàng)屬徦惴ǎ┐蠹覅⒖?,具體內(nèi)容如下
應(yīng)用場景
單件獎品搶購(可限時)
多件獎品按概率中獎(可限時、可不限量)
代碼實現(xiàn)
表結(jié)構(gòu):
--抽獎設(shè)置 create table AWARD_INFO ( ID NUMBER(11) not null, ACT_ID NUMBER(11), --活動ID NUM NUMBER(11), --獎品總量(0為不限量) REST NUMBER(11), --獎品余量 ODDS NUMBER(11) default 0, --中獎概率 START_DATE DATE, --開始日期(可為空) END_DATE DATE, --結(jié)束日期(可為空) PRODUCT_ID NUMBER(11), --獎品ID STATE NUMBER(5) default 0, --狀態(tài) 0-有效 1-失效 INFO_TYPE NUMBER(5) default 0 --0-正常 ); alter table AWARD_INFO add constraint PK_AWARD_INFO primary key (ID); --中獎紀錄 create table AWARD_LOG ( id number(11), act_id number(11), --活動ID get_time date, --中獎時間 product_id number(11), --獎品ID num number(11) default 1, --中獎數(shù)量 person varchar2(50), --中獎人 info_id number(11), --抽獎設(shè)置ID state number(5) --狀態(tài) 0-有效 1-失效 ); alter table AWARD_LOG add constraint PK_AWARD_LOG primary key (ID);
代碼:
public static class AwardResult{ public int ret; //返回結(jié)果 public int logId; //AWARD_LOG id } /** * 抽獎算法 * @param actId 抽獎活動ID * @param person 抽獎人 * @param productId 獎品ID -1則為該活動ID下所有獎品 * @param excludeId 排除獎品ID -1 則不排除,與productId不能同時>0 * @param checkDate 是否檢查時間 * @return -1 沒有抽獎數(shù)據(jù);-2 獎品已抽完; -3 其他錯誤;>=0 中獎productId; -4 排除id * @throws Exception */ public static AwardResult getAwardFull(int actId, String person, int productId, int[] excludeIds, boolean checkDate) throws SQLException{ AwardResult result = new AwardResult(); Connection conn = JDBC.getConnection(); conn.setAutoCommit(false); try{ List<Map<String,Object>> rows; String sql; String checkDateStr = ""; String baseSql = "select t.id, t.product_id, t.num, t.rest, t.odds, t.info_type from award_info t where t.act_id=? and t.state=0 "; if(checkDate){ checkDateStr = " and t.start_Date <= sysdate and t.end_Date >= sysdate "; } if(productId > 0){//搶購 sql = baseSql + " and t.product_id=? " + checkDateStr + " for update"; rows = JDBC.getRows(sql, new Object[]{actId, productId}, conn); }else{//活動所有物品抽獎 sql = baseSql + checkDateStr + " for update"; rows = JDBC.getRows(sql, new Object[]{actId}, conn); } if(rows.isEmpty()){//沒有抽獎數(shù)據(jù) log.info("沒有抽獎數(shù)據(jù) actId={} person={} productId={} excludeIds={} checkDate={}", actId, person, productId, excludeIds, checkDate); conn.commit(); result.ret = -1; return result; } int infoId = -1; int getProductId = -1; int num = -1; int rest = -1; if(rows.size() == 1){//搶購 num = ((Number)rows.get(0).get("NUM")).intValue(); rest = ((Number)rows.get(0).get("REST")).intValue(); infoId = ((Number)rows.get(0).get("ID")).intValue(); getProductId = ((Number)rows.get(0).get("PRODUCT_ID")).intValue(); }else{//抽獎 int[][] temp = new int[rows.size()][3]; int sum = -1; int i = 0; for(int k = 0; k < rows.size(); k++){//設(shè)置獎品池 int odds = ((BigDecimal)rows.get(k).get("ODDS")).intValue(); sum++; temp[i][0] = sum; //起始值 sum = sum + odds; temp[i][1] = sum; //結(jié)束值 temp[i][2] = k; //rows index i++; } //抽獎 Random random = new Random(); int r = random.nextInt(sum + 1); int j = 0; for(int k = 0; k < i; k++){ if(r >= temp[k][0] && r <= temp[k][1]){ j = k; break; } } infoId = ((BigDecimal)rows.get(temp[j][2]).get("ID")).intValue(); getProductId = ((BigDecimal)rows.get(temp[j][2]).get("PRODUCT_ID")).intValue(); num = ((Number)rows.get(temp[j][2]).get("NUM")).intValue(); rest = ((Number)rows.get(temp[j][2]).get("REST")).intValue(); } //判斷是否排除id if(ArrayUtils.contains(excludeIds, getProductId)){ log.info("是排除ID actId={} person={} productId={} excludeIds={} checkDate={}", actId, person, productId, excludeIds, checkDate); conn.commit(); result.ret = -4; return result; } //存量不足 if(num > 0 && rest <= 0){ log.info("獎品已清空 actId={} person={} productId={} excludeIds={} checkDate={}", actId, person, productId, excludeIds, checkDate); JDBC.commit(conn); result.ret = -2; return result; } //更新獎品記錄 if(num > 0){//非不限量 sql = "update award_info set rest = rest - 1 where id = ?"; JDBC.update(sql, new Object[]{infoId}, conn); } //記錄獲獎名單 AwardLog log = new AwardLog(); log.setActId(actId); log.setNum(1); log.setPerson(person); log.setProductId(getProductId); log.setInfoId(infoId); Number logId = log.save(conn); if(logId == null){ throw new SQLException("save award_log error"); } result.logId = logId.intValue(); conn.commit(); result.ret = getProductId; return result; }catch(SQLException e){ log.error("getAward error", e); conn.rollback(); }finally{ JDBC.close(conn); } result.ret = -3; return result; }
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
解決mybatis中resultType取出數(shù)據(jù)順序不一致的問題
這篇文章主要介紹了解決mybatis中resultType取出數(shù)據(jù)順序不一致的問題,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-02-02javascript與jsp發(fā)送請求到servlet的幾種方式實例
本文分別給出了javascript發(fā)送請求到servlet的5種方式實例與 jsp發(fā)送請求到servlet的6種方式實例2018-03-03Java中List、Set、Map的區(qū)別和實現(xiàn)方式示例代碼
這篇文章主要介紹了Java中List、Set、Map的區(qū)別和實現(xiàn)方式示例代碼,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2023-06-06