os2web_hearings.module

<?php

/**
 * @file
 * OS2Web Hearings module file.
 */

use Drupal\comment\CommentManagerInterface;
use Drupal\Component\Utility\Mail as MailHelper;
use Drupal\Core\Datetime\DrupalDateTime;
use Drupal\Core\Cache\Cache;
use Drupal\Core\Entity\EntityForm;
use Drupal\Core\Field\EntityReferenceFieldItemListInterface;
use Drupal\datetime\Plugin\Field\FieldType\DateTimeItemInterface;
use Drupal\node\Entity\Node;
use Drupal\Core\Entity\EntityInterface;
use Drupal\Core\Form\FormStateInterface;
use Drupal\os2web_hearings\Form\SettingsForm;

define('OS2WEB_HEARINGS_STATUS_ACTIVE_NAME', 'I gang');
define('OS2WEB_HEARINGS_STATUS_CLOSED_NAME', 'Afsluttet');

define('OS2WEB_HEARINGS_TYPE_HEARINGS', 'Høringer');
define('OS2WEB_HEARINGS_TYPE_DECISIONS', 'Afgørelserr');

define('OS2WEB_HEARINGS_CATEGORIES_BUDGET', 'Budget');
define('OS2WEB_HEARINGS_TYPE_LANDZONETILLADELSE', 'Landzonetilladelse');

/**
 * Implements hook_preprocess_paragraph().
 *
 * Adding meeting search form into paragraph.
 */
function os2web_hearings_preprocess_paragraph__os2web_hearings_search(&$variables) {
  if ($variables['view_mode'] == 'preview') {
    return;
  }

  $paragraph = $variables['paragraph'];
  // Getting the view type.
  $type = 'os2web_hearings_embed_search_simple';

  $type_value = $paragraph->get('field_os2web_hearings_search_typ')->getValue();
  if (!empty($type_value[0]['value'])) {
    $type = $type_value[0]['value'];
  }

  $view = \Drupal\views\Views::getView('os2web_hearings');
  $view->setDisplay($type);
  $view->preExecute();
  $view->execute();

  // Get Headers.
  $headers = $view->display_handler->getHandlers('header');
  $rendered_headers = [];
  if (!empty($headers)) {
    foreach ($headers as $header) {
      $rendered_headers[] = $header->render();
    }
  }
  $variables['content'][] = $rendered_headers;

  $variables['content'][] = $view->render();

  $variables['#cache']['tags'][] = 'os2web_hearings_search_cache';
}

/**
 * Implements hook_cron().
 */
