// متزامن — يحجب لمدة 30 ثانية
$csv = ReportService::generateMonthlyReport($tenant);

// غير متزامن — يعود فورًا، تعمل المهمة في الخلفية
GenerateReportJob::dispatch($tenant, 'monthly');
// يرى المستخدم: "جاري إنشاء التقرير. سنرسل لك بريدًا إلكترونيًا عندما يكون جاهزًا."

# .env
QUEUE_CONNECTION=redis

# اتصال Redis
REDIS_HOST=127.0.0.1
REDIS_PASSWORD=null
REDIS_PORT=6379

// config/queue.php
'connections' => [
    'database' => [
        'driver' => 'database',
        'table' => 'jobs',
        'queue' => 'default',
        'retry_after' => 90,
    ],
    'redis' => [
        'driver' => 'redis',
        'connection' => 'default',
        'queue' => '{default}',
        'retry_after' => 90,
        'block_for' => null,
    ],
],

# لمشغل قاعدة البيانات
php artisan queue:table
php artisan queue:failed-table
php artisan migrate

# ينشئ: جدول jobs + جدول failed_jobs

# .env — بيئة التطوير
QUEUE_CONNECTION=database

# .env — بيئة الإنتاج
QUEUE_CONNECTION=redis
REDIS_HOST=redis.shopmetrics.internal
REDIS_PORT=6379

# إنشاء جداول الطوابير (مشغل قاعدة البيانات)
php artisan queue:table
php artisan queue:failed-table
php artisan queue:batches-table
php artisan migrate

# تم تنفيذ الأمر بنجاح

php artisan make:job GenerateReportJob
# ينشئ: app/Jobs/GenerateReportJob.php

// app/Jobs/GenerateReportJob.php
class GenerateReportJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public int $tries = 3;
    public int $backoff = 60;
    public bool $deleteWhenMissingModels = true;

    public function __construct(
        public Tenant $tenant,
        public string $reportType,
        public string $format = 'csv',
    ) {}

    public function handle(
        ReportService $reportService,
        Mailer $mailer,
    ): void {
        $path = $reportService->generate(
            $this->tenant,
            $this->reportType,
            $this->format,
        );

        $url = Storage::disk('s3')->temporaryUrl($path, now()->addDays(7));

        $this->tenant->users->each(function ($user) use ($url) {
            $mailer->to($user)->send(new ReportReadyNotification($url, $this->reportType));
        });
    }

    public function failed(\Throwable $exception): void
    {
        Log::error('Report generation failed', [
            'tenant_id' => $this->tenant->id,
            'report_type' => $this->reportType,
            'error' => $exception->getMessage(),
        ]);
    }
}

// توزيع أساسي
GenerateReportJob::dispatch($tenant, 'monthly');

// توزيع مؤجل
GenerateReportJob::dispatch($tenant, 'monthly')
    ->delay(now()->addMinutes(5));

// توزيع على طابور محدد
GenerateReportJob::dispatch($tenant, 'monthly')
    ->onQueue('reports');

// توزيع شرطي
GenerateReportJob::dispatchIf($tenant->subscription?->isActive(), $tenant, 'monthly');

// توزيع بعد إرسال الاستجابة للمستخدم
GenerateReportJob::dispatchAfterResponse($tenant, 'monthly');

// app/Jobs/ProcessOrderJob.php
class ProcessOrderJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public int $tries = 3;
    public int $backoff = [30, 60, 120];

    public function __construct(public Order $order) {}

    public function handle(
        OrderService $orderService,
        PaymentGateway $payment,
    ): void {
        // خصم الدفع
        $payment->charge($this->order);

        // تحديث المخزون
        $orderService->deductInventory($this->order);

        // بث الحدث
        event(new OrderPlaced($this->order));

        // إرسال بريد تأكيد
        $this->order->user->notify(new OrderConfirmationNotification($this->order));
    }

    public function failed(\Throwable $exception): void
    {
        $this->order->update(['status' => 'failed']);
        $this->order->user->notify(new OrderFailedNotification($this->order));
    }
}

