sectionconnection.php

<?php
 
namespace Bitrix\Calendar\Core\Mappers;
 
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Core\Base\BaseException;
use Bitrix\Calendar\Internals\EO_SectionConnection;
use Bitrix\Calendar\Internals\SectionConnectionTable;
use Bitrix\Calendar\Sync;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Loader;
use Bitrix\Main\LoaderException;
use Bitrix\Main\ObjectException;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\ORM\Query\Result;
use Bitrix\Main\SystemException;
use Exception;
 
class SectionConnection extends Complex
{
    public function patch(
        Sync\Connection\SectionConnection $sectionConnection,
        array $fields
    ): Sync\Connection\SectionConnection
    {
        $sectionConnectionFields = $this->convertToArray($sectionConnection);
 
        $result = SectionConnectionTable::update(
            $sectionConnection->getId(),
            array_intersect_key($sectionConnectionFields, array_flip($fields))
        );
 
        if ($result->isSuccess())
        {
            return $sectionConnection;
        }
 
        throw new BaseException('Error of delete SectionConnection: '
            . implode('; ', $result->getErrorMessages()),
            400);
    }
 
    public function convertToArray(Sync\Connection\SectionConnection $sectionConnection): array
    {
        if (!$sectionConnection->getConnection())
        {
            throw new BaseException('The sectionConnection must have an connection');
        }
 
        return [
            'SECTION_ID'        => $sectionConnection->getSection()->getId(),
            'CONNECTION_ID'     => $sectionConnection->getConnection()->getId(),
            'VENDOR_SECTION_ID' => $sectionConnection->getVendorSectionId(),
            'SYNC_TOKEN'        => $sectionConnection->getSyncToken(),
            'PAGE_TOKEN'        => $sectionConnection->getPageToken(),
            'ACTIVE'            => $sectionConnection->isActive() ? self::POSITIVE_ANSWER : self::NEGATIVE_ANSWER,
            'LAST_SYNC_DATE'    => $sectionConnection->getLastSyncDate()
                ? $sectionConnection->getLastSyncDate()->getDate()
                : null,
            'LAST_SYNC_STATUS'  => $sectionConnection->getLastSyncStatus(),
            'VERSION_ID'        => $sectionConnection->getVersionId(),
            'IS_PRIMARY'        => $sectionConnection->isPrimary() ? self::POSITIVE_ANSWER : self::NEGATIVE_ANSWER,
        ];
    }
 
    protected function getMapClass(): string
    {
        return Sync\Connection\SectionConnectionMap::class;
    }
 
    protected function getEntityName(): string
    {
        return 'section connection link';
    }
 
    protected function getOneEntityByFilter(array $filter): ?object
    {
        if (!Loader::includeModule('dav'))
        {
            return null;
        }
        $link = SectionConnectionTable::query()
            ->setFilter($filter)
            ->setSelect(['*', 'SECTION', 'CONNECTION'])
            ->exec()->fetchObject();
 
        if ($link !== null)
        {
            return $this->convertToObject($link);
        }
 
        return null;
    }
 
    protected function convertToObject($objectEO): ?Sync\Connection\SectionConnection
    {
        $section = $objectEO->getSection();
        if ($section !== null)
        {
            $section = $this->prepareSection($section);
        }
        else
        {
            $objectEO->delete();
 
            return null;
        }
 
        $connection = $objectEO->getConnection();
        if ($connection !== null)
        {
            $connection = $this->prepareConnection($connection);
        }
        else
        {
            $objectEO->delete();
 
            return null;
        }
 
        $item = new Sync\Connection\SectionConnection();
        $item
            ->setId($objectEO->getId())
            ->setSection($section)
            ->setConnection($connection)
            ->setVendorSectionId($objectEO->getVendorSectionId())
            ->setSyncToken($objectEO->getSyncToken())
            ->setPageToken($objectEO->getPageToken())
            ->setActive($objectEO->getActive())
            ->setLastSyncDate(new Core\Base\Date($objectEO->getLastSyncDate()))
            ->setLastSyncStatus($objectEO->getLastSyncStatus())
            ->setVersionId($objectEO->get('VERSION_ID'))
            ->setPrimary($objectEO->getIsPrimary())
        ;
 
        return $item;
    }
 
    protected function createEntity($entity, array $params = []): ?Core\Base\EntityInterface
    {
        $data = $this->convertToArray($entity);
 
        $result = SectionConnectionTable::add($data);
 
        if ($result->isSuccess())
        {
            return $entity->setId($result->getId());
        }
 
        throw new BaseException('Error of create SectionConnection: '
            . implode('; ', $result->getErrorMessages()),
        400);
    }
 
    protected function updateEntity($entity, array $params = []): ?Core\Base\EntityInterface
    {
        $data = $this->convertToArray($entity);
 
        $result = SectionConnectionTable::update($entity->getId(), $data);
 
        if ($result->isSuccess())
        {
            return $entity;
        }
 
        throw new BaseException('Error of update SectionConnection: '
            . 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 = SectionConnectionTable::delete($entity->getId());
 
        if ($result->isSuccess())
        {
            return null;
        }
 
        throw new BaseException('Error of delete SectionConnection: '
            . implode('; ', $result->getErrorMessages()),
            400);
    }
 
    protected function getDataManagerResult(array $params): Result
    {
        Loader::includeModule('dav');
        if ($params['select'] === self::DEFAULT_SELECT)
        {
            $params['select'] = ["*", 'SECTION', 'CONNECTION'];
        }
 
        return SectionConnectionTable::getList($params);
    }
 
    protected function getEntityClass(): string
    {
        return Sync\Connection\SectionConnection::class;
    }
}