counter.php

<?php
 
namespace Bitrix\Sender\Internals\Model;
 
use Bitrix\Main\DB;
use Bitrix\Main\Entity;
use Bitrix\Main\Type\DateTime;
 
 
class CounterTable extends Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_sender_counter';
    }
 
    public static function getMap()
    {
        return [
            'CODE' =>[
                'data_type' => 'string',
                'primary' => true,
                'required' => true,
            ],
            'VALUE' => [
                'data_type' => 'integer',
                'required' => false
            ],
            'DATE_UPDATE' => array(
                'data_type' => 'datetime',
                'default_value' => new DateTime(),
            ),
        ];
    }
 
    public static function mergeData(array $insert, array $update)
    {
        $entity = static::getEntity();
        $connection = $entity->getConnection();
        $helper = $connection->getSqlHelper();
 
        $sql = $helper->prepareMerge($entity->getDBTableName(), $entity->getPrimaryArray(), $insert, $update);
 
        $sql = current($sql);
        if($sql <> '')
        {
            $connection->queryExecute($sql);
            $entity->cleanCache();
        }
    }
 
    public static function incrementByCode($code, $increment = 1)
    {
        $date = new DateTime();
        $insert = ['CODE' => $code, 'VALUE' => $increment, 'DATE_UPDATE' => $date];
        $update = [
            'VALUE' => new DB\SqlExpression("?# + ?i", 'VALUE', $increment),
            'DATE_UPDATE' => $date
        ];
 
        static::mergeData($insert, $update);
    }
 
    public static function getValueByCode($code)
    {
        $row = static::getRow(['filter' => ['=CODE' => $code], 'cache' => ['ttl' => 36000]]);
        return intval($row ? $row['VALUE'] : 0);
    }
 
    public static function resetValueByCode($code)
    {
        return static::delete(['CODE' => $code])->isSuccess();
    }
}