最近和其他部门合作项目，当然我是负责php接口方面的工作，
get到一些东西，所以来分享记录一下。
项目需求：
题目将通过主持人ipad投射至大屏幕，选手按‘抢答’
按钮进行抢答。抢答成功，选手所在组，以及大屏幕上广播抢答成功者的ipad屏幕，
抢答失败选手，返回抢答失败界面。
需求分析：
这里抢答，其实就是和秒杀活动机制一样了，不过这里场景可能稍微复杂点，
需要用到强弱连接，实时广播，大家可以去看看GatewayWordker当然，今天我们只是单纯
讨论抢答机制是如何实现。那么既然抢答，就要考虑高并发问题了。
思路分析：
1.把题目的状态写在redis里面，比如题目还没有被抢状态为1，抢完状态为0
2.选手进行抢答时，查询redis状态，为0，直接返回，题目已经被抢完；
3.选手进行抢答时，查询redis状态，为1，进入下一步逻辑操作，修改redis状态为0，
进入数据库查询改题目数据，运用行级琐机制。返回逻辑处理结果
框架依然用的是laravel，开发模式用的是仓库模式，这用有利于项目后期的维护和升级。
（数据字段涉及安全，暂时用test1等表示便好）
/******首先进行题目获取，并把题目对应的redis编号改为1******/
/**
* @desc 随机获得抢答题题目
* @date 2017/4/19 17:26
* @param [type]
* @author 十月桂花香十里
* @return [bool or array]
*/
public function getQuickQuestion(){
//获取抢答题随机题号id
$randNum = $this->getRandArray(config('test.start_quick_id'),config('test.end_quick_id'),config('djm.max_quick'));
DB::transaction(function () use ($randNum){
//将抢答题题号id写进redis,值为1题目可以进行抢答，0不可以进行抢答(为了便于后期维护，0和1都可以写进配置文件中)
$redis = PRedis::connection('default');
foreach($randNum as $k=>$v){
$redis->set("check_quick_id_".$v,1);
}
//将数据库中抢答题对应的id记录，test3状态改为可进行抢答
//DjmQuestion::whereIn('id', $randNum)->update(['test3'=>1]);
});
$res = DjmQuestion::whereIn('id', $randNum)
->orderByRaw(DB::raw("FIELD(id, ".implode(',', $randNum).")"))
->get(['id','test1','test2','test3','test4']);
if($res){
foreach($res as $k=>$v){
$res[$k]['test6'] = json_decode($v['test6'],true);
}
//处理需要返回的数组
return $res;
}else return false;
}
/******利用php的array_slice函数实现编号的随机选择******/
/*
* function getTenNum( int $min, int $max, int $num)
* 生成一定数量的随机数
* $min 和 $max: 指定随机数的范围
* $num: 指定生成数量
*/
public function getRandArray($min,$max,$num){
$array = range($min,$max);
shuffle($array);
$array = array_slice($array, -$num);
return $array;
}
/******选手抢答题目逻辑的实现******/
/**
* @desc 选手进行题目的抢答
* @date 2017/4/19 18:19
* @param [$id $uid]
* @author 十月桂花香十里
* @return [bool or array]
*/
public function userQuickAnswer($id='',$uid){
//判断uid是否是答题选手
if(!in_array($uid, config('test1.check_uid'))) return false;
//判断$id是否存在
if($id < config('test1.start_quick_id') || $id > config('test1.end_quick_id')) return false;
//redis判断题目是否可以进行抢答
$redis = PRedis::connection('default');
$check_quick_status = $redis->get("check_quick_id_".$id);
if($check_quick_status ==1){
//运用事务，添加共享锁
//DB::transaction(function () use ($redis,$id){
//将redis的状态和数据库field3改为0,变为不可抢答
//DjmQuestion::where('id',$id)->sharedLock()->update(['test1'=>0]);
//});
//将redis的状态改为0,变为不可抢答
$redis->set("check_quick_id_".$id,0);
//redis绑定此题和选手的关系
$redis->set("check_quick_id_".$id."_".$uid,1);
//获取本条数据记录
return DjmQuestion::find($id)->toArray();
}else return false;
}
/******选手抢答题目回答的实现******/
/**
* @desc 选手进行抢答题的回答
* @date 2017/4/20 10:09
* @param [$id,$uid]
* @author 1245049149@qq.com
* @return [bool or array]
*/
public function userQuickAnswerResult($id,$uid,$answer){
//判断uid是否是答题选手
if(!in_array($uid, config('djm.check_uid'))) return false;
//判断$id是否存在
if($id < config('djm.start_quick_id') || $id > config('djm.end_quick_id')) return false;
//redis判断此题和选手是否绑定关系
$redis = PRedis::connection('default');
$check_user_quick_status = $redis->get("check_quick_id_".$id."_".$uid);
if($check_user_quick_status == 1){
//关系如果已经绑定，判断选手答题情况
$redis->set("check_quick_id_".$id."_".$uid,0);
$check_answer = config('djm.check_answer'); //题目编号答案对照(如果题目数量不多且固定的话，建议写进配置文件中，不用查询数据库)
if($check_answer[$id] == strtoupper($answer)){
//回答正确分数自加5
DjmQuestionScore::where('test10',$uid)
->where('test11',config('djm.quick_test11'))
->increment('test12',5);
return array(
'msg' => '回答正确',
'status' => 1,
);
}else{
//回答错误分数自减5
DjmQuestionScore::where('test10',$uid)
->where('test11',config('djm.quick_test11'))
->decrement('score',5);
return array(
'msg' => '回答错误，正确答案：'.$check_answer[$id],
'test12' => $check_answer[$id],
'status' => 0,
);
}
}else return false;
}
ok，功能至此实现了。