Betorder.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985
  1. <?php
  2. namespace App\Api\Controller;
  3. use Biz\Money\Moneycopy;
  4. use Biz\Money\Money;
  5. use Biz\Account\AccountManager;
  6. use App\Api\Model\St_odds_code as odds_codeModel;
  7. use App\Api\Model\Dc_user_grade;
  8. /*
  9. * Class Register
  10. * @package App\Api\Controller
  11. * User: junghwi
  12. * Date: 2019/3/21
  13. */
  14. class Betorder extends BaseController{
  15. private $simplex_money = 0; //单式投注总额
  16. public function init() {
  17. $this->time = date('Y-m-d H:i:s',time());
  18. $this->MC = new Moneycopy();
  19. $this->M = new Money();
  20. $this->accountManager = new AccountManager();
  21. $this->commonFunction = C()->get('commonFunction');
  22. }
  23. /**
  24. * 单式串式分类
  25. * @param [array] $res 投注数据
  26. * @return [array] $data
  27. *
  28. */
  29. public function Classify(array $res){
  30. if(empty($res)){
  31. Render($res, '7003',lang('Errors','Api')->get('error-7003'));
  32. }
  33. $data['single'] = [];//单式
  34. $data['bunch'] = [];//串式
  35. $last[] = $res[count($res)-1];
  36. unset($res[count($res)-1]);
  37. foreach ($last as $k =>$v){
  38. foreach ($v as $kk =>$vv){
  39. /*
  40. $num = $kk+1;
  41. //验证球类代码是否有效
  42. $this->verify_gameType($vv['ballId'],$num);
  43. //验证联赛是否存在
  44. $this->verify_league($vv['ballId'],(int)$vv['lg_id'],$num);
  45. //验证赛事/赔率代码是否存在,如果match_id = 0 则为冠军联赛赔率,无需验证
  46. if($vv['match_id'] > 0 and $vv['is_champion'] == 0){
  47. $this->verify_match($vv['ballId'],$vv['match_id'],$num);
  48. //验证赛事下赔率玩法是否有效
  49. $this->verify_odds($vv['ballId'],$vv['odds_only'],$vv['odds'],$vv['condition'],$vv['odds_code'],$num);
  50. }
  51. */
  52. }
  53. }
  54. foreach($res as $k => $v){
  55. //根据类型分组
  56. if($v['type'] == '1'){
  57. $data['single'][$k] = array_merge($last[0][$v['index']],$v);
  58. }else{
  59. $data['bunch'][$k] = $v;
  60. }
  61. }
  62. if(!empty($data['bunch'])){
  63. $data['bunch'] = array_merge_recursive($data['bunch'],$last);
  64. }
  65. return $data;
  66. }
  67. /**
  68. * 根据赛事ID分组
  69. * @param [array] $data 球类数据
  70. * @return [array] $data
  71. */
  72. public function Group_ball($data = []){
  73. if(empty($data)){
  74. return $data;
  75. }
  76. foreach($data as $k => $v){
  77. //普通赛事
  78. if($v['match_id'] > 0){
  79. if(!isset($data[$v['match_id']])){
  80. $data[$v['match_id']][] = $v;
  81. unset($data[$k]);
  82. }else{
  83. $data[$v['match_id']][] = $v;
  84. unset($data[$k]);
  85. }
  86. }
  87. //冠军联赛
  88. if($v['match_id'] == 0){
  89. if(!isset($data[$v['lg_id']])){
  90. $data[$v['lg_id']][] = $v;
  91. unset($data[$k]);
  92. }else{
  93. $data[$v['lg_id']][] = $v;
  94. unset($data[$k]);
  95. }
  96. }
  97. }
  98. return $data;
  99. }
  100. /**
  101. * 单式投注数据处理
  102. * @param [array] $res 单式投注数据
  103. * @return [int] 1 成功 其他失败
  104. * @param [int] $batch_id 批量ID
  105. */
  106. public function Simplex_bet(array $res,array $userInfo,$batch_id){
  107. if(empty($res)||empty($userInfo)||empty($batch_id)){
  108. Render('', '7003',lang('Errors','Api')->get('error-7003'));
  109. }
  110. //验证与判断投注了几种
  111. foreach($res as $k => $v){
  112. $num = $k + 1;
  113. if(empty($v['bet_amount'])){
  114. $msg = '第'.$num.'条'.lang('Errors','Api')->get('error-5105');
  115. Render([], '5105',$msg);
  116. }
  117. //根据类型分组
  118. if(!isset($res[$v['ballId']])){
  119. $res[$v['ballId']][] = $v;
  120. unset($res[$k]);
  121. }else{
  122. $res[$v['ballId']][] = $v;
  123. unset($res[$k]);
  124. }
  125. }
  126. //球类联赛分类并且插入数据库
  127. $odds_ids = [];
  128. foreach($res as $k => $v){
  129. $gamedate = $this->Group_ball($res[$k]);
  130. $odds_ids[] = $this->Simplex_bet_insert($gamedate,$userInfo,$k,$batch_id);
  131. }
  132. return $odds_ids;
  133. }
  134. /**
  135. * 单式投注单个球类数据插入
  136. * @param [array] $data 单式投注数据
  137. * @param [array] $userInfo 用户信息
  138. * @param [type] $game_code 球类代码
  139. * @param [int] $batch_id 批量ID
  140. * @return [int] 1 成功 其他失败
  141. */
  142. public function Simplex_bet_insert__($data,$userInfo,$game_code,$batch_id){
  143. if(empty($data)||empty($userInfo)||empty($game_code)){
  144. Render('', '7003',lang('Errors','Api')->get('error-7003'));
  145. }
  146. foreach($data as $k => $v){
  147. $OrderID = OrderID('S');//生成订单ID
  148. $UUID = UUID(); //生成信息ID
  149. $bet_money = 0; //赛事总投注额
  150. $prize_money = 0; //可赢额
  151. //获取投注单中是否有冠军联赛数据
  152. $championData = [];
  153. foreach($v as $kk => $vv){
  154. $bet_money += $vv['bet_amount'];
  155. //计算每个投注玩法下的可赢金额
  156. // $prize_money += $this->commonFunction->getEarnMoney($game_code,$vv['p_code'],$vv['odds'],$vv['bet_amount'],1);
  157. $prize_money += $vv['odds']* $vv['bet_amount'];
  158. //是否是滚球投注
  159. $is_rolling = 0;
  160. if($vv['oddsType']=='StRollBall'){
  161. $is_rolling = 1;
  162. }
  163. $matchData =[
  164. 'odds_id' =>$vv['id'],
  165. 'home_team' => $vv['home_team'],
  166. 'guest_team' => $vv['guest_team'],
  167. 'condition' => $vv['condition'],
  168. 'odds' => $vv['odds'],
  169. 'odds_code' => $vv['odds_code'],
  170. 'p_code' => $vv['p_code'],
  171. 'odds_only' => $vv['odds_only'],
  172. 'match_id' => $vv['match_id'],
  173. 'game_code' => $game_code,
  174. 'lg_id' => $vv['lg_id'],
  175. 'batch_id' => $batch_id,
  176. 'bet_type' => 1,
  177. 'bet_money' => $vv['bet_amount'],
  178. 'ctime' => $this->time,
  179. 'utime' => $this->time,
  180. 'is_rolling' =>$is_rolling,
  181. ];
  182. //插入数据源
  183. $moneyBuyMatch = lm('MoneyBuyMatch','Api')->insert($matchData);
  184. if(!$moneyBuyMatch){
  185. Render('','3205',lang('errors','Api')->get('error-3205'));
  186. }
  187. }
  188. $order =[
  189. 'info_identity' => $UUID,
  190. 'account_name' => $userInfo['account'],
  191. 'account_identity' => $userInfo['account_identity'],
  192. 'order_id' => OrderID('S'),//$OrderID,
  193. 'game_code' => $game_code,
  194. 'batch_id' => $batch_id,
  195. 'match_id' => $k,
  196. 'game_no' => "",
  197. 'prize_money'=> $prize_money,
  198. 'money' => $bet_money, //投注金额
  199. 'money_time' => $this->time
  200. ];
  201. $insert = lm("MoneyBuySimplex",'Api')->insert($order);
  202. if(!$insert){
  203. Render('','3205',lang('errors','Api')->get('error-3205'));
  204. }
  205. $insertMoney = $this->M->insertMoney($userInfo['account_identity'],$bet_money,$OrderID,1,"",$UUID,$userInfo);
  206. if($insertMoney!=1){
  207. Render('', $insertMoney,lang('Errors','Api')->get('error'.$insertMoney));
  208. }
  209. $this->M->fanshui($userInfo['account_identity'],$userInfo['account'],$bet_money,$OrderID);//反水
  210. }
  211. }
  212. public function Simplex_bet_insert($data,$userInfo,$game_code,$batch_id){
  213. if(empty($data)||empty($userInfo)||empty($game_code)){
  214. Render('', '7003',lang('Errors','Api')->get('error-7003'));
  215. }
  216. //回调订单id
  217. $odds_ids = [];
  218. foreach($data as $k => $v){
  219. $OrderID = OrderID('S');//生成订单ID
  220. $UUID = UUID(); //生成信息ID
  221. $bet_money = 0; //赛事总投注额
  222. $prize_money = 0; //可赢额
  223. foreach($v as $kk => $vv){
  224. //是否是冠军投注,如果==0 则为冠军投注
  225. $is_champion = 0;
  226. if($vv['match_id'] == 0){
  227. $is_champion = 1;
  228. }
  229. //获取联赛id lg_id
  230. $lg_id = $vv['lg_id'];
  231. $bet_money += $vv['bet_amount'];
  232. //计算每个投注玩法下的可赢金额
  233. // $prize_money += $this->commonFunction->getEarnMoney($game_code,$vv['p_code'],$vv['odds'],$vv['bet_amount'],1);
  234. $prize_money += $vv['odds']* $vv['bet_amount'];
  235. //是否是滚球投注
  236. $is_rolling = 0;
  237. if($vv['oddsType']=='StRollBall'){
  238. $is_rolling = 1;
  239. }
  240. $matchData =[
  241. 'odds_id' =>$vv['id'],
  242. 'home_team' => $vv['home_team'],
  243. 'guest_team' => $vv['guest_team'],
  244. 'condition' => $vv['condition'],
  245. 'odds' => $vv['odds'],
  246. 'odds_code' => $vv['odds_code'],
  247. 'p_code' => $vv['p_code'],
  248. 'odds_only' => $vv['odds_only'],
  249. 'match_id' => $vv['match_id'],
  250. 'game_code' => $game_code,
  251. 'lg_id' => $vv['lg_id'],
  252. 'batch_id' => $batch_id,
  253. 'bet_type' => 1,
  254. 'bet_money' => $vv['bet_amount'],
  255. 'ctime' => $this->time,
  256. 'utime' => $this->time,
  257. 'is_rolling' =>$is_rolling,
  258. 'is_champion' => $is_champion?:0,//1 冠军投注 0普通赛事投注
  259. 'order_id'=>$OrderID,//追加所属订单id
  260. ];
  261. //插入数据源
  262. $moneyBuyMatch = lm('MoneyBuyMatch','Api')->insert($matchData);
  263. if(!$moneyBuyMatch){
  264. Render('','3205',lang('errors','Api')->get('error-3205'));
  265. }
  266. }
  267. $order = [];
  268. $order =[
  269. 'info_identity' => $UUID,
  270. 'account_name' => $userInfo['account'],
  271. 'account_identity' => $userInfo['account_identity'],
  272. 'order_id' => $OrderID,//$OrderID,
  273. 'game_code' => $game_code,
  274. 'batch_id' => $batch_id,
  275. 'match_id' => $k,
  276. 'lg_id' => $lg_id,
  277. 'game_no' => "",
  278. 'prize_money'=> $prize_money,
  279. 'money' => $bet_money, //投注金额
  280. 'money_time' => $this->time,
  281. 'is_champion' => $is_champion?:0,//1 冠军投注 0普通赛事投注
  282. ];
  283. //如果是冠军投注,追加字段
  284. if($is_champion == 1){
  285. $json_single_result = [
  286. 'lg_id'=> '',
  287. 'game_name' => '',
  288. 'result' => '',
  289. 'updatetime' => '',
  290. ];
  291. $order['single_result'] = json_encode($json_single_result);
  292. }
  293. //如果是滚球投注,追加字段
  294. if($is_rolling == 1){
  295. $order['roll_ratify'] = 2;//未审核滚球投注
  296. }
  297. $insert = lm("MoneyBuySimplex",'Api')->insert($order);
  298. if(!$insert){
  299. Render('','3205',lang('errors','Api')->get('error-3205'));
  300. }
  301. $insertMoney = $this->M->insertMoney($userInfo['account_identity'],$bet_money,$OrderID,1,"",$UUID,$userInfo);
  302. if($insertMoney!=1){
  303. Render('', $insertMoney,lang('Errors','Api')->get('error'.$insertMoney));
  304. }
  305. $this->M->fanshui($userInfo['account_identity'],$userInfo['account'],$bet_money,$OrderID);//反水
  306. if($is_rolling == 1){
  307. $odds_ids[] = $OrderID;
  308. }
  309. }
  310. return $odds_ids;
  311. }
  312. public function Bet(){
  313. /*
  314. // 模拟单式数据
  315. $get_data = [
  316. 'data'=>[
  317. [
  318. 'type'=>1,
  319. 'index'=>0,
  320. 'bet_amount'=>100,
  321. ],
  322. [
  323. 'type'=>1,
  324. 'index'=>1,
  325. 'bet_amount'=>200,
  326. ],
  327. [
  328. [
  329. 'id'=>226063,
  330. 'home_team'=>'内蒙古草上飞',
  331. 'guest_team'=>'吉林百嘉',
  332. 'name'=>'内蒙古草上飞',
  333. 'odds'=>0.81,
  334. 'match_id'=>0,
  335. 'condition'=>'0.5/1',
  336. 'ballId'=>'zq',
  337. 'odds_code'=>'concede_home',
  338. 'p_code'=>'concede',
  339. 'play_name'=>'让球',
  340. 'score'=>0,
  341. 'bettingTime'=>date('Y-m-d H:i:s',time()),
  342. 'odds_only'=>'272af2647b112b7eb337a2ed16753c6f',
  343. 'lg_id'=>29,
  344. 'repeat'=>'false',
  345. 'match_type'=>'StRollBall',//滚球投注
  346. // 'is_champion'=>1,//是否是冠军联赛
  347. ],
  348. [
  349. 'id'=>2260632,
  350. 'home_team'=>'内蒙古草上飞1',
  351. 'guest_team'=>'吉林百嘉2',
  352. 'name'=>'内蒙古草上飞',
  353. 'odds'=>0.81,
  354. 'match_id'=>1249,
  355. 'condition'=>'0.5/1',
  356. 'ballId'=>'zq',
  357. 'odds_code'=>'concede_home',
  358. 'p_code'=>'concede',
  359. 'play_name'=>'让球',
  360. 'score'=>0,
  361. 'bettingTime'=>date('Y-m-d H:i:s',time()),
  362. 'odds_only'=>'272af2647b112b7eb337a2ed16753c6f1',
  363. 'lg_id'=>29,
  364. 'repeat'=>'false',
  365. 'match_type'=>'StRollBall',//滚球投注
  366. 'is_champion'=>0,//是否是冠军联赛
  367. ],
  368. ]
  369. ],
  370. 'token'=>'mKoaQr15712941335da80bb5beb4e',
  371. 'bet_money'=>900,
  372. 'bet_money_arr'=>[100,200,300],
  373. ];
  374. /*
  375. // 模拟串式数据
  376. $get_data = [
  377. 'data'=>[
  378. [
  379. 'type'=>1,
  380. 'index'=>0,
  381. 'bet_amount'=>1,
  382. ],
  383. [
  384. 'type'=>'3串1',
  385. 'bet_amount' =>1,
  386. ],
  387. [
  388. [
  389. 'id'=>229351,
  390. 'home_team'=>'布琳狮子U20',
  391. 'guest_team'=>'圣奥尔本斯U20',
  392. 'name'=>'圣奥尔本斯U20',
  393. 'odds'=>1.01,
  394. 'match_id'=>0,
  395. 'condition'=>'4/4.5',
  396. 'ballId'=>'zq',
  397. 'odds_code'=>'goal_size_big',
  398. 'p_code'=>'goal_size',
  399. 'play_name'=>'大小',
  400. 'score'=>0,
  401. 'bettingTime'=>date('Y-m-d H:i:s',time()),
  402. 'odds_only'=>'908f8bae2233a0384c96c7b1f42e9ea7',
  403. 'lg_id'=>153,
  404. 'repeat'=>'false',
  405. 'match_type'=>'StRollBall',//滚球投注
  406. ],
  407. [
  408. 'id'=>238940,
  409. 'home_team'=>'格罗兹尼艾哈迈德U20',
  410. 'guest_team'=>'奥伦堡U20',
  411. 'name'=>'格罗兹尼艾哈迈德U20',
  412. 'odds'=>0.94,
  413. 'match_id'=>1247,
  414. 'condition'=>'1/1.5',
  415. 'ballId'=>'zq',
  416. 'odds_code'=>'concede_home',
  417. 'p_code'=>'concede',
  418. 'play_name'=>'让球',
  419. 'score'=>0,
  420. 'bettingTime'=>date('Y-m-d H:i:s',time()),
  421. 'odds_only'=>'9125bf40d6649fcdb663c43d8f55bebd',
  422. 'lg_id'=>20,
  423. 'repeat'=>'false',
  424. 'match_type'=>'StRollBall',//滚球投注
  425. ],
  426. [
  427. 'id'=>238958,
  428. 'home_team'=>'巴扬卡拉',
  429. 'guest_team'=>'马都拉联',
  430. 'name'=>'巴扬卡拉',
  431. 'odds'=>1.13,
  432. 'match_id'=>1254,
  433. 'condition'=>'0.5',
  434. 'ballId'=>'zq',
  435. 'odds_code'=>'concede_home',
  436. 'p_code'=>'concede',
  437. 'play_name'=>'让球',
  438. 'score'=>0,
  439. 'bettingTime'=>date('Y-m-d H:i:s',time()),
  440. 'odds_only'=>'3cf81ac0b9765218845fe8bc4de0ad99',
  441. 'lg_id'=>61,
  442. 'repeat'=>'false',
  443. 'match_type'=>'StRollBall',//滚球投注
  444. ],
  445. ]
  446. ],
  447. 'token'=>'ppWGRW15682541865d79a8eacb0b1',
  448. 'bet_money'=>2
  449. ];
  450. */
  451. //如果获取不到data,则为游戏端提交,需转成数组
  452. if(!empty($_POST['game_data'])){
  453. //获取参数转成数组
  454. $get_data = json_decode($_POST['game_data'],true);
  455. $token = $get_data['token'];
  456. $bet_money = $get_data['bet_money'];
  457. $data = $get_data['data'];
  458. // $bet_money_arr = $get_data['bet_money_arr'];
  459. }else{
  460. $data = $_REQUEST['data'];
  461. $bet_money = $_REQUEST['bet_money'];
  462. $token = $_REQUEST['token'];
  463. // $bet_money_arr = $_REQUEST['bet_money_arr'];
  464. }
  465. /*
  466. $data = $get_data['data'];
  467. $bet_money = $get_data['bet_money'];
  468. $token = $get_data['token'];
  469. */
  470. //验证用户token
  471. $userInfo = $this->getAgent($token);
  472. if(empty($data)||empty($bet_money)){
  473. Render('', '51029',lang('Errors','Api')->get('error-51029'));
  474. }
  475. //获取用户金额信息
  476. if(!$this->M->verifyMoney($bet_money,$userInfo['cash'])){
  477. Render('', '4204',lang('Errors','Api')->get('error-4204'));
  478. }
  479. //追加验证用户投注金额限额
  480. $this->bet_money_limit($data,$userInfo);
  481. //获取订单批次号
  482. $batch_id = OrderID();///strtotime(date('Y-m-d H:i:s',time())).mt_rand('1','99');//批量ID
  483. //执行数据插入
  484. try {
  485. _beginTransaction();//开启事务
  486. $data = $this->Classify($data);
  487. if(!empty($data['single'])){
  488. $odds_ids = $this->Simplex_bet($data['single'],$userInfo,$batch_id);//单式数据处理
  489. }
  490. if(!empty($data['bunch'])){
  491. $data_all = $data['bunch'][count($data['bunch'])-1];//获取最后一个数组
  492. unset($data['bunch'][count($data['bunch'])-1]);//删除最后一个元素
  493. $this->stringBet($data['bunch'],$data_all,$userInfo,$batch_id);
  494. }
  495. _commit();//提交
  496. Render('', '1',lang('Errors','Api')->get('error-1'));
  497. //延时处理滚球投注
  498. $this->Handle($odds_ids);
  499. } catch (Exception $e) {
  500. _rollBack();//回滚
  501. print $e->getMessage();
  502. }
  503. }
  504. /**
  505. * 追加滚球投注 延时处理审核
  506. */
  507. public function Handle($odds_ids = []){
  508. $size = ob_get_length();
  509. header("Content-Length: $size");
  510. header('Connection: close');
  511. header("HTTP/1.1 200 OK");
  512. header("Content-Type: application/json;charset=utf-8");
  513. ob_end_flush();
  514. if(ob_get_length())
  515. ob_flush();
  516. flush();
  517. if (function_exists("fastcgi_finish_request")) { // yii或yaf默认不会立即输出,加上此句即可(前提是用的fpm)
  518. fastcgi_finish_request(); // 响应完成, 立即返回到前端,关闭连接
  519. }
  520. ignore_user_abort(true);//在关闭连接后,继续运行php脚本
  521. set_time_limit(0); //no time limit,不设置超时时间(根据实际情况使用)
  522. //继续运行的代码
  523. sleep(20);//等待20秒后执行
  524. file_put_contents("test.txt", "This is something.");
  525. }
  526. /**
  527. * token获取用户详情
  528. */
  529. public function getAgent($token = '') {
  530. $checkToken = $this->accountManager->checkEffectiveTime($token);
  531. if ($checkToken['status'] != 1) {
  532. Render($checkToken['data'], $checkToken['status'], lang('commons')->get('user does login'));
  533. };
  534. $result = $this->accountManager->refreshToken($token);
  535. return $result['data'];
  536. }
  537. //验证联赛是否存在
  538. public function verify_league($game_code,$lg_id,$num = 1){
  539. if(empty($lg_id)){
  540. $msg = '第'.$num.'条'.lang('Errors','Api')->get('error-5112');
  541. Render([], '5112',$msg);
  542. }
  543. //根据球类代码 获取相关model
  544. $model = $this->commonFunction->getModels($game_code);
  545. $model_league = $model['model_league'];
  546. $info = lm($model_league,'Sports')
  547. ->select('id')
  548. ->where('id',$lg_id)
  549. ->first();
  550. if(empty($info)){
  551. $msg = '第'.$num.'条'.lang('Errors','Api')->get('error-5113');
  552. Render([], '5113',$msg);
  553. }
  554. }
  555. /**
  556. * 赛事是否存在或结束
  557. * @param [type] $game_code 球类代码
  558. * @param [type] $match_id 赔率ID
  559. * @param [type] $num 循环键值
  560. * $@param [type]type_str 串式
  561. *
  562. */
  563. public function verify_match($game_code,$match_id,$num = 1){
  564. if(empty($match_id)){
  565. $msg = '第'.$num.'条'.lang('Errors','Api')->get('error-5109');
  566. Render([], '5109',$msg);
  567. }
  568. //根据球类代码 获取相关model
  569. $models = $this->commonFunction->getModels($game_code);
  570. $model_match = $models['model_match'];
  571. $info = lm($model_match,'Sports')
  572. ->select('status')
  573. ->where('status', '<', '2')
  574. // ->where('us_time','>',qgmdate('Y-m-d H:i:s','', -4))
  575. // ->where('source','hg3535')
  576. ->where('id',$match_id)
  577. ->first();
  578. if(empty($info)){
  579. $msg = '第'.$num.'条'.lang('Errors','Api')->get('error-5103');
  580. Render([], '5103',$msg);
  581. }
  582. $info = $info->toarray();
  583. if($info['status'] == 2){
  584. $msg = '第'.$num.'条'.lang('Errors','Api')->get('error-5108');
  585. Render([], '5108',$msg);
  586. }
  587. return $info;
  588. }
  589. /**
  590. * 验证球类是否存在
  591. * @param [type] $game_code 球类代码
  592. * @param [type] $num 第几条
  593. */
  594. public function verify_gameType($game_code,$num){
  595. if(empty($game_code)){
  596. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-5102');
  597. Render([], '5102', $msg);
  598. }
  599. $info = lm('GameType','Sports')->where('game_code',$game_code)->first();
  600. if(empty($info)){
  601. $msg = '第' . $num . '条数据' . lang('Errors', 'Api')->get('error-5102');
  602. Render([], '5102', $msg);
  603. }
  604. return $info;
  605. }
  606. /**
  607. * 验证赔率是否存在
  608. * @param [type] $game_code 球类代码
  609. * @param [type] $odds_id 赔率IDkk
  610. *
  611. */
  612. public function verify_odds($game_code,$odds_only,$odds,$condition,$odds_code,$num = 1){
  613. if (empty($odds_only)){
  614. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-5111');
  615. Render([], '5111', $msg);
  616. }
  617. if(empty($odds_code)){
  618. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-7052');
  619. Render([], '7052', $msg);
  620. }
  621. if(empty($odds)){
  622. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-7029');
  623. Render([], '7029', $msg);
  624. }
  625. $odds_codeNum = odds_codeModel::getOddsCode($odds_code,$game_code);
  626. if($odds_codeNum < 1){
  627. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-7053');
  628. Render([], '7053', $msg);
  629. }
  630. //根据球类代码 获取相关model
  631. $models = $this->commonFunction->getModels($game_code);
  632. $model_odds = $models['model_odds'];
  633. $model_odds_record = $models['model_odds_record'];
  634. //匹配赔率是否过期
  635. $odds_info = lm($model_odds,'Sports')
  636. ->join($model_odds_record,$model_odds_record.'.odds_only',$model_odds.'.odds_only')
  637. ->select($model_odds_record.'.odds',$model_odds_record.'.condition')
  638. ->where($model_odds.'.odds_only',$odds_only)
  639. ->first();
  640. if(empty($odds_info)){
  641. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-7051');
  642. Render([], '7051', $msg);
  643. }
  644. $odds_info = $odds_info->toarray();
  645. if($condition != $odds_info['condition']){
  646. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-7047');
  647. Render([], '7047', $msg);
  648. }
  649. if($odds != $odds_info['odds']){
  650. $msg = '第'.$num.'条数据'.lang('Errors','Api')->get('error-7049');
  651. Render([], '7049', $msg);
  652. }
  653. return $odds_info;
  654. }
  655. /**
  656. * 处理串式投注
  657. * $data_str 各串式 数据
  658. * $data_all 所有赛事 数据
  659. * $userInfo 用户数据
  660. * $batch_id 批次号
  661. */
  662. public function stringBet($data_str=[],$data_all=[],$userInfo=[],$batch_id=0){
  663. //验证串式投注是否合法
  664. $this->verify_stringType($data_all);
  665. //获取串式 总赛事数量
  666. $groupNum = count($data_all);//总数量
  667. $orderData = [];
  668. foreach ($data_str as $k=>$v){
  669. //字符串替换
  670. $str = str_ireplace("串","_",$v['type']);
  671. //获取type 3_12
  672. $after = substr($str,strpos($str,"_")+1);
  673. //当前串式 值
  674. $sonNum = substr($str,0,strrpos($str,"_"));
  675. //获取倍数
  676. if((int)$after == 1){
  677. $multiple = $this->getMultiple($groupNum,(int)$sonNum);
  678. }else{
  679. $multiple =(int)$after;
  680. }
  681. //获取当前串式投注金额及可赢金额
  682. if($after == 1){
  683. $money_all = $this->getmakeMoney((int)$sonNum,$v['bet_amount'],$multiple,$data_all,$after);
  684. }else{
  685. $money_all = $this->getStrAllMoney((int)$sonNum,$v['bet_amount'],$multiple,$data_all,$after);
  686. }
  687. //投注金额
  688. $moneyData = $money_all['moneyData'];
  689. //可赢金额
  690. $prize_money = $money_all['prize_money'];
  691. $uuid = UUID();
  692. $orderID = OrderID('T');
  693. $orderData[$k]['info_identity'] = $uuid;
  694. $orderData[$k]['account_name'] = $userInfo['account'];
  695. $orderData[$k]['account_identity'] = $userInfo['account_identity'];
  696. $orderData[$k]['order_id'] = $orderID;
  697. $orderData[$k]['game_no'] = "";
  698. $orderData[$k]['money'] = $moneyData;//$pay_money//总投注金额
  699. $orderData[$k]['money_time'] = $this->time;//下注时间
  700. $orderData[$k]['prize_money'] = $prize_money;//$expect_money ;//预期总可赢金额
  701. $orderData[$k]['str_type'] = $v['type'];//串式类型
  702. $orderData[$k]['batch_id'] = $batch_id;//批次号
  703. $orderData[$k]['wait_match_num'] = count($data_all);//批次号
  704. //写资金变动表
  705. $insertMoney = $this->M->insertMoney($userInfo['account_identity'],$moneyData,$orderID,1,"",$uuid,$userInfo);
  706. if($insertMoney!=1){
  707. Render('', $insertMoney,lang('Errors','Api')->get('error'.$insertMoney));
  708. }
  709. $this->M->fanshui($userInfo['account_identity'],$userInfo['account'],$moneyData,$orderID);//反水
  710. }
  711. //写注单 表
  712. $moneyBuy = lm('MoneyBuyStr','Api')->insert($orderData);
  713. if(!$moneyBuy){
  714. Render('','3205',lang('errors','Api')->get('error-3205'));
  715. }
  716. foreach ($data_all as $kk=>$vv){
  717. $getModels = $this->commonFunction->getModels($vv['ballId']);
  718. $model_match = $getModels['model_match'];
  719. //获取是否是滚球投注
  720. $is_rolling = 0;
  721. if($vv['match_type'] == 'StRollBall'){
  722. $is_rolling = 1;
  723. }
  724. $matchData[] = [
  725. 'batch_id'=>$batch_id,
  726. 'odds_id'=>$vv['id'],
  727. 'home_team'=>$vv['home_team'],
  728. 'guest_team'=>$vv['guest_team'],
  729. 'condition'=>$vv['condition'],
  730. 'odds'=>$vv['odds'],
  731. 'odds_code'=>$vv['odds_code'],
  732. 'p_code'=>$vv['p_code'],
  733. 'odds_only'=>$vv['odds_only'],
  734. 'status'=>0,
  735. 'match_id'=>$vv['match_id'],
  736. 'game_code'=>$vv['ballId'],
  737. 'lg_id'=> $vv['lg_id'],
  738. 'ctime'=>$this->time,//写入时间
  739. 'utime' => $this->time,
  740. 'bet_type'=>2,
  741. 'is_rolling'=>$is_rolling,
  742. 'order_id'=> $orderID,
  743. ];
  744. }
  745. //写赔率数据表
  746. $moneyBuyMatch = lm('MoneyBuyMatch','Api')->insert($matchData);
  747. if(!$moneyBuyMatch){
  748. Render('','3205',lang('errors','Api')->get('error-3205'));
  749. }
  750. return true;
  751. }
  752. /**
  753. * 计算串式投注 倍率
  754. * $groupNum 总赛事 数量
  755. * $sonNum 当前串式 数量
  756. */
  757. public function getMultiple($groupNum = 0,$sonNum = 0){
  758. if($groupNum and $sonNum){
  759. $group =1;
  760. for($i = $groupNum ; $i >($groupNum - $sonNum);$i--) {
  761. $group = $group * $i;
  762. }
  763. $son =1;
  764. for($i = $sonNum ; $i >0;$i--) {
  765. $son = $son * $i;
  766. }
  767. }
  768. return $group/$son;
  769. }
  770. /**
  771. * @param int $sonNum 当前串式数量
  772. * @param int $bet_amount 当前串式投注额
  773. * @param int $multiple 当前串式倍数
  774. * @param array $data_all 当前注单 所有投注数据
  775. * @return mixed
  776. * 计算当前串式投注总额、可赢总额
  777. */
  778. public function getmakeMoney($sonNum=0,$bet_amount=0,$multiple=0,$data_all=[],$after = 0){
  779. $allNum = count($data_all);//所有数量
  780. $odds_all = [];//所有投注项数据
  781. foreach ($data_all as $k=>$v){
  782. $odds_all[] = $v['odds']+1;
  783. }
  784. //投注总额
  785. $data['moneyData'] = (double)$bet_amount*(double)$multiple;
  786. if($sonNum == $allNum and (int)$after ==1){//N场赛事 N串一
  787. //获取所有赛事赔率乘积
  788. $odds = array_product($odds_all) - 1;
  789. //获取可赢金额
  790. $data['prize_money'] = sprintf("%.2f",substr(sprintf("%.3f", $bet_amount*$odds), 0, -1));//floor($bet_amount*$odds*100)/100;//保留两位小数
  791. }
  792. if($sonNum < $allNum and (int)$after ==1){//例:N场赛事 <N串一
  793. //计算 组合赔率
  794. $group = $this->commonFunction->combination($odds_all, $sonNum);
  795. foreach ($group as $k=>$v){
  796. $odds[] = array_product($v);
  797. }
  798. $odds = (array_sum($odds))-(count($odds));
  799. //获取可赢金额
  800. $data['prize_money'] = sprintf("%.2f",substr(sprintf("%.3f", $bet_amount*$odds), 0, -1));//floor($bet_amount*$odds*100)/100;
  801. }
  802. return $data;
  803. }
  804. /**
  805. * 获取所有可用串式 N场赛事 2串1,3串1...N串1,N<11
  806. * 并计算 其投注可赢金额
  807. */
  808. public function getStrAllMoney($sonNum=0,$bet_amount=0,$multiple=0,$data_all=[],$after = 0){
  809. $d = [];
  810. for ($i=2;$i<($sonNum+1);$i++){
  811. $d[] = $i;
  812. }
  813. foreach ($d as $k=>$v){
  814. $multiple = $this->getMultiple($sonNum,$v);
  815. $money[] = $this->getmakeMoney($v,$bet_amount,$multiple,$data_all,1);
  816. }
  817. $data=array();
  818. foreach($money as $k=>$v){
  819. $data['moneyData']+=$v['moneyData'];
  820. $data['prize_money']+=$v['prize_money'];
  821. }
  822. return $data;
  823. }
  824. /**
  825. * 验证串式投注 是否合法
  826. * $data 串式 所有赛事
  827. */
  828. public function verify_stringType($data=[]){
  829. if($data){
  830. foreach($data as $k=>$v){
  831. if($v['match_id']==$v['match_id'] ){
  832. $r[$v['match_id']][] = $v;
  833. }
  834. }
  835. }
  836. if($r){
  837. foreach ($r as $k=>$v){
  838. if(count($v) > 1){
  839. $msg = lang('Errors','Api')->get('error-50038');
  840. Render([], '50038',$msg);
  841. }else if( $k == 0){
  842. $msg = lang('Errors','Api')->get('error-50043');
  843. Render([], '50043',$msg);
  844. }
  845. }
  846. }
  847. }
  848. /**
  849. * 更新投注项相关数据
  850. */
  851. public function getBetData(){
  852. $data = $_REQUEST;
  853. // $data = [['game_code'=>'zq','match_id'=>3095448,'odds_id'=>623078],['game_code'=>'zq','match_id'=>3095448,'odds_id'=>623078]];
  854. foreach ($data as $k=>$v){
  855. $getModels = $this->commonFunction->getModels($v['game_code']);
  856. $model_match = $getModels['model_match'];
  857. $model_odds = $getModels['model_odds'];
  858. $oddsData = lm($model_match,"Sports")
  859. ->join($model_odds,$model_odds.'.match_id',$model_match.'.id')
  860. ->select($model_match.'.id as match_id',$model_match.'.match_date',$model_match.'.home_team',$model_match.'.guest_team',$model_odds.'.id as odds_id',$model_odds.'.p_code',$model_odds.'.odds_code',$model_odds.'.condition',$model_odds.'.odds',$model_odds.'.odds_only',$model_odds.'.status',$model_odds.'.sort')
  861. // ->where($model_match.'.source',$this->source)
  862. ->where($model_match.'.id',$v['match_id'])
  863. ->where($model_odds.'.id',$v['odds_id'])
  864. //->where($model_odds.'.expire_time','>',date("Y-m-d H:i:s"))
  865. ->first();
  866. $oddsData->game_code = $v['game_code'];
  867. $betData[] = $oddsData;
  868. }
  869. Render($betData, '1', lang('Tips','Sports')->get('success'));
  870. }
  871. //用户投注限额验证
  872. public function bet_money_limit($bet_money_arr=[],$userInfo=[]){
  873. if(!empty($bet_money_arr)){
  874. foreach($bet_money_arr as $k=>$v){
  875. if($k == (count($bet_money_arr)-1)){
  876. unset($bet_money_arr[$k]);
  877. }
  878. }
  879. }
  880. //===追加验证用户投注金额限额===
  881. if(empty($bet_money_arr)) Render('', '3605',lang('Errors','Api')->get('error-3605'));
  882. //获取当前用户分组名称
  883. $substr = substr($userInfo['group_name'],strpos($userInfo['group_name'],'|')+1);
  884. $role_name = substr($substr, 0, -1);
  885. //获取用户分组的投注限额
  886. $bet_money_limit = Dc_user_grade::get_bet_money_limit($role_name);
  887. foreach($bet_money_arr as $k=>$v){
  888. if($v['bet_amount'] < $bet_money_limit->lower_limit) Render(['bet_amount'=>$v['bet_amount'],'lower_limit'=>$bet_money_limit->lower_limit], '3406','第'.($k+1).'条'.lang('Errors','Api')->get('error-3406'));
  889. if($v['bet_amount'] > $bet_money_limit->upper_limit) Render(['bet_amount'=>$v['bet_amount'],'upper_limit'=>$bet_money_limit->upper_limit], '3401','第'.($k+1).'条'.lang('Errors','Api')->get('error-3401'));
  890. }
  891. //===end==
  892. }
  893. //根据token获取用户投注限额
  894. public function getBetMoneyLimit(){
  895. //验证用户token
  896. $token = $_REQUEST['token'];
  897. $userInfo = $this->getAgent($token);
  898. //获取当前用户分组名称
  899. $substr = substr($userInfo['group_name'],strpos($userInfo['group_name'],'|')+1);
  900. $role_name = substr($substr, 0, -1);
  901. //获取用户分组的投注限额
  902. $bet_money_limit = Dc_user_grade::get_bet_money_limit($role_name);
  903. $data['bet_money_limit']=[
  904. 'lower_limit'=>$bet_money_limit->lower_limit,
  905. 'upper_limit'=>$bet_money_limit->upper_limit,
  906. ];
  907. Render($data, '1', lang('Tips','Sports')->get('success'));
  908. }
  909. }