statmethod.php

<?php
namespace Bitrix\Rest;
 
use Bitrix\Main;
 
class StatMethodTable extends Main\Entity\DataManager
{
    const METHOD_TYPE_METHOD = 'M';
    const METHOD_TYPE_EVENT = 'E';
    const METHOD_TYPE_PLACEMENT = 'P';
    const METHOD_TYPE_ROBOT = 'R';
    const METHOD_TYPE_ACTIVITY = 'A';
 
    protected static $methodCache = null;
 
    public static function getTableName()
    {
        return 'b_rest_stat_method';
    }
 
    public static function getMap()
    {
        return array(
            'ID' => array(
                'data_type' => 'integer',
                'primary' => true,
                'autocomplete' => true,
            ),
            'NAME' => array(
                'data_type' => 'string',
                'required' => true,
                'validation' => array(__CLASS__, 'validateName'),
            ),
            'METHOD_TYPE' => array(
                'data_type' => 'enum',
                'required' => false,
                'values' => array(
                    self::METHOD_TYPE_METHOD,
                    self::METHOD_TYPE_EVENT,
                    self::METHOD_TYPE_PLACEMENT,
                    self::METHOD_TYPE_ROBOT,
                    self::METHOD_TYPE_ACTIVITY,
                ),
            ),
        );
    }
    public static function validateName()
    {
        return array(
            new Main\Entity\Validator\Unique(),
        );
    }
 
    public static function getId($methodName)
    {
        static::checkList(array($methodName));
 
        return static::$methodCache[$methodName];
    }
 
    public static function checkList($methodList, $methodType = self::METHOD_TYPE_METHOD)
    {
        static::loadFromCache();
 
        $update = false;
        foreach($methodList as $method)
        {
            if(!array_key_exists($method, static::$methodCache))
            {
                static::addMethod($method, $methodType);
                $update = true;
            }
        }
 
        if($update)
        {
            static::loadFromCache(true);
        }
 
    }
 
    protected static function addMethod($methodName, $methodType)
    {
        $connection = Main\Application::getConnection();
        $helper = $connection->getSqlHelper();
 
        $sqlTableName = static::getTableName();
        $sqlMethodName = $helper->forSql($methodName);
        $sqlMethodType = in_array(
            $methodType, [
                static::METHOD_TYPE_METHOD,
                static::METHOD_TYPE_EVENT,
                static::METHOD_TYPE_PLACEMENT,
                static::METHOD_TYPE_ROBOT,
                static::METHOD_TYPE_ACTIVITY,
            ]
        ) ? $methodType : self::METHOD_TYPE_METHOD;
 
        $query = "INSERT IGNORE INTO {$sqlTableName} (NAME, METHOD_TYPE) VALUES ('{$sqlMethodName}', '{$sqlMethodType}')";
        $connection->query($query);
    }
 
    protected static function loadFromCache($force = false)
    {
        $managedCache = Main\Application::getInstance()->getManagedCache();
        $cacheId = 'stat_method_cache';
 
        if($force)
        {
            static::$methodCache = null;
            $managedCache->clean($cacheId);
        }
 
        if(static::$methodCache === null)
        {
            if($managedCache->read(86400, $cacheId))
            {
                static::$methodCache = $managedCache->get($cacheId);
            }
            else
            {
                static::$methodCache = array();
                $dbRes = static::getList();
                while($method = $dbRes->fetch())
                {
                    static::$methodCache[$method['NAME']] = $method['ID'];
                }
                $managedCache->set($cacheId, static::$methodCache);
            }
        }
    }
}