adapter.php

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

<?php
 
namespace Bitrix\Sender\Message;
 
use Bitrix\Main\ArgumentException;
use Bitrix\Main\SiteTable;
use Bitrix\Sender\Integration;
use Bitrix\Sender\Transport;

class Adapter implements iBase
{
    public const PATTERN_STATUS_ITEM = 'ENTITY_ID_';
    protected static $list;
    protected static $statuses = [];
    protected ?\Bitrix\Crm\Service\Factory $factory = null;

    protected $message;

    protected $tester;

    protected $configuration;

    protected $transport;

    protected $fields = array();

    protected $siteId = null;

    protected $siteData = null;

    protected $recipientCode;

    protected $recipientId;

    protected $recipientType;

    protected $recipientData;

    protected $readTracker;

    protected $clickTracker;

    protected $unsubTracker;

    public static function getInstance($code)
    {
        return isset(self::$list[$code]) ? self::$list[$code] : self::create($code);
    }

    public static function create($code)
    {
        $message = Factory::getMessage($code);
        if (!$message)
        {
            throw new ArgumentException($code);
        }
 
        return new static($message);
    }

    public function __construct(iBase $message)
    {
        $this->message = $message;
        $this->loadConfiguration();
 
        $this->readTracker = new Tracker(Tracker::TYPE_READ);
        $this->clickTracker = new Tracker(Tracker::TYPE_CLICK);
        $this->unsubTracker = new Tracker(Tracker::TYPE_UNSUB);
    }

    public function getName()
    {
        return $this->message->getName();
    }

    public function getTransport()
    {
        if ($this->transport)
        {
            return $this->transport;
        }
 
        $transportCode = $this->configuration->get('TRANSPORT_CODE') ?: current($this->message->getSupportedTransports());
        //$transportConfigId = $this->configuration->get('TRANSPORT_CONFIGURATION_ID');
        $this->transport = Transport\Adapter::create($transportCode);
        $this->transport->saveConfiguration($this->getConfiguration());
        $this->transport->loadConfiguration();
 
        return $this->transport;
    }

    public function setTransport(Transport\Adapter $transport)
    {
        $this->transport = $transport;
    }

    public function getCode()
    {
        return $this->message->getCode();
    }

    public function getId()
    {
        return $this->configuration->getId();
    }

    public function getSupportedTransports()
    {
        return $this->message->getSupportedTransports();
    }

    public function getSupportedRecipientTypes()
    {
        return $this->getTransport()->getSupportedRecipientTypes();
    }

    public function getTester()
    {
        if (!$this->tester)
        {
            $this->tester = new Tester($this);
        }
 
        return $this->tester;
    }

    public function loadConfiguration($id = null)
    {
        $this->configuration = $this->message->loadConfiguration($id);
        return $this->configuration;
        /*
        if (!$this->configuration)
        {
            $this->configuration = $this->message->loadConfiguration($id);
        }
 
        return $this->configuration;
        */
    }

    public function setConfigurationData(array $data)
    {
        foreach ($data as $key => $value)
        {
            $this->configuration->set($key, $value);
        }
    }

    public function getConfiguration()
    {
        return $this->configuration;
    }

    public function saveConfiguration(Configuration $configuration)
    {
        $result = $this->message->saveConfiguration($configuration);
        if ($result === null)
        {
            $result = new Result();
        }
 
        return $result;
    }

    public function copyConfiguration($id)
    {
        $result = $this->message->copyConfiguration($id);
        if ($result === null)
        {
            $result = new Result();
        }
 
        return $result;
    }

    public function getField($key)
    {
        return isset($this->fields[$key]) ? $this->fields[$key] : null;
    }

    public function getFields()
    {
        return $this->fields;
    }

    public function setFields(array $fields)
    {
        foreach ($fields as $key => $field)
        {
            $fields[$key] = nl2br(htmlspecialcharsbx((string) $field, ENT_COMPAT, false));
        }
 
        $this->fields = $fields;
    }

    public function replaceFields($content = "", $replaceChar = '#', $crmEntityTypeId = null)
    {
        $from = [];
        $to = [];
        foreach ($this->getFields() as $code => $value)
        {
            $handledCode = $this->preHandleReplaceCode($code, $crmEntityTypeId);
            $from[] = "$replaceChar$handledCode$replaceChar";
            $value = $this->preHandleReaplaceValue($code, $value);
            $to[] = nl2br(htmlspecialcharsbx((string)$value, ENT_COMPAT, false));
        }
 
        return Integration\Sender\Mail\TransportMail::replaceTemplate(str_replace($from, $to, $content));
    }

    public function getTo()
    {
        return $this->recipientCode;
    }

    public function getRecipientCode()
    {
        return $this->recipientCode;
    }

    public function setRecipientCode($code)
    {
        $this->recipientCode = $code;
    }

    public function getRecipientId()
    {
        return $this->recipientId;
    }

    public function setRecipientId($id)
    {
        $this->recipientId = $id;
    }

    public function getRecipientType()
    {
        return $this->recipientType;
    }

    public function setRecipientType($type)
    {
        $this->recipientType = $type;
    }

    public function getRecipientData()
    {
        return $this->recipientData;
    }

    public function setRecipientData(array $data)
    {
        $this->recipientData = $data;
    }

    public function getReadTracker()
    {
        return $this->readTracker;
    }

    public function getClickTracker()
    {
        return $this->clickTracker;
    }

    public function getUnsubTracker()
    {
        return $this->unsubTracker;
    }

