Merge branch 'master' of 47.76.126.2:seven/bot-28

app/Http/Controllers/admin/Sync.php

@@ -48,8 +48,8 @@ class Sync extends Controller
             // Log::error('✅ 获取到最新期号: ' . ($latestIssue ?? '无'));
 
             // 你的业务逻辑
-        IssueService::getLatestIssue(); // 获取最新的期号
-        return $this->success();
+       $res = IssueService::getLatestIssue(); // 获取最新的期号
+        return $this->success($res);
     }
 
     public function close()

app/Http/Controllers/admin/User.php

@@ -57,33 +57,6 @@ class User extends Controller
         return $this->success();
     }
 
-
-    /**
-     * @api {get} /admin/user 会员列表
-     * @apiGroup 会员管理
-     *
-     * @apiUse result
-     * @apiUse header
-     * @apiVersion 1.0.0
-     *
-     * @apiParam {int} [page=1]
-     * @apiParam {int} [limit=10]
-     * @apiParam {string} [first_name] 用户昵称
-     * @apiParam {string} [member_id] 房主 tg会员ID
-     * @apiParam {string} [game_id] 游戏ID
-     *
-     * @apiSuccess (data) {Object} data
-     * @apiSuccess (data) {int} data.total 数量
-     * @apiSuccess (data) {Object[]} data.data 列表
-     * @apiSuccess (data) {int} data.data.id
-     * @apiSuccess (data) {int} data.data.member_id tg会员id
-     * @apiSuccess (data) {string} data.data.first_name 昵称
-     * @apiSuccess (data) {string} data.data.usdt 用户usdt钱包地址
-     * @apiSuccess (data) {string} data.data.game_id 游戏ID
-     * @apiSuccess (data) {string} data.data.updated_at
-     * @apiSuccess (data) {string} data.data.created_at
-     * @apiSuccess (data) {string} data.data.secret_key 找回账号的秘钥
-     */
     public function index(): JsonResponse
     {
         try {
@@ -93,6 +66,7 @@ class User extends Controller
                 'member_id' => ['nullable', 'string', 'min:1'],
                 'first_name' => ['nullable', 'string', 'min:1'],
                 'username' => ['nullable', 'string', 'min:1'],
+                'register_ip' => ['nullable', 'string', 'min:1'],
             ]);
             $result = UserService::paginate($search);
         } catch (ValidationException $e) {
@@ -103,19 +77,6 @@ class User extends Controller
         return $this->success($result);
     }
 
-
-    /**
-     * @api {post} /admin/user/merge 账户合并
-     * @apiGroup 会员管理
-     * @apiDescription 合并后，余额，银行卡，USDT地址 将合并到新用户，请谨慎操作
-     *
-     * @apiUse result
-     * @apiUse header
-     * @apiVersion 1.0.0
-     *
-     * @apiParam {string} member_id 接收者的member_id
-     * @apiParam {string} secret_key 被合并的用户的秘钥
-     */
     public function merge(): JsonResponse
     {
         DB::beginTransaction();

app/Http/Controllers/admin/Wallet.php

@@ -9,6 +9,7 @@ use App\Services\BalanceLogService;
 use App\Services\RechargeService;
 use App\Services\TopUpService;
 use Exception;
+use Illuminate\Support\Facades\Cache;
 
 use Illuminate\Support\Facades\DB;
 use Illuminate\Validation\ValidationException;
@@ -78,16 +79,20 @@ class Wallet extends Controller
             $memberId = request()->input('member_id');
             $amount = request()->input('amount');
             $remark = request()->input('remark');
-
-
-            $wallet = WalletModel::where('member_id', $memberId)
-                ->first();
+            $key = 'api_request_' . md5($memberId . json_encode([
+                        'amount' => $amount,
+                        'remark' => $remark,
+                        'action' => "wallet/topUp"
+                    ]));
+            if (Cache::has($key)) throw new Exception("请求太频繁，请稍后再试。", HttpStatus::CUSTOM_ERROR);
+            Cache::put($key, true, 3);
+            $wallet = WalletModel::where('member_id', $memberId)->first();
             if (!$wallet) throw new Exception('用户不存在', HttpStatus::CUSTOM_ERROR);
-
-            $available_balance = bcadd($wallet->available_balance, $amount, 10);
+            $availableBalance = bcadd($wallet->available_balance, $amount, 10);
+            if ($availableBalance < 0) throw new Exception('可用余额不足', HttpStatus::CUSTOM_ERROR);
             $changeType = ($amount > 0 ? "人工充值" : "人工扣款");
-            BalanceLogService::addLog($memberId, $amount, $wallet->available_balance, $available_balance, $changeType, null, $remark);
-            $wallet->available_balance = $available_balance;
+            BalanceLogService::addLog($memberId, $amount, $wallet->available_balance, $availableBalance, $changeType, null, $remark);
+            $wallet->available_balance = $availableBalance;
             $wallet->save();
             DB::commit();
         } catch (ValidationException $e) {
@@ -98,10 +103,10 @@ class Wallet extends Controller
             return $this->error(intval($e->getCode()), $e->getMessage());
         }
 
