bot-28/app/Http/Controllers/admin/Wallet.php

<?php

namespace App\Http\Controllers\admin;

use App\Constants\HttpStatus;
use App\Http\Controllers\Controller;
use App\Models\Recharge;
use App\Services\BalanceLogService;
use App\Services\ManualAuditService;
use App\Services\WageringService;
use App\Services\MenuService;
use App\Services\RechargeService;
use App\Services\TopUpService;
use Exception;
use Illuminate\Support\Facades\Cache;

use Illuminate\Support\Facades\DB;
use Illuminate\Validation\ValidationException;
use App\Models\Wallet as WalletModel;
use App\Models\Withdraw;
use App\Models\Config;
use App\Models\PaymentOrder;
use App\Models\Order;
use App\Models\LhcOrder;
use App\Models\Bank;
use App\Models\Address;
use App\Services\Payment\QianBaoService;

class Wallet extends Controller
{

    /**
     * 获取提现通道
     */
    public function withdrawChannel()
    {
        $list = QianBaoService::withdrawChannel();
        $data[] = ['label' => 'USDT', 'value' => 'USDT'];
        foreach ($list as $key => $item) {
            $data[] = ['label' => $item, 'value' => $key];
        }
        return $this->success($data);
    }

    //银行卡/支付宝列表
    public function bankList()
    {
        try {
            $params = request()->validate([
                'channel' => 'nullable',
                'member_id' => 'nullable',
            ]);
            $where = [];
            if (!empty($params['channel'])) {
                $where[] = ['channel', '=', $params['channel']];
            }
            if (!empty($params['member_id'])) {
                $where[] = ['member_id', '=', $params['member_id']];
            }
            $list = Bank::where($where)->get()->toArray();

            return $this->success([
                'list' => $list,
            ]);
        } catch (\Exception $e) {
            return $this->error($e->getMessage());
        }
    }

    //地址列表
    public function address()
    {
        try {
            $params = request()->validate([
                'member_id' => 'nullable',
            ]);
            $where = [];
            if (!empty($params['member_id'])) {
                $where[] = ['member_id', '=', $params['member_id']];
            }
            $list = Address::where($where)->get()->toArray();

            return $this->success([
                'list' => $list,
            ]);
        } catch (\Exception $e) {
            return $this->error($e->getMessage());
        }
    }

    public function getChangeTypes()
    {
        return $this->success(BalanceLogService::$manualRecharge);
    }

    /**
     * @api {get} /admin/wallet/getPendingTasks 待处理任务
     * @apiDescription 后台每隔10秒，轮询请求这个接口获取待处理的任务数，如果有待处理的任务，则播放音乐
     * @apiGroup 充值管理
     * @apiUse result
     * @apiUse header
     * @apiVersion 1.0.0
     *
     * @apiSuccess (data) {Object} data
     * @apiSuccess (data) {int} data.recharge_task 待处理充值任务
     * @apiSuccess (data) {int} data.withdraw_task 待处理提现任务
     */
    function getPendingTasks()
    {
        $data = [
            'recharge_task' => 0,
            'withdraw_task' => 0,
            'rmb_withdraw_task' => 0,
        ];
        if (MenuService::checkMenu(request()->user->id, 'withdraw/topUp')) {
            $data['recharge_task'] = Recharge::where('type', 2)->where('status', 0)->count();
        }
        if (MenuService::checkMenu(request()->user->id, 'listUSDT')) {
            $data['withdraw_task'] = Withdraw::where('status', 0)->count();
        }
        if (MenuService::checkMenu(request()->user->id, 'listRMB')) {
            $data['rmb_withdraw_task'] = PaymentOrder::where('type', 2)->where('status', 0)->count();
        }
        return $this->success($data);
    }

