eventconnection.php

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

<?php
 
namespace Bitrix\Calendar\Core\Mappers;
 
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Core\Base\BaseException;
use Bitrix\Calendar\Internals\EO_EventConnection;
use Bitrix\Calendar\Internals\EventConnectionTable;
use Bitrix\Calendar\Sync;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Loader;
use Bitrix\Main\LoaderException;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\ORM\Query\Result;
use Bitrix\Main\SystemException;
use Exception;
 
class EventConnection extends Complex
{
    protected function getOneEntityByFilter(array $filter): ?object
    {
        if (!Loader::includeModule('dav'))
        {
            return null;
        }
 
        $link = EventConnectionTable::query()
            ->setFilter($filter)
            ->setSelect([
                ...EventConnectionTable::defaultSelect,
                'EVENT',
                'CONNECTION',
            ])
            ->exec()->fetchObject();
 
        if ($link === null)
        {
            return null;
        }
 
        return $this->convertToObject($link);
    }

    protected function getEntityName(): string
    {
        return 'event connection link';
    }

    protected function createEntity($entity, array $params = []): ?Core\Base\EntityInterface
    {
        $data = $this->convertToArray($entity);
 
        $result = EventConnectionTable::add($data);
        if ($result->isSuccess())
        {
            return $entity->setId($result->getId());
        }
 
        throw new BaseException('Error of create EventConnection: '
            . implode('; ', $result->getErrorMessages()),
            400);
    }

    protected function updateEntity($entity, array $params = []): ?Core\Base\EntityInterface
    {
        $data = $this->convertToArray($entity);
 
        $result = EventConnectionTable::update($entity->getId(), $data);
 
        if ($result->isSuccess())
        {
            return $entity;
        }
 
        throw new BaseException('Error of update EventConnection: '
            . implode('; ', $result->getErrorMessages()),
            400);
    }

    protected function deleteEntity(
        Core\Base\EntityInterface $entity,
        array $params = ['softDelete' => true]
    ): ?Core\Base\EntityInterface
    {
//      if (!empty($params['softDelete']))
//      {
//          $entity->setActive(false);
//          return $this->updateEntity($entity, $params);
//      }
 
        $result = EventConnectionTable::delete($entity->getId());
 
        if ($result->isSuccess())
        {
            return null;
        }
 
        throw new BaseException('Error of delete EventConnection: '
            . implode('; ', $result->getErrorMessages()),
            400);
    }

    protected function getMapClass(): string
    {
        return Sync\Connection\EventConnectionMap::class;
    }

    protected function convertToObject($objectEO): ?Sync\Connection\EventConnection
    {
        if ($objectEO->getEvent() === null || $objectEO->getConnection() === null)
        {
            $objectEO->delete();
 
            return null;
        }
 
        $event = $this->prepareEvent($objectEO->getEvent());
        $connection = $this->prepareConnection($objectEO->getConnection());
 
        return (new Sync\Connection\EventConnection())
            ->setLastSyncStatus($objectEO->getSyncStatus())
            ->setRetryCount($objectEO->getRetryCount())
            ->setVersion((int)$objectEO->getVersion())
            ->setVendorEventId($objectEO->getVendorEventId())
            ->setEntityTag($objectEO->getEntityTag())
            ->setRecurrenceId($objectEO->getRecurrenceId())
            ->setVendorVersionId($objectEO->getVendorVersionId())
            ->setId($objectEO->getId())
            ->setData($objectEO->getData())
            ->setEvent($event)
            ->setConnection($connection)
            ;
    }

    private function convertToArray(Sync\Connection\EventConnection $entity): array
    {
        return [
            'EVENT_ID' => $entity->getEvent()->getId(),
            'CONNECTION_ID' => $entity->getConnection()->getId(),
            'VENDOR_EVENT_ID' => $entity->getVendorEventId(),
            'SYNC_STATUS' => $entity->getLastSyncStatus(),
            'RETRY_COUNT' => $entity->getRetryCount(),
            'ENTITY_TAG' => $entity->getEntityTag(),
            'VENDOR_VERSION_ID' => $entity->getVendorVersionId(),
            'VERSION' => $entity->getVersion(),
            'DATA' => $entity->getData(),
            'RECURRENCE_ID' => $entity->getRecurrenceId(),
        ];
    }

    protected function getDataManagerResult(array $params): Result
    {
        Loader::includeModule('dav');
        if ($params['select'] === self::DEFAULT_SELECT)
        {
            $params['select'] = [
                ...EventConnectionTable::defaultSelect,
                'EVENT',
                'CONNECTION',
            ];
        }
 
        return EventConnectionTable::getList($params);
    }

    protected function getEntityClass(): string
    {
        return Sync\Connection\EventConnection::class;
    }
}