异常处理

app/Http/Controllers/Api/WriteSportsController.php

@@ -671,6 +671,8 @@ class WriteSportsController extends BaseController{
                 if($ret != true) throw new \Exception(Response::generate($gameName,Response::ODDS_SOLE_ERR));
 
                 //拼装 待写入 赔率数据
+                $ret_status_odds = [];
+                $ret_status_odds_r = [];
                 foreach($oddsData as $k=>$v){
                     //组装数据
                     $set_odds = [
@@ -695,7 +697,12 @@ class WriteSportsController extends BaseController{
                     $ret = $models['model_odds_record']->updateOrCreate(
                         ['odds_only'=>$v['odds_only']],$set_odds
                     );
-                    if(empty($ret)) throw new \Exception(Response::generate($gameName.'赔率记录-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_R_ERROR));
+                    if(empty($ret)) {
+                        $ret_status_odds_r[] = 0;
+                    }else{
+                        $ret_status_odds_r[] = 1;
+                    }
+                    // if(empty($ret)) throw new \Exception(Response::generate($gameName.'赔率记录-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_R_ERROR));
 
                     //追加参数
                     $set_odds['sole'] = $v['sole'];
@@ -704,8 +711,18 @@ class WriteSportsController extends BaseController{
                     $ret = $models['model_odds']->updateOrCreate(
                         ['odds_only'=>$v['odds_only']],$set_odds
                     );
-                    if(empty($ret)) throw new \Exception(Response::generate($gameName.'赔率-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_ERROR));
+                    if(empty($ret)) {
+                        $ret_status_odds[] = 0;
+                    }else{
+                        $ret_status_odds[] = 1;
+                    }
+                    // if(empty($ret)) throw new \Exception(Response::generate($gameName.'赔率-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_ERROR));
                 }
+
+                if(in_array(0,$ret_status_odds_r) == true) throw new \Exception(Response::generate('',Response::ADD_ODDS_R_ERROR));
+
+                if(in_array(0,$ret_status_odds) == true) throw new \Exception(Response::generate('',Response::ADD_ODDS_ERROR));
+
             }
            
             //提交事务