// تم التنفيذ بنجاح

// في فئة المهمة
public int $tries = 3;           // الحد الأقصى لمحاولات إعادة المحاولة
public int $backoff = 60;        // ثوانٍ بين المحاولات
public int $timeout = 120;       // الحد الأقصى للثواني لكل محاولة

// أو تراجع أسي
public array $backoff = [30, 60, 120]; // 30ث، 60ث، 120ث

// أو تراجع ديناميكي
public function backoff(): int
{
    return 30 * $this->attempts();
}

# عرض المهام الفاشلة
php artisan queue:failed

# إعادة محاولة مهمة فاشلة محددة
php artisan queue:retry 5

# إعادة محاولة جميع المهام الفاشلة
php artisan queue:retry all

# حذف مهمة فاشلة
php artisan queue:forget 5

# مسح جميع المهام الفاشلة
php artisan queue:flush

// app/Jobs/SendWebhookJob.php
class SendWebhookJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public int $tries = 5;
    public array $backoff = [10, 30, 60, 120, 300];
    public int $timeout = 30;

    public function __construct(
        public Shop $shop,
        public array $payload,
    ) {}

    public function handle(): void
    {
        $response = Http::timeout($this->timeout)
            ->post($this->shop->webhook_url, $this->payload);

        if (!$response->successful()) {
            $this->release($this->backoff[$this->attempts() - 1] ?? 60);
        }
    }

    public function failed(\Throwable $exception): void
    {
        $this->shop->tenant->users->each(function ($user) {
            $user->notify(new WebhookFailedNotification($this->shop));
        });
    }
}

// تم التنفيذ بنجاح

php artisan queue:batches-table
php artisan migrate

// app/Jobs/ProcessTenantAnalyticsJob.php
class ProcessTenantAnalyticsJob implements ShouldQueue
{
    use Batchable;

    public function __construct(public Tenant $tenant) {}

    public function handle(): void
    {
        if ($this->batch()->cancelled()) {
            return;
        }

        AnalyticsService::computeForTenant($this->tenant);
    }
}

use Illuminate\Bus\Batch;
use Illuminate\Support\Facades\Bus;

$batch = Bus::batch(
    Tenant::active()->get()->map(
        fn ($tenant) => new ProcessTenantAnalyticsJob($tenant)
    )
)->then(function (Batch $batch) {
    // اكتملت جميع المهام بنجاح
    Log::info("Batch {$batch->id} completed: {$batch->totalJobs} tenants processed.");
})->catch(function (Batch $batch, \Throwable $e) {
    // فشل أول مهمة
    Log::error("Batch {$batch->id} failed: {$e->getMessage()}");
})->finally(function (Batch $batch) {
    // يعمل دائمًا (نجاح أو فشل)
    Cache::forget('analytics:computing');
})->name('Process Monthly Analytics')
  ->onQueue('analytics')
  ->dispatch();

// التحقق من تقدم الدفعة
$batch = Bus::findBatch($batchId);
$batch->progress();     // 0-100
$batch->processedJobs();
$batch->totalJobs();
$batch->failedJobs();
$batch->finished();

// إلغاء الدفعة
$batch->cancel();

// app/Console/Commands/ProcessMonthlyAnalytics.php
class ProcessMonthlyAnalytics extends Command
{
    protected $signature = 'analytics:process-monthly';

    public function handle(): int
    {
        $tenants = Tenant::active()->get();
        $this->info("Processing analytics for {$tenants->count()} tenants...");

        Bus::batch(
            $tenants->map(fn ($t) => new ProcessTenantAnalyticsJob($t))
        )->then(function (Batch $batch) {
            $this->info("All {$batch->totalJobs} tenants processed.");
        })->catch(function (Batch $batch, \Throwable $e) {
            $this->error("Batch failed: {$e->getMessage()}");
        })->name('Monthly Analytics')
          ->onQueue('analytics')
          ->allowFailures()
          ->dispatch();

        return self::SUCCESS;
    }
}

// تم التنفيذ بنجاح

# Ubuntu/Debian
sudo apt-get install supervisor

