抽奖活动业务逻辑的处理

2015-03-27

注意：以下方法只适合低并发的抽奖活动，因为我们直接去操作了数据库，如果是高并发的活动可以尝试Redis。本例奖品是微信卡券，没限数量。

数据表结构如下：

CREATE TABLE `shakecard_card` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `card_id` varchar(120) NOT NULL COMMENT '微信卡券ID',
  `appid` char(32) NOT NULL COMMENT '公众号的appid',
  `status` tinyint(3) unsigned NOT NULL DEFAULT '1' COMMENT '卡券是否用来摇奖，0代表否，1代表是',
  `prob` int(10) unsigned NOT NULL COMMENT '奖品概率（概率=当前数/总和)',
  `activity_id` varchar(100) DEFAULT '',
  `shakecard_id` varchar(100) NOT NULL,
  `title` varchar(100) DEFAULT NULL COMMENT '卡券标题',
  PRIMARY KEY (`id`),
  KEY `appid` (`appid`),
  KEY `status` (`status`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='卡券表，这里就是指奖品表';

CREATE TABLE `shakecard_rid_cookie` (
  `id` bigint(10) unsigned NOT NULL AUTO_INCREMENT,
  `rid` char(32) NOT NULL COMMENT '一个随机不重复的数',
  `mp_user_id` int(10) unsigned DEFAULT NULL COMMENT '公众号用户中间表id',
  `activity_id` varchar(100) NOT NULL DEFAULT '' COMMENT '活动id',
  `today_shake_count` int(10) unsigned NOT NULL COMMENT '今天的摇奖次数',
  `total_shake_count` int(10) unsigned NOT NULL COMMENT '总共的摇奖次数',
  PRIMARY KEY (`id`),
  KEY `mp_user_id` (`mp_user_id`),
  KEY `today_shake_count` (`today_shake_count`),
  KEY `rid` (`rid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='cookie和openid对应表';

CREATE TABLE `shakecard_record` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `mp_user_id` int(10) unsigned NOT NULL COMMENT '公众号用户中间表id',
  `status` tinyint(3) unsigned NOT NULL COMMENT '是否中奖,0代表未中,1代表中',
  `card_id` int(11) NOT NULL COMMENT '获得奖券的id',
  `action_time` datetime NOT NULL COMMENT '摇一摇的时间',
  PRIMARY KEY (`id`),
  KEY `action_time` (`action_time`),
  KEY `mp_user_id` (`mp_user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='记录表';

主要代码如下,在本例子中微信卡券就是一种奖品。。

<?php
/****************************抽奖的概率算法*****************************/
function get_rand($proArr) {
	$result = '';
	//概率数组的总概率精度
	$proSum = array_sum($proArr);
	//概率数组循环
	foreach ($proArr as $key => $proCur) {//$proCur的值为100,200,300,400
		$randNum = mt_rand(1, $proSum); //$randNum位1~1000的一个随机数
		if ($randNum <= intval($proCur)) {   //如果这个随机数小于等于100
			$result = $key;
			break;
		} else {
			$proSum -= intval($proCur);
		}
	}
	unset ($proArr);
	return $result;
}

//首先查看该用户摇的次数是否已满，如果满了直接返回前端已满的状态，这就不举例了

// 为了防止用户中奖的数量大于库存需要做些安全上的处理，我这里用的锁表，也可以用事务。。
// *********************
// 从下面开始 到执行 UNLOCK TABLES 之间操作的所有表都需要在下面一行加上 ", `表名` WRITE"
// *********************
$dsn = 'mysql:dbname=testdb;host=127.0.0.1';
$user = 'dbuser';
$password = 'dbpass';
$db = new PDO($dsn, $user, $password);
$db->exec("LOCK TABLES `shakecard_card` WRITE,`shakecard_record` WRITE,`shakecard_rid_cookie` WRITE");

//查询出奖品的数据
$card_data = array(array(),array());//得到一个二维数组

$arr = array();
$win_prob = 0;
foreach ($card_data as $key => $val) {
	$arr[$key] = intval($val['prob']);
	$win_prob += intval($val['prob']);
}
//增加一个未中奖
$arr[] = 100 - $win_prob;

$rid = get_rand($arr); //根据概率获取奖项id

if($rid === count($arr) - 1){//未中奖			
	$status = 0;
	$card_id = '';
	$json_data = array(
		'status' => $status,
		'card_id' => $card_id,
	);
}else{
	$result = $card_data[$rid]; //中奖项array
	$status = 1;
	$card_id= $result['card_id'];

	//返回数据
	$json_data = array(
		'status' => $status,
		'card_id' => $card_id,
	);
}

//存取数据到rid_cookie表,摇的数量增加
$sql = "UPDATE `shakecard_rid_cookie` SET `today_shake_count`=`today_shake_count`+1,`total_shake_count`=`total_shake_count`+1 WHERE `mp_user_id`='$mp_user_id'";
$res = $db->exec($sql);

/******************存取抽奖记录*********************/
$sql = "INSERT INTO `shakecard_record` (`mp_user_id`,`card_id`,`status`,`action_time`) VALUES('$mp_user_id','$card_id','$status','$datetime')";
$res = $db->exec($sql);

// [cc] 解锁表
$db->exec("UNLOCK TABLES");

//前端ajax请求，输出json结果
echo json_encode($json_data);