BroadbandSaler/app/DataApiNew/Helper/GetPaysHelper.php

<?php
/*
 * @Description: 提现表
 * @Version: *
 * @Autor: lexuan
 * @Date: 2024-12-04 13:18:11
 * @LastEditors: lexuan
 * @LastEditTime: 2024-12-04 13:18:11
 */

namespace App\DataApiNew\Helper;

use App\DataApiNew\Models\GetPays;
use App\Models\Pages;
use App\Models\SpoutExport;
use App\Models\SpoutImport;
use App\DataApiNew\Models\AdminUsers;
use App\DataApiNew\Models\UserYjrecord;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;

class GetPaysHelper
{
    // 查询条件
    public function whens($query, $request)
    {
        return $query
            ->when($request->filled('id'), fn ($q) => $q->where('id', $request->id))
            ->when($request->filled('user_id'), fn ($q) => $q->where('user_id', $request->user_id))
            ->when($request->filled('type'), fn ($q) => $q->where('type', $request->type))
            ->when($request->filled('status'), fn ($q) => $q->where('status', $request->status));
    }

    // 查询列表
    public function select(Request $request)
    {
        $user_id = $request->user()->id;

        $page = new Pages($request, GetPays::query());

        $page->before(function ($query) use ($request, $user_id) {
            
            if(AdminUsers::isAdmin($user_id)){
                $query->select(GetPays::$selectFields);
            }else{
                $query->select([
                    'open_id', // 微信openid
                    'unionid', // 微信平台唯一码
                    'status', // 状态 0:待审核 1：审核通过 2：审核不通过
                    'amount',
                    'errmsg', // 失败原因
                    'order_no', // 提现订单号
                    'bankcard', // 银行卡号
                    'openbank', // 开户行
                    'username', // 姓名
                    'alipay', // 支付宝账号
                    'alipay_name', // 支付宝姓名
                    'wechat_no', // 微信号
                    'created_at', // 创建时间
                    'type', // 提现方式 1：支付宝 2：银行卡 3：微信
                    'remit_amount',
                    'charge_amount',
                    'tax_point', // 税点
                ])->where('user_id', $user_id);
            }

            return $this->whens($query, $request);
        });

        $result = $page->paginate();

        return $result;
    }

    // 导出
    public function export(Request $request)
    {
        $query = GetPays::select(GetPays::$selectFields);
        $query = $this->whens($query, $request);
        $query->orderBy('created_at', 'desc');
        $header = [
            '主键' => 'id',
            '用户id' => 'user_id',
            '微信openid' => 'open_id',
            '微信平台唯一码' => 'unionid',
            '状态 0:待审核 1：审核通过 2：审核不通过' => 'status',
            '失败原因' => 'errmsg',
            '提现订单号' => 'order_no',
            '银行卡号' => 'bankcard',
            '开户行' => 'openbank',
            '姓名' => 'username',
            '支付宝账号' => 'alipay',
            '支付宝姓名' => 'alipay_name',
            '微信号' => 'wechat_no',
            '创建时间' => 'created_at',
            '修改时间' => 'updated_at',
            '删除时间' => 'deleted_at',
            '提现方式 1：支付宝 2：银行卡 3：微信' => 'type',
            '打款信息id' => 'remit_id',
            '税点' => 'tax_point',
        ];
        $getEnValue = $this->getEnValue();

        $excel = new SpoutExport($header);
        $excel->setData($query->get());
        $result = $excel->setEnum($getEnValue)->spoutToExcel('excel_out');

        return $result ? success($result['url']) : error();
    }

    // 导入
    public function import(Request $request)
    {
        $header = [
            '主键' => 'id',
            '用户id' => 'user_id',
            '微信openid' => 'open_id',
            '微信平台唯一码' => 'unionid',
            '状态 0:待审核 1：审核通过 2：审核不通过' => 'status',
            '失败原因' => 'errmsg',
            '提现订单号' => 'order_no',
            '银行卡号' => 'bankcard',
            '开户行' => 'openbank',
            '姓名' => 'username',
            '支付宝账号' => 'alipay',
            '支付宝姓名' => 'alipay_name',
            '微信号' => 'wechat_no',
            '创建时间' => 'created_at',
            '修改时间' => 'updated_at',
            '删除时间' => 'deleted_at',
            '提现方式 1：支付宝 2：银行卡 3：微信' => 'type',
            '打款信息id' => 'remit_id',
            '税点' => 'tax_point',
        ];
        $SpoutImport = new SpoutImport($header);
        $dataList = $SpoutImport->setRequest($request)->getExcelData();
        return $dataList;
    }

    // 获取枚举值
    public function getEnValue()
    {
        $data = [];
        return $data;
    }