    public function send()
    {
        if (!$this->getTransport())
        {
            return false;
        }
 
        return $this->getTransport()->send($this);
    }

    public function getSendDuration()
    {
        if (!$this->getTransport())
        {
            return 0;
        }
 
        return $this->getTransport()->getDuration($this);
    }

    public function setSiteId($id = null)
    {
        $this->siteId = $id;
    }

    public function getSiteId()
    {
        $siteData = $this->getSiteData($this->siteId);
        return isset($siteData['LID']) ? $siteData['LID'] : SITE_ID;
    }

    public function getCharset()
    {
        $siteData = $this->getSiteData($this->siteId);
        return isset($siteData['CHARSET']) ? $siteData['CHARSET'] : SITE_CHARSET;
    }

    public function getSiteName()
    {
        $siteData = $this->getSiteData($this->siteId);
        return isset($siteData['SITE_NAME']) ? $siteData['SITE_NAME'] : SITE_ID;
    }

    public function getSiteServerName()
    {
        $siteData = $this->getSiteData($this->siteId);
        return isset($siteData['SERVER_NAME']) ? $siteData['SERVER_NAME'] : null;
    }

    private function getSiteData($id)
    {
        if ($this->siteData !== null)
        {
            $this->siteData;
        }
 
        $this->siteData = array();
        $siteDb = SiteTable::getList(array(
            'select'=>array('LID', 'SERVER_NAME', 'NAME', 'CHARSET'=>'CULTURE.CHARSET'),
            'filter' => array('=LID' => $id ?: SITE_ID)
        ));
        if($site = $siteDb->fetch())
        {
            $site['SITE_NAME'] = $site['NAME'];
            unset($site['NAME']);
            $this->siteData = $site;
        }
 
        return $this->siteData;
    }

    public function isAds()
    {
        return $this->message instanceof iAds;
    }

    public function isMarketing()
    {
        return $this->message instanceof iMarketing;
    }

    public function isMailing()
    {
        return $this->message instanceof iMailable;
    }

    public function isReturnCustomer()
    {
        return $this->message instanceof iReturnCustomer;
    }

    public function isMasterYandex(): bool
    {
        return $this->message instanceof iMasterYandex;
    }

    public function isHidden()
    {
        return ($this->message instanceof iHideable && $this->message->isHidden());
    }

    public function isAvailable()
    {
        if ($this->message instanceof iAds)
        {
            return Integration\Bitrix24\Service::isAdAvailable();
        }
 
        if ($this->message instanceof iReturnCustomer)
        {
            return Integration\Bitrix24\Service::isRcAvailable();
        }
 
        switch ($this->getCode())
        {
            case iBase::CODE_MAIL:
                return Integration\Bitrix24\Service::isEmailAvailable();
            case iBase::CODE_MASTER_YANDEX:
                return Integration\Bitrix24\Service::isMasterYandexAvailable();
 
            default:
                return Integration\Bitrix24\Service::isMailingsAvailable();
        }
    }

    public function hasStatistics()
    {
        switch ($this->getCode())
        {
            case iBase::CODE_MAIL:
                return true;
 
            default:
                return false;
        }
    }

    public function getAudioValue($optionCode, $newValue)
    {
        if ($this->message instanceof iAudible)
        {
            return $this->message->getAudioValue($optionCode, $newValue);
        }
        return $newValue;
    }
 
    public function onBeforeStart()
    {
        if ($this->message instanceof iBeforeAfter)
        {
            return $this->message->onBeforeStart();
        }
        return new \Bitrix\Main\Result();
    }
 
    public function onAfterEnd()
    {
        if ($this->message instanceof iBeforeAfter)
        {
            return $this->message->onAfterEnd();
        }
        return new \Bitrix\Main\Result();
    }

    public function getEntityCode()
    {
        return $this->message->getEntityCode();
    }
 
    public function preHandleReaplaceValue($code, $value)
    {
        $parts = explode('.', $code, 2);
        if (count($parts) === 1)
        {
            return $value;
        }
 
        $entityId = $parts[1];
 
        if (!self::$statuses)
        {
            $refClass = new \ReflectionClass(\Bitrix\Crm\StatusTable::class);
            $refConstants = $refClass->getConstants();
            if (is_iterable($refConstants))
            {
                foreach ($refConstants as $key => $refConstant)
                {
                    if (mb_strpos($key, self::PATTERN_STATUS_ITEM) !== false)
                    {
                        self::$statuses[] = $refConstant;
                    }
                }
            }
        }
 
        if (!in_array($entityId, self::$statuses, true))
        {
            return $value;
        }
 
        $values = \Bitrix\Crm\StatusTable::getStatusesList($entityId);
        if (array_key_exists($value, $values))
        {
            return $values[$value];
        }
 
        return $value;
    }
 
    public function preHandleReplaceCode($code, $crmEntityTypeId)
    {
        $parts = explode('.', $code, 2);
        if (count($parts) === 1)
        {
            return $code;
        }
 
        if (
            $crmEntityTypeId !== null
            && (!$this->factory || $this->factory->getEntityTypeId() !== $crmEntityTypeId)
        )
        {
            $this->factory = \Bitrix\Crm\Service\Container::getInstance()->getFactory($crmEntityTypeId);
        }
 
        if ($this->factory)
        {
            $parts[1] = $this->factory->getCommonFieldNameByMap($parts[1]);
            return implode('.', $parts);
        }
 
        return $code;
    }
}