dataexchangemanager.php

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

<?php
 
namespace Bitrix\Calendar\Sync\Managers;
 
use Bitrix\Calendar\Internals\Counter\CounterService;
use Bitrix\Calendar\Internals\Counter\Event\EventDictionary;
use Bitrix\Calendar\Sync\Connection\Connection;
use Bitrix\Calendar\Sync\Dictionary;
use Bitrix\Calendar\Sync\Entities\SyncSectionMap;
use Bitrix\Calendar\Sync\Exceptions\RemoteAccountException;
use Bitrix\Calendar\Sync\Factories\FactoriesCollection;
use Bitrix\Calendar\Sync\Factories\FactoryBase;
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Sync\Factories\SyncSectionFactory;
use Bitrix\Calendar\Sync\Google;
use Bitrix\Calendar\Sync\Office365;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\DI\ServiceLocator;
use Bitrix\Main\Loader;
use Bitrix\Main\LoaderException;
use Bitrix\Main\ObjectException;
use Bitrix\Main\ObjectNotFoundException;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\Result;
use Bitrix\Main\SystemException;
 
class DataExchangeManager
{
    private const COUNT_CONNECTIONS_FOR_REGULAR_SYNC = 10;
    private FactoriesCollection $factories;

    public function __construct(FactoriesCollection $factories)
    {
        $this->factories = $factories;
    }

    public static function markDeletedFailedConnection(Connection $connection): void
    {
        $mapperFactory = ServiceLocator::getInstance()->get('calendar.service.mappers.factory');
        $mapperFactory
            ->getConnection()
            ->patch($connection, ['IS_DELETED' => Core\Mappers\Mapper::POSITIVE_ANSWER])
        ;
    }

    public function exchange(): Result
    {
        foreach ($this->factories as $factory)
        {
            if (!$factory)
            {
                continue;
            }
 
            $exchangeManager = new VendorDataExchangeManager($factory, self::getSyncSectionMap($factory));
            $exchangeManager->exchange();
        }
 
        return new Result();
    }

    public function import(): Result
    {
        foreach ($this->factories as $factory)
        {
            $exchangeManager = new VendorDataExchangeManager($factory, self::getSyncSectionMap($factory));
            $exchangeManager
                ->importSections()
                ->importEvents()
                ->updateConnection($factory->getConnection())
                ->clearCache()
            ;
 
            try
            {
                $exchangeManager->renewSubscription($factory->getConnection());
            }
            catch (\Exception $e)
            {
            }
        }
 
        return new Result();
    }

    public static function importAgent(): string
    {
        if (!Loader::includeModule('calendar') || !Loader::includeModule('dav'))
        {
            return "\\Bitrix\\Calendar\\Sync\\Managers\\DataExchangeManager::importAgent();";
        }
 
        $userIds = [];
        $connections = self::getConnections();
        while ($connection = $connections->fetch())
        {
            if ($connection->getOwner() === null)
            {
                self::markDeletedFailedConnection($connection);
                continue;
            }
 
            $ownerId = $connection->getOwner()->getId();
            if ($ownerId)
            {
                $userIds[] = $ownerId;
            }
 
            try
            {
                $factory = FactoriesCollection::createByConnection($connection)->fetch();
 
                if (!$factory)
                {
                    continue;
                }
 
                $exchangeManager = new VendorDataExchangeManager($factory, self::getSyncSectionMap($factory));
                $exchangeManager
                    ->importSections()
                    ->importEvents()
                    ->updateConnection($factory->getConnection())
                    ->clearCache();
            }
            catch (RemoteAccountException $e)
            {
                self::markDeletedFailedConnection($connection);
            }
            catch (\Exception $e)
            {
                $connection->setSyncStatus(Dictionary::SYNC_STATUS['failed']);
            }
        }
 
        CounterService::addEvent(EventDictionary::SYNC_CHANGED, ['user_ids' => $userIds]);
 
        return "\\Bitrix\\Calendar\\Sync\\Managers\\DataExchangeManager::importAgent();";
    }

    private static function getConnections(): Core\Base\Map
    {
        $mapperFactory = ServiceLocator::getInstance()->get('calendar.service.mappers.factory');
 
        return $mapperFactory->getConnection()->getMap(
            [
                '=ACCOUNT_TYPE' => [
                    Google\Helper::GOOGLE_ACCOUNT_TYPE_API,
                    Office365\Helper::ACCOUNT_TYPE
                ],
                '=ENTITY_TYPE' => Core\Role\User::TYPE,
                '=IS_DELETED' => 'N',
            ],
            self::COUNT_CONNECTIONS_FOR_REGULAR_SYNC,
            ['SYNCHRONIZED' => 'ASC']
        );
    }

    private static function getSyncSectionMap(FactoryBase $factory): SyncSectionMap
    {
        return (new SyncSectionFactory())->getSyncSectionMapByFactory($factory);
    }
}