Часть 2. Персонализируем коммуникации

Привет! Меня зовут Анна Амирова, я из digital-интегратора БизнесПрофи. Сегодня возвращаюсь со второй частью статьи о том, как работает и чем помогает маркетологам и отделу продаж CDP на базе Битрикс24.

В предыдущей части статьи говорилось о том, какие методы сегментации можно использовать, чтобы выделить целевые аудитории для различных задач маркетинга и продаж. Сегодня речь пойдет о том, как реализованы рассылки в нашей CDP и как они позволяют работать с собранными сегментами ЦА.

Как объединить разные каналы рассылки в одном сервисе

CDP работает со всеми основными каналами рассылок: email, смс, WhatsApp и Телеграм.

Несмотря на то, что в Битрикс24 есть стандартные коннекторы для подключения всех перечисленных каналов, в CDP большей частью используются собственные решения. Например для интеграции с WhatsApp и для email-рассылок. Ниже объясню, почему.

Для рассылок через WhatsApp мы можем использовать официальную интеграцию через WhatsApp Business API, она требует наличия бизнес-аккаунта, и серую интеграцию через сервис OLChat с использованием большого числа обычных аккаунтов.

Рассылка через WhatsApp

WhatsApp активно борется с автоматизированной рассылкой, особенно если она выглядит подозрительно. Основные признаки, которые могут спровоцировать блокировку:

- Частые отправки сообщений подряд, особенно на новые номера.
- Идентичные тексты в сообщениях.
- Отсутствие персонализации.
- Отсутствие предыдущего взаимодействия с получателем.

Если сервис обнаруживает подобные действия, он может интерпретировать их как спам и заблокировать номер.

Чтобы избежать блокировки и сделать работу с WhatsApp эффективной, рекомендуется использовать интеграцию через WhatsApp Business API, который интегрирован в наш модуль CDP. При такой рассылке каждый шаблон сообщения должен быть согласован с сервисом. Риск блокировки минимизирован, но данная рассылка по стоимости сопоставима c отправкой смс.

Для сокращения бюджета на отправку сообщений через WhatsApp в модуле предусмотрена возможность рассылки через обычные аккаунты с помощью сервиса OLChat. При данной схеме увеличивается риск блокировки, но значительно сокращается бюджет на отправку. Для минимизации рисков мы внедрили собственный метод прогрева номеров. Он позволяет постепенно «настроить» сервис на работу с вашим номером, снижая риск автоматического ограничения.

За каждым клиентом мы закрепляем номер, с которого будут уходить сообщения, с тем, чтобы следующие сообщения не приходили с разных номеров. На уровне провайдера это не контролируется, он просто предоставляет номера, поэтому нам пришлось доработать решение.

Этапы прогрева, которые мы используем в нашем модуле:

1. Первые 2–3 дня — только ручное общение. Номер должен «показать себя» как настоящий пользователь, а не бот.
2. Следующие 2–3 дня — автоматизированная отправка с большим интервалом (2 минуты между сообщениями).
3. Следующие 2–3 дня — интервал сокращается до 1 минуты.
4. Следующие 2 недели — интервал уменьшается до 30 секунд.

После указанных этапов можно отправлять сообщения с интервалом 15 секунд, но не меньше.

Чем дольше номер «работает» без жалоб, тем выше его доверие в глазах WhatsApp. Важно не только соблюдать интервалы, но и делать каждое сообщение уникальным.

Работа с подтвержденными и неподтвержденными клиентами

Для эффективного управления рассылками в настройках номера для отправки сообщений мы разграничиваем интервалы отправок:

Интервал между сообщениями для подтвержденных клиентов — уменьшаем для тех, кто уже получал сообщения и откликнулся на них.
Интервал между сообщениями для неподтвержденных клиентов — увеличиваем для тех, кому отправляется первое сообщение.

Регулируем данные лимиты настройкой количества сообщений для каждого номера. При достижении установленного лимита, система перестаёт отправлять сообщения с номера, чтобы избежать перегрузки и блокировки.

Вот так выглядят настройки для каждого из номеров:

