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

<?php


namespace App\Http\Controllers\admin;

use App\Constants\HttpStatus;
use App\Http\Controllers\Controller;
use App\Services\PaymentOrderService;
use Exception;
use Illuminate\Support\Facades\DB;
use Illuminate\Validation\ValidationException;
use App\Models\Agent\AgentWithdrawal;
use App\Models\PaymentOrder as PaymentOrderModel;
use App\Models\Wallet;
use App\Models\Recharge;
use App\Models\Withdraw;
use App\Services\BalanceLogService;
use App\Services\AdminRealtime\AdminRealtime;

class PaymentOrder extends Controller
{

    //统计后台待处理订单及领取审核数（在线平台人数见 GET /admin/online/platformCount）
    public function unProcessed()
    {
        // 后台模拟会员的订单不进待处理角标
        $real = fn ($query) => \App\Support\MemberAudience::visibleMembers($query, 'member_id');
        //USDT充值订单
        $data['usdtRecharge'] = (int)$real(Recharge::where('status', 0))->where('created_at', '>', date('Y-m-d H:i:s', strtotime('-1 day')))->count();
        //人工充值订单
        $data['rgRecharge'] = (int)$real(PaymentOrderModel::whereIn('status', [0,1,5])->where('type', 3))->where('created_at', '>', date('Y-m-d H:i:s', strtotime('-1 day')))->count();
        //人民币充值订单
        $data['rmbRecharge'] = (int)$real(PaymentOrderModel::whereIn('status', [0,1])->where('type', 1))->where('created_at', '>', date('Y-m-d H:i:s', strtotime('-1 day')))->count();
        
        //USDT提现订单
        $data['usdtWithdraw'] = (int)$real(Withdraw::where('status', 0))->where('created_at', '>', date('Y-m-d H:i:s', strtotime('-1 day')))->count();
        //人工提现订单
        $data['rgWithdraw'] = (int)$real(PaymentOrderModel::where('status', 0)->where('type', 4))->where('created_at', '>', date('Y-m-d H:i:s', strtotime('-1 day')))->count();
        //人民币提现订单
        $data['rmbWithdraw'] = (int)$real(PaymentOrderModel::where('status', 0)->where('type', 2))->where('created_at', '>', date('Y-m-d H:i:s', strtotime('-1 day')))->count();
        // 代理充值待处理：人工充值待发送收款信息/待审核 + USDT 凭证待审核（与会员订单分开统计）。
        // 迁移未执行前（先发代码后迁移）表不存在，捕获后跳过，正常情况下不额外查表结构。
        try {
            $data['agentRecharge'] = (int)\App\Models\Agent\AgentPaymentOrder::where('type', 3)->whereIn('status', [0, 5])->count()
                + (int)\App\Models\Agent\AgentRecharge::where('type', 2)->where('status', 0)->count();
        } catch (\Illuminate\Database\QueryException $e) {
        }
        // 代理提现角标统计全部待审核申请，和会员提现分开。
        try {
            $data['agentWithdraw'] = (int) AgentWithdrawal::query()->where('status', 'pending')->count();
        } catch (\Illuminate\Database\QueryException $e) {
        }
        // 代理申请（会员前台提交）与合营代理分成方案申请：所有待审核持续提示，不限制申请日期。
        try {
            $data['agentApplication'] = (int)DB::table('agent_applications')->where('status', 'pending')->count();
            $data['agentPlanApplication'] = (int)DB::table('agent_plan_applications')->where('status', 'pending')->count();
        } catch (\Illuminate\Database\QueryException $e) {
        }
        // 分享赚钱领取审核：所有未审核申请持续提示，不限制申请日期。
        $data['shareClaim'] = (int)DB::table('share_claims')->where('status', 'pending')->count();
        return $this->success($data);
    }

