eventhandler.php

<?php
namespace Bitrix\Sender\Integration\Crm;
 
use Bitrix\Crm\Activity\BindingSelector;
use Bitrix\Crm\Integrity\ActualEntitySelector;
use Bitrix\Main\Application;
use Bitrix\Main\DB\SqlQueryException;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\Web\Json;
use Bitrix\Sender\Entity;
use Bitrix\Sender\Recipient;
use Bitrix\Sender\Runtime\TimeLineJob;
use Bitrix\Sender\TimeLineQueueTable;
 
Loc::loadMessages(__FILE__);
 
class EventHandler
{
    private const TIME_LINE_COUNT_LIMIT = 500;
    public static function onAfterPostingSendRecipient(array $eventData, Entity\Letter $letter)
    {
        if (!$eventData['SEND_RESULT'])
        {
            return;
        }
 
        static $isModuleIncluded = null;
        if ($isModuleIncluded === null)
        {
            $isModuleIncluded = Loader::includeModule('crm');
        }
 
        if (!$isModuleIncluded)
        {
            return;
        }
 
        if ($letter->getMessage()->isReturnCustomer())
        {
            return;
        }
 
        $recipient = $eventData['RECIPIENT'];
        $fields = $eventData['RECIPIENT']['FIELDS'];
 
        $entityId = $fields['CRM_ENTITY_ID'] ?? $recipient['CONTACT_ID'];
 
        if (!$entityId)
        {
            return;
        }
 
        TimeLineQueueTable::add([
            'RECIPIENT_ID' => $recipient['ID'],
            'POSTING_ID' => $letter->getId(),
            'FIELDS' => Json::encode($fields),
            'ENTITY_ID' => $entityId,
            'CONTACT_TYPE_ID' => $recipient['CONTACT_TYPE_ID'],
            'CONTACT_CODE' => $recipient['CONTACT_CODE'],
        ]);
    }
    public static function onAfterPostingSendRecipientMultiple(array $eventDataArray, Entity\Letter $letter)
    {
        static $isModuleIncluded = null;
 
        if ($isModuleIncluded === null)
        {
            $isModuleIncluded = Loader::includeModule('crm');
        }
 
        if (!$isModuleIncluded)
        {
            return;
        }
 
        if ($letter->getMessage()->isReturnCustomer())
        {
            return;
        }
 
        $dataToInsert = [];
        foreach($eventDataArray as $eventData)
        {
            $recipient = $eventData['RECIPIENT'];
            $fields = $eventData['RECIPIENT']['FIELDS'];
 
            $entityId = $fields['CRM_ENTITY_ID'] ?? $recipient['CONTACT_ID'];
 
            if (!$entityId)
            {
                continue;
            }
 
            $dataToInsert[] = [
                'RECIPIENT_ID' => $recipient['ID'],
                'POSTING_ID' => $letter->getId(),
                'FIELDS' => Json::encode($fields),
                'ENTITY_ID' => $entityId,
                'CONTACT_TYPE_ID' => $recipient['CONTACT_TYPE_ID'],
                'CONTACT_CODE' => $recipient['CONTACT_CODE'],
            ];
        }
 
        if($dataToInsert)
        {
            TimeLineQueueTable::addMulti($dataToInsert, true);
        }
    }
 
    public static function handleTimeLineEvents($letterId)
    {
        static $isModuleIncluded = null;
        if ($isModuleIncluded === null)
        {
            $isModuleIncluded = Loader::includeModule('crm');
        }
 
        if (!$isModuleIncluded)
        {
            return "";
        }
 
        $entityTypeId = $entityId = null;
        $batchData = [];
        $idsToDelete = [];
        self::lockTimelineQueue($letterId);
        $letter = Entity\Letter::createInstanceById($letterId);
 
        try
        {
            $queuedRows = TimeLineQueueTable::getList([
                'filter' => [
                    '=STATUS' => TimeLineQueueTable::STATUS_NEW,
                    '=POSTING_ID' => $letterId
                ],
                'limit' => self::TIME_LINE_COUNT_LIMIT
            ])->fetchAll();
 
            if(empty($queuedRows))
            {
                return "";
            }
 
            foreach ($queuedRows as $row)
            {
                $idsToDelete[] = $row['ID'];
                if (!$letter)
                {
                    continue;
                }
 
                $fields = Json::decode($row['FIELDS']);
                if (isset($fields['CRM_ENTITY_TYPE_ID']) && $fields['CRM_ENTITY_TYPE_ID'])
                {
                    $entityTypeId = $fields['CRM_ENTITY_TYPE_ID'];
                }
                if (isset($fields['CRM_ENTITY_ID']) && $fields['CRM_ENTITY_ID'])
                {
                    $entityId = $fields['CRM_ENTITY_ID'];
                }
 
                if (!$entityTypeId || !$entityId)
                {
                    $selector = self::getEntitySelectorByRecipient(
                        $row['CONTACT_TYPE_ID'],
                        $row['CONTACT_CODE']
                    );
                }
                else
                {
                    $selector = self::getEntitySelectorById($entityTypeId, $entityId);
                }
 
 
                if (!$selector)
                {
                    continue;
                }
 
                if (!$selector->search()->hasEntities())
                {
                    continue;
                }
 
                $recipient = [
                    'ID' => $row['RECIPIENT_ID'],
                    'CONTACT_TYPE_ID' => $row['CONTACT_TYPE_ID'],
                    'CONTACT_CODE' => $row['CONTACT_CODE'],
                ];
 
                $batchData[] = static::buildTimeLineEvent($selector, $letter, $recipient);
            }
 
            if (!empty($batchData))
            {
                Timeline\RecipientEntry::createMulti($batchData);
            }
 
            TimeLineQueueTable::deleteList(['=ID' => $idsToDelete]);
        } catch (\Exception $e)
        {
        }
 
        self::unlockTimelineQueue($letterId);
 
        return TimeLineJob::getAgentName($letterId);
    }
 