Работа с WhatsApp в автоматизированном режиме через модуль CDP требует тщательного подхода. Правильный прогрев номера, соблюдение интервалов между сообщениями и персонализация текста — ключевые факторы, которые помогут избежать блокировок и повысить эффективность коммуникации. Использование нескольких номеров и грамотная настройка групп позволяет масштабировать рассылки и сохранять стабильную интеграцию с сервисом.

С подробным техническим описанием процесса WhatsApp-рассылок можете ознакомиться здесь

Рассылка сообщений по каналу WhatsApp происходит в несколько этапов.

1. Для каждого клиента рассылки определяем, не было ли нами замечено ранее, что у клиента нет WhatsApp.
Информацию о том, есть WhatsApp или нет мы можем получить только после отправки сообщения. Если после первой отправки мы определяем, что у клиента нет WhatsApp, то мы фиксируем это в специальной таблице в БД. А тут проверяем наличие записи в этой таблице.

2. Для каждого клиента рассылки определяем, с какого номера ему нужно отправить сообщение.

namespace Bizprofi\Cdp\Helpers;

class WhatsappSenderDetectHelper
{
// ... тут есть другая логика хелпера
    public function getSenderByClient(Contact|Company $client, bool $first = false): ?WhatsappSender
    {
        // Есть ли у клиента whatsapp
        if (! $this-&gt;getWhatsappAvailabilityByClient($client)) {
            return null;
        }

        // Если в контакте/компании в специальном свойстве указан номер с которого отправлять
        if ($sender = $this-&gt;getSenderByClientUf($client)) {
            return $sender;
        }

        // Если клиенту уже отправлялось сообщение ранее, но он на него не среагировал
        if ($sender = $this-&gt;getSenderByLastMessage($client)) {
            return $sender;
        }

        // Отправляем сообщение с первого из доступных номеров для отправки.
        if ($first &amp;&amp; ($sender = $this-&gt;getFirstAvailableSender($client))) {
            return $sender;
        }

        // Отправляем сообщение с случайного из доступных номеров для отправки.
        if ($sender = $this-&gt;getRandomAvailableSender($client)) {
            return $sender;
        }

        return null;
    }

    public function getWhatsappAvailabilityByClient(Contact|Company $client): bool
    {
        $clientInfo = $this-&gt;whatsappClientInfos-&gt;getByPrimary([
            'ENTITY' =&gt; $this-&gt;entity,
            'ENTITY_ID' =&gt; $client-&gt;getId(),
        ]);

        // Если нет записи предполагаем что есть whatsapp
        if (! $clientInfo) {
            return true;
        }

        return $clientInfo-&gt;getWhatsappAvailability();
    }

    protected function getSenderByClientUf(Contact|Company $client): ?WhatsappSender
    {
        if (! ($uf = $this-&gt;getUserFieldCode())) {
            return null;
        }

        try {
            $phoneNumber = $client-&gt;get($uf);
        } catch (\Exception $ex) {
            $phoneNumber = null;
        }

        $senders = WhatsappSenderTable::getAll();
        if (! ($sender = $senders-&gt;getByPrimary($phoneNumber))) {
            return null;
        }

        if ($sender-&gt;getInSpamAtClient($client)) {
            return null;
        }

        return $sender;
    }

    protected function getUserFieldCode(): ?string
    {
        return match ($this-&gt;entity) {
            EntityType::COMPANY =&gt; WhatsappSettingsHelper::getCompanyPhoneNumberField(),
            EntityType::CONTACT =&gt; WhatsappSettingsHelper::getContactPhoneNumberField(),
        };
    }

    protected function getSenderByLastMessage(Contact|Company $client): ?WhatsappSender
    {
        /**
         * @var EO_WhatsappMessage $lastMessage
         */
        if (! ($lastMessage = $this-&gt;clientIdToLastMessage[$client-&gt;getId()])) {
            return null;
        }

        $senders = WhatsappSenderTable::getAll();
        if (! ($sender = $senders-&gt;getByPrimary($lastMessage-&gt;getPhoneNumber()))) {
            return null;
        }

        if ($sender-&gt;getInSpamAtClient($client)) {
            return null;
        }

        $secondsFromLastMessage = (new DateTime())-&gt;getTimestamp() - $lastMessage-&gt;getSendDate()-&gt;getTimestamp();
        if ($secondsFromLastMessage &lt;= WhatsappSettingsHelper::getIgnoreMessageSeconds()) {
            return $sender;
        }

        if ($sender-&gt;getFreeClientsCount() &gt; 0) {
            return $sender;
        }

        return null;
    }

