storage.php

<?php
 
namespace Bitrix\Sale\Internals\Analytics;
 
use Bitrix\Main;
 
final class Storage
{
    private $provider;
 
    public function __construct(Provider $provider)
    {
        $this->provider = $provider;
    }
 
    public function save(): void
    {
        $providerData = $this->provider->getData();
        if ($providerData)
        {
            $this->savePayload($providerData);
        }
    }
 
    public static function getPayloadByCode(string $code, Main\Type\DateTime $dateTo): array
    {
        if (empty($code))
        {
            return [];
        }
 
        $result = [];
 
        $analyticsIterator = AnalyticsTable::getList([
            'select' => ['ID', 'PAYLOAD'],
            'filter' => [
                '=CODE' => $code,
                '<=CREATED_AT' => $dateTo,
            ],
        ]);
        while ($analyticsData = $analyticsIterator->fetch())
        {
            $result[] = [
                'data' => $analyticsData['PAYLOAD'],
                'hash' => self::calculateHash($analyticsData),
            ];
        }
 
        return $result;
    }
 
    public static function clean(string $providerCode, Main\Type\DateTime $dateTo): void
    {
        if (empty($providerCode))
        {
            return;
        }
 
        AnalyticsTable::deleteByCodeAndDate($providerCode, $dateTo);
    }
 
    private function savePayload(array $data): void
    {
        AnalyticsTable::add([
            'CODE' => $this->provider::getCode(),
            'PAYLOAD' => $data,
        ]);
    }
 
    private static function calculateHash(array $data): string
    {
        if (self::isB24())
        {
            $uniqParam = BX24_HOST_NAME;
        }
        else
        {
            $uniqParam = Main\Analytics\Counter::getPrivateKey();
        }
 
        return md5(serialize($data) . $uniqParam);
    }
 
    private static function isB24(): bool
    {
        return Main\Loader::includeModule('bitrix24');
    }
 
    public static function cleanUpAgent(): string
    {
        $dateTo = new Main\Type\DateTime();
        $dateTo->add('-30D');
 
        AnalyticsTable::deleteByDate($dateTo);
 
        return '\Bitrix\Sale\Internals\Analytics\Storage::cleanUpAgent();';
    }
}