NathanGeerinck / laravel-newsletter

app/Jobs/SendCampaign.php

<?php

namespace App\Jobs;

use Mail;
use App\Models\User;
use App\Models\Campaign;
use App\Models\Template;
use App\Mail\CampaignMail;
use Illuminate\Bus\Queueable;
use App\Mail\CampaignSendMail;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Database\Eloquent\Collection;

/**
 * @property Campaign   campaign
 * @property Template   template
 * @property Collection subscriptions
 * @property User user
 */
class SendCampaign implements ShouldQueue
{
    use InteractsWithQueue, Queueable, SerializesModels;

The trait Illuminate\Queue\SerializesModels requires some properties which are not provided by App\Jobs\SendCampaign: $id, $class, $relations

    protected $campaign;
    protected $user;
    protected $template;

    /**
     * SendCampaign constructor.
     *
     * @param User $user
     * @param Campaign $campaign
     * @param Template $template
     */
    public function __construct(User $user, Campaign $campaign, Template $template)
    {
        $this->user = $user;
        $this->campaign = $campaign;
        $this->template = $template;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $lists = $this->campaign
            ->mailingLists()
            ->with('subscriptions')
            ->get();

        $chunk = ceil($lists->count() / 4);

        $lists->each(function ($list) use ($chunk) {
            $list->subscriptions()->chunk($chunk, function ($subscriptions) {
                $subscriptions->each(function ($subscription) {
                    Mail::to($subscription)->queue(new CampaignMail($subscription, $this->campaign, $this->template));
                });
            });
        });

        $this->campaign->update([
            'send' => 1
        ]);

        if ($this->user->preferences['notifications']) {
            Mail::to($this->user)->queue(new CampaignSendMail($this->campaign->getSubscriptions(), $this->campaign));
        }
    }
}