bot-28/app/Console/Commands/SportOdds.php

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use App\Models\Sport as SportModel;
use App\Models\SportOdds as SportOddsModel;
use App\Services\SportClientService;
use Illuminate\Support\Facades\Log;
use App\Models\Config;
use Illuminate\Support\Facades\Cache;

class SportOdds extends Command
{
    /**
     * 命令名称和签名
     *
     * @var string
     */
    protected $signature = 'sport:odds {is_live=0}';

    protected $is_live = 0;
    
    protected $long_status = [
        'Time To Be Defined' => 0,
        'Not Started' => 0,
        'First Half' => 1,
        'First Half, Kick Off' => 1,
        'Halftime' => 1,
        'Second Half' => 1,
        'Second Half, 2nd Half Started' => 1,
        'Extra Time' => 1,
        'Break Time' => 1,
        'Penalty In Progress' => 1,
        'Match Suspended' => 1,
        'Match Interrupted' => 1,
        'Match Finished' => 2,
        'Match Finished' => 2,
        'Match Finished' => 2,
        'Match Postponed' => 3,
        'Match Cancelled' => 4,
        'Match Abandoned' => 4,
        'Technical Loss' => 4,
        'WalkOver' => 4,
        'In Progress' => 1,
    ];        
    
    protected $fixture_status = [
        'First Half' => 1,
        'First Half, Kick Off' => 1,
        'Halftime' => 1,
        'Second Half' => 1,
        'Second Half, 2nd Half Started' => 1,
        'Extra Time' => 1,
        'Break Time' => 1,
        'Penalty In Progress' => 1,
    ];        

    /**
     * 命令描述
     *
     * @var string
     */
    protected $description = '赔率（直播赔率5秒更新一次，塞前赔率3小时更新一次）';
    /**
     * 执行命令
     *
     * @return int
     */
    public function handle()
    {
        $this->is_live = $this->argument('is_live');
        if ($this->is_live == 1) {
            // $this->info('直播赔率开始执行任务...');
            $this->sportOddsData($this->is_live);
        } else {
            // $this->info('开赛前赔率开始执行任务...');
            $this->sportOddsData($this->is_live);
        }
        
        // $this->info('结束执行赔率任务');
    }

    public function sportOddsData($is_live)
    {
        try {
            $limit = 3000;
            //直播赔率（获取正在直播的所有赛事的赔率）
            if ($is_live == 1) {
                $data = SportClientService::oddsLive([]);
                file_put_contents("oddsLive.json",json_encode($data));
                $this->updateOddsLive($data);
            } else {
                //普通球赛是开赛前购买，更新数据
                $where['state'] = 0;  //比赛状态：0未开始1进行中2已完场3延期4取消
                $list = SportModel::where($where)->where('odds',null)->limit($limit)->get()->toArray();
                foreach($list as $item) {
                    $data = SportClientService::odds([
                        'fixture' => $item['data_id'],
                    ]);
                    $this->updateOdds($item['data_id'],$data);
                }
            }
        } catch (\Exception $e) {
            Log::error($e->getMessage());
        }
        return true;
    }

    public function updateOddsLive($data)
    {
        //体育赛事结束前几(分钟)锁盘,90分钟结束
        $sport_locked = Config::where('field', 'sport_locked')->first()->val ?? 1;
        if(!empty($data['response'])) {
            $data = $data['response'];
            foreach($data as $item) {
                $data_id = $item['fixture']['id'];
                $odds = $this->doOdds($item['odds']);
                $odds = !empty($odds) ? json_encode($odds) : null;
                
                $update_data = [
                    'is_send' => 0,
                    'is_roll' => 1,
                    'is_locked' => 0,
                    'odds' => $odds,
                    'error' => 0, //异常类型：0正常；1直播赔率的赛事时异常
                ];
                $odd_fixture_status = null;//直播赔率中的赛事时间和状态（与直播赛事信息中的赛事时间和状态存在较大差异）
                if (isset($item['fixture']['status']['long']) ) {
                    $long = $item['fixture']['status']['long'];
                    if (isset($this->fixture_status[$long])) {
                        
                        $sport_info = SportModel::where('data_id',$data_id)->first();
                        $fixture_status = $sport_info['fixture_status'] ? json_decode($sport_info['fixture_status'],true) : [];
                        
                        $odd_fixture_status = $item['fixture']['status'];
                        $update_data['odd_fixture_status'] = json_encode($odd_fixture_status);
                        
                        //如果时间差距超过3分钟，则锁盘
                        if (isset($fixture_status['elapsed']) && isset($odd_fixture_status['elapsed'])) {
                            if ( $fixture_status['elapsed'] - $odd_fixture_status['elapsed'] >= 3) {
                                $odds = $sport_info['odds'] ? json_decode($sport_info['odds'],true) : null;
                                $odds_ids = [];
                                foreach($odds as $odd) {
                                    $odds_ids[] = $odd['id'];
                                }
                                $update_data['error'] = 1;
                                $update_data['is_locked'] = 1;
                                unset($update_data['odds']);//不更新赔率
                            } else {
                                $update_data['error'] = 0;
                            }
                        }
                    } 
                    
                    // if (isset($this->long_status[$long])) {
                    //     $update_data['state'] = $this->long_status[$long];
                    // }
                }
                // if (isset($item['teams']['home']['goals'])) {
                //     $update_data['score'] = $item['teams']['home']['goals'] ."-". $item['teams']['away']['goals'];
                // }
                
                //锁盘
                if (isset($item['fixture']['status']['blocked']) && $item['fixture']['status']['blocked']) {
                    $update_data['is_locked'] = 1;
                }
                //提前锁盘(比赛进行时长，分钟)
                if (isset($item['fixture']['status']['elapsed'])) {
                    $elapsed = $item['fixture']['status']['elapsed'];
                    if ((int)$elapsed >= 90 - $sport_locked ) {
                       $update_data['is_locked'] = 1;
                    }
                }
                //已结束
                if (isset($item['fixture']['status']['finished']) && $item['fixture']['status']['finished']) {
                    $update_data['state'] = 2;
                }
                //如果赛事取消、延期等，标记需要退款
                if (isset($update_data['state']) && $update_data['state'] > 2) {
                    $update_data['refund_status'] = 1;
                }

                SportModel::where('data_id',$data_id)->update($update_data);
                // echo $data_id.": 更新成功\r\n";
            }
        } 
    }

    public function updateOdds($data_id,$data)
    {
        // echo $data_id;
        if (!empty($data['response'][0]['bookmakers'][0]['bets'])) {
            $odds = $data['response'][0]['bookmakers'][0]['bets'];
            // echo "更新成功\r\n";
            SportModel::where('data_id',$data_id)->update(['odds' => json_encode($odds), 'is_send' => 0]);
        } else {
            // echo "更新失败\r\n";
        }
    }

    //去掉无效的赔率
    private function doOdds($odds) {
        // 1. 获取赔率，缓存数据
        $sport_odds = cache('sport_odds');
        if (!$sport_odds) {
            $sport_odds = SportOddsModel::where('function_name', '<>', null)->select()->toArray();
            Cache::set('sport_odds', $sport_odds, 300); //有效期5分钟
        }

        $sport_odds = array_column($sport_odds, null,'odd_name_en');
        $new_odds = [];
        foreach($odds as $item) {
            if (!isset($sport_odds[$item['name']])) {
                continue;
            }
            $new_odds[] = $item;
        }
        return $new_odds;
    }

}