    //人工充值，配置充值信息
    public function setPayData()
    {
        DB::beginTransaction();
        try {
            $params = request()->validate([
                'ids' => ['required', 'array', 'min:1'],
                'ids.*' => ['required', 'integer', 'min:1'],
                'payment_type' => ['required', 'integer'],
                'pay_data' => ['required', 'string'],
            ]);

            // $count = PaymentOrderModel::whereIn('id', $params['ids'])->where('payment_type', $params['payment_type'])->where('status', 0)->count();
            // if ($count != count($params['ids'])) throw new Exception('数据匹配异常，请刷新页面重试！', HttpStatus::CUSTOM_ERROR);
            
            $pending = PaymentOrderModel::whereIn('id', $params['ids'])
                ->where('payment_type', $params['payment_type'])
                ->where('status', 0);
            $ids = (clone $pending)->pluck('id')->all();
            $pending->update(['pay_data' => $params['pay_data'], 'status' => 4, 'is_send' => 0]);
            AdminRealtime::record('payment_orders', $ids);

            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(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }

    //人工充值审核
    public function manualAudit()
    {
        DB::beginTransaction();
        try {
            $params = request()->validate([
                'id' => ['required', 'integer', 'min:1'],
                'status' => ['required', 'integer', 'in:2,3'],
                'remark' => ['nullable', 'string'],
            ]);
            $remark = $params['remark'] ?? '';
            $info = PaymentOrderModel::where('id', $params['id'])
                ->where('type', PaymentOrderService::TYPE_SELF_PAY)
                ->lockForUpdate()->first();
            if (!$info) throw new Exception('数据不存在', HttpStatus::CUSTOM_ERROR);
            if ($params['status'] == 2 && $info->status != 5) throw new Exception('用户未提交充值凭证', HttpStatus::CUSTOM_ERROR);
            if ($params['status'] == 3 && !in_array($info->status, [0,1,4,5])) throw new Exception('订单已完成，不可驳回', HttpStatus::CUSTOM_ERROR);
            if ($params['status'] == 3) {
                //驳回
                if (empty($remark)) {
                    throw new Exception('请填写原因', HttpStatus::CUSTOM_ERROR);
                }
                $info->status = $params['status'];
                $info->remark = $remark;
                $info->save();
            } else {
                //充值成功
                $info->status = $params['status'];
                $info->remark = $remark;
                $info->state = 1;
                $info->save();

                $memberId = $info->member_id;
                $amount = $info->amount;
                // 前台提交并审核到账的人工充值属于真实充值；后台直接加款仍使用“人工充值”。
                $changeType = '充值';
                $wallet = Wallet::where('member_id', $memberId)->lockForUpdate()->first();
                if (!$wallet) throw new Exception('用户不存在', HttpStatus::CUSTOM_ERROR);
                $availableBalance = bcadd($wallet->available_balance, $amount, 10);
                $beforeBalance = (string)$wallet->available_balance;
                $wallet->available_balance = $availableBalance;
                $wallet->save();
                $principal = BalanceLogService::addLog($memberId, $amount, $beforeBalance, $availableBalance, $changeType, $info->id, $remark);
                \App\Services\RechargeBonusService::grant('payment_order', $info, $principal);
            }
            
            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(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }

    // 在线充值（代收）拒绝：未完成的订单直接置为失败，之后三方回调/查单不会再入账
    public function reject()
    {
        DB::beginTransaction();
        try {
            $params = request()->validate([
                'id' => ['required', 'integer', 'min:1'],
                'remark' => ['nullable', 'string', 'max:120'],
            ]);
            $order = PaymentOrderModel::where('id', $params['id'])
                ->where('type', PaymentOrderService::TYPE_PAY)
                ->lockForUpdate()
                ->first();
            if (!$order) throw new Exception('订单不存在', HttpStatus::CUSTOM_ERROR);
            $rejectable = [PaymentOrderService::STATUS_STAY, PaymentOrderService::STATUS_PROCESS, PaymentOrderService::STATUS_TIMEOUT];
            if (!in_array((int)$order->status, $rejectable, true)) {
                throw new Exception('订单已结束，不可拒绝', HttpStatus::CUSTOM_ERROR);
            }
            $order->status = PaymentOrderService::STATUS_FAIL;
            $order->remark = trim((string)($params['remark'] ?? '')) ?: '后台拒绝';
            $order->save();
            AdminRealtime::record('payment_orders', [$order->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(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }

    //提现审核
    public function audit()
    {
        DB::beginTransaction();
        try {
            
            $validate = [
                'ids' => ['required', 'array', 'min:1', 'max:20'],
                'ids.*' => ['required', 'integer', 'min:1'],
                'status' => ['required', 'integer', 'in:1,3'],
                'is_rgtx' => ['nullable', 'integer', 'in:0,1'],
            ];
            $status = request()->input('status', null);
            if ($status != 1) {
                $validate['remark'] = ['required', 'string', 'min:1', 'max:120'];
            }
            $params = request()->validate($validate);
            $remark = request()->input('remark', '');

            $count = 0;
            foreach ($params['ids'] as $id) {
                if ($params['status'] == 1) {
                    if (!empty($params['is_rgtx'])) {
                        $order = PaymentOrderModel::where('id', $id)
                            ->where('type', 4)
                            ->where('status', PaymentOrderService::STATUS_STAY)
                            ->lockForUpdate()
                            ->first();
                        if (!$order) throw new Exception("订单不存在_{$id}", HttpStatus::CUSTOM_ERROR);
                        $order->status = PaymentOrderService::STATUS_SUCCESS;
                        $order->save();
                        // 人工提现打款完成：扣除冻结余额
                        \App\Services\WithdrawFundsService::settle(\App\Services\WithdrawFundsService::PAYMENT_ORDERS, $order);
                    } else {
                        $ret = PaymentOrderService::createPayout($id);
                        if ($ret['code'] !== 0) throw new Exception($ret['msg'], HttpStatus::CUSTOM_ERROR);
                    }
                } else {
                    $ret = PaymentOrderService::withdrawalFailed($id, $remark);
                    if ($ret['code'] !== 0) throw new Exception($ret['msg'], HttpStatus::CUSTOM_ERROR);
                }
                $count++;
            }
            if ($count < 1) throw new Exception('操作失败', HttpStatus::CUSTOM_ERROR);
            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(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success();
    }


    /**
     * @apiParam {int} [page]
     * @apiParam {int} [limit]
     * @apiParam {int=0,1,2} type 类型 0全部 1=代收，2=代付
     * @apiParam {String} order_no 订单号
     * @apiPaaram {String} member_id 会员ID
     * @apiParam {int=1,2,3,7} [status] 状态：1处理中 2成功 3失败 7超时（处理中超过30分钟由 payment:pay-timeout 标记）
     *
     */
    public function index()
    {
        try {
            $params = request()->validate([
                'page' => ['nullable', 'integer', 'min:1'],
                'limit' => ['nullable', 'integer', 'min:1'],
                'order_no' => ['nullable', 'string'],
                'status' => ['nullable', 'integer'],
                'member_id' => ['nullable', 'integer'],
                'account' => ['nullable', 'string', 'max:64'],
                'first_name' => ['nullable'],
                'payment_type' => ['nullable', 'integer'],
                'channel' => ['nullable', 'string'],
            ]);

            $params['type'] = 1;
            $result = PaymentOrderService::paginate($params);
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
        return $this->success($result);
    }

    /**
     * @description: 查询订单的支付情况
     * @return {*}
     */
    public function check()
    {
        $id = request()->input('id');
        if (empty($id)) {
            return $this->error(HttpStatus::CUSTOM_ERROR, '参数错误');

        }
        try {
            $result = PaymentOrderService::singlePayOrder($id);
            $this->success([], $result['msg'] ?? '操作成功');
        } catch (Exception $e) {
            return $this->error(intval($e->getCode()));
        }
        return $this->success([], $result['msg'] ?? '操作成功');
    }

    //设置提现订单是否加锁
    public function setIsLocked()
    {
        DB::beginTransaction();
        try {
            $params = request()->validate([
                'ids' => ['required', 'array', 'min:1', 'max:20'],
                'ids.*' => ['required', 'integer', 'min:1'],
                'is_locked' => ['required', 'integer', 'in:1,0'],
            ]);
            PaymentOrderModel::whereIn('id',$params['ids'])->whereIn('type',[2,4])->update(['is_locked' => $params['is_locked']]);
            AdminRealtime::record('payment_orders', $params['ids']);
            
            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($e->getCode(), $e->getMessage());
        }
        return $this->success();
    }
}