使用PayPal Payouts自动化订阅平台佣金分配的教程

// 示例：Webhook处理器（概念性）
<?php
// 确保请求方法是POST，并且包含PayPal Webhook数据
if ($_SERVER['REQUEST_METHOD'] === 'POST') {
    $input = file_get_contents('php://input');
    $event = json_decode($input, true);

    // 验证Webhook签名（重要安全步骤，此处省略具体实现）
    // ...

    // 检查事件类型，例如订阅付款完成
    if (isset($event['event_type']) && $event['event_type'] === 'BILLING.SUBSCRIPTION.PAYMENT.COMPLETED') {
        $resource = $event['resource'];
        $subscriptionId = $resource['id']; // 订阅ID
        $payerId = $resource['payer']['payer_id']; // 付款人ID
        $amount = $resource['amount']['value']; // 订阅支付金额
        $currency = $resource['amount']['currency_code']; // 货币

        // 从您的数据库中获取与此订阅相关的创作者ID和佣金比例
        // 假设您有一个函数可以根据订阅ID获取创作者信息
        $creatorInfo = getCreatorInfoBySubscriptionId($subscriptionId); 
        if ($creatorInfo) {
            $creatorId = $creatorInfo['creator_paypal_email']; // 创作者PayPal邮箱
            $commissionRate = $creatorInfo['platform_commission_rate']; // 平台佣金比例，例如0.20 (20%)

            // 计算创作者应得金额
            $creatorShare = $amount * (1 - $commissionRate);

            // 触发PayPal Payouts付款
            initiatePayPalPayout($creatorId, $creatorShare, $currency, $subscriptionId);
        }
    }
    // 其他事件处理...

    http_response_code(200); // 告知PayPal已成功接收Webhook
} else {
    http_response_code(405); // 不允许的请求方法
}

// 辅助函数，实际应从数据库查询
function getCreatorInfoBySubscriptionId($subscriptionId) {
    // 模拟从数据库获取数据
    // 实际应用中，这里会查询您的数据库，根据 subscriptionId 找到对应的 creator_id, creator_paypal_email, platform_commission_rate 等
    $mockData = [
        'sub-123' => ['creator_paypal_email' => 'creator1@example.com', 'platform_commission_rate' => 0.15],
        'sub-456' => ['creator_paypal_email' => 'creator2@example.com', 'platform_commission_rate' => 0.20],
    ];
    return $mockData[$subscriptionId] ?? null;
}
?>

// 示例：调用PayPal Payouts API（概念性PHP Curl）
function initiatePayPalPayout($recipientEmail, $amount, $currency, $referenceId) {
    // 1. 获取PayPal OAuth2 Access Token
    // 这通常涉及使用您的Client ID和Secret进行认证请求
    // 实际生产环境中，Access Token应缓存并在过期前刷新
    $accessToken = getPayPalAccessToken(); // 假设您有函数获取Access Token

    if (!$accessToken) {
        error_log("Failed to get PayPal Access Token.");
        return false;
    }

    $payoutsApiUrl = 'https://api.paypal.com/v1/payments/payouts'; // 沙盒环境或生产环境URL

    $batchId = uniqid('payout_batch_'); // 生成唯一的批次ID
    $payoutData = [
        'sender_batch_header' => [
            'sender_batch_id' => $batchId,
            'email_subject' => '您的订阅收入佣金',
            'email_message' => '您通过平台获得的订阅收入已到账。'
        ],
        'items' => [
            [
                'recipient_type' => 'EMAIL',
                'receiver' => $recipientEmail,
                'amount' => [
                    'value' => number_format($amount, 2, '.', ''), // 格式化金额到两位小数
                    'currency' => $currency
                ],
                'note' => '订阅收入佣金',
                'sender_item_id' => 'sub_payout_' . $referenceId // 用于追踪的唯一ID
            ]
        ]
    ];

    $ch = curl_init($payoutsApiUrl);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payoutData));
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Content-Type: application/json',
        'Authorization: Bearer ' . $accessToken
    ]);

    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    if ($httpCode === 201) {
        $payoutResponse = json_decode($response, true);
        error_log("Payout initiated successfully. Batch ID: " . $payoutResponse['batch_header']['payout_batch_id']);
        // 记录Payout状态到数据库，以便追踪
        return true;
    } else {
        error_log("Failed to initiate Payout. HTTP Code: " . $httpCode . " Response: " . $response);
        // 处理错误，可能需要重试或通知管理员
        return false;
    }
}

// 假设的获取Access Token函数（需要替换为实际的认证逻辑）
function getPayPalAccessToken() {
    $clientId = 'YOUR_PAYPAL_CLIENT_ID';
    $clientSecret = 'YOUR_PAYPAL_CLIENT_SECRET';
    $tokenUrl = 'https://api.paypal.com/v1/oauth2/token'; // 沙盒环境或生产环境URL

    $ch = curl_init($tokenUrl);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_POSTFIELDS, 'grant_type=client_credentials');
    curl_setopt($ch, CURLOPT_USERPWD, $clientId . ':' . $clientSecret); // Basic认证
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Accept: application/json',
        'Accept-Language: en_US'
    ]);

    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);

    if ($httpCode === 200) {
        $tokenData = json_decode($response, true);
        return $tokenData['access_token'] ?? null;
    } else {
        error_log("Failed to get PayPal Access Token. HTTP Code: " . $httpCode . " Response: " . $response);
        return null;
    }
}
?>