PcIssueService.php 13 KB

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