ChZIPModule.php

Go to the documentation of this file.

<?php
 
ch_import('ChWsbModule');
 
class ChZIPModule extends ChWsbModule
{
    var $_server = 'http://ws.geonames.org'; // geonames server to use for geocoding
    var $_style = 'SHORT'; // SHORT,MEDIUM,LONG,FULL
    var $_maxRows = 500; // max number of zip codes to return
    var $_error = '';
 
    function __construct(&$aModule)
    {
        parent::__construct($aModule);
    }
 
    function serviceGetSqlParts ($mixedCountry, $sZip, $sMetric, $iDistance, &$sJoin, &$aWhere)
    {
        if (!getParam('ch_zip_enabled'))
            return false;
 
        $sWhere = '';
 
        // check input fields
        $sZip = process_db_input( strtoupper( trim($sZip) ), CH_TAGS_STRIP);
        $sMetric = process_db_input( $sMetric, CH_TAGS_STRIP);
        $iDistance = (int)$iDistance;
        if (is_array($mixedCountry)) {
            $sCountry = process_db_input( $mixedCountry[0], CH_TAGS_STRIP); // no reason to search by zipcode in different countries
        } else {
            $sCountry = process_db_input( $mixedCountry, CH_TAGS_STRIP);
        }
 
        // check GB and CA zipcodes
        if ('CA' == $sCountry) {
            $sZip = substr($sZip, 0, 3);
        } elseif ('GB' == $sCountry) {
            $sZip = strlen($sZip) > 4 ? trim(substr($sZip, 0, -3)) : trim($sZip);
        }
 
        // search using google - Worls Maps module needs to be installed and configured
        if ('Google' == getParam('ch_zip_mode') && $this->_oDb->isModule('wmap')) {
            if ($sMetric == 'km')
                $iDistance *= 0.62;
 
            do {
                $sAddress = "$sZip " . str_replace('_', '', $GLOBALS['aPreValues']['Country'][$sCountry]['LKey']);
                if (200 != $this->_geocodeGoogle ($sAddress, $fLat, $fLng, $sCountry)) {
                    $this->_setError (_t('_No zip codes found'));
                    break;
                }
 
                if (!class_exists('RadiusAssistant'))
                    require_once( CH_DIRECTORY_PATH_INC . 'RadiusAssistant.inc.php' );
 
                $zcdRadius = new RadiusAssistant( $fLat, $fLng, $iDistance );
                $minLat = $zcdRadius->MinLatitude();
                $maxLat = $zcdRadius->MaxLatitude();
                $minLong = $zcdRadius->MinLongitude();
                $maxLong = $zcdRadius->MaxLongitude();
 
                $sWhere = " `Profiles`.`Country` = '$sCountry' AND `ch_wmap_locations`.`country` = '$sCountry' AND `ch_wmap_locations`.`failed` = 0 AND `ch_wmap_locations`.`lat` >= {$minLat} AND `ch_wmap_locations`.`lat` <= {$maxLat} AND `ch_wmap_locations`.`lng` >= {$minLong} AND `ch_wmap_locations`.`lng` <= {$maxLong} ";
                $sJoin .= " INNER JOIN `ch_wmap_locations` ON (`ch_wmap_locations`.`part` = 'profiles' AND  `ch_wmap_locations`.`id` = `Profiles`.`ID`) ";
 
            } while (0);
        }
        // search using geonames
        else {
            if ($sMetric != 'km')
                $iDistance *= 1.61;
 
            if ($iDistance > 30 ) // free service don't allow to search more than 30 km
                $iDistance = 30;
 
            do {
                $s = $this->_readFromUrl($this->_server . "/findNearbyPostalCodes?postalcode={$sZip}&country={$sCountry}&radius={$iDistance}&style={$this->_style}&maxRows={$this->_maxRows}&username=" . trim(getParam('ch_zip_geonames_username')));
                if (!$s) {
                    $this->_setError (_t('_Server is too busy'));
                    break;
                }
 
                if (!$this->_getStatusMessage  ($s))
                    break;
 
                if (false === ($aZips = $this->_getZipCodesArray ($s)))
                    break;
 
                foreach ($aZips as $k => $s)
                    $aZips[$k] = strtoupper($s);
 
                if ('GB' == $sCountry) {
                    $sWhere = " `Country` = '$sCountry' AND (";
                    foreach ($aZips as $s)
                        $sWhere .= " UPPER(IF(LENGTH(`Profiles`.`zip`) > 4,TRIM(SUBSTRING(`Profiles`.`zip`,1,LENGTH(`Profiles`.`zip`)-3)),`Profiles`.`zip`)) = '$s' OR ";
                    $sWhere = substr($sWhere, 0, -4);
                    $sWhere .= ")";
                } elseif ('CA' == $sCountry)
                    $sWhere = " `Country` = '$sCountry' AND (UPPER(SUBSTRING(`Profiles`.`zip`,1,3)) = '" . join ("' OR UPPER(SUBSTRING(`Profiles`.`zip`,1,3)) = '", $aZips) . "') ";
                else
                    $sWhere = " `Country` = '$sCountry' AND (UPPER(`Profiles`.`zip`) = '" . join ("' OR UPPER(`Profiles`.`zip`) = '", $aZips) . "') ";
            } while (0);
 
        }
 
        if ($s = $this->getError()) {
            $aWhere[] = ' 0 ';
        } else {
            foreach ($aWhere as $k => $v)
                if (preg_match('/`zip`/', $v) || preg_match('/`Country`/', $v))
                    unset ($aWhere[$k]);
            $aWhere[] = $sWhere ? $sWhere : ' 0 ';
        }
 
        return true;
    }
 
