public function AggregatedFields::addFieldValues in Search API 8

Adds the values of properties defined by this processor to the item.

Parameters

\Drupal\search_api\Item\ItemInterface $item: The item whose field values should be added.

Overrides ProcessorPluginBase::addFieldValues

File

src/Plugin/search_api/processor/AggregatedFields.php, line 54

Class

AggregatedFields

Adds customized aggregations of existing fields to the index.

Namespace

Drupal\search_api\Plugin\search_api\processor

Code

public function addFieldValues(ItemInterface $item) {
  $fields = $this->index
    ->getFields();
  $aggregated_fields = $this
    ->getFieldsHelper()
    ->filterForPropertyPath($fields, NULL, 'aggregated_field');
  $required_properties_by_datasource = [
    NULL => [],
    $item
      ->getDatasourceId() => [],
  ];
  foreach ($aggregated_fields as $field) {
    foreach ($field
      ->getConfiguration()['fields'] as $combined_id) {
      list($datasource_id, $property_path) = Utility::splitCombinedId($combined_id);
      $required_properties_by_datasource[$datasource_id][$property_path] = $combined_id;
    }
  }
  $property_values = $this
    ->getFieldsHelper()
    ->extractItemValues([
    $item,
  ], $required_properties_by_datasource)[0];
  $aggregated_fields = $this
    ->getFieldsHelper()
    ->filterForPropertyPath($item
    ->getFields(), NULL, 'aggregated_field');
  foreach ($aggregated_fields as $aggregated_field) {
    $values = [];
    $configuration = $aggregated_field
      ->getConfiguration();
    foreach ($configuration['fields'] as $combined_id) {
      if (!empty($property_values[$combined_id])) {
        $values = array_merge($values, $property_values[$combined_id]);
      }
    }
    switch ($configuration['type']) {
      case 'concat':
        $values = [
          implode("\n\n", $values),
        ];
        break;
      case 'sum':
        $values = [
          array_sum($values),
        ];
        break;
      case 'count':
        $values = [
          count($values),
        ];
        break;
      case 'max':
        if ($values) {
          $values = [
            max($values),
          ];
        }
        break;
      case 'min':
        if ($values) {
          $values = [
            min($values),
          ];
        }
        break;
      case 'first':
        if ($values) {
          $values = [
            reset($values),
          ];
        }
        break;
      case 'last':
        if ($values) {
          $values = [
            end($values),
          ];
        }
        break;
      case 'first_char':
        $first_value = reset($values);
        $values = [];
        if ($first_value) {
          $values[] = mb_strtoupper(mb_substr($first_value, 0, 1));
        }
        break;
    }

    // Do not use setValues(), since that doesn't preprocess the values
    // according to their data type.
    foreach ($values as $value) {
      $aggregated_field
        ->addValue($value);
    }
  }
}