bot-28/app/Http/Controllers/api/TelegramWebHook.php

<?php

namespace App\Http\Controllers\api;

use App\Constants\StepStatus;
use App\Constants\Util;
use App\Exceptions\MessageException;
use App\Models\Message;
use App\Models\User;
use App\Services\QianBaoWithdrawService;
use App\Services\SanJinRechargeService;
use App\Services\SecretService;
use App\Services\SettlementService;
use App\Services\TopUpService;
use App\Services\UserService;
use App\Services\WalletService;
use App\Services\WithdrawService;
use App\Services\BalanceLogService;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Telegram\Bot\Api;
use Telegram\Bot\Exceptions\TelegramSDKException;
use Illuminate\Support\Facades\Log;
use App\Services\BetService;
use App\Services\IssueService;
use App\Services\KeyboardService;
use Telegram\Bot\FileUpload\InputFile;

class TelegramWebHook extends BaseController
{
    protected Api $telegram;

    public function __construct(Api $telegram)
    {
        $this->telegram = $telegram;
        parent::__construct();
    }

    public function handle(Request $request)
    {
        Log::error('Telegram 日志写入测试: ' . json_encode([$request->ip()], JSON_UNESCAPED_UNICODE));

        try {
            $telegram = new Api(config('services.telegram.token'));
        } catch (TelegramSDKException $e) {
            return response()->json(['status' => 'ok']);
        }
        try {
            $update = $telegram->getWebhookUpdate(); // 获取更新数据
            $update->callbackQuery;
            if ($update->has('callback_query')) {
                $callbackQuery = $update->callbackQuery;
                $message = $callbackQuery->message;
                $from = $callbackQuery->from;
                $data = $callbackQuery->data; // 获取 callback_data
                $callbackId = $callbackQuery->id; // 获取 callback_query 的 ID
                Util::delCache($message->chat->id);
                // Log::error('Telegram 回调数据(JSON): ' . json_encode($update, JSON_UNESCAPED_UNICODE));
                DB::beginTransaction();
                try {
                    $chatId = $message->chat->id;
                    $firstName = $message->chat->firstName;
                    $username = '';
                    $messageId = $message->messageId;
                    if (!$from->isBot) {
                        $chatId = $from->id;
                        $firstName = $from->firstName;
                        $username = $from->username;
                    }
                    $user = User::where('member_id', $chatId)->first();
                    if (!$user) {
                        $user = new User();
                        $user->member_id = $chatId;
                    }
                    if ($username) $user->username = $username;
                    $user->first_name = $firstName;
                    $user->save();
                    App::setLocale($user->language);

                    //给每个用户生成一个专属的USDT钱包
                    WalletService::getUserWallet($chatId);


                    QianBaoWithdrawService::init($telegram, $data, $chatId, $firstName, $messageId);
                    SanJinRechargeService::init($telegram, $data, $chatId, $firstName, $messageId);
                    SecretService::init($telegram, $data, $chatId, $firstName, $messageId);
                    UserService::init($telegram, $data, $chatId, $firstName, $messageId);


                    // 查看余额弹窗
                    if ($data === 'balanceAlert') {
                        $alertText = WalletService::getBalance($chatId)['text'];
                        WalletService::alertNotice($callbackId, $alertText);
                    }
                    // 今日流水弹窗
                    if ($data === 'todayFlowAlert') {
                        $alertText = BalanceLogService::getTodayFlowing($chatId)['text'];
                        BalanceLogService::alertNotice($callbackId, $alertText);
                    }
                    // 近期注单弹窗
                    if ($data === 'betsAlert') {
                        Cache::put('message_id_bet_record_' . $chatId, 0, 600);
                        $alertText = BetService::recentlyRecord($chatId);
                        BetService::alertNotice($callbackId, $alertText);
                    }

                    //选择充值地址
                    if ($data === "topUp@@TRC20" || $data === "topUp@@ERC20") {
                        $type = preg_replace('/^topUp@@/', '', $data);
                        $topService = new TopUpService();
                        $res = $topService->scan($chatId, $messageId, $type);
                        $telegram->deleteMessage([
                            'chat_id' => $chatId,
                            'message_id' => $messageId,
                        ]);
                        $telegram->sendPhoto($res);
                    }

                    //点击充值按钮
                    if ($data === 'topup@@topup') {

                        $res = TopUpService::chooseAddress($chatId, $messageId);
                        $telegram->editMessageText($res);
                    }

                    //点击充值的账单按钮
                    if ($data === 'topup@@bill') {
                        $res = (new TopUpService())->bill($chatId, $firstName, $messageId);
                        $telegram->editMessageText($res);
                    }

                    //点击我已付款按钮
                    //手动充值(后台审核后到账)
                    if ($data === 'topUp@@pay2') {
                        $telegram->deleteMessage([
                            'chat_id' => $chatId,
                            'message_id' => $messageId
                        ]);
                        $res = TopUpService::pay2($chatId);
                        $telegram->sendMessage($res);
                    } //
                    //自动充值
                    elseif ($data === 'topUp@@pay') {
                        $telegram->deleteMessage([
                            'chat_id' => $chatId,
                            'message_id' => $messageId
                        ]);
                        $topService = new TopUpService();
                        $res = $topService->done($chatId);
                        $telegram->sendMessage($res);
                    }

                    //充值首页
                    if ($data === "topUp@@home" || $data === "topUp@@home1") {
                        $returnMsg = WalletService::getBalance($chatId);
                        if ($returnMsg) {
                            if ($data === "topUp@@home1") {
                                $telegram->deleteMessage([
                                    'chat_id' => $chatId,
                                    'message_id' => $messageId
                                ]);
                                $this->telegram->sendMessage($returnMsg);
                            } else {
                                $returnMsg['message_id'] = $messageId;
                                $telegram->editMessageText($returnMsg);
                            }

                        }

                        // $res = (new TopUpService())->index($chatId, $firstName, $messageId);
                        // if ($data === "topUp@@home1") {
                        //     $telegram->deleteMessage([
                        //         'chat_id' => $chatId,
                        //         'message_id' => $messageId
                        //     ]);
                        //     $telegram->sendMessage($res);
                        // } else {
                        //     $telegram->editMessageText($res);
                        // }
                    }


                    //点击提现按钮
                    if ($data === "withdraw@@apply") {
                        $res = (new WithdrawService())->apply($chatId, $messageId);
                        $telegram->editMessageText($res);
                    }


                    //地址管理
                    if ($data === 'withdraw@@address') {
                        $res = WithdrawService::getAddress($chatId, $messageId);
                        $telegram->editMessageText($res);
                    }


                    //关闭本条消息
                    if ($data === 'message@@close') {
                        $telegram->deleteMessage([
                            'chat_id' => $chatId,
                            'message_id' => $messageId
                        ]);
                    }


                    if ($data === 'withdrawAddress@@add') {
                        $res = WithdrawService::addAddress($chatId, $messageId);
                        $telegram->editMessageText($res);
                    }

                    //提现管理
                    if ($data === "withdraw@@home") {
                        // $res = WithdrawService::index($chatId, $firstName, $messageId);
                        // $telegram->editMessageText($res);
                        $telegram->deleteMessage([
                            'chat_id' => $chatId,
                            'message_id' => $messageId
                        ]);
                        $returnMsg = WalletService::getBalance($chatId);
                        if ($returnMsg) {
                            $this->telegram->sendMessage($returnMsg);
                        }
                    }

                    //点击提现的账单按钮
                    if ($data === "withdraw@@bill") {
                        $res = (new WithdrawService())->bill($chatId, $firstName, $messageId);
                        $telegram->editMessageText($res);
//                    $telegram->sendMessage($res);
//                    $text = "📅 请输入查询日期\n";
//                    $date = date('Y-m-d');
//                    $text .= "例如您要查询的日期 {$date}\n";
//                    $text .= "那么请发送：【提现账单】{$date}\n";
//                    $telegram->sendMessage([
//                        'chat_id' => $chatId,
//                        'text' => $text
//                    ]);
                    }

                    if ($data === 'withdrawAddress@@done') {
                        $res = WithdrawService::done($chatId, $messageId, $firstName);
                        $telegram->editMessageText($res);
                    }

                    // 今日汇率
                    if ($data === 'todayExchangeRate@@rate') {
                        BetService::todayExchangeRate($chatId);
                        // $telegram->sendMessage($res);
                    }

                    //查看开奖历史图片
                    $pattern = "/^showLotteryHistory@@\d+$/";
                    if (preg_match($pattern, $data)) {
                        $id = preg_replace('/^showLotteryHistory@@/', '', $data);
                        IssueService::sendLotteryImage($chatId, $id);
                    }

                    //选择投注记录
                    $pattern = "/^betRecordType@@\d+$/";
                    if (preg_match($pattern, $data)) {
                        $type = preg_replace('/^betRecordType@@/', '', $data);
                        Cache::put('message_id_bet_record_' . $chatId, intval($type), 600);
                        $telegram->deleteMessage([
                            'chat_id' => $chatId,
                            'message_id' => $messageId,
                        ]);
                        $returnMsg = BetService::record($chatId);
                        $telegram->sendMessage($returnMsg);
                    }


                    //选择提现地址
                    $pattern = "/^withdrawAddress@@choose\d+$/";
                    if (preg_match($pattern, $data)) {
                        $id = preg_replace('/^withdrawAddress@@choose/', '', $data);
                        $res = WithdrawService::chooseAddress($chatId, $firstName, $messageId, $id);
                        $telegram->editMessageText($res);
                    }

                    //删除地址
                    $pattern = "/^withdrawAddress@@del\d+$/";
                    if (preg_match($pattern, $data)) {
                        $id = preg_replace('/^withdrawAddress@@del/', '', $data);
                        $res = WithdrawService::delAddress($chatId, $id, $messageId);
                        $telegram->editMessageText($res);
                    }
                    //地址详情
                    $pattern = "/^withdrawAddress@@detail\d+$/";
                    if (preg_match($pattern, $data)) {
                        $id = preg_replace('/^withdrawAddress@@detail/', '', $data);
                        $res = WithdrawService::addressDetails($chatId, $messageId, $id);
                        $telegram->editMessageText($res);
                    }

                    //充值账单，下一页
                    $pattern = "/^topUpBillNextPage@@\d+$/";
                    if (preg_match($pattern, $data)) {
                        $page = preg_replace('/^topUpBillNextPage@@/', '', $data);
                        $page = intval($page);
                        $res = (new TopUpService())->bill($chatId, $firstName, $messageId, $page);
                        $telegram->editMessageText($res);
                    }

                    //流水列表，下一页
                    $pattern = "/^FlowingHistoryPage@@\d+$/";
                    if (preg_match($pattern, $data)) {
                        $page = preg_replace('/^FlowingHistoryPage@@/', '', $data);
                        $page = intval($page);
                        $returnMsg = BalanceLogService::getFlowingHistory($chatId, $messageId, $page);
                        $telegram->editMessageText($returnMsg);
                    }


                    //提现账单，下一页
                    $pattern = "/^withdrawBillNextPage@@\d+$/";
                    if (preg_match($pattern, $data)) {
                        $page = preg_replace('/^withdrawBillNextPage@@/', '', $data);
                        $page = intval($page);
                        $res = (new WithdrawService())->bill($chatId, $firstName, $messageId, $page);
                        $telegram->editMessageText($res);
                    }

                    //近期注单，下一页
                    $pattern = "/^betRecordNextPage@@\d+$/";
                    if (preg_match($pattern, $data)) {
                        $page = preg_replace('/^betRecordNextPage@@/', '', $data);
                        $page = intval($page);
                        $res = BetService::record($chatId, $messageId, $page);
                        $telegram->editMessageText($res);
                    }
                    DB::commit();
                } //
                catch (MessageException $e) {
                    DB::rollBack();
                    $msg = $e->getMessage();
                    $msg = json_decode($msg, true);
                    $telegram->sendMessage($msg);
                } //
                catch (TelegramSDKException $e) {
                    DB::rollBack();
                    $m = new Message();
                    $m->json = $e->getMessage();
                    $m->save();
                    $telegram->sendMessage([
                        'chat_id' => $chatId,
                        'text' => '‼️‼️系统发生了错误，请联系客服'
                    ]);
                }//
                catch (\Exception $e) {
                    DB::rollBack();
                    $m = new Message();
                    $m->json = json_encode([
                        'line' => $e->getLine(),
                        'message' => $e->getMessage()
                    ]);
                    $m->save();
                    $telegram->sendMessage([
                        'chat_id' => $chatId,
                        'text' => '‼️‼️系统发生了错误，请联系客服'
                    ]);
                }

            } //
            else {
                $update = $request->all();
                Log::error('Telegram 文字消息回复: ' . json_encode($update, JSON_UNESCAPED_UNICODE));
                if (isset($update['message'])) {
                    $message = $update['message'];
                    $chatId = $message['chat']['id'];
                    $messageId = $message['message_id'];
                    DB::beginTransaction();
                    try {
                        $m = new Message();
                        $m->json = json_encode($update);
                        $m->save();

                        $returnMsg = $this->processChatMessage($chatId, $messageId, $message, $message['from']);
                        if ($returnMsg) {
                            if (isset($returnMsg['image']) && $returnMsg['image'] != '') {
                                KeyboardService::sendMessage($returnMsg['chat_id'], $returnMsg['text'] ?? '', $returnMsg['keyboard'] ?? [], $returnMsg['image'] ?? '');
                            } else if (isset($returnMsg['photo']) && $returnMsg['photo'] != '') {
                                $this->telegram->sendPhoto($returnMsg);
                            } else {
                                $this->telegram->sendMessage($returnMsg);
                            }

                        }
                        DB::commit();
                    } catch (MessageException $e) {
                        DB::rollBack();
                        $msg = $e->getMessage();
                        $msg = json_decode($msg, true);
                        $telegram->sendMessage($msg);
                    } //
                    catch (TelegramSDKException $e) {
                        DB::rollBack();
                        $m = new Message();
                        $m->json = $e->getMessage();
                        $m->save();
                        $telegram->sendMessage([
                            'chat_id' => $chatId,
                            'text' => '‼️‼️系统发生了错误，请联系客服'
                        ]);
                    }//
                    catch (\Exception $e) {
                        DB::rollBack();
                        $m = new Message();
                        $m->json = json_encode([
                            'line' => $e->getLine(),
                            'message' => $e->getMessage()
                        ]);
                        $m->save();
                        Log::error('Telegram 处理消息异常: ' . $e->getMessage());
                        $telegram->sendMessage([
                            'chat_id' => $chatId,
                            'text' => '‼️‼️系统发生了错误，请联系客服'
                        ]);
                    }
                }

            }
        } //
        catch (\Exception $e) {
            $m = new Message();
            $m->json = $e->getMessage();
            $m->save();
            if (!empty($chatId)) {
                $telegram->sendMessage([
                    'chat_id' => $chatId,
                    'text' => '‼️‼️系统发生了错误，请联系客服'
                ]);
            }
        }
        return response()->json(['status' => 'ok']);
    }

