2017-10-06 00:03:03 +03:00
< ? php
2017-10-08 18:00:59 +03:00
namespace Nominatim ;
2017-10-06 00:03:03 +03:00
2017-10-08 18:13:41 +03:00
require_once ( CONST_BasePath . '/lib/SpecialSearchOperator.php' );
2017-10-08 22:23:31 +03:00
require_once ( CONST_BasePath . '/lib/SearchContext.php' );
2017-10-19 00:54:47 +03:00
require_once ( CONST_BasePath . '/lib/Result.php' );
2017-10-08 18:13:41 +03:00
2017-10-06 00:03:03 +03:00
/**
* Description of a single interpretation of a search query .
*/
class SearchDescription
{
/// Ranking how well the description fits the query.
private $iSearchRank = 0 ;
/// Country code of country the result must belong to.
private $sCountryCode = '' ;
/// List of word ids making up the name of the object.
private $aName = array ();
/// List of word ids making up the address of the object.
private $aAddress = array ();
/// Subset of word ids of full words making up the address.
private $aFullNameAddress = array ();
/// List of word ids that appear in the name but should be ignored.
private $aNameNonSearch = array ();
/// List of word ids that appear in the address but should be ignored.
private $aAddressNonSearch = array ();
/// Kind of search for special searches, see Nominatim::Operator.
private $iOperator = Operator :: NONE ;
/// Class of special feature to search for.
private $sClass = '' ;
/// Type of special feature to search for.
private $sType = '' ;
/// Housenumber of the object.
private $sHouseNumber = '' ;
/// Postcode for the object.
private $sPostcode = '' ;
2017-10-08 22:23:31 +03:00
/// Global search constraints.
private $oContext ;
2017-10-06 00:03:03 +03:00
// Temporary values used while creating the search description.
2017-10-08 22:23:31 +03:00
/// Index of phrase currently processed.
2017-10-06 00:03:03 +03:00
private $iNamePhrase = - 1 ;
2017-10-06 01:14:48 +03:00
2017-10-08 18:00:59 +03:00
2017-10-10 01:15:56 +03:00
/**
* Create an empty search description .
*
* @ param object $oContext Global context to use . Will be inherited by
* all derived search objects .
*/
2017-10-08 22:23:31 +03:00
public function __construct ( $oContext )
{
$this -> oContext = $oContext ;
}
2017-10-10 01:15:56 +03:00
/**
* Get current search rank .
*
2018-02-18 16:11:35 +03:00
* The higher the search rank the lower the likelihood that the
2017-10-10 01:15:56 +03:00
* search is a correct interpretation of the search query .
*
* @ return integer Search rank .
*/
2017-10-07 13:01:56 +03:00
public function getRank ()
2017-10-06 01:14:48 +03:00
{
return $this -> iSearchRank ;
}
2017-10-10 01:15:56 +03:00
/**
* Make this search a POI search .
*
* In a POI search , objects are not ( only ) searched by their name
* but also by the primary OSM key / value pair ( class and type in Nominatim ) .
*
* @ param integer $iOperator Type of POI search
* @ param string $sClass Class ( or OSM tag key ) of POI .
* @ param string $sType Type ( or OSM tag value ) of POI .
*
* @ return void
*/
2017-10-07 13:01:56 +03:00
public function setPoiSearch ( $iOperator , $sClass , $sType )
2017-10-06 01:14:48 +03:00
{
$this -> iOperator = $iOperator ;
$this -> sClass = $sClass ;
$this -> sType = $sType ;
}
2017-10-10 01:15:56 +03:00
/**
* Check if this might be a full address search .
*
* @ return bool True if the search contains name , address and housenumber .
*/
2017-10-07 13:01:56 +03:00
public function looksLikeFullAddress ()
{
return sizeof ( $this -> aName )
&& ( sizeof ( $this -> aAddress || $this -> sCountryCode ))
&& preg_match ( '/[0-9]+/' , $this -> sHouseNumber );
}
2017-10-10 01:15:56 +03:00
/**
* Check if any operator is set .
*
* @ return bool True , if this is a special search operation .
*/
2017-10-07 13:01:56 +03:00
public function hasOperator ()
2017-10-06 01:14:48 +03:00
{
return $this -> iOperator != Operator :: NONE ;
}
2017-10-10 01:15:56 +03:00
/**
* Extract key / value pairs from a query .
*
* Key / value pairs are recognised if they are of the form [ < key >=< value > ] .
* If multiple terms of this kind are found then all terms are removed
* but only the first is used for search .
*
* @ param string $sQuery Original query string .
*
* @ return string The query string with the special search patterns removed .
*/
2017-10-07 13:01:56 +03:00
public function extractKeyValuePairs ( $sQuery )
2017-10-06 01:14:48 +03:00
{
// Search for terms of kind [<key>=<value>].
preg_match_all (
'/\\[([\\w_]*)=([\\w_]*)\\]/' ,
$sQuery ,
$aSpecialTermsRaw ,
PREG_SET_ORDER
);
foreach ( $aSpecialTermsRaw as $aTerm ) {
$sQuery = str_replace ( $aTerm [ 0 ], ' ' , $sQuery );
if ( ! $this -> hasOperator ()) {
$this -> setPoiSearch ( Operator :: TYPE , $aTerm [ 1 ], $aTerm [ 2 ]);
}
}
return $sQuery ;
}
2017-10-07 13:01:56 +03:00
2017-10-10 01:15:56 +03:00
/**
* Check if the combination of parameters is sensible .
*
* @ return bool True , if the search looks valid .
*/
2017-10-13 23:23:39 +03:00
public function isValidSearch ()
2017-10-08 13:57:22 +03:00
{
if ( ! sizeof ( $this -> aName )) {
if ( $this -> sHouseNumber ) {
return false ;
}
2017-10-13 23:23:39 +03:00
if ( ! $this -> sClass && ! $this -> sCountryCode ) {
return false ;
}
2017-10-08 13:57:22 +03:00
}
return true ;
}
/////////// Search building functions
2017-10-08 18:00:59 +03:00
2017-10-10 01:15:56 +03:00
/**
* Derive new searches by adding a full term to the existing search .
*
* @ param mixed [] $aSearchTerm Description of the token .
* @ param bool $bHasPartial True if there are also tokens of partial terms
* with the same name .
* @ param string $sPhraseType Type of phrase the token is contained in .
* @ param bool $bFirstToken True if the token is at the beginning of the
* query .
* @ param bool $bFirstPhrase True if the token is in the first phrase of
* the query .
* @ param bool $bLastToken True if the token is at the end of the query .
*
* @ return SearchDescription [] List of derived search descriptions .
*/
2017-10-24 23:42:29 +03:00
public function extendWithFullTerm ( $aSearchTerm , $bHasPartial , $sPhraseType , $bFirstToken , $bFirstPhrase , $bLastToken )
2017-10-08 13:57:22 +03:00
{
$aNewSearches = array ();
if (( $sPhraseType == '' || $sPhraseType == 'country' )
&& ! empty ( $aSearchTerm [ 'country_code' ])
&& $aSearchTerm [ 'country_code' ] != '0'
) {
if ( ! $this -> sCountryCode ) {
$oSearch = clone $this ;
$oSearch -> iSearchRank ++ ;
$oSearch -> sCountryCode = $aSearchTerm [ 'country_code' ];
// Country is almost always at the end of the string
// - increase score for finding it anywhere else (optimisation)
if ( ! $bLastToken ) {
$oSearch -> iSearchRank += 5 ;
}
$aNewSearches [] = $oSearch ;
}
} elseif (( $sPhraseType == '' || $sPhraseType == 'postalcode' )
&& $aSearchTerm [ 'class' ] == 'place' && $aSearchTerm [ 'type' ] == 'postcode'
) {
// We need to try the case where the postal code is the primary element
// (i.e. no way to tell if it is (postalcode, city) OR (city, postalcode)
// so try both.
2017-10-14 00:04:12 +03:00
if ( ! $this -> sPostcode
&& $aSearchTerm [ 'word' ]
2017-10-08 18:36:38 +03:00
&& pg_escape_string ( $aSearchTerm [ 'word' ]) == $aSearchTerm [ 'word' ]
) {
2017-10-08 13:57:22 +03:00
// If we have structured search or this is the first term,
// make the postcode the primary search element.
if ( $this -> iOperator == Operator :: NONE
&& ( $sPhraseType == 'postalcode' || $bFirstToken )
) {
$oSearch = clone $this ;
$oSearch -> iSearchRank ++ ;
$oSearch -> iOperator = Operator :: POSTCODE ;
$oSearch -> aAddress = array_merge ( $this -> aAddress , $this -> aName );
$oSearch -> aName =
array ( $aSearchTerm [ 'word_id' ] => $aSearchTerm [ 'word' ]);
$aNewSearches [] = $oSearch ;
}
// If we have a structured search or this is not the first term,
// add the postcode as an addendum.
if ( $this -> iOperator != Operator :: POSTCODE
&& ( $sPhraseType == 'postalcode' || sizeof ( $this -> aName ))
) {
$oSearch = clone $this ;
$oSearch -> iSearchRank ++ ;
$oSearch -> sPostcode = $aSearchTerm [ 'word' ];
$aNewSearches [] = $oSearch ;
}
}
} elseif (( $sPhraseType == '' || $sPhraseType == 'street' )
&& $aSearchTerm [ 'class' ] == 'place' && $aSearchTerm [ 'type' ] == 'house'
) {
if ( ! $this -> sHouseNumber && $this -> iOperator != Operator :: POSTCODE ) {
$oSearch = clone $this ;
$oSearch -> iSearchRank ++ ;
$oSearch -> sHouseNumber = trim ( $aSearchTerm [ 'word_token' ]);
// sanity check: if the housenumber is not mainly made
// up of numbers, add a penalty
2017-10-26 22:21:21 +03:00
if ( preg_match_all ( '/[^0-9]/' , $oSearch -> sHouseNumber , $aMatches ) > 2 ) {
2017-10-08 13:57:22 +03:00
$oSearch -> iSearchRank ++ ;
}
2017-10-08 18:36:38 +03:00
if ( ! isset ( $aSearchTerm [ 'word_id' ])) {
$oSearch -> iSearchRank ++ ;
}
2017-10-08 13:57:22 +03:00
// also must not appear in the middle of the address
2017-10-25 00:30:41 +03:00
if ( sizeof ( $this -> aAddress )
|| sizeof ( $this -> aAddressNonSearch )
|| $this -> sPostcode
) {
2017-10-08 13:57:22 +03:00
$oSearch -> iSearchRank ++ ;
}
$aNewSearches [] = $oSearch ;
}
2017-10-14 00:04:12 +03:00
} elseif ( $sPhraseType == '' && $aSearchTerm [ 'class' ]) {
if ( $this -> iOperator == Operator :: NONE ) {
2017-10-08 16:26:14 +03:00
$oSearch = clone $this ;
2017-10-08 13:57:22 +03:00
$oSearch -> iSearchRank ++ ;
$iOp = Operator :: NEAR ; // near == in for the moment
if ( $aSearchTerm [ 'operator' ] == '' ) {
2017-12-18 01:50:16 +03:00
if ( sizeof ( $this -> aName ) || $this -> oContext -> isBoundedSearch ()) {
2017-10-08 13:57:22 +03:00
$iOp = Operator :: NAME ;
}
$oSearch -> iSearchRank += 2 ;
}
$oSearch -> setPoiSearch ( $iOp , $aSearchTerm [ 'class' ], $aSearchTerm [ 'type' ]);
2017-10-08 17:42:04 +03:00
$aNewSearches [] = $oSearch ;
2017-10-08 13:57:22 +03:00
}
2017-10-13 23:23:39 +03:00
} elseif ( isset ( $aSearchTerm [ 'word_id' ])
&& $aSearchTerm [ 'word_id' ]
&& $sPhraseType != 'country'
) {
2017-10-08 13:57:22 +03:00
$iWordID = $aSearchTerm [ 'word_id' ];
if ( sizeof ( $this -> aName )) {
if (( $sPhraseType == '' || ! $bFirstPhrase )
2017-10-08 16:26:14 +03:00
&& $sPhraseType != 'country'
2017-10-08 13:57:22 +03:00
&& ! $bHasPartial
) {
$oSearch = clone $this ;
$oSearch -> iSearchRank ++ ;
$oSearch -> aAddress [ $iWordID ] = $iWordID ;
$aNewSearches [] = $oSearch ;
2017-10-08 18:00:59 +03:00
} else {
2017-10-08 13:57:22 +03:00
$this -> aFullNameAddress [ $iWordID ] = $iWordID ;
}
} else {
2018-03-02 00:35:34 +03:00
// in structured search only the first phrase can be the
// designated name
if ( $sPhraseType == '' || $bFirstPhrase ) {
$oSearch = clone $this ;
$oSearch -> iSearchRank ++ ;
$oSearch -> aName = array ( $iWordID => $iWordID );
$aNewSearches [] = $oSearch ;
}
2017-10-08 13:57:22 +03:00
}
}
return $aNewSearches ;
}
2017-10-10 01:15:56 +03:00
/**
* Derive new searches by adding a partial term to the existing search .
*
2017-10-14 00:11:09 +03:00
* @ param mixed [] $aSearchTerm Description of the token .
* @ param bool $bStructuredPhrases True if the search is structured .
* @ param integer $iPhrase Number of the phrase the token is in .
* @ param array [] $aFullTokens List of full term tokens with the
* same name .
2017-10-10 01:15:56 +03:00
*
* @ return SearchDescription [] List of derived search descriptions .
*/
2017-10-12 23:59:07 +03:00
public function extendWithPartialTerm ( $aSearchTerm , $bStructuredPhrases , $iPhrase , $aFullTokens )
2017-10-08 13:57:22 +03:00
{
// Only allow name terms.
if ( ! ( isset ( $aSearchTerm [ 'word_id' ]) && $aSearchTerm [ 'word_id' ])) {
return array ();
}
$aNewSearches = array ();
$iWordID = $aSearchTerm [ 'word_id' ];
if (( ! $bStructuredPhrases || $iPhrase > 0 )
&& sizeof ( $this -> aName )
&& strpos ( $aSearchTerm [ 'word_token' ], ' ' ) === false
) {
2017-10-12 23:59:07 +03:00
if ( $aSearchTerm [ 'search_name_count' ] + 1 < CONST_Max_Word_Frequency ) {
2017-10-08 16:26:14 +03:00
$oSearch = clone $this ;
2017-12-17 22:23:34 +03:00
$oSearch -> iSearchRank += 2 ;
2017-10-08 13:57:22 +03:00
$oSearch -> aAddress [ $iWordID ] = $iWordID ;
$aNewSearches [] = $oSearch ;
} else {
2017-10-08 16:26:14 +03:00
$oSearch = clone $this ;
2017-10-08 13:57:22 +03:00
$oSearch -> iSearchRank ++ ;
$oSearch -> aAddressNonSearch [ $iWordID ] = $iWordID ;
if ( preg_match ( '#^[0-9]+$#' , $aSearchTerm [ 'word_token' ])) {
$oSearch -> iSearchRank += 2 ;
}
2017-10-08 16:26:14 +03:00
if ( sizeof ( $aFullTokens )) {
2017-10-08 13:57:22 +03:00
$oSearch -> iSearchRank ++ ;
}
$aNewSearches [] = $oSearch ;
// revert to the token version?
foreach ( $aFullTokens as $aSearchTermToken ) {
if ( empty ( $aSearchTermToken [ 'country_code' ])
&& empty ( $aSearchTermToken [ 'lat' ])
&& empty ( $aSearchTermToken [ 'class' ])
) {
$oSearch = clone $this ;
$oSearch -> iSearchRank ++ ;
$oSearch -> aAddress [ $aSearchTermToken [ 'word_id' ]] = $aSearchTermToken [ 'word_id' ];
$aNewSearches [] = $oSearch ;
}
}
2017-10-08 18:00:59 +03:00
}
2017-10-08 13:57:22 +03:00
}
if (( ! $this -> sPostcode && ! $this -> aAddress && ! $this -> aAddressNonSearch )
&& ( ! sizeof ( $this -> aName ) || $this -> iNamePhrase == $iPhrase )
) {
$oSearch = clone $this ;
2017-12-17 18:00:44 +03:00
$oSearch -> iSearchRank += 2 ;
2017-10-08 13:57:22 +03:00
if ( ! sizeof ( $this -> aName )) {
2017-10-08 16:26:14 +03:00
$oSearch -> iSearchRank += 1 ;
2017-10-08 13:57:22 +03:00
}
2017-10-08 16:26:14 +03:00
if ( preg_match ( '#^[0-9]+$#' , $aSearchTerm [ 'word_token' ])) {
2017-10-08 13:57:22 +03:00
$oSearch -> iSearchRank += 2 ;
}
2017-10-12 23:59:07 +03:00
if ( $aSearchTerm [ 'search_name_count' ] + 1 < CONST_Max_Word_Frequency ) {
2017-10-08 13:57:22 +03:00
$oSearch -> aName [ $iWordID ] = $iWordID ;
} else {
2017-10-08 16:26:14 +03:00
$oSearch -> aNameNonSearch [ $iWordID ] = $iWordID ;
2017-10-08 13:57:22 +03:00
}
$oSearch -> iNamePhrase = $iPhrase ;
2017-10-08 16:26:14 +03:00
$aNewSearches [] = $oSearch ;
2017-10-08 13:57:22 +03:00
}
return $aNewSearches ;
}
/////////// Query functions
2017-10-10 00:12:13 +03:00
2017-10-10 01:15:56 +03:00
/**
* Query database for places that match this search .
*
* @ param object $oDB Database connection to use .
* @ param mixed [] $aWordFrequencyScores Number of times tokens appears
* overall in a planet database .
* @ param integer $iMinRank Minimum address rank to restrict
* search to .
* @ param integer $iMaxRank Maximum address rank to restrict
* search to .
* @ param integer $iLimit Maximum number of results .
*
* @ return mixed [] An array with two fields : IDs contains the list of
* matching place IDs and houseNumber the houseNumber
* if appicable or - 1 if not .
*/
2017-10-19 00:54:47 +03:00
public function query ( & $oDB , & $aWordFrequencyScores , $iMinRank , $iMaxRank , $iLimit )
2017-10-09 23:55:50 +03:00
{
2017-10-19 00:54:47 +03:00
$aResults = array ();
2017-10-09 23:55:50 +03:00
$iHousenumber = - 1 ;
if ( $this -> sCountryCode
&& ! sizeof ( $this -> aName )
&& ! $this -> iOperator
&& ! $this -> sClass
&& ! $this -> oContext -> hasNearPoint ()
) {
// Just looking for a country - look it up
if ( 4 >= $iMinRank && 4 <= $iMaxRank ) {
2017-10-19 00:54:47 +03:00
$aResults = $this -> queryCountry ( $oDB );
2017-10-09 23:55:50 +03:00
}
} elseif ( ! sizeof ( $this -> aName ) && ! sizeof ( $this -> aAddress )) {
// Neither name nor address? Then we must be
// looking for a POI in a geographic area.
if ( $this -> oContext -> isBoundedSearch ()) {
2017-10-19 00:54:47 +03:00
$aResults = $this -> queryNearbyPoi ( $oDB , $iLimit );
2017-10-09 23:55:50 +03:00
}
} elseif ( $this -> iOperator == Operator :: POSTCODE ) {
// looking for postcode
2017-10-19 00:54:47 +03:00
$aResults = $this -> queryPostcode ( $oDB , $iLimit );
2017-10-09 23:55:50 +03:00
} else {
// Ordinary search:
// First search for places according to name and address.
2017-10-19 00:54:47 +03:00
$aResults = $this -> queryNamedPlace (
2017-10-09 23:55:50 +03:00
$oDB ,
$aWordFrequencyScores ,
$iMinRank ,
$iMaxRank ,
$iLimit
);
//now search for housenumber, if housenumber provided
2017-10-19 00:54:47 +03:00
if ( $this -> sHouseNumber && sizeof ( $aResults )) {
$aNamedPlaceIDs = $aResults ;
$aResults = $this -> queryHouseNumber ( $oDB , $aNamedPlaceIDs , $iLimit );
if ( ! sizeof ( $aResults ) && $this -> looksLikeFullAddress ()) {
$aResults = $aNamedPlaceIDs ;
2017-10-09 23:55:50 +03:00
}
}
// finally get POIs if requested
2017-10-19 00:54:47 +03:00
if ( $this -> sClass && sizeof ( $aResults )) {
$aResults = $this -> queryPoiByOperator ( $oDB , $aResults , $iLimit );
2017-10-09 23:55:50 +03:00
}
}
if ( CONST_Debug ) {
2017-10-26 22:21:21 +03:00
echo '<br><b>Place IDs:</b> ' ;
2017-10-19 00:54:47 +03:00
var_dump ( array_keys ( $aResults ));
2017-10-09 23:55:50 +03:00
}
2017-10-19 00:54:47 +03:00
if ( sizeof ( $aResults ) && $this -> sPostcode ) {
$sPlaceIds = Result :: joinIdsByTable ( $aResults , Result :: TABLE_PLACEX );
if ( $sPlaceIds ) {
$sSQL = 'SELECT place_id FROM placex' ;
$sSQL .= ' WHERE place_id in (' . $sPlaceIds . ')' ;
$sSQL .= " AND postcode = ' " . $this -> sPostcode . " ' " ;
if ( CONST_Debug ) var_dump ( $sSQL );
$aFilteredPlaceIDs = chksql ( $oDB -> getCol ( $sSQL ));
if ( $aFilteredPlaceIDs ) {
$aNewResults = array ();
foreach ( $aFilteredPlaceIDs as $iPlaceId ) {
2017-10-25 21:16:35 +03:00
$aNewResults [ $iPlaceId ] = $aResults [ $iPlaceId ];
2017-10-19 00:54:47 +03:00
}
$aResults = $aNewResults ;
if ( CONST_Debug ) {
2017-10-26 22:21:21 +03:00
echo '<br><b>Place IDs after postcode filtering:</b> ' ;
2017-10-19 00:54:47 +03:00
var_dump ( array_keys ( $aResults ));
}
2017-10-09 23:55:50 +03:00
}
}
}
2017-10-19 00:54:47 +03:00
return $aResults ;
2017-10-09 23:55:50 +03:00
}
2017-10-08 18:00:59 +03:00
2017-10-09 23:55:50 +03:00
private function queryCountry ( & $oDB )
2017-10-07 13:01:56 +03:00
{
$sSQL = 'SELECT place_id FROM placex ' ;
$sSQL .= " WHERE country_code=' " . $this -> sCountryCode . " ' " ;
$sSQL .= ' AND rank_search = 4' ;
2017-10-08 23:44:01 +03:00
if ( $this -> oContext -> bViewboxBounded ) {
$sSQL .= ' AND ST_Intersects(' . $this -> oContext -> sqlViewboxSmall . ', geometry)' ;
2017-10-07 13:01:56 +03:00
}
2017-10-26 22:21:21 +03:00
$sSQL .= ' ORDER BY st_area(geometry) DESC LIMIT 1' ;
2017-10-07 13:01:56 +03:00
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
$aResults = array ();
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId );
}
return $aResults ;
2017-10-07 13:01:56 +03:00
}
2017-10-09 23:55:50 +03:00
private function queryNearbyPoi ( & $oDB , $iLimit )
2017-10-07 13:01:56 +03:00
{
if ( ! $this -> sClass ) {
return array ();
}
2017-10-19 00:54:47 +03:00
$aDBResults = array ();
2017-10-07 13:01:56 +03:00
$sPoiTable = $this -> poiTable ();
$sSQL = 'SELECT count(*) FROM pg_tables WHERE tablename = \'' . $sPoiTable . " ' " ;
if ( chksql ( $oDB -> getOne ( $sSQL ))) {
$sSQL = 'SELECT place_id FROM ' . $sPoiTable . ' ct' ;
2017-10-09 00:33:54 +03:00
if ( $this -> oContext -> sqlCountryList ) {
2017-10-07 13:01:56 +03:00
$sSQL .= ' JOIN placex USING (place_id)' ;
}
2017-10-08 22:23:31 +03:00
if ( $this -> oContext -> hasNearPoint ()) {
$sSQL .= ' WHERE ' . $this -> oContext -> withinSQL ( 'ct.centroid' );
2017-10-10 00:12:13 +03:00
} elseif ( $this -> oContext -> bViewboxBounded ) {
2017-10-08 23:44:01 +03:00
$sSQL .= ' WHERE ST_Contains(' . $this -> oContext -> sqlViewboxSmall . ', ct.centroid)' ;
2017-10-07 13:01:56 +03:00
}
2017-10-09 00:33:54 +03:00
if ( $this -> oContext -> sqlCountryList ) {
$sSQL .= ' AND country_code in ' . $this -> oContext -> sqlCountryList ;
2017-10-07 13:01:56 +03:00
}
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND place_id' );
2017-10-08 23:44:01 +03:00
if ( $this -> oContext -> sqlViewboxCentre ) {
$sSQL .= ' ORDER BY ST_Distance(' ;
$sSQL .= $this -> oContext -> sqlViewboxCentre . ', ct.centroid) ASC' ;
2017-10-08 22:23:31 +03:00
} elseif ( $this -> oContext -> hasNearPoint ()) {
$sSQL .= ' ORDER BY ' . $this -> oContext -> distanceSQL ( 'ct.centroid' ) . ' ASC' ;
2017-10-07 13:01:56 +03:00
}
$sSQL .= " limit $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
$aDBResults = chksql ( $oDB -> getCol ( $sSQL ));
2017-10-07 13:01:56 +03:00
}
2017-10-08 22:23:31 +03:00
if ( $this -> oContext -> hasNearPoint ()) {
2017-10-07 13:01:56 +03:00
$sSQL = 'SELECT place_id FROM placex WHERE ' ;
$sSQL .= 'class=\'' . $this -> sClass . " ' and type=' " . $this -> sType . " ' " ;
2017-10-08 22:23:31 +03:00
$sSQL .= ' AND ' . $this -> oContext -> withinSQL ( 'geometry' );
2017-10-07 13:01:56 +03:00
$sSQL .= ' AND linked_place_id is null' ;
2017-10-09 00:33:54 +03:00
if ( $this -> oContext -> sqlCountryList ) {
$sSQL .= ' AND country_code in ' . $this -> oContext -> sqlCountryList ;
2017-10-07 13:01:56 +03:00
}
2017-10-26 22:21:21 +03:00
$sSQL .= ' ORDER BY ' . $this -> oContext -> distanceSQL ( 'centroid' ) . ' ASC' ;
2017-10-07 13:01:56 +03:00
$sSQL .= " LIMIT $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
$aDBResults = chksql ( $oDB -> getCol ( $sSQL ));
2017-10-07 13:01:56 +03:00
}
2017-10-19 00:54:47 +03:00
$aResults = array ();
foreach ( $aDBResults as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId );
}
return $aResults ;
2017-10-07 13:01:56 +03:00
}
2017-10-09 23:55:50 +03:00
private function queryPostcode ( & $oDB , $iLimit )
2017-10-07 13:01:56 +03:00
{
2017-10-08 18:00:59 +03:00
$sSQL = 'SELECT p.place_id FROM location_postcode p ' ;
2017-10-07 13:01:56 +03:00
if ( sizeof ( $this -> aAddress )) {
$sSQL .= ', search_name s ' ;
$sSQL .= 'WHERE s.place_id = p.parent_place_id ' ;
$sSQL .= 'AND array_cat(s.nameaddress_vector, s.name_vector)' ;
2017-10-08 11:06:17 +03:00
$sSQL .= ' @> ' . getArraySQL ( $this -> aAddress ) . ' AND ' ;
2017-10-07 13:01:56 +03:00
} else {
$sSQL .= 'WHERE ' ;
}
2017-10-08 18:36:38 +03:00
$sSQL .= " p.postcode = ' " . reset ( $this -> aName ) . " ' " ;
2017-10-09 00:33:54 +03:00
$sSQL .= $this -> countryCodeSQL ( ' AND p.country_code' );
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND p.place_id' );
2017-10-07 13:01:56 +03:00
$sSQL .= " LIMIT $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
$aResults = array ();
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId , Result :: TABLE_POSTCODE );
}
return $aResults ;
2017-10-07 13:01:56 +03:00
}
2017-10-09 23:55:50 +03:00
private function queryNamedPlace ( & $oDB , $aWordFrequencyScores , $iMinAddressRank , $iMaxAddressRank , $iLimit )
2017-10-07 13:01:56 +03:00
{
$aTerms = array ();
$aOrder = array ();
if ( $this -> sHouseNumber && sizeof ( $this -> aAddress )) {
$sHouseNumberRegex = '\\\\m' . $this -> sHouseNumber . '\\\\M' ;
$aOrder [] = ' (' ;
$aOrder [ 0 ] .= 'EXISTS(' ;
$aOrder [ 0 ] .= ' SELECT place_id' ;
$aOrder [ 0 ] .= ' FROM placex' ;
$aOrder [ 0 ] .= ' WHERE parent_place_id = search_name.place_id' ;
$aOrder [ 0 ] .= " AND transliteration(housenumber) ~* E' " . $sHouseNumberRegex . " ' " ;
$aOrder [ 0 ] .= ' LIMIT 1' ;
$aOrder [ 0 ] .= ') ' ;
// also housenumbers from interpolation lines table are needed
if ( preg_match ( '/[0-9]+/' , $this -> sHouseNumber )) {
$iHouseNumber = intval ( $this -> sHouseNumber );
$aOrder [ 0 ] .= 'OR EXISTS(' ;
$aOrder [ 0 ] .= ' SELECT place_id ' ;
$aOrder [ 0 ] .= ' FROM location_property_osmline ' ;
$aOrder [ 0 ] .= ' WHERE parent_place_id = search_name.place_id' ;
$aOrder [ 0 ] .= ' AND startnumber is not NULL' ;
$aOrder [ 0 ] .= ' AND ' . $iHouseNumber . '>=startnumber ' ;
$aOrder [ 0 ] .= ' AND ' . $iHouseNumber . '<=endnumber ' ;
$aOrder [ 0 ] .= ' LIMIT 1' ;
$aOrder [ 0 ] .= ')' ;
}
$aOrder [ 0 ] .= ') DESC' ;
}
if ( sizeof ( $this -> aName )) {
2017-10-08 11:06:17 +03:00
$aTerms [] = 'name_vector @> ' . getArraySQL ( $this -> aName );
2017-10-07 13:01:56 +03:00
}
if ( sizeof ( $this -> aAddress )) {
// For infrequent name terms disable index usage for address
if ( CONST_Search_NameOnlySearchFrequencyThreshold
&& sizeof ( $this -> aName ) == 1
&& $aWordFrequencyScores [ $this -> aName [ reset ( $this -> aName )]]
< CONST_Search_NameOnlySearchFrequencyThreshold
) {
2017-10-08 11:06:17 +03:00
$aTerms [] = 'array_cat(nameaddress_vector,ARRAY[]::integer[]) @> ' . getArraySQL ( $this -> aAddress );
2017-10-07 13:01:56 +03:00
} else {
2017-10-08 11:06:17 +03:00
$aTerms [] = 'nameaddress_vector @> ' . getArraySQL ( $this -> aAddress );
2017-10-07 13:01:56 +03:00
}
}
2017-10-09 00:33:54 +03:00
$sCountryTerm = $this -> countryCodeSQL ( 'country_code' );
2017-10-07 13:01:56 +03:00
if ( $sCountryTerm ) {
$aTerms [] = $sCountryTerm ;
}
if ( $this -> sHouseNumber ) {
2017-10-26 22:21:21 +03:00
$aTerms [] = 'address_rank between 16 and 27' ;
2017-10-07 13:01:56 +03:00
} elseif ( ! $this -> sClass || $this -> iOperator == Operator :: NAME ) {
if ( $iMinAddressRank > 0 ) {
2017-10-26 22:21:21 +03:00
$aTerms [] = 'address_rank >= ' . $iMinAddressRank ;
2017-10-07 13:01:56 +03:00
}
if ( $iMaxAddressRank < 30 ) {
2017-10-26 22:21:21 +03:00
$aTerms [] = 'address_rank <= ' . $iMaxAddressRank ;
2017-10-07 13:01:56 +03:00
}
}
2017-10-08 22:23:31 +03:00
if ( $this -> oContext -> hasNearPoint ()) {
$aTerms [] = $this -> oContext -> withinSQL ( 'centroid' );
$aOrder [] = $this -> oContext -> distanceSQL ( 'centroid' );
2017-10-07 13:01:56 +03:00
} elseif ( $this -> sPostcode ) {
if ( ! sizeof ( $this -> aAddress )) {
$aTerms [] = " EXISTS(SELECT place_id FROM location_postcode p WHERE p.postcode = ' " . $this -> sPostcode . " ' AND ST_DWithin(search_name.centroid, p.geometry, 0.1)) " ;
} else {
$aOrder [] = " (SELECT min(ST_Distance(search_name.centroid, p.geometry)) FROM location_postcode p WHERE p.postcode = ' " . $this -> sPostcode . " ') " ;
}
}
2017-10-09 00:15:06 +03:00
$sExcludeSQL = $this -> oContext -> excludeSQL ( 'place_id' );
2017-10-07 13:01:56 +03:00
if ( $sExcludeSQL ) {
2017-10-09 00:15:06 +03:00
$aTerms [] = $sExcludeSQL ;
2017-10-07 13:01:56 +03:00
}
2017-10-08 23:44:01 +03:00
if ( $this -> oContext -> bViewboxBounded ) {
$aTerms [] = 'centroid && ' . $this -> oContext -> sqlViewboxSmall ;
2017-10-07 13:01:56 +03:00
}
2017-10-08 22:23:31 +03:00
if ( $this -> oContext -> hasNearPoint ()) {
$aOrder [] = $this -> oContext -> distanceSQL ( 'centroid' );
2017-10-07 13:01:56 +03:00
}
if ( $this -> sHouseNumber ) {
$sImportanceSQL = '- abs(26 - address_rank) + 3' ;
} else {
2018-02-20 01:24:12 +03:00
$sImportanceSQL = '(CASE WHEN importance = 0 OR importance IS NULL THEN 0.75001-(search_rank::float/40) ELSE importance END)' ;
2017-10-07 13:01:56 +03:00
}
2017-10-08 23:44:01 +03:00
$sImportanceSQL .= $this -> oContext -> viewboxImportanceSQL ( 'centroid' );
2017-10-07 13:01:56 +03:00
$aOrder [] = " $sImportanceSQL DESC " ;
if ( sizeof ( $this -> aFullNameAddress )) {
$sExactMatchSQL = ' ( ' ;
2017-10-08 11:06:17 +03:00
$sExactMatchSQL .= ' SELECT count(*) FROM ( ' ;
$sExactMatchSQL .= ' SELECT unnest(' . getArraySQL ( $this -> aFullNameAddress ) . ')' ;
$sExactMatchSQL .= ' INTERSECT ' ;
$sExactMatchSQL .= ' SELECT unnest(nameaddress_vector)' ;
$sExactMatchSQL .= ' ) s' ;
2017-10-07 13:01:56 +03:00
$sExactMatchSQL .= ') as exactmatch' ;
$aOrder [] = 'exactmatch DESC' ;
} else {
$sExactMatchSQL = '0::int as exactmatch' ;
}
if ( $this -> sHouseNumber || $this -> sClass ) {
$iLimit = 20 ;
}
2017-10-19 00:54:47 +03:00
$aResults = array ();
2017-10-07 13:01:56 +03:00
if ( sizeof ( $aTerms )) {
$sSQL = 'SELECT place_id,' . $sExactMatchSQL ;
$sSQL .= ' FROM search_name' ;
$sSQL .= ' WHERE ' . join ( ' and ' , $aTerms );
$sSQL .= ' ORDER BY ' . join ( ', ' , $aOrder );
$sSQL .= ' LIMIT ' . $iLimit ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
$aDBResults = chksql (
2017-10-08 16:26:14 +03:00
$oDB -> getAll ( $sSQL ),
2017-10-26 22:21:21 +03:00
'Could not get places for search terms.'
2017-10-07 13:01:56 +03:00
);
2017-10-19 00:54:47 +03:00
foreach ( $aDBResults as $aResult ) {
$oResult = new Result ( $aResult [ 'place_id' ]);
$oResult -> iExactMatches = $aResult [ 'exactmatch' ];
$aResults [ $aResult [ 'place_id' ]] = $oResult ;
}
2017-10-07 13:01:56 +03:00
}
2017-10-19 00:54:47 +03:00
return $aResults ;
2017-10-07 13:01:56 +03:00
}
2017-10-09 23:55:50 +03:00
private function queryHouseNumber ( & $oDB , $aRoadPlaceIDs , $iLimit )
2017-10-07 13:01:56 +03:00
{
2017-10-19 00:54:47 +03:00
$aResults = array ();
$sPlaceIDs = Result :: joinIdsByTable ( $aRoadPlaceIDs , Result :: TABLE_PLACEX );
if ( ! $sPlaceIDs ) {
return $aResults ;
}
2017-10-07 13:01:56 +03:00
$sHouseNumberRegex = '\\\\m' . $this -> sHouseNumber . '\\\\M' ;
$sSQL = 'SELECT place_id FROM placex ' ;
$sSQL .= 'WHERE parent_place_id in (' . $sPlaceIDs . ')' ;
$sSQL .= " AND transliteration(housenumber) ~* E' " . $sHouseNumberRegex . " ' " ;
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND place_id' );
2017-10-07 13:01:56 +03:00
$sSQL .= " LIMIT $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
// XXX should inherit the exactMatches from its parent
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId );
2017-10-07 13:01:56 +03:00
}
$bIsIntHouseNumber = ( bool ) preg_match ( '/[0-9]+/' , $this -> sHouseNumber );
$iHousenumber = intval ( $this -> sHouseNumber );
2017-10-19 00:54:47 +03:00
if ( $bIsIntHouseNumber && ! sizeof ( $aResults )) {
2017-10-07 13:01:56 +03:00
// if nothing found, search in the interpolation line table
$sSQL = 'SELECT distinct place_id FROM location_property_osmline' ;
$sSQL .= ' WHERE startnumber is not NULL' ;
$sSQL .= ' AND parent_place_id in (' . $sPlaceIDs . ') AND (' ;
if ( $iHousenumber % 2 == 0 ) {
// If housenumber is even, look for housenumber in streets
// with interpolationtype even or all.
$sSQL .= " interpolationtype='even' " ;
} else {
// Else look for housenumber with interpolationtype odd or all.
$sSQL .= " interpolationtype='odd' " ;
}
$sSQL .= " or interpolationtype='all') and " ;
2017-10-26 22:21:21 +03:00
$sSQL .= $iHousenumber . '>=startnumber and ' ;
$sSQL .= $iHousenumber . '<=endnumber' ;
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND place_id' );
2017-10-07 13:01:56 +03:00
$sSQL .= " limit $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$oResult = new Result ( $iPlaceId , Result :: TABLE_OSMLINE );
$oResult -> iHouseNumber = $iHousenumber ;
$aResults [ $iPlaceId ] = $oResult ;
2017-10-07 13:01:56 +03:00
}
}
// If nothing found try the aux fallback table
2017-10-19 00:54:47 +03:00
if ( CONST_Use_Aux_Location_data && ! sizeof ( $aResults )) {
2017-10-07 13:01:56 +03:00
$sSQL = 'SELECT place_id FROM location_property_aux' ;
$sSQL .= ' WHERE parent_place_id in (' . $sPlaceIDs . ')' ;
$sSQL .= " AND housenumber = ' " . $this -> sHouseNumber . " ' " ;
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND place_id' );
2017-10-07 13:01:56 +03:00
$sSQL .= " limit $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId , Result :: TABLE_AUX );
2017-10-07 13:01:56 +03:00
}
}
// If nothing found then search in Tiger data (location_property_tiger)
2017-10-19 00:54:47 +03:00
if ( CONST_Use_US_Tiger_Data && $bIsIntHouseNumber && ! sizeof ( $aResults )) {
$sSQL = 'SELECT place_id FROM location_property_tiger' ;
2017-10-07 13:01:56 +03:00
$sSQL .= ' WHERE parent_place_id in (' . $sPlaceIDs . ') and (' ;
if ( $iHousenumber % 2 == 0 ) {
$sSQL .= " interpolationtype='even' " ;
} else {
$sSQL .= " interpolationtype='odd' " ;
}
$sSQL .= " or interpolationtype='all') and " ;
2017-10-26 22:21:21 +03:00
$sSQL .= $iHousenumber . '>=startnumber and ' ;
$sSQL .= $iHousenumber . '<=endnumber' ;
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND place_id' );
2017-10-07 13:01:56 +03:00
$sSQL .= " limit $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$oResult = new Result ( $iPlaceId , Result :: TABLE_TIGER );
$oResult -> iHouseNumber = $iHousenumber ;
$aResults [ $iPlaceId ] = $oResult ;
2017-10-07 13:01:56 +03:00
}
}
2017-10-19 00:54:47 +03:00
return $aResults ;
2017-10-07 13:01:56 +03:00
}
2017-10-09 23:55:50 +03:00
private function queryPoiByOperator ( & $oDB , $aParentIDs , $iLimit )
2017-10-07 13:01:56 +03:00
{
2017-10-19 00:54:47 +03:00
$aResults = array ();
$sPlaceIDs = Result :: joinIdsByTable ( $aParentIDs , Result :: TABLE_PLACEX );
if ( ! $sPlaceIDs ) {
return $aResults ;
}
2017-10-07 13:01:56 +03:00
if ( $this -> iOperator == Operator :: TYPE || $this -> iOperator == Operator :: NAME ) {
// If they were searching for a named class (i.e. 'Kings Head pub')
// then we might have an extra match
$sSQL = 'SELECT place_id FROM placex ' ;
$sSQL .= " WHERE place_id in ( $sPlaceIDs ) " ;
$sSQL .= " AND class=' " . $this -> sClass . " ' " ;
$sSQL .= " AND type=' " . $this -> sType . " ' " ;
2017-10-26 22:21:21 +03:00
$sSQL .= ' AND linked_place_id is null' ;
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND place_id' );
2017-10-26 22:21:21 +03:00
$sSQL .= ' ORDER BY rank_search ASC ' ;
2017-10-07 13:01:56 +03:00
$sSQL .= " LIMIT $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId );
}
2017-10-07 13:01:56 +03:00
}
// NEAR and IN are handled the same
if ( $this -> iOperator == Operator :: TYPE || $this -> iOperator == Operator :: NEAR ) {
$sClassTable = $this -> poiTable ();
$sSQL = " SELECT count(*) FROM pg_tables WHERE tablename = ' $sClassTable ' " ;
2017-10-08 16:26:14 +03:00
$bCacheTable = ( bool ) chksql ( $oDB -> getOne ( $sSQL ));
2017-10-07 13:01:56 +03:00
$sSQL = " SELECT min(rank_search) FROM placex WHERE place_id in ( $sPlaceIDs ) " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-08 16:26:14 +03:00
$iMaxRank = ( int ) chksql ( $oDB -> getOne ( $sSQL ));
2017-10-07 13:01:56 +03:00
// For state / country level searches the normal radius search doesn't work very well
$sPlaceGeom = false ;
if ( $iMaxRank < 9 && $bCacheTable ) {
// Try and get a polygon to search in instead
$sSQL = 'SELECT geometry FROM placex' ;
$sSQL .= " WHERE place_id in ( $sPlaceIDs ) " ;
$sSQL .= " AND rank_search < $iMaxRank + 5 " ;
$sSQL .= " AND ST_GeometryType(geometry) in ('ST_Polygon','ST_MultiPolygon') " ;
2017-10-26 22:21:21 +03:00
$sSQL .= ' ORDER BY rank_search ASC ' ;
$sSQL .= ' LIMIT 1' ;
2017-10-07 13:01:56 +03:00
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-08 16:26:14 +03:00
$sPlaceGeom = chksql ( $oDB -> getOne ( $sSQL ));
2017-10-07 13:01:56 +03:00
}
if ( $sPlaceGeom ) {
$sPlaceIDs = false ;
} else {
$iMaxRank += 5 ;
$sSQL = 'SELECT place_id FROM placex' ;
$sSQL .= " WHERE place_id in ( $sPlaceIDs ) and rank_search < $iMaxRank " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-08 16:26:14 +03:00
$aPlaceIDs = chksql ( $oDB -> getCol ( $sSQL ));
2017-10-07 13:01:56 +03:00
$sPlaceIDs = join ( ',' , $aPlaceIDs );
}
if ( $sPlaceIDs || $sPlaceGeom ) {
$fRange = 0.01 ;
if ( $bCacheTable ) {
// More efficient - can make the range bigger
$fRange = 0.05 ;
$sOrderBySQL = '' ;
2017-10-08 22:23:31 +03:00
if ( $this -> oContext -> hasNearPoint ()) {
$sOrderBySQL = $this -> oContext -> distanceSQL ( 'l.centroid' );
2017-10-07 13:01:56 +03:00
} elseif ( $sPlaceIDs ) {
2017-10-26 22:21:21 +03:00
$sOrderBySQL = 'ST_Distance(l.centroid, f.geometry)' ;
2017-10-07 13:01:56 +03:00
} elseif ( $sPlaceGeom ) {
$sOrderBySQL = " ST_Distance(st_centroid(' " . $sPlaceGeom . " '), l.centroid) " ;
}
$sSQL = 'SELECT distinct i.place_id' ;
if ( $sOrderBySQL ) {
$sSQL .= ', i.order_term' ;
}
$sSQL .= ' from (SELECT l.place_id' ;
if ( $sOrderBySQL ) {
$sSQL .= ',' . $sOrderBySQL . ' as order_term' ;
}
$sSQL .= ' from ' . $sClassTable . ' as l' ;
if ( $sPlaceIDs ) {
2017-10-26 22:21:21 +03:00
$sSQL .= ',placex as f WHERE ' ;
2017-10-07 13:01:56 +03:00
$sSQL .= " f.place_id in ( $sPlaceIDs ) " ;
$sSQL .= " AND ST_DWithin(l.centroid, f.centroid, $fRange ) " ;
} elseif ( $sPlaceGeom ) {
$sSQL .= " WHERE ST_Contains(' $sPlaceGeom ', l.centroid) " ;
}
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND l.place_id' );
2017-10-07 13:01:56 +03:00
$sSQL .= 'limit 300) i ' ;
if ( $sOrderBySQL ) {
$sSQL .= 'order by order_term asc' ;
}
$sSQL .= " limit $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId );
}
2017-10-07 13:01:56 +03:00
} else {
2017-10-08 22:23:31 +03:00
if ( $this -> oContext -> hasNearPoint ()) {
$fRange = $this -> oContext -> nearRadius ();
2017-10-07 13:01:56 +03:00
}
$sOrderBySQL = '' ;
2017-10-08 22:23:31 +03:00
if ( $this -> oContext -> hasNearPoint ()) {
$sOrderBySQL = $this -> oContext -> distanceSQL ( 'l.geometry' );
2017-10-07 13:01:56 +03:00
} else {
2017-10-26 22:21:21 +03:00
$sOrderBySQL = 'ST_Distance(l.geometry, f.geometry)' ;
2017-10-07 13:01:56 +03:00
}
$sSQL = 'SELECT distinct l.place_id' ;
if ( $sOrderBySQL ) {
$sSQL .= ',' . $sOrderBySQL . ' as orderterm' ;
}
$sSQL .= ' FROM placex as l, placex as f' ;
$sSQL .= " WHERE f.place_id in ( $sPlaceIDs ) " ;
$sSQL .= " AND ST_DWithin(l.geometry, f.centroid, $fRange ) " ;
$sSQL .= " AND l.class=' " . $this -> sClass . " ' " ;
$sSQL .= " AND l.type=' " . $this -> sType . " ' " ;
2017-10-09 00:15:06 +03:00
$sSQL .= $this -> oContext -> excludeSQL ( ' AND l.place_id' );
2017-10-07 13:01:56 +03:00
if ( $sOrderBySQL ) {
2017-10-26 22:21:21 +03:00
$sSQL .= 'ORDER BY orderterm ASC' ;
2017-10-07 13:01:56 +03:00
}
$sSQL .= " limit $iLimit " ;
if ( CONST_Debug ) var_dump ( $sSQL );
2017-10-19 00:54:47 +03:00
foreach ( chksql ( $oDB -> getCol ( $sSQL )) as $iPlaceId ) {
$aResults [ $iPlaceId ] = new Result ( $iPlaceId );
}
2017-10-07 13:01:56 +03:00
}
}
}
2017-10-19 00:54:47 +03:00
return $aResults ;
2017-10-07 13:01:56 +03:00
}
2017-10-08 16:26:14 +03:00
2017-10-10 00:12:13 +03:00
private function poiTable ()
{
return 'place_classtype_' . $this -> sClass . '_' . $this -> sType ;
}
private function countryCodeSQL ( $sVar )
{
if ( $this -> sCountryCode ) {
return $sVar . ' = \'' . $this -> sCountryCode . " ' " ;
}
if ( $this -> oContext -> sqlCountryList ) {
return $sVar . ' in ' . $this -> oContext -> sqlCountryList ;
}
return '' ;
}
2017-10-08 16:26:14 +03:00
/////////// Sort functions
2017-10-08 18:00:59 +03:00
public static function bySearchRank ( $a , $b )
2017-10-08 16:26:14 +03:00
{
if ( $a -> iSearchRank == $b -> iSearchRank ) {
return $a -> iOperator + strlen ( $a -> sHouseNumber )
- $b -> iOperator - strlen ( $b -> sHouseNumber );
}
return $a -> iSearchRank < $b -> iSearchRank ? - 1 : 1 ;
}
2017-10-08 17:03:30 +03:00
//////////// Debugging functions
2017-10-08 18:00:59 +03:00
public function dumpAsHtmlTableRow ( & $aWordIDs )
2017-10-08 17:03:30 +03:00
{
2017-10-08 18:00:59 +03:00
$kf = function ( $k ) use ( & $aWordIDs ) {
return $aWordIDs [ $k ];
};
2017-10-08 17:03:30 +03:00
2017-10-26 22:21:21 +03:00
echo '<tr>' ;
2017-10-08 17:03:30 +03:00
echo " <td> $this->iSearchRank </td> " ;
2017-10-26 22:21:21 +03:00
echo '<td>' . join ( ', ' , array_map ( $kf , $this -> aName )) . '</td>' ;
echo '<td>' . join ( ', ' , array_map ( $kf , $this -> aNameNonSearch )) . '</td>' ;
echo '<td>' . join ( ', ' , array_map ( $kf , $this -> aAddress )) . '</td>' ;
echo '<td>' . join ( ', ' , array_map ( $kf , $this -> aAddressNonSearch )) . '</td>' ;
echo '<td>' . $this -> sCountryCode . '</td>' ;
echo '<td>' . Operator :: toString ( $this -> iOperator ) . '</td>' ;
echo '<td>' . $this -> sClass . '</td>' ;
echo '<td>' . $this -> sType . '</td>' ;
echo '<td>' . $this -> sPostcode . '</td>' ;
echo '<td>' . $this -> sHouseNumber . '</td>' ;
echo '</tr>' ;
2017-10-08 17:03:30 +03:00
}
2017-10-08 18:00:59 +03:00
}