vkexporteddata.php

См. документацию.

<?php
 
namespace Bitrix\Sale\TradingPlatform\Vk;
 
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ArgumentNullException;
use Bitrix\Main\Application;
 
Loc::loadMessages(__FILE__);

class VkExportedData
{
    
    const CACHE_DIR = '/sale/vkexport/';
    const CACHE_TTL = 3600;        // one hour, for update during long export
    const CACHE_ID_PREFIX = "vkexporteddata_cache";
    private $exportId;
    private $type;
    private $cacheId;
    
    public function __construct($exportId, $type)
    {
        $this->exportId = intval($exportId);
        
        if (in_array($type, array('PRODUCTS', 'ALBUMS')))
            $this->type = $type;
        else
            throw new ArgumentNullException("EXPORT_ID");
        
        $this->cacheId = $this->getCacheId();
    }
    public function __construct($exportId, $type) {…}
    
    
    public function getData()
    {
        $cacheManager = Application::getInstance()->getManagedCache();
        $result = NULL;
        
        if ($cacheManager->read(self::CACHE_TTL, $this->cacheId))
        {
            $result = $cacheManager->get($this->cacheId);
        }
        else
        {
            $result = $this->getDataFromVk();
            
            $cacheManager->set($this->cacheId, $result);
        }
        
        return $result;
    }
    public function getData() {…}
    
    
    public function removeData()
    {
        $cacheManager = Application::getInstance()->getManagedCache();
        $cacheManager->clean($this->cacheId);
    }
    public function removeData() {…}
    
    
    public function addData($newData)
    {
        $cacheManager = Application::getInstance()->getManagedCache();
 
//      get saved data from cache, if exist...
        if ($cacheManager->read(self::CACHE_TTL, $this->cacheId))
            $savedData = $cacheManager->get($this->cacheId);
 
//      ...or from VK
        else
            $savedData = $this->getDataFromVk();
 
//      add new data to existing
        $dataToSave = $savedData + $newData;
        $cacheManager->clean($this->cacheId);
        $cacheManager->read(self::CACHE_TTL, $this->cacheId);
        $cacheManager->set($this->cacheId, $dataToSave);
    }
    public function addData($newData) {…}
    
    
    private function getCacheId()
    {
        return self::CACHE_ID_PREFIX . '_' . $this->exportId . '_' . $this->type;
    }
    
    
    private function getDataFromVk()
    {
        $apiHelper = new Api\ApiHelper($this->exportId);
        $data = false;
        
        switch ($this->type)
        {
            case 'ALBUMS':
                $data = $apiHelper->getALbumsFromVk($this->getVkGroupId());
                break;
            
            case 'PRODUCTS':
                $data = $apiHelper->getProductsFromVk($this->getVkGroupId());
                break;
            
            default:
                break;
        }
        
        return $data;
    }
    
    private function getVkGroupId()
    {
        $vk = Vk::getInstance();
        
        return $vk->getGroupId($this->exportId);
    }
}
class VkExportedData {…};