incomingeventmanager.php

<?php
 
 
namespace Bitrix\Calendar\ICal;
 
 
use Bitrix\Calendar\ICal\Builder\AttendeesCollection;
use Bitrix\Calendar\ICal\MailInvitation\Helper;
use Bitrix\Calendar\ICal\MailInvitation\IncomingInvitationRequestHandler;
use Bitrix\Mail\Internals\MessageAccessTable;
use Bitrix\Mail\MailboxTable;
use Bitrix\Mail\MailMessageTable;
use Bitrix\Main\IO\FileNotFoundException;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\ORM\Fields\Relations\Reference;
use Bitrix\Main\ORM\Query\Join;
use Bitrix\Main\ORM\Query\Query;
use Bitrix\Main\Text\Encoding;
use Bitrix\Tasks\Integration\Disk;
use Bitrix\Calendar\ICal\Basic\{Dictionary, ICalUtil};
use Bitrix\Main\Type\Date;
 
 
class IncomingEventManager
{
    public static function handleRequest($params)
    {
        $event = $params['event'];
        $userId = $params['userId'];
        $answer = $params['answer'];
        $userEmail = $params['emailTo'];
        $organizerEmail = $event['ORGANIZER_MAIL']['EMAIL'];
 
        $event = static::updateEvent($event, $userId, $answer);
        $attendees = static::handleAttendeesFromRequest([
            'attendees' => $event['ATTENDEES_MAIL'],
            'answer' => $answer,
            'userId' => $userId,
            'userEmail' => $userEmail,
            'organizerEmail' => $organizerEmail
        ]);
 
        $parentId = \CCalendar::SaveEvent([
            'arFields' => static::updateParentEvent($event),
        ]);
 
        \CCalendar::SaveEvent([
            'arFields' => static::updateChildEvent($event, $parentId),
        ]);
 
 
        $replyStatus = OutcomingEventManager::createInstance([
            'icalMethod' => 'reply',
            'arFields' => $event,
            'userIndex' => $attendees,
            'receiver' => $event['ORGANIZER_MAIL'],
            'sender' => $attendees[$event['OWNER_ID']],
        ])->replyInvitation()->getStatus();
    }
 
    public static function handleReply(array $params): bool
    {
        $uid = $params['event']['DAV_XML_ID'];
        $emailUser = $params['event']['ATTENDEES_MAIL'][0];
        $userId = ICalUtil::getUserIdByEmail($emailUser);
        $localEvent = ICalUtil::getEventByUId($userId, $uid);
 
        if (!empty($localEvent))
        {
            $status = $params['event']['ATTENDEES_MAIL'][0]['STATUS'];
 
            \CCalendarEvent::SetMeetingStatusEx([
                'attendeeId' => $localEvent['OWNER_ID'],
                'eventId' => $localEvent['ID'],
                'status' => Dictionary::LOCAL_ATTENDEES_STATUS[$status],
                'personalNotification' => $localEvent['MEETING_HOST'],
            ]);
        }
 
        return true;
    }
 
    public static function handleReplyReceivedICalInvent(\Bitrix\Main\Event $event)
    {
        $attachments = $event->getParameter('attachments');
 
        if (is_array($attachments))
        {
            foreach($attachments as $key => $file)
            {
                if ($file['type'] === OutcomingEventManager::CONTENT_TYPE)
                {
                    $fileObject = new \Bitrix\Main\IO\File($file['tmp_name'], $event->getParameter('site_id'));
                    try
                    {
                        $fileContent = $fileObject->getContents();
                    }
                    catch (FileNotFoundException $e)
                    {
                        die();
                    }
                    $fileContent = Encoding::convertEncoding($fileContent, OutcomingEventManager::CHARSET, SITE_CHARSET);
                    $icalComponent = static::getDataInfo($fileContent);
 
                    if ($method === Dictionary::METHODS['reply'])
                    {
                        static::handleReply(['event' => $icalEvent]);
                    }
                }
            }
        }
    }
 
    public static function handleCancel($params)
    {
        $event = $params['event'];
        $userId = $params['userId'];
 
        $originalValue = ICalUtil::getEventByUId($userId, $event['DAV_XML_ID']);
        if (!empty($originalValue))
        {
            $deleteParams = [
                'sendNotification' => true,
                'checkPermissions' => false,
            ];
 
            \CCalendar::DeleteEvent($originalValue['ID'], true, $deleteParams);
        }
    }
 
    public static function getDataInfo($data, $params = []): array
    {
 
        $attachmentManager = IncomingAttachmentManager::getInstance([
            'data' => $data,
        ]);
        $event = $attachmentManager->prepareEventAttachment()->getEvent();
        $method = $attachmentManager->getMethod();
 
        return [$event, $method];
    }
 
