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 App\Services\Payment\ZimuPayService;
use Exception;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
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::INPUT_ADDRESS_ALIAS:
                $res = WithdrawService::inputAlias($chatId, $text, $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 (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";
        $text .= lang("别名") . "：{$address->alias}";

        $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
        ];
    }


    //输入别名
    public static function inputAlias($chatId, $alias, $messageId)
    {
        if (mb_strlen($alias) > 20) {
            return [
                'chat_id' => $chatId,
                'text' => lang("别名不能超过20个字，请重新输入"),
                'reply_to_message_id' => $messageId,
            ];
        }
        $address = Cache::get("{$chatId}_address");
        $a = new Address();
        $a->address = $address;
        $a->alias = $alias;
        $a->member_id = $chatId;
        $a->save();
        Cache::delete("{$chatId}_address");
        Cache::delete(get_step_key($chatId));
        return self::getAddress($chatId, $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,
            ];
        }
        Cache::put("{$chatId}_address", $address);
        Cache::put(get_step_key($chatId), StepStatus::INPUT_ADDRESS_ALIAS);
        return [
            'chat_id' => $chatId,
            'text' => lang("请输入地址别名，便于区分多个地址"),
        ];
    }

    //添加地址
    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->alias, '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;
        $activityUser = ActivityUserService::findOne(['member_id' => $chatId, 'status' => ActivityUser::STATUS_IN_PROGRESS]);
        if ($activityUser) {
            $text = lang("您有未完成的活动") . "\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}"],
                ]]])
            ];
        }


        $wallet = Wallet::where('member_id', $chatId)->first();
        $changeAmount = bcmul(($amount * -1), $rate, 2);
        $beforeBalance = $wallet->available_balance;
        $afterBalance = bcsub($wallet->available_balance, $rate_rmb_amount, 2);
        $wallet->available_balance = $afterBalance;
        $wallet->save();

        $withdraw = Withdraw::create([
            'member_id' => $chatId,
            'amount' => $amount,
            'service_charge' => $serviceCharge,
            'to_account' => $real,
            'address' => $address,
            'exchange_rate' => $rate,
            'status' => 0,
            'after_balance' => $afterBalance
        ]);


        BalanceLogService::addLog($chatId, $changeAmount, $beforeBalance, $afterBalance, '提现', $withdraw->id, '');
        $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->alias, '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 = WithdrawService::findOne(['id' => $id, 'status' => 0]);
        if (!$w) return 0;
        // 汇率
        $rate = $w->exchange_rate ?? 1;
        if ($status == 1 && ($w->channel ?? '') === ZimuPayService::CHANNEL_WITHDRAW) {
            $orderNo = $w->order_no ?: PaymentOrderService::createOrderNo('zw_', $w->member_id);
            $ret = ZimuPayService::withdraw($w->to_account, $orderNo, (string)$w->member_id, (string)$w->address);
            Log::channel('payment')->info('ZIMU钱包地址提现接口调用', [
                'withdraw_id' => $w->id,
                'order_no' => $orderNo,
                'member_id' => $w->member_id,
                'amount' => $w->to_account,
                'address' => $w->address,
                'response' => $ret,
            ]);
            if (($ret['code'] ?? -1) != 0) {
                throw new Exception($ret['msg'] ?? 'ZIMU钱包地址提现失败', HttpStatus::CUSTOM_ERROR);
            }

            $w->order_no = $orderNo;
            $w->pay_no = $ret['data']['orderNo'] ?? '';
            $w->pay_data = json_encode($ret, JSON_UNESCAPED_UNICODE);
            $w->status = 1;
            $w->save();
        } else if ($status == 1) {
            $w->status = 1;
            $w->save();
        } else if ($status == 2) {
            $rate_rmb_amount = bcmul($w->amount, $rate, 2);  // 提现金额 折合RMB
            $w->status = 2;

            $w->remark = $remark;
            $w->save();
            $wallet = WalletService::findOne(['member_id' => $w->member_id]);
            $afterBalance = bcadd($wallet->available_balance, $rate_rmb_amount, 10);
            BalanceLogService::addLog($w->member_id, $w->rate_rmb_amount, $wallet->available_balance, $afterBalance, '提现', $w->id, '');
            $wallet->available_balance = $afterBalance;
            $wallet->save();
        }

        $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 receiveZimuWithdraw(array $params): bool
    {
        $withdraw = Withdraw::where('order_no', $params['mchOrderNo'] ?? '')->first();
        if (!$withdraw || ($withdraw->channel ?? '') !== ZimuPayService::CHANNEL_WITHDRAW) {
            return false;
        }
        if (!ZimuPayService::verifyNotify($params)) {
            Log::error('ZIMU钱包地址提现回调验签失败', [
                'mch_order_no' => $params['mchOrderNo'] ?? '',
                'signature' => ZimuPayService::notifySignatureDiagnostics($params),
            ]);
            return false;
        }
        if (bccomp(ZimuPayService::amount($withdraw->to_account), ZimuPayService::amount($params['amount'] ?? 0), 2) !== 0) {
            Log::error('ZIMU钱包地址提现回调金额不一致', [
                'mch_order_no' => $params['mchOrderNo'] ?? '',
                'order_amount' => $withdraw->to_account,
                'callback_amount' => $params['amount'] ?? null,
            ]);
            return false;
        }

        DB::transaction(function () use ($params, $withdraw) {
            $order = Withdraw::where('id', $withdraw->id)->lockForUpdate()->first();
            if (!$order || $order->status == 2) {
                return;
            }

            $order->callback_data = json_encode($params, JSON_UNESCAPED_UNICODE);
            if ((string)$params['status'] === ZimuPayService::WITHDRAW_STATUS_SUCCESS) {
                $order->status = 1;
                $order->save();
            } elseif ((string)$params['status'] === ZimuPayService::WITHDRAW_STATUS_FAIL) {
                if ($order->status != 2) {
                    $order->status = 2;
                    $order->remark = $params['msg'] ?? 'ZIMU钱包地址提现失败';
                    $order->save();

                    $wallet = Wallet::where('member_id', $order->member_id)->lockForUpdate()->first();
                    if ($wallet) {
                        $refundAmount = bcmul($order->amount, $order->exchange_rate ?: 1, 2);
                        $beforeBalance = $wallet->available_balance;
                        $afterBalance = bcadd($beforeBalance, $refundAmount, 10);
                        $wallet->available_balance = $afterBalance;
                        $wallet->save();
                        BalanceLogService::addLog($order->member_id, $refundAmount, $beforeBalance, $afterBalance, '提现', $order->id, 'ZIMU钱包地址提现失败退款');
                    }
                }
            } else {
                $order->save();
            }
        }, 3);

        return true;
    }


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

    }
}