GoLang GAE PayPal IPN集成：解决参数顺序问题

package main

import (
    "bytes"
    "io"
    "log"
    "net/http"
    "strings" // 用于字符串比较，例如 "VERIFIED"

    "google.golang.org/appengine"
    "google.golang.org/appengine/urlfetch"
)

// ipnHandler 处理PayPal IPN回调
func ipnHandler(w http.ResponseWriter, r *http.Request) {
    // 1. 确保请求方法是POST
    if r.Method != http.MethodPost {
        http.Error(w, "Method Not Allowed", http.StatusMethodNotAllowed)
        return
    }

    c := appengine.NewContext(r)
    client := urlfetch.Client(c)

    // 2. 读取原始请求体
    // 为了确保原始请求体可以被多次读取（例如，如果需要解析参数到r.Form），
    // 最好先将其完全读入一个缓冲区。
    originalBodyBytes, err := io.ReadAll(r.Body)
    if err != nil {
        log.Errorf(c, "Failed to read request body: %v", err)
        http.Error(w, "Internal Server Error", http.StatusInternalServerError)
        return
    }

    // 3. 构建PayPal验证请求体
    // 按照PayPal要求，在原始请求体前面添加 "cmd=_notify-validate&"
    var validationBuf bytes.Buffer
    validationBuf.WriteString("cmd=_notify-validate&") // 添加PayPal要求的cmd参数
    validationBuf.Write(originalBodyBytes)             // 将原始请求体内容追加到后面

    // 4. 发送验证请求到PayPal
    // 注意：这里需要使用PayPal的实际IPN验证URL。
    // 沙盒环境：https://www.sandbox.paypal.com/cgi-bin/webscr
    // 生产环境：https://www.paypal.com/cgi-bin/webscr
    paypalVerifyURL := "https://www.sandbox.paypal.com/cgi-bin/webscr" // 示例：沙盒环境

    resp, err := client.Post(paypalVerifyURL, "application/x-www-form-urlencoded", &validationBuf)
    if err != nil {
        log.Errorf(c, "Failed to send IPN verification request: %v", err)
        http.Error(w, "Internal Server Error", http.StatusInternalServerError)
        return
    }
    defer resp.Body.Close() // 确保关闭响应体

    // 5. 处理PayPal的验证响应
    verificationResultBytes, err := io.ReadAll(resp.Body)
    if err != nil {
        log.Errorf(c, "Failed to read PayPal verification response: %v", err)
        http.Error(w, "Internal Server Error", http.StatusInternalServerError)
        return
    }

    verificationResult := strings.TrimSpace(string(verificationResultBytes))

    if verificationResult == "VERIFIED" {
        // IPN验证成功，处理业务逻辑
        log.Infof(c, "PayPal IPN VERIFIED. Transaction details: %s", string(originalBodyBytes))

        // TODO: 在这里解析 originalBodyBytes 中的参数（通常是 application/x-www-form-urlencoded 格式），
        // 并根据交易信息更新订单状态、发货、记录日志等。
        // 可以使用 net/url 包的 ParseQuery 函数来解析 originalBodyBytes。
        // 例如：
        // values, _ := url.ParseQuery(string(originalBodyBytes))
        // transactionID := values.Get("txn_id")
        // paymentStatus := values.Get("payment_status")
        // ...

        w.WriteHeader(http.StatusOK)
        w.Write([]byte("IPN Processed"))
    } else if verificationResult == "INVALID" {
        // IPN验证失败，记录错误或采取其他措施
        log.Warningf(c, "PayPal IPN INVALID. Raw body: %s", string(originalBodyBytes))
        http.Error(w, "IPN Invalid", http.StatusBadRequest)
    } else {
        // 未知响应，可能PayPal服务出现问题
        log.Errorf(c, "PayPal IPN Unknown response: %s. Raw body: %s", verificationResult, string(originalBodyBytes))
        http.Error(w, "Unknown PayPal IPN Response", http.StatusInternalServerError)
    }
}

func main() {
    // 注册IPN处理函数
    http.HandleFunc("/paypal-ipn", ipnHandler)
    // 启动App Engine服务
    appengine.Main()
}