当前位置：首页 > PHP

php实现团购

2026-02-16 15:49:27PHP

PHP实现团购功能

团购功能需要实现用户下单、库存管理、订单处理等核心模块。以下是实现团购功能的关键步骤：

数据库设计 创建必要的数据库表结构，包括商品表、订单表、用户表等。

CREATE TABLE `group_buy` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `product_id` int(11) NOT NULL,
  `title` varchar(255) NOT NULL,
  `price` decimal(10,2) NOT NULL,
  `group_price` decimal(10,2) NOT NULL,
  `start_time` datetime NOT NULL,
  `end_time` datetime NOT NULL,
  `min_people` int(11) NOT NULL,
  `max_people` int(11) NOT NULL,
  `current_people` int(11) NOT NULL DEFAULT 0,
  `status` tinyint(1) NOT NULL DEFAULT 0,
  PRIMARY KEY (`id`)
);

CREATE TABLE `group_orders` (
  `order_id` varchar(32) NOT NULL,
  `group_id` int(11) NOT NULL,
  `user_id` int(11) NOT NULL,
  `quantity` int(11) NOT NULL,
  `total_price` decimal(10,2) NOT NULL,
  `order_time` datetime NOT NULL,
  `payment_status` tinyint(1) NOT NULL DEFAULT 0,
  PRIMARY KEY (`order_id`)
);

团购商品展示 在商品页面显示团购信息和参与人数。

function getGroupBuyInfo($product_id) {
    $sql = "SELECT * FROM group_buy WHERE product_id = ? AND end_time > NOW()";
    $stmt = $pdo->prepare($sql);
    $stmt->execute([$product_id]);
    return $stmt->fetch(PDO::FETCH_ASSOC);
}

团购下单逻辑 处理用户下单请求，检查团购状态和库存。

php实现团购

function createGroupOrder($user_id, $group_id, $quantity) {
    // 检查团购状态
    $group = getGroupInfo($group_id);
    if(!$group || $group['status'] != 1) {
        return ['code' => 0, 'msg' => '团购已结束'];
    }

    // 生成订单号
    $order_id = generateOrderId();

    // 计算总价
    $total_price = $group['group_price'] * $quantity;

    // 创建订单
    $sql = "INSERT INTO group_orders VALUES (?, ?, ?, ?, ?, NOW(), 0)";
    $stmt = $pdo->prepare($sql);
    $stmt->execute([$order_id, $group_id, $user_id, $quantity, $total_price]);

    // 更新参与人数
    updateGroupPeople($group_id, $quantity);

    return ['code' => 1, 'order_id' => $order_id];
}

团购状态更新 定时检查团购状态，达到人数时标记为成功。

function checkGroupStatus() {
    $sql = "SELECT id FROM group_buy 
            WHERE status = 0 
            AND end_time <= NOW() 
            AND current_people >= min_people";
    $groups = $pdo->query($sql)->fetchAll();

    foreach($groups as $group) {
        $pdo->exec("UPDATE group_buy SET status = 1 WHERE id = {$group['id']}");
        notifyGroupSuccess($group['id']);
    }

    // 处理失败的团购
    $sql = "SELECT id FROM group_buy 
            WHERE status = 0 
            AND end_time <= NOW() 
            AND current_people < min_people";
    $groups = $pdo->query($sql)->fetchAll();

    foreach($groups as $group) {
        $pdo->exec("UPDATE group_buy SET status = 2 WHERE id = {$group['id']}");
        refundFailedGroup($group['id']);
    }
}

支付回调处理 处理支付成功后的回调逻辑。

php实现团购

function paymentCallback($order_id) {
    // 验证订单
    $order = getOrderInfo($order_id);
    if(!$order || $order['payment_status'] == 1) {
        return false;
    }

    // 更新订单状态
    $pdo->exec("UPDATE group_orders SET payment_status = 1 WHERE order_id = '$order_id'");

    // 检查团购是否完成
    $group = getGroupInfo($order['group_id']);
    if($group['current_people'] >= $group['min_people']) {
        processGroupSuccess($order['group_id']);
    }

    return true;
}

关键注意事项

并发控制 团购场景下需要特别注意并发问题，特别是库存和参与人数的更新。

function updateGroupPeople($group_id, $quantity) {
    $pdo->beginTransaction();
    try {
        $sql = "SELECT current_people FROM group_buy WHERE id = ? FOR UPDATE";
        $stmt = $pdo->prepare($sql);
        $stmt->execute([$group_id]);
        $current = $stmt->fetchColumn();

        $new = $current + $quantity;
        $sql = "UPDATE group_buy SET current_people = ? WHERE id = ?";
        $stmt = $pdo->prepare($sql);
        $stmt->execute([$new, $group_id]);

        $pdo->commit();
    } catch(Exception $e) {
        $pdo->rollBack();
        throw $e;
    }
}

性能优化 对于高并发场景，可以采用以下优化措施：