当前位置：首页 > PHP

php实现分销

2026-02-27 21:49:33PHP

PHP实现分销系统的基本思路

分销系统通常涉及多级佣金计算、用户关系管理和订单跟踪。以下是实现分销系统的核心模块和代码示例。

数据库设计

创建必要的表结构存储用户关系和佣金记录：

php实现分销

CREATE TABLE users (
    id INT PRIMARY KEY AUTO_INCREMENT,
    username VARCHAR(50),
    parent_id INT NULL,
    level INT DEFAULT 0
);

CREATE TABLE orders (
    id INT PRIMARY KEY AUTO_INCREMENT,
    user_id INT,
    amount DECIMAL(10,2),
    status VARCHAR(20)
);

CREATE TABLE commissions (
    id INT PRIMARY KEY AUTO_INCREMENT,
    order_id INT,
    user_id INT,
    level INT,
    amount DECIMAL(10,2),
    status VARCHAR(20)
);

用户关系处理

当新用户注册时建立分销关系：

function registerUser($username, $referralId = null) {
    $level = 0;
    if ($referralId) {
        $referrer = getUserById($referralId);
        $level = $referrer['level'] + 1;
    }

    $sql = "INSERT INTO users (username, parent_id, level) VALUES (?, ?, ?)";
    executeQuery($sql, [$username, $referralId, $level]);
}

佣金计算逻辑

订单完成时计算各级分销佣金：

php实现分销

function calculateCommissions($orderId) {
    $order = getOrderById($orderId);
    $user = getUserById($order['user_id']);

    $commissionRates = [0.3, 0.2, 0.1]; // 三级分销比例

    $currentUser = $user;
    for ($level = 0; $level < count($commissionRates); $level++) {
        if (!$currentUser['parent_id']) break;

        $parent = getUserById($currentUser['parent_id']);
        $commission = $order['amount'] * $commissionRates[$level];

        $sql = "INSERT INTO commissions (order_id, user_id, level, amount, status) 
                VALUES (?, ?, ?, ?, 'pending')";
        executeQuery($sql, [$orderId, $parent['id'], $level+1, $commission]);

        $currentUser = $parent;
    }
}

佣金结算处理

定期执行佣金结算：

function settleCommissions() {
    $sql = "UPDATE commissions SET status = 'paid' 
            WHERE status = 'pending' AND created_at < DATE_SUB(NOW(), INTERVAL 7 DAY)";
    executeQuery($sql);
}

分销网络查询

获取用户的分销网络：

function getDownline($userId, $depth = 3) {
    $downline = [];
    $queue = [[$userId, 0]];

    while (!empty($queue)) {
        list($currentId, $currentLevel) = array_shift($queue);

        if ($currentLevel >= $depth) continue;

        $children = getChildren($currentId);
        foreach ($children as $child) {
            $downline[] = [
                'user' => $child,
                'level' => $currentLevel + 1
            ];
            array_push($queue, [$child['id'], $currentLevel + 1]);
        }
    }

    return $downline;
}