View source
<?php
namespace Drupal\activity\Plugin\views\query;
use Drupal\activity\QueryActivity;
use Drupal\Core\Cache\Cache;
use Drupal\Core\Database\Query\Select;
use Drupal\views\Plugin\views\query\QueryPluginBase;
use Drupal\views\ResultRow;
use Drupal\views\ViewExecutable;
use Symfony\Component\DependencyInjection\ContainerInterface;
class ActivityPlugin extends QueryPluginBase {
protected $conditions = [];
protected $fields = [];
protected $allItems = [];
protected $orderBy = [];
protected $where = [];
protected $activities;
protected $activityQuery;
public function __construct(array $configuration, $plugin_id, array $plugin_definition, QueryActivity $activityQuery) {
parent::__construct($configuration, $plugin_id, $plugin_definition);
$this->activityQuery = $activityQuery;
$this->activities = $this->activityQuery
->getActivities();
}
public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {
return new static($configuration, $plugin_id, $plugin_definition, $container
->get('query_activity'));
}
protected function defineOptions() {
$options = parent::defineOptions();
$options['accept_lang'] = [
'default' => NULL,
];
return $options;
}
public function addWhere($group, $field, $value = NULL, $operator = NULL) {
if (empty($group)) {
$group = 0;
}
if (!isset($this->where[$group])) {
$this
->setWhereGroup('AND', $group);
}
if ($this->activities instanceof Select) {
$this->activities
->condition($field, $value, $operator);
}
}
public function addWhereExpression($group, $snippet, $args = []) {
if (empty($group)) {
$group = 0;
}
if (!isset($this->where[$group])) {
$this
->setWhereGroup('AND', $group);
}
$this->where[$group]['conditions'][] = [
'field' => $snippet,
'value' => $args,
'operator' => 'formula',
];
if ($this->activities instanceof Select) {
$this->activities
->where($snippet, []);
}
}
public function ensureTable($table, $relationship = NULL) {
return $table;
}
public function addField($table, $field, $alias = '', $params = []) {
$this->fields[$field] = $field;
return $field;
}
public function addOrderBy($table, $field, $order = 'ASC', $alias = '', $params = []) {
if ($table && $table != 'rand') {
$this
->ensureTable($table);
}
if (!$alias && $table) {
$as = $table . '_' . $field;
}
else {
$as = $alias;
}
if ($field) {
$as = $this
->addField($table, $field, $as, $params);
}
if ($this->activities instanceof Select) {
$this->activities
->orderBy($as, strtoupper($order));
}
}
public function setAllItems(array $allItems) {
$this->allItems = $allItems;
}
public function build(ViewExecutable $view) {
$this->view = $view;
$view
->initPager();
$view->pager
->query();
Cache::invalidateTags([
'config:views.view.' . $view
->id(),
]);
$view->build_info['query'] = $this->activities;
$view->build_info['count_query'] = $this->activityQuery
->countMessages();
}
public function execute(ViewExecutable $view) {
parent::execute($view);
$count_query = $view->build_info['count_query'];
$count_query
->preExecute();
$count_query = $count_query
->countQuery();
try {
if ($view->pager
->useCountQuery() || !empty($view->get_total_rows)) {
$view->pager
->executeCountQuery($count_query);
}
$view->pager
->preExecute($query);
if ($this->activities instanceof Select) {
if (!empty($this->limit) || !empty($this->offset)) {
$limit = intval(!empty($this->limit) ? $this->limit : 999999);
$offset = intval(!empty($this->offset) ? $this->offset : 0);
$this->activities
->range($offset, $limit);
}
$result = $this->activities
->execute();
$result
->setFetchMode(\PDO::FETCH_CLASS, 'Drupal\\views\\ResultRow');
$view->result = iterator_to_array($result);
array_walk($view->result, function (ResultRow $row, $index) {
$row->index = $index;
});
$view->pager
->postExecute($view->result);
$view->pager
->updatePageInfo();
$view->total_rows = $view->pager
->getTotalItems();
$this
->loadEntities($view->result);
}
} catch (DatabaseExceptionWrapper $e) {
$view->result = [];
if (!empty($view->live_preview)) {
drupal_set_message($e
->getMessage(), 'activity error view.');
}
else {
throw new DatabaseExceptionWrapper("Exception in {$view->storage->label()}[{$view->storage->id()}]: {$e->getMessage()}");
}
}
}
public function match($element, $condition) {
$value = $element[$condition['field']];
switch ($condition['operator']) {
case '=':
return $value == $condition['value'];
case 'IN':
return in_array($value, $condition['value']);
}
return FALSE;
}
public function calculateDependencies() {
return parent::calculateDependencies() + [
'content' => [
'ActivityPlugin',
],
];
}
}