php实现商品批发

PHP实现商品批发的核心逻辑

商品批发功能通常涉及批量价格计算、订单处理和数据展示。以下是实现的关键步骤：

数据库表设计

创建商品表和批发价格规则表是基础。商品表存储基本信息，批发价格规则表定义不同数量的价格阶梯。

商品表结构示例：

CREATE TABLE products (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255),
    retail_price DECIMAL(10,2),
    description TEXT
);

批发规则表结构：

CREATE TABLE wholesale_rules (
    id INT AUTO_INCREMENT PRIMARY KEY,
    product_id INT,
    min_quantity INT,
    unit_price DECIMAL(10,2),
    FOREIGN KEY (product_id) REFERENCES products(id)
);

批发价格计算逻辑

通过查询批发规则表实现动态价格计算。根据购买数量匹配对应的价格阶梯。

function calculateWholesalePrice($productId, $quantity) {
    $db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');

    // 获取所有适用于该商品的批发规则，按数量降序排列
    $stmt = $db->prepare("
        SELECT * FROM wholesale_rules 
        WHERE product_id = :product_id AND min_quantity <= :quantity
        ORDER BY min_quantity DESC
        LIMIT 1
    ");
    $stmt->execute([':product_id' => $productId, ':quantity' => $quantity]);
    $rule = $stmt->fetch(PDO::FETCH_ASSOC);

    if ($rule) {
        return $quantity * $rule['unit_price'];
    } else {
        // 没有批发规则则使用零售价
        $stmt = $db->prepare("SELECT retail_price FROM products WHERE id = :product_id");
        $stmt->execute([':product_id' => $productId]);
        $product = $stmt->fetch(PDO::FETCH_ASSOC);
        return $quantity * $product['retail_price'];
    }
}

前端交互实现

使用JavaScript实现实时价格计算，提升用户体验。

<div class="product">
    <h3><?php echo $product['name']; ?></h3>
    <input type="number" id="quantity" min="1" value="1">
    <button onclick="calculatePrice(<?php echo $product['id']; ?>)">计算批发价</button>
    <div id="priceResult"></div>
</div>

<script>
function calculatePrice(productId) {
    const quantity = document.getElementById('quantity').value;
    fetch(`calculate_price.php?product_id=${productId}&quantity=${quantity}`)
        .then(response => response.json())
        .then(data => {
            document.getElementById('priceResult').innerHTML = 
                `总价: ${data.total_price}`;
        });
}
</script>

后端价格计算接口

创建独立的PHP接口处理价格计算请求。

// calculate_price.php
header('Content-Type: application/json');

$productId = $_GET['product_id'] ?? 0;
$quantity = $_GET['quantity'] ?? 1;

$totalPrice = calculateWholesalePrice($productId, $quantity);

echo json_encode([
    'product_id' => $productId,
    'quantity' => $quantity,
    'total_price' => number_format($totalPrice, 2)
]);

批量订单处理

批发订单通常包含多个商品和大量数量，需要特殊处理。

function createWholesaleOrder($customerId, $items) {
    $db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');

    try {
        $db->beginTransaction();

        // 创建订单主记录
        $stmt = $db->prepare("
            INSERT INTO orders (customer_id, order_date, status) 
            VALUES (:customer_id, NOW(), 'pending')
        ");
        $stmt->execute([':customer_id' => $customerId]);
        $orderId = $db->lastInsertId();

        // 添加订单明细
        foreach ($items as $item) {
            $price = calculateWholesalePrice($item['product_id'], $item['quantity']);

            $stmt = $db->prepare("
                INSERT INTO order_items (order_id, product_id, quantity, unit_price)
                VALUES (:order_id, :product_id, :quantity, :unit_price)
            ");
            $stmt->execute([
                ':order_id' => $orderId,
                ':product_id' => $item['product_id'],
                ':quantity' => $item['quantity'],
                ':unit_price' => $price / $item['quantity']
            ]);
        }

        $db->commit();
        return $orderId;
    } catch (Exception $e) {
        $db->rollBack();
        throw $e;
    }
}

数据可视化展示

为批发商提供销售数据统计视图，辅助决策。

function getWholesaleSalesReport($startDate, $endDate) {
    $db = new PDO('mysql:host=localhost;dbname=your_db', 'username', 'password');

    $stmt = $db->prepare("
        SELECT p.name, SUM(oi.quantity) as total_quantity, 
               SUM(oi.quantity * oi.unit_price) as total_revenue
        FROM order_items oi
        JOIN orders o ON oi.order_id = o.id
        JOIN products p ON oi.product_id = p.id
        WHERE o.order_date BETWEEN :start_date AND :end_date
        GROUP BY oi.product_id
        ORDER BY total_revenue DESC
    ");
    $stmt->execute([
        ':start_date' => $startDate,
        ':end_date' => $endDate
    ]);

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

以上实现涵盖了商品批发系统的主要功能模块，可根据实际需求进行调整和扩展。重点在于批发规则管理、批量价格计算和高效订单处理。数据库优化和缓存策略对大批量数据处理尤为重要。