    //扣款
    public function debiting()
    {
        DB::beginTransaction();
        try {
            request()->validate([
                'amount' => ['required', 'numeric', 'min:0.01'],
                'member_id' => ['required', 'string', 'min:1'],
                'remark' => ['required', 'string', 'min:1'],
                // 人工充值按平台倍数扣除打码量；其他类型扣除 wager_amount；不传不调整打码量
                'recharge_type' => ['nullable', 'string', 'in:' . implode(',', BalanceLogService::$manualRecharge)],
                'wager_amount' => ['nullable', 'numeric', 'min:0'],
            ]);
            $memberId = request()->input('member_id');
            $amount = request()->input('amount');
            [$wagerDelta, $writeWager] = ManualAuditService::wagerDelta(true, (string)$amount, ManualAuditService::DEBIT_CHANGE_TYPE,
                request()->input('recharge_type'), request()->filled('wager_amount') ? (string)request()->input('wager_amount') : null);
            $amount = $amount * -1;
            $remark = request()->input('remark');
            $key = 'api_request_' . md5($memberId . json_encode([
                        'amount' => $amount,
                        'remark' => $remark,
                        'action' => "wallet/debiting"
                    ]));
            if (Cache::has($key)) throw new Exception("请求太频繁，请稍后再试。", HttpStatus::CUSTOM_ERROR);
            Cache::put($key, true, 3);
            $wallet = WalletModel::where('member_id', $memberId)->lockForUpdate()->first();
            if (!$wallet) throw new Exception('用户不存在', HttpStatus::CUSTOM_ERROR);
            $beforeBalance = (string)$wallet->available_balance;
            $availableBalance = bcadd($beforeBalance, $amount, 10);
            if ($availableBalance < 0) throw new Exception('可用余额不足', HttpStatus::CUSTOM_ERROR);
            $wallet->available_balance = $availableBalance;
            $wallet->save();
            $log = BalanceLogService::addLog($memberId, $amount, $beforeBalance, $availableBalance, "人工扣款", null, $remark);
            if ($writeWager) {
                WageringService::addRequirement($wallet, $wagerDelta, 'manual_debit', 'balance_log:' . $log->id, $remark, (int)request()->user->id);
            }

            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }
        $availableBalance = floatval($availableBalance);
        // 去除多余0后，再用 sprintf 补足两位
        $availableBalance = sprintf('%.2f', $availableBalance);
        TopUpService::notifyTransferSuccess($memberId, "您的账户余额更新：" . ($amount > 0 ? '+' : '') . "{$amount} \n总余额为：{$availableBalance}");
        return $this->success();
    }

    //会员账号充值
    public function topUp()
    {
        DB::beginTransaction();
        try {
            request()->validate([
                'amount' => ['required', 'numeric', 'min:0.01'],
                'member_id' => ['required', 'string', 'min:1'],
                'remark' => ['required', 'string', 'min:1'],
                'change_type' => ['required', 'string', 'in:' . implode(',', BalanceLogService::$manualRecharge)],
                // 人工充值按平台倍数自动计算；其他类型自行填写，留空为0
                'wager_amount' => ['nullable', 'numeric', 'min:0'],
            ]);
            $memberId = request()->input('member_id');
            $amount = request()->input('amount');
            $remark = request()->input('remark');
            $changeType = request()->input('change_type');
            [$wagerDelta, $writeWager] = ManualAuditService::wagerDelta(false, (string)$amount, (string)$changeType, null,
                request()->filled('wager_amount') ? (string)request()->input('wager_amount') : null);
            $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)->lockForUpdate()->first();
            if (!$wallet) throw new Exception('用户不存在', HttpStatus::CUSTOM_ERROR);
            $beforeBalance = (string)$wallet->available_balance;
            $availableBalance = bcadd($beforeBalance, $amount, 10);
            // 先保存余额再写日志：充值钩子（首充奖励、即充即送、打码量）会重新锁定并更新钱包
            $wallet->available_balance = $availableBalance;
            $wallet->save();
            $log = BalanceLogService::addLog($memberId, $amount, $beforeBalance, $availableBalance, $changeType, null, $remark);
            if ($writeWager) {
                $wallet = WalletModel::where('member_id', $memberId)->lockForUpdate()->first();
                WageringService::addRequirement($wallet, $wagerDelta, 'manual_credit', 'balance_log:' . $log->id, $remark, (int)request()->user->id);
            }

            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }

