toupiaoh5_hyperf/app/Controller/Api/v1/PlayerController.php

<?php

declare(strict_types=1);

namespace App\Controller\Api\v1;

use App\Controller\AbstractController;
use App\Utils\AppResult;
use App\Utils\Control\AuthUser;
use Hyperf\DbConnection\Db;

//
use App\Request\Api\v1\Player\RecordRequest;
use App\Master\Enum\RedisKeyEnum;
use App\Utils\RedisUtil;
use App\Service\QueueService;
use Hyperf\Di\Annotation\Inject;

/**
 * 选手接口
 * PlayerController
 */
class PlayerController extends AbstractController
{
    // 日志模块名称
    const LOG_MODULE = 'v1/PlayerController';

    #[Inject]
    protected QueueService $service;

    //给选手投票
    public function record(RecordRequest $request){

        if (!RedisUtil::getInstance(RedisKeyEnum::API_REQUEST_TRAFFIC)->tryTimes(1, 1)) {
            return AppResult::error('操作太快了,休息一下吧');
        }

        $params = $request->validated();// 获取校验通过的参数
        $user   = AuthUser::getInstance()->get();

        $player_id = $params['player_id'];
        if(!$player_id){
            return AppResult::error('投票失败');
        }

        //登录用户票数的检查
        $check_rs = $this->record_check($user['id']);
        if($check_rs['status'] === false){
            return AppResult::response_fast($check_rs['code'],$check_rs['msg']);//给不同的code，0报错，2跳到答题
        }

        //检查选手
        $player_info = Db::table('vote_player')->select(['id','subject_id','votes'])->where('id',$player_id)->first();
        if(!$player_info){
            return AppResult::error('不存在的选手');
        }

        //给选手加票
        $this->service->playerPush(['player_id' => $player_id, 'user_id' => $user['id']], 0);
        //日志

        //今日投票次数，自增一次
        RedisUtil::getInstance(RedisKeyEnum::VOTE_RECORD.date('Y-m-d').':'.$user['id'])->incr_expire(86400);

        //剩余票数，
        $a = $check_rs['uservote'] - 1;

        return AppResult::success('投票成功');
    }

    //投票检查
    private function record_check($user_id){
        $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 = site('gift_votes_user_eday');
        //今天,免费的答题次数
        $exam_times = 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();

        //投票次数  >= 免费票 + 答对次数
        if($today_record >= $gift_votes + $question_vote){
            $result['status'] = false;
            $result['code'] = 0;
            $result['msg'] = '投票失败,您今日剩余投票次数: 0次,明天再来吧';
            $result['uservote'] = 0;

            //今天，用户答题的次数
            $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'] = '投票失败,您今日剩余投票次数: 0次,可通过答题增加票数';
                $result['uservote'] = 0;
            }

            return $result;
        }

        //剩余票数
        $result['uservote'] = $gift_votes + $question_vote - $today_record;


        return $result;
    }


}