🚀 مُصادَق: تحديث برمجي جديد 2026-05-03 15:11

app/Modules/Admin/AdminController.php

@@ -1,49 +1,131 @@
 <?php
-
 declare(strict_types=1);
-
 namespace App\Modules\Admin;
 
 use App\Core\{Request, Response, Database};
 
 final class AdminController
 {
-    public function getSystemStats(Request $request): void
+    public function listTenants(Request $request): void
     {
-        // Must be super_admin
-        if (($request->user->role ?? '') !== 'super_admin') {
-            Response::error('غير مصرح', 'FORBIDDEN', 403);
+        $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();
         
-        $stmt = $db->prepare("SELECT COUNT(*) as count FROM tenants");
-        $stmt->execute();
-        $totalTenants = $stmt->fetch()['count'];
+        $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()
+        ];
 
-        $stmt = $db->prepare("SELECT COUNT(*) as count FROM invoices");
-        $stmt->execute();
-        $totalInvoices = $stmt->fetch()['count'];
+        Response::json(['success' => true, 'data' => $stats]);
+    }
 
-        // Simple Health Check
-        $redisHealth = 'ok';
-        try {
-            $redis = \App\Core\Redis::getInstance();
-            $redis->ping();
-        } catch (\Throwable $e) {
-            $redisHealth = 'failed';
-        }
+    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' => [
-                'total_tenants' => $totalTenants,
-                'total_invoices' => $totalInvoices,
-                'system_health' => [
-                    'database' => 'ok',
-                    'redis' => $redisHealth
-                ]
+                'db' => $dbStatus,
+                'redis' => $redisStatus,
+                'queue_pending' => $queuePending,
+                'queue_dead' => $queueDead
             ]
         ]);
     }