当前位置：首页 > PHP

PHP实现订单处理

2026-02-16 19:12:25PHP

订单处理流程设计

订单处理通常涉及创建、支付、发货、退款等环节。PHP实现需结合数据库操作（如MySQL）和业务逻辑，以下为关键实现步骤：

数据库表结构设计

创建订单相关表，例如：

CREATE TABLE orders (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT NOT NULL,
    order_number VARCHAR(50) UNIQUE,
    total_amount DECIMAL(10, 2),
    status ENUM('pending', 'paid', 'shipped', 'completed', 'refunded'),
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

CREATE TABLE order_items (
    id INT AUTO_INCREMENT PRIMARY KEY,
    order_id INT,
    product_id INT,
    quantity INT,
    price DECIMAL(10, 2),
    FOREIGN KEY (order_id) REFERENCES orders(id)
);

创建订单逻辑

通过表单或API接收数据，验证后写入数据库：

<?php
// 示例：接收POST数据
$userId = $_POST['user_id'];
$items = $_POST['items'];

// 计算总金额
$totalAmount = array_sum(array_map(function($item) {
    return $item['price'] * $item['quantity'];
}, $items));

// 插入订单主表
$orderNumber = 'ORD' . time() . rand(100, 999);
$stmt = $pdo->prepare("INSERT INTO orders (user_id, order_number, total_amount, status) VALUES (?, ?, ?, 'pending')");
$stmt->execute([$userId, $orderNumber, $totalAmount]);
$orderId = $pdo->lastInsertId();

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

支付回调处理

集成支付接口（如支付宝、微信支付），处理异步通知：

<?php
// 示例：验证支付回调
$paymentData = $_POST;
$orderNumber = $paymentData['out_trade_no'];

// 验证签名和订单状态
$stmt = $pdo->prepare("SELECT id FROM orders WHERE order_number = ? AND status = 'pending'");
$stmt->execute([$orderNumber]);
$order = $stmt->fetch();

if ($order && verifyPaymentSignature($paymentData)) {
    $pdo->prepare("UPDATE orders SET status = 'paid' WHERE id = ?")->execute([$order['id']]);
    echo 'SUCCESS'; // 通知支付平台处理成功
}
?>

订单状态管理

通过后台或定时任务更新状态（如发货、退款）：

PHP实现订单处理

<?php
// 示例：标记订单为已发货
function shipOrder($orderId) {
    global $pdo;
    $pdo->prepare("UPDATE orders SET status = 'shipped' WHERE id = ? AND status = 'paid'")->execute([$orderId]);
}
?>