        $availableBalance = floatval($availableBalance);
        // 去除多余0后，再用 sprintf 补足两位
        $availableBalance = sprintf('%.2f', $availableBalance);
        TopUpService::notifyTransferSuccess($memberId, "您的账户余额更新：" . ($amount > 0 ? '+' : '') . "{$amount} \n总余额为：{$availableBalance}");
        return $this->success();
    }

    //订单充值
    public function orderTopUp()
    {
        DB::beginTransaction();
        try {
            request()->validate([
                'amount' => ['required', 'numeric', 'min:0.01'],
                'remark' => ['required', 'string', 'min:1'],
                'order_type' => ['nullable'],
                'order_id' => ['nullable'],
            ]);
            $order_type = request()->input('order_type');
            $order_id = request()->input('order_id');
            $amount = request()->input('amount');
            $remark = request()->input('remark');
            // 订单补偿单独记类型：不算充值（等级、首充、返现等），报表仍计入人工加款
            $changeType = "订单补偿";
            $key = 'api_request_' . md5($order_id . json_encode([
                        'amount' => $amount,
                        'remark' => $remark,
                        'action' => "wallet/orderTopUp"
                    ]));
            if (Cache::has($key)) throw new Exception("请求太频繁，请稍后再试。", HttpStatus::CUSTOM_ERROR);
            Cache::put($key, true, 3);

            if ($order_type == 'sport') {
                $info = Order::where('id', $order_id)->first();
            } elseif ($order_type == 'lhc') {
                $info = LhcOrder::where('id', $order_id)->first();
            }
            if (!$info) {
                throw new \Exception('订单不存在');
            } else {
                $info->remark = $info->remark ? $info->remark. '|' . $remark : $remark;
                $info->save();
            }
            $memberId = $order_type == 'sport' ? $info->user_id : $info->member_id;

            $wallet = WalletModel::where('member_id', $memberId)->first();
            if (!$wallet) throw new Exception('用户不存在', HttpStatus::CUSTOM_ERROR);
            $availableBalance = bcadd($wallet->available_balance, $amount, 10);
            BalanceLogService::addLog($memberId, $amount, $wallet->available_balance, $availableBalance, $changeType, null, $remark);
            $wallet->available_balance = $availableBalance;
            $wallet->save();

            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }

        return $this->success();
    }

    //订单扣款
    public function orderDebiting()
    {
        DB::beginTransaction();
        try {
            request()->validate([
                'amount' => ['required', 'numeric', 'min:0.01'],
                'remark' => ['required', 'string', 'min:1'],
                'order_type' => ['required'],
                'order_id' => ['required'],
            ]);
            $order_type = request()->input('order_type');
            $order_id = request()->input('order_id');
            $amount = request()->input('amount');
            $amount = $amount * -1;
            $remark = request()->input('remark');
            $key = 'api_request_' . md5($order_id . json_encode([
                        'amount' => $amount,
                        'remark' => $remark,
                        'action' => "wallet/orderDebiting"
                    ]));
            if (Cache::has($key)) throw new Exception("请求太频繁，请稍后再试。", HttpStatus::CUSTOM_ERROR);
            Cache::put($key, true, 3);

            if ($order_type == 'sport') {
                $info = Order::where('id', $order_id)->first();
            } elseif ($order_type == 'lhc') {
                $info = LhcOrder::where('id', $order_id)->first();
            }
            if (!$info) {
                throw new \Exception('订单不存在');
            } else {
                $info->remark = $info->remark ? $info->remark. '|' . $remark : $remark;
                $info->save();
            }
            $memberId = $order_type == 'sport' ? $info->user_id : $info->member_id;

            $wallet = WalletModel::where('member_id', $memberId)->first();
            if (!$wallet) throw new Exception('用户不存在', HttpStatus::CUSTOM_ERROR);
            $availableBalance = bcadd($wallet->available_balance, $amount, 10);
            if ($availableBalance < 0) throw new Exception('可用余额不足', HttpStatus::CUSTOM_ERROR);
            BalanceLogService::addLog($memberId, $amount, $wallet->available_balance, $availableBalance, "人工扣款", null, $remark);
            $wallet->available_balance = $availableBalance;
            $wallet->save();

            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }
        return $this->success();
    }

    /**
     * @api {post} /admin/wallet/verifyRecharge 审核
     * @apiGroup 充值管理
     * @apiUse result
     * @apiUse header
     * @apiVersion 1.0.0
     * @apiParam {int} id 充值表的ID
     * @apiParam {int} status 状态
     * - 1 通过
     * - 2 拒绝
     * @apiParam {string} [remark] 说明
     * - 当status =2 时，此参数必填
     */
    public
    function verifyRecharge()
    {
        DB::beginTransaction();
        try {
            request()->validate([
                'id' => ['required', 'integer', 'min:1'],
                'status' => ['required', 'integer', 'in:1,2'],
                'remark' => ['required_if:status,2', 'string', 'min:1']
            ]);
            $id = request()->input('id');
            $status = request()->input('status');
            $remark = request()->input('remark', '');
            $recharge = Recharge::where('id', $id)
                ->where('type', 2)
                ->where('status', 0)->lockForUpdate()->first();
            if (!$recharge) throw new Exception("数据不存在", HttpStatus::CUSTOM_ERROR);
            $amount = floatval($recharge->amount);
            if ($status == 2) {
                $recharge->status = 2;
                $recharge->save();
                $text = "充值结果通知\n";
                $text .= "充值数量：{$amount} USDT\n";
                $text .= "充值地址：{$recharge->to_address}\n";
                $text .= "状态：失败\n";
                $text .= "原因：{$remark}\n";
                TopUpService::notifyTransferSuccess($recharge->member_id, $text);
            } else {
                // 汇率
                $rate = Config::where('field', 'exchange_rate_rmb')->first()->val ?? 1;
                $recharge->status = 1;
                $recharge->exchange_rate = $rate;
                $recharge->save();
                $wallet = WalletModel::where('member_id', $recharge->member_id)
                    ->lockForUpdate()->first();
                $rate_amount = bcmul($amount, $rate, 10); // 汇率转换后分数
                $available_balance = bcadd($wallet->available_balance, $rate_amount, 10);

                $beforeBalance = (string)$wallet->available_balance;
                $wallet->available_balance = $available_balance;
                $wallet->save();
                $principal = BalanceLogService::addLog($recharge->member_id, $rate_amount, $beforeBalance, $available_balance, "充值", $recharge->id, "用户充值后台审核到账");
                \App\Services\RechargeBonusService::grant('recharge', $recharge, $principal);

                $text = "充值结果通知\n";
                $text .= "充值数量：{$amount} USDT\n";
                $text .= "充值地址：{$recharge->to_address}\n";
                $text .= "汇率：1 USDT = {$rate} RMB\n";
                $text .= "折合金额：" . number_format($rate_amount, 2) . " RMB\n";
                $text .= "状态：成功\n";
                TopUpService::notifyTransferSuccess($recharge->member_id, $text);
            }
            DB::commit();
        } catch (ValidationException $e) {
            DB::rollBack();
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            DB::rollBack();
            return $this->error(intval($e->getCode()), $e->getMessage());
        }
        return $this->success();
    }

    /**
     * @api {get} /admin/wallet 充值列表
     * @apiGroup 充值管理
     * @apiDescription 如果列表的type=2 并且 status = 0 <br/>那么代表这条数据是需要后台手动审核的
     * 需要有审核按钮，审核通过或者拒绝，其它情况则不需要审核按钮
     *
     * @apiUse result
     * @apiUse header
     * @apiVersion 1.0.0
     *
     * @apiParam {int} [page=1]
     * @apiParam {int} [limit=10]
     * @apiParam {string} [member_id] 房主 tg会员ID
     * @apiParam {int} [status] 状态
     * - 0 待确认
     * - 1 已确认
     * - 2 失败
     * - 3 已忽略
     * @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.net 链接类型
     * @apiSuccess (data) {string} data.data.coin 币种
     * @apiSuccess (data) {string} data.data.amount 充值数量
     * @apiSuccess (data) {string} data.data.to_address 充值地址（平台地址）
     * @apiSuccess (data) {string} data.data.from_address 转出地址（用户发起地址）
     * @apiSuccess (data) {string} data.data.txid 链上交易哈希
     * @apiSuccess (data) {string} data.data.block_time 区块时间
     * @apiSuccess (data) {string} data.data.block_height
     * @apiSuccess (data) {int} data.data.confirmations 确认数
     * @apiSuccess (data) {string} data.data.updated_at
     * @apiSuccess (data) {string} data.data.created_at
     * @apiSuccess (data) {int} data.data.status 状态
     * - 0 待确认
     * - 1 已确认
     * - 2 失败
     * - 3 已忽略
     * @apiSuccess (data) {int} data.data.type 充值类型
     * - 1 自动
     * - 2 手动
     * @apiSuccess (data) {string} data.data.image 充值转账凭证图片
     */
    public
    function index()
    {
        try {
            request()->validate([
                'member_id' => ['nullable', 'string', 'min:1'],
                'status' => ['nullable', 'string', 'min:0', 'max:3'],
                'type' => ['nullable', 'integer', 'in:1,2'],
                'account' => ['nullable', 'string', 'max:64'],
                'first_name' => ['nullable'],
            ]);
            $search = request()->all();
            $result = RechargeService::paginate($search);
            foreach($result['data'] as &$item) {
                if ($item['from'] == 2) {
                    $item['image'] = str_replace(config('app.url'), config('app.football_url').'/', $item['image']);
                }
            }
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(intval($e->getCode()));
        }
        return $this->success($result);
    }

}