Просмотр архива RotorCms 14.2.1


<?php

namespace AppConsoleCommands;

use AppModelsMailing;
use AppModelsUser;
use IlluminateConsoleCommand;
use SymfonyComponentConsoleCommandCommand as SymfonyCommand;

class AddSubscribers extends Command
{
    /**
     * The name and signature of the console command.
     */
    protected $signature = 'add:subscribers';

    /**
     * The console command description.
     */
    protected $description = 'Add subscribers';

    /**
     * Добавляет подписчиков в рассылку
     */
    public function handle(): int
    {
        $deliveryUsers = User::query()
            ->where('sendprivatmail', 0)
            ->whereIn('level', User::USER_GROUPS)
            ->where('newprivat', '>', 0)
            ->where('updated_at', '<', now()->subDays((int) setting('sendprivatmailday')))
            ->whereNotNull('subscribe')
            ->limit(100)
            ->get();

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

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

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

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

        $this->info('Subscribers successfully added.');

        return SymfonyCommand::SUCCESS;
    }
}