<?php

namespace Api;

use Core\DB;
use Exception;

class ReferralController 
{

    public function handle_partner_id($request)
    {
        $partnerId = $request['partner_id'] ?? null;
        if ($partnerId === null || $partnerId === '') {
            return null;
        }

        $db = new DB();
        $connection = $db->getConnection(); // mysqli

        $sql = "
        INSERT INTO referral_visits (referral_id)
        SELECT r.id
        FROM referrals r
        WHERE r.partner_id = ?
        LIMIT 1
    ";

        $stmt = $connection->prepare($sql);
        if (!$stmt) {
            throw new Exception("Prepare failed: " . $connection->error);
        }

        $stmt->bind_param("s", $partnerId);

        if (!$stmt->execute()) {
            throw new Exception("Execute failed: " . $stmt->error);
        }

        if ($stmt->affected_rows === 1) {
            $visitId = $connection->insert_id;
            $stmt->close();
            return $visitId ?: null;
        }

        $stmt->close();
        return null;
    }
}