eventswithentityattendeesfind.php

<?php
 
namespace Bitrix\Calendar\Core\Queue\Processor;
 
use Bitrix\Calendar\Core\Queue\Interfaces;
use Bitrix\Calendar\Internals\EventTable;
use Bitrix\Calendar\Watcher\Membership\Handler\Handler;
 
class EventsWithEntityAttendeesFind implements Interfaces\Processor
{
    const CONVERT_DATA = [
        Handler::WORK_GROUP_TYPE => 'SG',
        Handler::DEPARTMENT_TYPE => 'DR',
        Handler::ALL_USERS_TYPE => 'UA',
    ];
 
    public function process(Interfaces\Message $message): string
    {
        $data = $message->getBody();
 
        if (empty($data['entityType']))
        {
            return self::REJECT;
        }
 
        $attendeeCode = $this->convertEntityToAttendeeCode($data['entityType'], $data['entityId'] ?? null);
 
        $events = EventTable::getList([
            'select' => ['ID'],
            'filter' => \Bitrix\Main\ORM\Query\Query::filter()
                ->where('DELETED', 'N')
                ->whereExpr("%s REGEXP '" . $attendeeCode."(_|$|,)'", ['ATTENDEES_CODES'])
                ->whereColumn('ID', 'PARENT_ID')
                //do subtract to make sampling more accurate
                ->where('DATE_TO_TS_UTC', '>=', time() - \CCalendar::GetDayLen())
            ,
            'order' => [
                'ID' => 'ASC',
            ],
        ])->fetchAll();
 
        if (count($events) === 1)
        {
            $this->sendMessageToQueue($events[0]['ID']);
        }
        else
        {
            $this->sendBatchOfMessagesToQueue($events);
        }
 
        return self::ACK;
    }
 
    protected function convertEntityToAttendeeCode(string $entityType, int $entityId = null): string
    {
        $attendeeCodeType = self::CONVERT_DATA[$entityType] ?? null;
 
        return $attendeeCodeType ? $attendeeCodeType . ($entityId ?: '')  : '';
    }
 
    protected function sendMessageToQueue(int $eventId): void
    {
        $message = (new \Bitrix\Calendar\Core\Queue\Message\Message())
            ->setBody([
                'eventId' => $eventId,
            ])
            ->setRoutingKey('calendar:update_event_attendees');
 
        (new \Bitrix\Calendar\Core\Queue\Producer\Producer())->send($message);
    }
 
    protected function sendBatchOfMessagesToQueue(array $events): void
    {
        $messages = [];
 
        foreach ($events as $event)
        {
            if (!empty($event['ID']))
            {
                $messages[] = (new \Bitrix\Calendar\Core\Queue\Message\Message())
                    ->setBody([
                        'eventId' => $event['ID'],
                    ])
                    ->setRoutingKey('calendar:update_event_attendees')
                ;
            }
        }
 
        (new \Bitrix\Calendar\Core\Queue\Producer\Producer())->sendBatch($messages);
    }
}