GetmatchData.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921
  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. //获取赛事id
  248. $match_ids = [];
  249. foreach ($matchData as $k => $v){
  250. $match_ids[] = $v['match_id'];
  251. }
  252. //组装联赛下赛事
  253. $data = [];
  254. foreach ($leagueData as $k=>$v){
  255. $data[$k] = $v;
  256. foreach ($matchData as $kk=>$vv){
  257. if($v['lg_id'] == $vv['lg_id']){
  258. $data[$k]['matchData'][] = $vv;
  259. }
  260. }
  261. $data[$k]['matchNum'] = count($data[$k]['matchData']);
  262. }
  263. //获取滚球/即将赛事 默认 赔率数据
  264. $data = $this->getDefault($data,$ret['game_code'],$models,$match_ids,$source);
  265. return $data;
  266. }
  267. /**
  268. * 获取即将数据
  269. */
  270. public function getSoon($source,$models,$where,$lg_id=0,$ret,$search='',$oddsTypeWhere=''){
  271. //获取当前状态下所有联赛
  272. $leagueData = leagueModel::getSoonLeagueData($source,$models,$where,$search);
  273. if(empty($leagueData)){
  274. return $leagueData=[];
  275. }
  276. //获取联赛id
  277. $lg_ids = [];
  278. foreach ($leagueData as $k => $v){
  279. $lg_ids[] = $v['lg_id'];
  280. }
  281. //统计联赛下的赛事及查询赛事
  282. $matchData = matchModel::getSoonMatchDataAll($source,$models,$where,$lg_ids);
  283. //获取赛事id
  284. $match_ids = [];
  285. foreach ($matchData as $k => $v){
  286. $match_ids[] = $v['match_id'];
  287. }
  288. //获取当前美东时间
  289. $s_time = strtotime($this->commonFunction->qgmdate('Y-m-d H:i:s', '', -4));
  290. $data = [];
  291. foreach ($leagueData as $k=>$v){
  292. $data[$k] = $v;
  293. foreach ($matchData as $kk=>$vv){
  294. if($v['lg_id'] == $vv['lg_id']){
  295. $wait_time = ceil(((strtotime( $vv['us_time']))-$s_time)/60);
  296. $vv['wait_time'] = $wait_time;//追加距离开赛时间
  297. $data[$k]['matchData'][] = $vv;
  298. }
  299. }
  300. $data[$k]['matchNum'] = count($data[$k]['matchData']);
  301. }
  302. //获取滚球/即将赛事 默认 赔率数据
  303. $data = $this->getDefault($data,$ret['game_code'],$models,$match_ids,$source);
  304. return $data;
  305. }
  306. /**
  307. * 获取今日数据
  308. */
  309. public function getToday($source,$models,$where,$lg_id=0,$search='',$oddsTypeWhere=[]){
  310. //获取model
  311. $model_match = $models['model_match'];
  312. $model_odds = $models['model_odds'];
  313. $model_league = $models['model_league'];
  314. $model_result = $models['model_result'];
  315. //根据联赛id 获取联赛下 赛事赔率数据
  316. if($lg_id >0){
  317. $leagueData = $this->getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,'',$oddsTypeWhere);
  318. return $leagueData;
  319. }
  320. $data = $this->getMatch($source,$model_league,$model_match,'',$search,$where);
  321. return $data;
  322. }
  323. /**
  324. * 获取早盘数据
  325. */
  326. public function getMorningPlate($source,$models,$where,$lg_id=0,$search='',$time='',$oddsTypeWhere=''){
  327. //获取model
  328. $model_match = $models['model_match'];
  329. $model_odds = $models['model_odds'];
  330. $model_league = $models['model_league'];
  331. $model_result = $models['model_result'];
  332. //根据联赛id 获取联赛下 赛事赔率数据
  333. if($lg_id >0){
  334. $leagueData = $this->getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,$time,$oddsTypeWhere);
  335. return $leagueData;
  336. }
  337. $data = $this->getMatch($source,$model_league,$model_match,'',$search,$where,$time);
  338. return $data;
  339. }
  340. /**
  341. * 获取串场数据
  342. */
  343. public function getStringScene($source,$models,$where,$lg_id=0,$search='',$time='',$oddsTypeWhere=''){
  344. //获取model
  345. $model_match = $models['model_match'];
  346. $model_odds = $models['model_odds'];
  347. $model_league = $models['model_league'];
  348. $model_result = $models['model_result'];
  349. //根据联赛id 获取联赛下 赛事赔率数据
  350. if($lg_id >0){
  351. $leagueData = $this->getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,$time,$oddsTypeWhere);
  352. return $leagueData;
  353. }
  354. $data = $this->getMatch($source,$model_league,$model_match,'',$search,$where,$time);
  355. return $data;
  356. }
  357. /**
  358. * 获取冠军数据
  359. */
  360. public function getChampion($source,$models,$where,$lg_id=0,$search='',$type_code=''){
  361. //获取model
  362. $model_odds = $models['model_odds'];
  363. $model_league = $models['model_league'];
  364. //根据联赛id 获取联赛下 冠军玩法盘口
  365. if($lg_id >0){
  366. $last_time = lm($model_league, 'Sports')
  367. ->select('last_time')
  368. ->where('id',$lg_id)
  369. ->first()->last_time;
  370. $championData = lm($model_odds, 'Sports')
  371. ->select("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  372. ->where('lg_id',$lg_id)
  373. ->where($where)
  374. ->groupBy("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  375. ->get()->toArray();
  376. //按p_code分组
  377. $p_code=array();
  378. foreach($championData as $k=>$v){
  379. $p_code[$v['p_code']][]=$v;
  380. }
  381. $sd = [];
  382. foreach ($p_code as $k1=>$v1){
  383. foreach ($v1 as $k2=>$v2){
  384. $sd[$v2['p_code']]['last_time'] =$last_time;
  385. $sd[$v2['p_code']][$v2['odds_code']][] = $v2;
  386. }
  387. }
  388. return $sd;
  389. }
  390. //获取国家/洲下所有联赛及数量
  391. $data = $this->getMatch($source,$model_league,'',$model_odds,$search,$where,'',$type_code);
  392. return $data;
  393. }
  394. /**
  395. * 获取国家/洲 下联赛
  396. */
  397. public function getMatch($source,$model_league,$model_match='',$model_odds='',$search,$where,$time='',$type_code=''){
  398. //国家下所有联赛
  399. $country = lm($model_league,"Sports")
  400. ->leftjoin('st_area_country','st_area_country.id',$model_league.'.country_id')
  401. ->select('st_area_country.id as country_id','st_area_country.name as region')
  402. ->distinct('st_area_country.name')
  403. ->where([[$model_league.'.name_chinese','!=','']])
  404. ->where($model_league.'.name_chinese','like','%'.$search.'%')
  405. ->get()
  406. ->toArray();
  407. //洲下所有联赛
  408. $area = lm($model_league,"Sports")
  409. ->leftjoin('st_area_country','st_area_country.id',$model_league.'.area_id')
  410. ->select('st_area_country.id as area_id','st_area_country.name as region')
  411. ->distinct('st_area_country.name')
  412. ->where([[$model_league.'.name_chinese','!=','']])
  413. ->where($model_league.'.name_chinese','like','%'.$search.'%')
  414. ->get()
  415. ->toArray();
  416. if($type_code != 'StChampion'){//非冠军赛事
  417. $data = $this->getMatchNum($source,$country,$area,$model_league,$model_match,$model_odds,$where,$search,$time);
  418. }else{//冠军赛事
  419. $data = $this->getMatchStChampionNum($source,$country,$area,$model_league,$model_match,$model_odds,$where,$search,$time);
  420. }
  421. return $data;
  422. }
  423. /**
  424. * 获取联赛下赛事 数量
  425. * 非冠军盘口
  426. */
  427. public function getMatchNum($source,$country,$area,$model_league,$model_match='',$model_odds='',$where,$search,$time='',$type=0){
  428. $leagueData = lm($model_league,'Sports')
  429. ->select('id as lg_id','name_chinese as league','country_id','area_id')
  430. ->where([[$model_league.'.name_chinese','!=','']])
  431. ->where($model_league.'.name_chinese','like','%'.$search.'%')
  432. ->get()
  433. ->toArray();
  434. $timeWhere = [];
  435. if(!empty($time)){
  436. if($time == 'other'){
  437. $timeWhere[] = ['match_date','>',date("Y-m-d",strtotime("+1weeks",strtotime(date('Y-m-d',time()))))];
  438. }else{
  439. $timeWhere[] = ['match_date',$time];
  440. }
  441. }
  442. $matchData = lm($model_match,'Sports')
  443. ->select('id as match_id','lg_id')
  444. ->where($where)
  445. ->where($timeWhere)
  446. ->get()
  447. ->toArray();
  448. //按国家
  449. $countryData = [];
  450. if(!empty($country) and !empty($leagueData) and !empty($matchData)){
  451. foreach ($country as $k=>$v){
  452. if($v['country_id']){
  453. $countryData[$k] = $v;
  454. foreach ($leagueData as $kk=>$vv){
  455. if($v['country_id'] == $vv['country_id']){
  456. $countryData[$k]['league_count'][] = $vv;
  457. }
  458. }
  459. }
  460. }
  461. }
  462. //去除无联赛 国家
  463. foreach ($countryData as $k=>$v){
  464. if(count($v) == 2){
  465. unset($countryData[$k]);
  466. }
  467. }
  468. //按地区
  469. $areaData = [];
  470. if(!empty($area) and !empty($leagueData) and($matchData)){
  471. foreach ($area as $k=>$v){
  472. if($v['area_id']){
  473. $areaData[$k] = $v;
  474. foreach ($leagueData as $kk=>$vv){
  475. if($v['area_id'] == $vv['area_id']){
  476. $areaData[$k]['league_count'][] = $vv;
  477. }
  478. }
  479. }
  480. }
  481. }
  482. //去除无联赛 地区
  483. foreach ($areaData as $k=>$v){
  484. if(count($v) == 2){
  485. unset($areaData[$k]);
  486. }
  487. }
  488. $countryData = $this->commonFunction->array_other_tt($countryData,$matchData);
  489. $areaData = $this->commonFunction->array_other_tt($areaData,$matchData);
  490. $data = array_merge($countryData,$areaData);
  491. return $data;
  492. }
  493. /**
  494. * 获取联赛下赛事 数量
  495. * 冠军盘口
  496. */
  497. public function getMatchStChampionNum($source,$country,$area,$model_league,$model_match='',$model_odds='',$where,$search,$time='',$type=0){
  498. $leagueData = lm($model_league,'Sports')
  499. ->select('id as lg_id','name_chinese as league','country_id','area_id')
  500. ->where([[$model_league.'.name_chinese','!=','']])
  501. ->where($model_league.'.name_chinese','like','%'.$search.'%')
  502. ->get()
  503. ->toArray();
  504. $oddsData = lm($model_odds,'Sports')
  505. ->select('id','lg_id','p_code')
  506. ->distinct("p_code")//去重
  507. ->where($where)
  508. ->get()
  509. ->toArray();
  510. //按国家
  511. $countryData = [];
  512. if(!empty($country) and !empty($leagueData) and !empty($oddsData)){
  513. foreach ($country as $k=>$v){
  514. if($v['country_id']){
  515. $countryData[$k] = $v;
  516. foreach ($leagueData as $kk=>$vv){
  517. if($v['country_id'] == $vv['country_id']){
  518. $countryData[$k]['league_count'][] = $vv;
  519. }
  520. }
  521. }
  522. }
  523. }
  524. //去除无联赛 国家
  525. foreach ($countryData as $k=>$v){
  526. if(count($v) == 2){
  527. unset($countryData[$k]);
  528. }
  529. }
  530. //按地区
  531. $areaData = [];
  532. if(!empty($area) and !empty($leagueData) and($oddsData)){
  533. foreach ($area as $k=>$v){
  534. if($v['area_id']){
  535. $areaData[$k] = $v;
  536. foreach ($leagueData as $kk=>$vv){
  537. if($v['area_id'] == $vv['area_id']){
  538. $areaData[$k]['league_count'][] = $vv;
  539. }
  540. }
  541. }
  542. }
  543. }
  544. //去除无联赛 地区
  545. foreach ($areaData as $k=>$v){
  546. if(count($v) == 2){
  547. unset($areaData[$k]);
  548. }
  549. }
  550. $countryData = $this->commonFunction->array_gj_tt($countryData,$oddsData);
  551. $areaData = $this->commonFunction->array_gj_tt($areaData,$oddsData);
  552. $data = array_merge($countryData,$areaData);
  553. return $data;
  554. }
  555. /**
  556. * 获取联赛下 赛事赔率
  557. */
  558. public function getMatchOdds($source,$model_league,$model_match,$model_odds,$where,$search,$lg_id,$time='',$oddsTypeWhere=[]){
  559. $leagueData = lm($model_league,"Sports")
  560. ->select('id as lg_id','name_chinese as leagueName')
  561. ->where('id',$lg_id)
  562. ->first();
  563. //根据时间 拼装查询条件
  564. $whereTime = [];
  565. if(!empty($time)){
  566. if($time == 'other'){
  567. //其他时间(七天后)
  568. $whereTime = [
  569. ['match_date','>',date("Y-m-d",strtotime("+1weeks",strtotime(date('Y-m-d',time()))))],
  570. ];
  571. }elseif($time == date('Y-m-d')){
  572. //今天
  573. $whereTime = [
  574. ['is_morningplate','=',1],
  575. ['match_date','=',$time],
  576. ['match_time','>',date("H:i:s", time())]
  577. ];
  578. }else{
  579. //今天以后 七天内
  580. $whereTime = [
  581. ['match_date','=',$time]
  582. ];
  583. }
  584. }
  585. $matchData = lm($model_match,"Sports")
  586. ->select($model_match.'.id as match_id',$model_match.'.tag','match_date',$model_match.'.match_time',$model_match.'.home_team',$model_match.'.guest_team')
  587. ->where($model_match.'.lg_id',$lg_id)
  588. ->where($where)
  589. ->where($whereTime)
  590. ->where(function($query)use ($model_match,$search){
  591. $query->where($model_match.'.home_team','like','%'.$search.'%')
  592. ->orWhere(function($query)use ($model_match,$search) {
  593. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  594. });
  595. })
  596. ->get()
  597. ->toarray();
  598. //获取各球类默认赔率
  599. $game_code = $_REQUEST['game_code'];
  600. switch ($game_code) {
  601. case 'zq'://足球
  602. $matchData = $this->getOddsData->getOddsZQ($matchData, $model_odds, $source,$oddsTypeWhere);
  603. break;
  604. case 'lq'://篮球
  605. $matchData = $this->getOddsData->getOddsLQ($matchData, $model_odds, $source,$oddsTypeWhere);
  606. break;
  607. case 'wq'://网球
  608. $matchData = $this->getOddsData->getOddsWQ($matchData, $model_odds, $source,$oddsTypeWhere);
  609. break;
  610. case 'bq'://棒球
  611. $matchData = $this->getOddsData->getOddsBQ($matchData, $model_odds, $source,$oddsTypeWhere);
  612. break;
  613. }
  614. $leagueData->matchNum = count($matchData);
  615. $leagueData->matchData = $matchData;
  616. return $leagueData;
  617. }
  618. /**
  619. * @param $source 数据源
  620. * @param $where 该状态 查询条件
  621. * @return array
  622. * @throws \Exception
  623. * 获取所有即将开赛 数据
  624. */
  625. public function getAllSoon($source,$where){
  626. $game = lm('GameType', 'Sports')->select('id','game_name','game_code','game_ico_url')->where('status',1)->get()->toArray();
  627. //获取当前美东时间
  628. $s_time = strtotime($this->commonFunction->qgmdate('Y-m-d H:i:s', '', -4));
  629. $data=[];
  630. foreach ($game as $key=>$item){
  631. if($item['game_code'] !='gj'){
  632. $model = $this->commonFunction->getModels($item['game_code']);
  633. $matchData = lm($model['model_match'], 'Sports')
  634. ->select('id as match_id','home_team','guest_team','match_time','us_time')
  635. ->where($where)
  636. ->orderBy('match_time','asc')
  637. ->get()->toArray();
  638. $matchNum = count($matchData);
  639. $matchData = array_slice($matchData,0,6);
  640. foreach ($matchData as $key1 => $item1){
  641. //获取等待时间
  642. $wait_time = ceil(((strtotime($item1['us_time']))-$s_time)/60);
  643. $matchData[$key1]['wait_time'] = $wait_time;
  644. }
  645. if($matchNum > 0){
  646. $data[$item['game_code']]['matchData'] = $matchData;
  647. $data[$item['game_code']]['matchNum'] = $matchNum;
  648. $data[$item['game_code']]['gameName'] = $item['game_name'];
  649. $data[$item['game_code']]['gameCode'] = $item['game_code'];
  650. }
  651. }
  652. }
  653. return $data;
  654. }
  655. /**
  656. * 获取欧冠 各状态赛事数据
  657. */
  658. public function getUEFAChampions($source){
  659. //根据搜索查询
  660. if(!empty($_GET['search'])){
  661. $search = $_GET['search'];
  662. }
  663. $model = $this->commonFunction->getModels('gj',1);
  664. $model_league = $model['model_league'];
  665. $leagueData = lm($model_league,'Sports')
  666. ->select('name_chinese','id as lg_id','last_time')
  667. ->where($model_league.'.name_chinese','欧洲冠军杯')
  668. ->first();
  669. //获取滚球数据
  670. $StRollBall = $this->getUEFAStRollBall($model,'StRollBall',$source,$leagueData->lg_id,$search);
  671. //获取今日数据
  672. $StToday = $this->getUEFAStToday($model,'StToday',$source,$leagueData->lg_id,$search);
  673. //获取早盘数据
  674. $StMorningPlate = $this->getUEFAStMorningPlate($model,'StMorningPlate',$source,$leagueData->lg_id,$search);
  675. //获取冠军盘口数据
  676. $StChampion = $this->getUEFAStChampion($model,'StChampion',$source,$leagueData->lg_id,$leagueData->last_time);
  677. $data = [
  678. 'lg_id' => $leagueData->lg_id,
  679. 'leagueName'=> $leagueData->name_chinese,
  680. 'StRollBall'=>[//滚球数据
  681. 'typeName'=>'滚球',
  682. 'matchNum'=>count($StRollBall),
  683. 'matchData'=>$StRollBall
  684. ],
  685. 'StToday'=>[//今日数据
  686. 'typeName'=>'今日',
  687. 'matchNum'=>count($StToday),
  688. 'matchData'=>$StToday
  689. ],
  690. 'StMorningPlate'=>[//早盘数据
  691. 'typeName'=>'早盘',
  692. 'matchNum'=>count($StMorningPlate),
  693. 'matchData'=>$StMorningPlate
  694. ],
  695. 'StChampion'=>[//冠军盘口
  696. 'typeName'=>'冠军盘口',
  697. 'matchNum'=>count($StChampion),
  698. 'matchData'=>$StChampion
  699. ]
  700. ];
  701. return $data;
  702. }
  703. /**
  704. * 获取欧冠 滚球数据
  705. */
  706. public function getUEFAStRollBall($model,$type_code,$source,$lg_id,$search=''){
  707. $model_match = $model['model_match'];
  708. $model_odds = $model['model_odds'];
  709. $model_result = $model['model_result'];
  710. $where = $this->commonFunction->getState($type_code,$model_match);
  711. $matchData = lm($model_match,"Sports")
  712. ->leftjoin($model_result,$model_result.'.match_id',$model_match.'.id')
  713. ->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')
  714. ->where($model_match.'.lg_id',$lg_id)
  715. ->where($where)
  716. ->where(function($query)use ($model_match,$search){
  717. $query->where($model_match.'.home_team','like','%'.$search.'%')
  718. ->orWhere(function($query)use ($model_match,$search) {
  719. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  720. });
  721. })
  722. ->get()
  723. ->toarray();
  724. //获取赛事id
  725. $match_ids = [];
  726. foreach ($matchData as $k => $v){
  727. $match_ids[] = $v['match_id'];
  728. }
  729. //获取赛事下滚球默认赔率
  730. $oddsData = ZQoddsModel::getMatchOdds($source,$model,$match_ids);
  731. foreach ($matchData as $k=>$v){
  732. //获取赛事下赔率并且分组
  733. $capot = [];
  734. $concede_size = [];
  735. foreach ($oddsData as $kk=>$vv){
  736. if ($vv['match_id'] == $v['match_id'] and $vv['sort']==0) {
  737. if($vv['p_code'] == 'concede_size'){
  738. $concede_size[] = $vv;
  739. }
  740. if($vv['p_code'] == 'capot'){
  741. $capot[] = $vv;
  742. }
  743. }
  744. }
  745. $matchData[$k]['oddsData'] = [$concede_size,$capot];
  746. }
  747. return $matchData;
  748. }
  749. /**
  750. * 获取欧冠 今日数据
  751. */
  752. public function getUEFAStToday($model,$type_code,$source,$lg_id,$search=''){
  753. $model_match = $model['model_match'];
  754. $model_odds = $model['model_odds'];
  755. $where = $this->commonFunction->getState($type_code);
  756. $matchData = lm($model_match,'Sports')
  757. ->select('id as match_id','match_date','match_time','tag','home_team','guest_team')
  758. ->where($where)
  759. ->where('lg_id',$lg_id)
  760. ->where(function($query)use ($model_match,$search){
  761. $query->where($model_match.'.home_team','like','%'.$search.'%')
  762. ->orWhere(function($query)use ($model_match,$search) {
  763. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  764. });
  765. })
  766. ->get()->toArray();
  767. //获取赛事id
  768. $match_ids = [];
  769. foreach ($matchData as $k => $v){
  770. $match_ids[] = $v['match_id'];
  771. }
  772. //获取赔率数据
  773. $oddsData = lm($model_odds, "Sports")
  774. ->select( 'id','p_code', 'odds_code','odds_only','status', 'odds', 'condition', 'sort','match_id')
  775. ->whereIn('match_id', $match_ids)
  776. ->groupBy($model_odds . '.id','p_code', 'odds_code','odds_only', $model_odds . '.status', 'odds', 'condition', 'sort','match_id')
  777. ->orderBy($model_odds . '.id','desc')
  778. ->get()
  779. ->toarray();
  780. foreach ($matchData as $k=>$v){
  781. foreach ($oddsData as $kk=>$vv){
  782. if($v['match_id'] == $vv['match_id']){
  783. $matchData[$k]['oddsData'][] = $vv;
  784. }
  785. }
  786. }
  787. return $matchData;
  788. }
  789. /**
  790. * 获取欧冠 早盘数据
  791. */
  792. public function getUEFAStMorningPlate($model,$type_code,$source,$lg_id,$search=''){
  793. $model_match = $model['model_match'];
  794. $model_odds = $model['model_odds'];
  795. $where = $this->commonFunction->getState($type_code);
  796. $matchData = lm($model_match,'Sports')
  797. ->select('id as match_id','match_date','match_time','tag','home_team','guest_team')
  798. ->where($where)
  799. ->where('lg_id',$lg_id)
  800. ->where(function($query)use ($model_match,$search){
  801. $query->where($model_match.'.home_team','like','%'.$search.'%')
  802. ->orWhere(function($query)use ($model_match,$search) {
  803. $query->where($model_match . '.guest_team', 'like', '%' . $search . '%');
  804. });
  805. })
  806. ->get()->toArray();
  807. $data = $this->getOddsData->getOddsZQ($matchData,$model_odds,$source,[]);
  808. return $data;
  809. }
  810. /**
  811. * 获取 欧冠 冠军盘口数据
  812. */
  813. public function getUEFAStChampion($model,$type_code,$source,$lg_id,$last_time=''){
  814. $model_odds = $model['model_odds'];
  815. $where = $this->commonFunction->getState($type_code);
  816. $championData = lm($model_odds, 'Sports')
  817. ->select("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  818. ->where('lg_id',$lg_id)
  819. ->where($where)
  820. ->groupBy("id","lg_id","match_id","p_code","odds_code","team","odds","sort","status","odds_only")
  821. ->get()->toArray();
  822. //按p_code分组
  823. $p_code=array();
  824. foreach($championData as $k=>$v){
  825. $p_code[$v['p_code']][]=$v;
  826. }
  827. $data = [];
  828. foreach ($p_code as $k1=>$v1){
  829. foreach ($v1 as $k2=>$v2){
  830. $data[$v2['p_code']]['last_time'] =$last_time;
  831. $data[$v2['p_code']][$v2['odds_code']][] = $v2;
  832. }
  833. }
  834. return $data;
  835. }
  836. }