Решил для рассылки писем использовать yii2-queue.
<?php
namespace app\models;
use yii\base\BaseObject;
use app\models\Newsletter;
use app\models\NewsletterQuene;
class NewsLetterJob extends BaseObject implements \yii\queue\JobInterface
{
public $newsLetterId;
public function execute($queue)
{
$newsLetter = Newsletter::find()->where(['id' => 8])->one();
$mails = NewsletterQuene::find()->where(['status' => 1])->
limit(\Yii::$app->params['newsLetterCount'])->all();
$changeStatus = [];
foreach ($mails as $mail){
\Yii::$app->mailer->compose(
'newsletter',
[
'content' => $newsLetter->message,
'name' => $mail->name
]
)
->setFrom(Yii::$app->params['fromEmail'])
->setTo($mail->email)
->setSubject($newsLetter->subject)
->send();
$mail->status = 2;
$mail->save();
$changeStatus[] = $mail->id;
}
NewsletterQuene::updateAll(['status' => 2], ['in', 'id', $changeStatus]);
}
}
вот Job
Создаю очередь так
Yii::$app->queue->push(new NewsLetterJob([
'newsLetterId' => $model->id,
]));
Запускаю в консоли, очередь отрабатывает, ошибок нет, но ничего не происходит, ни письма не отправляются, ни статус не меняется. Вопрос. Как отладить работу Joba это же не контроллер, чтоб можно было $this->stdout(var_dump(чтото); написать.
вывода нет, и не понятно, то ли ошибка то ли что. queue настроена на работу с db она работает все хорошо, вижу задания, вижу что выполнены...
stdout_logfile=/var/log/supervisor/yii-queue-worker.log
Плюс дебаг github.com/yiisoft/yii2-queue/blob/master/docs/guide/debug.md Плюс логирование github.com/yiisoft/yii2-queue/blob/master/docs/guide/usage.md