مشاهدة ملف: CampaignCreateJob.php

<?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)]);
    }
}