Viewing file:  Campaign.php (1.7 KB) -rw-rw-rw-
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace Webkul\Marketing\Helpers;
use Carbon\Carbon;
use Illuminate\Support\Facades\Mail;
use Webkul\Contact\Repositories\PersonRepository;
use Webkul\Marketing\Mail\CampaignMail;
use Webkul\Marketing\Repositories\CampaignRepository;
use Webkul\Marketing\Repositories\EventRepository;
class Campaign
{
/**
* Create a new helper instance.
*
*
* @return void
*/
public function __construct(
protected EventRepository $eventRepository,
protected CampaignRepository $campaignRepository,
protected PersonRepository $personRepository,
) {}
/**
* Process the email.
*/
public function process(): void
{
$campaigns = $this->campaignRepository->getModel()
->leftJoin('marketing_events', 'marketing_campaigns.marketing_event_id', 'marketing_events.id')
->leftJoin('email_templates', 'marketing_campaigns.marketing_template_id', 'email_templates.id')
->select('marketing_campaigns.*')
->where('marketing_campaigns.status', 1)
->where(function ($query) {
$query->where('marketing_events.date', Carbon::now()->format('Y-m-d'))
->orWhereNull('marketing_events.date');
})
->get();
collect($campaigns)->each(function ($campaign) {
collect($this->getPersonsEmails())->each(fn ($email) => Mail::queue(new CampaignMail($email, $campaign)));
});
}
/**
* Get the email address.
*/
private function getPersonsEmails(): array
{
return $this->personRepository->pluck('emails')
->flatMap(fn ($emails) => collect($emails)->pluck('value'))
->all();
}
}
|