GetmatchData.php 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952
  1. <?php
  2. /**
  3. * 根据不同状态获取 赛事数据
  4. * User: Jun.peng
  5. * Date: 2019/4/4
  6. * Time: 10:57
  7. */
  8. namespace Biz\Match;
  9. use Biz\Match\GetOddsData;
  10. use App\Sports\Model\St_zq_league as leagueModel;
  11. use App\Sports\Model\St_zq_competition as matchModel;
  12. use App\Sports\Model\St_zq_odds as ZQoddsModel;
  13. use App\Sports\Model\St_wq_odds as WQoddsModel;
  14. use App\Sports\Model\St_bq_odds as BQoddsModel;
  15. use App\Sports\Model\St_lq_odds as LQoddsModel;
  16. class GetmatchData {
  17. public function __construct() {
  18. $this->getOddsData = new GetOddsData();
  19. $this->commonFunction = C()->get('commonFunction');
  20. }
  21. /**
  22. * @param $ret 提交参数
  23. * @param $source 数据源条件
  24. * @return array
  25. * @throws \Exception
  26. * 获取不同状态下的赛事相关数据
  27. */
  28. public function typeData($ret,$source){
  29. //根据球类代码 获取相关model
  30. $models = $this->commonFunction->getModels($ret['game_code']);
  31. $model_match = $models['model_match'];
  32. //获取 不同状态的查询条件
  33. $where = $this->commonFunction->getState($ret['type_code'],$model_match);
  34. //根据联赛id查询
  35. if(!empty($ret['lg_id'])){
  36. $lg_id = $ret['lg_id'];
  37. }
  38. //根据搜索查询
  39. if(!empty($ret['search'])){
  40. $search = $ret['search'];
  41. }
  42. switch ($ret['type_code']){
  43. case 'StRollBall'://滚球
  44. $data = $this->getRollBall($source,$models,$where,$ret,$search);
  45. break;
  46. case 'StSoon'://即将
  47. $oddsTypeWhere = [
  48. [$models['model_odds'].'.is_morningplate','=',1],
  49. ];
  50. $data = $this->getSoon($source,$models,$where,$lg_id,$ret,$search,$oddsTypeWhere);
  51. break;
  52. case 'StToday'://今日
  53. $oddsTypeWhere = [
  54. [$models['model_odds'].'.is_today','=',1],
  55. ];
  56. $data = $this->getToday($source,$models,$where,$lg_id,$search,$oddsTypeWhere);
  57. break;
  58. case 'StMorningPlate'://早盘
  59. //默认当天
  60. if(empty($ret['match_date'])){
  61. $match_date = date("Y-m-d");
  62. }else{
  63. if($ret['match_date'] != 'other'){
  64. $match_date = $ret['match_date'];
  65. }else{
  66. $match_date = 'other';
  67. }
  68. }
  69. $oddsTypeWhere = [
  70. [$models['model_odds'].'.is_morningplate','=',1],
  71. ];
  72. $data = $this->getMorningPlate($source,$models,$where,$lg_id,$search,$match_date,$oddsTypeWhere);
  73. break;
  74. case 'StStringScene'://串场
  75. $oddsTypeWhere = [
  76. [$models['model_odds'].'.is_stringscene','=',1],
  77. ];
  78. if(empty($ret['str_type']) || $ret['str_type'] ==0){//赛事
  79. $data = $this->getStringScene($source,$models,$where,$lg_id,$search,'',$oddsTypeWhere);
  80. }
  81. if($ret['str_type'] == 1){//参赛表
  82. }
  83. if($ret['str_type'] == 2){//冠军盘口
  84. $where = $this->commonFunction->getState('StChampion',$model_match);
  85. $data = $this->getChampion($source,$models,$where,$lg_id,$search,'StChampion');
  86. }
  87. break;
  88. case 'StChampion'://冠军
  89. $data = $this->getChampion($source,$models,$where,$lg_id,$search,$ret['type_code']);
  90. break;
  91. default:
  92. throw new \Exception(Render([], '10002', lang('Tips','Sports')->get('PARAM_ERROR')));
  93. }
  94. return $data;
  95. }
  96. /**
  97. * 获取各球类 滚球/即将 默认赔率数据
  98. */
  99. public function getDefault($data,$game_code,$models,$match_ids,$source){
  100. if($game_code == 'zq') {
  101. //获取赛事下默认赔率
  102. $oddsData = ZQoddsModel::getMatchOdds($source, $models,$match_ids);
  103. foreach ($data as $k=>$v){
  104. foreach ($v['matchData'] as $kk=>$vv){
  105. //获取赛事下赔率并且分组
  106. foreach ($oddsData as $kkk=>$vvv) {
  107. if ($vv['match_id'] == $vvv['match_id'] and $vvv['sort']==0) {
  108. if($vvv['odds_code'] == 'concede_guest'){
  109. $concede_g = $vvv;
  110. }
  111. if($vvv['odds_code'] == 'concede_home'){
  112. $concede_h = $vvv;
  113. }
  114. if($vvv['odds_code'] == 'goal_size_big'){
  115. $size_s = $vvv;
  116. }
  117. if($vvv['odds_code'] == 'goal_size_small'){
  118. $size_b = $vvv;
  119. }
  120. if($vvv['odds_code'] == 'capot_home'){
  121. $capot_h = $vvv;
  122. }
  123. if($vvv['odds_code'] == 'capot_dogfall'){
  124. $capot_d = $vvv;
  125. }
  126. if($vvv['odds_code'] == 'capot_guest'){
  127. $capot_g = $vvv;
  128. }
  129. }
  130. }
  131. $concede_size = [$concede_g,$concede_h,$size_s,$size_b];
  132. $capot = [$capot_h,$capot_d,$capot_g];
  133. foreach ($concede_size as $key => $vaule){
  134. if($vaule == null) unset($concede_size[$key]);
  135. }
  136. foreach ($capot as $key1 => $vaule1){
  137. if($vaule1 == null) unset($capot[$key1]);
  138. }
  139. sort($concede_size);
  140. sort($capot);
  141. $data[$k]['matchData'][$kk]['oddsData'] = [$concede_size,$capot];
  142. }
  143. }
  144. }
  145. if($game_code == 'lq') {
  146. $oddsData = LQoddsModel::getMatchOdds($source,$match_ids);
  147. foreach ($data as $k=>$v){
  148. foreach ($v['matchData'] as $kk=>$vv){
  149. //获取赛事下赔率并且分组
  150. $capot = [];
  151. $total_size = [];
  152. $concede = [];
  153. foreach ($oddsData as $kkk=>$vvv) {
  154. if ($vv['match_id'] == $vvv['match_id'] and $vvv['sort']==0) {
  155. if($vvv['p_code'] == 'capot'){
  156. $capot[] = $vvv;
  157. }else{
  158. if($vvv['p_code'] == 'total_size'){
  159. $total_size[] = $vvv;
  160. }
  161. if($vvv['p_code'] == 'concede'){
  162. $concede[] = $vvv;
  163. }
  164. }
  165. }
  166. }
  167. $concede_size = [$concede[0],$concede[1],$total_size[0],$total_size[1]];
  168. $data[$k]['matchData'][$kk]['oddsData'] = [$concede_size,$capot];
  169. }
  170. }
  171. }
  172. if($game_code == 'wq') {
  173. $oddsData = WQoddsModel::getMatchOdds($source,$match_ids);
  174. foreach ($data as $k=>$v){
  175. foreach ($v['matchData'] as $kk=>$vv){
  176. //获取赛事下赔率并且分组
  177. $odds = [];
  178. foreach ($oddsData as $kkk=>$vvv) {
  179. if ($vv['match_id'] == $vvv['match_id'] and $vvv['sort']==0) {
  180. $odds[] = $vvv;
  181. }
  182. }
  183. $data[$k]['matchData'][$kk]['oddsData'] = $odds;
  184. }
  185. }
  186. }
  187. if($game_code == 'bq') {
  188. $oddsData = BQoddsModel::getMatchOdds($source,$match_ids);
  189. foreach ($data as $k=>$v){
  190. foreach ($v['matchData'] as $kk=>$vv){
  191. //获取赛事下赔率并且分组
  192. $odds = [];
  193. foreach ($oddsData as $kkk=>$vvv) {
  194. if ($vv['match_id'] == $vvv['match_id'] and $vvv['sort']==0) {
  195. if($vvv['odds_code'] == 'concede_guest'){
  196. $concede_g = $vvv;
  197. }
  198. if($vvv['odds_code'] == 'concede_home'){
  199. $concede_h = $vvv;
  200. }
  201. if($vvv['odds_code'] == 'total_size_small'){
  202. $size_s = $vvv;
  203. }
  204. if($vvv['odds_code'] == 'total_size_big'){
  205. $size_b = $vvv;
  206. }
  207. if($vvv['odds_code'] == 'capot_home'){
  208. $capot_h = $vvv;
  209. }
  210. if($vvv['odds_code'] == 'capot_guest'){
  211. $capot_g = $vvv;
  212. }
  213. }
  214. }
  215. $concede_size = [$concede_g,$concede_h,$size_s,$size_b];
  216. $capot = [$capot_h,$capot_g];
  217. foreach ($concede_size as $key => $vaule){
  218. if($vaule == null) unset($concede_size[$key]);
  219. }
  220. foreach ($capot as $key1 => $vaule1){
  221. if($vaule1 == null) unset($capot[$key1]);
  222. }
  223. sort($concede_size);
  224. sort($capot);
  225. $data[$k]['matchData'][$kk]['oddsData'] = [$concede_size,$capot];
  226. }
  227. }
  228. }
  229. return $data;
  230. }
  231. /**
  232. * 获取滚球数据
  233. */
  234. public function getRollBall($source,$models,$where,$ret,$search=''){
  235. //获取当前状态下所有联赛
  236. $leagueData = leagueModel::getRollLeagueData($source,$models,$where,$search);
  237. if(empty($leagueData)){
  238. return $leagueData=[];
  239. }
  240. //获取联赛id
  241. $lg_ids = [];
  242. foreach ($leagueData as $k => $v){
  243. $lg_ids[] = $v['lg_id'];
  244. }
  245. //统计联赛下的赛事及查询赛事
  246. $matchData = matchModel::getRollMatchDataAll($source,$models,$where,$lg_ids);
  247. //如果赛事为空,直接返回
  248. if(empty($matchData)) return $matchData;
  249. //===获取当前赛事是否有赔率,如果没有则去除===
  250. $matchData_new = $this->commonFunction->Handle_Odds_Null($matchData,$models);
  251. //获取当前match_id
  252. $match_ids = [];
  253. foreach($matchData as $k=>$v){
  254. $match_ids[] = $v['match_id'];
  255. }
  256. //组装联赛下赛事
  257. $data = [];
  258. foreach ($leagueData as $k=>$v){
  259. $data[$k] = $v;
  260. foreach ($matchData_new as $kk=>$vv){
  261. if($v['lg_id'] == $vv['lg_id']){
  262. $data[$k]['matchData'][] = $vv;
  263. }
  264. }
  265. $data[$k]['matchNum'] = count($data[$k]['matchData']);
  266. }
  267. //获取滚球/即将赛事 默认 赔率数据
  268. $data = $this->getDefault($data,$ret['game_code'],$models,$match_ids,$source);
  269. return $data;
  270. }
  271. /**
  272. * 获取即将数据
  273. */
  274. public function getSoon($source,$models,$where,$lg_id=0,$ret,$search='',$oddsTypeWhere=''){
  275. //获取当前状态下所有联赛
  276. $leagueData = leagueModel::getSoonLeagueData($source,$models,$where,$search);
  277. if(empty($leagueData)){
  278. return $leagueData=[];
  279. }
  280. //获取联赛id
  281. $lg_ids = [];
  282. foreach ($leagueData as $k => $v){
  283. $lg_ids[] = $v['lg_id'];
  284. }
  285. //统计联赛下的赛事及查询赛事
  286. $matchData = matchModel::getSoonMatchDataAll($source,$models,$where,$lg_ids);
  287. //如果赛事为空,直接返回
  288. if(empty($matchData)) return $matchData;
  289. //===获取当前赛事是否有赔率,如果没有则去除===
  290. $matchData_new = $this->commonFunction->Handle_Odds_Null($matchData,$models);
  291. //获取当前match_id
  292. $match_ids = [];
  293. foreach($matchData as $k=>$v){
  294. $match_ids[] = $v['match_id'];
  295. }
  296. //获取当前美东时间
  297. $s_time = strtotime($this->commonFunction->qgmdate('Y-m-d H:i:s', '', -4));
  298. $data = [];
  299. foreach ($leagueData as $k=>$v){
  300. $data[$k] = $v;
  301. foreach ($matchData_new as $kk=>$vv){
  302. if($v['lg_id'] == $vv['lg_id']){
  303. $wait_time = ceil(((strtotime( $vv['us_time']))-$s_time)/60);
  304. $vv['wait_time'] = $wait_time;//追加距离开赛时间
  305. $data[$k]['matchData'][] = $vv;
  306. }
  307. }
  308. $data[$k]['matchNum'] = count($data[$k]['matchData']);
  309. }
  310. //获取滚球/即将赛事 默认 赔率数据
  311. $data = $this->getDefault($data,$ret['game_code'],$models,$match_ids,$source);
  312. return $data;
  313. }
  314. /**
  315. * 获取今日数据
  316. */
  317. public function getToday($source,$models,$where,$lg_id=0,$search='',$oddsTypeWhere=[]){
  318. //获取model
  319. $model_match = $models['model_match'];
  320. $model_odds = $models['model_odds'];
  321. $model_league = $models['model_league'];
  322. $model_result = $models['model_result'];
  323. //根据联赛id 获取联赛下 赛事赔率数据
  324. if($lg_id >0){
  325. $leagueData = $this->getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,'',$oddsTypeWhere);
  326. return $leagueData;
  327. }
  328. $data = $this->getMatch($source,$models,$search,$where);
  329. return $data;
  330. }
  331. /**
  332. * 获取早盘数据
  333. */
  334. public function getMorningPlate($source,$models,$where,$lg_id=0,$search='',$time='',$oddsTypeWhere=''){
  335. //获取model
  336. $model_match = $models['model_match'];
  337. $model_odds = $models['model_odds'];
  338. $model_league = $models['model_league'];
  339. $model_result = $models['model_result'];
  340. //根据联赛id 获取联赛下 赛事赔率数据
  341. if($lg_id >0){
  342. $leagueData = $this->getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,$time,$oddsTypeWhere);
  343. return $leagueData;
  344. }
  345. $data = $this->getMatch($source,$models,$search,$where,$time);
  346. return $data;
  347. }
  348. /**
  349. * 获取串场数据
  350. */
  351. public function getStringScene($source,$models,$where,$lg_id=0,$search='',$time='',$oddsTypeWhere=''){
  352. //获取model
  353. $model_match = $models['model_match'];
  354. $model_odds = $models['model_odds'];
  355. $model_league = $models['model_league'];
  356. $model_result = $models['model_result'];
  357. //根据联赛id 获取联赛下 赛事赔率数据
  358. if($lg_id >0){
  359. $leagueData = $this->getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,$time,$oddsTypeWhere);
  360. return $leagueData;
  361. }
  362. $data = $this->getMatch($source,$models,$search,$where,$time);
  363. return $data;
  364. }
  365. /**
  366. * 获取冠军数据
  367. */
  368. public function getChampion($source,$models,$where,$lg_id=0,$search='',$type_code=''){
  369. //获取model
  370. $model_odds = $models['model_odds'];
  371. $model_league = $models['model_league'];
  372. //根据联赛id 获取联赛下 冠军玩法盘口
  373. if($lg_id >0){
  374. $last_time = lm($model_league, 'Sports')
  375. ->select('last_time')
  376. ->where('id',$lg_id)
  377. ->first()->last_time;
  378. $championData = lm($model_odds, 'Sports')
  379. ->select("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  380. ->where('lg_id',$lg_id)
  381. ->where($where)
  382. ->where(['status'=>0])
  383. ->groupBy("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  384. ->get()->toArray();
  385. //按p_code分组
  386. $p_code=array();
  387. foreach($championData as $k=>$v){
  388. $p_code[$v['p_code']][]=$v;
  389. }
  390. $sd = [];
  391. foreach ($p_code as $k1=>$v1){
  392. foreach ($v1 as $k2=>$v2){
  393. $sd[$v2['p_code']]['last_time'] =$last_time;
  394. $sd[$v2['p_code']][$v2['odds_code']][] = $v2;
  395. }
  396. }
  397. return $sd;
  398. }
  399. //获取国家/洲下所有联赛及数量
  400. $data = $this->getMatch($source,$models,$search,$where,'',$type_code);
  401. return $data;
  402. }
  403. /**
  404. * 获取国家/洲 下联赛
  405. */
  406. public function getMatch($source,$models,$search,$where,$time='',$type_code=''){
  407. //国家下所有联赛
  408. $country = lm($models['model_league'],"Sports")
  409. ->leftjoin('st_area_country','st_area_country.id',$models['model_league'].'.country_id')
  410. ->select('st_area_country.id as country_id','st_area_country.name as region')
  411. ->distinct('st_area_country.name')
  412. ->where([[$models['model_league'].'.name_chinese','!=','']])
  413. ->where($models['model_league'].'.name_chinese','like','%'.$search.'%')
  414. ->get()
  415. ->toArray();
  416. //洲下所有联赛
  417. $area = lm($models['model_league'],"Sports")
  418. ->leftjoin('st_area_country','st_area_country.id',$models['model_league'].'.area_id')
  419. ->select('st_area_country.id as area_id','st_area_country.name as region')
  420. ->distinct('st_area_country.name')
  421. ->where([[$models['model_league'].'.name_chinese','!=','']])
  422. ->where($models['model_league'].'.name_chinese','like','%'.$search.'%')
  423. ->get()
  424. ->toArray();
  425. if($type_code != 'StChampion'){//非冠军赛事
  426. $data = $this->getMatchNum($source,$country,$area,$models,$where,$search,$time);
  427. }else{//冠军赛事
  428. $data = $this->getMatchStChampionNum($source,$country,$area,$models,$where,$search,$time);
  429. }
  430. return $data;
  431. }
  432. /**
  433. * 获取联赛下赛事 数量
  434. * 非冠军盘口
  435. */
  436. public function getMatchNum($source,$country,$area,$models,$where,$search,$time='',$type=0){
  437. $leagueData = lm($models['model_league'],'Sports')
  438. ->select('id as lg_id','name_chinese as league','country_id','area_id')
  439. ->where([[$models['model_league'].'.name_chinese','!=','']])
  440. ->where($models['model_league'].'.name_chinese','like','%'.$search.'%')
  441. ->get()
  442. ->toArray();
  443. //如果有时间条件
  444. $timeWhere = [];
  445. if(!empty($time)){
  446. if($time == 'other'){
  447. $timeWhere[] = ['match_date','>',date("Y-m-d",strtotime("+1weeks",strtotime(date('Y-m-d',time()))))];
  448. }else{
  449. $timeWhere[] = ['match_date',$time];
  450. }
  451. }
  452. //获取赛事
  453. $matchData = lm($models['model_match'],'Sports')
  454. ->select('id as match_id','lg_id')
  455. ->where($where)
  456. ->where($timeWhere)
  457. ->get()
  458. ->toArray();
  459. //如果赛事为空,直接返回
  460. if(empty($matchData)) return $matchData;
  461. //===获取当前赛事是否有赔率,如果没有则去除===
  462. $matchData_new = $this->commonFunction->Handle_Odds_Null($matchData,$models);
  463. //按国家
  464. $countryData = [];
  465. if(!empty($country) and !empty($leagueData) and !empty($matchData_new)){
  466. foreach ($country as $k=>$v){
  467. if($v['country_id']){
  468. $countryData[$k] = $v;
  469. foreach ($leagueData as $kk=>$vv){
  470. if($v['country_id'] == $vv['country_id']){
  471. $countryData[$k]['league_count'][] = $vv;
  472. }
  473. }
  474. }
  475. }
  476. }
  477. //去除无联赛 国家
  478. foreach ($countryData as $k=>$v){
  479. if(count($v) == 2){
  480. unset($countryData[$k]);
  481. }
  482. }
  483. //按地区
  484. $areaData = [];
  485. if(!empty($area) and !empty($leagueData) and($matchData_new)){
  486. foreach ($area as $k=>$v){
  487. if($v['area_id']){
  488. $areaData[$k] = $v;
  489. foreach ($leagueData as $kk=>$vv){
  490. if($v['area_id'] == $vv['area_id']){
  491. $areaData[$k]['league_count'][] = $vv;
  492. }
  493. }
  494. }
  495. }
  496. }
  497. //去除无联赛 地区
  498. foreach ($areaData as $k=>$v){
  499. if(count($v) == 2){
  500. unset($areaData[$k]);
  501. }
  502. }
  503. $countryData = $this->commonFunction->array_other_tt($countryData,$matchData_new);
  504. $areaData = $this->commonFunction->array_other_tt($areaData,$matchData_new);
  505. $data = array_merge($countryData,$areaData);
  506. return $data;
  507. }
  508. /**
  509. * 获取联赛下赛事 数量
  510. * 冠军盘口
  511. */
  512. public function getMatchStChampionNum($source,$country,$area,$models,$where,$search,$time='',$type=0){
  513. $leagueData = lm($models['model_league'],'Sports')
  514. ->select('id as lg_id','name_chinese as league','country_id','area_id')
  515. ->where([[$models['model_league'].'.name_chinese','!=','']])
  516. ->where($models['model_league'].'.name_chinese','like','%'.$search.'%')
  517. ->get()
  518. ->toArray();
  519. $oddsData = lm($models['model_odds'],'Sports')
  520. ->select('id','lg_id','p_code')
  521. ->distinct("p_code")//去重
  522. ->where($where)
  523. ->where(['status'=>0])
  524. ->get()
  525. ->toArray();
  526. //按国家
  527. $countryData = [];
  528. if(!empty($country) and !empty($leagueData) and !empty($oddsData)){
  529. foreach ($country as $k=>$v){
  530. if($v['country_id']){
  531. $countryData[$k] = $v;
  532. foreach ($leagueData as $kk=>$vv){
  533. if($v['country_id'] == $vv['country_id']){
  534. $countryData[$k]['league_count'][] = $vv;
  535. }
  536. }
  537. }
  538. }
  539. }
  540. //去除无联赛 国家
  541. foreach ($countryData as $k=>$v){
  542. if(count($v) == 2){
  543. unset($countryData[$k]);
  544. }
  545. }
  546. //按地区
  547. $areaData = [];
  548. if(!empty($area) and !empty($leagueData) and($oddsData)){
  549. foreach ($area as $k=>$v){
  550. if($v['area_id']){
  551. $areaData[$k] = $v;
  552. foreach ($leagueData as $kk=>$vv){
  553. if($v['area_id'] == $vv['area_id']){
  554. $areaData[$k]['league_count'][] = $vv;
  555. }
  556. }
  557. }
  558. }
  559. }
  560. //去除无联赛 地区
  561. foreach ($areaData as $k=>$v){
  562. if(count($v) == 2){
  563. unset($areaData[$k]);
  564. }
  565. }
  566. $countryData = $this->commonFunction->array_gj_tt($countryData,$oddsData);
  567. $areaData = $this->commonFunction->array_gj_tt($areaData,$oddsData);
  568. $data = array_merge($countryData,$areaData);
  569. return $data;
  570. }
  571. /**
  572. * 获取联赛下 赛事赔率
  573. */
  574. public function getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,$time='',$oddsTypeWhere=[]){
  575. $leagueData = lm($model_league,"Sports")
  576. ->select('id as lg_id','name_chinese as leagueName')
  577. ->where('id',$lg_id)
  578. ->first();
  579. //根据时间 拼装查询条件
  580. $whereTime = [];
  581. if(!empty($time)){
  582. if($time == 'other'){
  583. //其他时间(七天后)
  584. $whereTime = [
  585. ['match_date','>',date("Y-m-d",strtotime("+1weeks",strtotime(date('Y-m-d',time()))))],
  586. ];
  587. }elseif($time == date('Y-m-d')){
  588. //今天
  589. $whereTime = [
  590. ['is_morningplate','=',1],
  591. ['match_date','=',$time],
  592. ['match_time','>',date("H:i:s", time())]
  593. ];
  594. }else{
  595. //今天以后 七天内
  596. $whereTime = [
  597. ['match_date','=',$time]
  598. ];
  599. }
  600. }
  601. $matchData = lm($model_match,"Sports")
  602. ->select($model_match.'.id as match_id',$model_match.'.tag','match_date',$model_match.'.match_time',$model_match.'.home_team',$model_match.'.guest_team')
  603. ->where($model_match.'.lg_id',$lg_id)
  604. ->where($where)
  605. ->where($whereTime)
  606. ->where(function($query)use ($model_match,$search){
  607. $query->where($model_match.'.home_team','like','%'.$search.'%')
  608. ->orWhere(function($query)use ($model_match,$search) {
  609. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  610. });
  611. })
  612. ->get()
  613. ->toarray();
  614. //如果赛事为空,直接返回
  615. if(empty($matchData)) return $matchData;
  616. //===获取当前赛事是否有赔率,如果没有则去除===
  617. $models = ['model_odds'=>$model_odds];
  618. $matchData_new = $this->commonFunction->Handle_Odds_Null($matchData,$models);
  619. //获取各球类默认赔率
  620. $game_code = $_REQUEST['game_code'];
  621. switch ($game_code) {
  622. case 'zq'://足球
  623. $matchData = $this->getOddsData->getOddsZQ($matchData_new, $model_odds, $source,$oddsTypeWhere);
  624. break;
  625. case 'lq'://篮球
  626. $matchData = $this->getOddsData->getOddsLQ($matchData_new, $model_odds, $source,$oddsTypeWhere);
  627. break;
  628. case 'wq'://网球
  629. $matchData = $this->getOddsData->getOddsWQ($matchData_new, $model_odds, $source,$oddsTypeWhere);
  630. break;
  631. case 'bq'://棒球
  632. $matchData = $this->getOddsData->getOddsBQ($matchData_new, $model_odds, $source,$oddsTypeWhere);
  633. break;
  634. }
  635. $leagueData->matchNum = count($matchData);
  636. $leagueData->matchData = $matchData;
  637. return $leagueData;
  638. }
  639. /**
  640. * @param $source 数据源
  641. * @param $where 该状态 查询条件
  642. * @return array
  643. * @throws \Exception
  644. * 获取所有即将开赛 数据
  645. */
  646. public function getAllSoon($source,$where){
  647. $game = lm('GameType', 'Sports')->select('id','game_name','game_code','game_ico_url')->where('status',1)->get()->toArray();
  648. //获取当前美东时间
  649. $s_time = strtotime($this->commonFunction->qgmdate('Y-m-d H:i:s', '', -4));
  650. $data=[];
  651. foreach ($game as $key=>$item){
  652. if($item['game_code'] !='gj'){
  653. $model = $this->commonFunction->getModels($item['game_code']);
  654. $matchData = lm($model['model_match'], 'Sports')
  655. ->select('id as match_id','home_team','guest_team','match_time','us_time')
  656. ->where($where)
  657. ->orderBy('match_time','asc')
  658. ->get()->toArray();
  659. $matchNum = count($matchData);
  660. $matchData = array_slice($matchData,0,6);
  661. foreach ($matchData as $key1 => $item1){
  662. //获取等待时间
  663. $wait_time = ceil(((strtotime($item1['us_time']))-$s_time)/60);
  664. $matchData[$key1]['wait_time'] = $wait_time;
  665. }
  666. if($matchNum > 0){
  667. $data[$item['game_code']]['matchData'] = $matchData;
  668. $data[$item['game_code']]['matchNum'] = $matchNum;
  669. $data[$item['game_code']]['gameName'] = $item['game_name'];
  670. $data[$item['game_code']]['gameCode'] = $item['game_code'];
  671. }
  672. }
  673. }
  674. return $data;
  675. }
  676. /**
  677. * 获取欧冠 各状态赛事数据
  678. */
  679. public function getUEFAChampions($source){
  680. //根据搜索查询
  681. if(!empty($_GET['search'])){
  682. $search = $_GET['search'];
  683. }
  684. $model = $this->commonFunction->getModels('gj',1);
  685. $model_league = $model['model_league'];
  686. $leagueData = lm($model_league,'Sports')
  687. ->select('name_chinese','id as lg_id','last_time')
  688. ->where($model_league.'.name_chinese','欧洲冠军杯')
  689. ->first();
  690. //获取滚球数据
  691. $StRollBall = $this->getUEFAStRollBall($model,'StRollBall',$source,$leagueData->lg_id,$search);
  692. //获取今日数据
  693. $StToday = $this->getUEFAStToday($model,'StToday',$source,$leagueData->lg_id,$search);
  694. //获取早盘数据
  695. $StMorningPlate = $this->getUEFAStMorningPlate($model,'StMorningPlate',$source,$leagueData->lg_id,$search);
  696. //获取冠军盘口数据
  697. $StChampion = $this->getUEFAStChampion($model,'StChampion',$source,$leagueData->lg_id,$leagueData->last_time);
  698. $data = [
  699. 'lg_id' => $leagueData->lg_id,
  700. 'leagueName'=> $leagueData->name_chinese,
  701. 'StRollBall'=>[//滚球数据
  702. 'typeName'=>'滚球',
  703. 'matchNum'=>count($StRollBall),
  704. 'matchData'=>$StRollBall
  705. ],
  706. 'StToday'=>[//今日数据
  707. 'typeName'=>'今日',
  708. 'matchNum'=>count($StToday),
  709. 'matchData'=>$StToday
  710. ],
  711. 'StMorningPlate'=>[//早盘数据
  712. 'typeName'=>'早盘',
  713. 'matchNum'=>count($StMorningPlate),
  714. 'matchData'=>$StMorningPlate
  715. ],
  716. 'StChampion'=>[//冠军盘口
  717. 'typeName'=>'冠军盘口',
  718. 'matchNum'=>count($StChampion),
  719. 'matchData'=>$StChampion
  720. ]
  721. ];
  722. return $data;
  723. }
  724. /**
  725. * 获取欧冠 滚球数据
  726. */
  727. public function getUEFAStRollBall($model,$type_code,$source,$lg_id,$search=''){
  728. $model_match = $model['model_match'];
  729. $model_odds = $model['model_odds'];
  730. $model_result = $model['model_result'];
  731. $where = $this->commonFunction->getState($type_code,$model_match);
  732. $matchData = lm($model_match,"Sports")
  733. ->leftjoin($model_result,$model_result.'.match_id',$model_match.'.id')
  734. ->select($model_match.'.id as match_id',$model_match.'.tag','match_date',$model_match.'.match_time',$model_match.'.home_team',$model_match.'.guest_team','home_score','guest_score',$model_result.'.match_time as a_time','match_process')
  735. ->where($model_match.'.lg_id',$lg_id)
  736. ->where($where)
  737. ->where(function($query)use ($model_match,$search){
  738. $query->where($model_match.'.home_team','like','%'.$search.'%')
  739. ->orWhere(function($query)use ($model_match,$search) {
  740. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  741. });
  742. })
  743. ->get()
  744. ->toarray();
  745. //获取赛事id
  746. $match_ids = [];
  747. foreach ($matchData as $k => $v){
  748. $match_ids[] = $v['match_id'];
  749. }
  750. //获取赛事下滚球默认赔率
  751. $oddsData = ZQoddsModel::getMatchOdds($source,$model,$match_ids);
  752. foreach ($matchData as $k=>$v){
  753. //获取赛事下赔率并且分组
  754. $capot = [];
  755. $concede_size = [];
  756. foreach ($oddsData as $kk=>$vv){
  757. if ($vv['match_id'] == $v['match_id'] and $vv['sort']==0) {
  758. if($vv['p_code'] == 'concede_size'){
  759. $concede_size[] = $vv;
  760. }
  761. if($vv['p_code'] == 'capot'){
  762. $capot[] = $vv;
  763. }
  764. }
  765. }
  766. $matchData[$k]['oddsData'] = [$concede_size,$capot];
  767. }
  768. return $matchData;
  769. }
  770. /**
  771. * 获取欧冠 今日数据
  772. */
  773. public function getUEFAStToday($model,$type_code,$source,$lg_id,$search=''){
  774. $model_match = $model['model_match'];
  775. $model_odds = $model['model_odds'];
  776. $where = $this->commonFunction->getState($type_code);
  777. $matchData = lm($model_match,'Sports')
  778. ->select('id as match_id','match_date','match_time','tag','home_team','guest_team')
  779. ->where($where)
  780. ->where('lg_id',$lg_id)
  781. ->where(function($query)use ($model_match,$search){
  782. $query->where($model_match.'.home_team','like','%'.$search.'%')
  783. ->orWhere(function($query)use ($model_match,$search) {
  784. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  785. });
  786. })
  787. ->get()->toArray();
  788. //获取赛事id
  789. $match_ids = [];
  790. foreach ($matchData as $k => $v){
  791. $match_ids[] = $v['match_id'];
  792. }
  793. //获取赔率数据
  794. $oddsData = lm($model_odds, "Sports")
  795. ->select( 'id','p_code', 'odds_code','odds_only','status', 'odds', 'condition', 'sort','match_id')
  796. ->whereIn('match_id', $match_ids)
  797. ->where(['status'=>0])
  798. ->groupBy($model_odds . '.id','p_code', 'odds_code','odds_only', $model_odds . '.status', 'odds', 'condition', 'sort','match_id')
  799. ->orderBy($model_odds . '.id','desc')
  800. ->get()
  801. ->toarray();
  802. foreach ($matchData as $k=>$v){
  803. foreach ($oddsData as $kk=>$vv){
  804. if($v['match_id'] == $vv['match_id']){
  805. $matchData[$k]['oddsData'][] = $vv;
  806. }
  807. }
  808. }
  809. return $matchData;
  810. }
  811. /**
  812. * 获取欧冠 早盘数据
  813. */
  814. public function getUEFAStMorningPlate($model,$type_code,$source,$lg_id,$search=''){
  815. $model_match = $model['model_match'];
  816. $model_odds = $model['model_odds'];
  817. $where = $this->commonFunction->getState($type_code);
  818. $matchData = lm($model_match,'Sports')
  819. ->select('id as match_id','match_date','match_time','tag','home_team','guest_team')
  820. ->where($where)
  821. ->where('lg_id',$lg_id)
  822. ->where(function($query)use ($model_match,$search){
  823. $query->where($model_match.'.home_team','like','%'.$search.'%')
  824. ->orWhere(function($query)use ($model_match,$search) {
  825. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  826. });
  827. })
  828. ->get()->toArray();
  829. $data = $this->getOddsData->getOddsZQ($matchData,$model_odds,$source,[]);
  830. return $data;
  831. }
  832. /**
  833. * 获取 欧冠 冠军盘口数据
  834. */
  835. public function getUEFAStChampion($model,$type_code,$source,$lg_id,$last_time=''){
  836. $model_odds = $model['model_odds'];
  837. $where = $this->commonFunction->getState($type_code);
  838. $championData = lm($model_odds, 'Sports')
  839. ->select("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  840. ->where('lg_id',$lg_id)
  841. ->where($where)
  842. ->where(['status'=>0])
  843. ->groupBy("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  844. ->get()->toArray();
  845. //按p_code分组
  846. $p_code=array();
  847. foreach($championData as $k=>$v){
  848. $p_code[$v['p_code']][]=$v;
  849. }
  850. $data = [];
  851. foreach ($p_code as $k1=>$v1){
  852. foreach ($v1 as $k2=>$v2){
  853. $data[$v2['p_code']]['last_time'] =$last_time;
  854. $data[$v2['p_code']][$v2['odds_code']][] = $v2;
  855. }
  856. }
  857. return $data;
  858. }
  859. }