TelegramWebHook.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721
  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@@qb_apply") {
  181. $res =WithdrawService::qbApply($chatId, $messageId);
  182. $telegram->editMessageText($res);
  183. }
  184. //地址管理
  185. if ($data === 'withdraw@@address') {
  186. $res = WithdrawService::getAddress($chatId, $messageId);
  187. $telegram->editMessageText($res);
  188. }
  189. //关闭本条消息
  190. if ($data === 'message@@close') {
  191. $telegram->deleteMessage([
  192. 'chat_id' => $chatId,
  193. 'message_id' => $messageId
  194. ]);
  195. }
  196. if ($data === 'withdrawAddress@@add') {
  197. $res = WithdrawService::addAddress($chatId, $messageId);
  198. $telegram->editMessageText($res);
  199. }
  200. //提现管理
  201. if ($data === "withdraw@@home") {
  202. // $res = WithdrawService::index($chatId, $firstName, $messageId);
  203. // $telegram->editMessageText($res);
  204. $telegram->deleteMessage([
  205. 'chat_id' => $chatId,
  206. 'message_id' => $messageId
  207. ]);
  208. $returnMsg = WalletService::getBalance($chatId);
  209. if ($returnMsg) {
  210. $this->telegram->sendMessage($returnMsg);
  211. }
  212. }
  213. //点击提现的账单按钮
  214. if ($data === "withdraw@@bill") {
  215. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId);
  216. $telegram->editMessageText($res);
  217. // $telegram->sendMessage($res);
  218. // $text = "📅 请输入查询日期\n";
  219. // $date = date('Y-m-d');
  220. // $text .= "例如您要查询的日期 {$date}\n";
  221. // $text .= "那么请发送:【提现账单】{$date}\n";
  222. // $telegram->sendMessage([
  223. // 'chat_id' => $chatId,
  224. // 'text' => $text
  225. // ]);
  226. }
  227. if ($data === 'withdrawAddress@@done') {
  228. $res = WithdrawService::done($chatId, $messageId, $firstName);
  229. $telegram->editMessageText($res);
  230. }
  231. // 今日汇率
  232. if ($data === 'todayExchangeRate@@rate') {
  233. $res = BetService::todayExchangeRate($chatId);
  234. // $telegram->sendMessage($res);
  235. }
  236. //查看开奖历史图片
  237. $pattern = "/^showLotteryHistory@@\d+$/";
  238. if (preg_match($pattern, $data)) {
  239. $id = preg_replace('/^showLotteryHistory@@/', '', $data);
  240. $res = IssueService::sendLotteryImage($chatId, $id);
  241. }
  242. //选择投注记录
  243. $pattern = "/^betRecordType@@\d+$/";
  244. if (preg_match($pattern, $data)) {
  245. $type = preg_replace('/^betRecordType@@/', '', $data);
  246. Cache::put('message_id_bet_record_' . $chatId, intval($type), 600);
  247. $telegram->deleteMessage([
  248. 'chat_id' => $chatId,
  249. 'message_id' => $messageId,
  250. ]);
  251. $returnMsg = BetService::record($chatId);
  252. $telegram->sendMessage($returnMsg);
  253. }
  254. //选择提现地址
  255. $pattern = "/^withdrawAddress@@choose\d+$/";
  256. if (preg_match($pattern, $data)) {
  257. $id = preg_replace('/^withdrawAddress@@choose/', '', $data);
  258. $res = WithdrawService::chooseAddress($chatId, $firstName, $messageId, $id);
  259. $telegram->editMessageText($res);
  260. }
  261. //删除地址
  262. $pattern = "/^withdrawAddress@@del\d+$/";
  263. if (preg_match($pattern, $data)) {
  264. $id = preg_replace('/^withdrawAddress@@del/', '', $data);
  265. $res = WithdrawService::delAddress($chatId, $id, $messageId);
  266. $telegram->editMessageText($res);
  267. }
  268. //地址详情
  269. $pattern = "/^withdrawAddress@@detail\d+$/";
  270. if (preg_match($pattern, $data)) {
  271. $id = preg_replace('/^withdrawAddress@@detail/', '', $data);
  272. $res = WithdrawService::addressDetails($chatId, $messageId, $id);
  273. $telegram->editMessageText($res);
  274. }
  275. //充值账单,下一页
  276. $pattern = "/^topUpBillNextPage@@\d+$/";
  277. if (preg_match($pattern, $data)) {
  278. $page = preg_replace('/^topUpBillNextPage@@/', '', $data);
  279. $page = intval($page);
  280. $res = (new TopUpService())->bill($chatId, $firstName, $messageId, $page);
  281. $telegram->editMessageText($res);
  282. }
  283. //流水列表,下一页
  284. $pattern = "/^FlowingHistoryPage@@\d+$/";
  285. if (preg_match($pattern, $data)) {
  286. $page = preg_replace('/^FlowingHistoryPage@@/', '', $data);
  287. $page = intval($page);
  288. $returnMsg = BalanceLogService::getFlowingHistory($chatId, $messageId, $page);
  289. $telegram->editMessageText($returnMsg);
  290. }
  291. //提现账单,下一页
  292. $pattern = "/^withdrawBillNextPage@@\d+$/";
  293. if (preg_match($pattern, $data)) {
  294. $page = preg_replace('/^withdrawBillNextPage@@/', '', $data);
  295. $page = intval($page);
  296. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId, $page);
  297. $telegram->editMessageText($res);
  298. }
  299. //近期注单,下一页
  300. $pattern = "/^betRecordNextPage@@\d+$/";
  301. if (preg_match($pattern, $data)) {
  302. $page = preg_replace('/^betRecordNextPage@@/', '', $data);
  303. $page = intval($page);
  304. $res = BetService::record($chatId, $messageId, $page);
  305. $telegram->editMessageText($res);
  306. }
  307. DB::commit();
  308. } //
  309. catch (MessageException $e) {
  310. DB::rollBack();
  311. $msg = $e->getMessage();
  312. $msg = json_decode($msg, true);
  313. $telegram->sendMessage($msg);
  314. } //
  315. catch (TelegramSDKException $e) {
  316. DB::rollBack();
  317. $m = new Message();
  318. $m->json = $e->getMessage();
  319. $m->save();
  320. $telegram->sendMessage([
  321. 'chat_id' => $chatId,
  322. 'text' => '‼️‼️系统发生了错误,请联系客服'
  323. ]);
  324. }//
  325. catch (\Exception $e) {
  326. DB::rollBack();
  327. $m = new Message();
  328. $m->json = json_encode([
  329. 'line' => $e->getLine(),
  330. 'message' => $e->getMessage()
  331. ]);
  332. $m->save();
  333. $telegram->sendMessage([
  334. 'chat_id' => $chatId,
  335. 'text' => '‼️‼️系统发生了错误,请联系客服'
  336. ]);
  337. }
  338. } else {
  339. $update = $request->all();
  340. Log::error('Telegram 文字消息回复: ' . json_encode($update, JSON_UNESCAPED_UNICODE));
  341. if (isset($update['message'])) {
  342. $message = $update['message'];
  343. $chatId = $message['chat']['id'];
  344. $messageId = $message['message_id'];
  345. DB::beginTransaction();
  346. try {
  347. $m = new Message();
  348. $m->json = json_encode($update);
  349. $m->save();
  350. $returnMsg = $this->processChatMessage($chatId, $messageId, $message, $message['from']);
  351. if ($returnMsg) {
  352. if (isset($returnMsg['photo']) && $returnMsg['photo'] != '') {
  353. $this->telegram->sendPhoto($returnMsg);
  354. } else {
  355. $this->telegram->sendMessage($returnMsg);
  356. }
  357. }
  358. DB::commit();
  359. } catch (MessageException $e) {
  360. DB::rollBack();
  361. $msg = $e->getMessage();
  362. $msg = json_decode($msg, true);
  363. $telegram->sendMessage($msg);
  364. } //
  365. catch (TelegramSDKException $e) {
  366. DB::rollBack();
  367. $m = new Message();
  368. $m->json = $e->getMessage();
  369. $m->save();
  370. $telegram->sendMessage([
  371. 'chat_id' => $chatId,
  372. 'text' => '‼️‼️系统发生了错误,请联系客服'
  373. ]);
  374. }//
  375. catch (\Exception $e) {
  376. DB::rollBack();
  377. $m = new Message();
  378. $m->json = json_encode([
  379. 'line' => $e->getLine(),
  380. 'message' => $e->getMessage()
  381. ]);
  382. $m->save();
  383. Log::error('Telegram 处理消息异常: ' . $e->getMessage());
  384. $telegram->sendMessage([
  385. 'chat_id' => $chatId,
  386. 'text' => '‼️‼️系统发生了错误,请联系客服'
  387. ]);
  388. }
  389. }
  390. }
  391. return response()->json(['status' => 'ok']);
  392. }
  393. /**
  394. * @description: 处理聊天消息
  395. * @param {*} $chatId
  396. * @param {*} $messageId
  397. * @param {*} $message
  398. * @param {*} $from
  399. * @return {*}
  400. */
  401. public function processChatMessage($chatId, $messageId, $message, $from)
  402. {
  403. $returnMsg = [];
  404. //用户发送图片,结算截图
  405. if (isset($message['photo'])) {
  406. $stepStatus = Cache::get(get_step_key($chatId), -1);
  407. $stepStatus = intval($stepStatus);
  408. // //结算截图
  409. // if ($stepStatus === StepStatus::INPUT_IMAGE) {
  410. // $photo = $message['photo'][count($message['photo']) - 1];
  411. // $res = (new SettlementService())->photo($photo, $chatId);
  412. // if ($res) $telegram->sendMessage($res);
  413. // }//
  414. // //充值截图
  415. // else
  416. if ($stepStatus === StepStatus::INPUT_TOP_UP_IMAGE) {
  417. $photo = $message['photo'][count($message['photo']) - 1];
  418. $res = TopUpService::photo($chatId, $photo);
  419. return $res;
  420. // if (isset($res['message_id'])) $telegram->editMessageText($res);
  421. // else $telegram->sendMessage($res);
  422. }
  423. } //用户发送了消息
  424. else if (isset($message['text'])) {
  425. $text = $message['text'];
  426. if ($message['chat']['type'] === 'private') {
  427. switch ($text) {
  428. case "/start":
  429. Util::delCache($chatId);
  430. $user = User::where('member_id', $chatId)->first();
  431. if (!$user) {
  432. $user = new User();
  433. $user->member_id = $chatId;
  434. }
  435. $user->first_name = $message['chat']['first_name'];
  436. if (isset($message['chat']['username'])) {
  437. $user->username = $message['chat']['username'];
  438. }
  439. $user->save();
  440. //给每个用户生成一个专属的USDT钱包
  441. WalletService::getUserWallet($chatId);
  442. $this->setReplyKeyboard($chatId);
  443. break;
  444. case "近期注单":
  445. Util::delCache($chatId);
  446. $returnMsg = BetService::record($chatId);
  447. // $this->telegram->sendMessage([
  448. // 'chat_id' => $chatId,
  449. // 'text' => $text
  450. // ]);
  451. break;
  452. case "✅近期注单":
  453. Util::delCache($chatId);
  454. $returnMsg = BetService::record($chatId);
  455. // $this->telegram->sendMessage([
  456. // 'chat_id' => $chatId,
  457. // 'text' => $text
  458. // ]);
  459. break;
  460. case "今日流水":
  461. Util::delCache($chatId);
  462. $returnMsg = BalanceLogService::getTodayFlowing($chatId);
  463. // $this->telegram->sendMessage($result);
  464. break;
  465. case "🔍今日流水":
  466. Util::delCache($chatId);
  467. $returnMsg = BalanceLogService::getTodayFlowing($chatId);
  468. // $this->telegram->sendMessage($result);
  469. break;
  470. case "流失列表":
  471. case "🔍流水列表":
  472. Util::delCache($chatId);
  473. $returnMsg = BalanceLogService::getFlowingHistory($chatId);
  474. // $this->telegram->sendMessage($result);
  475. break;
  476. case "联系客服":
  477. Util::delCache($chatId);
  478. $receivingAddress = Config::where('field', 'receiving_address')->first()->val;
  479. $serviceCustomer = Config::where('field', 'service_customer')->first()->val;
  480. $text = "官方唯一上分地址:\n";
  481. $text .= "USDT: \n";
  482. $text .= "{$receivingAddress}\n\n\n";
  483. $text .= "‼️特别注意‼️特别注意‼️\n";
  484. $text .= "‼️近期骗子肆意妄为,猖狂狡诈。经常冒充我方财务,管理人员以各种手段行使诈骗之术。多数为要求转账/提供验证码等。任何主动私聊您的都是非奸即盗。望各位老板谨记,预防受骗!\n";
  485. $text .= "‼️本群管理以及财务绝不会主动私聊客户。请各位老板务必认准群内带标识管理账号,转账前务必核对是否官方账号以及地址。任何一切不是官方行为的受骗上当,本群概不负责,谢谢!\n";
  486. $text .= "‼️为了您的资金安全,下分更换地址请提前告知财务,并使用原地址进行转账或录屏进行身份核实,核实为本人操作后才可进行更换地址下分\n";
  487. $text .= "‼️如查分金额与实际转账金额不同,请重新喊查。玩家重复查3次以上错误金额则视为恶意捣乱,将不退还转账金额!\n";
  488. $text .= "‼️如因为人为失误问题,到账金额与玩家实际转账金额不符,到账后的一切下注视为无效。\n";
  489. $text .= "‼️本群不接待以任何形式刷水的水军,一经发现玩家存在刷水行为将扣除历史所有返水、彩金。并冻结分数一个月,每天仅可下分账户余额10%。不纠结,不解释,请各大水军自行绕道。\n";
  490. $keyboard = [];
  491. $keyboard[] = [['text' => '✅ 唯一客服', 'callback_data' => "", 'url' => "https://t.me/{$serviceCustomer}"]];
  492. $returnMsg = [
  493. 'chat_id' => $chatId,
  494. 'text' => $text,
  495. 'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
  496. ];
  497. break;
  498. case "开奖历史":
  499. Util::delCache($chatId);
  500. IssueService::currentLotteryResults($chatId);
  501. break;
  502. case "📝开奖历史":
  503. Util::delCache($chatId);
  504. IssueService::currentLotteryResults($chatId);
  505. break;
  506. case "当期下注":
  507. Util::delCache($chatId);
  508. $returnMsg = BetService::currentBet($chatId);
  509. break;
  510. case "🔥当期下注":
  511. Util::delCache($chatId);
  512. $returnMsg = BetService::currentBet($chatId);
  513. break;
  514. case "🔥本期下注":
  515. Util::delCache($chatId);
  516. $returnMsg = BetService::currentBet($chatId);
  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. $returnMsg = WalletService::getBalance($chatId);
  526. // $this->telegram->sendMessage($result);
  527. break;
  528. case "投注大群":
  529. Util::delCache($chatId);
  530. $bettingGroup = Config::where('field', 'betting_group')->first()->val;
  531. $text = "👇👇👇点击下方按钮进群投注👇👇👇\n";
  532. $keyboard = [];
  533. $keyboard[] = [['text' => '✅ 投注群', 'callback_data' => "", 'url' => "https://t.me/{$bettingGroup}"]];
  534. $returnMsg = [
  535. 'chat_id' => $chatId,
  536. 'text' => $text,
  537. 'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
  538. ];
  539. break;
  540. default:
  541. // 关键字回复
  542. $keyboardText = KeyboardService::findOne(['button' => $text]);
  543. if ($keyboardText) {
  544. $keyboard = [];
  545. if ($keyboardText['buttons']) {
  546. $keyboard = json_decode($keyboardText['buttons'], true);
  547. }
  548. Util::delCache($chatId);
  549. $res = [
  550. 'chat_id' => $chatId,
  551. 'text' => $keyboardText['reply'],
  552. // 'reply_to_message_id' => $messageId
  553. ];
  554. if ($keyboard) {
  555. $res['reply_markup'] = json_encode(['inline_keyboard' => $keyboard]);
  556. }
  557. if ($keyboardText['image']) {
  558. $res['photo'] = InputFile::create(url($keyboardText['image']));
  559. unset($res['text']);
  560. $res['caption'] = $text;
  561. $res['protect_content'] = true; // 防止转发
  562. }
  563. return $res;
  564. break;
  565. }
  566. $stepStatus = Cache::get(get_step_key($chatId), -1);
  567. $stepStatus = intval($stepStatus);
  568. switch ($stepStatus) {
  569. case StepStatus::INPUT_TOP_UP_MONEY:
  570. $res = TopUpService::inputAmount($chatId, $text, $messageId);
  571. return $res;
  572. break;
  573. case StepStatus::INPUT_WITHDRAW_MONEY:
  574. $res = (new WithdrawService())->inputAmount($chatId, $text, $messageId);
  575. return $res[0];
  576. break;
  577. case StepStatus::INPUT_WITHDRAW_QB_MONEY:
  578. $res = WithdrawService::inputQbAmount($chatId, $text, $messageId);
  579. return $res;
  580. break;
  581. case StepStatus::INPUT_ADDRESS_TRC20:
  582. $res = WithdrawService::inputAddress($chatId, $text, $messageId);
  583. return $res;
  584. break;
  585. case StepStatus::INPUT_ADDRESS_ALIAS:
  586. $res = WithdrawService::inputAlias($chatId, $text, $messageId);
  587. return $res;
  588. break;
  589. }
  590. $returnMsg = BetService::bet($chatId, $text, $messageId);
  591. // $this->telegram->sendMessage($returnMsg);
  592. }
  593. return $returnMsg;
  594. }
  595. }
  596. }
  597. /**
  598. * @description: 设置 start 回复菜单
  599. * @param {*} $chatId
  600. * @return {*}
  601. */
  602. public function setReplyKeyboard($chatId)
  603. {
  604. $replyInfo = KeyboardService::findOne(['button' => '开始使用']);
  605. $telegram = new Api(config('services.telegram.token'));
  606. $keyboard = [
  607. ['近期注单', '今日流水', '联系客服'], // 第一排按钮
  608. ['开奖历史', '当期下注', '查看余额'], // 第二排按钮
  609. ['投注大群']
  610. ];
  611. if ($replyInfo && $replyInfo->buttons) {
  612. $keyboard = [];
  613. $buttons = json_decode($replyInfo->buttons, true);
  614. foreach ($buttons as $rowIndex => $row) {
  615. if (!empty($row)) {
  616. foreach ($row as $buttonIndex => $button) {
  617. $keyboard[$rowIndex][$buttonIndex] = $button['text'];
  618. }
  619. }
  620. }
  621. $keyboard = array_values($keyboard); // 重新索引数组
  622. Log::error('自定义开始使用按钮: ' . json_encode($keyboard));
  623. }
  624. $botMsg = [];
  625. $botMsg['chat_id'] = $chatId;
  626. $replyMarkup = [
  627. 'keyboard' => $keyboard,
  628. 'resize_keyboard' => true, // 自适应大小
  629. 'one_time_keyboard' => false, // 保持显示,不会点击后收起
  630. ];
  631. $botMsg['reply_markup'] = json_encode($replyMarkup);
  632. if ($replyInfo) {
  633. $image = '';
  634. if ($replyInfo->image) {
  635. $image = url($replyInfo->image);
  636. }
  637. if ($image != '') {
  638. $botMsg['photo'] = InputFile::create($image);
  639. $botMsg['caption'] = $replyInfo->reply;
  640. $botMsg['protect_content'] = true; // 防止转发
  641. KeyboardService::telegram()->sendPhoto($botMsg);
  642. } else {
  643. $botMsg['text'] = $replyInfo->reply;
  644. KeyboardService::telegram()->sendMessage($botMsg);
  645. }
  646. } else {
  647. $telegram->sendMessage([
  648. 'chat_id' => $chatId,
  649. 'text' => '你好,请选择功能菜单',
  650. 'reply_markup' => json_encode($replyMarkup),
  651. ]);
  652. }
  653. }
  654. }