function os2web_hearings_cron() {
  // Close hearing if end_date is reached.
  $tids = \Drupal::entityQuery('taxonomy_term')
    ->condition('vid', 'os2web_hearings_status')
    ->condition('name', OS2WEB_HEARINGS_STATUS_ACTIVE_NAME)
    ->execute();
  if (empty($tids)) {
    \Drupal::logger('os2web_horing')
      ->error('Term for active hearings status not found');
    return;
  }
  $active_tid = reset($tids);

  $now = new DrupalDateTime('now');
  $now->setTimezone(new \DateTimeZone(DateTimeItemInterface::STORAGE_TIMEZONE));

  // Fetching nodes with active status.
  $ids = \Drupal::entityQuery('node')
    ->condition('type', 'os2web_hearings_hearing_case')
    ->condition('field_os2web_hearings_end_date', $now->format(DateTimeItemInterface::DATETIME_STORAGE_FORMAT), '<')
    ->condition('field_os2web_hearings_status', $active_tid)
    ->execute();

  // Fetching nodes with empty status.
  $ids_empty = \Drupal::entityQuery('node')
    ->condition('type', 'os2web_hearings_hearing_case')
    ->condition('field_os2web_hearings_end_date', $now->format(DateTimeItemInterface::DATETIME_STORAGE_FORMAT), '<')
    ->notExists('field_os2web_hearings_status')
    ->execute();
  $ids = array_unique(array_merge($ids, $ids_empty));

  if (empty($ids)) {
    return;
  }

  $tids = \Drupal::entityQuery('taxonomy_term')
    ->condition('vid', 'os2web_hearings_status')
    ->condition('name', OS2WEB_HEARINGS_STATUS_CLOSED_NAME)
    ->execute();
  if (empty($tids)) {
    \Drupal::logger('os2web_horing')
      ->error('Term for closed hearings status not found');
    return;
  }
  $closed_tid = reset($tids);
  $tids = \Drupal::entityQuery('taxonomy_term')
    ->condition('vid', 'os2web_hearings_type')
    ->condition('name', OS2WEB_HEARINGS_TYPE_HEARINGS)
    ->execute();
  if (empty($tids)) {
    \Drupal::logger('os2web_horing')
      ->error('Term for hearings type not found');
    return;
  }
  $hearing_type_tid = reset($tids);
  $settingFormConfig = \Drupal::config(SettingsForm::$configName);
  /** @var \Drupal\node\NodeInterface $node */
  foreach (Node::loadMultiple($ids) as $node) {
    $node->set('field_os2web_hearings_status', $closed_tid);
    $node->save();
    if ($settingFormConfig->get('disable_sbsys_email_for_decision')) {
      $hearing_type = $node->field_os2web_hearings_type->getValue();
      if ($hearing_type[0]['target_id'] == $hearing_type_tid) {
        _os2web_hearings_send_email_notification($node);
      }
    }
    else {
      _os2web_hearings_send_email_notification($node);
    }
  }
}

/**
 * Implements hook_ENTITY_TYPE_presave().
 */
function os2web_hearings_node_presave(EntityInterface $entity) {
  if ($entity->bundle() != 'os2web_hearings_hearing_case') {
    return;
  }

  // Invalidating cache for all hearing search paragraphs.
  Cache::invalidateTags(['os2web_hearings_search_cache']);

  if ($entity->isNew()) {
    // If header is empty, use the title.
    if (empty($entity->field_os2web_hearings_heading->value)) {
      $entity->field_os2web_hearings_heading->value = $entity->label();
    }
  }

  /** @var Drupal\Core\Datetime\DrupalDateTime $endDate */
  $endDate = $entity->field_os2web_hearings_end_date->date;

  // Activate hearing when end date is changed.
  if (empty($endDate) || $endDate->getTimestamp() < time()) {
    return;
  }

  $tids = \Drupal::entityQuery('taxonomy_term')
    ->condition('vid', 'os2web_hearings_status')
    ->condition('name', OS2WEB_HEARINGS_STATUS_ACTIVE_NAME)
    ->execute();
  if (empty($tids)) {
    \Drupal::logger('os2web_horing')
      ->error('Can not set correct active status on new hearing');
    return;
  }
  $active_tid = reset($tids);
  $entity->set('field_os2web_hearings_status', $active_tid);

  if ($entity->status->value && empty($entity->field_os2web_hearings_published->value)) {
    $entity->set('field_os2web_hearings_published', date(DateTimeItemInterface::DATE_STORAGE_FORMAT, strtotime('now')));
  }
}

/**
 * Implements hook_theme().
 */
function os2web_hearings_theme() {
  return [
    'hearings_og_afgeorelse_case__mail' => [
      'variables' => [
        'node' => NULL,
        'attachments' => NULL,
        'comments' => NULL,
        'comments_files' => NULL,
      ],
    ],
    'hearings_og_afgeorelse_case__comment_mail_notification' => [
      'variables' => [
        'node' => NULL,
        'node_url' => NULL,
      ],
    ],
  ];
}

/**
 * Implements hook_mail().
 *
 * Captures the outgoing mail and sets appropriate message body and headers.
 */
