当前位置：首页 > PHP

php实现积分兑换

2026-02-15 20:17:02PHP

PHP实现积分兑换功能

积分兑换功能是许多网站和应用程序的常见需求，通常涉及用户账户积分的增减和商品兑换。以下是一个基本的PHP实现方案：

数据库设计

创建必要的数据库表来存储积分和兑换记录：

CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(50) NOT NULL,
    points INT DEFAULT 0
);

CREATE TABLE products (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(100) NOT NULL,
    points_required INT NOT NULL,
    stock INT NOT NULL
);

CREATE TABLE point_transactions (
    id INT PRIMARY KEY AUTO_INCREMENT,
    user_id INT NOT NULL,
    product_id INT,
    points_change INT NOT NULL,
    transaction_date TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (user_id) REFERENCES users(id),
    FOREIGN KEY (product_id) REFERENCES products(id)
);

积分兑换核心逻辑

function exchangePoints($userId, $productId) {
    $db = new PDO('mysql:host=localhost;dbname=your_database', 'username', 'password');

    // 开始事务
    $db->beginTransaction();

    try {
        // 获取用户当前积分
        $stmt = $db->prepare("SELECT points FROM users WHERE id = ?");
        $stmt->execute([$userId]);
        $user = $stmt->fetch(PDO::FETCH_ASSOC);

        // 获取商品信息
        $stmt = $db->prepare("SELECT points_required, stock FROM products WHERE id = ? FOR UPDATE");
        $stmt->execute([$productId]);
        $product = $stmt->fetch(PDO::FETCH_ASSOC);

        // 检查条件
        if (!$user || !$product) {
            throw new Exception("用户或商品不存在");
        }

        if ($user['points'] < $product['points_required']) {
            throw new Exception("积分不足");
        }

        if ($product['stock'] <= 0) {
            throw new Exception("商品库存不足");
        }

        // 扣除用户积分
        $newPoints = $user['points'] - $product['points_required'];
        $stmt = $db->prepare("UPDATE users SET points = ? WHERE id = ?");
        $stmt->execute([$newPoints, $userId]);

        // 减少商品库存
        $stmt = $db->prepare("UPDATE products SET stock = stock - 1 WHERE id = ?");
        $stmt->execute([$productId]);

        // 记录交易
        $stmt = $db->prepare("INSERT INTO point_transactions (user_id, product_id, points_change) VALUES (?, ?, ?)");
        $stmt->execute([$userId, $productId, -$product['points_required']]);

        // 提交事务
        $db->commit();

        return true;
    } catch (Exception $e) {
        $db->rollBack();
        return $e->getMessage();
    }
}

前端兑换界面示例

简单的HTML表单供用户兑换商品：

<form action="exchange.php" method="post">
    <input type="hidden" name="user_id" value="<?php echo $_SESSION['user_id']; ?>">
    <select name="product_id">
        <?php
        $products = $db->query("SELECT id, name, points_required FROM products WHERE stock > 0");
        foreach ($products as $product) {
            echo "<option value='{$product['id']}'>{$product['name']} ({$product['points_required']}积分)</option>";
        }
        ?>
    </select>
    <button type="submit">兑换</button>
</form>