106 lines
3.0 KiB
PHP
106 lines
3.0 KiB
PHP
|
<?php
|
||
|
|
/**
|
||
|
|
* Send alert to super admin.
|
||
|
|
*/
|
||
|
|
|
||
|
|
namespace App\Jobs;
|
||
|
|
|
||
|
|
use App\Mail\Alert;
|
||
|
|
use App\SendLog;
|
||
|
|
use App\User;
|
||
|
|
use Illuminate\Bus\Queueable;
|
||
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
||
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
||
|
|
use Illuminate\Queue\InteractsWithQueue;
|
||
|
|
use Illuminate\Queue\SerializesModels;
|
||
|
|
use Mail;
|
||
|
|
|
||
|
|
class SendAlert implements ShouldQueue
|
||
|
|
{
|
||
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
||
|
|
|
||
|
|
public $text;
|
||
|
|
|
||
|
|
public $title;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* The number of seconds the job can run before timing out.
|
||
|
|
* fwrite() function in /vendor/swiftmailer/swiftmailer/lib/classes/Swift/Transport/StreamBuffer.php
|
||
|
|
* in some cases may stuck and continue infinitely. This blocks queue:work and no other jobs are processed.
|
||
|
|
* So we need to set the timeout. On timeout the whole queue:work process is being killed by Laravel.
|
||
|
|
*/
|
||
|
|
public $timeout = 120;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Create a new job instance.
|
||
|
|
*
|
||
|
|
* @return void
|
||
|
|
*/
|
||
|
|
public function __construct($text, $title = '')
|
||
|
|
{
|
||
|
|
$this->text = $text;
|
||
|
|
$this->title = $title;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Execute the job.
|
||
|
|
*
|
||
|
|
* @return void
|
||
|
|
*/
|
||
|
|
public function handle()
|
||
|
|
{
|
||
|
|
// Configure mail driver according to Mailbox settings
|
||
|
|
\MailHelper::setSystemMailDriver();
|
||
|
|
|
||
|
|
$recipients = User::nonDeleted()
|
||
|
|
->where('role', User::ROLE_ADMIN)
|
||
|
|
->where('invite_state', User::INVITE_STATE_ACTIVATED)
|
||
|
|
->pluck('email')
|
||
|
|
->toArray();
|
||
|
|
|
||
|
|
$extra = \MailHelper::sanitizeEmails(\Option::get('alert_recipients'));
|
||
|
|
if ($extra) {
|
||
|
|
$recipients = array_unique(array_merge($recipients, $extra));
|
||
|
|
}
|
||
|
|
|
||
|
|
foreach ($recipients as $recipient) {
|
||
|
|
$exception = null;
|
||
|
|
|
||
|
|
try {
|
||
|
|
Mail::to([['name' => '', 'email' => $recipient]])
|
||
|
|
->send(new Alert($this->text, $this->title));
|
||
|
|
} catch (\Exception $e) {
|
||
|
|
// We come here in case SMTP server unavailable for example
|
||
|
|
activity()
|
||
|
|
->withProperties([
|
||
|
|
'error' => $e->getMessage().'; File: '.$e->getFile().' ('.$e->getLine().')',
|
||
|
|
])
|
||
|
|
->useLog(\App\ActivityLog::NAME_EMAILS_SENDING)
|
||
|
|
->log(\App\ActivityLog::DESCRIPTION_EMAILS_SENDING_ERROR_ALERT);
|
||
|
|
|
||
|
|
$exception = $e;
|
||
|
|
}
|
||
|
|
|
||
|
|
$status_message = '';
|
||
|
|
if ($exception) {
|
||
|
|
$status = SendLog::STATUS_SEND_ERROR;
|
||
|
|
$status_message = $exception->getMessage();
|
||
|
|
} else {
|
||
|
|
$failures = Mail::failures();
|
||
|
|
|
||
|
|
if (!empty($failures)) {
|
||
|
|
$status = SendLog::STATUS_SEND_ERROR;
|
||
|
|
} else {
|
||
|
|
$status = SendLog::STATUS_ACCEPTED;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
SendLog::log(null, null, $recipient, SendLog::MAIL_TYPE_ALERT, $status, null, null, $status_message);
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($exception) {
|
||
|
|
throw $exception;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|