View file app/Tasks/AddSubscribers.php

<?php

namespace App\Tasks;

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

class AddSubscribers extends Task
{
    /**
     * Добавляет подписчиков в рассылку
     */
    public function run()
    {
        $deliveryUsers = User::query()
            ->where('sendprivatmail', 0)
            ->whereIn('level', User::USER_GROUPS)
            ->where('newprivat', '>', 0)
            ->where('updated_at', '<', strtotime('-' . setting('sendprivatmailday') . ' days', SITETIME))
            ->whereNotNull('subscribe')
            ->groupBy('users.id')
            ->limit(100)
            ->get();

        if ($deliveryUsers->isNotEmpty()) {
            foreach ($deliveryUsers as $user) {

                $subject = $user->newprivat . ' непрочитанных сообщений (' . setting('title') . ')';

                $message = 'Здравствуйте ' . $user->login . '!<br>У вас имеются непрочитанные сообщения (' . $user->newprivat . ' шт.) на сайте ' . setting('title') . '<br>Прочитать свои сообщения вы можете по адресу <a href="' . siteUrl(true) . '/private">' . siteUrl(true) . '/private</a><br><br><small>Если вы не хотите получать эти email, пожалуйста, <a href="'.siteUrl(true).'/unsubscribe?key='.$user->subscribe.'">откажитесь от подписки</a></small>';

                $body = view('mailer.default', compact('subject', 'message'));

                Mailing::query()->create([
                    'user_id'    => $user->id,
                    'type'       => 'private',
                    'subject'    => $subject,
                    'text'       => $body,
                    'created_at' => SITETIME,
                ]);

                $user->update(['sendprivatmail' => 1]);
            }
        }
    }
}