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\QianBaoWithdrawService;
  11. use App\Services\RecordService;
  12. use App\Services\RoomService;
  13. use App\Services\SettlementService;
  14. use App\Services\TopUpService;
  15. use App\Services\TutorialService;
  16. use App\Services\UserService;
  17. use App\Services\WalletService;
  18. use App\Services\WithdrawService;
  19. use App\Services\BalanceLogService;
  20. use Carbon\Carbon;
  21. use Illuminate\Http\Request;
  22. use Illuminate\Support\Facades\Cache;
  23. use Illuminate\Support\Facades\DB;
  24. use Telegram\Bot\Api;
  25. use Telegram\Bot\Exceptions\TelegramSDKException;
  26. use Illuminate\Support\Facades\Log;
  27. use App\Models\Config;
  28. use App\Services\GameplayRuleService;
  29. use App\Services\BetService;
  30. use App\Services\IssueService;
  31. use App\Services\KeyboardService;
  32. use Telegram\Bot\FileUpload\InputFile;
  33. class TelegramWebHook extends Controller
  34. {
  35. protected $telegram;
  36. public function __construct(Api $telegram)
  37. {
  38. $this->telegram = $telegram;
  39. }
  40. public function handle(Request $request)
  41. {
  42. Log::error('Telegram 日志写入测试: ' . json_encode([$request->ip()], JSON_UNESCAPED_UNICODE));
  43. // try {
  44. $m = new Message();
  45. $m->json = $request->ip();
  46. $m->save();
  47. $telegram = new Api(config('services.telegram.token'));
  48. // } catch (TelegramSDKException $e) {
  49. // return response()->json(['status' => 'ok']);
  50. // }
  51. $update = $telegram->getWebhookUpdate(); // 获取更新数据
  52. $update->callbackQuery;
  53. if ($update->has('callback_query')) {
  54. $json['type'] = 'callback_query';
  55. $callbackQuery = $update->callbackQuery;
  56. $json['update'] = $callbackQuery;
  57. $message = $callbackQuery->message;
  58. $from = $callbackQuery->from;
  59. $data = $callbackQuery->data; // 获取 callback_data
  60. $callbackId = $callbackQuery->id; // 获取 callback_query 的 ID
  61. $m = new Message();
  62. $m->json = $data;
  63. $m->save();
  64. Util::delCache($message->chat->id);
  65. Log::error('Telegram 回调数据(JSON): ' . json_encode($update, JSON_UNESCAPED_UNICODE));
  66. DB::beginTransaction();
  67. try {
  68. $chatId = $message->chat->id;
  69. $firstName = $message->chat->firstName;
  70. $messageId = $message->messageId;
  71. if (!$from->isBot) {
  72. $chatId = $from->id;
  73. $firstName = $from->firstName;
  74. }
  75. $user = User::where('member_id', $chatId)->first();
  76. if (!$user) {
  77. $user = new User();
  78. $user->member_id = $chatId;
  79. }
  80. $user->first_name = $firstName;
  81. $user->save();
  82. //给每个用户生成一个专属的USDT钱包
  83. WalletService::getUserWallet($chatId);
  84. QianBaoWithdrawService::init($telegram, $data, $chatId, $firstName, $messageId);
  85. // 查看余额弹窗
  86. if ($data === 'balanceAlert') {
  87. $alertText = WalletService::getBalance($chatId)['text'];
  88. WalletService::alertNotice($callbackId, $alertText);
  89. }
  90. // 今日流水弹窗
  91. if ($data === 'todayFlowAlert') {
  92. $alertText = BalanceLogService::getTodayFlowing($chatId)['text'];
  93. BalanceLogService::alertNotice($callbackId, $alertText);
  94. }
  95. // 近期注单弹窗
  96. if ($data === 'betsAlert') {
  97. Cache::put('message_id_bet_record_' . $chatId, 0, 600);
  98. $alertText = BetService::recentlyRecord($chatId);
  99. BetService::alertNotice($callbackId, $alertText);
  100. }
  101. //选择充值地址
  102. if ($data === "topUp@@TRC20" || $data === "topUp@@ERC20") {
  103. $type = preg_replace('/^topUp@@/', '', $data);
  104. $topService = new TopUpService();
  105. $res = $topService->scan($chatId, $messageId, $type);
  106. $telegram->deleteMessage([
  107. 'chat_id' => $chatId,
  108. 'message_id' => $messageId,
  109. ]);
  110. $telegram->sendPhoto($res);
  111. }
  112. //点击充值按钮
  113. if ($data === 'topup@@topup') {
  114. $res = TopUpService::chooseAddress($chatId, $messageId);
  115. $telegram->editMessageText($res);
  116. }
  117. //点击充值的账单按钮
  118. if ($data === 'topup@@bill') {
  119. $res = (new TopUpService())->bill($chatId, $firstName, $messageId);
  120. $telegram->editMessageText($res);
  121. // $text = "📅 请输入查询日期\n";
  122. // $date = date('Y-m-d');
  123. // $text .= "例如您要查询的日期 {$date}\n";
  124. // $text .= "那么请发送:【充值账单】{$date}\n";
  125. // $telegram->sendMessage([
  126. // 'chat_id' => $chatId,
  127. // 'text' => $text
  128. // ]);
  129. }
  130. //点击我已付款按钮
  131. //手动充值(后台审核后到账)
  132. if ($data === 'topUp@@pay2') {
  133. $telegram->deleteMessage([
  134. 'chat_id' => $chatId,
  135. 'message_id' => $messageId
  136. ]);
  137. $res = TopUpService::pay2($chatId);
  138. $telegram->sendMessage($res);
  139. } //
  140. //自动充值
  141. elseif ($data === 'topUp@@pay') {
  142. $telegram->deleteMessage([
  143. 'chat_id' => $chatId,
  144. 'message_id' => $messageId
  145. ]);
  146. $topService = new TopUpService();
  147. $res = $topService->done($chatId);
  148. $telegram->sendMessage($res);
  149. }
  150. //充值首页
  151. if ($data === "topUp@@home" || $data === "topUp@@home1") {
  152. $returnMsg = WalletService::getBalance($chatId);
  153. if ($returnMsg) {
  154. if ($data === "topUp@@home1") {
  155. $telegram->deleteMessage([
  156. 'chat_id' => $chatId,
  157. 'message_id' => $messageId
  158. ]);
  159. $this->telegram->sendMessage($returnMsg);
  160. } else {
  161. $returnMsg['message_id'] = $messageId;
  162. $telegram->editMessageText($returnMsg);
  163. }
  164. }
  165. // $res = (new TopUpService())->index($chatId, $firstName, $messageId);
  166. // if ($data === "topUp@@home1") {
  167. // $telegram->deleteMessage([
  168. // 'chat_id' => $chatId,
  169. // 'message_id' => $messageId
  170. // ]);
  171. // $telegram->sendMessage($res);
  172. // } else {
  173. // $telegram->editMessageText($res);
  174. // }
  175. }
  176. //点击提现按钮
  177. if ($data === "withdraw@@apply") {
  178. $res = (new WithdrawService())->apply($chatId, $messageId);
  179. $telegram->editMessageText($res);
  180. }
  181. //地址管理
  182. if ($data === 'withdraw@@address') {
  183. $res = WithdrawService::getAddress($chatId, $messageId);
  184. $telegram->editMessageText($res);
  185. }
  186. //关闭本条消息
  187. if ($data === 'message@@close') {
  188. $telegram->deleteMessage([
  189. 'chat_id' => $chatId,
  190. 'message_id' => $messageId
  191. ]);
  192. }
  193. if ($data === 'withdrawAddress@@add') {
  194. $res = WithdrawService::addAddress($chatId, $messageId);
  195. $telegram->editMessageText($res);
  196. }
  197. //提现管理
  198. if ($data === "withdraw@@home") {
  199. // $res = WithdrawService::index($chatId, $firstName, $messageId);
  200. // $telegram->editMessageText($res);
  201. $telegram->deleteMessage([
  202. 'chat_id' => $chatId,
  203. 'message_id' => $messageId
  204. ]);
  205. $returnMsg = WalletService::getBalance($chatId);
  206. if ($returnMsg) {
  207. $this->telegram->sendMessage($returnMsg);
  208. }
  209. }
  210. //点击提现的账单按钮
  211. if ($data === "withdraw@@bill") {
  212. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId);
  213. $telegram->editMessageText($res);
  214. // $telegram->sendMessage($res);
  215. // $text = "📅 请输入查询日期\n";
  216. // $date = date('Y-m-d');
  217. // $text .= "例如您要查询的日期 {$date}\n";
  218. // $text .= "那么请发送:【提现账单】{$date}\n";
  219. // $telegram->sendMessage([
  220. // 'chat_id' => $chatId,
  221. // 'text' => $text
  222. // ]);
  223. }
  224. if ($data === 'withdrawAddress@@done') {
  225. $res = WithdrawService::done($chatId, $messageId, $firstName);
  226. $telegram->editMessageText($res);
  227. }
  228. // 今日汇率
  229. if ($data === 'todayExchangeRate@@rate') {
  230. $res = BetService::todayExchangeRate($chatId);
  231. // $telegram->sendMessage($res);
  232. }
  233. //查看开奖历史图片
  234. $pattern = "/^showLotteryHistory@@\d+$/";
  235. if (preg_match($pattern, $data)) {
  236. $id = preg_replace('/^showLotteryHistory@@/', '', $data);
  237. $res = IssueService::sendLotteryImage($chatId, $id);
  238. }
  239. //选择投注记录
  240. $pattern = "/^betRecordType@@\d+$/";
  241. if (preg_match($pattern, $data)) {
  242. $type = preg_replace('/^betRecordType@@/', '', $data);
  243. Cache::put('message_id_bet_record_' . $chatId, intval($type), 600);
  244. $telegram->deleteMessage([
  245. 'chat_id' => $chatId,
  246. 'message_id' => $messageId,
  247. ]);
  248. $returnMsg = BetService::record($chatId);
  249. $telegram->sendMessage($returnMsg);
  250. }
  251. //选择提现地址
  252. $pattern = "/^withdrawAddress@@choose\d+$/";
  253. if (preg_match($pattern, $data)) {
  254. $id = preg_replace('/^withdrawAddress@@choose/', '', $data);
  255. $res = WithdrawService::chooseAddress($chatId, $firstName, $messageId, $id);
  256. $telegram->editMessageText($res);
  257. }
  258. //删除地址
  259. $pattern = "/^withdrawAddress@@del\d+$/";
  260. if (preg_match($pattern, $data)) {
  261. $id = preg_replace('/^withdrawAddress@@del/', '', $data);
  262. $res = WithdrawService::delAddress($chatId, $id, $messageId);
  263. $telegram->editMessageText($res);
  264. }
  265. //地址详情
  266. $pattern = "/^withdrawAddress@@detail\d+$/";
  267. if (preg_match($pattern, $data)) {
  268. $id = preg_replace('/^withdrawAddress@@detail/', '', $data);
  269. $res = WithdrawService::addressDetails($chatId, $messageId, $id);
  270. $telegram->editMessageText($res);
  271. }
  272. //充值账单,下一页
  273. $pattern = "/^topUpBillNextPage@@\d+$/";
  274. if (preg_match($pattern, $data)) {
  275. $page = preg_replace('/^topUpBillNextPage@@/', '', $data);
  276. $page = intval($page);
  277. $res = (new TopUpService())->bill($chatId, $firstName, $messageId, $page);
  278. $telegram->editMessageText($res);
  279. }
  280. //流水列表,下一页
  281. $pattern = "/^FlowingHistoryPage@@\d+$/";
  282. if (preg_match($pattern, $data)) {
  283. $page = preg_replace('/^FlowingHistoryPage@@/', '', $data);
  284. $page = intval($page);
  285. $returnMsg = BalanceLogService::getFlowingHistory($chatId, $messageId, $page);
  286. $telegram->editMessageText($returnMsg);
  287. }
  288. //提现账单,下一页
  289. $pattern = "/^withdrawBillNextPage@@\d+$/";
  290. if (preg_match($pattern, $data)) {
  291. $page = preg_replace('/^withdrawBillNextPage@@/', '', $data);
  292. $page = intval($page);
  293. $res = (new WithdrawService())->bill($chatId, $firstName, $messageId, $page);
  294. $telegram->editMessageText($res);
  295. }
  296. //近期注单,下一页
  297. $pattern = "/^betRecordNextPage@@\d+$/";
  298. if (preg_match($pattern, $data)) {
  299. $page = preg_replace('/^betRecordNextPage@@/', '', $data);
  300. $page = intval($page);
  301. $res = BetService::record($chatId, $messageId, $page);
  302. $telegram->editMessageText($res);
  303. }
  304. DB::commit();
  305. } //
  306. catch (MessageException $e) {
  307. DB::rollBack();
  308. $msg = $e->getMessage();
  309. $msg = json_decode($msg, true);
  310. $telegram->sendMessage($msg);
  311. } //
  312. catch (TelegramSDKException $e) {
  313. DB::rollBack();
  314. $m = new Message();
  315. $m->json = $e->getMessage();
  316. $m->save();
  317. $telegram->sendMessage([
  318. 'chat_id' => $chatId,
  319. 'text' => '‼️‼️系统发生了错误,请联系客服'
  320. ]);
  321. }//
  322. catch (\Exception $e) {
  323. DB::rollBack();
  324. $m = new Message();
  325. $m->json = json_encode([
  326. 'line' => $e->getLine(),
  327. 'message' => $e->getMessage()
  328. ]);
  329. $m->save();
  330. $telegram->sendMessage([
  331. 'chat_id' => $chatId,
  332. 'text' => '‼️‼️系统发生了错误,请联系客服'
  333. ]);
  334. }
  335. } else {
  336. $update = $request->all();
  337. Log::error('Telegram 文字消息回复: ' . json_encode($update, JSON_UNESCAPED_UNICODE));
  338. if (isset($update['message'])) {
  339. $message = $update['message'];
  340. $chatId = $message['chat']['id'];
  341. $messageId = $message['message_id'];
  342. DB::beginTransaction();
  343. try {
  344. $m = new Message();
  345. $m->json = json_encode($update);
  346. $m->save();
  347. $returnMsg = $this->processChatMessage($chatId, $messageId, $message, $message['from']);
  348. if ($returnMsg) {
  349. if (isset($returnMsg['photo']) && $returnMsg['photo'] != '') {
  350. $this->telegram->sendPhoto($returnMsg);
  351. } else {
  352. $this->telegram->sendMessage($returnMsg);
  353. }
  354. }
  355. DB::commit();
  356. } catch (MessageException $e) {
  357. DB::rollBack();
  358. $msg = $e->getMessage();
  359. $msg = json_decode($msg, true);
  360. $telegram->sendMessage($msg);
  361. } //
  362. catch (TelegramSDKException $e) {
  363. DB::rollBack();
  364. $m = new Message();
  365. $m->json = $e->getMessage();
  366. $m->save();
  367. $telegram->sendMessage([
  368. 'chat_id' => $chatId,
  369. 'text' => '‼️‼️系统发生了错误,请联系客服'
  370. ]);
  371. }//
  372. catch (\Exception $e) {
  373. DB::rollBack();
  374. $m = new Message();
  375. $m->json = json_encode([
  376. 'line' => $e->getLine(),
  377. 'message' => $e->getMessage()
  378. ]);
  379. $m->save();
  380. Log::error('Telegram 处理消息异常: ' . $e->getMessage());
  381. $telegram->sendMessage([
  382. 'chat_id' => $chatId,
  383. 'text' => '‼️‼️系统发生了错误,请联系客服'
  384. ]);
  385. }
  386. }
  387. }
  388. return response()->json(['status' => 'ok']);
  389. }
  390. /**
  391. * @description: 处理聊天消息
  392. * @param {*} $chatId
  393. * @param {*} $messageId
  394. * @param {*} $message
  395. * @param {*} $from
  396. * @return {*}
  397. */
  398. public function processChatMessage($chatId, $messageId, $message, $from)
  399. {
  400. $returnMsg = [];
  401. //用户发送图片,结算截图
  402. if (isset($message['photo'])) {
  403. $stepStatus = Cache::get(get_step_key($chatId), -1);
  404. $stepStatus = intval($stepStatus);
  405. // //结算截图
  406. // if ($stepStatus === StepStatus::INPUT_IMAGE) {
  407. // $photo = $message['photo'][count($message['photo']) - 1];
  408. // $res = (new SettlementService())->photo($photo, $chatId);
  409. // if ($res) $telegram->sendMessage($res);
  410. // }//
  411. // //充值截图
  412. // else
  413. if ($stepStatus === StepStatus::INPUT_TOP_UP_IMAGE) {
  414. $photo = $message['photo'][count($message['photo']) - 1];
  415. $res = TopUpService::photo($chatId, $photo);
  416. return $res;
  417. // if (isset($res['message_id'])) $telegram->editMessageText($res);
  418. // else $telegram->sendMessage($res);
  419. }
  420. } //用户发送了消息
  421. else if (isset($message['text'])) {
  422. $text = $message['text'];
  423. if ($message['chat']['type'] === 'private') {
  424. switch ($text) {
  425. case "/start":
  426. Util::delCache($chatId);
  427. $user = User::where('member_id', $chatId)->first();
  428. if (!$user) {
  429. $user = new User();
  430. $user->member_id = $chatId;
  431. }
  432. $user->first_name = $message['chat']['first_name'];
  433. if (isset($message['chat']['username'])) {
  434. $user->username = $message['chat']['username'];
  435. }
  436. $user->save();
  437. //给每个用户生成一个专属的USDT钱包
  438. WalletService::getUserWallet($chatId);
  439. $this->setReplyKeyboard($chatId);
  440. break;
  441. case "近期注单":
  442. Util::delCache($chatId);
  443. $returnMsg = BetService::record($chatId);
  444. // $this->telegram->sendMessage([
  445. // 'chat_id' => $chatId,
  446. // 'text' => $text
  447. // ]);
  448. break;
  449. case "✅近期注单":
  450. Util::delCache($chatId);
  451. $returnMsg = BetService::record($chatId);
  452. // $this->telegram->sendMessage([
  453. // 'chat_id' => $chatId,
  454. // 'text' => $text
  455. // ]);
  456. break;
  457. case "今日流水":
  458. Util::delCache($chatId);
  459. $returnMsg = BalanceLogService::getTodayFlowing($chatId);
  460. // $this->telegram->sendMessage($result);
  461. break;
  462. case "🔍今日流水":
  463. Util::delCache($chatId);
  464. $returnMsg = BalanceLogService::getTodayFlowing($chatId);
  465. // $this->telegram->sendMessage($result);
  466. break;
  467. case "流失列表":
  468. case "🔍流水列表":
  469. Util::delCache($chatId);
  470. $returnMsg = BalanceLogService::getFlowingHistory($chatId);
  471. // $this->telegram->sendMessage($result);
  472. break;
  473. case "联系客服":
  474. Util::delCache($chatId);
  475. $receivingAddress = Config::where('field', 'receiving_address')->first()->val;
  476. $serviceCustomer = Config::where('field', 'service_customer')->first()->val;
  477. $text = "官方唯一上分地址:\n";
  478. $text .= "USDT: \n";
  479. $text .= "{$receivingAddress}\n\n\n";
  480. $text .= "‼️特别注意‼️特别注意‼️\n";
  481. $text .= "‼️近期骗子肆意妄为,猖狂狡诈。经常冒充我方财务,管理人员以各种手段行使诈骗之术。多数为要求转账/提供验证码等。任何主动私聊您的都是非奸即盗。望各位老板谨记,预防受骗!\n";
  482. $text .= "‼️本群管理以及财务绝不会主动私聊客户。请各位老板务必认准群内带标识管理账号,转账前务必核对是否官方账号以及地址。任何一切不是官方行为的受骗上当,本群概不负责,谢谢!\n";
  483. $text .= "‼️为了您的资金安全,下分更换地址请提前告知财务,并使用原地址进行转账或录屏进行身份核实,核实为本人操作后才可进行更换地址下分\n";
  484. $text .= "‼️如查分金额与实际转账金额不同,请重新喊查。玩家重复查3次以上错误金额则视为恶意捣乱,将不退还转账金额!\n";
  485. $text .= "‼️如因为人为失误问题,到账金额与玩家实际转账金额不符,到账后的一切下注视为无效。\n";
  486. $text .= "‼️本群不接待以任何形式刷水的水军,一经发现玩家存在刷水行为将扣除历史所有返水、彩金。并冻结分数一个月,每天仅可下分账户余额10%。不纠结,不解释,请各大水军自行绕道。\n";
  487. $keyboard = [];
  488. $keyboard[] = [['text' => '✅ 唯一客服', 'callback_data' => "", 'url' => "https://t.me/{$serviceCustomer}"]];
  489. $returnMsg = [
  490. 'chat_id' => $chatId,
  491. 'text' => $text,
  492. 'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
  493. ];
  494. break;
  495. case "开奖历史":
  496. Util::delCache($chatId);
  497. IssueService::currentLotteryResults($chatId);
  498. break;
  499. case "📝开奖历史":
  500. Util::delCache($chatId);
  501. IssueService::currentLotteryResults($chatId);
  502. break;
  503. case "当期下注":
  504. Util::delCache($chatId);
  505. $returnMsg = BetService::currentBet($chatId);
  506. break;
  507. case "🔥当期下注":
  508. Util::delCache($chatId);
  509. $returnMsg = BetService::currentBet($chatId);
  510. break;
  511. case "🔥本期下注":
  512. Util::delCache($chatId);
  513. $returnMsg = BetService::currentBet($chatId);
  514. break;
  515. case "查看余额":
  516. Util::delCache($chatId);
  517. $returnMsg = WalletService::getBalance($chatId);
  518. // $this->telegram->sendMessage($result);
  519. break;
  520. case "💰查看余额":
  521. Util::delCache($chatId);
  522. $returnMsg = WalletService::getBalance($chatId);
  523. // $this->telegram->sendMessage($result);
  524. break;
  525. case "投注大群":
  526. Util::delCache($chatId);
  527. $bettingGroup = Config::where('field', 'betting_group')->first()->val;
  528. $text = "👇👇👇点击下方按钮进群投注👇👇👇\n";
  529. $keyboard = [];
  530. $keyboard[] = [['text' => '✅ 投注群', 'callback_data' => "", 'url' => "https://t.me/{$bettingGroup}"]];
  531. $returnMsg = [
  532. 'chat_id' => $chatId,
  533. 'text' => $text,
  534. 'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
  535. ];
  536. break;
  537. default:
  538. // 关键字回复
  539. $keyboardText = KeyboardService::findOne(['button' => $text]);
  540. if ($keyboardText) {
  541. $keyboard = [];
  542. if ($keyboardText['buttons']) {
  543. $keyboard = json_decode($keyboardText['buttons'], true);
  544. }
  545. Util::delCache($chatId);
  546. $res = [
  547. 'chat_id' => $chatId,
  548. 'text' => $keyboardText['reply'],
  549. // 'reply_to_message_id' => $messageId
  550. ];
  551. if ($keyboard) {
  552. $res['reply_markup'] = json_encode(['inline_keyboard' => $keyboard]);
  553. }
  554. if ($keyboardText['image']) {
  555. $res['photo'] = InputFile::create(url($keyboardText['image']));
  556. unset($res['text']);
  557. $res['caption'] = $text;
  558. $res['protect_content'] = true; // 防止转发
  559. }
  560. return $res;
  561. break;
  562. }
  563. $stepStatus = Cache::get(get_step_key($chatId), -1);
  564. $stepStatus = intval($stepStatus);
  565. $res = QianBaoWithdrawService::onMessage($chatId, $text, $messageId, $stepStatus);
  566. if (!empty($res)) return $res;
  567. switch ($stepStatus) {
  568. case StepStatus::INPUT_TOP_UP_MONEY:
  569. $res = TopUpService::inputAmount($chatId, $text, $messageId);
  570. return $res;
  571. break;
  572. case StepStatus::INPUT_WITHDRAW_MONEY:
  573. $res = (new WithdrawService())->inputAmount($chatId, $text, $messageId);
  574. return $res[0];
  575. break;
  576. case StepStatus::INPUT_ADDRESS_TRC20:
  577. $res = WithdrawService::inputAddress($chatId, $text, $messageId);
  578. return $res;
  579. break;
  580. case StepStatus::INPUT_ADDRESS_ALIAS:
  581. $res = WithdrawService::inputAlias($chatId, $text, $messageId);
  582. return $res;
  583. break;
  584. }
  585. $returnMsg = BetService::bet($chatId, $text, $messageId);
  586. // $this->telegram->sendMessage($returnMsg);
  587. }
  588. return $returnMsg;
  589. }
  590. }
  591. }
  592. /**
  593. * @description: 设置 start 回复菜单
  594. * @param {*} $chatId
  595. * @return {*}
  596. */
  597. public function setReplyKeyboard($chatId)
  598. {
  599. $replyInfo = KeyboardService::findOne(['button' => '开始使用']);
  600. $telegram = new Api(config('services.telegram.token'));
  601. $keyboard = [
  602. ['近期注单', '今日流水', '联系客服'], // 第一排按钮
  603. ['开奖历史', '当期下注', '查看余额'], // 第二排按钮
  604. ['投注大群']
  605. ];
  606. if ($replyInfo && $replyInfo->buttons) {
  607. $keyboard = [];
  608. $buttons = json_decode($replyInfo->buttons, true);
  609. foreach ($buttons as $rowIndex => $row) {
  610. if (!empty($row)) {
  611. foreach ($row as $buttonIndex => $button) {
  612. $keyboard[$rowIndex][$buttonIndex] = $button['text'];
  613. }
  614. }
  615. }
  616. $keyboard = array_values($keyboard); // 重新索引数组
  617. Log::error('自定义开始使用按钮: ' . json_encode($keyboard));
  618. }
  619. $botMsg = [];
  620. $botMsg['chat_id'] = $chatId;
  621. $replyMarkup = [
  622. 'keyboard' => $keyboard,
  623. 'resize_keyboard' => true, // 自适应大小
  624. 'one_time_keyboard' => false, // 保持显示,不会点击后收起
  625. ];
  626. $botMsg['reply_markup'] = json_encode($replyMarkup);
  627. if ($replyInfo) {
  628. $image = '';
  629. if ($replyInfo->image) {
  630. $image = url($replyInfo->image);
  631. }
  632. if ($image != '') {
  633. $botMsg['photo'] = InputFile::create($image);
  634. $botMsg['caption'] = $replyInfo->reply;
  635. $botMsg['protect_content'] = true; // 防止转发
  636. KeyboardService::telegram()->sendPhoto($botMsg);
  637. } else {
  638. $botMsg['text'] = $replyInfo->reply;
  639. KeyboardService::telegram()->sendMessage($botMsg);
  640. }
  641. } else {
  642. $telegram->sendMessage([
  643. 'chat_id' => $chatId,
  644. 'text' => '你好,请选择功能菜单',
  645. 'reply_markup' => json_encode($replyMarkup),
  646. ]);
  647. }
  648. }
  649. }