View source
<?php
namespace Drupal\activity_send_email\Plugin\QueueWorker;
use Drupal\activity_creator\Entity\Activity;
use Drupal\activity_send\Plugin\QueueWorker\ActivitySendWorkerBase;
use Drupal\activity_send_email\EmailFrequencyManager;
use Drupal\activity_send_email\Plugin\ActivityDestination\EmailActivityDestination;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Link;
use Drupal\Core\Mail\MailManagerInterface;
use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
use Drupal\Core\Render\RendererInterface;
use Drupal\Core\StringTranslation\TranslationInterface;
use Drupal\Core\Url;
use Symfony\Component\DependencyInjection\ContainerInterface;
class ActivityDigestWorker extends ActivitySendWorkerBase implements ContainerFactoryPluginInterface {
protected $entityTypeManager;
protected $emailFrequencyManager;
protected $mailManager;
protected $renderer;
protected $translation;
public function __construct(array $configuration, $plugin_id, $plugin_definition, EntityTypeManagerInterface $entity_type_manager, EmailFrequencyManager $email_frequency_manager, MailManagerInterface $mail_manager, RendererInterface $renderer, TranslationInterface $translation) {
parent::__construct($configuration, $plugin_id, $plugin_definition);
$this->entityTypeManager = $entity_type_manager;
$this->emailFrequencyManager = $email_frequency_manager;
$this->mailManager = $mail_manager;
$this->renderer = $renderer;
$this->translation = $translation;
}
public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
return new static($configuration, $plugin_id, $plugin_definition, $container
->get('entity_type.manager'), $container
->get('plugin.manager.emailfrequency'), $container
->get('plugin.manager.mail'), $container
->get('renderer'), $container
->get('string_translation'));
}
public function processItem($data) {
if (!empty($data['uid']) && !empty($data['frequency']) && !empty($data['activities'])) {
$user_storage = $this->entityTypeManager
->getStorage('user');
$message_storage = $this->entityTypeManager
->getStorage('message');
$target = $user_storage
->load($data['uid']);
if (is_object($target) && $target
->isActive()) {
$langcode = $target
->getPreferredLangcode();
$digest_notifications = [
'#theme' => 'digestmail',
];
$activity_storage = $this->entityTypeManager
->getStorage('activity');
foreach ($data['activities'] as $activity_id) {
$activity = $activity_storage
->load($activity_id);
if ($activity instanceof Activity && $activity
->getRelatedEntity() !== NULL && !$activity
->getRelatedEntity()
->access('view', $target)) {
continue;
}
if (isset($activity->field_activity_output_text)) {
$message = $message_storage
->load($activity->field_activity_message->target_id);
$body_text = EmailActivityDestination::getSendEmailOutputText($message, $langcode);
if ($langcode && !empty($body_text)) {
$digest_notifications['#notifications'][] = $body_text;
}
}
}
if (!empty($digest_notifications['#notifications'])) {
$notification_count = count($digest_notifications['#notifications']);
$digest_notifications['#notification_count'] = $this->translation
->formatPlural($notification_count, 'You have received <strong>:count</strong> notification', 'You have received <strong>:count</strong> notifications', [
':count' => $notification_count,
], [
'langcode' => $langcode,
]);
$instance = $this->emailFrequencyManager
->createInstance($data['frequency']);
$frequency_translated = t($instance
->getName()
->getUntranslatedString(), [], [
'langcode' => $langcode,
]);
$digest_notifications['#notification_settings'] = $this->translation
->formatPlural($notification_count, 'Based on your @settings, the notification above is sent to you as a <strong>:frequency mail</strong>', 'Based on your @settings, the notifications above are sent to you as a <strong>:frequency mail</strong>', [
'@settings' => Link::fromTextAndUrl(t('email notification settings'), Url::fromRoute('activity_send_email.user_edit_page')
->setAbsolute())
->toString(),
':frequency' => $frequency_translated,
], [
'langcode' => $langcode,
]);
$params['body'] = $this->renderer
->renderRoot($digest_notifications);
$this->mailManager
->mail('activity_send_email', 'activity_send_email', $target
->getEmail(), $langcode, $params, NULL, TRUE);
}
}
}
}
}