Query.php in CiviCRM Entity 8.3

Namespace

Drupal\civicrm_entity\Entity\Query\CiviCRM

File

src/Entity/Query/CiviCRM/Query.php

<?php

namespace Drupal\civicrm_entity\Entity\Query\CiviCRM;

use Drupal\civicrm_entity\CiviCrmApi;
use Drupal\Core\Entity\EntityTypeInterface;
use Drupal\Core\Entity\Query\QueryBase;
use Drupal\Core\Entity\Query\QueryInterface;

/**
 * The CiviCRM entity query class.
 */
class Query extends QueryBase implements QueryInterface {
  protected $civicrmApi;

  /**
   * {@inheritdoc}
   */
  public function __construct(EntityTypeInterface $entity_type, $conjunction, array $namespaces, CiviCrmApi $civicrm_api) {
    parent::__construct($entity_type, $conjunction, $namespaces);
    $this->civicrmApi = $civicrm_api;
  }

  /**
   * {@inheritdoc}
   */
  public function execute() {
    $params = [];
    foreach ($this->condition
      ->conditions() as $condition) {

      // If there's anything requiring a custom field, set condition which cannot
      // be completed.
      // @todo Introduced when supporting field config. Find something better.
      // @see \Drupal\field_ui\Form\FieldStorageConfigEditForm::validateCardinality()
      if (substr($condition['field'], 0, 6) === 'field_') {
        $params['id'] = '-1';
        break;
      }
      $operator = $condition['operator'] ?: '=';
      if ($operator == 'CONTAINS') {
        $params[$condition['field']] = [
          'LIKE' => '%' . $condition['value'] . '%',
        ];
      }
      elseif ($operator != '=') {
        $params[$condition['field']] = [
          $operator => $condition['value'],
        ];
      }
      else {
        $params[$condition['field']] = $condition['value'];
      }
    }
    $this
      ->initializePager();
    if ($this->range) {
      $params['options'] = [
        'limit' => $this->range['length'],
        'offset' => $this->range['start'],
      ];
    }
    if ($this->count) {
      return $this->civicrmApi
        ->getCount($this->entityType
        ->get('civicrm_entity'), $params);
    }
    else {
      $result = $this->civicrmApi
        ->get($this->entityType
        ->get('civicrm_entity'), $params);
      return array_keys($result);
    }
  }

}

Classes

Name	Description
Query	The CiviCRM entity query class.