kknongchang_2506/app/Module/OpenAPI/Handlers/Fund/DiamondRechargeHandler.php

<?php

namespace App\Module\OpenAPI\Handlers\Fund;

use App\Module\OpenAPI\Handlers\BaseHandler;
use App\Module\OpenAPI\Services\ScopeService;
use App\Module\OpenAPI\Services\DeveloperAccountService;
use App\Module\OpenAPI\Enums\SCOPE_TYPE;
use App\Module\OpenAPI\Validations\DiamondRechargeValidation;
use App\Module\Fund\Services\FundService;
use App\Module\Fund\Enums\FUND_TYPE;
use App\Module\Fund\Enums\FUND_CURRENCY_TYPE;
use Illuminate\Http\JsonResponse;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

/**
 * 钻石充值Handler
 * 
 * 处理开发者为用户充值钻石的业务逻辑
 * 资金流向：开发者充值账户 -> 用户钻石账户
 */
class DiamondRechargeHandler extends BaseHandler
{
    public function __construct(ScopeService $scopeService)
    {
        parent::__construct($scopeService);
    }

    /**
     * 获取所需的权限范围
     *
     * @return SCOPE_TYPE[]
     */
    public function getRequiredScopes(): array
    {
        return [SCOPE_TYPE::FUND_RECHARGE];
    }

    /**
     * 处理钻石充值请求
     *
     * @param array $data 请求数据
     * @param array $context 上下文信息
     * @return JsonResponse
     */
    protected function process(array $data, array $context = []): JsonResponse
    {
        // 使用验证类进行数据验证
        $validation = new DiamondRechargeValidation($data);
        $validation->validate();

        if ($validation->isFail()) {
            return $this->errorResponse('参数验证失败', $validation->getErrors(), 422);
        }

        // 获取验证后的数据
        $safeData = $validation->getSafeData();
        $targetUserId = $safeData['user_id'];
        $amount = $safeData['amount'];
        $remark = $safeData['remark'] ?? '开发者充值钻石';
        $orderId = $safeData['order_id'] ?? null;

        // 获取应用信息
        $app = $this->getApp($context);
        if (!$app) {
            return $this->errorResponse('无法获取应用信息', null, 400);
        }

        try {
            DB::beginTransaction();

            // 检查开发者账户是否存在
            $accountCheck = DeveloperAccountService::checkDeveloperAccounts($app);
            if (!$accountCheck['recharge_account_exists']) {
                // 自动创建开发者账户
                $createResult = DeveloperAccountService::createDeveloperAccounts($app);
                if (!$createResult['success']) {
                    DB::rollBack();
                    return $this->errorResponse('创建开发者账户失败', $createResult['message'], 500);
                }
            }

            // 获取开发者充值账户用户ID
            $rechargeUserId = DeveloperAccountService::getRechargeUserId($app->id);

            // 检查开发者充值账户余额
            $rechargeFundService = new FundService($rechargeUserId, FUND_TYPE::FUND2->value);
            $rechargeBalance = $rechargeFundService->balance();

            if ($rechargeBalance < $amount) {
                DB::rollBack();
                return $this->errorResponse('开发者充值账户余额不足', [
                    'required' => $amount,
                    'available' => $rechargeBalance
                ], 400);
            }

            // 检查目标用户是否存在钻石账户，如果不存在则创建
            $targetFundService = new FundService($targetUserId, FUND_TYPE::FUND2->value);
            $targetAccount = $targetFundService->getAccount();
            if (!$targetAccount) {
                // 初始化用户钻石账户
                $initResult = $targetFundService->admin(FUND_TYPE::FUND2, 0, 1, '初始化钻石账户');
                if (is_string($initResult)) {
                    DB::rollBack();
                    return $this->errorResponse('初始化用户账户失败', $initResult, 500);
                }
            }

            // 执行转账：从开发者充值账户转到用户钻石账户
            $transferResult = $rechargeFundService->transfer(
                $targetUserId,
                $amount,
                $remark . ($orderId ? " (订单号: {$orderId})" : '')
            );

            if (is_string($transferResult)) {
                DB::rollBack();
                return $this->errorResponse('充值转账失败', $transferResult, 500);
            }

            DB::commit();

            // 记录操作日志
            $this->logAction('diamond.recharge', [
                'app_id' => $app->id,
                'recharge_user_id' => $rechargeUserId,
                'target_user_id' => $targetUserId,
                'amount' => $amount,
                'order_id' => $orderId,
                'transfer_id' => $transferResult->transferId,
            ], $context);

            // 获取充值后的账户信息
            $rechargeAccountInfo = $rechargeFundService->getAccount();
            $targetAccountInfo = $targetFundService->getAccount();

            $responseData = [
                'transfer_id' => $transferResult->transferId,
                'order_id' => $orderId,
                'amount' => $amount,
                'currency_type' => FUND_CURRENCY_TYPE::ZUANSHI->value,
                'currency_name' => FUND_CURRENCY_TYPE::ZUANSHI->getCurrencyName(),
                'from_account' => [
                    'user_id' => $rechargeUserId,
                    'account_type' => '开发者充值账户',
                    'balance_after' => $rechargeAccountInfo ? $rechargeAccountInfo->balance : 0,
                ],
                'to_account' => [
                    'user_id' => $targetUserId,
                    'account_type' => '用户钻石账户',
                    'balance_after' => $targetAccountInfo ? $targetAccountInfo->balance : 0,
                ],
                'remark' => $remark,
                'created_at' => $transferResult->createdAt,
            ];

            return $this->successResponse('钻石充值成功', $responseData);

        } catch (\Exception $e) {
            DB::rollBack();
            
            Log::error('钻石充值失败', [
                'app_id' => $app->id,
                'target_user_id' => $targetUserId,
                'amount' => $amount,
                'error' => $e->getMessage(),
                'trace' => $e->getTraceAsString()
            ]);

            return $this->errorResponse('充值处理失败', $e->getMessage(), 500);
        }
    }

    /**
     * 获取开发者账户余额信息
     *
     * @param array $data 请求数据
     * @param array $context 上下文信息
     * @return JsonResponse
     */
    public function getRechargeAccountBalance(array $data, array $context = []): JsonResponse
    {
        // 获取应用信息
        $app = $this->getApp($context);
        if (!$app) {
            return $this->errorResponse('无法获取应用信息', null, 400);
        }

        try {
            // 获取开发者账户信息
            $accountInfo = DeveloperAccountService::getDeveloperAccountInfo($app);
            
            $responseData = [
                'app_id' => $app->id,
                'app_name' => $app->name,
                'recharge_account' => $accountInfo['recharge_account'],
                'currency_type' => FUND_CURRENCY_TYPE::ZUANSHI->value,
                'currency_name' => FUND_CURRENCY_TYPE::ZUANSHI->getCurrencyName(),
                'precision' => FUND_CURRENCY_TYPE::ZUANSHI->getPrecision(),
            ];

            return $this->successResponse('获取充值账户余额成功', $responseData);

        } catch (\Exception $e) {
            Log::error('获取充值账户余额失败', [
                'app_id' => $app->id,
                'error' => $e->getMessage(),
            ]);

            return $this->errorResponse('获取账户信息失败', $e->getMessage(), 500);
        }
    }
}