    protected function getFirstAvailableSender(Contact|Company $client): ?WhatsappSender
    {
        if (!($clientInGroups = $this-&gt;getClientSenderGroups($client))) {
            return null;
        }

        foreach (WhatsappSenderTable::getAll()-&gt;getAvailableSenders() as $sender) {
            if ($sender-&gt;getInSpamAtClient($client)) {
                continue;
            }

            if (count(array_intersect($clientInGroups, $sender-&gt;getGroups()-&gt;getIdList())) &gt; 0) {
                return $sender;
            }
        }

        return null;
    }

    protected function getClientSenderGroups(Contact|Company $client): ?array
    {
        $clientInGroups = [];
        foreach ($this-&gt;groupIdToClientIds as $groupId =&gt; $clientIds) {
            if (in_array($client-&gt;getId(), $clientIds, true)) {
                $clientInGroups[] = $groupId;
            }
        }

        return count($clientInGroups) &gt; 0 ? $clientInGroups: null;
    }

    protected function getRandomAvailableSender(Contact|Company $client): ?WhatsappSender
    {
        if (!($clientInGroups = $this-&gt;getClientSenderGroups($client))) {
            return null;
        }

        $allAvailableSenders = WhatsappSenderTable::getAll()-&gt;getAvailableSenders();

        $allowedSenderNumbers = [];
        foreach ($allAvailableSenders as $sender) {
            if ($sender-&gt;getInSpamAtClient($client)) {
                continue;
            }

            if (count(array_intersect($clientInGroups, $sender-&gt;getGroups()-&gt;getIdList())) &lt;= 0) {
                continue;
            }

            $allowedSenderNumbers[] = $sender-&gt;getPhoneNumber();
        }

        if (count($allowedSenderNumbers) &lt;= 0) {
            return null;
        }

        if (count($allowedSenderNumbers) === 1) {
            return $allAvailableSenders-&gt;getByPrimary($allowedSenderNumbers[0]);
        }

        return $allAvailableSenders-&gt;getByPrimary(
            $allowedSenderNumbers[array_rand($allowedSenderNumbers)]
        );
    }
// ... там далее другая логика хелпера
}

3. Если номер, с которого отправлять удалось определить, то добавляем запись в таблицу WhatsApp сообщений со статусом "Ожидает отправки". Если не удалось определить, то добавляем со статусом "Не валидно" и комментарием с причиной не валидности.

4. Раз в 15 минут запускается агент, который проверяет таблицу WhatsApp сообщений на наличие писем, которые нужно отправить. Если такие письма есть, то для каждого номера, с которого надо отправить в фоновом режиме запускаем отправку сообщений. В фоновом режиме, чтобы не блокировать работу агентов, поскольку в процессе отправки стоят паузы.

5. Контроллер отправки сообщений с конкретного номера берет из таблицы WhatsApp сообщений по 12 сообщений за итерацию и поочередно отправляет их, после каждой отправки выставляется пауза соответственно установленным ограничениям на номере. Если по завершению итерации в базе еще есть сообщения, которые нужно отправить с этого номера, то контроллер вызывает сам себя в фоновом режиме и завершает работу. И так до тех пор пока не будут отправлены все сообщения. В запуске контроллера предусмотрена защита от повторного запуска, если отправка с номера телефона уже запущена, то повторная — не запустится.

namespace Bizprofi\Cdp\Controllers\Actions\DistributionWhatsapp;

