当前位置：首页 > PHP

php商城积分实现

2026-02-15 12:57:05PHP

PHP商城积分系统实现

积分系统是电商平台常见的用户激励手段，通过消费、签到、评价等行为获取积分，积分可兑换商品或抵扣现金。以下是基于PHP的商城积分系统核心实现方案。

数据库设计

积分系统需设计以下核心表结构：

CREATE TABLE `user_points` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` int(11) NOT NULL COMMENT '用户ID',
  `points` int(11) NOT NULL DEFAULT '0' COMMENT '可用积分',
  `frozen_points` int(11) NOT NULL DEFAULT '0' COMMENT '冻结积分',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  `updated_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `user_id` (`user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

CREATE TABLE `points_log` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` int(11) NOT NULL,
  `points` int(11) NOT NULL COMMENT '变动积分',
  `type` tinyint(4) NOT NULL COMMENT '1获得 2消耗',
  `source` varchar(20) NOT NULL COMMENT '来源',
  `remark` varchar(255) DEFAULT NULL COMMENT '备注',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  KEY `user_id` (`user_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

积分增减逻辑

封装积分服务类处理核心业务逻辑：

class PointsService {
    // 增加积分
    public static function addPoints($userId, $points, $source, $remark = '') {
        DB::beginTransaction();
        try {
            // 更新用户积分
            $affected = DB::table('user_points')
                ->where('user_id', $userId)
                ->increment('points', $points);

            if (!$affected) {
                DB::table('user_points')->insert([
                    'user_id' => $userId,
                    'points' => $points
                ]);
            }

            // 记录日志
            DB::table('points_log')->insert([
                'user_id' => $userId,
                'points' => $points,
                'type' => 1,
                'source' => $source,
                'remark' => $remark,
                'created_at' => now()
            ]);

            DB::commit();
            return true;
        } catch (\Exception $e) {
            DB::rollBack();
            return false;
        }
    }

    // 消耗积分
    public static function consumePoints($userId, $points, $source, $remark = '') {
        DB::beginTransaction();
        try {
            $affected = DB::table('user_points')
                ->where('user_id', $userId)
                ->where('points', '>=', $points)
                ->decrement('points', $points);

            if (!$affected) {
                throw new \Exception('积分不足');
            }

            DB::table('points_log')->insert([
                'user_id' => $userId,
                'points' => $points,
                'type' => 2,
                'source' => $source,
                'remark' => $remark,
                'created_at' => now()
            ]);

            DB::commit();
            return true;
        } catch (\Exception $e) {
            DB::rollBack();
            return false;
        }
    }
}

积分规则配置

在配置文件中定义积分获取规则：

// config/points.php
return [
    'rules' => [
        'register' => 100, // 注册赠送
        'login' => 10,     // 每日登录
        'order' => [
            'base' => 1,   // 每元获得积分
            'max' => 1000  // 单笔订单上限
        ],
        'review' => 20     // 评价商品
    ],
    'expire' => 365 // 积分有效期(天)
];

订单积分处理

订单支付完成时调用积分发放：

class OrderService {
    public function completeOrder($orderId) {
        $order = Order::find($orderId);
        $points = min(
            $order->amount * config('points.rules.order.base'),
            config('points.rules.order.max')
        );

        PointsService::addPoints(
            $order->user_id,
            $points,
            'order',
            '订单完成: '.$order->order_no
        );
    }
}

积分兑换实现

前端提交兑换请求时处理：

class PointsController extends Controller {
    public function exchange(Request $request) {
        $product = Product::find($request->product_id);
        if (PointsService::consumePoints(
            auth()->id(),
            $product->exchange_points,
            'exchange',
            '兑换商品: '.$product->name
        )) {
            // 生成兑换订单
            ExchangeOrder::create([
                'user_id' => auth()->id(),
                'product_id' => $product->id,
                'points' => $product->exchange_points,
                'status' => 1
            ]);
            return response()->json(['success' => true]);
        }
        return response()->json(['error' => '积分不足'], 400);
    }
}