Почему не отправляются уведомления в Laravel 8?

Question

[afal99]

Через фасад отправляю уведомления с задержкой

foreach ($orders as $i => $order)
{
    Notification::send($order, (new OrdersDelivered($text_template))
        ->delay(now()->addSeconds($i * 30))
    );
}

Само уведомление выглядит так

class OrdersDelivered extends Notification implements ShouldQueue
{
    use Queueable;

    private string $text;

    public function __construct($text)
    {
        $this->text = $text;
    }

    public function via($notifiable): array
    {
        return [WhatsappChannel::class];
    }

    public function toWhatsapp($notifiable): WhatsappMessage
    {
        return (new WhatsappMessage())
            ->to($notifiable->client_phone)
            ->text($this->text)
            ->totalOrders($notifiable->total);
    }
}

Канал для отправки я сделал свой

class WhatsappChannel
{
    public function send(mixed $notifiable, Notification $notification)
    {
        $message = $notification->toWhatsapp($notifiable);
        WhatsappApi::send($message);
    }
}

Все это прекрасно работает, если не использовать очередь и не писать implements ShouldQueue. Мне же необходимо использовать очередь, но когда обработчик вытаскивает задания, то метод send у канала даже не вызывается. При этом в очередь все задания попадают

Answer 1

[Владимир]

Скорее всего надо запустить обработчик очереди, сама по себе очередь ничего не делает, необходимо выполнить команду
php artisan queue:work
либо
php artisan queue:listen
Обратите внимание, что обработчик, согласно документации, должен быть запущен перед отправкой уведомлений в очередь!

Comments

[afal99]

На последнем скриншоте вывод обработчика очереди. Проблема как раз в том, что обработчик вытаскивает задачу из очереди и сразу завершается, не обращаясь к моему каналу.

[Владимир]

Гм, точно. А в failed_jobs что-то есть?

[afal99]

Владимир, Нет, пусто. Честно говоря, даже не знаю как выявить проблему. Пробовал XDebug'ом пройтись, но, во-первых, разбираться в 10-15 файлах фреймворка бессмысленно, во-вторых, в очередь задачи то ставятся, там никаких проблем, а вот с обработкой проблемы.

[Владимир]

Попробуйте проверить, что у вас в toWhatsapp приходит во время обработки очереди, есть подозрение, что из-за того, что выполнение идет в другом контексте, метод получает не то, что вы думаете. Поставьте в send() вызов dd($notifiable), чтобы посмотреть, что там:

class WhatsappChannel
{
    public function send(mixed $notifiable, Notification $notification)
    {
        dd($notifiable);
        $message = $notification->toWhatsapp($notifiable);
        WhatsappApi::send($message);
    }
}

Если там все в порядке, аналогично проверьте $message. Если и там все хорошо, то проблема в WhatsappApi::send($message).

[afal99]

Владимир, поставил Log::info($notifiable), но в логах ничего не появилось, dd тоже пробовал, похоже функция send не вызывается.

Проверил стандартный канал для отправки на email:

public function via($notifiable): array
    {
        return ['mail'];
    }

Он так же не работает.

[Владимир]

Мистика какая-то. Что у вас в конфигурации с очередями, смотрели? А в XDebug'е не обратили внимание на стек вызовов? Возможно, по какой-то причине обработчик вызывает другой send(). И что у вас в namespace и use объявлено перед OrdersDelivered проверьте, может там что-то упустили.

[Владимир]

afal99 Чем все закончилось, удалось разобраться?