use Bitrix\Main\Application;
use Bitrix\Main\Config\Option;
use Bitrix\Main\Engine\Action;
use Bitrix\Main\Engine\UrlManager;
use Bitrix\Main\Error;
use Bitrix\Main\ORM\Objectify\State;
use Bitrix\Main\Result;
use Bitrix\Main\Type\DateTime;
use Bitrix\Main\Web\HttpClient;
use Bizprofi\Cdp\DataManagers\DistributionTable;
use Bizprofi\Cdp\DataManagers\Whatsapp\EO_WhatsappClientInfo;
use Bizprofi\Cdp\DataManagers\Whatsapp\EO_WhatsappClientInfo_Collection;
use Bizprofi\Cdp\DataManagers\Whatsapp\EO_WhatsappMessage;
use Bizprofi\Cdp\DataManagers\Whatsapp\WhatsappClientInfoTable;
use Bizprofi\Cdp\DataManagers\Whatsapp\WhatsappMessageTable;
use Bizprofi\Cdp\DataManagers\Whatsapp\WhatsappSenderHistoryTable;
use Bizprofi\Cdp\Enums\Whatsapp\WhatsappMessageStatus;
use Bizprofi\Cdp\Enums\Whatsapp\WhatsappSenderHistoryAction;
use Bizprofi\Cdp\Integrations\OlChat\ApiRequests\SendFileApiRequest;
use Bizprofi\Cdp\Integrations\OlChat\ApiRequests\SendTextApiRequest;
use Bizprofi\Cdp\Integrations\OlChat\ApiResponses\AbstractApiResponse;
use Bizprofi\Cdp\Integrations\OlChat\ApiResponses\FailureApiResponse;
use Bizprofi\Cdp\Integrations\OlChat\ApiResponses\SendFileApiResponse;
use Bizprofi\Cdp\Integrations\OlChat\ApiResponses\SendTextApiResponse;
use Bizprofi\Cdp\Models\Whatsapp\WhatsappSender;

class SendMessagesAction extends Action
{
    /**
     * BX.ajax.runAction('bizprofi:cdp.Controllers.DistributionWhatsappController.sendMessages', {data: {phoneNumber: '79111111111'}})
     * @param WhatsappSender $whatsappSender
     * @return array
     */
    public function run(WhatsappSender $whatsappSender): array
    {
        // Пишем в историю о начале отправки сообщений
        $result = $this-&gt;logStartTime($whatsappSender);
        if (! $result-&gt;isSuccess()) {
            $this-&gt;addErrors($result-&gt;getErrors());
            return [];
        }

        // Получаем апи клиент для отправки сообщений
        if (! ($whatsappSender-&gt;getApiClient())) {
            $this-&gt;addError(
                new Error('Failure get api client for whatsapp sender')
            );
            return [];
        }

        // Флаг наличия сообщений для отправки
        $thereAreMessages = false;

        // Переберем сообщения на отправку
        /**
         * @var EO_WhatsappMessage $message
         */
        foreach ($this-&gt;getNextMessages($whatsappSender) as $message) {
            $thereAreMessages = true;

            // Отправку и изменение сообщения в БД делаем в ттранзакции
            Application::getConnection()-&gt;startTransaction();

            // Меняем статус и дату отправки
            $message-&gt;setStatus(WhatsappMessageStatus::IN_PROCESS);
            $message-&gt;setSendDate(new DateTime());
            $result = $message-&gt;save();
            if (! $result-&gt;isSuccess()) {
                $this-&gt;addErrors($result-&gt;getErrors());
                Application::getConnection()-&gt;rollbackTransaction();
                continue;
            }

            // Отправляем сообщение
            $result = $this-&gt;sendWhatsappMessage($whatsappSender, $message);
            if (! $result-&gt;isSuccess()) {
                $this-&gt;addErrors($result-&gt;getErrors());
            }

            // Сохраняем сообщение еще раз после отправки, так как там поменялся статус
            $saveResult = $message-&gt;save();
            if (! $saveResult-&gt;isSuccess()) {
                $this-&gt;addErrors($saveResult-&gt;getErrors());
                Application::getConnection()-&gt;rollbackTransaction();
                continue;
            }

            // Закрываем транзакцию
            Application::getConnection()-&gt;commitTransaction();

            // Фиксируем в истории отправку сообщения
            $this-&gt;logSendMessage($whatsappSender, $message, $result);

            // Ставим паузу до отправки следующего сообщения
            $this-&gt;sleepAfterSendMessage($whatsappSender, $message);
        }

        // Повторяем запуск до тех пор пока не закончатся сообщения на отправку
        if ($thereAreMessages) {
            static::runSelfInBackground($whatsappSender);
        }

        return [];
    }

