当前位置：首页 > PHP

php实现订单

2026-01-30 02:55:16PHP

PHP实现订单系统

在PHP中实现订单系统需要考虑数据库设计、订单处理逻辑、用户界面交互等多个方面。以下是一个基本的实现方案：

数据库设计

创建订单相关的数据表结构：

CREATE TABLE orders (
    order_id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT NOT NULL,
    order_date DATETIME NOT NULL,
    total_amount DECIMAL(10,2) NOT NULL,
    status VARCHAR(20) NOT NULL,
    payment_method VARCHAR(50),
    shipping_address TEXT
);

CREATE TABLE order_items (
    item_id INT AUTO_INCREMENT PRIMARY KEY,
    order_id INT NOT NULL,
    product_id INT NOT NULL,
    quantity INT NOT NULL,
    unit_price DECIMAL(10,2) NOT NULL,
    FOREIGN KEY (order_id) REFERENCES orders(order_id)
);

订单创建逻辑

处理用户提交订单的PHP代码示例：

<?php
// 连接数据库
$db = new PDO('mysql:host=localhost;dbname=shop', 'username', 'password');

// 获取购物车数据
$cartItems = $_SESSION['cart'];
$userId = $_SESSION['user_id'];

// 计算总金额
$totalAmount = 0;
foreach ($cartItems as $item) {
    $totalAmount += $item['price'] * $item['quantity'];
}

// 开始事务
$db->beginTransaction();

try {
    // 插入订单主表
    $stmt = $db->prepare("INSERT INTO orders (user_id, order_date, total_amount, status) 
                         VALUES (?, NOW(), ?, 'pending')");
    $stmt->execute([$userId, $totalAmount]);
    $orderId = $db->lastInsertId();

    // 插入订单明细
    $stmt = $db->prepare("INSERT INTO order_items (order_id, product_id, quantity, unit_price) 
                         VALUES (?, ?, ?, ?)");
    foreach ($cartItems as $item) {
        $stmt->execute([$orderId, $item['product_id'], $item['quantity'], $item['price']]);
    }

    // 清空购物车
    unset($_SESSION['cart']);

    // 提交事务
    $db->commit();

    // 返回成功响应
    echo json_encode(['success' => true, 'order_id' => $orderId]);
} catch (Exception $e) {
    // 回滚事务
    $db->rollBack();
    echo json_encode(['success' => false, 'error' => $e->getMessage()]);
}
?>

订单状态管理

实现订单状态更新功能：

function updateOrderStatus($orderId, $newStatus) {
    $db = new PDO('mysql:host=localhost;dbname=shop', 'username', 'password');

    $stmt = $db->prepare("UPDATE orders SET status = ? WHERE order_id = ?");
    $result = $stmt->execute([$newStatus, $orderId]);

    return $result ? true : false;
}

订单查询功能

获取用户订单列表：

function getUserOrders($userId) {
    $db = new PDO('mysql:host=localhost;dbname=shop', 'username', 'password');

    $stmt = $db->prepare("SELECT * FROM orders WHERE user_id = ? ORDER BY order_date DESC");
    $stmt->execute([$userId]);

    return $stmt->fetchAll(PDO::FETCH_ASSOC);
}

function getOrderDetails($orderId) {
    $db = new PDO('mysql:host=localhost;dbname=shop', 'username', 'password');

    // 获取订单基本信息
    $stmt = $db->prepare("SELECT * FROM orders WHERE order_id = ?");
    $stmt->execute([$orderId]);
    $order = $stmt->fetch(PDO::FETCH_ASSOC);

    // 获取订单商品明细
    $stmt = $db->prepare("SELECT oi.*, p.product_name 
                         FROM order_items oi 
                         JOIN products p ON oi.product_id = p.product_id
                         WHERE oi.order_id = ?");
    $stmt->execute([$orderId]);
    $items = $stmt->fetchAll(PDO::FETCH_ASSOC);

    return ['order' => $order, 'items' => $items];
}