notificationmanager.php

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

<?php
 
namespace Bitrix\Calendar\Sync\Managers;
 
use Bitrix\Main\LoaderException;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main;
use CAgent;
use CIMNotify;
use CTimeZone;
 
use function ConvertTimeStamp;
 
class NotificationManager
{
    private const FINISHED_SYNC_NOTIFICATION_DELAY = 60;

    public static function sendFinishedSyncNotification(int $userId, string $vendorName): void
    {
        if (
            $userId
            && !empty($vendorName)
            && Main\Loader::includeModule("im")
        )
        {
            $notificationCallback = fn (?string $languageId = null) => Loc::getMessage(
                'FINISHED_SYNC_NOTIFICATION_' . mb_strtoupper($vendorName),
                null,
                $languageId
            );
 
            CIMNotify::Add([
                'TO_USER_ID' => $userId,
                'FROM_USER_ID' => $userId,
                'NOTIFY_TYPE' => IM_NOTIFY_SYSTEM,
                'NOTIFY_MODULE' => 'calendar',
                'NOTIFY_TAG' => 'CALENDAR|SYNC_FINISH|'.$userId,
                'NOTIFY_SUB_TAG' => 'CALENDAR|SYNC_FINISH|'.$userId,
                'NOTIFY_MESSAGE' => $notificationCallback
            ]);
        }
    }

    public static function sendRollbackSyncNotification(int $userId, string $vendorName): void
    {
        if (
            $userId
            && !empty($vendorName)
            && Main\Loader::includeModule("im")
        )
        {
            $notificationCallback = fn (?string $languageId = null) => Loc::getMessage(
                'ROLLBACK_SYNC_NOTIFICATION_' . mb_strtoupper($vendorName),
                null,
                $languageId
            );
 
            CIMNotify::Add([
                'TO_USER_ID' => $userId,
                'FROM_USER_ID' => $userId,
                'NOTIFY_TYPE' => IM_NOTIFY_SYSTEM,
                'NOTIFY_MODULE' => 'calendar',
                'NOTIFY_TAG' => 'CALENDAR|SYNC_ROLLBACK|'.$userId,
                'NOTIFY_SUB_TAG' => 'CALENDAR|SYNC_ROLLBACK|'.$userId,
                'NOTIFY_MESSAGE' => $notificationCallback
            ]);
        }
    }

    public static function clearFinishedSyncNotificationAgent(int $userId, string $vendorName): void
    {
        CAgent::RemoveAgent(
            '\\Bitrix\\Calendar\\Sync\\Managers\\NotificationManager::sendFinishedSyncNotification('
            . $userId . ', '
            . "'" . $vendorName . "'" . ');',
            'calendar'
        );
    }

    public static function addFinishedSyncNotificationAgent(int $userId, string $vendorName): void
    {
        CAgent::AddAgent(
            '\\Bitrix\\Calendar\\Sync\\Managers\\NotificationManager::sendFinishedSyncNotification('
            . $userId . ', '
            . "'" . $vendorName . "'" . ');',
            'calendar',
            'Y',
            0,
            '',
            'Y',
            ConvertTimeStamp(time() + CTimeZone::GetOffset() + self::FINISHED_SYNC_NOTIFICATION_DELAY, 'FULL')
        );
    }

    public static function sendBlockChangeNotification(int $userId, $messageCode, $vars): void
    {
        if (
            $userId
            && !empty(Loc::getMessage($messageCode))
            && Main\Loader::includeModule("im")
        )
        {
            $notificationCallback = fn (?string $languageId = null) => Loc::getMessage($messageCode, $vars, $languageId);
 
            CIMNotify::Add([
                'TO_USER_ID' => $userId,
                'FROM_USER_ID' => $userId,
                'NOTIFY_TYPE' => IM_NOTIFY_SYSTEM,
                'NOTIFY_MODULE' => 'calendar',
                'NOTIFY_TAG' => 'CALENDAR|SYNC_ROLLBACK|' . $userId . '|' . ($vars['EVENT_ID'] ?? random_int(1,100)),
                'NOTIFY_SUB_TAG' => 'CALENDAR|SYNC_ROLLBACK|'.$userId,
                'NOTIFY_MESSAGE' => $notificationCallback
            ]);
        }
    }
}