    protected function logStartTime(WhatsappSender $whatsappSender): Result
    {
        $history = WhatsappSenderHistoryTable::createObject();
        $history-&gt;setPhoneNumber($whatsappSender-&gt;getPhoneNumber());
        $history-&gt;setAction(WhatsappSenderHistoryAction::START_SENDING);
        $history-&gt;setActionDate(new DateTime());
        $history-&gt;setData([]);
        return $history-&gt;save();
    }

    protected function logFinishTime(WhatsappSender $whatsappSender): Result
    {
        $history = WhatsappSenderHistoryTable::createObject();
        $history-&gt;setPhoneNumber($whatsappSender-&gt;getPhoneNumber());
        $history-&gt;setAction(WhatsappSenderHistoryAction::FINISH_SENDING);
        $history-&gt;setActionDate(new DateTime());
        $history-&gt;setData([]);
        return $history-&gt;save();
    }

    protected function logSendMessage(WhatsappSender $whatsappSender, EO_WhatsappMessage $message, Result $result): Result
    {
        $history = WhatsappSenderHistoryTable::createObject();
        $history-&gt;setPhoneNumber($whatsappSender-&gt;getPhoneNumber());
        $history-&gt;setAction(WhatsappSenderHistoryAction::SEND);
        $history-&gt;setActionDate(new DateTime());
        $history-&gt;setData([
            'messageId' =&gt; $message-&gt;getId(),
            'status' =&gt; $result-&gt;isSuccess() ? 'success': 'failure',
            'data' =&gt; $result-&gt;getData(),
            'messages' =&gt; $result-&gt;getErrorMessages(),
        ]);
        return $history-&gt;save();
    }

    protected function getNextMessages(WhatsappSender $whatsappSender): \Generator
    {
        $currentHour = (new DateTime())-&gt;format('H');

        // Формируем запрос на получение сообщений для отправки
        $rows = WhatsappMessageTable::query()
            -&gt;setSelect(['*', 'DSESES'])
            -&gt;where('PHONE_NUMBER', $whatsappSender-&gt;getPhoneNumber())
            -&gt;where('STATUS', WhatsappMessageStatus::WAIT)
            -&gt;whereIn(
                'DSESES.DISTRIBUTION_ID',
                DistributionTable::query()
                    -&gt;addSelect('ID')
                    -&gt;where('DISTRIBUTION_WHATSAPP.SENDING_START_TIME', '&lt;=', $currentHour)
                    -&gt;where('DISTRIBUTION_WHATSAPP.SENDING_END_TIME', '&gt;', $currentHour)
            )
            -&gt;setLimit(12)
            -&gt;exec();

        if ($rows-&gt;getSelectedRowsCount() &lt;= 0) {
            $result = $this-&gt;logFinishTime($whatsappSender);
            if (! $result-&gt;isSuccess()) {
                $this-&gt;addErrors($result-&gt;getErrors());
            }

            return;
        }

        while ($whatsappMessage = $rows-&gt;fetchObject()) {
            yield $whatsappMessage;
        }
    }

    protected function sendWhatsappMessage(WhatsappSender $whatsappSender, EO_WhatsappMessage $message): Result
    {
        $message-&gt;setSendDate(new DateTime());

        $sendFileResponse = $this-&gt;sendWhatsappFileMessage($whatsappSender, $message);
        if (! $sendFileResponse-&gt;isSuccess()) {
            return $sendFileResponse;
        }

        $sendTextResponse = $this-&gt;sendWhatsappTextMessage($whatsappSender, $message);
        if (! $sendTextResponse-&gt;isSuccess()) {
            return $sendTextResponse;
        }

        return new Result();
    }