    // 查询一条
    public function find(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
        ]);
        $result = GetPays::where(['id' => $request->id])->select(GetPays::$selectFields)->first();
        return success($result);
    }

    // 添加
    public function insert(Request $request)
    {
        $request->validate([
            // 'name' => 'required',
        ]);
        $result = GetPays::create($request->all());
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 修改
    public function update(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
        ]);

        $result = GetPays::where(['id' => $request->id])->update($request->all());
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 删除
    public function delete(Request $request)
    {
        $request->validate([
            'ids' => 'required',
        ]);
        $id_str = $request->ids;
        $arr = explode(",", $id_str);
        // 查询是否存在子数据
        // $count = Shop::whereIn('tm_id',$arr)->count();
        // if($count > 0){
        //     return ['code'=>0,'msg'=>"存在子数据，禁止删除"];
        // }
        $result = GetPays::whereIn('id', $arr)->delete();
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    //提现申请
    public function userGetpayApply(Request $request)
    {
        $request->validate([
            'amount' => 'required|numeric',
            'type' => 'required|integer|in:1,2,3', // 提现方式 1：支付宝 2：银行卡 3：微信
        ]);

        if ($request->type == 1) {
            $request->validate([
                'alipay' => 'required|string|max:30',
                'alipayname' => 'required|string|max:30',
            ]);
        } elseif ($request->type == 2) {
            $request->validate([
                'username' => 'required|string|max:20',
                'bankcard' => 'required|string|max:30',
                'openbank' => 'required|string|max:100',
            ]);
        } elseif ($request->type == 3) {
            $request->validate([
                'wechat_no' => 'required|string|max:50',
            ]);
        }

        sys_log($request, '提现申请', '提现记录');

        $user_id = $request->user()->id;

        $cacheKey = "getpay_apply_" . $user_id;
        if (!Cache::add($cacheKey, 1, 5)) {
            return ['code' => 0, 'msg' => "请勿频繁请求"];
        }

        if (empty($request->amount) || $request->amount < 1)  return ['code' => 0, 'msg' => '提现金额不能为空或小于1元'];

        // 查询实名
        $is_real = AdminUsers::where('id', $user_id)->value('is_real');
        if ($is_real != 1) {
            return ['code' => 0, 'msg' => "未进行实名认证"];
        }

        $amount = $request->amount;
        $type = $request->type;
        $username = $request->input('username', null);
        $bankcard = $request->input('bankcard', null);
        $openbank = $request->input('openbank', null);
        $alipay = $request->input('alipay', null);
        $alipayname = $request->input('alipayname', null);
        $wechat_no = $request->input('wechat_no', null);

        $user = AdminUsers::where('id', $user_id)->select(['id', 'parent_id', 'username', 'yj'])->first();
        if (empty($user)) {
            return ['code' => 0, 'msg' => '无效的用户信息'];
        }

        if ($user->yj < $amount)  return ['code' => 0, 'msg' => '账户余额不足，无法申请提现'];

        //0：待审核 1：审核成功 2：审核失败 3：打款中
        $exists = GetPays::where(['user_id' => $user_id])->whereIn('status', [0])->exists();
        if ($exists) {
            return ['code' => 0, 'msg' => '当前有在提现的金额，请审核通过后再申请提现'];
        }

        $order_no = UtilsHelper::order_id();

        // 处理银行卡号空格 
        if (!empty($bankcard)) {
            $bankcard = str_replace(' ', '', $bankcard);
        }

        $tax_point = env('GETPAY_TAX'); //税点比例

        if ($tax_point == 0) {
            $charge_amount = 0;
            $remit_amount = $amount;
        } else {
            $charge_amount = bcmul($amount, bcdiv($tax_point, '100', 2), 2); //扣税金额
            $remit_amount = bcsub($amount, $charge_amount, 2); //打款金额
        }

        $data = [
            'order_no' => $order_no,
            'amount' => $amount,
            'charge_amount' => $charge_amount,
            'remit_amount' => $remit_amount,
            'tax_point' => $tax_point,
            'user_id' => $user_id,
            'bankcard' => $bankcard,
            'openbank' => $openbank,
            'username' => $username,
            'alipay' => $alipay,
            'type' => $type,
            'alipay_name' => $alipayname,
            'wechat_no' => $wechat_no,
        ];

        if (GetPays::create($data)) {
            sys_log($request, '用户申请提现', '提现记录');
            return ['code' => 1, 'msg' => '提现申请提交成功'];
        } else {
            return ['code' => 0, 'msg' => '提现申请提交失败'];
        }
    }

    // 提现审核
    public function userGetpayCheck(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
            'status' => 'required|integer|in:1,2', // 提现状态 1：审核通过 2：审核失败
        ]);

        sys_log($request, '用户提现审核', '提现记录');

        $getPays = GetPays::find($request->id);
        if (empty($getPays)) {
            return ['code' => 0, 'msg' => "无效的提现记录"];
        }

        DB::beginTransaction();

        try {
            if ($request->status == 1) {
                (new UserYjrecord())->recharge([
                    'user_id' => $getPays->user_id,
                    'yj' => $getPays->remit_amount,
                    'type' => UserYjrecord::TYPE_WITHDRAW,
                    'status' => UserYjrecord::STATUS_SUB,
                    'order_no' => $getPays->order_no,
                    'source' => '余额提现',
                ]);
            }

            $getPays->update(['status' => $request->status]);

            DB::commit();

            return ['code' => 1, 'msg' => "操作成功"];
        } catch (\Throwable $th) {
            Log::error('提现审核失败：' . $th->getMessage());
            DB::rollBack();
            return ['code' => 0, 'msg' => "操作失败"];
        }
    }
}