-        $available_balance = floatval($available_balance);
+        $availableBalance = floatval($availableBalance);
         // 去除多余0后，再用 sprintf 补足两位
-        $available_balance = sprintf('%.2f', $available_balance);
-        TopUpService::notifyTransferSuccess($memberId, "您的账户余额更新：" . ($amount > 0 ? '+' : '') . "{$amount} \n总余额为：{$available_balance}");
+        $availableBalance = sprintf('%.2f', $availableBalance);
+        TopUpService::notifyTransferSuccess($memberId, "您的账户余额更新：" . ($amount > 0 ? '+' : '') . "{$amount} \n总余额为：{$availableBalance}");
         return $this->success();
     }
 

app/Http/Controllers/api/TelegramWebHook.php

@@ -5,23 +5,17 @@ namespace App\Http\Controllers\api;
 use App\Constants\StepStatus;
 use App\Constants\Util;
 use App\Exceptions\MessageException;
-use App\Http\Controllers\Controller;
 use App\Models\Message;
 use App\Models\User;
-use App\Services\OnLineService;
 use App\Services\QianBaoWithdrawService;
 use App\Services\SanJinRechargeService;
-use App\Services\RecordService;
-use App\Services\RoomService;
 use App\Services\SecretService;
 use App\Services\SettlementService;
 use App\Services\TopUpService;
-use App\Services\TutorialService;
 use App\Services\UserService;
 use App\Services\WalletService;
 use App\Services\WithdrawService;
 use App\Services\BalanceLogService;
-use Carbon\Carbon;
 use Illuminate\Http\Request;
 use Illuminate\Support\Facades\App;
 use Illuminate\Support\Facades\Cache;
@@ -29,12 +23,9 @@ use Illuminate\Support\Facades\DB;
 use Telegram\Bot\Api;
 use Telegram\Bot\Exceptions\TelegramSDKException;
 use Illuminate\Support\Facades\Log;
-use App\Models\Config;
-use App\Services\GameplayRuleService;
 use App\Services\BetService;
 use App\Services\IssueService;
 use App\Services\KeyboardService;
-use Google\Service\Dfareporting\Language;
 use Telegram\Bot\FileUpload\InputFile;
 
 class TelegramWebHook extends BaseController
@@ -50,198 +41,202 @@ class TelegramWebHook extends BaseController
     public function handle(Request $request)
     {
         Log::error('Telegram 日志写入测试: ' . json_encode([$request->ip()], JSON_UNESCAPED_UNICODE));
-        $telegram = new Api(config('services.telegram.token'));
-        $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);
+        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();
 
-                //给每个用户生成一个专属的USDT钱包
-                WalletService::getUserWallet($chatId);
+                    if (!$user) {
+                        $user = new User();
+                        $user->member_id = $chatId;
+                    }
+                    if (empty($user->register_ip)) {
+                        $registerIp = request()->ip();
+                        if (User::where('register_ip', $registerIp)->exists()) {
+                            User::where('register_ip', $registerIp)->update(['status' => 1]);
+                            $user->status = 1;
+                        }
+                        $user->register_ip = $registerIp;
+                    }
+                    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);
 
+                    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 === '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@@topup') {
+                    //选择充值地址
+                    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);
+                    }
 
