IssueService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872
  1. <?php
  2. namespace App\Services;
  3. use App\Services\BaseService;
  4. use App\Models\Issue;
  5. use App\Models\Config;
  6. use Illuminate\Support\Facades\DB;
  7. use Illuminate\Support\Collection;
  8. use Illuminate\Support\Facades\Cache;
  9. use Illuminate\Support\Facades\Log;
  10. use App\Services\GameplayRuleService;
  11. use App\Constants\GameplayRuleEnum;
  12. use App\Http\Controllers\admin\Lottery;
  13. use App\Services\KeyboardService;
  14. use App\Services\LotteryImageService;
  15. use Telegram\Bot\FileUpload\InputFile;
  16. /**
  17. * 投注
  18. */
  19. class IssueService extends BaseService
  20. {
  21. /**
  22. * @description: 模型
  23. * @return {string}
  24. */
  25. public static function model() :string
  26. {
  27. return Issue::class;
  28. }
  29. /**
  30. * @description: 枚举
  31. * @return {*}
  32. */
  33. public static function enum() :string
  34. {
  35. return '';
  36. }
  37. /**
  38. * @description: 获取查询条件
  39. * @param {array} $search 查询内容
  40. * @return {array}
  41. */
  42. public static function getWhere(array $search = []) :array
  43. {
  44. $where = [];
  45. if(isset($search['issue_no']) && !empty($search['issue_no'])){
  46. $where[] = ['issue_no', '=', $search['issue_no']];
  47. }
  48. if(isset($search['id']) && !empty($search['id'])){
  49. $where[] = ['id', '=', $search['id']];
  50. }
  51. if(isset($search['status']) && !empty($search['status'])){
  52. $where[] = ['status', '=', $search['status']];
  53. }
  54. return $where;
  55. }
  56. /**
  57. * @description: 查询单条数据
  58. * @param array $search
  59. * @return \App\Models\Coin|null
  60. */
  61. public static function findOne(array $search): ?Issue
  62. {
  63. return self::model()::where(self::getWhere($search))->first();
  64. }
  65. /**
  66. * @description: 查询所有数据
  67. * @param array $search
  68. * @return \Illuminate\Database\Eloquent\Collection
  69. */
  70. public static function findAll(array $search = [])
  71. {
  72. return self::model()::where(self::getWhere($search))->get();
  73. }
  74. /**
  75. * @description: 分页查询
  76. * @param array $search
  77. * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
  78. */
  79. public static function paginate(array $search = [])
  80. {
  81. $limit = isset($search['limit'])?$search['limit']:15;
  82. $paginator = self::model()::where(self::getWhere($search))->orderBy('issue_no','desc')->paginate($limit);
  83. return ['total' => $paginator->total(), 'data' => $paginator->items()];
  84. }
  85. /**
  86. * @description:
  87. * @param {*} $params
  88. * @return {*}
  89. */
  90. public static function submit($params = [])
  91. {
  92. $result = false;
  93. $msg['code'] = self::NOT;
  94. $msg['msg'] = '';
  95. // 2. 判断是否是更新
  96. if (!empty($params['id'])) {
  97. // 更新
  98. $info = self::findOne(['id'=>$params['id']] );
  99. if (!$info) {
  100. $msg['msg'] = '期号不存在!';
  101. }else{
  102. $result = $info->update($params);
  103. $id = $params['id'];
  104. }
  105. } else {
  106. // 创建
  107. $result = $info = self::model()::create($params);
  108. $id = $result->id;
  109. }
  110. if($result){
  111. $msg['code'] = self::YES;
  112. $msg['msg'] = '设置成功';
  113. $msg['key'] = $id;
  114. }else{
  115. $msg['msg'] = empty($msg['msg']) ?'操作失败':$msg['msg'];
  116. }
  117. return $msg;
  118. }
  119. /**
  120. * @description: 开始下注
  121. * @param {*} $id
  122. * @return {*}
  123. */
  124. public static function betting($id)
  125. {
  126. $info = self::findOne(['id'=>$id]);
  127. if(!$info){
  128. return ['code'=>self::NOT, 'msg'=>'期号不存在'];
  129. }
  130. if(!in_array($info->status, [self::model()::STATUS_DRAFT,self::model()::STATUS_BETTING])){
  131. return ['code'=>self::NOT, 'msg'=>'期号状态不正确'];
  132. }
  133. $info->status = self::model()::STATUS_BETTING;
  134. $info->save();
  135. // $text = "";
  136. // $text .= "第".$info->issue_no."期\n";
  137. // $text .= "🔥🔥🔥🔥🔥开始下注🔥🔥🔥🔥🔥\n";
  138. $replyInfo = KeyboardService::findOne(['button' => '开始下注']);
  139. if($replyInfo){
  140. $text = $replyInfo->reply;
  141. $buttons = json_decode($replyInfo->buttons,true);
  142. $image = $replyInfo->image;
  143. if($image){
  144. $image = url($image);
  145. }
  146. self::bettingGroupNotice($text, $buttons, $image);
  147. }
  148. $replyInfo = KeyboardService::findOne(['button' => '玩法规则']);
  149. if($replyInfo){
  150. $text = $replyInfo->reply;
  151. $buttons = json_decode($replyInfo->buttons,true);
  152. $image = $replyInfo->image;
  153. if($image){
  154. $image = url($image);
  155. }
  156. if(empty($buttons)){
  157. $buttons = self::getOperateButton();
  158. }
  159. self::bettingGroupNotice($text, $buttons, $image);
  160. }
  161. return ['code'=>self::YES, 'msg'=>'开始下注'];
  162. }
  163. /**
  164. * @description: 封盘
  165. * @param {*} $id
  166. * @return {*}
  167. */
  168. public static function closeBetting($id)
  169. {
  170. $info = self::findOne(['id'=>$id]);
  171. if(!$info){
  172. return ['code'=>self::NOT, 'msg'=>'期号不存在'];
  173. }
  174. if($info->status != self::model()::STATUS_BETTING){
  175. return ['code'=>self::NOT, 'msg'=>'期号状态不正确'];
  176. }
  177. $info->status = self::model()::STATUS_CLOSE;
  178. $info->save();
  179. $replyInfo = KeyboardService::findOne(['button' => '停止下注']);
  180. if($replyInfo){
  181. $text = $replyInfo->reply;
  182. $buttons = json_decode($replyInfo->buttons,true);
  183. $image = $replyInfo->image;
  184. if($image){
  185. $image = url($image);
  186. }
  187. self::bettingGroupNotice($text, $buttons, $image);
  188. }
  189. $replyInfo = KeyboardService::findOne(['button' => '封盘开奖']);
  190. if($replyInfo){
  191. $text = $replyInfo->reply;
  192. $buttons = json_decode($replyInfo->buttons,true);
  193. $image = $replyInfo->image;
  194. if($image){
  195. $image = url($image);
  196. }
  197. self::bettingGroupNotice($text, $buttons, $image);
  198. }
  199. return ['code'=>self::YES, 'msg'=>'封盘成功'];
  200. }
  201. /**
  202. * @description: 开奖
  203. * @param {*} $id
  204. * @param {*} $winning_numbers 开奖号码
  205. * @param {*} $combo 开奖组合
  206. * @param {*} $recordImage 开奖图片
  207. * @return {*}
  208. */
  209. public static function lotteryDraw($id, $winning_numbers ,$combo ,$recordImage)
  210. {
  211. $info = self::findOne(['id'=>$id]);
  212. if(!$info){
  213. return ['code'=>self::NOT, 'msg'=>'期号不存在'];
  214. }
  215. if($info->status != self::model()::STATUS_CLOSE){
  216. return ['code'=>self::NOT, 'msg'=>'期号状态不正确'];
  217. }
  218. // 计算中奖
  219. $awards = self::award(explode(',',$winning_numbers));
  220. DB::beginTransaction();
  221. try {
  222. $info->status = self::model()::STATUS_DRAW;
  223. $info->winning_numbers = $winning_numbers;
  224. $info->combo = $combo;
  225. $info->image = $recordImage;
  226. $info->save();
  227. $replyInfo = KeyboardService::findOne(['button' => '本期开奖']);
  228. if($replyInfo){
  229. $text = $replyInfo->reply;
  230. $text .= "\n";
  231. $text .= $info->issue_no."期 ".implode('+',explode(',',$winning_numbers))."=".array_sum(explode(',',$winning_numbers))." ".$combo;
  232. $buttons = json_decode($replyInfo->buttons,true);
  233. $image = $replyInfo->image;
  234. if($image){
  235. $image = url($image);
  236. }
  237. if(empty($buttons)){
  238. $serviceAccount = Config::where('field', 'service_account')->first()->val;
  239. $buttons[] = [['text' => '✅唯一财务', 'callback_data' => "", 'url' => "https://t.me/{$serviceAccount}"]];
  240. }
  241. self::bettingGroupNotice($text, $buttons, $image ,true);
  242. }
  243. $recordImage = self::lotteryImage($info->issue_no);
  244. if($recordImage){
  245. self::bettingGroupNotice('', [], url($recordImage));
  246. }
  247. BetService::betSettled($info->issue_no, $awards);
  248. DB::commit();
  249. return ['code'=>self::YES, 'msg'=>'开奖成功'];
  250. } catch (\Exception $e) {
  251. DB::rollBack();
  252. Log::error('开奖失败: '.$e->getMessage());
  253. return ['code'=>self::NOT, 'msg'=>'开奖失败'];
  254. }
  255. }
  256. // 虚拟开奖
  257. public static function fakeLotteryDraw()
  258. {
  259. // 期数验证
  260. $issueInfo = IssueService::model()::where('status',IssueService::model()::STATUS_BETTING)->orderBy('id','desc')->first();
  261. if($issueInfo){
  262. $fake_bet_list = Cache::get('fake_bet_'.$issueInfo->issue_no,[]);
  263. $winning_numbers = '5,6,2';
  264. // 计算中奖
  265. $awards = self::award(explode(',',$winning_numbers));
  266. $text = "虚拟开奖\n";
  267. foreach($fake_bet_list as $k => $v){
  268. $lastStr = self::getLastChar($v['first_name'],1);
  269. if(in_array($v['keywords'],$awards)){
  270. $profit = $v['amount'] * $v['odds'];
  271. if($profit > 880000){
  272. $profit = 880000; // 单注最高奖金880000
  273. }
  274. $item['profit'] = $profit;
  275. $yl = $profit - $v['amount'];
  276. if($k+1 <= 30){
  277. $text .= "私聊下注 【******".$lastStr."】 {$yl}\n";
  278. }
  279. }else{
  280. if($k+1 <= 30){
  281. $text .= "私聊下注 【******".$lastStr."】 -{$v['amount']}\n";
  282. }
  283. }
  284. }
  285. $inlineButton = self::getOperateButton();
  286. // 群通知
  287. self::bettingGroupNotice($text, $inlineButton, '');
  288. }
  289. }
  290. /**
  291. * @description: 获取中奖的奖项
  292. * @param {*} $winning_numbers
  293. * @return {*}
  294. */
  295. public static function award($winning_numbers)
  296. {
  297. $result = [];
  298. // 组合
  299. $sum = array_sum($winning_numbers);
  300. $section = self::getSection($sum); // 总和段位
  301. $result[] = $section;
  302. $sumOddEven = self::calculateOddEven($sum); // 总和单双
  303. $result[] = $sumOddEven;
  304. $sumSize = self::calculateSumSize($sum); // 总和大小
  305. $result[] = $sumSize;
  306. $sumExtremeSize = self::calculateSumExtremeSize($sum); // 总和极值
  307. if($sumExtremeSize){
  308. $result[] = $sumExtremeSize;
  309. }
  310. $sumCao = $sum . '操'; // 总和数字
  311. $result[] = $sumCao;
  312. $sumCombo = $sumSize. $sumOddEven; // 总和大小单双组合
  313. $result[] = $sumCombo;
  314. $sumBaoZi = self::isBaoZi($winning_numbers[0], $winning_numbers[1], $winning_numbers[2]); // 豹子
  315. if($sumBaoZi){
  316. $result[] = $sumBaoZi;
  317. }
  318. $sumPair = self::isPair($winning_numbers[0], $winning_numbers[1], $winning_numbers[2]); // 对子
  319. if($sumPair){
  320. $result[] = $sumPair;
  321. }
  322. $sumStraight = self::isStraight($winning_numbers[0], $winning_numbers[1], $winning_numbers[2]); // 顺子
  323. if($sumStraight){
  324. $result[] = $sumStraight;
  325. }
  326. $tail = self::getLastDigit($sum); // 总和尾数
  327. $result[] = $tail . '尾'; // 尾数
  328. $tailOddEven = self::calculateOddEven($tail); // 尾数单双
  329. $result[] = '尾'.$tailOddEven;
  330. $tailSize = self::calculateOneSize($tail); // 尾数大小
  331. $result[] = '尾'.$tailSize;
  332. $tailCombo = '尾'.$tailSize . $tailOddEven; // 尾数大小单双组合
  333. $result[] = $tailCombo;
  334. $numA = $winning_numbers[0]; // A球
  335. $result[] = $numA.'A';
  336. $numAOddEven = self::calculateOddEven($numA); // A球单双
  337. $result[] = 'A'.$numAOddEven;
  338. $numASize = self::calculateOneSize($numA); // A球大小
  339. $result[] = 'A'.$numASize;
  340. $result[] = 'A'.$numASize.$numAOddEven; // A球大小单双组合
  341. $numB = $winning_numbers[1]; // B球
  342. $result[] = $numB.'B';
  343. $numBOddEven = self::calculateOddEven($numB); // B球
  344. $result[] = 'B'.$numBOddEven;
  345. $numBSize = self::calculateOneSize($numB); // B球大小
  346. $result[] = 'B'.$numBSize;
  347. $result[] = 'B'.$numBSize.$numBOddEven; // B球大小单双组合
  348. $numC = $winning_numbers[2];
  349. $result[] = $numC.'C';
  350. $numCOddEven = self::calculateOddEven($numC); // C球单双
  351. $result[] = 'C'.$numCOddEven;
  352. $numCSize = self::calculateOneSize($numC); // C球大小
  353. $result[] = 'C'.$numCSize;
  354. $result[] = 'C'.$numCSize.$numCOddEven; // C球大小单双组合
  355. return $result;
  356. }
  357. /**
  358. * @description: 算单双
  359. * @param {*} $number
  360. * @return {*}
  361. */
  362. public static function calculateOddEven($number)
  363. {
  364. if ($number & 1) {
  365. return GameplayRuleEnum::SINGLE;
  366. } else {
  367. return GameplayRuleEnum::DOUBLE;
  368. }
  369. }
  370. /**
  371. * @description: 总和大小
  372. * @param {*} $number
  373. * @return {*}
  374. */
  375. public static function calculateSumSize($number)
  376. {
  377. if($number >= GameplayRuleEnum::SUM_BIG) {
  378. return GameplayRuleEnum::BIG;
  379. }
  380. if($number <= GameplayRuleEnum::SUM_SMALL){
  381. return GameplayRuleEnum::SMALL;
  382. }
  383. }
  384. /**
  385. * @description: 总和极值
  386. * @param {*} $number
  387. * @return {*}
  388. */
  389. public static function calculateSumExtremeSize($number)
  390. {
  391. $result = '';
  392. if($number >= GameplayRuleEnum::SUM_EXTREME_BIG) {
  393. $result = GameplayRuleEnum::EXTREME_BIG;
  394. }
  395. if($number <= GameplayRuleEnum::SUM_EXTREME_SMALL){
  396. $result = GameplayRuleEnum::EXTREME_SMALL;
  397. }
  398. return $result;
  399. }
  400. /**
  401. * @description: 豹子
  402. * @param {int} $a
  403. * @param {int} $b
  404. * @param {int} $c
  405. * @return {*}
  406. */
  407. public static function isBaoZi(int $a, int $b, int $c)
  408. {
  409. $result = '';
  410. if($a === $b && $b === $c){
  411. $result = GameplayRuleEnum::BAO_ZI;
  412. }
  413. return $result;
  414. }
  415. /**
  416. * @description: 对子
  417. * @param {int} $a
  418. * @param {int} $b
  419. * @param {int} $c
  420. * @return {*}
  421. */
  422. public static function isPair($a, $b, $c) {
  423. $result = '';
  424. // 确保输入都是个位数
  425. if (!is_numeric($a) || !is_numeric($b) || !is_numeric($c) ||
  426. $a < 0 || $a > 9 || $b < 0 || $b > 9 || $c < 0 || $c > 9) {
  427. return ''; // 或者抛出异常
  428. }
  429. if(($a == $b && $a != $c) ||
  430. ($a == $c && $a != $b) ||
  431. ($b == $c && $b != $a)){
  432. $result = GameplayRuleEnum::PAIRS;
  433. }
  434. // 判断是否为对子情况
  435. return $result;
  436. }
  437. /**
  438. * @description: 顺子
  439. * @param {int} $a
  440. * @param {int} $b
  441. * @param {int} $c
  442. * @return {*}
  443. */
  444. public static function isStraight($a, $b, $c) {
  445. $result = '';
  446. // 确保输入都是个位数(0-9)
  447. if (!is_numeric($a) || !is_numeric($b) || !is_numeric($c) ||
  448. $a < 0 || $a > 9 || $b < 0 || $b > 9 || $c < 0 || $c > 9) {
  449. return '';
  450. }
  451. // 去重(顺子必须三个不同数字)
  452. if ($a == $b || $a == $c || $b == $c) {
  453. return '';
  454. }
  455. // 检查是否是完全升序或完全降序的连续数字
  456. $numbers = [$a, $b, $c];
  457. sort($numbers); // 排序后检查是否是 x, x+1, x+2
  458. list($x, $y, $z) = $numbers;
  459. // 情况1:升序连续(1,2,3)
  460. $isAscending = ($x + 1 == $y) && ($y + 1 == $z);
  461. // 情况2:降序连续(3,2,1)
  462. $isDescending = ($z + 1 == $y) && ($y + 1 == $x);
  463. if($isAscending || $isDescending){
  464. $result = GameplayRuleEnum::STRAIGHT;
  465. }
  466. return $result;
  467. }
  468. /**
  469. * 获取数字的尾数
  470. * @param int $number 输入数字
  471. * @return int 尾数
  472. */
  473. public static function getLastDigit($number) {
  474. // 确保输入是整数
  475. $number = (int)$number;
  476. // 取绝对值,处理负数情况
  477. $number = abs($number);
  478. // 取模10得到尾数
  479. return $number % 10;
  480. }
  481. /**
  482. * @description: 尾大小
  483. * @param {*} $number
  484. * @return {*}
  485. */
  486. public static function calculateOneSize($number)
  487. {
  488. if($number >= GameplayRuleEnum::ONE_BIG) {
  489. return GameplayRuleEnum::BIG;
  490. }
  491. if($number <= GameplayRuleEnum::ONE_SMALL){
  492. return GameplayRuleEnum::SMALL;
  493. }
  494. }
  495. /**
  496. * @description: 获取段位
  497. * @param {*} $number
  498. * @return {*}
  499. */
  500. public static function getSection($number) {
  501. $result = '';
  502. if ($number >= GameplayRuleEnum::SECTION_1[0] && $number <= GameplayRuleEnum::SECTION_1[1]) {
  503. $result = GameplayRuleEnum::ONE;
  504. } elseif ($number >= GameplayRuleEnum::SECTION_2[0] && $number <= GameplayRuleEnum::SECTION_2[1]) {
  505. $result = GameplayRuleEnum::TWO;
  506. } elseif ($number >= GameplayRuleEnum::SECTION_3[0] && $number <= GameplayRuleEnum::SECTION_3[1]) {
  507. $result = GameplayRuleEnum::THREE;
  508. } elseif ($number >= GameplayRuleEnum::SECTION_4[0] && $number <= GameplayRuleEnum::SECTION_4[1]) {
  509. $result = GameplayRuleEnum::FOUR;
  510. }
  511. return $result; // 不在任何段中
  512. }
  513. /**
  514. * @description: 近期开奖记录
  515. * @return {*}
  516. */
  517. public static function currentLotteryResults($memberId)
  518. {
  519. // $result = self::model()::where('status', self::model()::STATUS_DRAW)->orderBy('id','desc')->take(16)->get();
  520. // $text = "📅 近期开奖记录\n";
  521. // $text .= "====================\n";
  522. // if($result){
  523. // foreach($result as $k => $v){
  524. // $winArr = explode(',',$v->winning_numbers);
  525. // // 组合
  526. // $sum = array_sum($winArr);
  527. // $combo = [];
  528. // $sumOddEven = self::calculateOddEven($sum); // 总和单双
  529. // $sumSize = self::calculateSumSize($sum); // 总和大小
  530. // $sumExtremeSize = self::calculateSumExtremeSize($sum); // 总和极值
  531. // if(empty($sumExtremeSize)){
  532. // $sumExtremeSize = "-";
  533. // }
  534. // $tail = self::getLastDigit($sum); // 总和尾数
  535. // if($tail == 0){
  536. // $tail = '-'; // 尾数
  537. // }else{
  538. // $tail = '尾'.$tail; // 尾数
  539. // }
  540. // $text .= "回合:{$v->issue_no}期 \n";
  541. // $text .= "结果:".implode('+',explode(',',$v->winning_numbers))."=".array_sum(explode(',',$v->winning_numbers))." \n";
  542. // $text .= "组合:{$sumSize} {$sumOddEven} \n";
  543. // $text .= "极值:{$sumExtremeSize} \n";
  544. // $text .= "尾数:{$tail} \n";
  545. // $text .= "---------------------------\n";
  546. // }
  547. // self::telegram()->sendMessage([
  548. // 'chat_id' => $memberId,
  549. // 'text' => $text,
  550. // ]);
  551. // }else{
  552. // self::telegram()->sendMessage([
  553. // 'chat_id' => $memberId,
  554. // 'text' => "暂无开奖记录",
  555. // ]);
  556. // }
  557. $result = self::model()::where('status', self::model()::STATUS_DRAW)->orderBy('id','desc')->first();
  558. if($result){
  559. if($result->image){
  560. self::telegram()->sendPhoto([
  561. 'chat_id' => $memberId,
  562. 'photo' => InputFile::create(url($result->image)),
  563. ]);
  564. }else{
  565. // if($result->combo){
  566. // self::telegram()->sendMessage([
  567. // 'chat_id' => $memberId,
  568. // 'text' => "",
  569. // ]);
  570. // }else{
  571. self::telegram()->sendMessage([
  572. 'chat_id' => $memberId,
  573. 'text' => "暂无开奖记录",
  574. ]);
  575. // }
  576. }
  577. }
  578. }
  579. // 获取最新的开奖数据
  580. public static function getLatestIssue()
  581. {
  582. $url = "https://ydpc28.co/api/pc28/list";
  583. $result = file_get_contents($url);
  584. $result = json_decode($result,true);
  585. if($result['errorCode'] != 0){
  586. return ['code'=>self::NOT, 'msg'=>'获取最新期号失败'];
  587. }
  588. $nextDrawInfo = $result['data']['nextDrawInfo'];
  589. if($nextDrawInfo['nextDrawTime'] >= date('H:i:s')) {
  590. $endTime = date('Y-m-d').' '.$nextDrawInfo['nextDrawTime']; // 下一期的截止时间
  591. }else{
  592. $endTime = date('Y-m-d',strtotime('+1 day')).' '.$nextDrawInfo['nextDrawTime']; // 下一期的截止时间
  593. }
  594. $list = $result['data']['list'];
  595. $listKey = [];
  596. foreach($list as $k => $v){
  597. $listKey[$v['lotNumber']] = $v;
  598. }
  599. $oldList = self::findAll(['status' => self::model()::STATUS_CLOSE]); // 获取所有封盘的期号
  600. foreach($oldList as $k => $v){
  601. if(isset($listKey[$v->issue_no])){
  602. $issue = $listKey[$v->issue_no];
  603. $winning_numbers = implode(',', str_split((string)$issue['openCode']));
  604. $winArr = explode(',',$winning_numbers);
  605. // 组合
  606. $sum = array_sum($winArr);
  607. $combo = [];
  608. $sumOddEven = self::calculateOddEven($sum); // 总和单双
  609. $combo[] = $sumOddEven;
  610. $sumSize = self::calculateSumSize($sum); // 总和大小
  611. $combo[] = $sumSize;
  612. $sumExtremeSize = self::calculateSumExtremeSize($sum); // 总和极值
  613. if($sumExtremeSize){
  614. $combo[] = $sumExtremeSize;
  615. }
  616. $sumBaoZi = self::isBaoZi($winArr[0], $winArr[1], $winArr[2]); // 豹子
  617. if($sumBaoZi){
  618. $combo[] = $sumBaoZi;
  619. }
  620. $sumPair = self::isPair($winArr[0], $winArr[1], $winArr[2]); // 对子
  621. if($sumPair){
  622. $combo[] = $sumPair;
  623. }
  624. $sumStraight = self::isStraight($winArr[0], $winArr[1], $winArr[2]); // 顺子
  625. if($sumStraight){
  626. $combo[] = $sumStraight;
  627. }
  628. $tail = self::getLastDigit($sum); // 总和尾数
  629. if($tail == 0 || $tail == 9){
  630. }else{
  631. $combo[] = '尾'.$tail; // 尾数
  632. }
  633. $combo = implode(' ', $combo);
  634. self::lotteryDraw($v->id, $winning_numbers, $combo,'');
  635. }
  636. }
  637. sleep(3); // 等待开奖完成
  638. $latestIssue = $list[0]; // 最后开奖
  639. $new_issue_no = $latestIssue['lotNumber'] + 1; // 新期号
  640. $newInfo = self::findOne(['issue_no' => $new_issue_no]); // 找新的期号
  641. // 不存在
  642. if(!$newInfo){
  643. $res = self::submit([
  644. 'issue_no' => $new_issue_no,
  645. 'status' => self::model()::STATUS_DRAFT,
  646. 'start_time' => date('Y-m-d H:i:s'),
  647. 'end_time' => $endTime,
  648. ]);
  649. $id = $res['key']??0;
  650. if($id){
  651. self::betting($id); // 开始下注
  652. }
  653. }
  654. return $result;
  655. }
  656. // 封盘倒数
  657. public static function syncCountdownIssue()
  658. {
  659. $now_date = date('Y-m-d H:i:s',time() + 50); // 提前50秒
  660. $info = self::model()::where('status', self::model()::STATUS_BETTING)->orderBy('end_time','asc')->first();
  661. if($info){
  662. if($info['end_time'] < $now_date){
  663. $replyInfo = KeyboardService::findOne(['button' => '封盘倒数']);
  664. if($replyInfo){
  665. $text = $replyInfo->reply;
  666. $buttons = json_decode($replyInfo->buttons,true);
  667. $image = $replyInfo->image;
  668. if($image){
  669. $image = url($image);
  670. }
  671. if(Cache::has('issue_countdown_'.$info->id)){
  672. }else{
  673. self::bettingGroupNotice($text, $buttons, $image);
  674. Cache::put('issue_countdown_'.$info->id, true, 60); // 缓存50秒,防止多次发送
  675. }
  676. }
  677. }
  678. }
  679. }
  680. // 停止下注
  681. public static function syncCloseIssue()
  682. {
  683. $now_date = date('Y-m-d H:i:s',time() + 30); // 提前30秒
  684. $list = self::findAll(['status' => self::model()::STATUS_BETTING]);
  685. foreach($list as $k => $v){
  686. if($v['end_time'] < $now_date){
  687. self::closeBetting($v->id);
  688. }
  689. }
  690. }
  691. // 生成开奖图片
  692. public static function lotteryImage($issue_no)
  693. {
  694. $list = self::model()::where('issue_no','<=',$issue_no)->where(self::getWhere(['status' => self::model()::STATUS_DRAW]))->orderBy('issue_no','desc')->take(20)->get();
  695. $records = $list->toArray();
  696. foreach($records as $k => $v){
  697. $winning_numbers = explode(',',$v['winning_numbers']);
  698. $v['winning_numbers'] = $winning_numbers;
  699. // 组合
  700. $sum = array_sum($winning_numbers);
  701. $v['sum'] = $sum;
  702. $sumOddEven = self::calculateOddEven($sum); // 总和单双
  703. $sumSize = self::calculateSumSize($sum); // 总和大小
  704. $v['combo'] = $sumSize . ' ' . $sumOddEven;
  705. $sumExtremeSize = self::calculateSumExtremeSize($sum); // 总和极值
  706. if(!$sumExtremeSize){
  707. $sumExtremeSize = '-';
  708. }
  709. $v['extreme'] = $sumExtremeSize;
  710. $tail = self::getLastDigit($sum); // 总和尾数
  711. if($tail === 0 || $tail === 9){
  712. $tailStr = '-';
  713. }else{
  714. $tailStr = '尾' . $tail;
  715. }
  716. $v['tail'] = $tailStr;
  717. $records[$k] = $v;
  718. }
  719. $service = new LotteryImageService();
  720. $url = $service->generate($records);
  721. self::model()::where('issue_no', $issue_no)->update(['image' => $url]);
  722. return $url;
  723. }
  724. }