    protected function sendWhatsappFileMessage(WhatsappSender $whatsappSender, EO_WhatsappMessage $message): Result
    {
        if ((int) $message-&gt;getFileId() &lt;= 0) {
            return new Result();
        }

        /**
         * @var FailureApiResponse|SendTextApiResponse $sendTextResponse
         */
        $response = $whatsappSender-&gt;getApiClient()-&gt;executeRequest(
            new SendFileApiRequest(
                $message-&gt;getClientPhoneNumber(),
                (int) $message-&gt;getFileId(),
                'Y'
            )
        );

        return $this-&gt;checkWhatsappMessageApiResponse($message, $response);
    }

    protected function checkWhatsappMessageApiResponse(EO_WhatsappMessage $message, AbstractApiResponse $response): Result
    {
        if ($response instanceof FailureApiResponse) {
            return $this-&gt;checkWhatsappMessageFailureApiResponse($message, $response);
        }

        if ($response instanceof SendFileApiResponse || $response instanceof SendTextApiResponse) {
            return $this-&gt;checkWhatsappMessageSuccessApiResponse($message, $response);
        }

        return new Result();
    }

    protected function checkWhatsappMessageFailureApiResponse(EO_WhatsappMessage $message, FailureApiResponse $response): Result
    {
        $message-&gt;setStatus(WhatsappMessageStatus::FAILURE);

        $result = new Result();
        $result-&gt;addError(
            new Error($response-&gt;message)
        );

        if (! $response-&gt;isNumberNotFoundFailure()) {
            return $result;
        }

        $saveClientInfoResult = $this-&gt;recordMessageNotWhatsappAvailability($message);
        if (! $saveClientInfoResult-&gt;isSuccess()) {
            $result-&gt;addErrors(
                $saveClientInfoResult-&gt;getErrors()
            );
        }

        return $result;
    }

    protected function recordMessageNotWhatsappAvailability(EO_WhatsappMessage $message): Result
    {
        $clientInfos = $this-&gt;getClientInfosByMessage($message);

        foreach ($clientInfos as $clientInfo) {
            $clientInfo-&gt;setWhatsappAvailability(false);
        }

        return $clientInfos-&gt;save(true);
    }

    protected function getClientInfosByMessage(EO_WhatsappMessage $message): EO_WhatsappClientInfo_Collection
    {
        $clientInfos = WhatsappClientInfoTable::createCollection();

        $dseses = $message-&gt;getDseses() ?: [];
        foreach ($dseses as $dses) {
            $clientInfo = WhatsappClientInfoTable::getByPrimary([
                'ENTITY' =&gt; $dses-&gt;getEntity(),
                'ENTITY_ID' =&gt; $dses-&gt;getEntityId(),
            ])-&gt;fetchObject();

            if (! $clientInfo) {
                $clientInfo = WhatsappClientInfoTable::createObject();
                $clientInfo-&gt;setEntity($dses-&gt;getEntity());
                $clientInfo-&gt;setEntityId($dses-&gt;getEntityId());
            }

            $clientInfos-&gt;add($clientInfo);
        }


        return $clientInfos;
    }

    protected function checkWhatsappMessageSuccessApiResponse(EO_WhatsappMessage $message, SendFileApiResponse|SendTextApiResponse $response): Result
    {
        $message-&gt;setWhatsappMessageId($response-&gt;messageId);

        if (! $response-&gt;isSent()) {
            $message-&gt;setStatus(WhatsappMessageStatus::SPAM);

            return $this-&gt;recordMessageHowSpam($message);
        }

        return $this-&gt;recordMessageWhatsappAvailability($message);
    }

    protected function recordMessageHowSpam(EO_WhatsappMessage $message): Result
    {
        $clientInfos = $this-&gt;getClientInfosByMessage($message);

        foreach ($clientInfos as $clientInfo) {
            $senderToSpamDate = $clientInfo-&gt;getSenderToSpamDate() ?: [];
            $senderToSpamDate[$message-&gt;getPhoneNumber()] = (new DateTime())-&gt;getTimestamp();

            $clientInfo-&gt;setSenderToSpamDate($senderToSpamDate);
        }

        return $clientInfos-&gt;save(true);
    }