function os2web_hearings_mail($key, &$message, $params) {
  if (isset($params['headers'])) {
    $message['headers'] = array_merge($message['headers'], $params['headers']);
  }

  $message['from'] = $params['from'];
  $message['subject'] = $params['subject'];
  $message['body'][] = $params['body'];
}

/**
 * Implements hook_form_FORM_ID_alter().
 */
function os2web_hearings_form_taxonomy_term_os2web_hearings_status_form_alter(&$form, FormStateInterface $form_state, $form_id) {
  // Status terms names are using as key for changing status.
  // It shouldn't be possible to change name on term that is used for statuses.
  /** @var \Drupal\taxonomy\Entity\Term $term */
  $term = $form_state->getFormObject()->getEntity();
  if (in_array($term->label(), [OS2WEB_HEARINGS_STATUS_CLOSED_NAME, OS2WEB_HEARINGS_STATUS_ACTIVE_NAME])) {
    $form['name']['widget'][0]['#disabled'] = TRUE;
    $form['name']['widget']['description'] = ['#markup' => t('This taxonomy term is used for hearing status field and can not be renamed')];
  }
}

/**
 * Implements hook_form_FORM_ID_alter().
 */
function os2web_hearings_form_taxonomy_term_os2web_hearings_status_delete_form_alter(&$form, FormStateInterface $form_state, $form_id) {
  // Status terms names are using as key for changing status.
  // It shouldn't be possible to delete term that is used for statuses.
  /** @var \Drupal\taxonomy\Entity\Term $term */
  $term = $form_state->getFormObject()->getEntity();
  if (in_array($term->label(), [OS2WEB_HEARINGS_STATUS_CLOSED_NAME, OS2WEB_HEARINGS_STATUS_ACTIVE_NAME])) {
    $form['description'] = [
      '#markup' => t('This taxonomy term is used for hearing status field and can not be deleted'),
    ];
    $form['#disabled'] = TRUE;
  }
}

/**
 * Implements hook_form_FORM_ID_alter().
 *
 * Changes the fields position.
 */
function os2web_hearings_form_views_exposed_form_alter(&$form, FormStateInterface $form_state, $form_id) {
  if (in_array($form['#id'],
    ['views-exposed-form-os2web-hearings-os2web-hearings-embed-search-tender-category',
      'views-exposed-form-os2web-hearings-os2web-hearings-embed-search-category',
      'views-exposed-form-os2web-hearings-os2web-hearings-embed-search-tender',
      'views-exposed-form-os2web-hearings-os2web-hearings-embed-search-simple'
    ])) {
    $terms = \Drupal::service('entity_type.manager')
      ->getStorage('taxonomy_term')
      ->loadByProperties(['vid' => 'os2web_hearings_status', 'name'=> OS2WEB_HEARINGS_STATUS_ACTIVE_NAME]);
    $term = reset($terms);
    $request = \Drupal::request();
    if ($term && is_null($request->get('field_os2web_hearings_status_target_id'))) {
      // get all input fields first then modify the one you want to change
      $input = $form_state->getUserInput();
      $input['field_os2web_hearings_status_target_id'] = $term->id();
      $form_state->setUserInput($input);
    }

  }
  if ($form['#id'] == 'views-exposed-form-os2web-hearings-os2web-hearings-embed-search-simple') {
    // Making sure status filter is in the bottom.
    $status_filter = $form['field_os2web_hearings_status_target_id'];
    unset($form['field_os2web_hearings_status_target_id']);
    $form['field_os2web_hearings_status_target_id'] = $status_filter;
  }
}

/**
 * Implements hook_form_FORM_ID_alter().
 */
