@@ -126,12 +126,12 @@ discard block |
||
126 | 126 | $queryTextExists = ($this->queryText != ''); |
127 | 127 | $isMultiMatch = ($this->fields != null); |
128 | 128 | |
129 | - if ($this->selectedFilters == null) { |
|
129 | + if($this->selectedFilters == null) { |
|
130 | 130 | $this->selectedFilters = array(); |
131 | 131 | } |
132 | 132 | |
133 | 133 | $this->manipulatorInstance = null; |
134 | - if ($this->manipulator) { |
|
134 | + if($this->manipulator) { |
|
135 | 135 | $this->manipulatorInstance = \Injector::inst()->create($this->manipulator); |
136 | 136 | $this->manipulatorInstance->queryGenerator = $this; |
137 | 137 | $this->manipulatorInstance->originalQueryString = $this->queryText; |
@@ -140,7 +140,7 @@ discard block |
||
140 | 140 | //This is a query_string object |
141 | 141 | $textQuery = null; |
142 | 142 | |
143 | - if (!$isMultiMatch) { |
|
143 | + if(!$isMultiMatch) { |
|
144 | 144 | $textQuery = $this->simpleTextQuery(); |
145 | 145 | } else { |
146 | 146 | $textQuery = $this->multiMatchQuery(); |
@@ -159,7 +159,7 @@ discard block |
||
159 | 159 | $query->setLimit($this->pageLength); |
160 | 160 | $query->setFrom($this->start); |
161 | 161 | |
162 | - if ($this->manipulatorInstance && !$queryTextExists) { |
|
162 | + if($this->manipulatorInstance && !$queryTextExists) { |
|
163 | 163 | $sort = $this->manipulatorInstance->getDefaultSort(); |
164 | 164 | $query->setSort($sort); |
165 | 165 | } |
@@ -190,7 +190,7 @@ discard block |
||
190 | 190 | 'size' => 10, |
191 | 191 | 'query' => array( |
192 | 192 | 'match' => array( |
193 | - $field.'.autocomplete' => array( |
|
193 | + $field . '.autocomplete' => array( |
|
194 | 194 | 'query' => $this->queryText, |
195 | 195 | 'operator' => 'and' |
196 | 196 | ) |
@@ -199,7 +199,7 @@ discard block |
||
199 | 199 | ); |
200 | 200 | |
201 | 201 | // The query clause can only have one entry, so a bit of mangling |
202 | - if (!empty($this->selectedFilters)) { |
|
202 | + if(!empty($this->selectedFilters)) { |
|
203 | 203 | $filtered = array(); |
204 | 204 | $filtered['query'] = $data['query']; |
205 | 205 | unset($data['query']); |
@@ -228,17 +228,17 @@ discard block |
||
228 | 228 | * @param Elastica\Query\QueryString $textQuery A query_string representing the current query |
229 | 229 | */ |
230 | 230 | private function addFilters($textQuery) { |
231 | - if ($this->manipulator) { |
|
231 | + if($this->manipulator) { |
|
232 | 232 | $this->manipulatorInstance->updateFilters($this->selectedFilters); |
233 | 233 | } |
234 | 234 | |
235 | 235 | $elFilters = array(); |
236 | 236 | $rangeFilterKeys = RangedAggregation::getTitles(); |
237 | 237 | |
238 | - foreach ($this->selectedFilters as $key => $value) { |
|
239 | - if (!in_array($key, $rangeFilterKeys)) { |
|
238 | + foreach($this->selectedFilters as $key => $value) { |
|
239 | + if(!in_array($key, $rangeFilterKeys)) { |
|
240 | 240 | $filter = new Term(); |
241 | - $filter->setTerm($key,$value); |
|
241 | + $filter->setTerm($key, $value); |
|
242 | 242 | $elFilters[] = $filter; |
243 | 243 | } else { |
244 | 244 | // get the selected range filter |
@@ -251,7 +251,7 @@ discard block |
||
251 | 251 | |
252 | 252 | // if not facets selected, pass through null |
253 | 253 | $queryFilter = null; |
254 | - switch (count($this->selectedFilters)) { |
|
254 | + switch(count($this->selectedFilters)) { |
|
255 | 255 | case 0: |
256 | 256 | // filter already null |
257 | 257 | break; |
@@ -261,18 +261,18 @@ discard block |
||
261 | 261 | default: |
262 | 262 | $queryFilter = new BoolAnd(); |
263 | 263 | |
264 | - foreach ($elFilters as $filter) { |
|
264 | + foreach($elFilters as $filter) { |
|
265 | 265 | $queryFilter->addFilter($filter); |
266 | 266 | } |
267 | 267 | break; |
268 | 268 | } |
269 | 269 | |
270 | 270 | // the Elastica query object |
271 | - if ($queryFilter == null) { |
|
271 | + if($queryFilter == null) { |
|
272 | 272 | $query = new Query($textQuery); |
273 | 273 | } else { |
274 | 274 | //MatchAll appears not be allowed inside a filtered query which is a bit of a pain. |
275 | - if ($textQuery instanceof MatchAll) { |
|
275 | + if($textQuery instanceof MatchAll) { |
|
276 | 276 | $textQuery = null; |
277 | 277 | } |
278 | 278 | |
@@ -289,7 +289,7 @@ discard block |
||
289 | 289 | |
290 | 290 | private function addAggregation(&$query) { |
291 | 291 | // aggregation (optional) |
292 | - if ($this->manipulatorInstance) { |
|
292 | + if($this->manipulatorInstance) { |
|
293 | 293 | $this->manipulatorInstance->augmentQuery($query); |
294 | 294 | } |
295 | 295 | } |
@@ -316,7 +316,7 @@ discard block |
||
316 | 316 | //Setting the lenient flag means that numeric fields can be searched for text values |
317 | 317 | $textQuery->setParam('lenient', true); |
318 | 318 | |
319 | - if ($this->showResultsForEmptyQuery && $this->queryText == '') { |
|
319 | + if($this->showResultsForEmptyQuery && $this->queryText == '') { |
|
320 | 320 | $textQuery = new MatchAll(); |
321 | 321 | } |
322 | 322 | |
@@ -329,8 +329,8 @@ discard block |
||
329 | 329 | $textQuery = new MultiMatch(); |
330 | 330 | |
331 | 331 | // Differing cases for showing and not showing empty string |
332 | - if ($this->queryText == '') { |
|
333 | - if (!$this->showResultsForEmptyQuery) { |
|
332 | + if($this->queryText == '') { |
|
333 | + if(!$this->showResultsForEmptyQuery) { |
|
334 | 334 | $textQuery->setQuery(''); |
335 | 335 | } else { |
336 | 336 | //WIP |
@@ -343,7 +343,7 @@ discard block |
||
343 | 343 | $textQuery->setQuery($this->queryText); |
344 | 344 | } |
345 | 345 | |
346 | - if ($textQuery instanceof MultiMatch) { |
|
346 | + if($textQuery instanceof MultiMatch) { |
|
347 | 347 | $elasticaFields = $this->convertWeightedFieldsForElastica($this->fields); |
348 | 348 | $textQuery->setFields($elasticaFields); |
349 | 349 | $textQuery->setType('most_fields'); |
@@ -366,20 +366,20 @@ discard block |
||
366 | 366 | */ |
367 | 367 | public function convertWeightedFieldsForElastica($fields) { |
368 | 368 | $result = array(); |
369 | - $nameToType = self::getSearchFieldsMappingForClasses($this->classes,$fields); |
|
369 | + $nameToType = self::getSearchFieldsMappingForClasses($this->classes, $fields); |
|
370 | 370 | |
371 | - if (sizeof($fields) != 0) { |
|
372 | - foreach ($fields as $fieldName => $weight) { |
|
371 | + if(sizeof($fields) != 0) { |
|
372 | + foreach($fields as $fieldName => $weight) { |
|
373 | 373 | $fieldCfg = "$fieldName"; |
374 | - if ($weight != 1) { |
|
375 | - $fieldCfg .= '^'.$weight; |
|
374 | + if($weight != 1) { |
|
375 | + $fieldCfg .= '^' . $weight; |
|
376 | 376 | } |
377 | 377 | array_push($result, $fieldCfg); |
378 | - if (isset($nameToType[$fieldName])) { |
|
379 | - if ($nameToType[$fieldName] == 'string') { |
|
378 | + if(isset($nameToType[$fieldName])) { |
|
379 | + if($nameToType[$fieldName] == 'string') { |
|
380 | 380 | $fieldCfg = "{$fieldName}.*"; |
381 | - if ($weight != 1) { |
|
382 | - $fieldCfg .= '^'.$weight; |
|
381 | + if($weight != 1) { |
|
382 | + $fieldCfg .= '^' . $weight; |
|
383 | 383 | } |
384 | 384 | array_push($result, $fieldCfg); |
385 | 385 | } |
@@ -405,29 +405,29 @@ discard block |
||
405 | 405 | // Get a array of relevant classes to search |
406 | 406 | $cache = QueryGenerator::getCache(); |
407 | 407 | $csvClasses = $classes; |
408 | - if (is_array($classes)) { |
|
409 | - $csvClasses = implode(',',$classes); |
|
408 | + if(is_array($classes)) { |
|
409 | + $csvClasses = implode(',', $classes); |
|
410 | 410 | } |
411 | 411 | |
412 | 412 | error_log("CSV CLASSES: $csvClasses"); |
413 | 413 | |
414 | - $key ='SEARCHABLE_FIELDS_'.str_replace(',', '_', $csvClasses); |
|
414 | + $key = 'SEARCHABLE_FIELDS_' . str_replace(',', '_', $csvClasses); |
|
415 | 415 | |
416 | - if ($fieldsAllowed) { |
|
416 | + if($fieldsAllowed) { |
|
417 | 417 | $fieldsAllowedCSV = self::convertToQuotedCSV(array_keys($fieldsAllowed)); |
418 | - $key .= '_' . str_replace(',', '_', str_replace("'", '_',$fieldsAllowedCSV)); |
|
418 | + $key .= '_' . str_replace(',', '_', str_replace("'", '_', $fieldsAllowedCSV)); |
|
419 | 419 | $key = str_replace('.', '_', $key); |
420 | 420 | $key = str_replace(' ', '_', $key); |
421 | 421 | } |
422 | 422 | |
423 | 423 | $result = $cache->load($key); |
424 | 424 | error_log("RESULT:$result for key $key \n"); |
425 | - if (!$result) { |
|
425 | + if(!$result) { |
|
426 | 426 | $relevantClasses = array(); |
427 | - if (empty($csvClasses)) { |
|
427 | + if(empty($csvClasses)) { |
|
428 | 428 | $sql = "SELECT DISTINCT Name from SearchableClass where InSiteTree = 1 order by Name"; |
429 | 429 | $records = \DB::query($sql); |
430 | - foreach ($records as $record) { |
|
430 | + foreach($records as $record) { |
|
431 | 431 | array_push($relevantClasses, $record['Name']); |
432 | 432 | } |
433 | 433 | } else { |
@@ -435,21 +435,21 @@ discard block |
||
435 | 435 | } |
436 | 436 | |
437 | 437 | $result = array(); |
438 | - if (sizeof($relevantClasses) > 0) { |
|
438 | + if(sizeof($relevantClasses) > 0) { |
|
439 | 439 | $relevantClassesCSV = self::convertToQuotedCSV($relevantClasses); |
440 | 440 | |
441 | 441 | //Perform a database query to get get a list of searchable fieldnames to Elasticsearch mapping |
442 | 442 | $sql = "SELECT sf.Name,sf.Type FROM SearchableClass sc INNER JOIN SearchableField sf ON " |
443 | 443 | . "sc.id = sf.SearchableClassID WHERE sc.name IN ($relevantClassesCSV)"; |
444 | - if ($fieldsAllowed) { |
|
444 | + if($fieldsAllowed) { |
|
445 | 445 | $fieldsAllowedCSV = self::convertToQuotedCSV(array_keys($fieldsAllowed)); |
446 | - if (strlen($fieldsAllowedCSV) > 0) { |
|
446 | + if(strlen($fieldsAllowedCSV) > 0) { |
|
447 | 447 | $sql .= " AND sf.Name IN ($fieldsAllowedCSV)"; |
448 | 448 | } |
449 | 449 | } |
450 | 450 | |
451 | 451 | $records = \DB::query($sql); |
452 | - foreach ($records as $record) { |
|
452 | + foreach($records as $record) { |
|
453 | 453 | $name = $record['Name']; |
454 | 454 | $type = $record['Type']; |
455 | 455 | |
@@ -463,11 +463,11 @@ discard block |
||
463 | 463 | $result[$name] = $type; |
464 | 464 | } |
465 | 465 | } |
466 | - $cache->save(json_encode($result),$key); |
|
467 | - } else { |
|
466 | + $cache->save(json_encode($result), $key); |
|
467 | + } else { |
|
468 | 468 | // true is necessary here to decode the array hash back to an array and not a struct |
469 | 469 | self::$cacheHitCtr++; |
470 | - $result = json_decode($result,true); |
|
470 | + $result = json_decode($result, true); |
|
471 | 471 | } |
472 | 472 | |
473 | 473 | return $result; |
@@ -488,21 +488,21 @@ discard block |
||
488 | 488 | */ |
489 | 489 | public static function convertToQuotedCSV($csvOrArray) { |
490 | 490 | $asArray = $csvOrArray; |
491 | - if (!is_array($csvOrArray)) { |
|
492 | - if ($csvOrArray == null) { |
|
491 | + if(!is_array($csvOrArray)) { |
|
492 | + if($csvOrArray == null) { |
|
493 | 493 | $asArray = array(); |
494 | 494 | } else { |
495 | 495 | $asArray = explode(',', $csvOrArray); |
496 | 496 | } |
497 | 497 | } |
498 | 498 | $quoted = array(); |
499 | - foreach ($asArray as $value) { |
|
500 | - if (strlen($value) > 0) { |
|
501 | - $item = "'".$value."'"; |
|
499 | + foreach($asArray as $value) { |
|
500 | + if(strlen($value) > 0) { |
|
501 | + $item = "'" . $value . "'"; |
|
502 | 502 | array_push($quoted, $item); |
503 | 503 | } |
504 | 504 | |
505 | 505 | } |
506 | - return implode(',', $quoted);; |
|
506 | + return implode(',', $quoted); ; |
|
507 | 507 | } |
508 | 508 | } |