    /**
     * @description: 处理聊天消息
     * @param {*} $chatId
     * @param {*} $messageId
     * @param {*} $message
     * @param {*} $from
     * @throws TelegramSDKException
     */
    public function processChatMessage($chatId, $messageId, $message, $from)
    {
        $returnMsg = [];
        //用户发送图片,结算截图
        if (isset($message['photo'])) {
            $stepStatus = Cache::get(get_step_key($chatId), -1);
            $stepStatus = intval($stepStatus);
            // //结算截图
            if ($stepStatus === StepStatus::INPUT_IMAGE) {
                $photo = $message['photo'][count($message['photo']) - 1];
                return (new SettlementService())->photo($photo, $chatId);
            }//
            //充值截图
            else if ($stepStatus === StepStatus::INPUT_TOP_UP_IMAGE) {
                $photo = $message['photo'][count($message['photo']) - 1];
                return TopUpService::photo($chatId, $photo);
            } else {
                return [];
            }

        } //用户发送了消息
        else if (isset($message['text'])) {
            $text = $message['text'];

            $user = User::where('member_id', $chatId)->first();
            if (!$user) {
                $user = new User();
                $user->member_id = $chatId;
            }
            $user->first_name = $message['chat']['first_name'];
            if (isset($message['chat']['username'])) {
                $user->username = $message['chat']['username'];
            }
            $user->save();
            App::setLocale($user->language);
            if ($message['chat']['type'] === 'private') {

                // 校验开始菜单事件
                $returnMsg = KeyboardService::checkStart($chatId, $text);
                if ($returnMsg) {
                    return $returnMsg;
                }


                switch ($text) {
                    case "/start":
                        Util::delCache($chatId);
                        //给每个用户生成一个专属的USDT钱包
                        WalletService::getUserWallet($chatId);
                        self::setReplyKeyboard($chatId, $user->language);
                        break;
                    default:
                        // 关键字回复
                        $keyboardText = KeyboardService::findOne(['button' => $text]);
                        if ($keyboardText) {
                            $keyboard = [];
                            if ($keyboardText['buttons']) {
                                $keyboard = json_decode($keyboardText['buttons'], true);
                            }
                            Util::delCache($chatId);
                            $res = [
                                'chat_id' => $chatId,
                                'text' => $keyboardText['reply'],
                                // 'reply_to_message_id' => $messageId
                            ];
                            if ($keyboard) {
                                $res['reply_markup'] = json_encode(['inline_keyboard' => $keyboard]);
                            }
                            if ($keyboardText['image']) {
                                $res['photo'] = InputFile::create(url($keyboardText['image']));
                                unset($res['text']);
                                $res['caption'] = $text;
                                $res['protect_content'] = true;  // 防止转发
                            }
                            return $res;
                        }
                        $stepStatus = Cache::get(get_step_key($chatId), -1);
                        $stepStatus = intval($stepStatus);
                        $res = QianBaoWithdrawService::onMessage($chatId, $text, $messageId, $stepStatus);
                        if (empty($res)) $res = SanJinRechargeService::onMessage($chatId, $text, $messageId, $stepStatus);
                        if (empty($res)) $res = SecretService::onMessage($chatId, $text, $messageId, $stepStatus);
                        if (!empty($res)) return $res;
                        switch ($stepStatus) {
                            case StepStatus::INPUT_TOP_UP_MONEY:
                                return TopUpService::inputAmount($chatId, $text, $messageId);
                            case StepStatus::INPUT_WITHDRAW_MONEY:
                                $res = (new WithdrawService())->inputAmount($chatId, $text, $messageId);
                                return $res[0];
                            case StepStatus::INPUT_ADDRESS_TRC20:
                                return WithdrawService::inputAddress($chatId, $text, $messageId);
                            case StepStatus::INPUT_ADDRESS_ALIAS:
                                return WithdrawService::inputAlias($chatId, $text, $messageId);
                        }
                        $returnMsg = BetService::bet($chatId, $text, $messageId);
                }

                return $returnMsg;
            }
        }
        return [];
    }

