$subject_id, 'status' => 1, ]; //搜索 $keyword = input('keyword',''); if($keyword){ $map['title|suozaidanwei|tuijiangonghui'] = ['LIKE','%'.$keyword.'%']; } $lists = Db::name('vote_player')->field('id,title') ->where($map)->order('votes desc,id desc')->autopage()->select(); $this->success(1,$lists); } //用户绑定选手 public function bind_player(){ $player_id = input('player_id',0); $data = [ 'bind_player_id' => $player_id, 'bind_player_date' => strtotime(date('Y-m-d')), ]; Db::name('user')->where('id',$this->auth->id)->update($data); $this->success('绑定成功'); } //给选手投票 public function record(){ if(!$this->apiLimit('操作太快了,休息一下吧')); $player_id = input('player_id',''); if(!$player_id){ $this->error(); } //登录用户票数的检查 $check_rs = $this->record_check($this->auth->id); if($check_rs['status'] === false){ $this->error($check_rs['msg'],null,$check_rs['code']);//给不同的code,0报错,2跳到答题 } Db::startTrans(); //检查选手 $player_info = Db::name('vote_player')->field('id,subject_id,votes,score')->where(['id'=>$player_id,'status'=>1])->lock(true)->find(); if(!$player_info){ Db::rollback(); $this->error('不存在的选手'); } $subject_id = $player_info['subject_id']; $update_data = [ 'votes' => $player_info['votes'] + 1, ]; //入库 $update_rs = Db::name('vote_player')->where('id',$player_id)->update($update_data); if($update_rs === false){ Db::rollback(); $this->error('投票失败'); } //日志 $data = [ 'user_id' => $this->auth->id, 'subject_id' => $subject_id, 'player_id' => $player_id, 'createdate' => strtotime(date('Y-m-d')), 'createtime' => time(), ]; $log_id = Db::name('vote_record')->insertGetId($data); if(!$log_id){ Db::rollback(); $this->error('投票失败'); } Db::commit(); //今日投票次数,自增一次 RedisUtil::getInstance(RedisKeyEnum::VOTE_RECORD.date('Y-m-d').':'.$this->auth->id)->incr_expire(86400); $this->success('投票成功'); } //投票检查 private function record_check($uid){ $result = array( 'status'=>true, 'code'=>1, 'msg'=>'', ); //今天,投了几票 // $today_record = Db::name('vote_record')->where('createdate',strtotime(date('Y-m-d')))->where('user_id',$uid)->count(); $today_record = RedisUtil::getInstance(RedisKeyEnum::VOTE_RECORD.date('Y-m-d').':'.$this->auth->id)->get(); //今天,免费的的票 $gift_votes = config('site.gift_votes_user_eday'); //今天,免费的答题次数 $exam_times = config('site.exam_times_user_eday'); //投票次数 >= 所有的来源 if($today_record >= $gift_votes + $exam_times){ $result['status'] = false; $result['code'] = 0; $result['msg'] = '今天的票已经用光了,明天再来吧'; return $result; } //今天,用户答对的次数,也就是答题获得的票数 // $question_vote = Db::name('user_question_log')->where('createdate',strtotime(date('Y-m-d')))->where('user_id',$uid)->where('is_right',1)->count(); $question_vote = RedisUtil::getInstance(RedisKeyEnum::EAXM_RIGHT.date('Y-m-d').':'.$this->auth->id)->get(); //投票次数 >= 免费票 + 答对次数 if($today_record >= $gift_votes + $question_vote){ $result['status'] = false; $result['code'] = 0; $result['msg'] = '今天的票已经用光了,明天再来吧'; //今天,用户答题的次数 // $today_question = Db::name('user_question_log')->where('createdate',strtotime(date('Y-m-d')))->where('user_id',$uid)->count(); $today_question = RedisUtil::getInstance(RedisKeyEnum::EAXM_TIMES.date('Y-m-d').':'.$this->auth->id)->get(); //还有答题机会 if($exam_times > $today_question){ $result['code'] = 2; $result['msg'] = '票已经用光了,去答题获得票?'; } return $result; } return $result; } }