datiGame/app/Jobs/Settlement.php

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use App\Model\Option;
use App\Model\User;
use App\Model\Room;
use App\Model\RoomUser;
use App\Model\RoomAnswer;
use App\Model\RoomQuestion;
use App\Jobs\Distribute;
use GuzzleHttp\Client;
use GuzzleHttp\Cookie\CookieJar;
use Illuminate\Support\Facades\Redis;
use GatewayWorker\Lib\Gateway;
use Illuminate\Support\Facades\Log;

class Settlement implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $room_id;     //房间ID

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($room_id)
    {
        $this->room_id = $room_id;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        //获取当前房间回答情况
        $question_id = RoomQuestion::where("room_id", $this->room_id)->whereNull("end_at")->value("question_id");
        if(!$question_id){
            echo "找不到题目";
            return 0;
        }
        //获取当前房间获取问题数
        $room_question_count = RoomQuestion::where("room_id", $this->room_id)->count();
        //注册gateway地址
        Gateway::$registerAddress = env("WS_REGEDIT_ADDR");
        //结算当前局
        $update_data["end_at"] = date("Y-m-d H:i:s");
        RoomQuestion::where([
            "room_id" => $this->room_id,
            "question_id" => $question_id,
        ])->update($update_data);

        //返回各个用户回答的问题
        $group_users = Gateway::getUidListByGroup($this->room_id);
        $anwsers = RoomAnswer::select('user_id', 'option_id', 'question_id')->where([
            "question_id" => $question_id,
            "room_id" => $this->room_id,
        ])->whereIn("user_id", array_values($group_users))->get();
        $option_id = Option::where([
            "question_id" => $question_id,
            "is_answer" => 1,
        ])->value("option_id");
        $info['anwser'] = $option_id;
        $info['players_answer'] = $anwsers;
        //发送回合结算信息
        $message['info'] = $info;
        $message['type'] = 'round_end';
        Gateway::sendToGroup($this->room_id, json_encode($message));

        if($room_question_count > 4){
            //当前房间结束
            $update_data["is_end"] = 1;
            $update_data["end_at"] = date("Y-m-d H:i:s");
            Room::where("room_id", $this->room_id)->update($update_data);
            //获取胜利者
            $players = RoomUser::select("user_id","score")->where([
                "room_id" => $this->room_id,
            ])->get();
            $winer = '';
            $winer_score = 0;
            $pkresult = [];
            foreach ($players as $k => $player) {
                if($player->score > $winer_score){
                    $winer = $player->user_id;
                    $winer_score = $player->score;
                }
                $user = User::select("user_id", "cmcc_id", "mt", "is_robot")->where("user_id", $player->user_id)->first();
                if($user->is_robot != 1){
                    $mt = $user->mt;
                    $cmcc_id = $user->cmcc_id;
                }
                $pkresult[] = [
                    "robot_flag" => $user->is_robot,
                    "user_id" => $user->cmcc_id,
                    "score" => $player->score,
                ];
            }
            //通知平台
            $user_power = [];
            if($mt && !env("YANSHI")){
                //上传用户游戏信息
                $client = new Client([
                    'verify' => false,
                ]);
                $platform_upload_score_url = env("PLATFORM_UPLOAD_SCORE_URL");
                $req_time = date('YmdHis');
                $sign = md5($cmcc_id . $req_time . $mt);
                $params['req_param'] = [
                    "pub_info" => [
                        "req_src" => "1",
                        "ver" => "1.0",
                        "mt" => $mt,
                        "user_id" => $cmcc_id,
                        "req_time" => $req_time,
                        "sign" => $sign,
                    ],
                    "page_info" => [
                        // "current_page" => 1,
                        // "page_size" => 10,
                    ],
                    "busi_info" => [
                        "pk_result" => $pkresult
                    ],
                ];

                Log::info("通知平台放请求信息: \n ". json_encode($params) ."\n");

                $result = $client->request('POST', $platform_upload_score_url, [
                    'json' => $params
                ]);

                if($result->getStatusCode() == 200){
                    $cmcc_result = json_decode($result->getBody()->getContents());
                    if($cmcc_result->rsp_param->pub_info->code == "0000"){
                        $user_power = $cmcc_result->rsp_param->busi_info->user_power;
                    }
                }
                
                Log::info("平台返回信息: \n ". json_encode($cmcc_result) ."\n");
            }

            //给用户发送信息
            foreach ($players as $k => $player) {
                $is_win = 0;
                $user = User::where("user_id", $player->user_id)->first();
                if($winer == $player->user_id){
                    //更新胜利局数
                    User::where("user_id", $player->user_id)->increment('win_count', 1);
                    $is_win = 1;
                }else{
                    User::where("user_id", $player->user_id)->increment('lose_count', 1);
                }
                
                //更新用户在房间的信息
                unset($update_data);
                $update_data['state'] = 2;
                $update_data['is_win'] = $is_win;
                $update_data['updated_at'] = date("Y-m-d H:i:s");
                RoomUser::where([
                    "user_id" => $player->user_id,
                    "room_id" => $this->room_id,
                ])->update($update_data);

                //用户信息
                $info['user_id'] = $user->user_id;
                $info['name'] = $user->name;
                $info['avatar'] = $user->avatar;
                $info['is_win'] = $is_win;
                $info['play_next'] = 0;
                $info['power_change'] = 0;
                if(!env("YANSHI")){
                    foreach ($user_power as $k => $up) {
                        if(isset($up->user_id) && $up->user_id == $user->cmcc_id){
                            $info['play_next'] = $up->play_next;
                            $info['power_change'] = $up->power_change;
                        }
                    }
                }

                //获取用户星力变化等信息返回
                $message['info'] = $info;
                $message['winer'] = $winer;
                $message['winer_score'] = $winer_score;
                $message['type'] = 'game_end';
                Gateway::sendToUid($user->user_id, json_encode($message));
            }
        }else{
            sleep(3);
            //执行发题
            Distribute::dispatch($this->room_id)->onQueue('distribute');
        }
    }
}