class.ilMassMailTaskProcessor.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2019 ILIAS open source, Extended GPL, see docs/LICENSE */
 
use ILIAS\BackgroundTasks\Implementation\Bucket\BasicBucket;
use ILIAS\BackgroundTasks\Task\TaskFactory;
use ILIAS\BackgroundTasks\TaskManager;
use ILIAS\DI\Container;
 
class ilMassMailTaskProcessor
{
    private $taskManager;
 
    private $taskFactory;
 
    private $language;
 
    private $logger;
 
    private $objectJsonService;
 
    private $anonymousUserId;
 
    public function __construct(
        TaskManager $taskManager = null,
        TaskFactory $taskFactory = null,
        ilLanguage $language = null,
        ilLogger $logger = null,
        Container $dic = null,
        ilMailValueObjectJsonService $objectJsonService = null,
        string $anonymousUserId = ANONYMOUS_USER_ID
    ) {
        if (null === $dic) {
            global $DIC;
            $dic = $DIC;
        }
 
        if (null === $taskManager) {
            $taskManager = $dic->backgroundTasks()->taskManager();
        }
        $this->taskManager = $taskManager;
 
        if (null === $taskFactory) {
            $taskFactory = $dic->backgroundTasks()->taskFactory();
        }
        $this->taskFactory = $taskFactory;
 
        if (null === $language) {
            $language = $dic->language();
        }
        $this->language = $language;
 
        if (null === $logger) {
            $logger = ilLoggerFactory::getLogger('mail');
        }
        $this->logger = $logger;
 
        if (null === $objectJsonService) {
            $objectJsonService = new ilMailValueObjectJsonService();
        }
        $this->objectJsonService = $objectJsonService;
 
        $this->anonymousUserId = $anonymousUserId;
    }
 
    public function run(
        array $mailValueObjects,
        int $userId,
        string $contextId,
        array $contextParameters,
        int $mailsPerTask = 100
    ) {
        $objectsServiceSize = sizeof($mailValueObjects);
 
        if ($objectsServiceSize <= 0) {
            throw new ilException('First parameter must contain at least 1 array element');
        }
 
        if ($mailsPerTask <= 0) {
            throw new ilException(sprintf('The mails per task MUST be a positive integer, "%s" given', $mailsPerTask));
        }
 
        foreach ($mailValueObjects as $mailValueObject) {
            if (false === ($mailValueObject instanceof ilMailValueObject)) {
                throw new ilException('Array MUST contain ilMailValueObjects ONLY');
            }
        }
 
        $lastTask = null;
        $taskCounter = 0;
 
        $remainingObjects = array();
        foreach ($mailValueObjects as $mailValueObject) {
            $taskCounter++;
 
            $remainingObjects[] = $mailValueObject;
            if ($taskCounter === $mailsPerTask) {
                $interaction = $this->createInteraction($userId, $contextId, $contextParameters, $remainingObjects);
 
                $this->runTask($interaction, $userId);
 
                $taskCounter = 0;
                $remainingObjects = array();
            }
        }
 
        if (array() !== $remainingObjects) {
            $interaction = $this->createInteraction($userId, $contextId, $contextParameters, $remainingObjects);
 
            $this->runTask($interaction, $userId);
        }
    }
 
    private function runTask(\ILIAS\BackgroundTasks\Task $task, int $userId)
    {
        $bucket = new BasicBucket();
        $bucket->setUserId($userId);
 
        $bucket->setTask($task);
        $bucket->setTitle($this->language->txt('mail_bg_task_title'));
 
        $this->logger->info('Delegated delivery to background task');
        $this->taskManager->run($bucket);
    }
 
    private function createInteraction(
        int $userId,
        string $contextId,
        array $contextParameters,
        $remainingObjects
    ) : \ILIAS\BackgroundTasks\Task {
        $jsonString = $this->objectJsonService->convertToJson($remainingObjects);
 
        $task = $this->taskFactory->createTask(\ilMassMailDeliveryJob::class, [
            (int) $userId,
            (string) $jsonString,
            (string) $contextId,
            (string) serialize($contextParameters),
        ]);
 
        // Important: Don't return the task (e.g. as an early return for anonymous user id) https://mantis.ilias.de/view.php?id=33618
 
        $parameters = [$task, (int) $userId];
 
        $interaction = $this->taskFactory->createTask(
            \ilMailDeliveryJobUserInteraction::class,
            $parameters
        );
 
        return $interaction;
    }
}