-                    $res = TopUpService::chooseAddress($chatId, $messageId);
-                    $telegram->editMessageText($res);
-                }
+                    //点击充值按钮
+                    if ($data === 'topup@@topup') {
 
-                //点击充值的账单按钮
-                if ($data === 'topup@@bill') {
-                    $res = (new TopUpService())->bill($chatId, $firstName, $messageId);
-                    $telegram->editMessageText($res);
+                        $res = TopUpService::chooseAddress($chatId, $messageId);
+                        $telegram->editMessageText($res);
+                    }
 
+                    //点击充值的账单按钮
+                    if ($data === 'topup@@bill') {
+                        $res = (new TopUpService())->bill($chatId, $firstName, $messageId);
+                        $telegram->editMessageText($res);
+                    }
 
-//                    $text = "📅 请输入查询日期\n";
-//                    $date = date('Y-m-d');
-//                    $text .= "例如您要查询的日期 {$date}\n";
-//                    $text .= "那么请发送：【充值账单】{$date}\n";
-//                    $telegram->sendMessage([
-//                        'chat_id' => $chatId,
-//                        'text' => $text
-//                    ]);
-                }
+                    //点击我已付款按钮
+                    //手动充值(后台审核后到账)
+                    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@@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);
+                            }
 
-                //充值首页
-                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);
+                        // }
                     }
 
-                    // $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@@apply") {
+                        $res = (new WithdrawService())->apply($chatId, $messageId);
+                        $telegram->editMessageText($res);
+                    }
 
 
-                //地址管理
-                if ($data === 'withdraw@@address') {
-                    $res = WithdrawService::getAddress($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 === 'message@@close') {
+                        $telegram->deleteMessage([
+                            'chat_id' => $chatId,
+                            'message_id' => $messageId
+                        ]);
+                    }
 
 
-                if ($data === 'withdrawAddress@@add') {
-                    $res = WithdrawService::addAddress($chatId, $messageId);
-                    $telegram->editMessageText($res);
-                }
+                    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@@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);
+                    //点击提现的账单按钮
+                    if ($data === "withdraw@@bill") {
+                        $res = (new WithdrawService())->bill($chatId, $firstName, $messageId);
+                        $telegram->editMessageText($res);
 //                    $telegram->sendMessage($res);
 //                    $text = "📅 请输入查询日期\n";
 //                    $date = date('Y-m-d');
@@ -251,157 +246,102 @@ class TelegramWebHook extends BaseController
 //                        'chat_id' => $chatId,
 //                        'text' => $text
 //                    ]);
-                }
-
-                if ($data === 'withdrawAddress@@done') {
-                    $res = WithdrawService::done($chatId, $messageId, $firstName);
-                    $telegram->editMessageText($res);
-                }
-
-                // 今日汇率
-                if ($data === 'todayExchangeRate@@rate') {
-                    $res = BetService::todayExchangeRate($chatId);
-                    // $telegram->sendMessage($res);
-                }
-
-                //查看开奖历史图片
-                $pattern = "/^showLotteryHistory@@\d+$/";
-                if (preg_match($pattern, $data)) {
-                    $id = preg_replace('/^showLotteryHistory@@/', '', $data);
-                    $res = 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);
-                }
+                    if ($data === 'withdrawAddress@@done') {
+                        $res = WithdrawService::done($chatId, $messageId, $firstName);
+                        $telegram->editMessageText($res);
+                    }
 
+                    // 今日汇率
+                    if ($data === 'todayExchangeRate@@rate') {
+                        BetService::todayExchangeRate($chatId);
+                        // $telegram->sendMessage($res);
+                    }
 
-                //选择提现地址
-                $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 = "/^showLotteryHistory@@\d+$/";
+                    if (preg_match($pattern, $data)) {
+                        $id = preg_replace('/^showLotteryHistory@@/', '', $data);
+                        IssueService::sendLotteryImage($chatId, $id);
+                    }
 
-                //删除地址
-                $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 = "/^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 = "/^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 = "/^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 = "/^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 = "/^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 = "/^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' => '‼️‼️系统发生了错误，请联系客服'
-                ]);
-            }
+                    //流水列表，下一页
+                    $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);
+                    }
 
-        } 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);
-                        }
+                    //提现账单，下一页
+                    $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) {
+                } //
+                catch (MessageException $e) {
                     DB::rollBack();
                     $msg = $e->getMessage();
                     $msg = json_decode($msg, true);
@@ -425,14 +365,82 @@ class TelegramWebHook extends BaseController
                         'message' => $e->getMessage()
                     ]);
                     $m->save();
