View file app/Tasks/SendMessages.php

<?php

namespace App\Tasks;

use App\Models\Mailing;
use Crontask\Tasks\Task;

class SendMessages extends Task
{
    /**
     * Рассылает письма
     */
    public function run()
    {
        $queues = Mailing::query()
            ->where('sent', 0)
            ->limit(setting('sendmailpacket'))
            ->get();

        if ($queues->isNotEmpty()) {
            foreach ($queues as $queue) {
                $user = getUserById($queue->user_id);

                if ($user) {
                    sendMail($user->email, $queue->subject, $queue->text);

                    $queue->update([
                        'sent'    => 1,
                        'sent_at' => SITETIME,
                    ]);
                }
            }
        }
    }
}