analyticstable.php

<?php
 
namespace Bitrix\Sale\Internals\Analytics;
 
use Bitrix\Main;
use Bitrix\Main\ORM\Fields\ArrayField;
use Bitrix\Main\ORM\Fields\IntegerField;
use Bitrix\Main\ORM\Fields\DatetimeField;
use Bitrix\Main\ORM\Fields\StringField;
use Bitrix\Main\Type\DateTime;
 
class AnalyticsTable extends Main\Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_sale_analytics';
    }
 
    public static function getMap()
    {
        return [
            (new IntegerField('ID'))
                ->configureAutocomplete()
                ->configurePrimary(),
            (new StringField('CODE'))
                ->configureRequired()
                ->configureSize(255),
            (new DatetimeField('CREATED_AT'))
                ->configureRequired()
                ->configureDefaultValue(static function() {
                    return new DateTime();
                }),
            (new ArrayField('PAYLOAD'))
                ->configureSerializationPhp()
                ->configureUnserializeCallback(function ($value) {
                    return unserialize(
                        $value,
                        ['allowed_classes' => false]
                    );
                }),
        ];
    }
 
    public static function deleteByDate(Main\Type\DateTime $dateTo): Main\DB\Result
    {
        $connection = Main\Application::getConnection();
        $helper = $connection->getSqlHelper();
 
        return $connection->query(sprintf(
            'DELETE FROM %s WHERE CREATED_AT <= %s',
            $helper->quote(AnalyticsTable::getTableName()),
            $helper->convertToDbDateTime($dateTo)
        ));
    }
 
    public static function deleteByCodeAndDate(string $providerCode, Main\Type\DateTime $dateTo): Main\DB\Result
    {
        $connection = Main\Application::getConnection();
        $helper = $connection->getSqlHelper();
 
        return $connection->query(sprintf(
            'DELETE FROM %s WHERE CODE = %s AND CREATED_AT <= %s',
            $helper->quote(AnalyticsTable::getTableName()),
            $helper->convertToDbString($providerCode),
            $helper->convertToDbDateTime($dateTo)
        ));
    }
}