-                    Log::error('Telegram 处理消息异常: ' . $e->getMessage());
                     $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']);
     }
@@ -443,7 +451,7 @@ class TelegramWebHook extends BaseController
      * @param {*} $messageId
      * @param {*} $message
      * @param {*} $from
-     * @return {*}
+     * @throws TelegramSDKException
      */
     public function processChatMessage($chatId, $messageId, $message, $from)
     {
@@ -453,19 +461,16 @@ class TelegramWebHook extends BaseController
             $stepStatus = Cache::get(get_step_key($chatId), -1);
             $stepStatus = intval($stepStatus);
             // //结算截图
-            // if ($stepStatus === StepStatus::INPUT_IMAGE) {
-            //     $photo = $message['photo'][count($message['photo']) - 1];
-            //     $res = (new SettlementService())->photo($photo, $chatId);
-            //     if ($res) $telegram->sendMessage($res);
-            // }//
-            // //充值截图
-            // else 
-            if ($stepStatus === StepStatus::INPUT_TOP_UP_IMAGE) {
+            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];
-                $res = TopUpService::photo($chatId, $photo);
-                return $res;
-                // if (isset($res['message_id'])) $telegram->editMessageText($res);
-                // else $telegram->sendMessage($res);
+                return TopUpService::photo($chatId, $photo);
+            } else {
+                return [];
             }
 
         } //用户发送了消息
@@ -477,6 +482,15 @@ class TelegramWebHook extends BaseController
                 $user = new User();
                 $user->member_id = $chatId;
             }
