hazza/Phraseanet
1
0
Fork 0
mirror of https://github.com/alchemy-fr/Phraseanet.git synced 2025-10-18 23:43:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improve query fields path by boosting some signals

Browse Source 
Also remove paths with very low score
This commit is contained in:
Damien Alexandre
2014-11-07 12:07:04 +01:00
parent b303de15d7
commit a69ba34393
1 changed files with 20 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
lib/Alchemy/Phrasea/SearchEngine/Elastic/ElasticSearchEngine.php
View File

@@ -270,7 +270,6 @@ class ElasticSearchEngine implements SearchEngineInterface
public function query($string, $offset, $perPage, SearchEngineOptions $options = null) public function query($string, $offset, $perPage, SearchEngineOptions $options = null)
{ {
$options = $options ?: new SearchEngineOptions(); $options = $options ?: new SearchEngineOptions();
$parser = new QueryParser(); $parser = new QueryParser();
$ast = $parser->parse($string); $ast = $parser->parse($string);
@@ -281,13 +280,18 @@ class ElasticSearchEngine implements SearchEngineInterface
// Only search in thesaurus for full text search // Only search in thesaurus for full text search
if ($ast->isFullTextOnly()) { if ($ast->isFullTextOnly()) {
$termFiels = $this->expendToAnalyzedFieldsNames('value'); $termFields = $this->expendToAnalyzedFieldsNames('value', null, $this->app['locale']);
$termsQuery = $ast->getQuery($termFiels); $termsQuery = $ast->getQuery($termFields);
$params = $this->createTermQueryParams($termsQuery, $options); $params = $this->createTermQueryParams($termsQuery, $options);
$terms = $this->doExecute('search', $params); $terms = $this->doExecute('search', $params);
foreach ($terms['hits']['hits'] as $term) { foreach ($terms['hits']['hits'] as $term) {
// Skip paths with very low score
if ($term['_score'] < 1) {
continue;
}
$pathsToFilter[$term['_source']['path']] = $term['_score']; $pathsToFilter[$term['_source']['path']] = $term['_score'];
foreach ($term['_source']['fields'] as $field) { foreach ($term['_source']['fields'] as $field) {
@@ -304,7 +308,7 @@ class ElasticSearchEngine implements SearchEngineInterface
$searchFieldNames = array_keys($collectFields); $searchFieldNames = array_keys($collectFields);
} }
$recordFields = $this->expendToAnalyzedFieldsNames($searchFieldNames); $recordFields = $this->expendToAnalyzedFieldsNames($searchFieldNames, null, $this->app['locale']);
$recordQuery = [ $recordQuery = [
'bool' => [ 'bool' => [
@@ -570,13 +574,12 @@ class ElasticSearchEngine implements SearchEngineInterface
} }
/** /**
* @todo Add a booster on the lang the use is using?
*
* @param array|string $fields * @param array|string $fields
* @param array|null $locales * @param array|null $locales
* @param null $currentLocale
* @return array * @return array
*/ */
public function expendToAnalyzedFieldsNames($fields, $locales = null) public function expendToAnalyzedFieldsNames($fields, $locales = null, $currentLocale = null)
{ {
$fieldsExpended = []; $fieldsExpended = [];
@@ -586,9 +589,15 @@ class ElasticSearchEngine implements SearchEngineInterface
foreach ((array) $fields as $field) { foreach ((array) $fields as $field) {
foreach ($locales as $locale) { foreach ($locales as $locale) {
$fieldsExpended[] = sprintf('%s.%s', $field, $locale); $boost = "";
if ($locale === $currentLocale) {
$boost = "^5";
} }
$fieldsExpended[] = sprintf('%s.%s', $field, 'light');
$fieldsExpended[] = sprintf('%s.%s%s', $field, $locale, $boost);
}
$fieldsExpended[] = sprintf('%s.%s', $field, 'light^10');
} }
return $fieldsExpended; return $fieldsExpended;