107 lines
3.9 KiB
PHP
107 lines
3.9 KiB
PHP
<?php
|
|
|
|
namespace App\Containers\Dashboard\Jobs;
|
|
|
|
use App\Containers\Dashboard\Actions\EmailNews\FetchEmailNewsAction;
|
|
use App\Containers\Dashboard\Exceptions\EmailFetchException;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
use Illuminate\Support\Facades\Log;
|
|
|
|
/**
|
|
* Queue Job для обработки email новостей
|
|
*
|
|
* OPTIMIZATION: Выносит тяжелую IMAP-обработку в queue worker,
|
|
* предотвращая переполнение памяти в веб-процессах.
|
|
*
|
|
* Usage:
|
|
* ProcessEmailNewsJob::dispatch();
|
|
* ProcessEmailNewsJob::dispatch()->onQueue('email-processing');
|
|
*/
|
|
class ProcessEmailNewsJob implements ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
/**
|
|
* Максимальное время выполнения (секунды)
|
|
*/
|
|
public $timeout = 300; // 5 минут
|
|
|
|
/**
|
|
* Максимальное количество попыток
|
|
*/
|
|
public $tries = 3;
|
|
|
|
/**
|
|
* Количество секунд ожидания перед повторной попыткой
|
|
*/
|
|
public $backoff = 60; // 1 минута
|
|
|
|
/**
|
|
* Создать новую задачу
|
|
*/
|
|
public function __construct()
|
|
{
|
|
// Параметры не требуются, все берется из конфига
|
|
}
|
|
|
|
/**
|
|
* Выполнить задачу
|
|
*
|
|
* @param FetchEmailNewsAction $fetchEmailNewsAction
|
|
* @return void
|
|
* @throws \Exception Если обработка не удалась (Laravel автоматически повторит)
|
|
*/
|
|
public function handle(FetchEmailNewsAction $fetchEmailNewsAction): void
|
|
{
|
|
Log::channel('app')->info('Начало обработки job', [
|
|
'job_id' => $this->job?->getJobId() ?? 'unknown',
|
|
'attempt' => $this->attempts(),
|
|
'memory_limit' => ini_get('memory_limit'),
|
|
]);
|
|
|
|
// Выполняем обработку — если выбросит исключение, Laravel автоматически повторит job
|
|
$result = $fetchEmailNewsAction->run();
|
|
|
|
Log::channel('app')->info('Обработка завершена успешно', [
|
|
'job_id' => $this->job?->getJobId() ?? 'unknown',
|
|
'processed_emails' => $result['processed_emails'],
|
|
'created_posts' => $result['created_posts'],
|
|
'skipped_emails' => $result['skipped_emails'],
|
|
'errors_count' => count($result['errors']),
|
|
'batches_processed' => $result['batches_processed'] ?? 0,
|
|
'peak_memory' => round(memory_get_peak_usage(true) / 1024 / 1024, 2) . 'MB',
|
|
]);
|
|
|
|
// Если были ошибки, логируем их как warning
|
|
if (!empty($result['errors'])) {
|
|
foreach ($result['errors'] as $error) {
|
|
Log::channel('app')->warning('Ошибка обработки письма', [
|
|
'subject' => $error['email_subject'] ?? 'unknown',
|
|
'error' => $error['error'],
|
|
]);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Обработка проваленной задачи (вызывается Laravel после исчерпания попыток)
|
|
*
|
|
* @param \Throwable $exception
|
|
* @return void
|
|
*/
|
|
public function failed(\Throwable $exception): void
|
|
{
|
|
Log::channel('app')->critical('Job окончательно провален', [
|
|
'total_attempts' => $this->tries,
|
|
'error' => $exception->getMessage(),
|
|
]);
|
|
|
|
// Здесь можно отправить уведомление администратору
|
|
// Notification::route('mail', 'admin@ntspi.ru')->notify(new EmailProcessingFailed($exception));
|
|
}
|
|
}
|