Viewing file:  CampaignCreateJob.php (2.93 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace App\Jobs;
use App\Models\Campaign;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Carbon;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Bus;
class CampaignCreateJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
private $from_email;
private $to_email;
private $campaign;
private $message;
private $templateId;
private $total_to_count;
/**
* @var float|int
*/
private $daily_sent_limit;
/**
* @var float|int
*/
private $date_difference;
private $start_date;
private $start_time;
private $send_speed;
private $user;
private $take_count = 5000;
/**
* @var array
*/
private $campaign_running_date;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($from, $to, $campaign, $message, $totalTo, $dateDiff, $startDate, $startTime, $user)
{
$this->from_email = $from;
$this->to_email = $to;
$this->campaign = $campaign;
$this->message = $message;
$this->total_to_count = $totalTo;
$this->date_difference = $dateDiff;
$this->daily_sent_limit = ceil($this->total_to_count / $this->date_difference);
$this->start_date = $startDate;
$this->start_time = $startTime;
$this->user = $user;
$this->setCampaignFutureDates();
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
$jobs = new Collection();
foreach ($this->getCampaignFutureDates() as $key => $date) {
$jobs->push(new CampaignCreateChunk(
$this->message,
$this->daily_sent_limit,
$date,
$this->send_speed,
$this->user,
$key * $this->daily_sent_limit
));
}
$jobs->push(
new CampaignCreateSuccessJob($this->campaign)
);
Bus::chain($jobs->toArray())->dispatch();
}
public function getCampaignFutureDates(): array
{
return $this->campaign_running_date;
}
private function setCampaignFutureDates(): array
{
$campaign_running_date = [];
for ($i = 1; $i <= $this->date_difference; $i++) {
$campaign_running_date[] = Carbon::parse($this->start_date->addDay()->toDateString() . ' ' . $this->start_time->toTimeString());
}
$this->campaign_running_date = $campaign_running_date;
return $campaign_running_date;
}
public function failed($exception)
{
Campaign::where('id', $this->message->campaign_id)->update(['status' => 'failed', 'import_fail_message' => substr($exception->getMessage(), 0, 191)]);
}
}
|