异常处理

Application/Sports/Controller/MatchListWeb.php

@@ -163,6 +163,7 @@ class MatchListWeb extends Controller{
      * 获取赛事数据1
      */
     public function getMatchData($type,$game_code,$p_code='',$time='',$lg_ids=[],$search=''){
+
         //$p_code 获取具体玩法下的赛事数据
         $models = $this->commonFunction->getModels($game_code,1);
         $where = $this->commonFunction->getState($type,$models['model_match'],$game_code, $p_code);
@@ -188,6 +189,13 @@ class MatchListWeb extends Controller{
             }else{
                 $select = [$models['model_league'].'.id as lg_id',$models['model_league'].'.name_chinese as leagueName',$models['model_match'].'.id as match_id','home_team','guest_team','match_date','match_time','tag','country_id','area_id'];
             }
+        }else{
+            //赔率数据
+            $oddsCodeNum = $this->getOddsData($game_code,$models['model_odds'],$match_ids,$lg_ids,$p_code,$type);
+
+            if(empty($p_code) and $type != 'StRollBall') {
+                return $oddsCodeNum;
+            }
         }
        
         //如果是滚球
@@ -660,98 +668,136 @@ where a.match_id = b.match_id and a.id = b.id ";
 
         //==补充缺少玩法==
         //默认玩法
-        $codeData=[
+        $wq_codeData = [
             [
-                'game_code'=>'zq',
+                'game_code'=>'wq',
                 'game_num'=>0,
-                'p_code'=>'B',
+                'p_code'=>'CO',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'zq',
+                'game_code'=>'wq',
                 'game_num'=>0,
-                'p_code'=>'CO',
+                'p_code'=>'kemp',
                 'code_num'=>0
-            ],
+            ]
+            ];
+        $lq_codeData=[
             [
-                'game_code'=>'zq',
+                'game_code'=>'lq',
                 'game_num'=>0,
-                'p_code'=>'C',
+                'p_code'=>'kemp',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'zq',
+                'game_code'=>'lq',
                 'game_num'=>0,
-                'p_code'=>'TS',
+                'p_code'=>'CO',
                 'code_num'=>0
-            ],
+            ]
+        ];
+        $bq_codeData = [
             [
-                'game_code'=>'zq',
+                'game_code'=>'bq',
                 'game_num'=>0,
-                'p_code'=>'TG',
+                'p_code'=>'CO',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'zq',
+                'game_code'=>'bq',
                 'game_num'=>0,
-                'p_code'=>'kemp',
+                'p_code'=>'B',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'lq',
+                'game_code'=>'bq',
                 'game_num'=>0,
                 'p_code'=>'kemp',
                 'code_num'=>0
-            ],
+            ]
+        ];
+        $zq_codeData=[
             [
-                'game_code'=>'lq',
+                'game_code'=>'zq',
                 'game_num'=>0,
-                'p_code'=>'CO',
+                'p_code'=>'B',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'bq',
+                'game_code'=>'zq',
                 'game_num'=>0,
                 'p_code'=>'CO',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'bq',
+                'game_code'=>'zq',
                 'game_num'=>0,
-                'p_code'=>'B',
+                'p_code'=>'C',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'bq',
+                'game_code'=>'zq',
                 'game_num'=>0,
-                'p_code'=>'kemp',
+                'p_code'=>'TS',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'wq',
+                'game_code'=>'zq',
                 'game_num'=>0,
-                'p_code'=>'CO',
+                'p_code'=>'TG',
                 'code_num'=>0
             ],
             [
-                'game_code'=>'wq',
+                'game_code'=>'zq',
                 'game_num'=>0,
                 'p_code'=>'kemp',
                 'code_num'=>0
             ]
         ];
 
