bot-28/app/Services/WithdrawService.php

<?php


namespace App\Services;


use App\Constants\HttpStatus;
use App\Constants\StepStatus;
use App\Models\ActivityUser;
use App\Models\Address;
use App\Models\BalanceLog;
use App\Models\Bank;
use App\Models\Config;
use App\Models\RoomUser;
use App\Models\User;
use App\Models\Wallet;
use App\Models\Withdraw;
use Exception;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use LaravelLang\Publisher\Console\Add;
use Telegram\Bot\Api;
use Telegram\Bot\Exceptions\TelegramSDKException;

class WithdrawService
{
    public $serviceCharge;

    public static function init(Api $telegram, $data, $chatId, $firstName, $messageId): void
    {


        switch ($data) {
            case "withdraw@@address"://地址管理
                $res = WithdrawService::getAddress($chatId, $messageId);
                $telegram->editMessageText($res);
                break;
            case "withdrawAddress@@done":
                $res = WithdrawService::done($chatId, $messageId, $firstName);
                $telegram->editMessageText($res);
                break;
            case "withdraw@@bill"://点击提现的账单按钮
                $res = WithdrawService::bill($chatId, $firstName, $messageId);
                $telegram->editMessageText($res);
                break;
            case "withdrawAddress@@add":
                $res = WithdrawService::addAddress($chatId, $messageId);
                $telegram->editMessageText($res);
                break;
            case "withdraw@@apply"://点击提现按钮
                $res = WithdrawService::apply($chatId, $messageId);
                $telegram->editMessageText($res);
                break;
            default:
                //选择提现地址
                $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 = WithdrawService::bill($chatId, $firstName, $messageId, $page);
                    $telegram->editMessageText($res);
                }
                break;

        }

    }


    public static function onMessage($chatId, $text, $messageId, $stepStatus)
    {
        switch ($stepStatus) {
            case StepStatus::INPUT_WITHDRAW_MONEY:
                $res = WithdrawService::inputAmount($chatId, $text, $messageId);
                $res = $res[0];
                break;
            case StepStatus::INPUT_ADDRESS_TRC20:
                $res = WithdrawService::inputAddress($chatId, $text, $messageId);
                break;
            case StepStatus::LEGACY_INPUT_ADDRESS_ALIAS:
                $address = Cache::get("{$chatId}_address");
                $res = is_string($address) && $address !== ''
                    ? self::inputAddress($chatId, $address, $messageId)
                    : self::addAddress($chatId, $messageId);
                break;
            default:
                $res = null;
                break;
        }
        return $res;
    }


    public static function model(): string
    {
        return Withdraw::class;
    }

    public static function enum(): string
    {
        return '';
    }

    public static function getWhere(array $search = []): array
    {
        $where = [];
        if (isset($search['id']) && !empty($search['id'])) {
            $where[] = ['withdraws.id', '=', $search['id']];
        }


        if (isset($search['member_id']) && !empty($search['member_id'])) {
            $where[] = ['withdraws.member_id', '=', $search['member_id']];
        }
        if (isset($search['status']) && $search['status'] != '') {
            $where[] = ['withdraws.status', '=', $search['status']];
        }
        if (!empty($search['account'])) {
            $where[] = ['users.account', 'like', '%' . trim((string)$search['account']) . '%'];
        }
        if (isset($search['first_name']) && !empty($search['first_name'])) {
            $where[] = ['users.first_name', 'like', "%" . $search['first_name'] . "%"];
        }
        return $where;
    }

    public static function findOne(array $search): ?Withdraw
    {
        return self::model()::where(self::getWhere($search))->first();
    }

    public static function findAll(array $search = [])
    {
        return self::model()::where(self::getWhere($search))->get();
    }

    public static function paginate(array $search = [])
    {
        $limit = isset($search['limit']) ? $search['limit'] : 10;
        $paginator = self::model()::where(self::getWhere($search))
            ->orderBy('created_at', 'desc')->paginate($limit);
        return ['total' => $paginator->total(), 'data' => $paginator->items()];
    }


    public function __construct()
    {
        $serviceCharge = Config::where('field', 'service_charge')->first()->val;
        $serviceCharge = floatval($serviceCharge);
        $this->serviceCharge = $serviceCharge;
    }

    public static function getServiceCharge(): float
    {
        $serviceCharge = Config::where('field', 'service_charge')->first()->val;
        return floatval($serviceCharge);
    }

    public static function notify($data)
    {
        try {
            $telegram = new Api(config('services.telegram.token'));
            $telegram->sendMessage($data);
        } catch (TelegramSDKException $e) {
            return false;
        }
        return true;
    }


    //提现账单
    public static function bill($chatId, $firstName, $messageId = null, $page = 1, $limit = 5)
    {
        $list = Withdraw::where('member_id', $chatId)
            ->orderBy('id', 'desc')
            ->forPage($page, $limit)
            ->get();


        $count = Withdraw::where('member_id', $chatId)
            ->whereIn('status', [0, 1])
            ->count();

        $status = [lang('等待放行'), lang('已到账'), lang("失败")];
        $text = "👤 {$firstName}({$chatId})    " . lang("钱包提现记录") . "\n\n";

        foreach ($list as $item) {
            $amount = floatval($item->amount);
            $balance = floatval($item->after_balance);
            $text .= "-------------------------------------\n";
            $text .= "➖ {$amount} USDT\n" . lang("余额") . "：{$balance} \n";
            $text .= lang("类别") . "类别：" . lang("提现") . "\n";
            $text .= lang("状态") . "：{$status[$item->status]}\n";
            if ($item->remark) {
                $text .= lang("说明") . "：{$item->remark}\n";
            }
            $text .= lang("日期") . "：{$item->created_at}\n";
        }

        if ($page > 1) {
            $keyboard[] = [
                ['text' => lang("👆上一页"), 'callback_data' => "withdrawBillNextPage@@" . ($page - 1)]
            ];
        }
        $allPage = ceil($count / $limit);
        if ($allPage > $page) {
            if ($page > 1) {
                $keyboard[count($keyboard) - 1][] = ['text' => lang("👇下一页"), 'callback_data' => "withdrawBillNextPage@@" . ($page + 1)];
            } else {
                $keyboard[] = [
                    ['text' => lang("👇下一页"), 'callback_data' => "withdrawBillNextPage@@" . ($page + 1)]
                ];
            }
        }

        $keyboard[] = [
            ['text' => lang("↩️返回"), 'callback_data' => "withdraw@@home"]
        ];
        return [
            'chat_id' => $chatId,
            'text' => $text,
            'message_id' => $messageId,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
        ];
    }


    //删除地址
    public static function delAddress($chatId, $id, $messageId)
    {
        Address::where('id', $id)
            ->where('member_id', $chatId)->delete();
        return WithdrawService::getAddress($chatId, $messageId);
    }

    //地址详情
    public static function addressDetails($chatId, $messageId, $id)
    {
        $text = lang("*TRC20 地址管理*") . "\n\n";
        $address = Address::where('id', $id)
            ->where('member_id', $chatId)->first();
        $text .= lang("地址") . "：{$address->address}\n";

        $keyboard = [
            [['text' => lang('❌删除该地址'), 'callback_data' => "withdrawAddress@@del{$id}"]],
            [['text' => lang('↩️返回列表'), 'callback_data' => 'withdraw@@address']]
        ];
        return [
            'chat_id' => $chatId,
            'parse_mode' => 'MarkdownV2',
            'text' => $text,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard]),
            'message_id' => $messageId
        ];
    }


    //用户输入TRC20地址
    public static function inputAddress($chatId, $address, $messageId)
    {
        if (!preg_match('/^T[a-zA-Z1-9]{33}$/', $address)) {
            return [
                'chat_id' => $chatId,
                'text' => lang("地址输入不正确，请重新输入TRC20地址"),
                'reply_to_message_id' => $messageId,
            ];
        }
        Address::create(['member_id' => $chatId, 'address' => $address]);
        Cache::delete("{$chatId}_address");
        Cache::delete(get_step_key($chatId));

        return self::getAddress($chatId, $messageId);
    }

    //添加地址
    public static function addAddress($chatId, $messageId)
    {
        $text = lang('请输入新的TRC20地址') . "\n";
        $keyboard = [[
            ['text' => lang('❌取消'), 'callback_data' => "message@@close"],
        ]];
        Cache::put(get_step_key($chatId), StepStatus::INPUT_ADDRESS_TRC20);
        return [
            'chat_id' => $chatId,
            'text' => $text,
            'message_id' => $messageId,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
        ];
    }


    //地址管理
    public static function getAddress($chatId, $messageId)
    {
        $text = lang("🏠 地址管理");
        $text .= "\n--------------------------\n";

        $list = Address::where('member_id', $chatId)
            ->get();

        $keyboard = [];
        foreach ($list as $item) {
            $keyboard[] = [['text' => $item->address, 'callback_data' => "withdrawAddress@@detail{$item->id}"]];
        }
        if (count($list) < 5) {
            $keyboard[] = [['text' => lang("➕ 添加地址"), 'callback_data' => "withdrawAddress@@add"]];
        }
        $keyboard[] = [['text' => lang("↩️返回"), 'callback_data' => "withdraw@@home"]];
        return [
            'chat_id' => $chatId,
            'text' => $text,
            'message_id' => $messageId,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
        ];
    }

    public static function done($chatId, $messageId, $firstName)
    {
        $serviceAccount = Config::where('field', 'service_customer')->first()->val;
        $wagerLeft = WageringService::remainingFor((string)$chatId);
        if ($wagerLeft !== null) {
            $text = lang("打码量未完成，剩余打码量") . "：{$wagerLeft}\n";
            $text .= lang("任何疑问都可以联系唯一客服") . "：@{$serviceAccount}";
            return [
                'chat_id' => $chatId,
                'text' => $text,
                'message_id' => $messageId,
            ];
        }


        $serviceCharge = (new WithdrawService())->serviceCharge;
        $amount = Cache::get("{$chatId}_WITHDRAW_MONEY", '');
        $address = Cache::get("{$chatId}_WITHDRAW_ADDRESS", '');
        if (!$amount || !$address) return WithdrawService::index($chatId, $firstName, $messageId);
        $real = bcsub($amount, $serviceCharge, 10);
        $real = floatval($real);

        if ($amount <= $serviceCharge) {
            return [
                'chat_id' => $chatId,
                'text' => lang("⚠️提现不能少于") . "{$serviceCharge} USDT，" . lang("请重试"),
                'message_id' => $messageId
            ];
        }

        $wallet = Wallet::where('member_id', $chatId)->first();
        $temp = floatval($wallet->available_balance);
        // 汇率
        $rate = Config::where('field', 'exchange_rate_rmb')->first()->val ?? 1;
        $exchange_rate_difference = Config::where('field', 'exchange_rate_difference')->first()->val ?? 0;
        $rate = bcadd($rate, $exchange_rate_difference, 2);

        $rate_usdt_amount = bcdiv($temp, $rate, 2);  // 钱包可用余额 折合USDT

        $rate_rmb_amount = bcmul($amount, $rate, 2);  // 提现金额 折合RMB
        if ($amount > $rate_usdt_amount) {
            return [
                'chat_id' => $chatId,
                'text' => lang("⚠️可用余额不足，请重试"),
                'message_id' => $messageId
            ];
        }


        $ru = RoomUser::where('member_id', $chatId)
            ->whereIn('status', [0, 1, 2, 3])
            ->first();
        if ($ru) {
            $text = lang("游戏未结算") . "\n";
            $text .= "⚠️ " . lang("您还有进行中的游戏，所有游戏结算后方可提现") . "\n";
            return [
                'chat_id' => $chatId,
                'text' => $text,
                'message_id' => $messageId,
                'reply_markup' => json_encode(['inline_keyboard' => [[
                    ['text' => lang('进入房间'), 'callback_data' => "games@@home{$ru->room_id}"],
                ]]])
            ];
        }


        // 校验打码量 → 可用余额转入冻结余额 → 创建提现单 → 重置打码周期
        try {
            [, $wallet] = WithdrawFundsService::hold((string)$chatId, $rate_rmb_amount, '提现', '', WithdrawFundsService::WITHDRAWS,
                fn ($before, $after) => Withdraw::create([
                    'member_id' => $chatId,
                    'amount' => $amount,
                    'service_charge' => $serviceCharge,
                    'to_account' => $real,
                    'address' => $address,
                    'exchange_rate' => $rate,
                    'status' => 0,
                    'after_balance' => $after,
                ]));
        } catch (\Exception $e) {
            if ($e->getCode() !== HttpStatus::CUSTOM_ERROR) LogService::error($e);
            return [
                'chat_id' => $chatId,
                'text' => '⚠️' . ($e->getCode() === HttpStatus::CUSTOM_ERROR ? $e->getMessage() : lang('系统繁忙，请稍后重试！')),
                'message_id' => $messageId,
            ];
        }
        $afterBalance = $wallet->available_balance;
        $temp = floatval($afterBalance);
        $text = "✅ " . lang("提现申请已提交！") . "\n\n";
        $text .= lang("钱包余额") . "：{$temp} RMB\n";
        $text .= lang("汇率") . "：1 USDT = {$rate} RMB\n";
        $text .= lang("剩余可用USDT余额") . "：" . number_format(bcdiv($temp, $rate, 2), 2) . " USDT\n";
        $text .= lang("提现金额") . "：{$amount} USDT\n";
        $text .= lang("实际到账") . "：{$real} USDT\n";
        $text .= lang("手续费") . "：{$serviceCharge} USDT\n\n";
        $text .= lang("⌛️请等待系统处理, 到账时间可能需要几分钟!") . "\n";
        Cache::delete(get_step_key($chatId));
        return [
            'chat_id' => $chatId,
            'text' => $text,
            'message_id' => $messageId,
        ];
    }


    public static function chooseAddress($chatId, $firstName, $messageId, $id)
    {
        $serviceCharge = (new WithdrawService())->serviceCharge;
        $amount = Cache::get("{$chatId}_WITHDRAW_MONEY", '');
        if (!$amount) return WithdrawService::index($chatId, $firstName, $messageId);
        $amount = floatval($amount);
        $real = bcsub($amount, $serviceCharge, 10);
        $real = floatval($real);
        $address = Address::where('id', $id)
            ->where('member_id', $chatId)->first();


        $text = lang("请确认") . "\n\n";
        $text .= lang('手续费') . "：{$serviceCharge} USDT\n";
        $text .= lang("提现金额") . "：{$amount} USDT\n";
        $text .= lang("实际到账") . "：{$real} USDT\n";
        $text .= lang("提现地址") . "：{$address->address}\n";

        $keyboard = [
            [
                ['text' => lang('✅ 确认'), 'callback_data' => "withdrawAddress@@done"],
            ],
            [
                ['text' => lang('❌取消'), 'callback_data' => "message@@close"]
            ]
        ];
        Cache::put("{$chatId}_WITHDRAW_ADDRESS", $address->address);
        return [
            'chat_id' => $chatId,
            'text' => $text,
            'message_id' => $messageId,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
        ];
    }


    //用户输入提现金额(USDT)
    public static function inputAmount($chatId, $amount, $messageId)
    {
        if (!preg_match('/^-?\d+(\.\d+)?$/', $amount)) {
            return [[
                'chat_id' => $chatId,
                'text' => lang("金额输入不正确，请发送提现数字"),
                'reply_to_message_id' => $messageId
            ]];
        }
        if ($amount < 20) {
            return [[
                'chat_id' => $chatId,
                'text' => lang("提现不能少于20 USDT，请重试"),
                'reply_to_message_id' => $messageId
            ]];
        }

        $wallet = Wallet::where('member_id', $chatId)->first();
        $temp = floatval($wallet->available_balance);
        // 汇率
        $rate = Config::where('field', 'exchange_rate_rmb')->first()->val ?? 1;
        $rate_amount = bcdiv($temp, $rate, 2);
        $serviceCharge = Config::where('field', 'service_charge')->first()->val;
        $serviceCharge = floatval($serviceCharge);
        if ($amount <= $serviceCharge) {
            return [[
                'chat_id' => $chatId,
                'text' => lang("⚠️提现不能少于") . "{$serviceCharge} USDT，" . lang('请重试'),
                'reply_to_message_id' => $messageId
            ]];
        }
        if ($amount > $rate_amount) {
            return [[
                'chat_id' => $chatId,
                'text' => lang("可用余额不足，请重试"),
                'reply_to_message_id' => $messageId
            ]];
        }
        $ru = RoomUser::where('member_id', $chatId)
            ->whereIn('status', [0, 1, 2, 3])
            ->first();
        if ($ru) {
            $text = lang('*游戏未结算*') . "\n";
            $text .= lang("⚠️ 您还有进行中的游戏，所有游戏结算后方可提现") . "\n";
            return [[
                'chat_id' => $chatId,
                'text' => $text,
                'parse_mode' => 'MarkdownV2',
                'reply_markup' => json_encode(['inline_keyboard' => [[
                    ['text' => lang('进入房间'), 'callback_data' => "games@@home{$ru->room_id}"],
                ]]])
            ]];
        }


        $list = Address::where('member_id', $chatId)->get();
        $keyboard = [];
        foreach ($list as $item) {
            $keyboard[] = [['text' => $item->address, 'callback_data' => "withdrawAddress@@choose{$item->id}"]];
        }
        $keyboard[] = [
            ['text' => lang("🏠 地址管理"), 'callback_data' => "withdraw@@address"],
            ['text' => lang('❌取消'), 'callback_data' => "message@@close"]
        ];

        $text = lang('请直接选择下面的地址') . "\n";
        $text .= lang("⚠️提示：请务必确认提现地址正确无误，\n否则资金丢失将无法找回请自负！");
        Cache::put("{$chatId}_WITHDRAW_MONEY", $amount);
        Cache::put(get_step_key($chatId), StepStatus::CHOOSE_WITHDRAW_ADDRESS);
        return [[
            'chat_id' => $chatId,
            'text' => $text,
            'reply_to_message_id' => $messageId,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
        ]];
    }


    //申请提现
    public static function apply($chatId, $messageId)
    {
        $wallet = Wallet::where('member_id', $chatId)->first();
        // 汇率
        $rate = Config::where('field', 'exchange_rate_rmb')->first()->val ?? 1;
        $exchange_rate_difference = Config::where('field', 'exchange_rate_difference')->first()->val ?? 0;
        $rate = bcadd($rate, $exchange_rate_difference, 2);
        $temp = floatval($wallet->available_balance);
        $amount = bcdiv($temp, $rate, 2);
        $serviceCharge = static::getServiceCharge();
        $text = lang("请发送提现金额");
        $text .= " (USDT)";
        $text .= "\n💰 " . lang('当前余额') . "：{$temp} RMB  ({$amount} USDT)\n";
        $text .= "⚠️" . lang('汇率') . "：1 USDT = {$rate} RMB\n";
        $text .= "⚠️ " . lang('提现将收取') . "{$serviceCharge}" . lang('U作为手续费') . "\n";
//        $keyboard = [[
//            ['text' => "🔙返回", 'callback_data' => "withdraw@@home"],
//        ]];
        Cache::put(get_step_key($chatId), StepStatus::INPUT_WITHDRAW_MONEY);
        return [
            'chat_id' => $chatId,
            'text' => $text,
            'message_id' => $messageId,
//            'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
        ];
    }

    //提现管理
    public static function index($chatId, $firstName, $messageId = null)
    {
        $wallet = Wallet::where('member_id', $chatId)->first();
        $text = "👤 {$firstName}({$chatId})\n\n";
        $text .= "💰钱包余额\n";
        $temp = floatval($wallet->available_balance);
        $text .= "USDT：{$temp}\n";
        $text .= "--------------------------\n";
        $serviceAccount = Config::where('field', 'service_account')->first()->val;
        $keyboard = [
            [
                ['text' => '➕ 提现', 'callback_data' => "withdraw@@apply"],
                ['text' => '🧾 账单', 'callback_data' => "withdraw@@bill"]
            ],
            [
                ['text' => lang("🏠 地址管理"), 'callback_data' => "withdraw@@address"],
                ['text' => lang('👩 客服帮助'), 'url' => "https://t.me/{$serviceAccount}"]
            ],
            [
                ['text' => lang('❌取消'), 'callback_data' => "message@@close"],
            ]
        ];

        return [
            'chat_id' => $chatId,
            'text' => $text,
            'message_id' => $messageId,
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard])
        ];
    }


    public static function setStatus($id, $status, $remark)
    {
        $w = DB::transaction(function () use ($id, $status, $remark) {
            $w = Withdraw::where('id', $id)->where('status', 0)->lockForUpdate()->first();
            if (!$w) return null;
            // 汇率
            $rate = $w->exchange_rate ?? 1;
            if ($status == 1) {
                $w->status = 1;
                $w->save();
                // 提现成功：扣除冻结余额
                WithdrawFundsService::settle(WithdrawFundsService::WITHDRAWS, $w);
            } else if ($status == 2) {
                $rate_rmb_amount = bcmul($w->amount, $rate, 2);  // 提现金额 折合RMB（旧单退回金额）
                $w->status = 2;
                $w->remark = $remark;
                $w->save();
                // 审核拒绝：冻结余额退回可用余额
                WithdrawFundsService::release(WithdrawFundsService::WITHDRAWS, $w, $rate_rmb_amount, '提现', '');
            }
            return $w;
        }, 3);
        if (!$w) return 0;

        $arr = ['⏳️申请中', '✅️成功', '❌️失败'];
        $text = "📢 提现结果通知\n\n";

        $temp = floatval($w->service_charge);
        $text .= "手续费：{$temp} USDT\n";
        $temp = floatval($w->amount);
        $text .= "提现金额：{$temp} USDT\n";
        $temp = floatval($w->to_account);
        $text .= "到账金额：{$temp} USDT\n";
        $text .= "提现地址：{$w->address}\n\n";
        $text .= "状态：{$arr[$w->status]}\n";
        if ($w->remark) $text .= "说明：{$w->remark}";
        WithdrawService::notify([
            'chat_id' => $w->member_id,
            'text' => $text,
        ]);
        return 1;
    }


    public static function batchReject()
    {
        $list = Withdraw::where('status', 0)->get();
        foreach ($list as $k => $v) {
            WithdrawService::setStatus($v->id, 2, '赠送彩金，提现需满足活动需求，提现只允许走rmb渠道');
        }

    }
}