PcIssueService.php 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289
  1. <?php
  2. namespace App\Services;
  3. use App\Jobs\SendTelegramGroupMessageJob;
  4. use App\Models\Config;
  5. use App\Models\PcCao;
  6. use App\Models\PcCaoHistory;
  7. use App\Models\PcIssue;
  8. use App\Models\PcPrediction;
  9. use Illuminate\Support\Facades\Cache;
  10. use Illuminate\Support\Facades\DB;
  11. use Illuminate\Support\Facades\Log;
  12. class PcIssueService extends BaseService
  13. {
  14. public static $MODEL = PcIssue::class;
  15. public static function index(): void
  16. {
  17. //创建新的期号
  18. PcIssueService::createIssueNo();
  19. //对该封盘的进行封盘
  20. PcIssueService:: fengPan();
  21. //将未开奖的进行开奖
  22. PcIssueService:: kaiJiang();
  23. }
  24. private static function fengPan()
  25. {
  26. $list = PcIssue::where('status', PcIssue::STATUS_BETTING)->get();
  27. $now = time();
  28. foreach ($list as $item) {
  29. if (strtotime($item->end_time) - 30 <= $now) {
  30. $item->status = PcIssue::STATUS_CLOSE;
  31. $item->save();
  32. }
  33. }
  34. }
  35. private static function kaiJiang(): void
  36. {
  37. $list = PcIssue::where('status', PcIssue::STATUS_CLOSE)->get();
  38. $now = time();
  39. foreach ($list as $item) {
  40. if (strtotime($item->end_time) <= $now) {
  41. $keno = static::getKeno();
  42. $item->keno = json_encode($keno);
  43. $winningNumbers = static::getWinningNumbers($keno);
  44. $item->winning_numbers = implode(',', $winningNumbers);
  45. $item->status = PcIssue::STATUS_DRAW;
  46. $item->save();
  47. $winArr = array_map('intval', $winningNumbers);
  48. // 组合
  49. $sum = array_sum($winArr);
  50. $combo = [];
  51. $sumOddEven = IssueService::calculateOddEven($sum); // 总和单双
  52. $combo[] = $sumOddEven;
  53. $sumSize = IssueService::calculateSumSize($sum); // 总和大小
  54. $combo[] = $sumSize;
  55. $sumExtremeSize = IssueService::calculateSumExtremeSize($sum); // 总和极值
  56. if ($sumExtremeSize) {
  57. $combo[] = $sumExtremeSize;
  58. }
  59. $sumBaoZi = IssueService::isBaoZi($winArr[0], $winArr[1], $winArr[2]); // 豹子
  60. if ($sumBaoZi) {
  61. $combo[] = $sumBaoZi;
  62. }
  63. $sumPair = IssueService::isPair($winArr[0], $winArr[1], $winArr[2]); // 对子
  64. if ($sumPair) {
  65. $combo[] = $sumPair;
  66. }
  67. $sumStraight = IssueService::isStraight($winArr[0], $winArr[1], $winArr[2]); // 顺子
  68. if ($sumStraight) {
  69. $combo[] = $sumStraight;
  70. }
  71. $tail = IssueService::getLastDigit($sum); // 总和尾数
  72. if ($tail != 0 && $tail != 9) {
  73. $combo[] = '尾' . $tail; // 尾数
  74. }
  75. $key = 'lottery_numbers_' . $item->issue_no;
  76. $combo = implode(' ', $combo);
  77. if (Cache::add($key, $item->winning_numbers, 100)) {
  78. $res = self::lotteryDraw($item->issue_no, $item->winning_numbers, $combo, '');
  79. // 'code' => self::NOT
  80. }
  81. $awards = IssueService::award(explode(',', $item->winning_numbers));
  82. //预测结果
  83. PcPrediction::result($item->issue_no, $item->winning_numbers, $awards);
  84. //自开奖以来的结果统计
  85. PcCao::updateData($awards);
  86. //每天开奖结果统计
  87. PcCaoHistory::updateData($awards);
  88. }
  89. }
  90. }
  91. //开奖
  92. private static function lotteryDraw($issue_no, $winning_numbers, $combo, $recordImage)
  93. {
  94. $info = PcIssue::where('issue_no', $issue_no)->first();
  95. if (!$info) {
  96. return ['code' => self::NOT, 'msg' => '期号不存在'];
  97. }
  98. // if ($info->status == PcIssue::STATUS_DRAW) {
  99. // return ['code' => self::NOT, 'msg' => '期号状态不正确'];
  100. // }
  101. $winArr = array_map('intval', explode(',', $winning_numbers));
  102. // 计算中奖
  103. $awards = IssueService::award(explode(',', $winning_numbers));
  104. DB::beginTransaction();
  105. try {
  106. $info->status = PcIssue::STATUS_DRAW;
  107. $info->winning_numbers = $winning_numbers;
  108. $info->combo = $combo;
  109. $info->image = $recordImage;
  110. $info->save();
  111. $replyInfo = KeyboardService::findOne(['button' => '本期开奖']);
  112. if ($replyInfo) {
  113. $text = $replyInfo->reply;
  114. $text .= "\n";
  115. $text .= $info->issue_no . "期 " . implode('+', explode(',', $winning_numbers)) . "=" . array_sum($winArr) . " " . $combo;
  116. $buttons = json_decode($replyInfo->buttons, true);
  117. $image = $replyInfo->image;
  118. if ($image) {
  119. $image = url($image);
  120. }
  121. if (empty($buttons)) {
  122. $serviceAccount = Config::where('field', 'service_account')->first()->val;
  123. $buttons[] = [['text' => '✅唯一财务', 'callback_data' => "", 'url' => "https://t.me/{$serviceAccount}"]];
  124. }
  125. SendTelegramGroupMessageJob::dispatch($text, $buttons, $image, true);
  126. }
  127. if (config('app.url') != 'https://bot28dev.testx2.cc') {
  128. // $recordImage = self::lotteryImage($info->issue_no);
  129. }
  130. if ($recordImage) {
  131. // self::bettingGroupNotice('', [], url($recordImage));
  132. SendTelegramGroupMessageJob::dispatch('', [], url($recordImage), false);
  133. }
  134. BetService::betSettled($info->issue_no, $awards);
  135. DB::commit();
  136. return ['code' => self::YES, 'msg' => '开奖成功'];
  137. }catch (\Exception $e) {
  138. DB::rollBack();
  139. Log::error('开奖失败: ' . $e->getMessage() . $winning_numbers);
  140. return ['code' => self::NOT, 'msg' => '开奖失败'];
  141. }
  142. }
  143. // 生成开奖图片
  144. private static function lotteryImage($issue_no)
  145. {
  146. $list = PcIssue::where('issue_no', '<=', $issue_no)->where('status' , PcIssue::STATUS_DRAW)->orderBy('issue_no', 'desc')->take(20)->get();
  147. $records = $list->toArray();
  148. foreach ($records as $k => $v) {
  149. $winning_numbers = explode(',', $v['winning_numbers']);
  150. $v['winning_numbers'] = $winning_numbers;
  151. // 组合
  152. $sum = array_sum($winning_numbers);
  153. $v['sum'] = $sum;
  154. $sumOddEven = IssueService::calculateOddEven($sum); // 总和单双
  155. $sumSize = IssueService::calculateSumSize($sum); // 总和大小
  156. $v['combo'] = $sumSize . ' ' . $sumOddEven;
  157. $sumExtremeSize = IssueService::calculateSumExtremeSize($sum); // 总和极值
  158. if (!$sumExtremeSize) {
  159. $sumExtremeSize = '-';
  160. }
  161. $v['extreme'] = $sumExtremeSize;
  162. $tail = IssueService::getLastDigit($sum); // 总和尾数
  163. if ($tail === 0 || $tail === 9) {
  164. $tailStr = '-';
  165. } else {
  166. $tailStr = '尾' . $tail;
  167. }
  168. $v['tail'] = $tailStr;
  169. $records[$k] = $v;
  170. }
  171. $service = new LotteryImageService();
  172. $url = $service->generate($records);
  173. PcIssue::where('issue_no', $issue_no)->update(['image' => $url]);
  174. return $url;
  175. }
  176. private static function createIssueNo()
  177. {
  178. $issue = PcIssue::orderByDesc('id')->first();
  179. $now = time();
  180. if (strtotime($issue->end_time) <= $now) {
  181. $issue_no = $issue->issue_no;
  182. $number = preg_replace('/\D/', '', $issue_no);
  183. $number = (int)$number + 1;
  184. $new_str = "P" . $number;
  185. $end_time = strtotime($issue->end_time) + 210;
  186. $status = $end_time - 30 > $now ? PcIssue::STATUS_BETTING : PcIssue::STATUS_CLOSE;
  187. $issue = PcIssue::create([
  188. 'issue_no' => $new_str,
  189. 'status' => $status,
  190. 'start_time' => $issue->end_time,
  191. 'end_time' => date('Y-m-d H:i:s', $end_time),
  192. ]);
  193. //预测
  194. PcPrediction::prediction($new_str);
  195. if (strtotime($issue->end_time) <= $now) {
  196. static::createIssueNo();
  197. }
  198. }
  199. }
  200. //获取随机的20个数字
  201. private static function getKeno(): array
  202. {
  203. $numbers = range(1, 80);
  204. shuffle($numbers);
  205. $random_numbers = array_slice($numbers, 0, 20);
  206. sort($random_numbers);
  207. return $random_numbers;
  208. }
  209. //根据20个数字计算开奖号码
  210. private static function getWinningNumbers($keno): array
  211. {
  212. $winningNumbers = [];
  213. $sum = $keno[1] + $keno[4] + $keno[7] + $keno[10] + $keno[13] + $keno[16];
  214. $winningNumbers[0] = $sum % 10;
  215. $sum = $keno[2] + $keno[5] + $keno[8] + $keno[11] + $keno[14] + $keno[17];
  216. $winningNumbers[1] = $sum % 10;
  217. $sum = $keno[3] + $keno[6] + $keno[9] + $keno[12] + $keno[15] + $keno[18];
  218. $winningNumbers[2] = $sum % 10;
  219. return $winningNumbers;
  220. }
  221. //根据指定0-27的数字 得到20个数字
  222. public static function getMatchingNumbers($target): array|null
  223. {
  224. $numbers = range(1, 80);
  225. $bestMatch = null;
  226. for ($i = 0; $i < 100000; $i++) {
  227. shuffle($numbers);
  228. $selectedNumbers = array_slice($numbers, 0, 20);
  229. sort($selectedNumbers);
  230. $firstSum = $selectedNumbers[1] + $selectedNumbers[4] + $selectedNumbers[7] + $selectedNumbers[10] + $selectedNumbers[13] + $selectedNumbers[16];
  231. $firstDigit = $firstSum % 10;
  232. $secondSum = $selectedNumbers[2] + $selectedNumbers[5] + $selectedNumbers[8] + $selectedNumbers[11] + $selectedNumbers[14] + $selectedNumbers[17];
  233. $secondDigit = $secondSum % 10;
  234. $thirdSum = $selectedNumbers[3] + $selectedNumbers[6] + $selectedNumbers[9] + $selectedNumbers[12] + $selectedNumbers[15] + $selectedNumbers[18];
  235. $thirdDigit = $thirdSum % 10;
  236. $result = $firstDigit + $secondDigit + $thirdDigit;
  237. if ($result === $target) {
  238. $bestMatch = $selectedNumbers;
  239. break;
  240. }
  241. }
  242. return $bestMatch;
  243. }
  244. }