-        //匹配获取的玩法数量，没有则使用默认
-        foreach($codeData as $k=>$v){
-            foreach($oddsCodeNum as $kk=>$vv){
-                if($v['game_code'] == $vv['game_code'] and $v['p_code'] == $vv['p_code']){
-                    $codeData[$k] = $vv;
+        if($game_code == 'zq'){
+            foreach($zq_codeData as $k=>$v){
+                foreach($oddsCodeNum as $kk=>$vv){
+                    if($v['game_code'] == $vv['game_code'] and $v['p_code'] == $vv['p_code']){
+                        $zq_codeData[$k] = $vv;
+                    }
+                }
+            }
+            return $zq_codeData;
+        }
+        if($game_code == 'lq'){
+            foreach($lq_codeData as $k=>$v){
+                foreach($oddsCodeNum as $kk=>$vv){
+                    if($v['game_code'] == $vv['game_code'] and $v['p_code'] == $vv['p_code']){
+                        $lq_codeData[$k] = $vv;
+                    }
                 }
             }
+            return $lq_codeData;
         }
+        if($game_code == 'wq'){
+            foreach($wq_codeData as $k=>$v){
+                foreach($oddsCodeNum as $kk=>$vv){
+                    if($v['game_code'] == $vv['game_code'] and $v['p_code'] == $vv['p_code']){
+                        $wq_codeData[$k] = $vv;
+                    }
+                }
+            }
+            return $wq_codeData;
+        }
+        if($game_code == 'bq'){
+            foreach($bq_codeData as $k=>$v){
+                foreach($oddsCodeNum as $kk=>$vv){
+                    if($v['game_code'] == $vv['game_code'] and $v['p_code'] == $vv['p_code']){
+                        $bq_codeData[$k] = $vv;
+                    }
+                }
+            }
+            return $bq_codeData;
+        }
+       
 
         //==end==
-        return $codeData;
     }
 
     //获取直播数据

Application/Sports/Controller/MatchVer.php

@@ -57,7 +57,7 @@ class MatchVer extends Controller
 
         //数据转arr
         $data_arr = json_decode($data_json,true);
-        if(empty($data_arr)) Render('', '1', lang('Tips','Sports')->get('success'));
+        if(empty($data_arr)) Render('', '10030', lang('Errors','Sports')->get('error-10030'));
         //循环处理 根据球类分组
         //足球 赛事数据
         $zq_data = [];
@@ -70,6 +70,10 @@ class MatchVer extends Controller
         foreach($data_arr as $k=>$v){
             //序号 赋值
             $v['sort'] = $k;
+            //状态 默认0 待处理 1正常 2赛事状态异常  3赔率异常 4赛事比分有更新
+            $v['status'] = 1;
+            //异常提示
+            $v['ver_mark'] = '正常';
             //足球
             if($v['game_code'] == 'zq'){
                 $zq_data[] = $v;
@@ -86,31 +90,144 @@ class MatchVer extends Controller
             if($v['game_code'] == 'bq'){
                 $bq_data[] = $v;
             }
+            $data_arr[$k] = $v;
         }
         //处理 足球
+        $zq_odd_err = [];
         if(!empty($zq_data)){
-            //获取model
-            $getModels = $this->commonFunction->getModels('zq');
-            //获取赛事id
-            $zq_match_ids = array_column($zq_data,'match_id');
-            //根据赛事id 获取赛事状态
-            $zq_match_status = $this->getMatchStatus($zq_match_ids,$getModels);
-            //根据赛事id 获取赛事比分
-            $zq_match_score = $this->getMatchScore($zq_match_ids,$getModels);
-            //根据赔率uuid 验证是否存在
+            $zq_odd_err = $this->verOddsData('zq',$zq_data);
+        }
+        //处理 篮球
+        $lq_odd_err = [];
+        if(!empty($lq_data)){
+            $lq_odd_err = $this->verOddsData('lq',$lq_data);
+        }
+        //处理 网球
+        $wq_odd_err = [];
+        if(!empty($wq_data)){
+            $wq_odd_err = $this->verOddsData('wq',$wq_data);
+        }
+        //处理 棒球
+        $bq_odd_err = [];
+        if(!empty($bq_data)){
+            $bq_odd_err = $this->verOddsData('bq',$bq_data);
+        }
+
+        //合并各球类异常投注项
+        $all_err = array_merge($zq_odd_err,$lq_odd_err,$wq_odd_err,$bq_odd_err);
+
+
+        //如果有异常投注数据
+        if(!empty($all_err)){
+            //合并 投注赔率数据
+            foreach($data_arr as $k=>$v){
+                foreach($all_err as $kk=>$vv){
+                    if($v['sort'] == $vv['sort']){
+                        $data_arr[$k] = $vv;
+                    }
+                }
+            }
+        }
+              
+        //验证比分是否发生变化
+        Render($data_arr, '1', lang('Tips','Sports')->get('success'));
+    }
+    
+    /**
+     * 验证投注内容 
+     */
+    public function verOddsData($game_code,$oddsData){
+        //获取model
+        $getModels = $this->commonFunction->getModels($game_code);
+        //获取赛事id
+        $match_ids = array_column($oddsData,'match_id');
+        //获取赔率odds_only
+        $odds_onlys =  array_column($oddsData,'odds_only');
+        //比分正常 投注项
+        $score_pass = [];
+        //比分异常 投注项
+        $score_err = [];
+        //玩法赔率正常 投注项
+        $odds_pass = [];
+        //玩法赔率 异常 投注项
+        $odds_err = [];
+        //赛事状态异常的 投注项
+        $status_err = [];
+        //赛事状态正常的 投注项
+        $status_pass = [];
+
+        //根据赛事id 获取赛事状态
+        $match_status = $this->getMatchStatus($match_ids,$getModels);
+        //验证赛事状态是否异常
+        if(!empty($match_status)){
             
+            foreach($match_status as $k=>$v){
+                foreach($oddsData as $kk=>$vv){
+                    if($v['match_id'] == $vv['match_id'] and $v['status'] > 1){
+                        $vv['status'] = 2;//赛事状态异常
+                        $vv['ver_mark'] = '赛事状态变更或数据异常';
+                        $status_err[] = $vv;
+                        //排除当前投注项
+                        unset($oddsData[$kk]);
+                    }
+                }
+            }
 
-            dd($zq_match_score);exit;
+            //当前正常投注项
+            $status_pass = $oddsData;
         }
-        dd($zq_data);
 
-        //验证比分是否发生变化
-        //
-        dd(123);
+         //如果 还有投注项 验证玩法赔率
+         if(!empty($status_pass)){
+            //根据赔率uuid 验证是否存在
+            $odds_data = $this->getOdds($odds_onlys,$getModels);
+           
+            foreach($status_pass as $k=>$v){
+                if(!empty($odds_data)){
+                    foreach($odds_data as $kk=>$vv){
+                        if($v['odds_only'] == $vv['odds_only']){
+                            $odds_pass[] = $v;
+                            //排除当前投注项
+                            unset($status_pass[$k]);
+                        }
+                    }
+                }
+            }
 
-        Render('', '1', lang('Tips','Sports')->get('success'));
+            //赋值异常 投注
+            if(!empty($status_pass)){
+                foreach($status_pass as $k=>$v){
+                    $v['status'] = 3;//赔率数据异常
+                    $v['ver_mark'] = '玩法盘口已关闭或赔率有更新';
+                    $odds_err[] = $v;
+                }
+            }
+        }
 
+        //如果 还有投注项 验证赛事比分
+        if(!empty($odds_pass)){
+            //根据赛事id 获取赛事比分
+            $match_score = $this->getMatchScore($match_ids,$getModels,$game_code);
+            foreach($odds_pass as $k=>$v){
+                foreach($match_score as $kk=>$vv){
+                    //获取异常
+                    if($v['match_id'] == $vv->match_id ){
+                        if($v['home_score'] != $vv->home_score || $v['guest_score'] != $vv->guest_score){
+                            $v['status'] = 4;//比分数据异常
+                            $v['ver_mark'] = '进球/比分有变更或数据异常';
+                            $score_err[] = $v;
+                            unset($odds_pass[$k]);
+                        }
+                    }
+                }
+            }
 
+            //赋值正常 投注
+            $score_pass = $odds_pass;
+        }
+        //合并以上所有异常
+        $all_err = array_merge_recursive($status_err,$odds_err,$score_err);
+        return $all_err;
     }
 
     /**
@@ -119,7 +236,6 @@ class MatchVer extends Controller
     public function getMatchStatus($match_ids,$getModels){
         
         $match_model = $getModels['model_match'];
-
         $match_status = lm($match_model, 'Sports')
             ->select('id as match_id','status')
             ->whereIn('id',$match_ids)
@@ -132,16 +248,47 @@ class MatchVer extends Controller
     /**
      * 获取各球类 指定赛事 比分
      */
-    public function getMatchScore($match_ids,$getModels){
-        $model_result = $getModels['model_result'];
+    public function getMatchScore($match_ids,$getModels,$game_code){
 
-        $match_result = lm($model_result, 'Sports')
-            ->select('home_score','guest_score')
-            ->whereIn('id',$match_ids)
+        $match_ids_str = implode(",", $match_ids);
+        $result_record = $getModels['model_result_record'];
+
+         //如果是网球
+         if($game_code == 'wq'){
+            $sql = "select a.match_id,a.home_player_score as home_score,a.guest_player_score as guest_score,a.match_time as a_time,a.match_process,a.result_mark from $result_record a,
+(select match_id,max(id) id from $result_record where match_id IN ($match_ids_str) group by match_id)b
+where a.match_id = b.match_id and a.id = b.id ";
+        }else
+        //如果是棒球
+        if($game_code == 'bq' || $game_code == 'lq'){
+            $sql = "select a.match_id,a.home_score,a.guest_score,a.match_time as a_time,a.match_process,a.result_mark from $result_record a,
+(select match_id,max(id) id from $result_record where match_id IN ($match_ids_str) group by match_id)b
+where a.match_id = b.match_id and a.id = b.id ";
+        }else{
+            //其他球类
+            $sql = "select a.match_id,a.home_score,a.guest_score,a.match_time as a_time,a.match_process from $result_record a,
+(select match_id,max(id) id from $result_record where match_id IN ($match_ids_str) group by match_id)b
+where a.match_id = b.match_id and a.id = b.id ";
+        }
+        //查询 赛事结果记录最新的一条
+        $match_result_record = S ('DB')->select ($sql);
+
+        return $match_result_record;
+    }
+
+    /**
+     * 获取存在赔率
+     */
+    public function getOdds($odds_onlys,$getModels){
+        $model_odds = $getModels['model_odds'];
+
+        $odds_data = lm($model_odds,'Sports')
+            ->select('odds_only')
+            ->whereIn('odds_only',$odds_onlys)
             ->get()
             ->toArray();
 
-        return $match_result;
+        return $odds_data;
     }
 
     /**
@@ -152,10 +299,7 @@ class MatchVer extends Controller
         if ($checkToken['status'] != 1) {
             Render($checkToken['data'], $checkToken['status'], lang('commons')->get('user does login'));
         };
-        // $result = $this->accountManager->refreshToken($token);
-        // return $result['data'];
     }
-
 }