接收PayPal IPN后无法更新用户数据库的技术求助

首先得戳破你遇到的核心问题：PayPal的IPN请求和用户的浏览器会话完全不相关，你想用$_SESSION['log_id']定位用户根本行不通！IPN是PayPal服务器直接发给你的服务器的独立请求，这个请求里没有用户浏览器的SESSION cookie，所以$_SESSION['log_id']是空值，数据库更新语句自然找不到要修改的用户。

接下来我帮你梳理代码里的问题和落地的修复方案：

1. 核心修正：用自定义参数关联支付用户 #

你必须在用户发起支付时，把用户的唯一标识（比如用户ID）作为自定义参数传给PayPal。比如在生成PayPal支付按钮时，添加custom字段传递当前登录用户ID：

<!-- 示例支付按钮，custom字段绑定用户ID -->
<form action="https://www.paypal.com/cgi-bin/webscr" method="post">
  <input type="hidden" name="cmd" value="_xclick">
  <input type="hidden" name="business" value="your-paypal-email@example.com">
  <input type="hidden" name="item_name" value="Premium Account">
  <input type="hidden" name="amount" value="9.99">
  <!-- 传递当前登录用户的ID -->
  <input type="hidden" name="custom" value="<?php echo $_SESSION['log_id']; ?>">
  <input type="image" src="https://www.paypalobjects.com/en_US/i/btn/btn_buynowCC_LG.gif" border="0" name="submit" alt="PayPal - The safer, easier way to pay online!">
</form>

之后在IPN监听器里，通过$_POST['custom']获取这个用户ID，用它来定位要更新的数据库记录。

2. 修复代码中的语法错误 #

你的代码里所有$_POST['$xxx']的写法都是错误的，键名里的$完全多余，比如：

// 错误写法
$item_number = $_POST['$item_number'];
// 正确写法
$item_number = $_POST['item_number'];

所有类似$_POST['$payment_status']、$_POST['$txn_id']的语句都要去掉键名里的$，否则根本获取不到PayPal传递的参数。

3. 修正IPN响应匹配逻辑 #

fgets($fh, 1024)读取的响应可能包含换行符（比如VERIFIED\r\n），直接用strcmp和"VERIFIED"比较会匹配失败。需要先去掉首尾空白字符：

$readresp = trim(fgets($fh, 1024));
if (strcmp($readresp, "VERIFIED") == 0) {
    // 验证通过的逻辑
}

4. 增加错误处理与日志记录 #

你的代码几乎没有错误排查机制，建议添加日志函数，把关键节点的状态写入日志文件，方便定位问题：

// 写入IPN日志的工具函数
function writeIPNLog($message) {
    $logFile = 'ipn_logs.txt';
    $timestamp = date('Y-m-d H:i:s');
    file_put_contents($logFile, "[$timestamp] $message" . PHP_EOL, FILE_APPEND);
}

然后在关键节点调用：

• 连接PayPal失败时：writeIPNLog("IPN连接失败: $errno - $errstr");
• 验证为INVALID时：writeIPNLog("IPN验证失败，交易ID: $txn_id");
• 数据库更新后检查结果：

if ($query->rowCount() === 0) {
    writeIPNLog("更新用户失败，用户ID: $customUserId，交易ID: $txn_id");
} else {
    writeIPNLog("用户ID $customUserId 已升级为Premium，交易ID: $txn_id");
}

5. 推荐用CURL替代fsockopen #

fsockopen在部分服务器环境下可能被禁用，且处理HTTPS请求不如CURL可靠，这里给你替换成CURL的验证逻辑：

$ch = curl_init('https://www.paypal.com/cgi-bin/webscr');
curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, $resp);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
curl_setopt($ch, CURLOPT_FORBID_REUSE, true);
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
    'Connection: Close',
    'Content-Type: application/x-www-form-urlencoded'
));

$readresp = curl_exec($ch);
if (curl_errno($ch)) {
    writeIPNLog("CURL错误: " . curl_error($ch));
    curl_close($ch);
    exit;
}
curl_close($ch);

$readresp = trim($readresp);
if (strcmp($readresp, "VERIFIED") == 0) {
    // 验证通过逻辑
}

修改后的完整监听器代码示例 #

<?php
// 开启错误日志（调试用，上线后可关闭）
error_reporting(E_ALL);
ini_set('log_errors', 1);
ini_set('error_log', 'ipn_error_logs.txt');

// 写入IPN日志函数
function writeIPNLog($message) {
    $logFile = 'ipn_logs.txt';
    $timestamp = date('Y-m-d H:i:s');
    file_put_contents($logFile, "[$timestamp] $message" . PHP_EOL, FILE_APPEND);
}

// 响应PayPal的初始请求
header('HTTP/1.1 200 OK');

// 构建验证请求
$resp = "cmd=_notify-validate";
foreach ($_POST as $parm => $var) {
    $var = urlencode(stripslashes($var));
    $resp .= "&$parm=$var";
}

// 获取PayPal传递的参数（修正键名错误）
$payment_status = $_POST['payment_status'];
$txn_id = $_POST['txn_id'];
$customUserId = $_POST['custom']; // 获取支付时传递的用户ID
$payer_email = $_POST['payer_email'];

// 使用CURL验证IPN
$ch = curl_init('https://www.paypal.com/cgi-bin/webscr');
curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, $resp);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
curl_setopt($ch, CURLOPT_FORBID_REUSE, true);
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
    'Connection: Close',
    'Content-Type: application/x-www-form-urlencoded'
));

$readresp = curl_exec($ch);
if (curl_errno($ch)) {
    $errorMsg = "CURL连接失败: " . curl_error($ch);
    writeIPNLog($errorMsg);
    curl_close($ch);
    exit;
}
curl_close($ch);

$readresp = trim($readresp);
if (strcmp($readresp, "VERIFIED") == 0) {
    // 只处理已完成的支付
    if ($payment_status == 'Completed') {
        require 'scr/db.inc.php';
        try {
            $handler = new Dbh();
            $sql = 'UPDATE `users` SET `type` = "PREMIUM" WHERE `id` = :id';
            $query = $handler->connect()->prepare($sql);
            $query->execute(array(':id' => $customUserId));
            
            if ($query->rowCount() > 0) {
                writeIPNLog("成功升级用户ID $customUserId 为Premium，交易ID: $txn_id，支付邮箱: $payer_email");
            } else {
                writeIPNLog("未找到用户ID $customUserId，无法升级，交易ID: $txn_id");
            }
        } catch (PDOException $e) {
            writeIPNLog("数据库错误: " . $e->getMessage() . "，交易ID: $txn_id");
        }
    } else {
        writeIPNLog("支付状态未完成: $payment_status，交易ID: $txn_id");
    }
} else if (strcmp($readresp, "INVALID") == 0) {
    writeIPNLog("IPN验证失败，交易ID: $txn_id，请求参数: " . print_r($_POST, true));
} else {
    writeIPNLog("未知的IPN响应: $readresp，交易ID: $txn_id");
}
?>

最后检查要点 #

• 确保支付按钮里的custom字段正确传递了用户ID
• 确认服务器可以访问PayPal的443端口（HTTPS接口）
• 查看ipn_logs.txt和ipn_error_logs.txt日志，排查具体错误
• 数据库用户拥有users表的UPDATE权限，且id、type字段存在且类型匹配

内容的提问来源于stack exchange，提问作者aaaaaron