+            if (empty($user->register_ip)) {
+                $registerIp = request()->ip();
+                if (User::where('register_ip', $registerIp)->exists()) {
+                    User::where('register_ip', $registerIp)->update(['status' => 1]);
+                    $user->status = 1;
+                }
+                $user->register_ip = $registerIp;
+            }
+
             $user->first_name = $message['chat']['first_name'];
             if (isset($message['chat']['username'])) {
                 $user->username = $message['chat']['username'];
@@ -499,79 +513,6 @@ class TelegramWebHook extends BaseController
                         WalletService::getUserWallet($chatId);
                         self::setReplyKeyboard($chatId, $user->language);
                         break;
-                    // case lang("近期注单"):
-                    // case lang('"✅近期注单"'):
-                    //     Util::delCache($chatId);
-                    //     $returnMsg = BetService::record($chatId);
-                    //     break;
-                    // case lang("今日流水"):
-                    // case lang("🔍今日流水"):
-                    //     Util::delCache($chatId);
-                    //     $returnMsg = BalanceLogService::getTodayFlowing($chatId);
-                    //     // $this->telegram->sendMessage($result);
-                    //     break;
-                    // case lang("流水列表"):
-                    // case lang("🔍流水列表"):
-                    //     Util::delCache($chatId);
-                    //     $returnMsg = BalanceLogService::getFlowingHistory($chatId);
-                    //     // $this->telegram->sendMessage($result);
-                    //     break;
-                    // case lang("联系客服"):
-                    //     Util::delCache($chatId);
-                    //     $receivingAddress = Config::where('field', 'receiving_address')->first()->val;
-                    //     $serviceCustomer = Config::where('field', 'service_customer')->first()->val;
-                    //     $text = "官方唯一上分地址：\n";
-                    //     $text .= "USDT: \n";
-                    //     $text .= "{$receivingAddress}\n\n\n";
-                    //     $text .= "‼️特别注意‼️特别注意‼️\n";
-                    //     $text .= "‼️近期骗子肆意妄为，猖狂狡诈。经常冒充我方财务，管理人员以各种手段行使诈骗之术。多数为要求转账/提供验证码等。任何主动私聊您的都是非奸即盗。望各位老板谨记，预防受骗！\n";
-                    //     $text .= "‼️本群管理以及财务绝不会主动私聊客户。请各位老板务必认准群内带标识管理账号，转账前务必核对是否官方账号以及地址。任何一切不是官方行为的受骗上当，本群概不负责，谢谢！\n";
-                    //     $text .= "‼️为了您的资金安全，下分更换地址请提前告知财务，并使用原地址进行转账或录屏进行身份核实，核实为本人操作后才可进行更换地址下分\n";
-                    //     $text .= "‼️如查分金额与实际转账金额不同，请重新喊查。玩家重复查3次以上错误金额则视为恶意捣乱，将不退还转账金额！\n";
-                    //     $text .= "‼️如因为人为失误问题，到账金额与玩家实际转账金额不符，到账后的一切下注视为无效。\n";
-                    //     $text .= "‼️本群不接待以任何形式刷水的水军，一经发现玩家存在刷水行为将扣除历史所有返水、彩金。并冻结分数一个月，每天仅可下分账户余额10%。不纠结，不解释，请各大水军自行绕道。\n";
-                    //     $keyboard = [];
-                    //     $keyboard[] = [['text' => '✅ 唯一客服', 'callback_data' => "", 'url' => "https://t.me/{$serviceCustomer}"]];
-                    //     $returnMsg = [
-                    //         'chat_id' => $chatId,
-                    //         'text' => $text,
-                    //         'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
-                    //     ];
-                    //     break;
-                    // case lang("开奖历史"):
-                    // case lang("📝开奖历史"):
-                    //     Util::delCache($chatId);
-                    //     IssueService::currentLotteryResults($chatId);
-                    //     break;
-                    // case lang("当期下注"):
-                    // case lang("🔥当期下注"):
-                    // case lang("🔥本期下注"):
-                    //     Util::delCache($chatId);
-                    //     $returnMsg = BetService::currentBet($chatId);
-                    //     break;
-                    // case lang("选择语言"):
-                    //     Util::delCache($chatId);
-                    //     $returnMsg = UserService::getLanguages($chatId);
-                    //     break;
-                    // case lang("查看余额"):
-                    // case lang("💰查看余额"):
-                    //     Util::delCache($chatId);
-                    //     $returnMsg = WalletService::getBalance($chatId);
-                    //     break;
-                    // case lang("投注大群"):
-                    //     Util::delCache($chatId);
-
-                    //     $bettingGroup = Config::where('field', 'betting_group')->first()->val;
-
-                    //     $text = "👇👇👇点击下方按钮进群投注👇👇👇 \n";
-                    //     $keyboard = [];
-                    //     $keyboard[] = [['text' => '✅ 投注群', 'callback_data' => "", 'url' => "https://t.me/{$bettingGroup}"]];
-                    //     $returnMsg = [
-                    //         'chat_id' => $chatId,
-                    //         'text' => $text,
-                    //         'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
-                    //     ];
-                    //     break;
                     default:
                         // 关键字回复
                         $keyboardText = KeyboardService::findOne(['button' => $text]);
@@ -594,50 +535,33 @@ class TelegramWebHook extends BaseController
                                 unset($res['text']);
                                 $res['caption'] = $text;
                                 $res['protect_content'] = true;  // 防止转发
-
                             }
-
                             return $res;
-                            break;
                         }
-
                         $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)) $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:
-                                $res = TopUpService::inputAmount($chatId, $text, $messageId);
-                                return $res;
-                                break;
+                                return TopUpService::inputAmount($chatId, $text, $messageId);
                             case StepStatus::INPUT_WITHDRAW_MONEY:
                                 $res = (new WithdrawService())->inputAmount($chatId, $text, $messageId);
                                 return $res[0];
-                                break;
-
                             case StepStatus::INPUT_ADDRESS_TRC20:
-                                $res = WithdrawService::inputAddress($chatId, $text, $messageId);
-                                return $res;
-                                break;
+                                return WithdrawService::inputAddress($chatId, $text, $messageId);
                             case StepStatus::INPUT_ADDRESS_ALIAS:
-                                $res = WithdrawService::inputAlias($chatId, $text, $messageId);
-                                return $res;
-                                break;
-
+                                return WithdrawService::inputAlias($chatId, $text, $messageId);
                         }
                         $returnMsg = BetService::bet($chatId, $text, $messageId);
-                    // $this->telegram->sendMessage($returnMsg);
                 }
 
                 return $returnMsg;
             }
         }
