TelegramWebHook.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736
  1. <?php
  2. namespace App\Http\Controllers\api;
  3. use App\Constants\StepStatus;
  4. use App\Constants\Util;
  5. use App\Exceptions\MessageException;
  6. use App\Http\Controllers\Controller;
  7. use App\Models\Message;
  8. use App\Models\User;
  9. use App\Services\OnLineService;
  10. use App\Services\RecordService;
  11. use App\Services\RoomService;
  12. use App\Services\SettlementService;
  13. use App\Services\TopUpService;
  14. use App\Services\TutorialService;
  15. use App\Services\UserService;
  16. use App\Services\WalletService;
  17. use App\Services\WithdrawService;
  18. use Illuminate\Http\Request;
  19. use Illuminate\Support\Facades\Cache;
  20. use Illuminate\Support\Facades\DB;
  21. use Telegram\Bot\Api;
  22. use Telegram\Bot\Exceptions\TelegramSDKException;
  23. class TelegramWebHook extends Controller
  24. {
  25. public function handle(Request $request)
  26. {
  27. try {
  28. $m = new Message();
  29. $m->json = $request->ip();
  30. $m->save();
  31. $telegram = new Api(config('services.telegram.token'));
  32. } catch (TelegramSDKException $e) {
  33. return response()->json(['status' => 'ok']);
  34. }
  35. $update = $telegram->getWebhookUpdate(); // 获取更新数据
  36. $update->callbackQuery;
  37. if ($update->has('callback_query')) {
  38. $json['type'] = 'callback_query';
  39. $callbackQuery = $update->callbackQuery;
  40. $json['update'] = $callbackQuery;
  41. $message = $callbackQuery->message;
  42. $from = $callbackQuery->from;
  43. $data = $callbackQuery->data; // 获取 callback_data
  44. $m = new Message();
  45. $m->json = $data;
  46. $m->save();
  47. Util::delCache($message->chat->id);
  48. DB::beginTransaction();
  49. try {
  50. $chatId = $message->chat->id;
  51. $firstName = $message->chat->firstName;
  52. $messageId = $message->messageId;
  53. if (!$from->isBot) {
  54. $chatId = $from->id;
  55. $firstName = $from->firstName;
  56. }
  57. $user = User::where('member_id', $chatId)->first();
  58. if (!$user) {
  59. $user = new User();
  60. $user->member_id = $chatId;
  61. }
  62. $user->first_name = $firstName;
  63. $user->save();
  64. //给每个用户生成一个专属的USDT钱包
  65. WalletService::getUserWallet($chatId);
  66. //取消创建游戏
  67. if ($data === "games@@cancel") {
  68. $roomService = new RoomService($telegram);
  69. $res = $roomService->cancel($chatId, $messageId);
  70. $telegram->editMessageText($res);
  71. }
  72. if ($data === 'withdrawAddress@@done') {
  73. $res = WithdrawService::done($chatId, $messageId, $firstName);
  74. $telegram->editMessageText($res);
  75. }
  76. //选择提现地址
  77. $pattern = "/^withdrawAddress@@choose\d+$/";
  78. if (preg_match($pattern, $data)) {
  79. $id = preg_replace('/^withdrawAddress@@choose/', '', $data);
  80. $res = WithdrawService::chooseAddress($chatId, $firstName, $messageId, $id);
  81. $telegram->editMessageText($res);
  82. }
  83. //删除地址
  84. $pattern = "/^withdrawAddress@@del\d+$/";
  85. if (preg_match($pattern, $data)) {
  86. $id = preg_replace('/^withdrawAddress@@del/', '', $data);
  87. $res = WithdrawService::delAddress($chatId, $id, $messageId);
  88. $telegram->editMessageText($res);
  89. }
  90. //地址详情
  91. $pattern = "/^withdrawAddress@@detail\d+$/";
  92. if (preg_match($pattern, $data)) {
  93. $id = preg_replace('/^withdrawAddress@@detail/', '', $data);
  94. $res = WithdrawService::addressDetails($chatId, $messageId, $id);
  95. $telegram->editMessageText($res);
  96. }
  97. //教程帮助
  98. $pattern = "/^Tutorial@@\d+$/";
  99. if (preg_match($pattern, $data)) {
  100. $index = preg_replace('/^Tutorial@@/', '', $data);
  101. $res = TutorialService::help($chatId, $index, $messageId);
  102. $telegram->editMessageText($res);
  103. }
  104. if ($data === 'Tutorial@@home') {
  105. $res = (new TutorialService())->index($chatId);
  106. $res['message_id'] = $messageId;
  107. $telegram->editMessageText($res);
  108. }
  109. //游戏房间首页
  110. $pattern = "/^games@@home\d+$/";
  111. if (preg_match($pattern, $data)) {
  112. $roomId = preg_replace('/^games@@home/', '', $data);
  113. $res = (new RoomService($telegram))->gameHome($roomId, $chatId, $messageId);
  114. $m = new Message();
  115. $m->json = json_encode($res);
  116. $m->save();
  117. $telegram->editMessageText($res);
  118. }
  119. //选择游戏
  120. $pattern = "/^inputGameName@@.+$/";
  121. if (preg_match($pattern, $data)) {
  122. $gameName = preg_replace('/^inputGameName@@/', '', $data);
  123. $roomService = new RoomService($telegram);
  124. $res = $roomService->setGameName($chatId, $gameName, $messageId);
  125. if (isset($res['message_id'])) $telegram->editMessageText($res);
  126. else $telegram->sendMessage($res);
  127. }
  128. //选择中途加入
  129. $pattern = "/^setGameMidway@@.+$/";
  130. if (preg_match($pattern, $data)) {
  131. $midway = preg_replace('/^setGameMidway@@/', '', $data);
  132. $roomService = new RoomService($telegram);
  133. $res = $roomService->setGameMidway($chatId, $midway, $messageId);
  134. if (isset($res['message_id'])) $telegram->editMessageText($res);
  135. else $telegram->sendMessage($res);
  136. }
  137. //确认游戏ID
  138. $pattern = "/^inputGameID@@\d+$/";
  139. if (preg_match($pattern, $data)) {
  140. $gameId = preg_replace('/^inputGameID@@/', '', $data);
  141. $rs = new RoomService($telegram);
  142. $res = $rs->setGameID($chatId, $gameId, $messageId);
  143. foreach ($res as $r) {
  144. if (isset($r['message_id'])) {
  145. $telegram->editMessageText($r);
  146. } else {
  147. $telegram->sendMessage($r);
  148. }
  149. }
  150. }
  151. //房间低分
  152. $pattern = '/^roomMin@@.*/';
  153. if (preg_match($pattern, $data)) {
  154. $roomService = new RoomService($telegram);
  155. $res = $roomService->setMin($data, $chatId, $messageId);
  156. if (isset($res['message_id'])) {
  157. $telegram->editMessageText($res);
  158. } else {
  159. $telegram->sendMessage($res);
  160. }
  161. }
  162. //删除本条数据
  163. if ($data === 'del@@message') {
  164. $telegram->deleteMessage([
  165. 'chat_id' => $chatId,
  166. 'message_id' => $messageId,
  167. ]);
  168. }
  169. //确认创建房间
  170. if ($data === 'room@@done') {
  171. $roomService = new RoomService($telegram);
  172. $res = $roomService->done($chatId, $messageId);
  173. foreach ($res as $r) {
  174. if (isset($r['message_id'])) {
  175. $telegram->editMessageText($r);
  176. } else {
  177. $telegram->sendMessage($r);
  178. }
  179. }
  180. }
  181. //客服帮助
  182. if ($data === "/tutorial") {
  183. $res = (new TutorialService())->index($chatId);
  184. $telegram->sendMessage($res);
  185. }
  186. //点击提现按钮
  187. if ($data === "withdraw@@apply") {
  188. $res = (new WithdrawService())->apply($chatId, $messageId);
  189. $telegram->editMessageText($res);
  190. }
  191. //地址管理
  192. if ($data === 'withdraw@@address') {
  193. $res = WithdrawService::getAddress($chatId, $messageId);
  194. $telegram->editMessageText($res);
  195. }
  196. //点击充值按钮
  197. if ($data === 'topup@@topup') {
  198. $telegram->deleteMessage([
  199. 'chat_id' => $chatId,
  200. 'message_id' => $messageId,
  201. ]);
  202. $topService = new TopUpService();
  203. $res = $topService->scan($chatId, $messageId);
  204. $telegram->sendPhoto($res);
  205. }
  206. //点击充值的账单按钮
  207. if ($data === 'topup@@bill') {
  208. $res = (new TopUpService())->bill($chatId, $firstName, $messageId);
  209. $telegram->editMessageText($res);
  210. // $text = "📅 请输入查询日期\n";
  211. // $date = date('Y-m-d');
  212. // $text .= "例如您要查询的日期 {$date}\n";
  213. // $text .= "那么请发送:【充值账单】{$date}\n";
  214. // $telegram->sendMessage([
  215. // 'chat_id' => $chatId,
  216. // 'text' => $text
  217. // ]);
  218. }
  219. //关闭本条消息
  220. if ($data === 'message@@close') {
  221. $telegram->deleteMessage([
  222. 'chat_id' => $chatId,
  223. 'message_id' => $messageId
  224. ]);
  225. }
  226. if ($data === 'withdrawAddress@@add') {
  227. $res = WithdrawService::addAddress($chatId, $messageId);
  228. $telegram->editMessageText($res);
  229. }
  230. //提现管理
  231. if ($data === "withdraw@@home") {
  232. $res = WithdrawService::index($chatId, $firstName, $messageId);
  233. $telegram->editMessageText($res);
  234. }
  235. //点击提现的账单按钮
  236. if ($data === "withdraw@@bill") {
  237. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId);
  238. $telegram->editMessageText($res);
  239. // $telegram->sendMessage($res);
  240. // $text = "📅 请输入查询日期\n";
  241. // $date = date('Y-m-d');
  242. // $text .= "例如您要查询的日期 {$date}\n";
  243. // $text .= "那么请发送:【提现账单】{$date}\n";
  244. // $telegram->sendMessage([
  245. // 'chat_id' => $chatId,
  246. // 'text' => $text
  247. // ]);
  248. }
  249. //充值首页
  250. if ($data === "topUp@@home" || $data === "topUp@@home1") {
  251. $res = (new TopUpService())->index($chatId, $firstName, $messageId);
  252. if ($data === "topUp@@home1") {
  253. $telegram->deleteMessage([
  254. 'chat_id' => $chatId,
  255. 'message_id' => $messageId
  256. ]);
  257. $telegram->sendMessage($res);
  258. } else {
  259. $telegram->editMessageText($res);
  260. }
  261. }
  262. //点击我已付款按钮
  263. //手动充值(后台审核后到账)
  264. if ($data === 'topUp@@pay2') {
  265. $telegram->deleteMessage([
  266. 'chat_id' => $chatId,
  267. 'message_id' => $messageId
  268. ]);
  269. $res = TopUpService::pay2($chatId);
  270. $telegram->sendMessage($res);
  271. } //
  272. //自动充值
  273. elseif ($data === 'topUp@@pay') {
  274. $telegram->deleteMessage([
  275. 'chat_id' => $chatId,
  276. 'message_id' => $messageId
  277. ]);
  278. $topService = new TopUpService();
  279. $res = $topService->done($chatId);
  280. $telegram->sendMessage($res);
  281. }
  282. //充值账单,下一页
  283. $pattern = "/^topUpBillNextPage@@\d+$/";
  284. if (preg_match($pattern, $data)) {
  285. $page = preg_replace('/^topUpBillNextPage@@/', '', $data);
  286. $page = intval($page);
  287. $res = (new TopUpService())->bill($chatId, $firstName, $messageId, $page);
  288. $telegram->editMessageText($res);
  289. }
  290. //提现账单,下一页
  291. $pattern = "/^withdrawBillNextPage@@\d+$/";
  292. if (preg_match($pattern, $data)) {
  293. $page = preg_replace('/^withdrawBillNextPage@@/', '', $data);
  294. $page = intval($page);
  295. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId, $page);
  296. $telegram->editMessageText($res);
  297. }
  298. //提前开始游戏
  299. $pattern = "/^games@@start\d+$/";
  300. if (preg_match($pattern, $data)) {
  301. $roomId = preg_replace('/^games@@start/', '', $data);
  302. $roomService = new RoomService($telegram);
  303. $res = $roomService->start($chatId, $roomId, $messageId);
  304. foreach ($res as $r) {
  305. if (isset($r['message_id'])) {
  306. $telegram->editMessageText($r);
  307. } else {
  308. $telegram->sendMessage($r);
  309. }
  310. }
  311. }
  312. //解散房间
  313. $pattern = "/^games@@Disband\d+$/";
  314. if (preg_match($pattern, $data)) {
  315. $roomService = new RoomService($telegram);
  316. $roomId = preg_replace('/^games@@Disband/', '', $data);
  317. $res = $roomService->disband($roomId, $chatId, $messageId);
  318. foreach ($res as $r) {
  319. if (isset($r['message_id'])) {
  320. $telegram->editMessageText($r);
  321. } else {
  322. $telegram->sendMessage($r);
  323. }
  324. }
  325. }
  326. //退出房间
  327. $pattern = "/^games@@exit\d+$/";
  328. if (preg_match($pattern, $data)) {
  329. $roomService = new RoomService($telegram);
  330. $res = $roomService->exit($data, $chatId, $messageId);
  331. if (isset($res['message_id'])) $telegram->editMessageText($res);
  332. else $telegram->sendMessage($res);
  333. }
  334. //人员/状态
  335. $pattern = "/^games@@status\d+$/";
  336. if (preg_match($pattern, $data)) {
  337. $roomId = preg_replace('/^games@@status/', '', $data);
  338. $roomService = new RoomService($telegram);
  339. $res = $roomService->userStatus($roomId, $chatId, $messageId);
  340. if (isset($res['message_id'])) $telegram->editMessageText($res);
  341. else $telegram->sendMessage($res);
  342. }
  343. //准备
  344. $pattern = "/^games@@ready\d+$/";
  345. if (preg_match($pattern, $data)) {
  346. $roomId = preg_replace('/^games@@ready/', '', $data);
  347. $res = (new RoomService($telegram))->ready($roomId, $chatId, $messageId);
  348. foreach ($res as $r) {
  349. if (isset($r['message_id'])) {
  350. $telegram->editMessageText($r);
  351. } else {
  352. $telegram->sendMessage($r);
  353. }
  354. }
  355. }
  356. //结算游戏
  357. $pattern = "/^games@@settle\d+$/";
  358. if (preg_match($pattern, $data)) {
  359. $roomId = preg_replace('/^games@@settle/', '', $data);
  360. $res = (new SettlementService())->settle($roomId, $chatId, $messageId);
  361. if (isset($res['message_id'])) $telegram->editMessageText($res);
  362. else $telegram->sendMessage($res);
  363. }
  364. //在线房间,下一页
  365. $pattern = "/^onlineNextPage@@\d+$/";
  366. if (preg_match($pattern, $data)) {
  367. $page = preg_replace('/^onlineNextPage@@/', '', $data);
  368. $page = intval($page);
  369. $res = (new OnLineService())->getList($chatId, $messageId, $page);
  370. $telegram->editMessageText($res);
  371. }
  372. //我的战绩,下一页
  373. $pattern = "/^recordNextPage@@\d+$/";
  374. if (preg_match($pattern, $data)) {
  375. $page = preg_replace('/^recordNextPage@@/', '', $data);
  376. $page = intval($page);
  377. $res = (new RecordService())->getList($chatId, $firstName, $messageId, $page);
  378. $telegram->editMessageText($res);
  379. }
  380. //加入房间
  381. $pattern = "/^join@@\d+$/";
  382. if (preg_match($pattern, $data)) {
  383. $roomId = preg_replace('/^join@@/', '', $data);
  384. $res = (new RoomService($telegram))->join($chatId, $roomId, $messageId);
  385. foreach ($res as $r) {
  386. if (isset($r['message_id'])) {
  387. $telegram->editMessageText($r);
  388. } else {
  389. $telegram->sendMessage($r);
  390. }
  391. }
  392. }
  393. //输入房间号加入房间
  394. if ($data === 'join@@room') {
  395. $res = OnLineService::joinRoom($chatId, $messageId);
  396. $telegram->editMessageText($res);
  397. }
  398. //通过频道加入房间
  399. $pattern = "/^channelJoin@@\d+$/";
  400. if (preg_match($pattern, $data)) {
  401. $roomId = preg_replace('/^channelJoin@@/', '', $data);
  402. $res = (new RoomService($telegram))->join($from->id, $roomId);
  403. foreach ($res as $r) {
  404. if (isset($r['message_id'])) {
  405. $telegram->editMessageText($r);
  406. } else {
  407. $telegram->sendMessage($r);
  408. }
  409. }
  410. }
  411. DB::commit();
  412. } //
  413. catch (MessageException $e) {
  414. DB::rollBack();
  415. $msg = $e->getMessage();
  416. $msg = json_decode($msg, true);
  417. $telegram->sendMessage($msg);
  418. } //
  419. catch (TelegramSDKException $e) {
  420. DB::rollBack();
  421. $m = new Message();
  422. $m->json = $e->getMessage();
  423. $m->save();
  424. $telegram->sendMessage([
  425. 'chat_id' => $chatId,
  426. 'text' => '‼️‼️系统发生了错误,请联系客服'
  427. ]);
  428. }//
  429. catch (\Exception $e) {
  430. DB::rollBack();
  431. $m = new Message();
  432. $m->json = json_encode([
  433. 'line' => $e->getLine(),
  434. 'message' => $e->getMessage()
  435. ]);
  436. $m->save();
  437. $telegram->sendMessage([
  438. 'chat_id' => $chatId,
  439. 'text' => '‼️‼️系统发生了错误,请联系客服'
  440. ]);
  441. }
  442. } //
  443. else {
  444. $update = $request->all();
  445. if (isset($update['message'])) {
  446. $message = $update['message'];
  447. $chatId = $message['chat']['id'];
  448. $messageId = $message['message_id'];
  449. DB::beginTransaction();
  450. try {
  451. $m = new Message();
  452. $m->json = json_encode($update);
  453. $m->save();
  454. $user = User::where('member_id', $chatId)->first();
  455. if (!$user) {
  456. $user = new User();
  457. $user->member_id = $chatId;
  458. }
  459. $user->first_name = $message['chat']['first_name'];
  460. $user->save();
  461. //给每个用户生成一个专属的USDT钱包
  462. WalletService::getUserWallet($chatId);
  463. //用户发送图片,结算截图
  464. if (isset($message['photo'])) {
  465. $stepStatus = Cache::get(get_step_key($chatId), -1);
  466. $stepStatus = intval($stepStatus);
  467. //结算截图
  468. if ($stepStatus === StepStatus::INPUT_IMAGE) {
  469. $photo = $message['photo'][count($message['photo']) - 1];
  470. $res = (new SettlementService())->photo($photo, $chatId);
  471. if ($res) $telegram->sendMessage($res);
  472. }//
  473. //充值截图
  474. else if ($stepStatus === StepStatus::INPUT_TOP_UP_IMAGE) {
  475. $photo = $message['photo'][count($message['photo']) - 1];
  476. $res = TopUpService::photo($chatId, $photo);
  477. if (isset($res['message_id'])) $telegram->editMessageText($res);
  478. else $telegram->sendMessage($res);
  479. }
  480. } //用户发送了消息
  481. else if (isset($message['text'])) {
  482. $text = $message['text'];
  483. if ($message['chat']['type'] === 'private') {
  484. switch ($text) {
  485. //教程帮助
  486. case "/tutorial":
  487. Util::delCache($chatId);
  488. $res = (new TutorialService())->index($chatId);
  489. $telegram->sendMessage($res);
  490. break;
  491. //提现管理
  492. case "/withdraw":
  493. Util::delCache($chatId);
  494. $res = WithdrawService::index($chatId, $message['chat']['first_name']);
  495. $telegram->sendMessage($res);
  496. break;
  497. //我的战绩
  498. case "/record":
  499. Util::delCache($chatId);
  500. $res = (new RecordService())->getList($chatId, $message['chat']['first_name']);
  501. $telegram->sendMessage($res);
  502. break;
  503. //充值管理
  504. case "/topup":
  505. Util::delCache($chatId);
  506. $res = (new TopUpService())->index($chatId, $message['chat']['first_name']);
  507. $telegram->sendMessage($res);
  508. break;
  509. //在线房间
  510. case"/online":
  511. Util::delCache($chatId);
  512. $data = (new OnLineService())->getList($chatId, null, 1);
  513. $telegram->sendMessage($data);
  514. break;
  515. //创建房间
  516. case "/room":
  517. Util::delCache($chatId);
  518. $roomService = new RoomService($telegram);
  519. $res = $roomService->create($chatId);
  520. $telegram->sendMessage($res);
  521. break;
  522. case "/start":
  523. Util::delCache($chatId);
  524. $user = User::where('member_id', $chatId)->first();
  525. if (!$user) {
  526. $user = new User();
  527. $user->member_id = $chatId;
  528. }
  529. $user->first_name = $message['chat']['first_name'];
  530. $user->save();
  531. //给每个用户生成一个专属的USDT钱包
  532. WalletService::getUserWallet($chatId);
  533. $username = config('services.telegram.username');
  534. $telegram->sendMessage(['chat_id' => $chatId, 'text' => "🎉欢迎使用 @{$username}"]);
  535. break;
  536. default:
  537. $stepStatus = Cache::get(get_step_key($chatId), -1);
  538. $stepStatus = intval($stepStatus);
  539. switch ($stepStatus) {
  540. case StepStatus::INPUT_GAME_INTRODUCTION:
  541. $res = (new RoomService($telegram))->setIntroduction($chatId, $text, $messageId);
  542. if (isset($res['message_id'])) $telegram->editMessageText($res);
  543. else $telegram->sendMessage($res);
  544. break;
  545. case StepStatus::INPUT_TOP_UP_MONEY:
  546. $res = TopUpService::inputAmount($chatId, $text, $messageId);
  547. if (isset($res['message_id'])) $telegram->editMessageText($res);
  548. else $telegram->sendMessage($res);
  549. break;
  550. case StepStatus::INPUT_JOIN_ROOM_ID:
  551. $res = OnLineService::join($chatId, $text, $messageId);
  552. foreach ($res as $r) {
  553. if (isset($r['message_id'])) $telegram->editMessageText($r);
  554. else $telegram->sendMessage($r);
  555. }
  556. break;
  557. case StepStatus::INPUT_ADDRESS_ALIAS:
  558. $res = WithdrawService::inputAlias($chatId, $text, $messageId);
  559. $telegram->sendMessage($res);
  560. break;
  561. case StepStatus::INPUT_ADDRESS_TRC20:
  562. $res = WithdrawService::inputAddress($chatId, $text, $messageId);
  563. $telegram->sendMessage($res);
  564. break;
  565. case StepStatus::INPUT_WITHDRAW_MONEY:
  566. $res = (new WithdrawService())->inputAmount($chatId, $text, $messageId);
  567. foreach ($res as $r) $telegram->sendMessage($r);
  568. break;
  569. case StepStatus::INPUT_TOP_UP_IMAGE:
  570. $telegram->sendMessage([
  571. 'chat_id' => $chatId,
  572. 'text' => "输入错误,请上传充值截图!",
  573. 'reply_to_message_id' => $messageId
  574. ]);
  575. break;
  576. case StepStatus::INPUT_IMAGE:
  577. $telegram->sendMessage([
  578. 'chat_id' => $chatId,
  579. 'text' => "输入错误,请上传战绩截图!",
  580. 'reply_to_message_id' => $messageId
  581. ]);
  582. break;
  583. //输入结算分数
  584. case StepStatus::INPUT_SCORE:
  585. $res = (new SettlementService())->submitSettle($chatId, $text, $messageId);
  586. foreach ($res['data'] as $r) $telegram->sendMessage($r);
  587. break;
  588. //输入游戏名称
  589. case StepStatus::INPUT_GAME_NAME:
  590. $gameName = $text;
  591. $roomService = new RoomService($telegram);
  592. $res = $roomService->setGameName($chatId, $gameName, $messageId);
  593. if (isset($res['message_id'])) $telegram->editMessageText($res);
  594. else $telegram->sendMessage($res);
  595. break;
  596. //输入房间号
  597. case StepStatus::INPUT_ROOM_ID:
  598. $roomId = $text;
  599. $roomService = new RoomService($telegram);
  600. $res = $roomService->setNum($chatId, $roomId, $messageId);
  601. if (isset($res['message_id'])) $telegram->editMessageText($res);
  602. else $telegram->sendMessage($res);
  603. break;
  604. //输入是否允许中途加入
  605. case StepStatus::INPUT_MIDWAY:
  606. $midway = $text;
  607. $roomService = new RoomService($telegram);
  608. $res = $roomService->setGameMidway($chatId, $midway, $messageId);
  609. if (isset($res['message_id'])) $telegram->editMessageText($res);
  610. else $telegram->sendMessage($res);
  611. break;
  612. //输入 人数/局数
  613. case StepStatus::INPUT_ROOM_NUM:
  614. $array = explode('/', $text);
  615. $roomService = new RoomService($telegram);
  616. $res = $roomService->setNumberOfGames($chatId, $array, $messageId);
  617. if (isset($res['message_id'])) $telegram->editMessageText($res);
  618. else $telegram->sendMessage($res);
  619. break;
  620. //输入 游戏ID
  621. case StepStatus::INPUT_GAME_ID:
  622. $gameId = $text;
  623. $rs = new RoomService($telegram);
  624. $res = $rs->setGameID($chatId, $gameId, $messageId);
  625. foreach ($res as $r) {
  626. if (isset($r['message_id'])) $telegram->editMessageText($r);
  627. else $telegram->sendMessage($r);
  628. }
  629. break;
  630. break;
  631. default:
  632. Util::delCache($chatId);
  633. $res = (new TutorialService())->index($chatId);
  634. $telegram->sendMessage($res);
  635. break;
  636. }
  637. break;
  638. }
  639. }
  640. }
  641. DB::commit();
  642. } //
  643. catch (MessageException $e) {
  644. DB::rollBack();
  645. $m = new Message();
  646. $m->json = $e->getMessage();
  647. $m->save();
  648. try {
  649. $msg = $e->getMessage();
  650. $msg = json_decode($msg, true);
  651. $telegram->sendMessage($msg);
  652. } catch (TelegramSDKException $e) {
  653. }
  654. } //
  655. catch (TelegramSDKException $e) {
  656. DB::rollBack();
  657. $m = new Message();
  658. $m->json = $e->getMessage();
  659. $m->save();
  660. $telegram->sendMessage([
  661. 'chat_id' => $chatId,
  662. 'text' => '‼️‼️系统发生了错误,请联系客服'
  663. ]);
  664. }//
  665. catch (\Exception $e) {
  666. DB::rollBack();
  667. $m = new Message();
  668. $m->json = $e->getMessage();
  669. $m->save();
  670. $telegram->sendMessage([
  671. 'chat_id' => $chatId,
  672. 'text' => '‼️‼️系统发生了错误,请联系客服'
  673. ]);
  674. }
  675. }
  676. }
  677. return response()->json(['status' => 'ok']);
  678. }
  679. }