当前位置：首页 > PHP

php 实现积分功能

2026-04-03 08:20:42PHP

PHP 实现积分功能

数据库设计

创建数据库表存储用户积分信息，通常包含用户ID、积分值、积分变动记录等字段。示例表结构：

CREATE TABLE user_points (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT NOT NULL,
    points INT DEFAULT 0,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    FOREIGN KEY (user_id) REFERENCES users(id)
);

CREATE TABLE point_logs (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT NOT NULL,
    points_change INT NOT NULL,
    reason VARCHAR(255),
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (user_id) REFERENCES users(id)
);

积分增减操作

封装积分操作函数，确保事务安全：

php 实现积分功能

function addPoints($userId, $points, $reason = '') {
    $db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');
    $db->beginTransaction();

    try {
        // 更新用户总积分
        $stmt = $db->prepare("UPDATE user_points SET points = points + ? WHERE user_id = ?");
        $stmt->execute([$points, $userId]);

        // 记录积分变动日志
        $stmt = $db->prepare("INSERT INTO point_logs (user_id, points_change, reason) VALUES (?, ?, ?)");
        $stmt->execute([$userId, $points, $reason]);

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

积分查询

实现积分查询功能：

php 实现积分功能

function getUserPoints($userId) {
    $db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');
    $stmt = $db->prepare("SELECT points FROM user_points WHERE user_id = ?");
    $stmt->execute([$userId]);
    return $stmt->fetchColumn();
}

积分兑换

实现积分兑换商品或服务：

function redeemPoints($userId, $requiredPoints, $itemId) {
    $currentPoints = getUserPoints($userId);

    if ($currentPoints < $requiredPoints) {
        return false;
    }

    $db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');
    $db->beginTransaction();

    try {
        // 扣除积分
        $stmt = $db->prepare("UPDATE user_points SET points = points - ? WHERE user_id = ?");
        $stmt->execute([$requiredPoints, $userId]);

        // 记录兑换日志
        $stmt = $db->prepare("INSERT INTO point_logs (user_id, points_change, reason) VALUES (?, ?, ?)");
        $stmt->execute([$userId, -$requiredPoints, "兑换商品ID: $itemId"]);

        // 处理商品发放逻辑
        // ...

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

积分排行榜

实现积分排行榜功能：

function getPointsRanking($limit = 10) {
    $db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');
    $stmt = $db->prepare("SELECT u.username, up.points 
                         FROM user_points up
                         JOIN users u ON up.user_id = u.id
                         ORDER BY up.points DESC
                         LIMIT ?");
    $stmt->execute([$limit]);
    return $stmt->fetchAll(PDO::FETCH_ASSOC);
}