Битрикс24: очистка истории событий CRM

<?php
use Bitrix\Main\Loader;

Loader::includeModule('crm');

// Удаление событий у Лида
$leadId = 123;
CCrmEvent::DeleteByElement(CCrmOwnerType::Lead, $leadId);

// Удаление событий у Сделки
$dealId = 456;
CCrmEvent::DeleteByElement(CCrmOwnerType::Deal, $dealId);

// Удаление событий у Контакта
$contactId = 789;
CCrmEvent::DeleteByElement(CCrmOwnerType::Contact, $contactId);

// Удаление событий у Компании
$companyId = 101;
CCrmEvent::DeleteByElement(CCrmOwnerType::Company, $companyId);

<?php

namespace Local\Maintenance;

use Bitrix\Main\Loader;
use Bitrix\Crm\EventTable;
use Bitrix\Crm\EventRelationsTable;

class CrmEventCleaner
{
    /**
     * Размер пакета для обработки
     */
    private const BATCH_SIZE = 5000;

    /**
     * Очистка событий старше указанной даты
     */
    public function cleanOlderThan(string $date, int $maxBatches = 10): array
    {
        if (!Loader::includeModule('crm')) {
            throw new \RuntimeException('Модуль CRM не установлен');
        }

        $stats = [
            'events_deleted' => 0,
            'relations_deleted' => 0,
            'batches_processed' => 0,
        ];

        for ($batch = 0; $batch < $maxBatches; $batch++) {
            $events = $this->getEventsBatch($date);
            
            if (empty($events)) {
                break;
            }

            $eventIds = array_column($events, 'ID');
            $relationsDeleted = $this->deleteRelations($eventIds);
            $eventsDeleted = $this->deleteEvents($eventIds);

            $stats['events_deleted'] += $eventsDeleted;
            $stats['relations_deleted'] += $relationsDeleted;
            $stats['batches_processed']++;

            // Пауза между пакетами для снижения нагрузки
            usleep(100000); // 100ms
        }

        return $stats;
    }

    /**
     * Получение пакета событий для удаления
     */
    private function getEventsBatch(string $beforeDate): array
    {
        $result = EventTable::getList([
            'order' => ['ID' => 'ASC'],
            'filter' => [
                '<DATE_CREATE' => $beforeDate,
            ],
            'select' => ['ID'],
            'limit' => self::BATCH_SIZE,
        ]);

        return $result->fetchAll();
    }

    /**
     * Удаление связей событий
     */
    private function deleteRelations(array $eventIds): int
    {
        $relations = EventRelationsTable::getList([
            'filter' => ['EVENT_ID' => $eventIds],
            'select' => ['ID'],
        ])->fetchAll();

        $count = 0;
        foreach ($relations as $relation) {
            $crmEvent = new \CCrmEvent();
            if ($crmEvent->Delete((int)$relation['ID'], ['CURRENT_USER' => 1])) {
                $count++;
            }
        }

        return $count;
    }

    /**
     * Прямое удаление событий (после удаления связей)
     */
    private function deleteEvents(array $eventIds): int
    {
        $count = 0;
        foreach ($eventIds as $eventId) {
            $result = EventTable::delete($eventId);
            if ($result->isSuccess()) {
                $count++;
            }
        }
        return $count;
    }

    /**
     * Подсчёт событий для очистки
     */
    public function countEventsOlderThan(string $date): int
    {
        if (!Loader::includeModule('crm')) {
            return 0;
        }

        $result = EventTable::getList([
            'filter' => ['<DATE_CREATE' => $date],
            'select' => ['ID'],
            'count_total' => true,
        ]);

        return $result->getCount();
    }

    /**
     * Получение статистики по таблицам
     */
    public function getTableStats(): array
    {
        global $DB;

        $stats = [];

        // Размер таблицы событий
        $sql = "SELECT 
                    COUNT(*) as row_count,
                    ROUND(DATA_LENGTH / 1024 / 1024, 2) as data_mb,
                    ROUND(INDEX_LENGTH / 1024 / 1024, 2) as index_mb
                FROM information_schema.TABLES 
                WHERE TABLE_NAME = 'b_crm_event'";
        
        $result = $DB->Query($sql);
        if ($row = $result->Fetch()) {
            $stats['b_crm_event'] = $row;
        }

        // Размер таблицы связей
        $sql = "SELECT 
                    COUNT(*) as row_count,
                    ROUND(DATA_LENGTH / 1024 / 1024, 2) as data_mb,
                    ROUND(INDEX_LENGTH / 1024 / 1024, 2) as index_mb
                FROM information_schema.TABLES 
                WHERE TABLE_NAME = 'b_crm_event_relations'";
        
        $result = $DB->Query($sql);
        if ($row = $result->Fetch()) {
            $stats['b_crm_event_relations'] = $row;
        }

        return $stats;
    }
}

<?php
$_SERVER['DOCUMENT_ROOT'] = realpath(__DIR__ . '/../../');
require $_SERVER['DOCUMENT_ROOT'] . '/bitrix/modules/main/include/prolog_before.php';

use Local\Maintenance\CrmEventCleaner;

$cleaner = new CrmEventCleaner();

// Показываем текущую статистику
echo "=== Статистика таблиц ===\n";
$stats = $cleaner->getTableStats();
foreach ($stats as $table => $info) {
    echo "{$table}:\n";
    echo "  Записей: {$info['row_count']}\n";
    echo "  Данные: {$info['data_mb']} MB\n";
    echo "  Индексы: {$info['index_mb']} MB\n";
}

// Подсчёт событий старше года
$oneYearAgo = date('d.m.Y 00:00:00', strtotime('-1 year'));
$count = $cleaner->countEventsOlderThan($oneYearAgo);
echo "\nСобытий старше года: {$count}\n";

// Запуск очистки (раскомментируйте для выполнения)
// echo "\n=== Запуск очистки ===\n";
// $result = $cleaner->cleanOlderThan($oneYearAgo, 20);
// print_r($result);

php /home/bitrix/www/local/scripts/clean_crm_events.php

<?php
// /local/php_interface/init.php

use Local\Maintenance\CrmEventCleaner;

// Регистрация агента (раз в сутки в 3:00)
CAgent::AddAgent(
    '\\Local\\Maintenance\\CrmEventCleaner::runAgent();',
    'main',
    'N',
    86400,
    '',
    'Y',
    ConvertTimeStamp(strtotime('tomorrow 03:00'), 'FULL')
);

public static function runAgent(): string
{
    $cleaner = new self();
    
    // Очищаем события старше 6 месяцев
    $sixMonthsAgo = date('d.m.Y 00:00:00', strtotime('-6 months'));
    $cleaner->cleanOlderThan($sixMonthsAgo, 5);
    
    // Возвращаем имя агента для повторного запуска
    return __METHOD__ . '();';
}

OPTIMIZE TABLE b_crm_event;
OPTIMIZE TABLE b_crm_event_relations;