function os2web_hearings_form_comment_os2web_hearings_hearing_reply_form_alter(&$form, FormStateInterface $form_state, $form_id) {
  $form['comment_body']['widget']['#after_build'][] = '_os2web_hearings_remove_textarea_help';

  /** @var \Drupal\Core\Entity\EntityForm $form_object */
  $form_object = $form_state->getFormObject();
  if ($form_object instanceof EntityForm) {
    /** @var \Drupal\comment\Entity\Comment $entity */
    $comment = $form_object->getEntity();

    $node = $comment->getCommentedEntity();
    if (!$node->field_os2web_hearings_sp_rol_ena->value) {
      unset($form['field_os2web_hearings_reply_sp_r']);
    } else {
      // Making select html5 required.
      unset($form['field_os2web_hearings_reply_sp_r']['widget']['#options']['_none']);
      $form['field_os2web_hearings_reply_sp_r']['widget']['#options'] = ['' => '- Vælg -'] + $form['field_os2web_hearings_reply_sp_r']['widget']['#options'];
      $form['field_os2web_hearings_reply_sp_r']['widget']['#required'] = TRUE;
    }
  }
}

/**
 * Hides the field format help text.
 *
 * @param array $form_element
 *   Form element to hide the help text from.
 * @param \Drupal\Core\Form\FormStateInterface $form_state
 *   Form state.
 *
 * @return mixed
 *   Form element without help text from.
 */
function _os2web_hearings_remove_textarea_help(array $form_element, FormStateInterface $form_state) {
  if (isset($form_element[0]['format'])) {
    // All this stuff is needed to hide the help text.
    unset($form_element[0]['format']['guidelines']);
    unset($form_element[0]['format']['help']);
    unset($form_element[0]['format']['#type']);
    unset($form_element[0]['format']['#theme_wrappers']);
    $form_element[0]['format']['format']['#access'] = FALSE;
  }

  return $form_element;
}

function _os2web_hearings_send_email_notification($node) {
  $type = t('Høringe elle Afgørelse');
  if (!empty($node->field_os2web_hearings_type) && $node->field_os2web_hearings_type instanceof EntityReferenceFieldItemListInterface) {
    $type_value = $node->field_os2web_hearings_type->referencedEntities();
    $type = $type_value[0]->label();
  }

  $site_config = \Drupal::service('config.factory')->get('system.site');
  $renderer = \Drupal::service('renderer');
  $params = [
    'headers' => [
      'Content-Type' => 'text/html; charset=UTF-8;',
      'Content-Transfer-Encoding' => '8Bit',
    ],
    'from' => MailHelper::formatDisplayName($site_config->get('name')) . ' <' . $site_config->get('mail') . '>',
    'subject' => t('@type #@nid', [
      '@nid' => $node->id(),
      '@type' => $type,
    ]),
  ];

  // Gathering hearing attachments.
  $hearing_attachments = [];
  if (!empty($node->field_os2web_hearings_attac_doc)) {
    foreach ($node->field_os2web_hearings_attac_doc->referencedEntities() as $file) {
      if (!file_exists($file->getFileUri())) {
        continue;
      }
      $params['files'][] = (object) [
        'filename' => $file->getFilename(),
        'uri' => $file->getFileUri(),
        'filemime' => $file->getMimeType(),
      ];

      $hearing_attachments[] = [
        'name' => $file->getFilename(),
        'url' => $file->createFileUrl(FALSE),
      ];
    }
  }

  // Gathering comments.
  $comments = \Drupal::service('entity_type.manager')->getStorage('comment')->loadThread($node, 'field_os2web_hearings_reply', CommentManagerInterface::COMMENT_MODE_FLAT);

  // Gathering comments files.
  $comments_files = [];
  foreach ($comments as $comment) {
    if (empty($comment->field_os2web_hearings_reply_docs)) {
      continue;
    }
    foreach ($comment->field_os2web_hearings_reply_docs->referencedEntities() as $file) {
      if (!file_exists($file->getFileUri())) {
        continue;
      }
      $params['files'][] = (object) [
        'filename' => $file->getFilename(),
        'uri' => $file->getFileUri(),
        'filemime' => $file->getMimeType(),
      ];

      $comments_files[$comment->id()][] = [
        'name' => $file->getFilename(),
        'url' => $file->createFileUrl(FALSE),
      ];
    }
  }
  // Creating theme build array.
  $build = [
    '#theme' => 'hearings_og_afgeorelse_case__mail',
    '#node' => $node,
    '#attachments' => $hearing_attachments,
    '#comments' => $comments,
    '#comments_files' => $comments_files,
  ];
  $params['body'] = $renderer->renderRoot($build);

  /** @var \Drupal\os2web_hearings\SbsysGenerator $sbsys_generator */
  $sbsys_generator = \Drupal::service('os2web_hearings.sbsys_generator');
  $xmlFileUri = $sbsys_generator->generateFile('os2formsFormular', $node, $params['body']->__toString());

  // Attaching SBSYS XML.
  if ($xmlFileUri) {
    $xmlFile = (object) [
      'filename' => 'sbsys.xml',
      'uri' => $xmlFileUri,
      'filemime' => 'application/xml',
    ];
    $params['files'][] = $xmlFile;
  }

  $langcode = \Drupal::languageManager()->getDefaultLanguage()->getId();
  $settingFormConfig = \Drupal::config(SettingsForm::$configName);
  $mailto = $settingFormConfig->get('sbsys_email');
  if (empty($mailto)) {
    \Drupal::logger('os2web_hearings')->warning(t('Notification email is empty. Can not send email notification for os2web_hearings_hearing_case with id @nid.', ['@nid' => $node->id()]));
    return;
  }
  $mail_manager = \Drupal::service('plugin.manager.mail');
  if (!$mail_manager->mail('os2web_hearings', 'default', $mailto, $langcode, $params)) {
    \Drupal::logger('os2web_hearings')->error(t('Sending of email notification for os2web_hearings_hearing_case with id @nid failed.', ['@nid' => $node->id()]));
  }
}

