当前位置：首页 > PHP

php 实现积分功能

2026-01-29 02:27:08PHP

实现积分功能的基本思路

积分功能通常涉及用户行为触发积分增减、积分记录存储、积分等级计算等模块。PHP 实现需要结合数据库操作和业务逻辑。

数据库设计

创建两张核心表存储积分数据：

用户积分表（user_points）：记录用户当前总积分

php 实现积分功能

CREATE TABLE user_points (
  user_id INT PRIMARY KEY,
  points INT DEFAULT 0,
  updated_at TIMESTAMP
);

积分记录表（points_log）：记录每次积分变动

CREATE TABLE points_log (
  id INT AUTO_INCREMENT PRIMARY KEY,
  user_id INT,
  points_change INT,
  action_type VARCHAR(50),
  remark TEXT,
  created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

积分增减逻辑实现

创建 PointsService 类处理核心逻辑：

php 实现积分功能

class PointsService {
    private $db;

    public function __construct($dbConnection) {
        $this->db = $dbConnection;
    }

    public function addPoints($userId, $points, $actionType, $remark = '') {
        // 开启事务
        $this->db->beginTransaction();

        try {
            // 更新用户总积分
            $stmt = $this->db->prepare(
                "INSERT INTO user_points (user_id, points, updated_at) 
                 VALUES (:user_id, :points, NOW()) 
                 ON DUPLICATE KEY UPDATE 
                 points = points + VALUES(points), 
                 updated_at = NOW()"
            );
            $stmt->execute([':user_id' => $userId, ':points' => $points]);

            // 记录积分日志
            $stmt = $this->db->prepare(
                "INSERT INTO points_log 
                 (user_id, points_change, action_type, remark) 
                 VALUES (:user_id, :points, :action_type, :remark)"
            );
            $stmt->execute([
                ':user_id' => $userId,
                ':points' => $points,
                ':action_type' => $actionType,
                ':remark' => $remark
            ]);

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

积分消费验证

实现积分消费前的余额检查：

public function consumePoints($userId, $points, $actionType, $remark = '') {
    // 先检查可用积分
    $stmt = $this->db->prepare(
        "SELECT points FROM user_points WHERE user_id = :user_id FOR UPDATE"
    );
    $stmt->execute([':user_id' => $userId]);
    $current = $stmt->fetch(PDO::FETCH_ASSOC);

    if (!$current || $current['points'] < $points) {
        throw new Exception("积分不足");
    }

    // 使用负数表示消费
    return $this->addPoints($userId, -$points, $actionType, $remark);
}

积分等级计算

根据业务需求实现等级规则：

public function getUserLevel($userId) {
    $stmt = $this->db->prepare(
        "SELECT points FROM user_points WHERE user_id = :user_id"
    );
    $stmt->execute([':user_id' => $userId]);
    $result = $stmt->fetch(PDO::FETCH_ASSOC);

    $points = $result['points'] ?? 0;

    // 示例等级规则
    if ($points >= 10000) return '钻石';
    if ($points >= 5000) return '黄金';
    if ($points >= 1000) return '白银';
    return '普通';
}

定时任务处理过期积分

创建处理过期积分的脚本：

// 每天执行一次的过期处理
public function expirePoints() {
    // 找出30天前的获得记录
    $stmt = $this->db->query(
        "SELECT user_id, SUM(points_change) as expiring 
         FROM points_log 
         WHERE created_at < DATE_SUB(NOW(), INTERVAL 30 DAY)
         AND points_change > 0
         GROUP BY user_id"
    );

    while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
        // 添加过期记录(负积分)
        $this->addPoints(
            $row['user_id'], 
            -$row['expiring'], 
            'points_expire',
            '积分过期扣除'
        );
    }
}