eventconnection.php

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

<?php
 
namespace Bitrix\Calendar\Sync\Connection;
 
use Bitrix\Calendar\Core\Base\EntityInterface;
use Bitrix\Calendar\Core\Event\Event;
use Bitrix\Calendar\Internals\EventConnectionTable;
use Bitrix\Main\ArgumentException;
 
class EventConnection implements EntityInterface
{
    private int $version = 0;
    private ?Event $event = null;
    private string $vendorEventId = '';
    private ?Connection $connection = null;
    private string $lastSyncStatus = '';
    private int $retryCount = 0;
    private ?string $entityTag = null;
    private ?array $data = null;
    private ?string $recurrenceId = null;
    private ?int $id = null;
    private ?string $vendorVersionId = null;

    public function setId(?int $id): EventConnection
    {
        $this->id = $id;
 
        return $this;
    }

    public function getId(): ?int
    {
        return $this->id;
    }

    public function getEvent(): Event
    {
        return $this->event;
    }

    public function setEvent(Event $event): self
    {
        $this->event = $event;
 
        return $this;
    }

    public function getVendorEventId(): string
    {
        return $this->vendorEventId;
    }

    public function setVendorEventId(string $vendorEventId): self
    {
        $this->vendorEventId = $vendorEventId;
 
        return $this;
    }

    public function getConnection(): Connection
    {
        return $this->connection;
    }

    public function setConnection(Connection $connection): self
    {
        $this->connection = $connection;
 
        return $this;
    }

    public function getLastSyncStatus(): string
    {
        return $this->lastSyncStatus;
    }

    public function setLastSyncStatus(string $lastSyncStatus): self
    {
        $this->lastSyncStatus = $lastSyncStatus;
 
        return $this;
    }

    public function setRetryCount(int $retryCount = 0): EventConnection
    {
        $this->retryCount = $retryCount;
 
        return $this;
    }

    public function getRetryCount(): int
    {
        return $this->retryCount;
    }

    public function getEntityTag(): ?string
    {
        return $this->entityTag;
    }

    public function getVendorVersionId(): ?string
    {
        return $this->vendorVersionId;
    }

    public function setVendorVersionId(?string $versionId): self
    {
        $this->vendorVersionId = $versionId;
 
        return $this;
    }

    public function setEntityTag(?string $entityTag = null): self
    {
        $this->entityTag = $entityTag;
 
        return $this;
    }

    public function setVersion(int $version): self
    {
        $this->version = $version;
 
        return $this;
    }

    public function getVersion(): int
    {
        return $this->version;
    }
 
    public function getData(): ?array
    {
        return $this->data;
    }
 
    public function setData($data): EventConnection
    {
        $this->data = $data;
 
        return $this;
    }
 
    public function fetchData(): ?array
    {
        if ($this->id <= 0)
        {
            return null;
        }
 
        try
        {
            $fetchDataResult = EventConnectionTable::query()
                ->setSelect(['DATA'])
                ->where('ID', $this->id)
                ->fetch()
            ;
 
            return $fetchDataResult['DATA'] ?? null;
        }
        catch (ArgumentException $e)
        {}
 
        return null;
    }

    public function getEventVersion(): ?string
    {
        return $this->getVersion();
    }

    public function setRecurrenceId(?string $id): EventConnection
    {
        $this->recurrenceId = $id;
 
        return $this;
    }

    public function getRecurrenceId(): ?string
    {
        return $this->recurrenceId;
    }
 
    public function upVersion()
    {
        $this->version++;
    }
}