ilMassMailTaskProcessor Class Reference

Collaboration diagram for ilMassMailTaskProcessor:

Public Member Functions
	__construct (TaskManager $taskManager=null, TaskFactory $taskFactory=null, ilLanguage $language=null, ilLogger $logger=null, Container $dic=null, ilMailValueObjectJsonService $objectJsonService=null, string $anonymousUserId=ANONYMOUS_USER_ID)
	run (array $mailValueObjects, int $userId, string $contextId, array $contextParameters, int $mailsPerTask=100)

Private Member Functions
	runTask (\ILIAS\BackgroundTasks\Task $task, int $userId)
	createInteraction (int $userId, string $contextId, array $contextParameters, $remainingObjects)

Private Attributes
	$taskManager
	$taskFactory
	$language
	$logger
	$objectJsonService
	$anonymousUserId

Detailed Description

Author

Niels Theen nthee.nosp@m.n@da.nosp@m.tabay.nosp@m..de

Definition at line 12 of file class.ilMassMailTaskProcessor.php.

Constructor & Destructor Documentation

__construct()

ilMassMailTaskProcessor::__construct	(	TaskManager	$taskManager = null,
		TaskFactory	$taskFactory = null,
		ilLanguage	$language = null,
		ilLogger	$logger = null,
		Container	$dic = null,
		ilMailValueObjectJsonService	$objectJsonService = null,
		string	$anonymousUserId = ANONYMOUS_USER_ID
	)

Parameters

TaskManager	$taskManager
TaskFactory | null	$taskFactory
ilLanguage | null	$language
ilLogger | null	$logger
Container | null	$dic
ilMailValueObjectJsonService | null	$objectJsonService
string	$anonymousUserId

Definition at line 53 of file class.ilMassMailTaskProcessor.php.

References $anonymousUserId, $dic, $DIC, $language, $logger, $objectJsonService, $taskFactory, $taskManager, ilLoggerFactory\getLogger(), and language().

      {
        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;
    }

Here is the call graph for this function:

Member Function Documentation

createInteraction()

ilMassMailTaskProcessor::createInteraction ( int  $userId, string  $contextId, array  $contextParameters,   $remainingObjects  )

private

Parameters

int	$userId
string	$contextId
array	$contextParameters
	$remainingObjects

Returns

Definition at line 174 of file class.ilMassMailTaskProcessor.php.

Referenced by run().

      : \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;
    }

Here is the caller graph for this function:

run()

ilMassMailTaskProcessor::run	(	array	$mailValueObjects,
		int	$userId,
		string	$contextId,
		array	$contextParameters,
		int	$mailsPerTask = 100
	)

Parameters

	ilMailValueObject[]	$mailValueObjects - One MailValueObject = One Task
int	$userId	- User ID of the user who executes the background task
string	$contextId	- context ID of the Background task
array	$contextParameters	- context parameters for the background tasks
int	$mailsPerTask	- Defines how many mails will be added before a background task is executed

Exceptions

ilException

Definition at line 103 of file class.ilMassMailTaskProcessor.php.

References createInteraction(), and runTask().

      {
        $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);
        }
    }

Here is the call graph for this function:

runTask()

ilMassMailTaskProcessor::runTask ( \ILIAS\BackgroundTasks\Task  $task, int  $userId  )

private

Parameters

\ILIAS\BackgroundTasks\Task	$task
int	$userId

Definition at line 155 of file class.ilMassMailTaskProcessor.php.

References language().

Referenced by run().

    {
        $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);
    }

Here is the call graph for this function:

Here is the caller graph for this function:

Field Documentation

$anonymousUserId

ilMassMailTaskProcessor::$anonymousUserId

private

Definition at line 42 of file class.ilMassMailTaskProcessor.php.

Referenced by __construct().

$language

ilMassMailTaskProcessor::$language

private

Definition at line 27 of file class.ilMassMailTaskProcessor.php.

Referenced by __construct().

$logger

ilMassMailTaskProcessor::$logger

private

Definition at line 32 of file class.ilMassMailTaskProcessor.php.

Referenced by __construct().

$objectJsonService

ilMassMailTaskProcessor::$objectJsonService

private

Definition at line 37 of file class.ilMassMailTaskProcessor.php.

Referenced by __construct().

$taskFactory

ilMassMailTaskProcessor::$taskFactory

private

Definition at line 22 of file class.ilMassMailTaskProcessor.php.

Referenced by __construct().

$taskManager

ilMassMailTaskProcessor::$taskManager

private

Definition at line 17 of file class.ilMassMailTaskProcessor.php.

Referenced by __construct().

---

The documentation for this class was generated from the following file:

• Services/Mail/classes/BackgroundTask/class.ilMassMailTaskProcessor.php