TelegramWebHook.php 65 KB

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