<?php
/**
 * Если пришёл по реферальной ссылке
 */
$extra_param = $this->getMessage()->getText(true); // Получаем родителя
$is_referrer = $pdo->query("SELECT * FROM `referrals` WHERE `referrer_id` = {$user_id} LIMIT 1"); // Проверяем, есть ли реферер с таким ID в базе

if ((isset($extra_param) && is_numeric($extra_param)) && $is_referrer->rowCount() === 0) {
    /**
     * Если такой пользователь существует и это не сам реферер
     */
    $user = $pdo->query("SELECT * FROM `user` WHERE `id` = {$extra_param} LIMIT 1");
    if ($user->rowCount() !== 0 && $user_id != $extra_param) {
        $pdo->query("INSERT INTO `referrals` (`user_id`, `referrer_id`) VALUES ({$extra_param}, {$user_id})"); // Добавляем в базу реферов
        $pdo->query("UPDATE `users` SET `amount` = (`amount` + 1) WHERE `id` = {$extra_param} LIMIT 1"); // Начисляем 1$ родителю

        /**
         * TODO: Поиск рефералов вплоть до пятого уровня и начисление отдельного баланса каждому
         */
    }
}