# إنشاء تهيئة
sudo nano /etc/supervisor/conf.d/shopmetrics-worker.conf

[program:shopmetrics-worker-default]
process_name=%(program_name)s_%(process_num)02d
command=php /var/www/shopmetrics/artisan queue:work redis --queue=default --sleep=3 --tries=3 --max-time=3600
autostart=true
autorestart=true
stopasgroup=true
killasgroup=true
user=www-data
numprocs=2
redirect_stderr=true
stdout_logfile=/var/log/shopmetrics/worker-default.log
stopwaitsecs=3600

[program:shopmetrics-worker-reports]
process_name=%(program_name)s_%(process_num)02d
command=php /var/www/shopmetrics/artisan queue:work redis --queue=reports --sleep=3 --tries=3 --max-time=3600
autostart=true
autorestart=true
numprocs=1
user=www-data
redirect_stderr=true
stdout_logfile=/var/log/shopmetrics/worker-reports.log

# قراءة التهيئة الجديدة
sudo supervisorctl reread
sudo supervisorctl update

# بدء/إيقاف/إعادة تشغيل العمال
sudo supervisorctl start shopmetrics-worker-default:*
sudo supervisorctl stop shopmetrics-worker-default:*
sudo supervisorctl restart shopmetrics-worker-default:*

# التحقق من الحالة
sudo supervisorctl status

# التطوير — عامل واحد، جميع الطوابير
php artisan queue:work --queue=default,reports,notifications

# الإنتاج — عمال منفصلون حسب أولوية كل طابور
# الأولوية: high > default > low
php artisan queue:work redis --queue=high,default
php artisan queue:work redis --queue=reports,low

# معالجة المهام بحد زمني (إعادة تشغيل تلقائية لتسرب الذاكرة)
php artisan queue:work --max-time=3600 --max-jobs=1000

# مراقبة الطابور
php artisan queue:monitor redis:default,redis:reports

# تم تنفيذ الأمر بنجاح

// ============================================
// شامل: نظام التقارير غير المتزامنة في ShopMetrics
// يغطي: المهام، الدفعات، إعادة المحاولة، Supervisor، الإشعارات
// ============================================

// app/Jobs/GenerateReportJob.php
class GenerateReportJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public int $tries = 3;
    public array $backoff = [60, 180, 600];
    public int $timeout = 600;
    public bool $deleteWhenMissingModels = true;

    public function __construct(
        public Tenant $tenant,
        public string $reportType,
        public string $format = 'csv',
        public ?int $userId = null,
    ) {
        $this->onQueue('reports');
    }

    public function handle(ReportService $reportService): void
    {
        $path = $reportService->generate(
            $this->tenant,
            $this->reportType,
            $this->format,
        );

        $downloadUrl = Storage::disk('s3')->temporaryUrl($path, now()->addDays(7));

        $user = $this->userId ? User::find($this->userId) : $this->tenant->users->first();
        $user?->notify(new ReportReadyNotification(
            downloadUrl: $downloadUrl,
            reportType: $this->reportType,
            expiresAt: now()->addDays(7),
        ));
    }

    public function failed(\Throwable $exception): void
    {
        $user = $this->userId ? User::find($this->userId) : $this->tenant->users->first();
        $user?->notify(new ReportFailedNotification(
            reportType: $this->reportType,
            error: $exception->getMessage(),
        ));
    }
}

// الاستخدام في المتحكم
class ReportController extends Controller
{
    public function generate(Request $request): JsonResponse
    {
        $validated = $request->validate([
            'report_type' => 'required|in:monthly,weekly,custom',
            'format' => 'sometimes|in:csv,xlsx,pdf',
            'date_from' => 'sometimes|date',
            'date_to' => 'sometimes|date|after:date_from',
        ]);

        GenerateReportJob::dispatch(
            tenant(),
            $validated['report_type'],
            $validated['format'] ?? 'csv',
            auth()->id(),
        );

        return response()->json([
            'message' => 'Report generation started. You will receive an email when ready.',
            'estimated_time' => '5-15 minutes',
        ], 202);
    }
}