    /**
     * @description: 设置 start 回复菜单
     * @param {*} $chatId
     * @throws TelegramSDKException
     */
    public static function setReplyKeyboard($chatId, $language = 'en'): void
    {
        $replyInfo = KeyboardService::findOne(['button' => '开始使用', 'language' => $language]);
        if (empty($replyInfo)) {
            $replyInfo = KeyboardService::findOne(['button' => '开始使用', 'language' => 'en']);
        }
        $telegram = new Api(config('services.telegram.token'));

        $keyboard = [
            [lang('近期注单'), lang('今日流水'), lang('联系客服')], // 第一排按钮
            [lang('开奖历史'), lang('当期下注'), lang('查看余额')],    // 第二排按钮
            [lang('投注大群')]
        ];

        if ($replyInfo && $replyInfo->buttons) {
            $keyboard = [];
            $buttons = json_decode($replyInfo->buttons, true);

            foreach ($buttons as $rowIndex => $row) {
                if (!empty($row)) {
                    foreach ($row as $buttonIndex => $button) {
                        // $keyboard[$rowIndex][$buttonIndex] = lang($button['text']);
                        $keyboard[$rowIndex][$buttonIndex] = $button['text'];
                    }
                }

            }
            $keyboard = array_values($keyboard); // 重新索引数组
            Log::error('自定义开始使用按钮: ' . json_encode($keyboard));

        }

        $botMsg = [];
        $botMsg['chat_id'] = $chatId;
        $replyMarkup = [
            'keyboard' => $keyboard,
            'resize_keyboard' => true,    // 自适应大小
            'one_time_keyboard' => false, // 保持显示，不会点击后收起
        ];
        $botMsg['reply_markup'] = json_encode($replyMarkup);

        if ($replyInfo) {
            $image = '';
            if ($replyInfo->image) {
                $image = url($replyInfo->image);

            }

            if ($image != '') {
                $botMsg['photo'] = InputFile::create($image);
                $botMsg['caption'] = lang($replyInfo->reply);
                $botMsg['protect_content'] = true;  // 防止转发
                KeyboardService::telegram()->sendPhoto($botMsg);
            } else {
                $botMsg['text'] = lang($replyInfo->reply);

                KeyboardService::telegram()->sendMessage($botMsg);
            }
        } else {
            $telegram->sendMessage([
                'chat_id' => $chatId,
                'text' => lang('你好，请选择功能菜单'),
                'reply_markup' => json_encode($replyMarkup),
            ]);
        }


    }
}