<?php

namespace Api;
use Core\DB;

abstract class BaseController {
    protected ?int $request_id = null;

    public function __construct(?int $request_id = null) {
        $this->request_id = $request_id;
    }

    private function log($message)
    {
        $message = mb_convert_encoding($message, 'UTF-8', 'auto');
        file_put_contents(__DIR__ . '/../../app.log', date('Y-m-d H:i:s') . " | MESSAGE: " . $message . PHP_EOL, FILE_APPEND);
    }

    public function getRequestId(): ?int {
     return $this->request_id;
    }

    public function addPolicyIdToRequest(int $policy_id): ?bool
    {
        $visit_id = $this->request_id;

        if ($visit_id === null || $visit_id <= 0 || $policy_id <= 0) {
            return null;
        }

        $connection = $this->connection ?? (new DB())->getConnection();

        $query = "UPDATE referral_visits SET policy_id = ? WHERE id = ?";
        $stmt = $connection->prepare($query);

        if (!$stmt) {
            $this->log("Prepare failed in addPolicyIdToRequest: " . $connection->error);
            return false;
        }

        $stmt->bind_param("ii", $policy_id, $visit_id);

        if (!$stmt->execute()) {
            $this->log("Execute failed in addPolicyIdToRequest: " . $stmt->error);
            $stmt->close();
            return false;
        }

        if ($stmt->affected_rows === 0) {
            $this->log("No rows updated for visit_id={$visit_id}, policy_id={$policy_id} (visit not found or already set)");
        }

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