mailingmanager.php

См. документацию.

<?php
namespace Bitrix\Sender;
 
use Bitrix\Main;
use Bitrix\Main\DB\Exception;
use Bitrix\Main\Event;
use Bitrix\Main\EventResult;
use Bitrix\Main\Type;
use Bitrix\Sender\Dispatch\MethodSchedule;
use Bitrix\Sender\Entity;
use Bitrix\Sender\Internals\Model;
 
class MailingManager
{
    /* @var Exception $error */
    protected static $error = null;

    public static function getErrors()
    {
        return static::$error;
    }

    public static function getAgentNamePeriod()
    {
        return Runtime\ReiteratedJob::getAgentName();
    }

    public static function getAgentName($mailingChainId)
    {
        return Runtime\SenderJob::getAgentName($mailingChainId);
    }

    public static function actualizeAgent($mailingId = null, $mailingChainId = null)
    {
        (new Runtime\SenderJob())
            ->withCampaignId($mailingId)
            ->withLetterId($mailingChainId)
            ->actualize();
 
        (new Runtime\ReiteratedJob())->actualize();
    }
 
    protected static function checkOnBeforeChainSend($letterId)
    {
        $event = new Main\Event('sender', 'onBeforeChainSend', ['LETTER_ID' => $letterId]);
        $event->send();
        foreach ($event->getResults() as $eventResult)
        {
            if (
                $eventResult->getType() === Main\EventResult::ERROR
                || $eventResult->getParameters()
                && isset($eventResult->getParameters()['ALLOW_SEND'])
                && $eventResult->getParameters()['ALLOW_SEND'] === false
            )
            {
                return false;
            }
        }
 
        return true;
    }

    public static function chainSend($letterId)
    {
        static::$error = null;
 
        $letter = Model\LetterTable::getRowById($letterId);
        if($letter && $letter['STATUS'] === Model\LetterTable::STATUS_PLAN)
        {
            $updateResult = Model\LetterTable::update($letterId, array('STATUS' => Model\LetterTable::STATUS_SEND));
            if ($updateResult->isSuccess())
            {
                $letter = Model\LetterTable::getRowById($letterId);
            }
        }
        if(!$letter || !in_array($letter['STATUS'], [
            Model\LetterTable::STATUS_SEND
            ]))
        {
            return "";
        }
 
        if(!static::checkOnBeforeChainSend($letterId))
        {
            return Runtime\SenderJob::getAgentName($letterId);
        }
 
        $postingSendStatus = '';
        if(!empty($letter['POSTING_ID']))
        {
            try
            {
                $postingSendStatus = PostingManager::send(
                    $letter['POSTING_ID'],
                    Runtime\Env::getJobExecutionTimeout(),
                    Runtime\Env::getJobExecutionItemLimit()
                );
            }
            catch (\Throwable $e)
            {
                static::$error = $e;
 
                $postingSendStatus = PostingManager::SEND_RESULT_ERROR;
            }
        }
 
        if(
            in_array($postingSendStatus, [PostingManager::SEND_RESULT_CONTINUE, PostingManager::SEND_RESULT_ERROR], true)
        )
        {
            return Runtime\SenderJob::getAgentName($letterId);
        }
 
 
        if ($postingSendStatus === PostingManager::SEND_RESULT_WAIT)
        {
            Model\LetterTable::update($letterId, array('STATUS' => Model\LetterTable::STATUS_WAIT));
            return "";
        }
 
 
        if (
            $postingSendStatus === PostingManager::SEND_RESULT_WAITING_RECIPIENT
            || \Bitrix\Sender\PostingRecipientTable::hasUnprocessed($letter['POSTING_ID'])
        )
        {
            return Runtime\SenderJob::getAgentName($letterId);
        }
 
        if ($letter['REITERATE'] !== 'Y')
        {
            Model\LetterTable::update($letterId, array('STATUS' => Model\LetterTable::STATUS_END));
            return "";
        }
 
        $isNeedUpdate = true;
        if($letter['IS_TRIGGER'] == 'Y')
        {
            $postingDb = PostingTable::getList(array(
                'select' => array('ID', 'DATE_CREATE'),
                'filter' => array(
                    'STATUS' => PostingTable::STATUS_NEW,
                    'MAILING_CHAIN_ID' => $letter['ID']
                ),
                'order' => array('DATE_CREATE' => 'ASC'),
                'limit' => 1
            ));
            if($posting = $postingDb->fetch())
            {
                $dateCreate = $posting['DATE_CREATE'];
                $updateFields = [
                    'STATUS' => Model\LetterTable::STATUS_SEND,
                    'AUTO_SEND_TIME' => $dateCreate ? $dateCreate->add($letter['TIME_SHIFT'].' minutes') : null,
                    'POSTING_ID' => $posting['ID']
                ];
                Model\LetterTable::update($letterId, $updateFields);
                $isNeedUpdate = false;
            }
        }
 
        if ($isNeedUpdate)
        {
            $letterInstance = new Entity\Letter();
            $letterInstance->loadByArray($letter);
            $letterInstance->wait();
        }
 
        $eventData = array(
            'MAILING_CHAIN' => $letter
        );
        $event = new \Bitrix\Main\Event('sender', 'OnAfterMailingChainSend', array($eventData));
        $event->send();
 
        return "";
    }