    protected function recordMessageWhatsappAvailability(EO_WhatsappMessage $message): Result
    {
        $clientInfos = $this-&gt;getClientInfosByMessage($message);

        foreach ($clientInfos as $clientInfo) {
            if ($clientInfo-&gt;state !== State::RAW) {
                continue;
            }

            $clientInfo-&gt;setWhatsappAvailability(true);
            $clientInfo-&gt;setDateWhatsappAvailability(new DateTime());
        }

        return $clientInfos-&gt;save(true);
    }

    protected function sendWhatsappTextMessage(WhatsappSender $whatsappSender, EO_WhatsappMessage $message): Result
    {
        if (strlen((string) $message-&gt;getMessageBody()) &lt;= 0) {
            return new Result();
        }

        /**
         * @var FailureApiResponse|SendTextApiResponse $sendTextResponse
         */
        $response = $whatsappSender-&gt;getApiClient()-&gt;executeRequest(
            new SendTextApiRequest(
                $message-&gt;getClientPhoneNumber(),
                $message-&gt;getMessageBody(),
                'Y'
            )
        );

        return $this-&gt;checkWhatsappMessageApiResponse($message, $response);
    }

    // Паузы между сообщениями делаем не статическими. Берем случайное значение между интервалом указанным в настройках модуля
    // и этим же интервалом увеличеным в двое для не не подтвержденных клиентов и в полтора раза для подтвержденных клиентов
    // таким образом имитируем человечность
    protected function sleepAfterSendMessage(WhatsappSender $whatsappSender, EO_WhatsappMessage $message): void
    {
        $factor = 2;
        $interval = $whatsappSender-&gt;getMessageIntervalForUnverified();
        if ($message-&gt;getIsConfirmed()) {
            $factor = 1.5;
            $interval = $whatsappSender-&gt;getMessageIntervalForVerified();
        }

        sleep(rand($interval, $interval * $factor));
    }

    public static function runSelfInBackground(WhatsappSender $whatsappSender): void
    {
        $httpClient = new HttpClient(['waitResponse' =&gt; false]);
        $httpClient-&gt;get(
            UrlManager::getInstance()-&gt;create(
                'bizprofi:cdp.Controllers.DistributionWhatsappController.sendMessages',
                [
                    'phoneNumber' =&gt; $whatsappSender-&gt;getPhoneNumber(),
                ],
                true
            )-&gt;withScheme((int) Option::get('bizprofi.cdp', 'use_https') === 1 ? 'https': 'http')
        );
    }
}

6. Раз в час запускается агент, который определяет номера телефонов, для которых синхронизация статусов не выполнялась более часа. Для таких номеров запускается синхронизация статусов сообщений в фоновом режиме. В фоновом режиме, чтобы не задерживать работу агентов.

7. Контроллер синхронизации статусов для конкретного номера выбирает 12 сообщений, статус которых — "Отправлено", и проверяет не изменился ли их статус, если статус изменился, то меняем его в рассылке.

Рассылка через email

Для отправки email-рассылок в CDP используется интеграция с сервисом DashaMail. Это позволяет снизить репутационные риски в отношении почтового домена, так как сервис автоматически контролирует отписки, жалобы на спам и т.д.

При создании рассылки сегмент синхронизируется с DashaMail, и создается адресная база. При запуске рассылки в сервисе устанавливается время запуска. По окончании рассылки мы синхронизируем отчет с CDP в течение месяца. В этот период интервалы синхронизации одного отчета последовательно увеличиваются от 5 минут до недели, проходя промежуточные этапы в 30 минут, 1 час, 12 часов и 24 часа. Такая градация позволяет оптимизировать нагрузку на систему при сохранении необходимого уровня актуальности данных.

Комплексные рассылки

Комплексные рассылки — это гибкий инструмент, который позволяет отправлять всей аудитории первое сообщение, а затем, на основе отчета рассылки, можно сформировать независимые сегменты для разделения цепочек касаний. Например, тем, кто не открыл первое письмо, мы через неделю отправляем второе с измененным заголовком. А тем, кто открыл письмо, но не сделал целевого действия, направляем сообщение через другой канал коммуникаций, например, чат-бот в Телеграм. Информацию о статусах: пользователь открыл письмо, перешел по ссылке и т.д., мы получаем из системы рассылок.

