contactlistupdateservice.php

<?php
 
namespace Bitrix\Sender\Service;
 
use Bitrix\Main\Application;
use Bitrix\Sender\ContactListTable;
use Bitrix\Sender\ContactTable;
use Bitrix\Sender\Internals\Dto\UpdateContactDtoCollection;
use Bitrix\Sender\Internals\SqlBatch;
 
class ContactListUpdateService
{
    public function updateByCollection(UpdateContactDtoCollection $collection, int $listId): void
    {
        $codesByType = [];
        foreach ($collection->all() as $updateItem)
        {
            $codesByType[$updateItem->typeId][] = $updateItem->code;
        }
        $sqlHelper = Application::getConnection()->getSqlHelper();
 
        foreach ($codesByType as $typeId => $allCodes)
        {
            $typeId = (int)$typeId;
            $listId = (int)$listId;
            $contactTableName = ContactTable::getTableName();
            $contactListTableName = ContactListTable::getTableName();
            foreach (SqlBatch::divide($allCodes) as $codes)
            {
                $codes = SqlBatch::getInString($codes);
 
                $fields = '(CONTACT_ID, LIST_ID) ';
                $subSelect = "SELECT ID AS CONTACT_ID, $listId as LIST_ID ";
                $subSelect .= "FROM $contactTableName ";
                $subSelect .= "WHERE TYPE_ID=$typeId AND CODE in ($codes)";
                $sql = $sqlHelper->getInsertIgnore($contactListTableName, $fields, $subSelect);
                Application::getConnection()->query($sql);
            }
        }
    }
}