toupiaoh5/application/api/controller/Player.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Db;
use app\utils\RedisKeyEnum;
use app\utils\RedisUtil;
/**
 * 选手
 */
class Player extends Api
{
    protected $noNeedLogin = ['playerlist'];
    protected $noNeedRight = ['*'];

    //待绑定选手列表
    public function playerlist(){
        $subject_id = 1;

        $map = [
            'subject_id' => $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(){
//        $this->error('接口作废');
        if(!$this->apiLimit('操作太快了,休息一下吧'));

        $player_id = input('player_id','');
        $vote      = input('vote',1);
        if(!$player_id){
            $this->error();
        }

        //登录用户票数的检查
        $check_rs = $this->record_check($this->auth->id,$vote);
        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')->where(['id'=>$player_id])->lock(true)->find();
        if(!$player_info){
            Db::rollback();
            $this->error('不存在的选手');
        }

        //给选手加票
        $update_data = [
            'votes' => $player_info['votes'] + $vote,
        ];
        $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' => $player_info['subject_id'],
            'player_id' => $player_id,
            'vote' => $vote,
            '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($user_id,$vote){
        $result = array(
            'status'=>true,
            'code'=>1,
            'msg'=>'',
            'uservote' => 0,
        );


        //今天,投了几票

        $today_record = RedisUtil::getInstance(RedisKeyEnum::VOTE_RECORD.date('Y-m-d').':'.$user_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'] = '投票失败,您今日剩余0票,明天再来吧';
            $result['uservote'] = 0;
            return $result;
        }

        //今天，用户答对的次数，也就是答题获得的票数

        $question_vote  = RedisUtil::getInstance(RedisKeyEnum::EAXM_RIGHT.date('Y-m-d').':'.$user_id)->get();

        //免费票 + 答对次数 - 已投票次数 < vote
        $times = $gift_votes + $question_vote - $today_record;
        if($times < 0){$times = 0;}
        if($times < $vote){
            $result['status'] = false;
            $result['code'] = 0;
            $result['msg'] = '投票失败,您今日剩余: '.$times.'票';
            $result['uservote'] = $times;

            //今天，用户答题的次数

            $today_question = RedisUtil::getInstance(RedisKeyEnum::EAXM_TIMES.date('Y-m-d').':'.$user_id)->get();

            //还有答题机会
            if($exam_times > $today_question){
                $result['status'] = false;
                $result['code'] = 2;
                $result['msg'] = '投票失败,您今日剩余: '.$times.'票,可通过答题增加票数';
                $result['uservote'] = $times;
            }

            return $result;
        }

        //剩余票数
        $result['uservote'] = $times;


        return $result;
    }




}