    function actionAdministration ()
    {
        if (!$this->isAdmin()) {
            $this->_oTemplate->displayAccessDenied ();
            return;
        }
 
        $this->_oTemplate->pageStart();
 
        $iId = $this->_oDb->getSettingsCategory();
        if(empty($iId)) {
            echo MsgBox(_t('_sys_request_page_not_found_cpt'));
            $this->_oTemplate->pageCodeAdmin (_t('_ch_zip_administration'));
            return;
        }
 
        ch_import('ChWsbAdminSettings');
 
        $mixedResult = '';
        if(isset($_POST['save']) && isset($_POST['cat'])) {
            $oSettings = new ChWsbAdminSettings($iId);
            $mixedResult = $oSettings->saveChanges($_POST);
        }
 
        $oSettings = new ChWsbAdminSettings($iId);
        $sResult = $oSettings->getForm();
 
        if($mixedResult !== true && !empty($mixedResult))
            $sResult = $mixedResult . $sResult;
 
        $aVars = array (
            'content' => $sResult,
        );
        echo $this->_oTemplate->adminBlock ($this->_oTemplate->parseHtmlByName('default_padding', $aVars), _t('_ch_zip_administration'));
 
        $aVars = array (
            'content' => _t('_ch_zip_help_text'),
        );
        echo $this->_oTemplate->adminBlock ($this->_oTemplate->parseHtmlByName('default_padding', $aVars), _t('_ch_zip_help'));
 
        $this->_oTemplate->addCssAdmin ('forms_adv.css');
        $this->_oTemplate->pageCodeAdmin (_t('_ch_zip_administration'));
    }
 
    function isAdmin ()
    {
        return $GLOBALS['logged']['admin'] ? true : false;
    }
 
    function _readFromUrl ($sUrl)
    {
        if (function_exists('curl_init')) {
                $curl = curl_init();
 
                curl_setopt($curl, CURLOPT_URL, $sUrl);
                curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
                curl_setopt($curl, CURLOPT_HEADER, false);
 
                $s = curl_exec($curl);
 
                curl_close($curl);
 
                if (true === $s) $s = '';
        } else {
            $s = @file_get_contents($sUrl);
        }
        return $s;
    }
 
    function _getTotalResultsNum (&$s)
    {
        if (preg_match('/<totalResultsCount>(\d+)<\/totalResultsCount>/', $s, $m)) {
            return $m[1];
        }
        return 0;
    }
 
    function _getLat (&$s)
    {
        if (preg_match('/<lat>([0-9\.-]+)<\/lat>/', $s, $m)) {
            return $m[1];
        }
        return false;
    }
 
    function _getLng (&$s)
    {
        if (preg_match('/<lng>([0-9\.-]+)<\/lng>/', $s, $m)) {
            return $m[1];
        }
        return false;
    }
 
    function _getStatusMessage  (&$s)
    {
        if (preg_match('/<status\s+message="(.*)"\s+value="(\d+)"\s*\/>/', $s, $m)) {
            $this->_setError ($m[1]);
            return false;
        }
        return true;
    }
 
    function _getZipCodesArray (&$s)
    {
        if (!preg_match_all('/<postalcode>(.*)<\/postalcode>/', $s, $m)) {
            $this->_setError (_t('_No zip codes found'));
            return false;
        }
        return array_unique($m[1]);
    }
 
    function _getCountriesArray (&$s)
    {
        if (!preg_match_all('/<countryCode>(.*)<\/countryCode>/', $s, $m)) {
            return array ();
        }
        return array_unique($m[1]);
    }
 
    function _setError ($s)
    {
        $this->_error = $s;
    }
 
    function getError ()
    {
        return $this->_error;
    }
 
    function _geocodeGoogle ($sAddress, &$fLatitude, &$fLongitude, &$sCountryCode)
    {
        $sAddress = rawurlencode($sAddress);
 
        $sUrl = "http://maps.googleapis.com/maps/api/geocode/json";
 
        $s = ch_file_get_contents($sUrl, array(
            'address' => $sAddress,
            'sensor' => 'false'
        ));
 
        $oData = json_decode($s);
        if (null == $oData)
            return 404;
 
        if ('OK' != $oData->status)
            return 404;
 
        foreach ($oData->results as $oResult) {
 
            $sShortNameCountry = '';
            foreach ($oResult->address_components as $oAddressComponent)
                if (in_array('country', $oAddressComponent->types))
                    $sShortNameCountry = $oAddressComponent->short_name;
 
            if (!$sCountryCode || ($sShortNameCountry && $sCountryCode == $sShortNameCountry)) {
                $fLatitude = $oResult->geometry->location->lat;
                $fLongitude = $oResult->geometry->location->lng;
                $sCountryCode = $sShortNameCountry;
                return 200;
            }
        }
 
        return 404;
    }
}