    public static function checkSend()
    {
        if(\COption::GetOptionString("sender", "auto_method") !== 'cron')
            return;
 
        $mailingChainDb = MailingChainTable::getList(array(
            'select' => array('ID'),
            'filter' => array(
                '=STATUS' => array(
                    MailingChainTable::STATUS_SEND,
                    MailingChainTable::STATUS_PLAN,
                    ),
                '=MAILING.ACTIVE' => 'Y',
                '<=AUTO_SEND_TIME' => new Type\DateTime(),
            )
        ));
 
        while ($mailingChain = $mailingChainDb->fetch())
        {
            $event = new Event('sender', 'onBeforeMailingChainSend', [
                'chain' => $mailingChain,
            ]);
            $event->send();
            foreach ($event->getResults() as $eventResult)
            {
                if ($eventResult->getType() === EventResult::ERROR)
                {
                    continue 2;
                }
            }
 
            static::chainSend($mailingChain['ID']);
        }
    }

    public static function checkPeriod($isAgentExec = true)
    {
        $isAgentExecInSetting = !Runtime\Env::isReiteratedJobCron();
        if(($isAgentExec && !$isAgentExecInSetting) || (!$isAgentExec && $isAgentExecInSetting))
        {
                return "";
        }
 
        $dateTodayPhp = new \DateTime();
        $datetimeToday = Type\DateTime::createFromPhp(clone $dateTodayPhp);
        $dateToday = clone $dateTodayPhp;
        $dateToday = Type\Date::createFromPhp($dateToday->setTime(0,0,0));
        $dateTomorrow = clone $dateTodayPhp;
        $dateTomorrow = Type\Date::createFromPhp($dateTomorrow->setTime(0,0,0))->add('1 DAY');
        $arDateFilter = array($dateToday, $dateTomorrow);
 
        $chainDb = MailingChainTable::getList(array(
            'select' => array(
                'ID', 'LAST_EXECUTED', 'POSTING_ID',
                'MONTHS_OF_YEAR', 'DAYS_OF_MONTH', 'DAYS_OF_WEEK', 'TIMES_OF_DAY'
            ),
            'filter' => array(
                '=REITERATE' => 'Y',
                '=MAILING.ACTIVE' => 'Y',
                '=IS_TRIGGER' => 'N',
                '=STATUS' => MailingChainTable::STATUS_WAIT,
                //'!><LAST_EXECUTED' => $arDateFilter,
            )
        ));
        while($arMailingChain = $chainDb->fetch())
        {
            $lastExecuted = $arMailingChain['LAST_EXECUTED'];
            /* @var \Bitrix\Main\Type\DateTime $lastExecuted*/
            if($lastExecuted && $lastExecuted->getTimestamp() >= $dateToday->getTimestamp())
            {
                continue;
            }
 
            $event = new Event('sender', 'onBeforeMailingPeriodChainSend', [
                'chain' => $arMailingChain,
            ]);
            $event->send();
            foreach ($event->getResults() as $eventResult)
            {
                if ($eventResult->getType() === EventResult::ERROR)
                {
                    continue 2;
                }
            }
 
            $timeOfExecute = static::getDateExecute(
                $dateTodayPhp,
                $arMailingChain["DAYS_OF_MONTH"],
                $arMailingChain["DAYS_OF_WEEK"],
                $arMailingChain["TIMES_OF_DAY"],
                $arMailingChain["MONTHS_OF_YEAR"]
            );
 
            if($timeOfExecute)
            {
                $arUpdateMailChain = array('LAST_EXECUTED' => $datetimeToday);
 
                $postingDb = PostingTable::getList(array(
                    'select' => array('ID'),
                    'filter' => array(
                        '=MAILING_CHAIN_ID' => $arMailingChain['ID'],
                        '><DATE_CREATE' => $arDateFilter
                    )
                ));
                $arPosting = $postingDb->fetch();
                if(!$arPosting)
                {
                    $postingId = MailingChainTable::initPosting($arMailingChain['ID']);
                }
                else
                {
                    $postingId = $arPosting['ID'];
                    $arUpdateMailChain['POSTING_ID'] = $postingId;
                    PostingTable::initGroupRecipients($postingId);
                }
 
                if ($postingId)
                {
                    $arUpdateMailChain['STATUS'] = MailingChainTable::STATUS_SEND;
                    $arUpdateMailChain['AUTO_SEND_TIME'] = Type\DateTime::createFromPhp($timeOfExecute);
                }
 
                $result = Model\LetterTable::update($arMailingChain['ID'], $arUpdateMailChain);
                if (!$result->isSuccess())
                {
                    return "";
                }
            }
        }
 
        (new Runtime\ReiteratedJob())->actualize();
        return '';
    }

    protected static function getDateExecute(
        \DateTime $date,
        ?string $daysOfMonth = '',
        ?string $dayOfWeek = '',
        ?string $timesOfDay = '',
        ?string $monthsOfYear = ''
    )
    {
        $timeOfExecute = null;
 
        $months = MethodSchedule::parseMonthsOfYear($monthsOfYear);
        $arDay = MethodSchedule::parseDaysOfMonth($daysOfMonth);
        $arWeek = MethodSchedule::parseDaysOfWeek($dayOfWeek);
        $arTime = MethodSchedule::parseTimesOfDay($timesOfDay);
 
        if(!$arTime)
            $arTime = array(0,0);
 
        $day = $date->format('j');
        $week = $date->format('N');
        $month = $date->format('n');
 
        if( (!$arDay || in_array($day, $arDay)) && (!$arWeek || in_array($week, $arWeek)) && (!$months || in_array($month, $months)) )
            $timeOfExecute = $date->setTime($arTime[0], $arTime[1]);
 
        return $timeOfExecute;
    }
}