    protected static function addTimeLineEvent(ActualEntitySelector $selector, Entity\Base $letter, $recipient)
    {
        $parameters = static::buildTimeLineEvent($selector, $letter, $recipient);
 
        if(!empty($parameters))
        {
            Timeline\RecipientEntry::create($parameters);
        }
    }
 
    protected static function buildTimeLineEvent(ActualEntitySelector $selector, Entity\Base $letter, $recipient)
    {
        $isAd = $letter instanceof Entity\Ad;
        $createdBy = $letter->get('CREATED_BY');
        if (!$createdBy)
        {
            return [];
        }
 
        // convert format to time line
        $bindings = [];
        $activityBindings = BindingSelector::findBindings($selector);
        foreach ($activityBindings as $binding)
        {
            $binding['ENTITY_ID'] = $binding['OWNER_ID'];
            $binding['ENTITY_TYPE_ID'] = $binding['OWNER_TYPE_ID'];
            $bindings[] = [
                'ENTITY_TYPE_ID' => $binding['OWNER_TYPE_ID'],
                'ENTITY_ID' => $binding['OWNER_ID'],
            ];
        }
 
        return [
            'ENTITY_TYPE_ID' => $selector->getPrimaryTypeId(),
            'ENTITY_ID' => $selector->getPrimaryId(),
            'TYPE_CATEGORY_ID' => $letter->getMessage()->getCode(),
            'AUTHOR_ID' => $createdBy,
            'SETTINGS' => [
                'letterId' => $letter->getId(),
                'isAds' => $isAd,
                'recipient' => [
                    'id' => $recipient['ID'],
                    'typeId' => $recipient['CONTACT_TYPE_ID'],
                    'code' => $recipient['CONTACT_ID'],
                ],
            ],
            'BINDINGS' => $bindings
        ];
    }
 
    protected static function getEntitySelector()
    {
        static $selector = null;
        if (!$selector)
        {
            $selector = new ActualEntitySelector();
        }
        else
        {
            $selector->clear();
        }
 
        return $selector;
    }
 
    protected static function getEntitySelectorById($entityTypeId, $entityId)
    {
        return self::getEntitySelector()->setEntity($entityTypeId, $entityId);
    }
 
    protected static function getEntitySelectorByRecipient($recipientTypeId, $recipientCode)
    {
        $selector = self::getEntitySelector();
 
        switch ($recipientTypeId)
        {
            case Recipient\Type::EMAIL:
                $selector->appendEmailCriterion($recipientCode);
                break;
 
            case Recipient\Type::PHONE:
                $selector->appendPhoneCriterion($recipientCode);
                break;
 
            default:
                return null;
        }
 
        return $selector;
    }
 
    protected static function lockTimelineQueue($letterId): bool
    {
        $connection = Application::getInstance()->getConnection();
        $lockName = self::getTimelineQueueLock((string)$letterId);
 
        return $connection->lock($lockName);
    }
 
    protected static function unlockTimelineQueue($letterId): bool
    {
        $connection = Application::getInstance()->getConnection();
        $lockName = self::getTimelineQueueLock((string)$letterId);
 
        return $connection->unlock($lockName);
    }
 
    private static function getTimelineQueueLock(string $letterId): string
    {
        return "time_line_queue_$letterId";
    }
}