bytic / mail-module

src/Console/Commands/EmailsSend.php

<?php
declare(strict_types=1);

namespace Nip\MailModule\Console\Commands;

use Exception;
use Nip\Records\Collections\Collection as RecordCollection;

/**
 * Class EmailsSend
 * @package Nip\MailModule\Console\Commands
 */
class EmailsSend extends EmailsAbstract
{
    /**
     * @return int
     */
    public function handle()
    {
        $sent = 0;
        $batchCount = 1;
        while ($sent < 10) {
            $sentEmails = $this->sendBatch($batchCount);
            if ($sentEmails === false) {
                return $sent;
            }
            $sent += $this->sendBatch($batchCount);
            $batchCount++;
        }
        return $sent;
    }

    /**
     * @param int $number
     * @return int|bool
     */
    protected function sendBatch($number = 1)
    {
        $emailsCount = 10;
        $emails = $this->getEmailsBatch($emailsCount, $emailsCount * ($number - 1));
        return $this->sendEmails($emails);
    }

    /**
     * @param RecordCollection $emails
     * @return int|bool
     */
    protected function sendEmails($emails)
    {
        if (count($emails) < 1) {
            return false;
        }
        $sent = 0;
        $recipients = 0;

The assignment to $recipients is dead and can be removed.

        foreach ($emails as $email) {
            echo 'send email [ID:' . $email->id . '][TO:' . implode(',', array_keys($email->getTos())) . ']';
            try {
                $recipients = $email->send();
                $sent++;
            } catch (Exception $exception) {
                echo $exception->getMessage();
//            die('');
            }
            echo '[R:' . $recipients . ']<br />' . "\n";
        }
        return $sent;
    }

    /**
     * @param int $count
     * @param int $offset
     * @return RecordCollection
     */
    protected function getEmailsBatch($count = 10, $offset = 0)
    {
        $emailsManager = $this->emailsManager();
        return $emailsManager->findByParams(
            [
                'where' => ['`sent` = \'no\' OR `sent` IS NULL OR `sent` = \'\' '],
                'limit' => $offset . ',' . $count,
            ]
        );
    }
}