senderjob.php

<?php
namespace Bitrix\Sender\Runtime;
 
use Bitrix\Main\Config\Option;
use Bitrix\Sender\Internals\Model\LetterTable;
 
class SenderJob extends Job
{
    protected $letterId;
 
    protected $campaignId;
 
    public function withCampaignId($campaignId)
    {
        $this->campaignId = $campaignId;
        return $this;
    }
 
    public function withLetterId($letterId)
    {
        $this->letterId = $letterId;
        return $this;
    }
 
    public function actualize()
    {
        $filter = [];
        if ($this->campaignId)
        {
            $filter['=CAMPAIGN_ID'] = $this->campaignId;
        }
        if ($this->letterId)
        {
            $filter['=ID'] = $this->letterId;
        }
 
        $list = LetterTable::getList(array(
            'select' => ['ID', 'POSTING_ID', 'STATUS', 'AUTO_SEND_TIME', 'CAMPAIGN_ACTIVE' => 'CAMPAIGN.ACTIVE'],
            'filter' => $filter
        ));
 
        $data = [];
 
        foreach ($list as $row)
        {
            $data[] = $row;
        }
 
        foreach ($data as $row)
        {
            $agentName = static::getAgentName($row['ID']);
            if (!$agentName)
            {
                continue;
            }
 
            self::removeAgent($agentName);
 
            if (Env::isSenderJobCron())
            {
                continue;
            }
 
            if (empty($row['AUTO_SEND_TIME']))
            {
                continue;
            }
 
            if ($row['CAMPAIGN_ACTIVE'] !== 'Y')
            {
                continue;
            }
 
            $allowedStatuses = [LetterTable::STATUS_SEND, LetterTable::STATUS_PLAN];
            if (!in_array($row['STATUS'], $allowedStatuses))
            {
                continue;
            }
 
            $interval = Option::get('sender', 'auto_agent_interval');
            self::addAgent($agentName, $interval, $row['AUTO_SEND_TIME']);
        }
 
        return $this;
    }
 
    public static function getAgentName($letterId, $threadId = false)
    {
        $letterId = (int) $letterId;
        if (!$letterId)
        {
            return '';
        }
 
        return '\Bitrix\Sender\MailingManager::chainSend('. $letterId. ');';
    }
}