当前位置：首页 > PHP

php充值功能实现

2026-02-27 22:36:07PHP

实现PHP充值功能的方法

数据库设计

创建一个数据库表来存储充值记录，字段包括充值ID、用户ID、金额、充值时间、状态等。例如：

CREATE TABLE recharge_records (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT NOT NULL,
    amount DECIMAL(10,2) NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    status ENUM('pending', 'completed', 'failed') DEFAULT 'pending'
);

前端表单设计

设计一个简单的HTML表单，用于用户输入充值金额和选择支付方式：

<form action="recharge.php" method="post">
    <label for="amount">充值金额：</label>
    <input type="number" id="amount" name="amount" min="1" step="0.01" required>

    <label for="payment_method">支付方式：</label>
    <select id="payment_method" name="payment_method" required>
        <option value="alipay">支付宝</option>
        <option value="wechat">微信支付</option>
    </select>

    <button type="submit">提交</button>
</form>

后端处理逻辑

创建recharge.php文件处理充值请求，验证用户输入并记录充值信息：

<?php
// 连接数据库
$db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');

// 获取用户输入
$user_id = $_SESSION['user_id']; // 假设用户已登录
$amount = floatval($_POST['amount']);
$payment_method = $_POST['payment_method'];

// 验证金额
if ($amount <= 0) {
    die('充值金额必须大于0');
}

// 插入充值记录
$stmt = $db->prepare("INSERT INTO recharge_records (user_id, amount, status) VALUES (?, ?, 'pending')");
$stmt->execute([$user_id, $amount]);
$recharge_id = $db->lastInsertId();

// 调用支付接口
if ($payment_method === 'alipay') {
    // 调用支付宝接口逻辑
    header("Location: alipay_payment.php?recharge_id=$recharge_id&amount=$amount");
} elseif ($payment_method === 'wechat') {
    // 调用微信支付接口逻辑
    header("Location: wechat_payment.php?recharge_id=$recharge_id&amount=$amount");
}
?>

支付接口集成

根据选择的支付方式，集成相应的支付API。以支付宝为例：

// alipay_payment.php
require_once 'alipay_sdk.php';

$alipay = new Alipay();
$params = [
    'out_trade_no' => $_GET['recharge_id'],
    'total_amount' => $_GET['amount'],
    'subject' => '账户充值'
];

$payment_url = $alipay->createPayment($params);
header("Location: $payment_url");

回调处理

设置支付回调接口，处理支付结果并更新数据库状态：

// callback.php
$recharge_id = $_POST['out_trade_no'];
$status = ($_POST['trade_status'] === 'TRADE_SUCCESS') ? 'completed' : 'failed';

$stmt = $db->prepare("UPDATE recharge_records SET status = ? WHERE id = ?");
$stmt->execute([$status, $recharge_id]);

if ($status === 'completed') {
    // 更新用户余额
    $stmt = $db->prepare("UPDATE users SET balance = balance + ? WHERE id = ?");
    $stmt->execute([$_POST['total_amount'], $_POST['user_id']]);
}

echo 'success';