+        return [];
     }
 
     /**

app/Models/Message.php

@@ -2,6 +2,9 @@
 
 namespace App\Models;
 
+/**
+ * @property string $json
+ */
 class Message extends BaseModel
 {
     protected $table = 'messages';

app/Models/User.php

@@ -8,11 +8,13 @@ namespace App\Models;
  * @property string $username
  * @property string $first_name
  * @property string $language
+ * @property string $register_ip
+ * @property integer $status
  */
 class User extends BaseModel
 {
     protected $table = 'users';
-    protected $fillable = ['usdt', 'is_banned', 'admin_note', 'member_id', 'first_name', 'game_id', 'username', 'secret_key', 'secret_pass', 'language'];
+    protected $fillable = ['usdt', 'is_banned', 'register_ip', 'status', 'admin_note', 'member_id', 'first_name', 'game_id', 'username', 'secret_key', 'secret_pass', 'language'];
     protected $attributes = [
         'language' => 'zh',
     ];

app/Services/BalanceLogService.php

@@ -63,9 +63,9 @@ class BalanceLogService extends BaseService
     /**
      * @description: 分页查询
      * @param array $search
-     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
+     * @return array
      */
-    public static function paginate(array $search = [])
+    public static function paginate(array $search = []): array
     {
 
         $limit = isset($search['limit']) ? $search['limit'] : 15;

app/Services/TopUpService.php

@@ -98,11 +98,16 @@ class TopUpService
      * 充值图片
      * @param $chatId
      * @param $photo
+     * @return array
      * @throws TelegramSDKException
      */
-    public static function photo($chatId, $photo)
+    public static function photo($chatId, $photo): array
     {
-        $telegram = $telegram = new Api(config('services.telegram.token'));
+        try {
+            $telegram = new Api(config('services.telegram.token'));
+        } catch (TelegramSDKException $e) {
+            return [];
+        }
         $file = $telegram->getFile(['file_id' => $photo['file_id']]);
         $filePath = $file->getFilePath();
         $token = config('services.telegram.token');

app/Services/UserService.php

@@ -46,6 +46,11 @@ class UserService extends BaseService
         if (isset($search['id']) && !empty($search['id'])) {
             $where[] = ['id', '=', $search['id']];
         }
+
+        if(isset($search['register_ip']) && !empty($search['register_ip'])){
+            $where[] = ['register_ip', '=', $search['register_ip']];
+        }
+
         if (isset($search['game_id']) && !empty($search['game_id'])) {
             $where[] = ['game_id', '=', $search['game_id']];
         }

app/Services/WalletService.php

@@ -143,7 +143,13 @@ class WalletService extends BaseService
 
     }
 
-    // 新用户注册活动
+
+    /**
+     * 新用户注册活动
+     * @param $memberId
+     * @return void
+     * @throws TelegramSDKException
+     */
     public static function newUserRegisterActivity($memberId)
     {
         $start_date = '2025-12-23'; // 活动开始
@@ -152,24 +158,19 @@ class WalletService extends BaseService
         $date = date('Y-m-d');
         if($date >= $start_date && $date <= $end_date){
             $user = UserService::findOne(['member_id' => $memberId]);
+            $amount = 28;//活动金额
             // 有用户名的账号
             if($user && $user->getUsername()){
                 $wallets = self::findOne(['member_id' => $memberId]);
-                $amount = 28;   //活动金额
-
                 $before_balance = $wallets->available_balance;
                 $after_balance = $before_balance + $amount;
-
                 $wallets->available_balance = $after_balance;
                 $wallets->save();
                 BalanceLogService::addLog($memberId,$amount,$before_balance,$after_balance,'人工充值',0,'双旦活动注册赠送28');
                 $returnMsg = WalletService::getBalance($user->getMemberId());
-                try {
-                    $telegram = new Api(config('services.telegram.token'));
-                    $telegram->sendMessage($returnMsg);
-                } catch (TelegramSDKException $e) {
+                $telegram = new Api(config('services.telegram.token'));
+                $telegram->sendMessage($returnMsg);
 
-                }
             }
         }
         

database/migrations/2026_01_19_141856_update_users.php

@@ -0,0 +1,31 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::table('users', function (Blueprint $table) {
+            $table->string('register_ip')->default('')->comment('注册IP');
+            $table->tinyInteger('status')->default(0)->comment('状态，0正常，1异常');
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        //
+    }
+};