function CommentStatistics::update

Update or insert comment statistics records after a comment is added.

Parameters

\Drupal\comment\CommentInterface $comment: The comment added or updated.

Overrides CommentStatisticsInterface::update

File

core/modules/comment/src/CommentStatistics.php, line 207

Class

CommentStatistics

Namespace

Code

public function update(CommentInterface $comment) {
  // Allow bulk updates and inserts to temporarily disable the maintenance of
  // the {comment_entity_statistics} table.
  if (!$this->state
    ->get('comment.maintain_entity_statistics')) {
    return;
  }
  $query = $this->database
    ->select('comment_field_data', 'c');
  $query->addExpression('COUNT([cid])');
  $count = $query->condition('c.entity_id', $comment->getCommentedEntityId())
    ->condition('c.entity_type', $comment->getCommentedEntityTypeId())
    ->condition('c.field_name', $comment->getFieldName())
    ->condition('c.status', CommentInterface::PUBLISHED)
    ->condition('default_langcode', 1)
    ->execute()
    ->fetchField();
  if ($count > 0) {
    // Comments exist.
    $last_reply = $this->database
      ->select('comment_field_data', 'c')
      ->fields('c', [
      'cid',
      'name',
      'changed',
      'uid',
    ])
      ->condition('c.entity_id', $comment->getCommentedEntityId())
      ->condition('c.entity_type', $comment->getCommentedEntityTypeId())
      ->condition('c.field_name', $comment->getFieldName())
      ->condition('c.status', CommentInterface::PUBLISHED)
      ->condition('default_langcode', 1)
      ->orderBy('c.created', 'DESC')
      ->range(0, 1)
      ->execute()
      ->fetchObject();
    // Use merge here because entity could be created before comment field.
    $this->database
      ->merge('comment_entity_statistics')
      ->fields([
      'cid' => $last_reply->cid,
      'comment_count' => $count,
      'last_comment_timestamp' => $last_reply->changed,
      'last_comment_name' => $last_reply->uid ? '' : $last_reply->name,
      'last_comment_uid' => $last_reply->uid,
    ])
      ->keys([
      'entity_id' => $comment->getCommentedEntityId(),
      'entity_type' => $comment->getCommentedEntityTypeId(),
      'field_name' => $comment->getFieldName(),
    ])
      ->execute();
  }
  else {
    // Comments do not exist.
    $entity = $comment->getCommentedEntity();
    // Get the user ID from the entity if it's set, or default to the
    // currently logged in user.
    if ($entity instanceof EntityOwnerInterface) {
      $last_comment_uid = $entity->getOwnerId();
    }
    if (!isset($last_comment_uid)) {
      // Default to current user when entity does not implement
      // EntityOwnerInterface or author is not set.
      $last_comment_uid = $this->currentUser
        ->id();
    }
    $this->database
      ->update('comment_entity_statistics')
      ->fields([
      'cid' => 0,
      'comment_count' => 0,
      // Use the changed date of the entity if it's set, or default to
      // request time.
'last_comment_timestamp' => $entity instanceof EntityChangedInterface ? $entity->getChangedTimeAcrossTranslations() : $this->time
        ->getRequestTime(),
      'last_comment_name' => '',
      'last_comment_uid' => $last_comment_uid,
    ])
      ->condition('entity_id', $comment->getCommentedEntityId())
      ->condition('entity_type', $comment->getCommentedEntityTypeId())
      ->condition('field_name', $comment->getFieldName())
      ->execute();
  }
  // Reset the cache of the commented entity so that when the entity is loaded
  // the next time, the statistics will be loaded again.
  $this->entityTypeManager
    ->getStorage($comment->getCommentedEntityTypeId())
    ->resetCache([
    $comment->getCommentedEntityId(),
  ]);
}