PcIssueService.php 12 KB

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