owl-admin/app/Services/Client/WalletService.php

<?php

namespace App\Services\Client;

use App\Models\Order;
use App\Models\Wallet;
use App\Enums\UserStatus;
use App\Models\MemberUser;
use App\Enums\WithdrawMethod;
use App\Enums\WithdrawStatus;
use App\Models\WalletTransRecord;
use App\Enums\WithdrawAuditStatus;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use App\Models\WalletWithdrawRecord;

class WalletService
{
    /**
     * [钱包管理]获取钱包明细
     *
     * @param  int  $userId  用户ID
     * @param  int  $perPage  每页记录数
     * @return array 包含 items 和 total 的数组
     *
     * @throws \Exception
     */
    public function getWalletRecords($userId, $perPage = 10)
    {
        try {
            // 获取当前用户
            $user = MemberUser::find($userId);

            // 检查用户是否存在
            abort_if(! $user, 400, '用户不存在');
            // 检查用户状态
            abort_if($user->state != UserStatus::OPEN->value, 400, '用户状态异常');

            // 获取钱包交易记录
            $paginator = $user->wallet->transRecords()
                ->orderBy('created_at', 'desc')
                ->paginate($perPage);

            // 转换为统一的分页格式
            return [
                'items' => $paginator->items(),
                'total' => $paginator->total(),
            ];
        } catch (\Exception $e) {
            // 记录错误日志
            \Log::error('获取钱包明细失败', [
                'userId' => $userId,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString(),
            ]);
            throw $e;
        }
    }

    /**
     * 获取用户钱包
     */
    public function getUserWallet($userId)
    {
        try {
            $user = MemberUser::find($userId);

            abort_if(! $user, 400, '用户不存在');
            abort_if($user->state != UserStatus::OPEN->value, 400, '用户状态异常');

            $wallet = $user->wallet;
            if (! $wallet) {
                Log::warning('用户钱包不存在', ['user_id' => $user->id]);
                throw new \Exception('钱包不存在');
            }

            return $wallet;
        } catch (\Exception $e) {
            Log::error('获取用户钱包失败', ['error' => $e->getMessage()]);
            throw $e;
        }
    }

    /**
     * 用户钱包提现
     *
     * @param  int  $userId  用户ID
     * @param  array  $data  提现数据
     * @return array
     *
     * @throws \Exception
     */
    public function withdraw(int $userId, array $data)
    {
        return DB::transaction(function () use ($userId, $data) {
            try {
                // 获取用户信息
                $user = MemberUser::findOrFail($userId);
                abort_if($user->state != UserStatus::OPEN->value, 400, '用户状态异常');
                abort_if(! $user->wallet, 404, '钱包信息不存在');

                // 锁定钱包记录
                $wallet = Wallet::where('id', $user->wallet->id)
                    ->lockForUpdate()
                    ->first();

                // 验证提现金额
                $amount = $data['amount'];
                abort_if($amount <= 10, 422, '提现金额必须不小于10元');
                abort_if($amount > $wallet->available_balance, 422, '可提现余额不足');

                // 如果是微信提现，获取用户的微信openid
                if ($data['withdraw_type'] == WithdrawMethod::WECHAT->value) { // 1:微信提现
                    $socialAccount = DB::table('member_social_accounts')
                        ->where('user_id', $userId)
                        ->where('platform', 'wechat')
                        ->where('state', 1)
                        ->first();

                    abort_if(!$socialAccount, 422, '未绑定微信账号，无法进行微信提现');
                    $data['withdraw_account'] = $socialAccount->social_id; // 使用openid作为提现账号
                    $data['withdraw_account_name'] = $socialAccount->nickname; // 使用微信昵称作为账户名称
                }

                // 验证提现账号和账户名称
                abort_if(empty($data['withdraw_account']), 422, '请填写提现账号');
                abort_if(empty($data['withdraw_account_name']), 422, '请填写提现账户名');

                // 生成交易流水号
                $transNo = 'CW' . date('YmdHis') . mt_rand(1000, 9999);

                // 创建提现记录
                $withdraw = WalletWithdrawRecord::create([
                    'wallet_id' => $wallet->id,                                // 钱包ID
                    'trans_no' => $transNo,                                    // 交易流水号
                    'amount' => $amount,                                       // 提现金额
                    'withdraw_type' => $data['withdraw_type'],                 // 提现方式(1:微信 2:支付宝 3:银行卡)
                    'withdraw_account' => $data['withdraw_account'],           // 提现账号
                    'withdraw_account_name' => $data['withdraw_account_name'], // 提现账户名称
                    'state' => WithdrawStatus::PROCESSING,                    // 提现状态
                    'audit_state' => WithdrawAuditStatus::PENDING->value
                ]);

                // 创建交易记录
                WalletTransRecord::create([
                    'wallet_id' => $wallet->id,
                    'trans_no' => $transNo,
                    'trans_type' => 2, // 支出
                    'amount' => -$amount,
                    'before_balance' => $wallet->available_balance,
                    'after_balance' => $wallet->available_balance - $amount,
                    'owner_type' => WalletWithdrawRecord::class,
                    'owner_id' => $withdraw->id,
                    'remark' => '提现申请',
                    'state' => 2, // 处理中
                ]);

                // 冻结提现金额
                $wallet->decrement('available_balance', $amount);
                $wallet->increment('frozen_amount', $amount);

                // 记录日志
                Log::info('用户提现申请成功', [
                    'user_id' => $userId,
                    'trans_no' => $transNo,
                    'amount' => $amount,
                    'wallet_id' => $wallet->id,
                ]);

                return [
                    'message' => '提现申请已提交',
                    'trans_no' => $transNo,
                    'amount' => number_format($amount, 2, '.', ''),
                    'state' => '处理中',
                ];
            } catch (\Exception $e) {
                Log::error('用户提现申请失败', [
                    'user_id' => $userId,
                    'data' => $data,
                    'error' => $e->getMessage(),
                    'file' => $e->getFile(),
                    'line' => $e->getLine(),
                ]);
                throw $e;
            }
        });
    }

    /**
     * 扣减钱包余额
     *
     * @param int $userId 用户ID
     * @param float $amount 扣减金额
     * @param string $type 交易类型
     * @param int|null $objectId 关联对象ID
     * @param string $remark 备注说明
     * @return bool
     * @throws \Exception
     */
    public function deduct(
        int $userId,
        float $amount,
        string $type,
        ?int $objectId = null,
        string $remark = ''
    ): bool {
        return DB::transaction(function () use ($userId, $amount, $type, $objectId, $remark) {
            // 获取用户钱包
            $wallet = $this->getUserWallet($userId);

            // 检查余额是否足够
            abort_if(
                $wallet->available_balance < $amount,
                422,
                '钱包余额不足'
            );

            // 扣减余额
            $wallet->decrement('total_balance', $amount);
            $wallet->decrement('available_balance', $amount);

            // 增加总支出
            $wallet->increment('total_expense', $amount);

            // 创建交易记录
            $wallet->transRecords()->create([
                'amount' => -$amount,  // 负数表示支出
                'trans_type' => $type,
                'owner_type' => Order::class,
                'owner_id' => $objectId,
                'remark' => $remark ?: '订单支付',
                'before_balance' => $wallet->total_balance + $amount,
                'after_balance' => $wallet->total_balance,
                'state' => 1,
                'storage_type' => 1,  // 添加 storage_type 字段，1 表示余额
            ]);

            return true;
        });
    }
}