    public static function rehandleRequest($params)
    {
        $params['event']['SKIP_TIME'] = $params['event']['DT_SKIP_TIME'] === 'Y';
 
        $attendees = static::handleAttendeesByUser(
            ICalUtil::getUsersByCode($params['event']['ATTENDEES_CODES']),
            $params['answer'],
            $params['userId']
        );
 
        $mailBoxQuery = MessageAccessTable::query()
            ->setSelect(['EMAIL' => 'MAILBOX.EMAIL'])
            ->registerRuntimeField(
                'MAILBOX',
                new Reference(
                    'MAILBOX',
                    MailboxTable::class,
                    Join::on('this.MAILBOX_ID', 'ref.ID'),
                    ['join_type' => Join::TYPE_INNER]
                )
            )
            ->where('ENTITY_TYPE', MessageAccessTable::ENTITY_TYPE_CALENDAR_EVENT)
            ->where('ENTITY_ID', $params['event']['ID'])
        ;
 
        $mailbox = $mailBoxQuery->fetch();
        if (!$mailbox)
        {
            return;
        }
 
        $params['event']['ORGANIZER_MAIL'] = $attendees[$params['event']['MEETING_HOST']];
        $params['event']['ORGANIZER_MAIL']['MAILTO'] = $params['event']['MEETING']['MAILTO'];
        $params['event']['ATTENDEES_MAIL'] = $attendees[$params['event']['OWNER_ID']];
        $params['event']['ICAL_ORGANIZER'] = (Helper::getAttendee($params['event']['MEETING_HOST'], $params['event']['PARENT_ID'], false))
            ->setStatus(null)
            ->setRole(null)
            ->setRsvp(false)
            ->setCutype(null)
        ;
 
        $answer = isset($params['answer']) && $params['answer']
            ? IncomingInvitationRequestHandler::MEETING_STATUS_ACCEPTED_CODE
            : IncomingInvitationRequestHandler::MEETING_STATUS_DECLINED_CODE
        ;
        $attendee = Helper::getAttendee($params['event']['OWNER_ID'], $params['event']['PARENT_ID'], false);
        $status = Dictionary::OUT_ATTENDEES_STATUS[$answer];
        $attendee->setStatus($status);
        $attendee->setEmail($mailbox['EMAIL'])->setMailto($mailbox['EMAIL']);
        $attendeesCollection = new AttendeesCollection([$attendee]);
 
        $replyStatus = OutcomingEventManager::createInstance([
            'icalMethod' => 'reply',
            'arFields' => $params['event'],
            'userIndex' => $attendeesCollection,
            'receiver' => $params['event']['ORGANIZER_MAIL'],
            'sender' => $attendees[$params['event']['OWNER_ID']],
            'answer' => $answer,
        ])->replyInvitation()->getStatus();
    }
 
    private static function updateEvent(array $event, $userId, $answer): array
    {
        if (isset($event['DATE_FROM']))
        {
            $event['DATE_FROM_MAIL'] = $event['SKIP_TIME']
                ? static::getDateString($event['DATE_FROM'])
                : static::getDateTimeString($event['DATE_FROM']);
            $event['DATE_FROM'] = static::getDateTimeString($event['DATE_FROM']);
        }
 
        if (isset($event['DATE_TO']))
        {
            $event['DATE_TO'] = static::getDateTimeString($event['DATE_TO']);
        }
 
        if (isset($event['DATE_CREATE']))
        {
            $event['DATE_CREATE'] = static::getDateTimeString($event['DATE_CREATE']);
        }
 
        if (isset($event['TIMESTAMP_X']))
        {
            $event['TIMESTAMP_X'] = static::getDateTimeString($event['TIMESTAMP_X']);
        }
 
        if (isset($event['DT_STAMP']))
        {
            $event['DT_STAMP'] = static::getDateTimeString($event['DT_STAMP']);
        }
 
        if (isset($event['TZ_FROM']))
        {
            $event['TZ_FROM'] = static::getTimezoneNameString($event['TZ_FROM']);
        }
 
        if (isset($event['TZ_TO']))
        {
            $event['TZ_TO'] = static::getTimezoneNameString($event['TZ_TO']);
        }
 
        $event['OWNER_ID'] = $userId;
        $event['MEETING_HOST'] = ICalUtil::getUserIdByEmail($event['ORGANIZER_MAIL']);
        $event['IS_MEETING'] = 1;
        $event['SECTION_CAL_TYPE'] = 'user';
        $event['ATTENDEES_CODES'] = ['U'.$event['OWNER_ID'], 'U'.$event['MEETING_HOST']];
        $event['MEETING_STATUS'] = $answer === 'confirmed' ? 'Y' : 'N';
 
        if (empty($event['ACCESSIBILITY']))
        {
            $event['ACCESSIBILITY'] = 'free';
        }
 
        if (empty($event['IMPORTANCE']))
        {
            $event['IMPORTANCE'] = 'normal';
        }
 
        if (empty($event['STATUS']))
        {
            $event['STATUS'] = $answer === 'ACCEPT' ? 'CONFIRMED' : 'CANCELLED';
        }
 
        if (empty($event['REMIND']))
        {
            $event['REMIND'] = [
                'type' => 'min',
                'count' => '15'
            ];
        }
 
        if (empty($event['MEETING']))
        {
            $event['MEETING'] = [
                'HOST_NAME' => $event['ORGANIZER_MAIL']['name'],
                'NOTIFY' => 1,
                'REINVITE' => 0,
                'ALLOW_INVITE' => 0,
                'MEETING_CREATOR' => $event['MEETING_HOST'],
                'EXTERNAL_TYPE' => 'mail',
            ];
        }
 
        $originalValue = ICalUtil::getEventByUId($userId, $event['DAV_XML_ID']);
        $event['ID'] = $originalValue ? $originalValue['ID'] : 0;
 
        return $event;
    }
 