Дальнейшие рассылки могут быть последовательными или параллельными, независимыми. Второй вариант используется редко. А последовательные рассылки очень популярны у маркетологов, так как они позволяют не перегревать базу и достигать более высокой конверсии.

Комплексные рассылки могут строиться как на статических, так и на динамических аудиториях, то есть обновляться раз в сутки или другой настраиваемый интервал времени.

В нашей CDP-платформе уже доступна в бета-тестировании древовидная визуализация комплексной рассылки. В ближайшее время планируется релиз в основную версию продукта. Это позволит маркетологу в более удобном интерфейсе работать со сложными комплексными рассылками.

A/B тестирование в рассылках

Мы предлагаем возможность маркетологам оценить конверсию до отправки рассылки по выбранному сегменту. Для этого можно отобрать до 40% аудитории и протестировать на этом объеме от 2 до 4 вариантов рассылки.

При этом маркетолог может сам выбирать не только количество вариантов, но и то, какому количеству пользователей в рамках доступных 40% нужно отправить каждый из вариантов. Можно разделить тестовый сегмент поровну между вариантами, а можно неравными долями, например, первый вариант отправить 10%, второй - 20%, а третий и четвертый - 5%. Второй вариант мы реализовали по запросу нескольких наших клиентов, но в целом рекомендуем использовать классический подход с равномерным распределением тестового сегмента.

Система определяет лучшие варианты по разным признакам (выше открытия или переходы по ссылкам), а затем либо автоматически отправляет лучший вариант по оставшимся адресам, либо уведомляет маркетолога о результатах, после чего он сам принимает решение, какой вариант отправлять.

Как еще улучшить рассылки

Короткие ссылки

Для работы с рассылками мы реализовали еще несколько удобных фишек. Например, короткие ссылки, основанные на доменном имени компании и привязанные к его порталу. Для этого мы разработали функционал в модуле, который генерирует такие ссылки, и уже по ним маркетолог в отчетах по сквозной аналитике, который мы выстраиваем, может наблюдать путь клиента. Особенно важно это в онлайн-бизнесе, где таким образом можно отслеживать конкретные конверсии по всей воронке. Мы расширили стандартный функционал коротких ссылок Битрикс24.

К ссылке добавлены дополнительные параметры, которые нигде не прописаны (ни в короткой, ни в длинной ссылке), но являются связанными атрибутами. Данные параметры используются для связанного функционала, например, для отчетности.

Спецпредложения

Часто колл-центр компании не знает обо всех акциях, доступных или уже предложенных конкретному клиенту, и на входящем звонке не может дать ему полную информацию. Для того, чтобы у операторов была вся информация, мы стали отображать непосредственно в карточке клиента все спецпредложения, которые ему отправляли в рассылках. Также клиент может, используя API, дать возможность своим пользователям самим видеть доступные ему предложения в мобильном приложении или на сайте, если он авторизован в личном кабинете.

Отчеты по рассылкам

В CDP доступен базовый сводный отчет по разным каналам коммуникации, периоду, разным срезам отчётности. А кастомные отчеты, которые клиент хочет настроить под себя, мы делаем через BI-конструктор Битрикса. Мы сделали интеграцию - передаем в Битрикс таблицы с данными, и по ним уже строятся отчеты. Используя Rest API, пользователь может забирать данные из нашей системы и строить отчеты, например, в Power BI и других системах.

И в завершении статьи пара слов о плюсах тесной интеграции CDP с Битрикс24. Наша платформа — не просто дополнение, модуль для Битрикс24, который можно скачать в Маркетплейсе и дополнить функциональность CRM. Это коробочное решение на ядре D7, которое позволяет пользователю работать с базой данных в режиме одного окна: сегментировать данные, анализировать рассылки, настраивать бизнес-процессы в CRM без передачи персональных данных в облачные сервисы.

Рассылка на миллион: как CDP от БизнесПрофи на базе Битрикс24 помогает оперировать реально огромными базами контактов