class.ilMassMailDeliveryJob.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\Tasks\AbstractJob;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\BooleanValue;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\IntegerValue;
use ILIAS\BackgroundTasks\Implementation\Values\ScalarValues\StringValue;
use ILIAS\BackgroundTasks\Observer;
use ILIAS\BackgroundTasks\Types\SingleType;

class ilMassMailDeliveryJob extends AbstractJob
{
    private $dic;

    private $mailJsonService;

    public function __construct()
    {
        global $DIC;
        $this->dic = $DIC;

        $this->mailJsonService = new ilMailValueObjectJsonService();
    }

    public function run(array $input, Observer $observer)
    {
        $mailValueObjects = $this->mailJsonService->convertFromJson((string) $input[1]->getValue());

        foreach ($mailValueObjects as $mailValueObject) {
            $mail = new ilMail((int) $input[0]->getValue());

            $mail->setSaveInSentbox((bool) $mailValueObject->shouldSaveInSentBox());
            $contextId = $input[2]->getValue();
            $mail = $mail
                ->withContextId((string) $contextId)
                ->withContextParameters((array) unserialize($input[3]->getValue()));

            $recipients = (string) $mailValueObject->getRecipients();
            $recipientsCC = (string) $mailValueObject->getRecipientsCC();
            $recipientsBCC = (string) $mailValueObject->getRecipientsBCC();

            $this->dic->logger()->mail()->info(
                sprintf(
                    'Mail delivery to recipients: "%s" CC: "%s" BCC: "%s" From sender: "%s"',
                    $recipients,
                    $recipientsCC,
                    $recipientsBCC,
                    $mailValueObject->getFrom()
                )
            );

            $mail->sendMail(
                $recipients,
                $recipientsCC,
                $recipientsBCC,
                (string) $mailValueObject->getSubject(),
                (string) $mailValueObject->getBody(),
                (array) $mailValueObject->getAttachments(),
                (bool) $mailValueObject->isUsingPlaceholders()
            );
        }

        $output = new BooleanValue();
        $output->setValue(true);

        return $output;
    }

    public function getInputTypes()
    {
        return [
            new SingleType(IntegerValue::class), // User Id
            new SingleType(StringValue::class),  // JSON encoded array of ilMailValueObject
            new SingleType(StringValue::class),  // Context Id
            new SingleType(StringValue::class),  // Context Parameters
        ];
    }

    public function isStateless()
    {
        return true;
    }

    public function getExpectedTimeOfTaskInSeconds()
    {
        return 42; // The answer to life, universe and the rest
    }

    public function getOutputType()
    {
        return new SingleType(BooleanValue::class);
    }
}