调整直播数据写入接口

app/Http/Controllers/Api/SettlementController.php

@@ -48,17 +48,21 @@ class SettlementController extends Controller
         exit ;
         */
 
-            $id = 28840954 ;
+
+
+        /*
+            $id = 3 ;
             $obj = new  SettlementWinFail();
             $ret = $obj->doRun($id);
             print_r($ret);
             echo "cost:" . (microtime(true) - floatval($_SERVER['REQUEST_TIME_FLOAT'])) .' 秒!';
             exit;
+        */
 
 
-        $oida = $this->getIds(1,866,'zq');
+        $oida = $this->getIds(1,455,'zq');
         $swf =  new SettlementOrder();
-        $ret = $swf->reSettlement($oida,1,2,'zq',866);
+        $ret = $swf->reSettlement($oida,1,2,'zq',455);
         var_dump($ret);
         echo "<hr/>";
         echo "cost:" . (microtime(true) - floatval($_SERVER['REQUEST_TIME_FLOAT'])) .' 秒!';
@@ -70,9 +74,6 @@ class SettlementController extends Controller
 
 
 
-
-
-
         $cond = '+2.5/3';
         $cond = '+3/3.5';
 
@@ -97,10 +98,9 @@ class SettlementController extends Controller
 
 
         $noticeid = 3592444;
-        $matchid = 3217130;
+        $matchid = 900;
         $order_ids = $this->getIds(1, $matchid,'zq');
 
-
         $winorfalse = new  SettlementWinFail();
         $ret1 = $winorfalse->doRun($noticeid);
         print_r(['ret1' => $ret1]);

app/Http/Controllers/Api/WriteSportsController.php

@@ -831,6 +831,9 @@ class WriteSportsController extends BaseController{
             }
             //获取 球类
             $game_code = $getData['game_code'];
+            //删除当前球类已存在的直播数据
+            $del = broadcastModel::where('game_code', $game_code)->delete();
+            if($del != true) throw new \Exception(Response::generate('',Response::DEL_PAST_BROADCAST_ERR));   
             //获取 直播 数据
             $BroadCast = $getData['data'];
             $set_broadcast = [];

app/Http/Model/StZqOdds.php

@@ -75,8 +75,8 @@ class StZqOdds extends Model
             }
         }
         //批量更新 赔率状态
-        $ds = $model['model_odds']::whereIn('odds_only', $only)
+        $del = $model['model_odds']::whereIn('odds_only', $only)
         ->delete();
-        if($ds) return true;
+        if($del) return true;
     }
 }

app/Http/Response/Response.php

@@ -47,6 +47,8 @@ class Response
     const SPORTS_RECORD_ERR = 10037;
     //未获取到本地赛事id
     const L_MATCH_ID_ERR = 10038;
+    //删除历史直播数据
+    const DEL_PAST_BROADCAST_ERR = 10039;
 
 
     private static $errorMsgs = [
@@ -89,6 +91,8 @@ class Response
         self::SPORTS_RECORD_ERR=>'写请求数据日志记录失败',
         //===未获取到本地赛事id===
         self::L_MATCH_ID_ERR=>'未获取到赔率所属本地赛事id',
+        //===删除历史直播数据失败===
+        self::DEL_PAST_BROADCAST_ERR=>'删除历史直播数据失败',
 
     ];
 

app/Lib/Settlement/SettlementOrder.php

@@ -407,13 +407,14 @@ class SettlementOrder extends SettlementBase
 
 
         // 新增中奖记录表
-        $old = $this->money_prize_map[$order_id];
+        //$old = $this->money_prize_map[$order_id];
         $table = 'money_prize';
         if (isset($this->money_prize_map[$order_id])) {
             $this->sqlArray[] = "update $table  set money=$money,prize_money=$returnMoney, get_money= $returnMoney - $money where  order_id='$order_id'";
         } else {
+            $tmp_account = $this->account_map_array[$account_identity]->account ;
             $sql = "insert into  $table (info_identity,order_id,account_identity,account_name,game_name,buy_identity,money,money_time,status,prize_money,get_money) values ";
-            $sql .= "('$info_identity','$order_id','$account_identity','$accountInfo->account','$game_name','$buy_identity',$money,'$money_time',1,$returnMoney,$returnMoney - $money)";
+            $sql .= "('$info_identity','$order_id','$account_identity','$tmp_account','$game_name','$buy_identity',$money,'$money_time',1,$returnMoney,$returnMoney - $money)";
             $this->sqlArray[] = $sql;
         }