|
|
@@ -569,6 +569,139 @@ class WriteSportsController extends BaseController{
|
|
|
->update(['tag'=>$tag,'utime'=>date('Y-m-d H:i:s')]);
|
|
|
if($upMatch < 1) throw new \Exception(Response::generate($gameName.'赛事-match_id:'.$s_match_id.';',Response::UPMATCHTAG_ERROR)) ;
|
|
|
|
|
|
+ //获取 赔率数据
|
|
|
+ $oddsData = $getData['data'];
|
|
|
+ //获取 当前 所有 可用 赔率 sole
|
|
|
+ $odds_only = $getData['odds_only'];
|
|
|
+ //更新赛事下所有 不在本次请求的赔率 状态
|
|
|
+ $ret= OddsModel::upOddsStatus($models,$s_match_id,'',$source,$odds_only);
|
|
|
+ if($ret != true) throw new \Exception(Response::generate($gameName,Response::ODDS_SOLE_ERR));
|
|
|
+
|
|
|
+ //获取当前赛事 在本地的所有赔率
|
|
|
+ $l_odds_data = $models['model_odds']::select('odds_only')->where(['match_id'=>$match_id])->get()->toArray();
|
|
|
+ if(empty($l_odds_data)){
|
|
|
+ if(!empty($oddsData)){
|
|
|
+ //处理待写入 赔率数据
|
|
|
+ foreach($oddsData as $k=>$v){
|
|
|
+ //组装数据
|
|
|
+ $set_odds = [
|
|
|
+ 'match_id'=> $match_id?:0,
|
|
|
+ 'others_match_id'=> $v['match_id']?:0,
|
|
|
+ 'odds_code'=> $v['odds_code']?:'',
|
|
|
+ 'status'=> $v['status']?:0,
|
|
|
+ 'sort'=> $v['sort']?:0,
|
|
|
+ 'p_code'=> $v['p_code']?:'',
|
|
|
+ 'odds'=> $v['odds']?:0,
|
|
|
+ 'condition'=> $v['condition'],
|
|
|
+ 'odds_only'=> $v['odds_only']?:'',
|
|
|
+ 'source'=> $v['source']?:'',
|
|
|
+ 'type'=> $v['type']?:0,
|
|
|
+ 'team'=> $v['team']?:'',
|
|
|
+ 'lg_id'=> $lg_id,
|
|
|
+ 'others_lg_id'=> $v['lg_id'],
|
|
|
+ 'ctime'=> date('Y-m-d H:i:s'),
|
|
|
+ 'utime'=> date('Y-m-d H:i:s'),
|
|
|
+ ];
|
|
|
+ //写赔率记录数据
|
|
|
+ $ret = $models['model_odds_record']::insert($set_odds);
|
|
|
+ if($ret != true) throw new \Exception(Response::generate($gameName.'赔率记录-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_R_ERROR));
|
|
|
+ //追加参数
|
|
|
+ $set_odds['sole'] = $v['sole'];
|
|
|
+ $set_odds['expire_time'] = date('Y-m-d H:i:s',time()+60);
|
|
|
+ //写赔率 数据
|
|
|
+ $ret = $models['model_odds']::insert($set_odds);
|
|
|
+ if($ret != true) throw new \Exception(Response::generate($gameName.'赔率-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_ERROR));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }else{
|
|
|
+ //区分本地已有的赔率
|
|
|
+ //需更新赔率
|
|
|
+ $up_odds_data = [];
|
|
|
+ //需写入赔率
|
|
|
+ $in_odds_data = [];
|
|
|
+ if(!empty($oddsData)){
|
|
|
+ foreach($oddsData as $k=>$v){
|
|
|
+ foreach($l_odds_data as $kk=>$vv){
|
|
|
+ if($v['odds_only'] == $vv['odds_only']){
|
|
|
+ $up_odds_data[] = $v;
|
|
|
+ }else{
|
|
|
+ $in_odds_data[] = $v;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //执行 更新赔率
|
|
|
+ if(!empty($up_odds_data)){
|
|
|
+ foreach($oddsData as $k=>$v){
|
|
|
+ //组装数据
|
|
|
+ $set_odds = [
|
|
|
+ 'match_id'=> $match_id?:0,
|
|
|
+ 'others_match_id'=> $v['match_id']?:0,
|
|
|
+ 'odds_code'=> $v['odds_code']?:'',
|
|
|
+ 'status'=> $v['status']?:0,
|
|
|
+ 'sort'=> $v['sort']?:0,
|
|
|
+ 'p_code'=> $v['p_code']?:'',
|
|
|
+ 'odds'=> $v['odds']?:0,
|
|
|
+ 'condition'=> $v['condition'],
|
|
|
+ 'odds_only'=> $v['odds_only']?:'',
|
|
|
+ 'source'=> $v['source']?:'',
|
|
|
+ 'type'=> $v['type']?:0,
|
|
|
+ 'team'=> $v['team']?:'',
|
|
|
+ 'lg_id'=> $lg_id,
|
|
|
+ 'others_lg_id'=> $v['lg_id'],
|
|
|
+ 'ctime'=> date('Y-m-d H:i:s'),
|
|
|
+ 'utime'=> date('Y-m-d H:i:s'),
|
|
|
+ ];
|
|
|
+ //写赔率记录数据
|
|
|
+ $ret = $models['model_odds_record']::where(['odds_only'=>$v['odds_only']])
|
|
|
+ -> update($set_odds);
|
|
|
+ if($ret < 1) throw new \Exception(Response::generate($gameName.'赔率记录-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_R_ERROR));
|
|
|
+ //追加参数
|
|
|
+ $set_odds['sole'] = $v['sole'];
|
|
|
+ $set_odds['expire_time'] = date('Y-m-d H:i:s',time()+60);
|
|
|
+ //写赔率 数据
|
|
|
+ $ret = $models['model_odds']::where(['odds_only'=>$v['odds_only']])
|
|
|
+ -> update($set_odds);
|
|
|
+ if($ret < 1) throw new \Exception(Response::generate($gameName.'赔率-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_ERROR));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //执行 新增赔率
|
|
|
+ if(!empty($in_odds_data)){
|
|
|
+ foreach($oddsData as $k=>$v){
|
|
|
+ //组装数据
|
|
|
+ $set_odds = [
|
|
|
+ 'match_id'=> $match_id?:0,
|
|
|
+ 'others_match_id'=> $v['match_id']?:0,
|
|
|
+ 'odds_code'=> $v['odds_code']?:'',
|
|
|
+ 'status'=> $v['status']?:0,
|
|
|
+ 'sort'=> $v['sort']?:0,
|
|
|
+ 'p_code'=> $v['p_code']?:'',
|
|
|
+ 'odds'=> $v['odds']?:0,
|
|
|
+ 'condition'=> $v['condition'],
|
|
|
+ 'odds_only'=> $v['odds_only']?:'',
|
|
|
+ 'source'=> $v['source']?:'',
|
|
|
+ 'type'=> $v['type']?:0,
|
|
|
+ 'team'=> $v['team']?:'',
|
|
|
+ 'lg_id'=> $lg_id,
|
|
|
+ 'others_lg_id'=> $v['lg_id'],
|
|
|
+ 'ctime'=> date('Y-m-d H:i:s'),
|
|
|
+ 'utime'=> date('Y-m-d H:i:s'),
|
|
|
+ ];
|
|
|
+ //写赔率记录数据
|
|
|
+ $ret = $models['model_odds_record']::insert($set_odds);
|
|
|
+ if($ret != true) throw new \Exception(Response::generate($gameName.'赔率记录-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_R_ERROR));
|
|
|
+ //追加参数
|
|
|
+ $set_odds['sole'] = $v['sole'];
|
|
|
+ $set_odds['expire_time'] = date('Y-m-d H:i:s',time()+60);
|
|
|
+ //写赔率 数据
|
|
|
+ $ret = $models['model_odds']::insert($set_odds);
|
|
|
+ if($ret != true) throw new \Exception(Response::generate($gameName.'赔率-odds_only:'.$v['odds_only'].';',Response::ADD_ODDS_ERROR));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /*
|
|
|
//获取 赔率数据
|
|
|
$oddsData = $getData['data'];
|
|
|
if(!empty($oddsData)){
|
|
|
@@ -638,6 +771,7 @@ class WriteSportsController extends BaseController{
|
|
|
// if(count($ret_status_odds) != count($oddsData)) throw new \Exception(Response::generate('',Response::ADD_ODDS_ERROR));
|
|
|
|
|
|
}
|
|
|
+ */
|
|
|
|
|
|
//提交事务
|
|
|
DB::commit();
|