PHP项目怎么实现购物车功能？

wen java案例 2026-07-24 1

PHP购物车功能实现指南：从基础到高阶的全栈解决方案

📌 目录导读

购物车功能的核心需求分析
基于Session的临时购物车实现（初学者首选）
基于数据库的持久化购物车方案（进阶）
购物车增删改查完整代码示例（含MySQL）
购物车价格计算与库存校验
常见问题FAQ（含问答）
SEO优化建议与性能注意事项

购物车功能的核心需求分析

在电商项目中,购物车是用户下单前的“暂存区”，根据搜索引擎收录的众多PHP教程总结，一个完整的购物车需要满足：

PHP项目怎么实现购物车功能？

临时存储：未登录用户也能使用（Session方案）
持久存储：用户登录后数据不丢失（数据库方案）
实时统计：商品数量、总价、优惠计算
库存校验：下单前验证商品是否仍有库存
合并机制：用户登录时合并Session与数据库购物车

❓ 问：为什么需要两种方案？
✅ 答：Session方案简单适合原型，但用户清空缓存或登录后数据丢失；数据库方案安全可靠但需额外开发。最优实践是在用户登录后，将Session购物车合并到数据库。

基于Session的临时购物车实现

1 数据结构设计（伪代码）

$_SESSION['cart'] = [
    'product_id_1' => ['qty'=>2, 'price'=>99.00, 'name'=>'商品A'],
    'product_id_2' => ['qty'=>1, 'price'=>149.00, 'name'=>'商品B']
];

键：商品ID（唯一标识）
值：包含数量(qty)、单价(price)、名称(name)

2 添加购物车函数

function addToCart($productId, $quantity = 1) {
    session_start();
    if (!isset($_SESSION['cart'])) $_SESSION['cart'] = [];
    // 从数据库获取商品信息（简写）
    $product = getProductById($productId); 
    if (isset($_SESSION['cart'][$productId])) {
        $_SESSION['cart'][$productId]['qty'] += $quantity;
    } else {
        $_SESSION['cart'][$productId] = [
            'qty' => $quantity,
            'price' => $product['price'],
            'name' => $product['name']
        ];
    }
    // 可选：限制数量
    if ($_SESSION['cart'][$productId]['qty'] > $product['stock']) {
        $_SESSION['cart'][$productId]['qty'] = $product['stock'];
    }
    return true;
}

3 更新与删除

function updateCartQty($productId, $newQty) {
    if ($newQty <= 0) {
        unset($_SESSION['cart'][$productId]);
    } else {
        $_SESSION['cart'][$productId]['qty'] = $newQty;
    }
}

❓ 问：Session购物车的最大缺陷是什么？
✅ 答：1) 用户关闭浏览器或session过期后购物车丢失；2) 无法在不同设备间同步；3) 不利于做数据分析（放弃率等）。

基于数据库的持久化购物车方案

1 数据库表设计

CREATE TABLE `carts` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` int(11) NOT NULL,          -- 关联用户
  `product_id` int(11) NOT NULL,
  `quantity` int(11) NOT NULL DEFAULT 1,
  `created_at` timestamp DEFAULT CURRENT_TIMESTAMP,
  `updated_at` timestamp DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  UNIQUE KEY `unique_user_product` (`user_id`,`product_id`)
);

使用UNIQUE KEY避免同一用户添加同一商品时出现重复行，直接更新数量。

2 核心CRUD函数（PDO示例）

添加/更新商品

function addToCartDB($userId, $productId, $qty) {
    $pdo = getDBConnection(); // 你的PDO连接
    $stmt = $pdo->prepare("INSERT INTO carts (user_id, product_id, quantity) 
                           VALUES (?, ?, ?) 
                           ON DUPLICATE KEY UPDATE quantity = quantity + VALUES(quantity)");
    return $stmt->execute([$userId, $productId, $qty]);
}

获取购物车列表

function getCartItems($userId) {
    $sql = "SELECT c.*, p.name, p.price, p.stock 
            FROM carts c 
            JOIN products p ON c.product_id = p.id 
            WHERE c.user_id = ?";
    $stmt = $pdo->prepare($sql);
    $stmt->execute([$userId]);
    return $stmt->fetchAll(PDO::FETCH_ASSOC);
}

❓ 问：为什么使用ON DUPLICATE KEY UPDATE而不是先查询再判断？
✅ 答：避免二次查询，原子操作，防止并发时数据不一致，这是数据库层面的“UPSERT”操作。

购物车页面完整示例（PHP+MySQL）

1 显示购物车列表

<?php session_start(); ?>
<table>
    <thead>
        <tr>
            <th>商品</th>
            <th>单价</th>
            <th>数量</th>
            <th>小计</th>
            <th>操作</th>
        </tr>
    </thead>
    <tbody>
    <?php
    $userId = $_SESSION['user_id'] ?? null;
    // 判断使用Session还是数据库
    if ($userId) {
        $cartItems = getCartItems($userId); // 数据库方案
    } else {
        $cartItems = $_SESSION['cart'] ?? []; // 转换为数组遍历
    }
    $total = 0;
    foreach ($cartItems as $item): 
        $subtotal = $item['price'] * $item['qty'];
        $total += $subtotal;
    ?>
        <tr>
            <td><?= htmlspecialchars($item['name']) ?></td>
            <td>¥<?= number_format($item['price'],2) ?></td>
            <td>
                <input type="number" value="<?= $item['qty'] ?>" 
                       onchange="updateQty(<?= $item['product_id'] ?>, this.value)">
            </td>
            <td>¥<?= number_format($subtotal,2) ?></td>
            <td><a href="cart.php?action=remove&id=<?= $item['product_id'] ?>">删除</a></td>
        </tr>
    <?php endforeach; ?>
    </tbody>
</table>
<p>总计：¥<?= number_format($total,2) ?></p>

2 删除与清空接口

if ($_GET['action'] == 'remove' && isset($_GET['id'])) {
    removeCartItem($userId ?? null, $_GET['id']);
    header('Location: cart.php');
    exit;
}
function removeCartItem($userId, $productId) {
    if ($userId) {
        $pdo->prepare("DELETE FROM carts WHERE user_id=? AND product_id=?")->execute([$userId, $productId]);
    } else {
        unset($_SESSION['cart'][$productId]);
    }
}

❓ 问：如何处理用户登录时Session购物车与数据库购物车合并？
✅ 答：在登录成功回调中，遍历$_SESSION['cart']，对每个商品调用addToCartDB($userId, $id, $qty)，然后清空Session购物车。

购物车价格计算与库存校验

1 实时计算总价

前端：使用AJAX异步请求PHP接口，更新总金额

后端：严禁相信前端传来的总价，必须在服务器端重新计算：

function calculateTotal($cartItems) {
  $total = 0;
  foreach ($cartItems as $item) {
      $total += $item['price'] * $item['qty'];
  }
  // 可在此应用优惠券折扣
  return $total;
}

2 库存校验（下单前必做）

function checkStock($cartItems) {
    foreach ($cartItems as $item) {
        $product = getProductById($item['product_id']);
        if ($item['qty'] > $product['stock']) {
            throw new Exception("{$item['name']} 库存不足，仅有 {$product['stock']} 件");
        }
    }
    return true;
}