/**
 * Implements hook_preprocess_node().
 */
function os2web_hearings_preprocess_node(&$variables) {
  if ($variables['node']->getType() == 'os2web_hearings_hearing_case') {
    $hearing = $variables['node'];

    /** @var \Drupal\Core\Datetime\DrupalDateTime $endDate */
    $endDate = $hearing->field_os2web_hearings_end_date->date;
    $type_value = $hearing->field_os2web_hearings_type->referencedEntities();
    $type = $type_value[0]->label();
    $variables['content']['#is_decision'] = ($type == OS2WEB_HEARINGS_TYPE_DECISIONS);

    $tender_value = $hearing->field_os2web_hearings_tender->referencedEntities();

    $reply_text = null;

    if (!empty($tender_value[0])) {
      $tender = $tender_value[0];
      if (is_object($tender)) {
        if ($tender->id() == 4563) // udbud
        {
          $reply_text = 'Send dit tilbud.';
        }
        else if ($tender->id() == 4564) // høring
        {
          $reply_text = 'Send dit høringssvar.';
        }
      }
    }

    $variables['content']['#reply_text'] = $reply_text;

    if ($endDate->getTimestamp() < time()) {
      $variables['content']['#closed'] = TRUE;
    }
    else {
      $variables['content']['#closed'] = FALSE;
    }

    $settingFormConfig = \Drupal::config(SettingsForm::$configName);
    if ($settingFormConfig->get('disable_comments')) {
      $variables['content']['#closed'] = TRUE;
    }

    $variables['content']['destination'] = \Drupal::request()->server->get('HTTP_REFERER');
  }
}

/**
 * Implements hook_preprocess_field().
 */
