<?php
declare(strict_types=1);
namespace App\Modules\Admin;

use App\Core\{Request, Response, Database};

final class AdminController
{
    public function listTenants(Request $request): void
    {
        $db = Database::getInstance();
        $page = max(1, (int)$request->input('page', 1));
        $limit = 20;
        $offset = ($page - 1) * $limit;

        $stmt = $db->prepare("SELECT t.*, 
            (SELECT COUNT(*) FROM invoices i WHERE i.tenant_id = t.id) as invoices_count,
            (SELECT COUNT(*) FROM users u WHERE u.tenant_id = t.id) as users_count
            FROM tenants t ORDER BY t.created_at DESC LIMIT {$limit} OFFSET {$offset}");
        $stmt->execute();
        $tenants = $stmt->fetchAll();

        $total = (int)$db->query("SELECT COUNT(*) FROM tenants")->fetchColumn();

        Response::json([
            'success' => true,
            'data' => $tenants,
            'meta' => ['total' => $total, 'page' => $page, 'per_page' => $limit]
        ]);
    }

    public function getTenant(Request $request, string $id): void
    {
        $db = Database::getInstance();
        $stmt = $db->prepare("SELECT t.*, s.plan, s.max_invoices_per_month, s.invoices_used_this_month 
            FROM tenants t 
            LEFT JOIN subscriptions s ON t.id = s.tenant_id 
            WHERE t.id = ?");
        $stmt->execute([$id]);
        $tenant = $stmt->fetch();

        if (!$tenant) {
            Response::error('المستأجر غير موجود', 'NOT_FOUND', 404);
            return;
        }

        Response::json(['success' => true, 'data' => $tenant]);
    }

    public function updateTenant(Request $request, string $id): void
    {
        $data = $request->getBody();
        $status = $data['status'] ?? null;

        if (!in_array($status, ['active', 'suspended', 'trial'])) {
            Response::error('حالة غير صالحة', 'VALIDATION_ERROR', 422);
            return;
        }

        $db = Database::getInstance();
        $stmt = $db->prepare("UPDATE tenants SET status = ? WHERE id = ?");
        $stmt->execute([$status, $id]);

        Response::json(['success' => true, 'message' => 'تم تحديث حالة المستأجر بنجاح']);
    }

    public function getSystemStats(Request $request): void
    {
        $db = Database::getInstance();
        
        $stats = [
            'tenants' => (int)$db->query("SELECT COUNT(*) FROM tenants")->fetchColumn(),
            'invoices' => (int)$db->query("SELECT COUNT(*) FROM invoices")->fetchColumn(),
            'users' => (int)$db->query("SELECT COUNT(*) FROM users")->fetchColumn(),
            'queue_depth' => (int)$db->query("SELECT COUNT(*) FROM queue_jobs WHERE status = 'pending'")->fetchColumn()
        ];

        Response::json(['success' => true, 'data' => $stats]);
    }

    public function getQueueStatus(Request $request): void
    {
        $db = Database::getInstance();
        $stmt = $db->prepare("SELECT status, COUNT(*) as count FROM queue_jobs GROUP BY status");
        $stmt->execute();
        $counts = $stmt->fetchAll();

        $stmt = $db->prepare("SELECT * FROM queue_jobs WHERE status IN ('failed', 'dead') ORDER BY created_at DESC LIMIT 50");
        $stmt->execute();
        $failedJobs = $stmt->fetchAll();

        Response::json([
            'success' => true, 
            'data' => [
                'counts' => $counts,
                'failed_jobs' => $failedJobs
            ]
        ]);
    }

    public function retryJob(Request $request, string $id): void
    {
        $db = Database::getInstance();
        $stmt = $db->prepare("UPDATE queue_jobs SET status = 'pending', attempts = 0 WHERE id = ? AND status = 'dead'");
        $stmt->execute([$id]);

        Response::json(['success' => true, 'message' => 'تم إعادة محاولة الوظيفة بنجاح']);
    }

    public function health(Request $request): void
    {
        $dbStatus = 'ok';
        try { Database::getInstance()->query("SELECT 1"); } catch (\Throwable $e) { $dbStatus = 'error'; }

        $redisStatus = 'ok';
        try { \App\Core\Redis::getInstance()->ping(); } catch (\Throwable $e) { $redisStatus = 'error'; }

        $db = Database::getInstance();
        $queuePending = (int)$db->query("SELECT COUNT(*) FROM queue_jobs WHERE status = 'pending'")->fetchColumn();
        $queueDead = (int)$db->query("SELECT COUNT(*) FROM queue_jobs WHERE status = 'dead'")->fetchColumn();

        Response::json([
            'success' => true,
            'data' => [
                'db' => $dbStatus,
                'redis' => $redisStatus,
                'queue_pending' => $queuePending,
                'queue_dead' => $queueDead
            ]
        ]);
    }
}