当前位置：首页 > PHP

php实现分销

2026-04-03 06:33:49PHP

PHP实现分销系统的基本方法

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

数据库设计

创建必要的表结构存储分销关系：

CREATE TABLE `users` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `username` varchar(50) NOT NULL,
  `parent_id` int(11) DEFAULT NULL COMMENT '上级ID',
  `level` tinyint(4) DEFAULT '1' COMMENT '分销层级',
  PRIMARY KEY (`id`)
);

CREATE TABLE `orders` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `user_id` int(11) NOT NULL,
  `amount` decimal(10,2) NOT NULL,
  `status` tinyint(4) DEFAULT '0' COMMENT '0未支付 1已支付',
  PRIMARY KEY (`id`)
);

CREATE TABLE `commission` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `order_id` int(11) NOT NULL,
  `user_id` int(11) NOT NULL,
  `amount` decimal(10,2) NOT NULL,
  `level` tinyint(4) NOT NULL COMMENT '佣金层级',
  `status` tinyint(4) DEFAULT '0' COMMENT '0未结算 1已结算',
  PRIMARY KEY (`id`)
);

用户关系绑定

处理用户注册时的上下级关系：

function bindParent($userId, $parentId) {
    $parent = getUserById($parentId);
    if (!$parent) return false;

    $level = $parent['level'] + 1;
    $sql = "UPDATE users SET parent_id = ?, level = ? WHERE id = ?";
    executeQuery($sql, [$parentId, $level, $userId]);

    return true;
}

佣金计算逻辑

实现多级佣金分配：

function calculateCommission($orderId) {
    $order = getOrderById($orderId);
    if ($order['status'] != 1) return false;

    $user = getUserById($order['user_id']);
    $commissionRates = [0.1, 0.05, 0.03]; // 三级佣金比例

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

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

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

        $currentUser = $parent;
    }

    return true;
}

佣金结算处理

定期处理已完成的佣金：

function settleCommissions() {
    $sql = "UPDATE commission SET status = 1 
            WHERE status = 0 AND order_id IN 
            (SELECT id FROM orders WHERE status = 1)";
    executeQuery($sql);

    $sql = "SELECT c.user_id, SUM(c.amount) as total 
            FROM commission c 
            WHERE c.status = 1 
            GROUP BY c.user_id";
    $results = fetchAll($sql);

    foreach ($results as $row) {
        // 实际打款操作
        transferToUser($row['user_id'], $row['total']);
    }
}

前端展示

用户佣金查询接口：

php实现分销

function getUserCommission($userId) {
    $sql = "SELECT c.*, o.amount as order_amount 
            FROM commission c 
            JOIN orders o ON c.order_id = o.id 
            WHERE c.user_id = ?";
    return fetchAll($sql, [$userId]);
}