    private static function getDateTimeString(Date $date): string
    {
        return $date->format(Date::convertFormatToPhp(FORMAT_DATETIME));
    }
 
    private static function getDateString(Date $date): string
    {
        return $date->format('d.m.Y');
    }
 
    private static function getTimezoneNameString(\DateTimeZone $tz)
    {
        return $tz->getName();
    }
 
    private static function handleAttendeesFromRequest(array $params): array
    {
        $result = [];
 
        foreach ($params['attendees'] as $attendee)
        {
            if ($attendee['EMAIL'] == $params['userEmail'])
            {
                $usersInfo = ICalUtil::getIndexUsersById([$params['userId']]);
                $attendee['NAME'] = $usersInfo[$params['userId']]['NAME'];
                $attendee['LAST_NAME'] = $usersInfo[$params['userId']]['LAST_NAME'];
                $attendee['STATUS'] = $params['answer'] === 'confirmed' ? 'accepted' : 'declined';
                $result[$params['userId']] = $attendee;
            }
 
            if ($attendee['EMAIL'] == $params['organizerEmail'])
            {
                $id = ICalUtil::getUserIdByEmail($attendee);
                $result[$id] = $attendee;
            }
        }
 
        return $result;
    }
 
    private static function handleAttendeesByUser(array $attendees, $answer, $userId)
    {
        $result = [];
        foreach ($attendees as $attendee)
        {
            if ($attendee['ID'] == $userId)
            {
                $attendee['STATUS'] = $answer ? 'accepted' : 'declined';
            }
 
            $result[$attendee['ID']] = $attendee;
        }
 
        return $result;
    }
 
    private static function updateChildEvent(array $event, $parentId)
    {
        $event['PARENT_ID'] = $parentId;
        $event['MEETING']['MAILTO'] = $event['ORGANIZER_MAIL']['MAILTO'];
        $event['DESCRIPTION'] .= "\r\n"
            . Loc::getMessage('EC_ORGANIZER_NAME_TITLE') . ': ' . static::getOrganizerString($event['ORGANIZER_MAIL']) . "\r\n"
            . Loc::getMessage('EC_ATTENDEES_LIST_TITLE') . ': ' . static::getAttendeesString($event['ATTENDEES_MAIL']);
        if (!empty($event['ATTACHMENT_LINK']))
        {
            $event['DESCRIPTION'] .= "\r\n"
                . Loc::getMessage('EC_FILES_TITLE') . ': ' . static::getFilesString($event['ATTACHMENT_LINK']);
        }
        return $event;
    }
 
    private static function getAttendeesString($attendees)
    {
        $res = [];
        foreach ($attendees as $attendee)
        {
            $res[] = $attendee['NAME'] . ' ' . $attendee['LAST_NAME'] . ' ('. $attendee['EMAIL'] .')';
        }
 
        return implode(', ', $res);
    }
 
    private static function getOrganizerString($organizer)
    {
        return $organizer['NAME'] . ' ' . $organizer['LAST_NAME'] . ' ('. $organizer['EMAIL'] .')';
    }
 
    private static function updateParentEvent(array $event)
    {
        $event['OWNER_ID'] = $event['MEETING_HOST'];
        unset($event['DAV_XML_ID']);
 
        return $event;
    }
 
    private static function getFilesString(array $attachments)
    {
        $res = [];
        foreach ($attachments as $attachment)
        {
            $res[] = $attachment['filename'] . ' (' . $attachment['link'] . ')';
        }
        return implode(', ', $res);
    }
}