TelegramWebHook.php 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260
  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 App\Services\BalanceLogService;
  19. use Illuminate\Http\Request;
  20. use Illuminate\Support\Facades\Cache;
  21. use Illuminate\Support\Facades\DB;
  22. use Telegram\Bot\Api;
  23. use Telegram\Bot\Exceptions\TelegramSDKException;
  24. use Illuminate\Support\Facades\Log;
  25. use App\Models\Config;
  26. use App\Services\GameplayRuleService;
  27. use App\Services\BetService;
  28. use App\Services\IssueService;
  29. class TelegramWebHook extends Controller
  30. {
  31. protected $telegram;
  32. public function __construct(Api $telegram)
  33. {
  34. $this->telegram = $telegram;
  35. }
  36. public function handle(Request $request)
  37. {
  38. Log::error('Telegram 日志写入测试: ' . json_encode([$request->ip()], JSON_UNESCAPED_UNICODE));
  39. // try {
  40. $m = new Message();
  41. $m->json = $request->ip();
  42. $m->save();
  43. $telegram = new Api(config('services.telegram.token'));
  44. // } catch (TelegramSDKException $e) {
  45. // return response()->json(['status' => 'ok']);
  46. // }
  47. $update = $telegram->getWebhookUpdate(); // 获取更新数据
  48. $update->callbackQuery;
  49. if ($update->has('callback_query')) {
  50. $json['type'] = 'callback_query';
  51. $callbackQuery = $update->callbackQuery;
  52. $json['update'] = $callbackQuery;
  53. $message = $callbackQuery->message;
  54. $from = $callbackQuery->from;
  55. $data = $callbackQuery->data; // 获取 callback_data
  56. $callbackId = $callbackQuery->id; // 获取 callback_query 的 ID
  57. $m = new Message();
  58. $m->json = $data;
  59. $m->save();
  60. Util::delCache($message->chat->id);
  61. Log::error('Telegram 回调数据(JSON): ' . json_encode($update, JSON_UNESCAPED_UNICODE));
  62. DB::beginTransaction();
  63. try {
  64. $chatId = $message->chat->id;
  65. $firstName = $message->chat->firstName;
  66. $messageId = $message->messageId;
  67. if (!$from->isBot) {
  68. $chatId = $from->id;
  69. $firstName = $from->firstName;
  70. }
  71. $user = User::where('member_id', $chatId)->first();
  72. if (!$user) {
  73. $user = new User();
  74. $user->member_id = $chatId;
  75. }
  76. $user->first_name = $firstName;
  77. $user->save();
  78. //给每个用户生成一个专属的USDT钱包
  79. WalletService::getUserWallet($chatId);
  80. // 查看余额弹窗
  81. if($data === 'balanceAlert'){
  82. $alertText = WalletService::getBalance($chatId)['text'];
  83. WalletService::alertNotice($callbackId , $alertText);
  84. }
  85. // 今日流水弹窗
  86. if($data === 'todayFlowAlert'){
  87. $alertText = BalanceLogService::getTodayFlowing($chatId)['text'];
  88. BalanceLogService::alertNotice($callbackId , $alertText);
  89. }
  90. // 近期注单弹窗
  91. if($data === 'betsAlert'){
  92. $alertText = BetService::recentlyRecord($chatId);
  93. BetService::alertNotice($callbackId , $alertText);
  94. }
  95. //点击充值按钮
  96. if ($data === 'topup@@topup') {
  97. $telegram->deleteMessage([
  98. 'chat_id' => $chatId,
  99. 'message_id' => $messageId,
  100. ]);
  101. $topService = new TopUpService();
  102. $res = $topService->scan($chatId, $messageId);
  103. $telegram->sendPhoto($res);
  104. }
  105. //点击充值的账单按钮
  106. if ($data === 'topup@@bill') {
  107. $res = (new TopUpService())->bill($chatId, $firstName, $messageId);
  108. $telegram->editMessageText($res);
  109. // $text = "📅 请输入查询日期\n";
  110. // $date = date('Y-m-d');
  111. // $text .= "例如您要查询的日期 {$date}\n";
  112. // $text .= "那么请发送:【充值账单】{$date}\n";
  113. // $telegram->sendMessage([
  114. // 'chat_id' => $chatId,
  115. // 'text' => $text
  116. // ]);
  117. }
  118. //点击我已付款按钮
  119. //手动充值(后台审核后到账)
  120. if ($data === 'topUp@@pay2') {
  121. $telegram->deleteMessage([
  122. 'chat_id' => $chatId,
  123. 'message_id' => $messageId
  124. ]);
  125. $res = TopUpService::pay2($chatId);
  126. $telegram->sendMessage($res);
  127. } //
  128. //自动充值
  129. elseif ($data === 'topUp@@pay') {
  130. $telegram->deleteMessage([
  131. 'chat_id' => $chatId,
  132. 'message_id' => $messageId
  133. ]);
  134. $topService = new TopUpService();
  135. $res = $topService->done($chatId);
  136. $telegram->sendMessage($res);
  137. }
  138. //充值首页
  139. if ($data === "topUp@@home" || $data === "topUp@@home1") {
  140. // $res = (new TopUpService())->index($chatId, $firstName, $messageId);
  141. $telegram->deleteMessage([
  142. 'chat_id' => $chatId,
  143. 'message_id' => $messageId
  144. ]);
  145. $returnMsg = WalletService::getBalance($chatId);
  146. if($returnMsg){
  147. $this->telegram->sendMessage($returnMsg);
  148. }
  149. // if ($data === "topUp@@home1") {
  150. // $telegram->deleteMessage([
  151. // 'chat_id' => $chatId,
  152. // 'message_id' => $messageId
  153. // ]);
  154. // $telegram->sendMessage($res);
  155. // } else {
  156. // $telegram->editMessageText($res);
  157. // }
  158. }
  159. //点击提现按钮
  160. if ($data === "withdraw@@apply") {
  161. $res = (new WithdrawService())->apply($chatId, $messageId);
  162. $telegram->editMessageText($res);
  163. }
  164. //地址管理
  165. if ($data === 'withdraw@@address') {
  166. $res = WithdrawService::getAddress($chatId, $messageId);
  167. $telegram->editMessageText($res);
  168. }
  169. //关闭本条消息
  170. if ($data === 'message@@close') {
  171. $telegram->deleteMessage([
  172. 'chat_id' => $chatId,
  173. 'message_id' => $messageId
  174. ]);
  175. }
  176. if ($data === 'withdrawAddress@@add') {
  177. $res = WithdrawService::addAddress($chatId, $messageId);
  178. $telegram->editMessageText($res);
  179. }
  180. //提现管理
  181. if ($data === "withdraw@@home") {
  182. // $res = WithdrawService::index($chatId, $firstName, $messageId);
  183. // $telegram->editMessageText($res);
  184. $telegram->deleteMessage([
  185. 'chat_id' => $chatId,
  186. 'message_id' => $messageId
  187. ]);
  188. $returnMsg = WalletService::getBalance($chatId);
  189. if($returnMsg){
  190. $this->telegram->sendMessage($returnMsg);
  191. }
  192. }
  193. //点击提现的账单按钮
  194. if ($data === "withdraw@@bill") {
  195. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId);
  196. $telegram->editMessageText($res);
  197. // $telegram->sendMessage($res);
  198. // $text = "📅 请输入查询日期\n";
  199. // $date = date('Y-m-d');
  200. // $text .= "例如您要查询的日期 {$date}\n";
  201. // $text .= "那么请发送:【提现账单】{$date}\n";
  202. // $telegram->sendMessage([
  203. // 'chat_id' => $chatId,
  204. // 'text' => $text
  205. // ]);
  206. }
  207. if ($data === 'withdrawAddress@@done') {
  208. $res = WithdrawService::done($chatId, $messageId, $firstName);
  209. $telegram->editMessageText($res);
  210. }
  211. //选择提现地址
  212. $pattern = "/^withdrawAddress@@choose\d+$/";
  213. if (preg_match($pattern, $data)) {
  214. $id = preg_replace('/^withdrawAddress@@choose/', '', $data);
  215. $res = WithdrawService::chooseAddress($chatId, $firstName, $messageId, $id);
  216. $telegram->editMessageText($res);
  217. }
  218. //删除地址
  219. $pattern = "/^withdrawAddress@@del\d+$/";
  220. if (preg_match($pattern, $data)) {
  221. $id = preg_replace('/^withdrawAddress@@del/', '', $data);
  222. $res = WithdrawService::delAddress($chatId, $id, $messageId);
  223. $telegram->editMessageText($res);
  224. }
  225. //地址详情
  226. $pattern = "/^withdrawAddress@@detail\d+$/";
  227. if (preg_match($pattern, $data)) {
  228. $id = preg_replace('/^withdrawAddress@@detail/', '', $data);
  229. $res = WithdrawService::addressDetails($chatId, $messageId, $id);
  230. $telegram->editMessageText($res);
  231. }
  232. //充值账单,下一页
  233. $pattern = "/^topUpBillNextPage@@\d+$/";
  234. if (preg_match($pattern, $data)) {
  235. $page = preg_replace('/^topUpBillNextPage@@/', '', $data);
  236. $page = intval($page);
  237. $res = (new TopUpService())->bill($chatId, $firstName, $messageId, $page);
  238. $telegram->editMessageText($res);
  239. }
  240. //提现账单,下一页
  241. $pattern = "/^withdrawBillNextPage@@\d+$/";
  242. if (preg_match($pattern, $data)) {
  243. $page = preg_replace('/^withdrawBillNextPage@@/', '', $data);
  244. $page = intval($page);
  245. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId, $page);
  246. $telegram->editMessageText($res);
  247. }
  248. //近期注单,下一页
  249. $pattern = "/^betRecordNextPage@@\d+$/";
  250. if (preg_match($pattern, $data)) {
  251. $page = preg_replace('/^betRecordNextPage@@/', '', $data);
  252. $page = intval($page);
  253. $res = BetService::record($chatId ,$messageId ,$page );
  254. $telegram->editMessageText($res);
  255. }
  256. DB::commit();
  257. } //
  258. catch (MessageException $e) {
  259. DB::rollBack();
  260. $msg = $e->getMessage();
  261. $msg = json_decode($msg, true);
  262. $telegram->sendMessage($msg);
  263. } //
  264. catch (TelegramSDKException $e) {
  265. DB::rollBack();
  266. $m = new Message();
  267. $m->json = $e->getMessage();
  268. $m->save();
  269. $telegram->sendMessage([
  270. 'chat_id' => $chatId,
  271. 'text' => '‼️‼️系统发生了错误,请联系客服'
  272. ]);
  273. }//
  274. catch (\Exception $e) {
  275. DB::rollBack();
  276. $m = new Message();
  277. $m->json = json_encode([
  278. 'line' => $e->getLine(),
  279. 'message' => $e->getMessage()
  280. ]);
  281. $m->save();
  282. $telegram->sendMessage([
  283. 'chat_id' => $chatId,
  284. 'text' => '‼️‼️系统发生了错误,请联系客服'
  285. ]);
  286. }
  287. }else {
  288. $update = $request->all();
  289. Log::error('Telegram 文字消息回复: ' . json_encode($update, JSON_UNESCAPED_UNICODE));
  290. if (isset($update['message'])) {
  291. $message = $update['message'];
  292. $chatId = $message['chat']['id'];
  293. $messageId = $message['message_id'];
  294. DB::beginTransaction();
  295. try {
  296. $m = new Message();
  297. $m->json = json_encode($update);
  298. $m->save();
  299. $returnMsg = $this->processChatMessage($chatId, $messageId, $message, $message['from']);
  300. if($returnMsg){
  301. $this->telegram->sendMessage($returnMsg);
  302. }
  303. DB::commit();
  304. }
  305. catch (MessageException $e) {
  306. DB::rollBack();
  307. $msg = $e->getMessage();
  308. $msg = json_decode($msg, true);
  309. $telegram->sendMessage($msg);
  310. } //
  311. catch (TelegramSDKException $e) {
  312. DB::rollBack();
  313. $m = new Message();
  314. $m->json = $e->getMessage();
  315. $m->save();
  316. $telegram->sendMessage([
  317. 'chat_id' => $chatId,
  318. 'text' => '‼️‼️系统发生了错误,请联系客服'
  319. ]);
  320. }//
  321. catch (\Exception $e) {
  322. DB::rollBack();
  323. $m = new Message();
  324. $m->json = json_encode([
  325. 'line' => $e->getLine(),
  326. 'message' => $e->getMessage()
  327. ]);
  328. $m->save();
  329. Log::error('Telegram 处理消息异常: ' . $e->getMessage());
  330. $telegram->sendMessage([
  331. 'chat_id' => $chatId,
  332. 'text' => '‼️‼️系统发生了错误,请联系客服'
  333. ]);
  334. }
  335. }
  336. }
  337. return response()->json(['status' => 'ok']);
  338. }
  339. /**
  340. * @description: 处理聊天消息
  341. * @param {*} $chatId
  342. * @param {*} $messageId
  343. * @param {*} $message
  344. * @param {*} $from
  345. * @return {*}
  346. */
  347. public function processChatMessage($chatId, $messageId, $message, $from)
  348. {
  349. $returnMsg = [];
  350. //用户发送图片,结算截图
  351. if (isset($message['photo'])) {
  352. $stepStatus = Cache::get(get_step_key($chatId), -1);
  353. $stepStatus = intval($stepStatus);
  354. // //结算截图
  355. // if ($stepStatus === StepStatus::INPUT_IMAGE) {
  356. // $photo = $message['photo'][count($message['photo']) - 1];
  357. // $res = (new SettlementService())->photo($photo, $chatId);
  358. // if ($res) $telegram->sendMessage($res);
  359. // }//
  360. // //充值截图
  361. // else
  362. if ($stepStatus === StepStatus::INPUT_TOP_UP_IMAGE) {
  363. $photo = $message['photo'][count($message['photo']) - 1];
  364. $res = TopUpService::photo($chatId, $photo);
  365. return $res;
  366. // if (isset($res['message_id'])) $telegram->editMessageText($res);
  367. // else $telegram->sendMessage($res);
  368. }
  369. } //用户发送了消息
  370. else if (isset($message['text'])) {
  371. $text = $message['text'];
  372. if ($message['chat']['type'] === 'private') {
  373. switch ($text) {
  374. case "/start":
  375. Util::delCache($chatId);
  376. $user = User::where('member_id', $chatId)->first();
  377. if (!$user) {
  378. $user = new User();
  379. $user->member_id = $chatId;
  380. }
  381. $user->first_name = $message['chat']['first_name'];
  382. $user->save();
  383. //给每个用户生成一个专属的USDT钱包
  384. WalletService::getUserWallet($chatId);
  385. $username = config('services.telegram.username');
  386. $this->setReplyKeyboard($chatId);
  387. break;
  388. case "近期注单":
  389. Util::delCache($chatId);
  390. $returnMsg = BetService::record($chatId);
  391. // $this->telegram->sendMessage([
  392. // 'chat_id' => $chatId,
  393. // 'text' => $text
  394. // ]);
  395. break;
  396. case "今日流水":
  397. Util::delCache($chatId);
  398. $returnMsg = BalanceLogService::getTodayFlowing($chatId);
  399. // $this->telegram->sendMessage($result);
  400. break;
  401. case "联系客服":
  402. Util::delCache($chatId);
  403. $receivingAddress = Config::where('field', 'receiving_address')->first()->val;
  404. $serviceAccount = Config::where('field', 'service_account')->first()->val;
  405. $text = "官方唯一上分地址:\n";
  406. $text .= "USDT: \n";
  407. $text .= "{$receivingAddress}\n\n\n";
  408. $text .= "‼️特别注意‼️特别注意‼️\n";
  409. $text .= "‼️近期骗子肆意妄为,猖狂狡诈。经常冒充我方财务,管理人员以各种手段行使诈骗之术。多数为要求转账/提供验证码等。任何主动私聊您的都是非奸即盗。望各位老板谨记,预防受骗!\n";
  410. $text .= "‼️本群管理以及财务绝不会主动私聊客户。请各位老板务必认准群内带标识管理账号,转账前务必核对是否官方账号以及地址。任何一切不是官方行为的受骗上当,本群概不负责,谢谢!\n";
  411. $text .= "‼️为了您的资金安全,下分更换地址请提前告知财务,并使用原地址进行转账或录屏进行身份核实,核实为本人操作后才可进行更换地址下分\n";
  412. $text .= "‼️如查分金额与实际转账金额不同,请重新喊查。玩家重复查3次以上错误金额则视为恶意捣乱,将不退还转账金额!\n";
  413. $text .= "‼️如因为人为失误问题,到账金额与玩家实际转账金额不符,到账后的一切下注视为无效。\n";
  414. $text .= "‼️本群不接待以任何形式刷水的水军,一经发现玩家存在刷水行为将扣除历史所有返水、彩金。并冻结分数一个月,每天仅可下分账户余额10%。不纠结,不解释,请各大水军自行绕道。\n";
  415. $keyboard = [];
  416. $keyboard[] = [['text' => '✅ 唯一客服', 'callback_data' => "", 'url' => "https://t.me/{$serviceAccount}"]];
  417. $returnMsg = [
  418. 'chat_id' => $chatId,
  419. 'text' => $text,
  420. 'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
  421. ];
  422. break;
  423. case "开奖历史":
  424. Util::delCache($chatId);
  425. IssueService::currentLotteryResults($chatId);
  426. break;
  427. case "当期下注":
  428. Util::delCache($chatId);
  429. $returnMsg = BetService::currentBet($chatId);
  430. break;
  431. case "查看余额":
  432. Util::delCache($chatId);
  433. $returnMsg = WalletService::getBalance($chatId);
  434. // $this->telegram->sendMessage($result);
  435. break;
  436. case "投注大群":
  437. Util::delCache($chatId);
  438. $bettingGroup = Config::where('field', 'betting_group')->first()->val;
  439. $text = "👇👇👇点击下方按钮进群投注👇👇👇\n";
  440. $keyboard = [];
  441. $keyboard[] = [['text' => '✅ 投注群', 'callback_data' => "", 'url' => "https://t.me/{$bettingGroup}"]];
  442. $returnMsg = [
  443. 'chat_id' => $chatId,
  444. 'text' => $text,
  445. 'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
  446. ];
  447. break;
  448. default:
  449. $stepStatus = Cache::get(get_step_key($chatId), -1);
  450. $stepStatus = intval($stepStatus);
  451. switch ($stepStatus) {
  452. case StepStatus::INPUT_TOP_UP_MONEY:
  453. $res = TopUpService::inputAmount($chatId, $text, $messageId);
  454. return $res;
  455. break;
  456. case StepStatus::INPUT_WITHDRAW_MONEY:
  457. $res = (new WithdrawService())->inputAmount($chatId, $text, $messageId);
  458. return $res[0];
  459. break;
  460. case StepStatus::INPUT_ADDRESS_TRC20:
  461. $res = WithdrawService::inputAddress($chatId, $text, $messageId);
  462. return $res;
  463. break;
  464. case StepStatus::INPUT_ADDRESS_ALIAS:
  465. $res = WithdrawService::inputAlias($chatId, $text, $messageId);
  466. return $res;
  467. break;
  468. }
  469. $returnMsg = BetService::bet($chatId,$text,$messageId);
  470. // $this->telegram->sendMessage($returnMsg);
  471. }
  472. return $returnMsg;
  473. }
  474. }
  475. }
  476. /**
  477. * @description: 设置 start 回复菜单
  478. * @param {*} $chatId
  479. * @return {*}
  480. */
  481. public function setReplyKeyboard($chatId)
  482. {
  483. $telegram = new Api(config('services.telegram.token'));
  484. $keyboard = [
  485. ['近期注单', '今日流水', '联系客服'], // 第一排按钮
  486. ['开奖历史', '当期下注', '查看余额'], // 第二排按钮
  487. ['投注大群']
  488. ];
  489. $replyMarkup = [
  490. 'keyboard' => $keyboard,
  491. 'resize_keyboard' => true, // 自适应大小
  492. 'one_time_keyboard' => false, // 保持显示,不会点击后收起
  493. ];
  494. $telegram->sendMessage([
  495. 'chat_id' => $chatId,
  496. 'text' => '你好,请选择功能菜单',
  497. 'reply_markup' => json_encode($replyMarkup),
  498. ]);
  499. }
  500. public function handleMessage(Request $request)
  501. {
  502. $telegram = new Api(config('services.telegram.token'));
  503. $update = $telegram->getWebhookUpdate(); // 获取更新数据
  504. $update->callbackQuery;
  505. if ($update->has('callback_query')) {
  506. $json['type'] = 'callback_query';
  507. $callbackQuery = $update->callbackQuery;
  508. $json['update'] = $callbackQuery;
  509. $message = $callbackQuery->message;
  510. $from = $callbackQuery->from;
  511. $data = $callbackQuery->data; // 获取 callback_data
  512. $callbackId = $callbackQuery->id; // 获取 callback_query 的 ID
  513. $m = new Message();
  514. $m->json = $data;
  515. $m->save();
  516. Util::delCache($message->chat->id);
  517. DB::beginTransaction();
  518. try {
  519. $chatId = $message->chat->id;
  520. $firstName = $message->chat->firstName;
  521. $messageId = $message->messageId;
  522. if (!$from->isBot) {
  523. $chatId = $from->id;
  524. $firstName = $from->firstName;
  525. }
  526. $user = User::where('member_id', $chatId)->first();
  527. if (!$user) {
  528. $user = new User();
  529. $user->member_id = $chatId;
  530. }
  531. $user->first_name = $firstName;
  532. $user->save();
  533. //给每个用户生成一个专属的USDT钱包
  534. WalletService::getUserWallet($chatId);
  535. // 查看余额弹窗
  536. if($data === 'balanceAlert'){
  537. Log::error('查看余额弹窗 balanceAlert: ' . $callbackId);
  538. // $alertText = WalletService::getBalance($chatId)['text'];
  539. WalletService::alertNotice($callbackId , '您好,您的余额为:');
  540. }
  541. //取消创建游戏
  542. if ($data === "games@@cancel") {
  543. $roomService = new RoomService($telegram);
  544. $res = $roomService->cancel($chatId, $messageId);
  545. $telegram->editMessageText($res);
  546. }
  547. if ($data === 'withdrawAddress@@done') {
  548. $res = WithdrawService::done($chatId, $messageId, $firstName);
  549. $telegram->editMessageText($res);
  550. }
  551. //选择提现地址
  552. $pattern = "/^withdrawAddress@@choose\d+$/";
  553. if (preg_match($pattern, $data)) {
  554. $id = preg_replace('/^withdrawAddress@@choose/', '', $data);
  555. $res = WithdrawService::chooseAddress($chatId, $firstName, $messageId, $id);
  556. $telegram->editMessageText($res);
  557. }
  558. //删除地址
  559. $pattern = "/^withdrawAddress@@del\d+$/";
  560. if (preg_match($pattern, $data)) {
  561. $id = preg_replace('/^withdrawAddress@@del/', '', $data);
  562. $res = WithdrawService::delAddress($chatId, $id, $messageId);
  563. $telegram->editMessageText($res);
  564. }
  565. //地址详情
  566. $pattern = "/^withdrawAddress@@detail\d+$/";
  567. if (preg_match($pattern, $data)) {
  568. $id = preg_replace('/^withdrawAddress@@detail/', '', $data);
  569. $res = WithdrawService::addressDetails($chatId, $messageId, $id);
  570. $telegram->editMessageText($res);
  571. }
  572. //教程帮助
  573. $pattern = "/^Tutorial@@\d+$/";
  574. if (preg_match($pattern, $data)) {
  575. $index = preg_replace('/^Tutorial@@/', '', $data);
  576. $res = TutorialService::help($chatId, $index, $messageId);
  577. $telegram->editMessageText($res);
  578. }
  579. if ($data === 'Tutorial@@home') {
  580. $res = (new TutorialService())->index($chatId);
  581. $res['message_id'] = $messageId;
  582. $telegram->editMessageText($res);
  583. }
  584. //游戏房间首页
  585. $pattern = "/^games@@home\d+$/";
  586. if (preg_match($pattern, $data)) {
  587. $roomId = preg_replace('/^games@@home/', '', $data);
  588. $res = (new RoomService($telegram))->gameHome($roomId, $chatId, $messageId);
  589. $m = new Message();
  590. $m->json = json_encode($res);
  591. $m->save();
  592. $telegram->editMessageText($res);
  593. }
  594. //选择游戏
  595. $pattern = "/^inputGameName@@.+$/";
  596. if (preg_match($pattern, $data)) {
  597. $gameName = preg_replace('/^inputGameName@@/', '', $data);
  598. $roomService = new RoomService($telegram);
  599. $res = $roomService->setGameName($chatId, $gameName, $messageId);
  600. if (isset($res['message_id'])) $telegram->editMessageText($res);
  601. else $telegram->sendMessage($res);
  602. }
  603. //选择中途加入
  604. $pattern = "/^setGameMidway@@.+$/";
  605. if (preg_match($pattern, $data)) {
  606. $midway = preg_replace('/^setGameMidway@@/', '', $data);
  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. }
  612. //确认游戏ID
  613. $pattern = "/^inputGameID@@\d+$/";
  614. if (preg_match($pattern, $data)) {
  615. $gameId = preg_replace('/^inputGameID@@/', '', $data);
  616. $rs = new RoomService($telegram);
  617. $res = $rs->setGameID($chatId, $gameId, $messageId);
  618. foreach ($res as $r) {
  619. if (isset($r['message_id'])) {
  620. $telegram->editMessageText($r);
  621. } else {
  622. $telegram->sendMessage($r);
  623. }
  624. }
  625. }
  626. //房间低分
  627. $pattern = '/^roomMin@@.*/';
  628. if (preg_match($pattern, $data)) {
  629. $roomService = new RoomService($telegram);
  630. $res = $roomService->setMin($data, $chatId, $messageId);
  631. if (isset($res['message_id'])) {
  632. $telegram->editMessageText($res);
  633. } else {
  634. $telegram->sendMessage($res);
  635. }
  636. }
  637. //删除本条数据
  638. if ($data === 'del@@message') {
  639. $telegram->deleteMessage([
  640. 'chat_id' => $chatId,
  641. 'message_id' => $messageId,
  642. ]);
  643. }
  644. //确认创建房间
  645. if ($data === 'room@@done') {
  646. $roomService = new RoomService($telegram);
  647. $res = $roomService->done($chatId, $messageId);
  648. foreach ($res as $r) {
  649. if (isset($r['message_id'])) {
  650. $telegram->editMessageText($r);
  651. } else {
  652. $telegram->sendMessage($r);
  653. }
  654. }
  655. }
  656. //客服帮助
  657. if ($data === "/tutorial") {
  658. $res = (new TutorialService())->index($chatId);
  659. $telegram->sendMessage($res);
  660. }
  661. //点击提现按钮
  662. if ($data === "withdraw@@apply") {
  663. $res = (new WithdrawService())->apply($chatId, $messageId);
  664. $telegram->editMessageText($res);
  665. }
  666. //地址管理
  667. if ($data === 'withdraw@@address') {
  668. $res = WithdrawService::getAddress($chatId, $messageId);
  669. $telegram->editMessageText($res);
  670. }
  671. //点击充值按钮
  672. if ($data === 'topup@@topup') {
  673. $telegram->deleteMessage([
  674. 'chat_id' => $chatId,
  675. 'message_id' => $messageId,
  676. ]);
  677. $topService = new TopUpService();
  678. $res = $topService->scan($chatId, $messageId);
  679. $telegram->sendPhoto($res);
  680. }
  681. //点击充值的账单按钮
  682. if ($data === 'topup@@bill') {
  683. $res = (new TopUpService())->bill($chatId, $firstName, $messageId);
  684. $telegram->editMessageText($res);
  685. // $text = "📅 请输入查询日期\n";
  686. // $date = date('Y-m-d');
  687. // $text .= "例如您要查询的日期 {$date}\n";
  688. // $text .= "那么请发送:【充值账单】{$date}\n";
  689. // $telegram->sendMessage([
  690. // 'chat_id' => $chatId,
  691. // 'text' => $text
  692. // ]);
  693. }
  694. //关闭本条消息
  695. if ($data === 'message@@close') {
  696. $telegram->deleteMessage([
  697. 'chat_id' => $chatId,
  698. 'message_id' => $messageId
  699. ]);
  700. }
  701. if ($data === 'withdrawAddress@@add') {
  702. $res = WithdrawService::addAddress($chatId, $messageId);
  703. $telegram->editMessageText($res);
  704. }
  705. //提现管理
  706. if ($data === "withdraw@@home") {
  707. $res = WithdrawService::index($chatId, $firstName, $messageId);
  708. $telegram->editMessageText($res);
  709. }
  710. //点击提现的账单按钮
  711. if ($data === "withdraw@@bill") {
  712. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId);
  713. $telegram->editMessageText($res);
  714. // $telegram->sendMessage($res);
  715. // $text = "📅 请输入查询日期\n";
  716. // $date = date('Y-m-d');
  717. // $text .= "例如您要查询的日期 {$date}\n";
  718. // $text .= "那么请发送:【提现账单】{$date}\n";
  719. // $telegram->sendMessage([
  720. // 'chat_id' => $chatId,
  721. // 'text' => $text
  722. // ]);
  723. }
  724. //充值首页
  725. if ($data === "topUp@@home" || $data === "topUp@@home1") {
  726. $res = (new TopUpService())->index($chatId, $firstName, $messageId);
  727. if ($data === "topUp@@home1") {
  728. $telegram->deleteMessage([
  729. 'chat_id' => $chatId,
  730. 'message_id' => $messageId
  731. ]);
  732. $telegram->sendMessage($res);
  733. } else {
  734. $telegram->editMessageText($res);
  735. }
  736. }
  737. //点击我已付款按钮
  738. //手动充值(后台审核后到账)
  739. if ($data === 'topUp@@pay2') {
  740. $telegram->deleteMessage([
  741. 'chat_id' => $chatId,
  742. 'message_id' => $messageId
  743. ]);
  744. $res = TopUpService::pay2($chatId);
  745. $telegram->sendMessage($res);
  746. } //
  747. //自动充值
  748. elseif ($data === 'topUp@@pay') {
  749. $telegram->deleteMessage([
  750. 'chat_id' => $chatId,
  751. 'message_id' => $messageId
  752. ]);
  753. $topService = new TopUpService();
  754. $res = $topService->done($chatId);
  755. $telegram->sendMessage($res);
  756. }
  757. //充值账单,下一页
  758. $pattern = "/^topUpBillNextPage@@\d+$/";
  759. if (preg_match($pattern, $data)) {
  760. $page = preg_replace('/^topUpBillNextPage@@/', '', $data);
  761. $page = intval($page);
  762. $res = (new TopUpService())->bill($chatId, $firstName, $messageId, $page);
  763. $telegram->editMessageText($res);
  764. }
  765. //提现账单,下一页
  766. $pattern = "/^withdrawBillNextPage@@\d+$/";
  767. if (preg_match($pattern, $data)) {
  768. $page = preg_replace('/^withdrawBillNextPage@@/', '', $data);
  769. $page = intval($page);
  770. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId, $page);
  771. $telegram->editMessageText($res);
  772. }
  773. //提前开始游戏
  774. $pattern = "/^games@@start\d+$/";
  775. if (preg_match($pattern, $data)) {
  776. $roomId = preg_replace('/^games@@start/', '', $data);
  777. $roomService = new RoomService($telegram);
  778. $res = $roomService->start($chatId, $roomId, $messageId);
  779. foreach ($res as $r) {
  780. if (isset($r['message_id'])) {
  781. $telegram->editMessageText($r);
  782. } else {
  783. $telegram->sendMessage($r);
  784. }
  785. }
  786. }
  787. //解散房间
  788. $pattern = "/^games@@Disband\d+$/";
  789. if (preg_match($pattern, $data)) {
  790. $roomService = new RoomService($telegram);
  791. $roomId = preg_replace('/^games@@Disband/', '', $data);
  792. $res = $roomService->disband($roomId, $chatId, $messageId);
  793. foreach ($res as $r) {
  794. if (isset($r['message_id'])) {
  795. $telegram->editMessageText($r);
  796. } else {
  797. $telegram->sendMessage($r);
  798. }
  799. }
  800. }
  801. //退出房间
  802. $pattern = "/^games@@exit\d+$/";
  803. if (preg_match($pattern, $data)) {
  804. $roomService = new RoomService($telegram);
  805. $res = $roomService->exit($data, $chatId, $messageId);
  806. if (isset($res['message_id'])) $telegram->editMessageText($res);
  807. else $telegram->sendMessage($res);
  808. }
  809. //人员/状态
  810. $pattern = "/^games@@status\d+$/";
  811. if (preg_match($pattern, $data)) {
  812. $roomId = preg_replace('/^games@@status/', '', $data);
  813. $roomService = new RoomService($telegram);
  814. $res = $roomService->userStatus($roomId, $chatId, $messageId);
  815. if (isset($res['message_id'])) $telegram->editMessageText($res);
  816. else $telegram->sendMessage($res);
  817. }
  818. //准备
  819. $pattern = "/^games@@ready\d+$/";
  820. if (preg_match($pattern, $data)) {
  821. $roomId = preg_replace('/^games@@ready/', '', $data);
  822. $res = (new RoomService($telegram))->ready($roomId, $chatId, $messageId);
  823. foreach ($res as $r) {
  824. if (isset($r['message_id'])) {
  825. $telegram->editMessageText($r);
  826. } else {
  827. $telegram->sendMessage($r);
  828. }
  829. }
  830. }
  831. //结算游戏
  832. $pattern = "/^games@@settle\d+$/";
  833. if (preg_match($pattern, $data)) {
  834. $roomId = preg_replace('/^games@@settle/', '', $data);
  835. $res = (new SettlementService())->settle($roomId, $chatId, $messageId);
  836. if (isset($res['message_id'])) $telegram->editMessageText($res);
  837. else $telegram->sendMessage($res);
  838. }
  839. //在线房间,下一页
  840. $pattern = "/^onlineNextPage@@\d+$/";
  841. if (preg_match($pattern, $data)) {
  842. $page = preg_replace('/^onlineNextPage@@/', '', $data);
  843. $page = intval($page);
  844. $res = (new OnLineService())->getList($chatId, $messageId, $page);
  845. $telegram->editMessageText($res);
  846. }
  847. //我的战绩,下一页
  848. $pattern = "/^recordNextPage@@\d+$/";
  849. if (preg_match($pattern, $data)) {
  850. $page = preg_replace('/^recordNextPage@@/', '', $data);
  851. $page = intval($page);
  852. $res = (new RecordService())->getList($chatId, $firstName, $messageId, $page);
  853. $telegram->editMessageText($res);
  854. }
  855. //加入房间
  856. $pattern = "/^join@@\d+$/";
  857. if (preg_match($pattern, $data)) {
  858. $roomId = preg_replace('/^join@@/', '', $data);
  859. $res = (new RoomService($telegram))->join($chatId, $roomId, $messageId);
  860. foreach ($res as $r) {
  861. if (isset($r['message_id'])) {
  862. $telegram->editMessageText($r);
  863. } else {
  864. $telegram->sendMessage($r);
  865. }
  866. }
  867. }
  868. //输入房间号加入房间
  869. if ($data === 'join@@room') {
  870. $res = OnLineService::joinRoom($chatId, $messageId);
  871. $telegram->editMessageText($res);
  872. }
  873. //通过频道加入房间
  874. $pattern = "/^channelJoin@@\d+$/";
  875. if (preg_match($pattern, $data)) {
  876. $roomId = preg_replace('/^channelJoin@@/', '', $data);
  877. $res = (new RoomService($telegram))->join($from->id, $roomId);
  878. foreach ($res as $r) {
  879. if (isset($r['message_id'])) {
  880. $telegram->editMessageText($r);
  881. } else {
  882. $telegram->sendMessage($r);
  883. }
  884. }
  885. }
  886. DB::commit();
  887. } //
  888. catch (MessageException $e) {
  889. DB::rollBack();
  890. $msg = $e->getMessage();
  891. $msg = json_decode($msg, true);
  892. $telegram->sendMessage($msg);
  893. } //
  894. catch (TelegramSDKException $e) {
  895. DB::rollBack();
  896. $m = new Message();
  897. $m->json = $e->getMessage();
  898. $m->save();
  899. $telegram->sendMessage([
  900. 'chat_id' => $chatId,
  901. 'text' => '‼️‼️系统发生了错误,请联系客服'
  902. ]);
  903. }//
  904. catch (\Exception $e) {
  905. DB::rollBack();
  906. $m = new Message();
  907. $m->json = json_encode([
  908. 'line' => $e->getLine(),
  909. 'message' => $e->getMessage()
  910. ]);
  911. $m->save();
  912. $telegram->sendMessage([
  913. 'chat_id' => $chatId,
  914. 'text' => '‼️‼️系统发生了错误,请联系客服'
  915. ]);
  916. }
  917. } //
  918. else {
  919. $update = $request->all();
  920. if (isset($update['message'])) {
  921. $message = $update['message'];
  922. $chatId = $message['chat']['id'];
  923. $messageId = $message['message_id'];
  924. DB::beginTransaction();
  925. try {
  926. $m = new Message();
  927. $m->json = json_encode($update);
  928. $m->save();
  929. $user = User::where('member_id', $chatId)->first();
  930. if (!$user) {
  931. $user = new User();
  932. $user->member_id = $chatId;
  933. }
  934. $user->first_name = $message['chat']['first_name'];
  935. $user->save();
  936. //给每个用户生成一个专属的USDT钱包
  937. WalletService::getUserWallet($chatId);
  938. //用户发送图片,结算截图
  939. if (isset($message['photo'])) {
  940. $stepStatus = Cache::get(get_step_key($chatId), -1);
  941. $stepStatus = intval($stepStatus);
  942. //结算截图
  943. if ($stepStatus === StepStatus::INPUT_IMAGE) {
  944. $photo = $message['photo'][count($message['photo']) - 1];
  945. $res = (new SettlementService())->photo($photo, $chatId);
  946. if ($res) $telegram->sendMessage($res);
  947. }//
  948. //充值截图
  949. else if ($stepStatus === StepStatus::INPUT_TOP_UP_IMAGE) {
  950. $photo = $message['photo'][count($message['photo']) - 1];
  951. $res = TopUpService::photo($chatId, $photo);
  952. if (isset($res['message_id'])) $telegram->editMessageText($res);
  953. else $telegram->sendMessage($res);
  954. }
  955. } //用户发送了消息
  956. else if (isset($message['text'])) {
  957. $text = $message['text'];
  958. if ($message['chat']['type'] === 'private') {
  959. switch ($text) {
  960. //教程帮助
  961. case "/tutorial":
  962. Util::delCache($chatId);
  963. $res = (new TutorialService())->index($chatId);
  964. $telegram->sendMessage($res);
  965. break;
  966. //提现管理
  967. case "/withdraw":
  968. Util::delCache($chatId);
  969. $res = WithdrawService::index($chatId, $message['chat']['first_name']);
  970. $telegram->sendMessage($res);
  971. break;
  972. //我的战绩
  973. case "/record":
  974. Util::delCache($chatId);
  975. $res = (new RecordService())->getList($chatId, $message['chat']['first_name']);
  976. $telegram->sendMessage($res);
  977. break;
  978. //充值管理
  979. case "/topup":
  980. Util::delCache($chatId);
  981. $res = (new TopUpService())->index($chatId, $message['chat']['first_name']);
  982. $telegram->sendMessage($res);
  983. break;
  984. //在线房间
  985. case"/online":
  986. Util::delCache($chatId);
  987. $data = (new OnLineService())->getList($chatId, null, 1);
  988. $telegram->sendMessage($data);
  989. break;
  990. //创建房间
  991. case "/room":
  992. Util::delCache($chatId);
  993. $roomService = new RoomService($telegram);
  994. $res = $roomService->create($chatId);
  995. $telegram->sendMessage($res);
  996. break;
  997. case "/start":
  998. Util::delCache($chatId);
  999. $user = User::where('member_id', $chatId)->first();
  1000. if (!$user) {
  1001. $user = new User();
  1002. $user->member_id = $chatId;
  1003. }
  1004. $user->first_name = $message['chat']['first_name'];
  1005. $user->save();
  1006. //给每个用户生成一个专属的USDT钱包
  1007. WalletService::getUserWallet($chatId);
  1008. $username = config('services.telegram.username');
  1009. $telegram->sendMessage(['chat_id' => $chatId, 'text' => "🎉欢迎使用 @{$username}"]);
  1010. break;
  1011. default:
  1012. $stepStatus = Cache::get(get_step_key($chatId), -1);
  1013. $stepStatus = intval($stepStatus);
  1014. switch ($stepStatus) {
  1015. case StepStatus::INPUT_GAME_INTRODUCTION:
  1016. $res = (new RoomService($telegram))->setIntroduction($chatId, $text, $messageId);
  1017. if (isset($res['message_id'])) $telegram->editMessageText($res);
  1018. else $telegram->sendMessage($res);
  1019. break;
  1020. case StepStatus::INPUT_TOP_UP_MONEY:
  1021. $res = TopUpService::inputAmount($chatId, $text, $messageId);
  1022. if (isset($res['message_id'])) $telegram->editMessageText($res);
  1023. else $telegram->sendMessage($res);
  1024. break;
  1025. case StepStatus::INPUT_JOIN_ROOM_ID:
  1026. $res = OnLineService::join($chatId, $text, $messageId);
  1027. foreach ($res as $r) {
  1028. if (isset($r['message_id'])) $telegram->editMessageText($r);
  1029. else $telegram->sendMessage($r);
  1030. }
  1031. break;
  1032. case StepStatus::INPUT_ADDRESS_ALIAS:
  1033. $res = WithdrawService::inputAlias($chatId, $text, $messageId);
  1034. $telegram->sendMessage($res);
  1035. break;
  1036. case StepStatus::INPUT_ADDRESS_TRC20:
  1037. $res = WithdrawService::inputAddress($chatId, $text, $messageId);
  1038. $telegram->sendMessage($res);
  1039. break;
  1040. case StepStatus::INPUT_WITHDRAW_MONEY:
  1041. $res = (new WithdrawService())->inputAmount($chatId, $text, $messageId);
  1042. foreach ($res as $r) $telegram->sendMessage($r);
  1043. break;
  1044. case StepStatus::INPUT_TOP_UP_IMAGE:
  1045. $telegram->sendMessage([
  1046. 'chat_id' => $chatId,
  1047. 'text' => "输入错误,请上传充值截图!",
  1048. 'reply_to_message_id' => $messageId
  1049. ]);
  1050. break;
  1051. case StepStatus::INPUT_IMAGE:
  1052. $telegram->sendMessage([
  1053. 'chat_id' => $chatId,
  1054. 'text' => "输入错误,请上传战绩截图!",
  1055. 'reply_to_message_id' => $messageId
  1056. ]);
  1057. break;
  1058. //输入结算分数
  1059. case StepStatus::INPUT_SCORE:
  1060. $res = (new SettlementService())->submitSettle($chatId, $text, $messageId);
  1061. foreach ($res['data'] as $r) $telegram->sendMessage($r);
  1062. break;
  1063. //输入游戏名称
  1064. case StepStatus::INPUT_GAME_NAME:
  1065. $gameName = $text;
  1066. $roomService = new RoomService($telegram);
  1067. $res = $roomService->setGameName($chatId, $gameName, $messageId);
  1068. if (isset($res['message_id'])) $telegram->editMessageText($res);
  1069. else $telegram->sendMessage($res);
  1070. break;
  1071. //输入房间号
  1072. case StepStatus::INPUT_ROOM_ID:
  1073. $roomId = $text;
  1074. $roomService = new RoomService($telegram);
  1075. $res = $roomService->setNum($chatId, $roomId, $messageId);
  1076. if (isset($res['message_id'])) $telegram->editMessageText($res);
  1077. else $telegram->sendMessage($res);
  1078. break;
  1079. //输入是否允许中途加入
  1080. case StepStatus::INPUT_MIDWAY:
  1081. $midway = $text;
  1082. $roomService = new RoomService($telegram);
  1083. $res = $roomService->setGameMidway($chatId, $midway, $messageId);
  1084. if (isset($res['message_id'])) $telegram->editMessageText($res);
  1085. else $telegram->sendMessage($res);
  1086. break;
  1087. //输入 人数/局数
  1088. case StepStatus::INPUT_ROOM_NUM:
  1089. $array = explode('/', $text);
  1090. $roomService = new RoomService($telegram);
  1091. $res = $roomService->setNumberOfGames($chatId, $array, $messageId);
  1092. if (isset($res['message_id'])) $telegram->editMessageText($res);
  1093. else $telegram->sendMessage($res);
  1094. break;
  1095. //输入 游戏ID
  1096. case StepStatus::INPUT_GAME_ID:
  1097. $gameId = $text;
  1098. $rs = new RoomService($telegram);
  1099. $res = $rs->setGameID($chatId, $gameId, $messageId);
  1100. foreach ($res as $r) {
  1101. if (isset($r['message_id'])) $telegram->editMessageText($r);
  1102. else $telegram->sendMessage($r);
  1103. }
  1104. break;
  1105. break;
  1106. default:
  1107. Util::delCache($chatId);
  1108. $res = (new TutorialService())->index($chatId);
  1109. $telegram->sendMessage($res);
  1110. break;
  1111. }
  1112. break;
  1113. }
  1114. }
  1115. }
  1116. DB::commit();
  1117. } //
  1118. catch (MessageException $e) {
  1119. DB::rollBack();
  1120. $m = new Message();
  1121. $m->json = $e->getMessage();
  1122. $m->save();
  1123. try {
  1124. $msg = $e->getMessage();
  1125. $msg = json_decode($msg, true);
  1126. $telegram->sendMessage($msg);
  1127. } catch (TelegramSDKException $e) {
  1128. }
  1129. } //
  1130. catch (TelegramSDKException $e) {
  1131. DB::rollBack();
  1132. $m = new Message();
  1133. $m->json = $e->getMessage();
  1134. $m->save();
  1135. $telegram->sendMessage([
  1136. 'chat_id' => $chatId,
  1137. 'text' => '‼️‼️系统发生了错误,请联系客服'
  1138. ]);
  1139. }//
  1140. catch (\Exception $e) {
  1141. DB::rollBack();
  1142. $m = new Message();
  1143. $m->json = $e->getMessage();
  1144. $m->save();
  1145. $telegram->sendMessage([
  1146. 'chat_id' => $chatId,
  1147. 'text' => '‼️‼️系统发生了错误,请联系客服'
  1148. ]);
  1149. }
  1150. }
  1151. }
  1152. return response()->json(['status' => 'ok']);
  1153. }
  1154. }