AbstractServiceCollection.php 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\Framework\Api;
  7. use Magento\Framework\Data\Collection\EntityFactoryInterface;
  8. use Magento\Framework\Exception\LocalizedException;
  9. /**
  10. * Base for service collections
  11. */
  12. abstract class AbstractServiceCollection extends \Magento\Framework\Data\Collection
  13. {
  14. /**
  15. * Filters on specific fields
  16. *
  17. * Each filter has the following structure
  18. * <pre>
  19. * [
  20. * 'field' => $field,
  21. * 'condition' => $condition,
  22. * ]
  23. * </pre>
  24. * @see addFieldToFilter() for more information on conditions
  25. *
  26. * @var array
  27. */
  28. protected $fieldFilters = [];
  29. /**
  30. * @var FilterBuilder
  31. */
  32. protected $filterBuilder;
  33. /**
  34. * @var SearchCriteriaBuilder
  35. */
  36. protected $searchCriteriaBuilder;
  37. /**
  38. * @var \Magento\Framework\Api\SortOrderBuilder
  39. */
  40. protected $sortOrderBuilder;
  41. /**
  42. * @param EntityFactoryInterface $entityFactory
  43. * @param FilterBuilder $filterBuilder
  44. * @param SearchCriteriaBuilder $searchCriteriaBuilder
  45. * @param \Magento\Framework\Api\SortOrderBuilder $sortOrderBuilder
  46. */
  47. public function __construct(
  48. EntityFactoryInterface $entityFactory,
  49. FilterBuilder $filterBuilder,
  50. SearchCriteriaBuilder $searchCriteriaBuilder,
  51. SortOrderBuilder $sortOrderBuilder
  52. ) {
  53. parent::__construct($entityFactory);
  54. $this->filterBuilder = $filterBuilder;
  55. $this->searchCriteriaBuilder = $searchCriteriaBuilder;
  56. $this->sortOrderBuilder = $sortOrderBuilder;
  57. }
  58. /**
  59. * Add field filter to collection
  60. *
  61. * If $condition integer or string - exact value will be filtered ('eq' condition)
  62. *
  63. * If $condition is array - one of the following structures is expected:
  64. * <pre>
  65. * - ["from" => $fromValue, "to" => $toValue]
  66. * - ["eq" => $equalValue]
  67. * - ["neq" => $notEqualValue]
  68. * - ["like" => $likeValue]
  69. * - ["in" => [$inValues]]
  70. * - ["nin" => [$notInValues]]
  71. * - ["notnull" => $valueIsNotNull]
  72. * - ["null" => $valueIsNull]
  73. * - ["moreq" => $moreOrEqualValue]
  74. * - ["gt" => $greaterValue]
  75. * - ["lt" => $lessValue]
  76. * - ["gteq" => $greaterOrEqualValue]
  77. * - ["lteq" => $lessOrEqualValue]
  78. * - ["finset" => $valueInSet]
  79. * - ["regexp" => $regularExpression]
  80. * - ["seq" => $stringValue]
  81. * - ["sneq" => $stringValue]
  82. * </pre>
  83. *
  84. * If non matched - sequential parallel arrays are expected and OR conditions
  85. * will be built using above mentioned structure.
  86. *
  87. * Example:
  88. * <pre>
  89. * $field = ['age', 'name'];
  90. * $condition = [42, ['like' => 'Mage']];
  91. * or
  92. * ['rate', 'tax_postcode']
  93. * [['from'=>"3",'to'=>'8.25'], ['like' =>'%91000%']];
  94. * </pre>
  95. * The above would find where age equal to 42 OR name like %Mage%.
  96. *
  97. * @param string|array $field
  98. * @param string|int|array $condition
  99. * @throws LocalizedException if some error in the input could be detected.
  100. * @return $this
  101. */
  102. public function addFieldToFilter($field, $condition)
  103. {
  104. if (is_array($field) && is_array($condition) && count($field) != count($condition)) {
  105. throw new LocalizedException(
  106. new \Magento\Framework\Phrase(
  107. 'The field array failed to pass. The array must have a matching condition array.'
  108. )
  109. );
  110. } elseif (is_array($field) && !count($field) > 0) {
  111. throw new LocalizedException(
  112. new \Magento\Framework\Phrase(
  113. 'The array of fields failed to pass. The array must include at one field.'
  114. )
  115. );
  116. }
  117. $this->processFilters($field, $condition);
  118. return $this;
  119. }
  120. /**
  121. * Pre-process filters to create multiple groups in case of multiple conditions eg: from & to
  122. * @param string|array $field
  123. * @param string|int|array $condition
  124. * @return $this
  125. */
  126. private function processFilters($field, $condition)
  127. {
  128. //test if we have multiple conditions per field
  129. $requiresMultipleFilterGroups = false;
  130. if (is_array($field) && is_array($condition)) {
  131. foreach ($condition as $cond) {
  132. if (is_array($cond) && count($cond) > 1) {
  133. $requiresMultipleFilterGroups = true;
  134. break;
  135. }
  136. }
  137. } elseif (is_array($condition)) {
  138. $requiresMultipleFilterGroups = true;
  139. }
  140. if ($requiresMultipleFilterGroups) {
  141. $this->addFilterGroupsForMultipleConditions($field, $condition);
  142. } else {
  143. $this->addFilterGroupsForSingleConditions($field, $condition);
  144. }
  145. return $this;
  146. }
  147. /**
  148. * Return a single filter group in case of single conditions
  149. * @param string|array $field
  150. * @param string|int|array $condition
  151. * @return $this
  152. */
  153. private function addFilterGroupsForSingleConditions($field, $condition)
  154. {
  155. $this->fieldFilters[] = ['field' => $field, 'condition' => $condition];
  156. return $this;
  157. }
  158. /**
  159. * Return multiple filters groups in case of multiple conditions eg: from & to
  160. * @param string|array $field
  161. * @param array $condition
  162. * @return $this
  163. */
  164. private function addFilterGroupsForMultipleConditions($field, $condition)
  165. {
  166. if (!is_array($field) && is_array($condition)) {
  167. foreach ($condition as $key => $value) {
  168. $this->fieldFilters[] = ['field' => $field, 'condition' => [$key => $value]];
  169. }
  170. } else {
  171. $cnt = 0;
  172. foreach ($condition as $cond) {
  173. if (is_array($cond)) {
  174. //we Do want multiple groups in this case
  175. foreach ($cond as $condKey => $condValue) {
  176. $this->fieldFilters[] = [
  177. 'field' => array_slice($field, $cnt, 1, true),
  178. 'condition' => [$condKey => $condValue]
  179. ];
  180. }
  181. } else {
  182. $this->fieldFilters[] = ['field' => array_slice($field, $cnt, 1, true), 'condition' => $cond];
  183. }
  184. $cnt++;
  185. }
  186. }
  187. return $this;
  188. }
  189. /**
  190. * Creates a search criteria DTO based on the array of field filters.
  191. *
  192. * @return SearchCriteria
  193. */
  194. protected function getSearchCriteria()
  195. {
  196. foreach ($this->fieldFilters as $filter) {
  197. // array of fields, put filters in array to use 'or' group
  198. /** @var Filter[] $filterGroup */
  199. $filterGroup = [];
  200. if (!is_array($filter['field'])) {
  201. // just one field
  202. $filterGroup = [$this->createFilterData($filter['field'], $filter['condition'])];
  203. } else {
  204. foreach ($filter['field'] as $index => $field) {
  205. $filterGroup[] = $this->createFilterData($field, $filter['condition'][$index]);
  206. }
  207. }
  208. $this->searchCriteriaBuilder->addFilters($filterGroup);
  209. }
  210. foreach ($this->_orders as $field => $direction) {
  211. /** @var SortOrder $sortOrder */
  212. /** @var string $direction */
  213. $direction = ($direction == 'ASC') ? SortOrder::SORT_ASC : SortOrder::SORT_DESC;
  214. $sortOrder = $this->sortOrderBuilder->setField($field)->setDirection($direction)->create();
  215. $this->searchCriteriaBuilder->addSortOrder($sortOrder);
  216. }
  217. $this->searchCriteriaBuilder->setCurrentPage($this->_curPage);
  218. $this->searchCriteriaBuilder->setPageSize($this->_pageSize);
  219. return $this->searchCriteriaBuilder->create();
  220. }
  221. /**
  222. * Creates a filter DTO for given field/condition
  223. *
  224. * @param string $field Field for new filter
  225. * @param string|array $condition Condition for new filter.
  226. * @return Filter
  227. */
  228. protected function createFilterData($field, $condition)
  229. {
  230. $this->filterBuilder->setField($field);
  231. if (is_array($condition)) {
  232. $this->filterBuilder->setValue(reset($condition));
  233. $this->filterBuilder->setConditionType(key($condition));
  234. } else {
  235. // not an array, just use eq as condition type and given value
  236. $this->filterBuilder->setConditionType('eq');
  237. $this->filterBuilder->setValue($condition);
  238. }
  239. return $this->filterBuilder->create();
  240. }
  241. }