triggerconnector.php

<?php
namespace Bitrix\Sender\Trigger;
 
use Bitrix\Sender\Connector;
 
abstract class TriggerConnector extends Base
{
    public $connector;
 
    final protected function getConnectorForm()
    {
        $endpoint = $this->getConnector();
        if(is_array($endpoint) && !empty($endpoint['CODE']))
        {
            $this->connector = Connector\Manager::getConnector($endpoint);
        }
        elseif(is_object($endpoint) && $endpoint instanceof Connector\Base)
        {
            $this->connector = $endpoint;
        }
 
        if($this->connector)
        {
            $this->connector->setFieldPrefixExtended($this->getFieldPrefix());
            $this->connector->setFieldFormName($this->getFieldFormName());
            $this->connector->setFieldValues($this->getFields());
 
            return $this->connector->getForm();
        }
        else
            return '';
    }
 
    final protected function filterConnectorData()
    {
        $result = true;
 
        $endpoint = $this->getConnector();
        if(is_array($endpoint) && !empty($endpoint['CODE']))
        {
            // do not send mails if connector will not found
            $result = false;
 
            // try to find connector
            $connector = Connector\Manager::getConnector($endpoint);
            $this->connector = $connector;
        }
        elseif(is_object($endpoint) && $endpoint instanceof Connector\Base)
        {
            $this->connector = $endpoint;
        }
 
 
        if($this->connector)
        {
            // merge connector filter and proxy fields. proxy fields have priority
            $connectorFields = $this->getProxyFieldsFromEventToConnector();
            if(!empty($connectorFields))
            {
                $connectorFields = $connectorFields + $this->getFields();
            }
            // set fields to connector
            $this->connector->setFieldValues($connectorFields);
 
 
            $result = false;
            // add recipient from data if connector get it
            $recipientDb = $this->connector->getData();
            if($recipient = $recipientDb->Fetch())
            {
                $this->recipient = $recipient;
                $result = true;
            }
        }
 
        return $result;
    }
 
 
    public function getForm()
    {
        $connectorForm = $this->getConnectorForm();
        if($connectorForm)
            return $connectorForm;
        else
            return '';
    }
 
    public function filter()
    {
        return $this->filterConnectorData();
    }
 
    public function getRecipient()
    {
        return $this->recipient;
    }
 
    public function getProxyFieldsFromEventToConnector()
    {
        $eventData = $this->getParam('EVENT');
        return array('ID' => $eventData['ID']);
    }
 
    public function getRecipientResult()
    {
        $result = parent::getRecipientResult();
        if(!$this->connector)
        {
            return $result;
        }
 
        $personalizeList = array();
        $connectorPersonalizeList = $this->connector->getPersonalizeList();
        foreach($connectorPersonalizeList as $tag)
        {
            if($tag['CODE'] <> '')
            {
                $personalizeList[] = $tag['CODE'];
            }
        }
        $result->setFilterFields(array_merge($result->getFilterFields(),  $personalizeList));
 
        return $result;
    }
 
    public function getConnector()
    {
        return array(
            'MODULE_ID' => '',
            'CODE' => ''
        );
    }
}