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

<?php

namespace App\Console\Commands;

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

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 = 100;
            //直播赔率（获取正在直播的所有赛事的赔率）
            if ($is_live == 1) {
                $data = SportClientService::oddsLive([]);
                
                // file_put_contents("oddsLive.json",json_encode($data));
                $this->updateOddsLive($data);
            } else {
                //按照日期获取赔率
                // $data = SportClientService::odds([
                //     'date' => date('Y-m-d'),
                // ]);


                //普通球赛是开赛前购买，更新数据
                $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)
    {
        if(!empty($data['response'])) {
            $data = $data['response'];
            foreach($data as $item) {
                $data_id = $item['fixture']['id'];
                $long_status = $item['fixture']['status']['long']; 
                $state = isset($this->long_status[$long_status]) ? $this->long_status[$long_status] : null;
                $odds = $item['odds'];
                
                $fixture_status = null;
                if (isset($item['fixture']['status']['long']) && isset($this->$fixture_status[$item['fixture']['status']['long']])) {
                    $fixture_status = json_encode($item['fixture']['status']);
                }
                $update_data = [
                    'state' => $state,
                    'odds' => $odds,
                    'fixture_status' => $fixture_status,
                    'score' => isset($item['teams']['home']['goals']) ? "{$item['teams']['home']['goals']}-{$item['teams']['away']['goals']}":'-',
                    'is_send' => 0,
                ];
                
                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";
            file_put_contents('odds-error.log', json_encode($data)."\r\n\r\n", FILE_APPEND);
        }
    }

}