function os2web_hearings_preprocess_field(&$variables) {
  $element = $variables['element'];
  if ($element['#field_name'] == 'field_os2web_hearings_reply') {

    foreach ($variables['items'][0]['content']['comments'] as $commentRendered) {
      // Check if the rendered comment exists.
      if (!isset($commentRendered['#comment'])) {
        continue;
      }

      /** @var \Drupal\comment\Entity\Comment $comment */
      $comment = $commentRendered['#comment'];
      $speakerRoles = $comment->get('field_os2web_hearings_reply_sp_r')->referencedEntities();

      // If there are no speaker roles, skip this iteration.
      if (empty($speakerRoles)) {
        continue;
      }

      /** @var \Drupal\taxonomy\Plugin\views\wizard\TaxonomyTerm $speakerRole */
      $speakerRole = reset($speakerRoles);

      // Initialize the speaker role section if it doesn't exist.
      if (!isset($variables['#comments_speaker_role'][$speakerRole->id()])) {
        $variables['#comments_speaker_role'][$speakerRole->id()] = [
          'role' => $speakerRole->label(),
          'comments_section' => [
            [
              'content' => [
                'comments' => [
                  '#sorted' => $variables['items'][0]['content']['comments']['#sorted'],
                  '#pre_render' => $variables['items'][0]['content']['comments']['#pre_render'],
                  'pager' => $variables['items'][0]['content']['comments']['pager'],
                ],
                '#comment_type' => 'os2web_hearings_hearing_reply',
                '#comment_display_mode' => 0,
                'comment_form' => []
              ],
              'attributes' => $variables['items'][0]['attributes']
            ]
          ]
        ];
      }

      // Add the rendered comment to the speaker role section.
      $variables['#comments_speaker_role'][$speakerRole->id()]['comments_section'][0]['content']['comments'][$comment->id()] = $commentRendered;

      // Remove the comment from the original comments array.
      unset($variables['items'][0]['content']['comments'][$comment->id()]);
    }
  }
}

/**
 * Implements hook_ENTITY_TYPE_insert().
 */
function os2web_hearings_comment_insert(Drupal\Core\Entity\EntityInterface $entity) {
  if ($entity->getCommentedEntityTypeId() != 'node') {
    return;
  }

  /** @var \Drupal\node\NodeInterface $node */
  $node = $entity->getCommentedEntity();
  if ($node->getType() != 'os2web_hearings_hearing_case') {
    return;
  }

  // Do not send notifications if no recipient.
  if (empty($node->field_os2web_hearings_not_email) || $node->field_os2web_hearings_not_email->isEmpty()) {
    return;
  }

  $type = t('Høringe eller Afgørelse');
  if (!empty($node->field_os2web_hearings_type) && $node->field_os2web_hearings_type instanceof EntityReferenceFieldItemListInterface) {
    $type_value = $node->field_os2web_hearings_type->referencedEntities();
    $type = $type_value[0]->label();
  }
  $language = \Drupal::languageManager()->getDefaultLanguage();
  $site_config = \Drupal::service('config.factory')->get('system.site');
  $build = [
    '#theme' => 'hearings_og_afgeorelse_case__comment_mail_notification',
    '#node' => $node,
    '#node_url' => $node->toUrl('canonical')->setAbsolute()->toString(),
  ];
  $params = [
    'headers' => [
      'Content-Type' => 'text/html; charset=UTF-8;',
      'Content-Transfer-Encoding' => '8Bit',
    ],
    'from' => MailHelper::formatDisplayName($site_config->get('name')) . ' <' . $site_config->get('mail') . '>',
    'subject' => t('Nyt kommentar på @type #@nid', [
      '@nid' => $node->id(),
      '@type' => $type,
    ]),
    'body' => \Drupal::service('renderer')->renderRoot($build),
  ];

  $mailto = $node->field_os2web_hearings_not_email->first()->value;
  $mail_manager = \Drupal::service('plugin.manager.mail');
  if (!$mail_manager->mail('os2web_hearings', 'default', $mailto, $language->getId(), $params)) {
    \Drupal::logger('os2web_hearings')->error(t('Sending of email notification for os2web_hearings_hearing_case with id @nid failed.', ['@nid' => $node->id()]));
  }
}