Расскажу про геотаргетинг и как его встроить в приложения на Zend Framework 2. Геотаргетинг - это определение местоположения пользователя на основе его персональных данных, ip д.р. способы. В статье я буду рассказывать про геотаргетинг с использованием ip адреса и сервиса ipGeoBase - http://ipgeobase.ru/.

Что нужно для геотаргетинга.

• Базы данных с ipGeoBase(ipGeoBase).
• Zend FrameWork 2
• Готовый модуль Zend Framework для работы, например (https://github.com/akrabat/zf2-tutorial)

Основную работу при определении местоположения пользователя будет выполнять класс "Geo". Его инициализация внутри действия контроллёра выглядит следующим образом:

$o = array(); // опции. необзятательно. $o['charset'] = 'utf-8'; // нужно указать требуемую кодировку, если она отличается от windows-1251 $geo = $this->Geo($o); $region = $geo->get_value('region', false); $country = $geo->get_value('country', false);

Этот код нужно расположить внутри нужного действия Вашего контроллёра, например:

public function indexAction() { //..... $o = array(); // опции. необзятательно. $o['charset'] = 'utf-8'; // нужно указать требуемую кодировку, если она отличается от windows-1251 $geo = $this->Geo($o); $region = $geo->get_value('region', false); $country = $geo->get_value('country', false); }

Класс Geo будет плагином Zend Frmework 2, для того чтобы к нему обращаться как плагину, его необходимо подключить в файле module.config.php для модуля Zend Framework, я делаю это следующим образом, подключая его вместе с другими модулями в моём приложении:

'controller_plugins' => array( 'invokables' => array( 'breadcrumbsFilter' => 'Application\Controller\Plugin\breadcrumbsFilter', 'Geo' => 'Application\Controller\Plugin\Geo\Geo', 'qtipFilter' => 'Application\Controller\Plugin\qtipFilter', ), ),

Подключив плагин в конфигурационном файле, его необходимо правильно разместить по адресу: "Application\Controller\Plugin\Geo\Geo.php" - соответствие шаблону "Application\Controller\Plugin\Geo\Geo". Весь пример плагина Geo, подробное объяснение указанно после этого листинга.

<?php namespace Application\Controller\Plugin\Geo; use Zend\Mvc\Controller\Plugin\AbstractPlugin; use Zend\Authentication\AuthenticationService; use Zend\ServiceManager\ServiceManagerAwareInterface; use Zend\ServiceManager\ServiceManager; use Zend\Db\Sql\Select; use Zend\Db\Sql\Sql; class Geo extends AbstractPlugin implements ServiceManagerAwareInterface { public function __construct($options = null) { $this->dirname = dirname(__file__); //var_dump($options['charset']); // ip if(!isset($options['ip']) OR !$this->is_valid_ip($options['ip'])) $this->ip = $this->get_ip(); elseif($this->is_valid_ip($options['ip'])) $this->ip = $options['ip']; // кодировка if(isset($options['charset']) && $options['charset'] && $options['charset']!='windows-1251') $this->charset = $options['charset']; } /** * функция возвращет конкретное значение из полученного массива данных по ip * @param string - ключ массива. Если интересует конкретное значение. * Ключ может быть равным 'inetnum', 'country', 'city', 'region', 'district', 'lat', 'lng' * @param bolean - устанавливаем хранить данные в куки или нет * Если true, то в куки будут записаны данные по ip и повторные запросы на ipgeobase происходить не будут. * Если false, то данные постоянно будут запрашиваться с ipgeobase * @return array OR string - дополнительно читайте комментарии внутри функции. */ function get_value($key = false, $cookie = true) { $key_array = array('inetnum', 'country', 'city', 'region', 'district', 'lat', 'lng'); if(!in_array($key, $key_array)) $key = false; // если используем куки и параметр уже получен, то достаем и возвращаем данные из куки if($cookie && isset($_COOKIE['geobase'])) { $data = unserialize($_COOKIE['geobase']); } else { $data = $this->get_geobase_data(); setcookie('geobase', serialize($data), time()+3600*24*7); //устанавливаем куки на неделю } if($key) return $data[$key]; // если указан ключ, возвращаем строку с нужными данными else return $data; // иначе возвращаем массив со всеми данными } /** * функция получает данные по ip. * @return array - возвращает массив с данными */ function get_geobase_data() { $ra1 = sprintf("%u", ip2long($this->ip)); $sql = new Sql($this->getpgAdapter()); $sender = $id; $select = new Select(); $select->from(array('g'=>'geo_new')) ->columns(array('g.city_id'=>'city_id','ip2','ip1','country')) ->join(array('m'=>'master_new'),'g.city_id=m.city_id') ->where("('".$ra1."')>=ip1 AND ('".$ra1."')<=ip2") ->limit(1); $statement = $sql->prepareStatementForSqlObject($select); $data = $statement->execute()->current(); if(empty($data)) { // получаем данные по ip $link = 'ipgeobase.ru:7020/geo?ip='.$this->ip; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $link); curl_setopt($ch, CURLOPT_HEADER, false); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_TIMEOUT, 3); curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 3); $string = curl_exec($ch); // если указана кодировка отличная от windows-1251, изменяем кодировку $string = iconv("windows-1251", "UTF-8", $string); $data = $this->parse_string($string); } return $data; } /** * функция парсит полученные в XML данные в случае, если на сервере не установлено расширение Simplexml * @return array - возвращает массив с данными */ function parse_string($string) { $pa['inetnum'] = '#<inetnum>(.*)</inetnum>#is'; $pa['country'] = '#<country>(.*)</country>#is'; $pa['city'] = '#<city>(.*)</city>#is'; $pa['region'] = '#<region>(.*)</region>#is'; $pa['district'] = '#<district>(.*)</district>#is'; $pa['lat'] = '#<lat>(.*)</lat>#is'; $pa['lng'] = '#<lng>(.*)</lng>#is'; $data = array(); foreach($pa as $key => $pattern) { preg_match($pattern, $string, $out); if(isset($out[1]) && $out[1]) $data[$key] = trim($out[1]); } return $data; } /** * функция определяет ip адрес по глобальному массиву $_SERVER * ip адреса проверяются начиная с приоритетного, для определения возможного использования прокси * @return ip-адрес */ function get_ip() { $ip = false; if (isset($_SERVER['HTTP_X_FORWARDED_FOR'])) $ipa[] = trim(strtok($_SERVER['HTTP_X_FORWARDED_FOR'], ',')); if (isset($_SERVER['HTTP_CLIENT_IP'])) $ipa[] = $_SERVER['HTTP_CLIENT_IP']; if (isset($_SERVER['REMOTE_ADDR'])) $ipa[] = $_SERVER['REMOTE_ADDR']; if (isset($_SERVER['HTTP_X_REAL_IP'])) $ipa[] = $_SERVER['HTTP_X_REAL_IP']; // проверяем ip-адреса на валидность начиная с приоритетного. foreach($ipa as $ips) { // если ip валидный обрываем цикл, назначаем ip адрес и возвращаем его if($this->is_valid_ip($ips)) { $ip = $ips; break; } } return $ip; } /** * функция для проверки валидности ip адреса * @param ip адрес в формате 1.2.3.4 * @return bolean : true - если ip валидный, иначе false */ function is_valid_ip($ip=null) { if(preg_match("#^([0-9]{1,3})\.([0-9]{1,3})\.([0-9]{1,3})\.([0-9]{1,3})$#", $ip)) return true; // если ip-адрес попадает под регулярное выражение, возвращаем true return false; // иначе возвращаем false } /** * Retrieve service manager instance * * @return ServiceManager */ public function getServiceManager() { return $this->serviceManager->getServiceLocator(); } /** * Set service manager instance * * @param ServiceManager $locator * @return void */ public function setServiceManager(ServiceManager $serviceManager) { $this->serviceManager = $serviceManager; } public function getpgAdapter() { if (!$this->pgadapter) { $this->pgadapter = $this->serviceManager->getServiceLocator()->get('app_zend_db_adapter'); } return $this->pgadapter; } } ?>

Основные функции объясняются подробно в комментариях, однако подробно объясню отдельно функцию "getpgAdapter()". Функция создаёт экземпляр класса подключения к базе данных (Adapter), создаётся он на основе конфигурационных данных содержащихся в файлах, как правило это файл "config\autoload\global.php", согласно документации:

"It is important to know that by using this style of adapter creation, the Adapter will attempt to create any dependencies that were not explicitly provided. A Driver object will be created from the configuration array provided in the constructor. A Platform object will be created based off the type of Driver object that was instantiated. And lastly, a default ResultSet object is created and utilized. Any of these objects can be injected, to do this, see the next section."

Ещё хотелось объяснить интересную функцию "get_geobase_data", по сути это модифицирлваннфый вариант скрипта скаченного с сайта ipgeobase, за исключением того, что мы помещаем данные в базу (о чём будет рассказано после следующего листинга), а после этого используем их для наших целей, согласитесь, поиск по базе данных с индексированным столбцами намного быстрее и удобнее чем работа с xlm данными, хотя скрипт написан таким образом, что когда в базе не находится нужный регион, происходит обращение к xml файлу с официального сайта - ipgeobase, с надеждой найти данные там.

function get_geobase_data() { $ra1 = sprintf("%u", ip2long($this->ip)); $sql = new Sql($this->getpgAdapter()); $sender = $id; $select = new Select(); $select->from(array('g'=>'geo_new')) ->columns(array('g.city_id'=>'city_id','ip2','ip1')) ->join(array('m'=>'master_new'),'g.city_id=m.city_id') ->where("('".$ra1."')>=ip1 AND ('".$ra1."')<=ip2") ->limit(1); $statement = $sql->prepareStatementForSqlObject($select); $results = $statement->execute()->current(); $data['region'] = $results['region']; if(!$results['region']) { // получаем данные по ip $link = 'ipgeobase.ru:7020/geo?ip='.$this->ip; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $link); curl_setopt($ch, CURLOPT_HEADER, false); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_TIMEOUT, 3); curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 3); $string = curl_exec($ch); // если указана кодировка отличная от windows-1251, изменяем кодировку $string = iconv("windows-1251", "UTF-8", $string); $data = $this->parse_string($string); } return $data; }

Как я и обещал, ниже приведён файл который может использоваться для обновления данных содержащихся в базе, поместите этот файл в директорию, скрытыю от публичного доступа.

<?php $master_file = 'cities.txt'; // Наши основной файл с ip $slave_file = 'cidr_optim.txt'; // Наши дополнительный файл с ip include '../config.php'; class getXmltoDb { protected $Mymysql; function __construct(){ $connection = mysql_connect ("localhost", USER, PASS) or die ("Ошибка соединения с сервером"); $db = mysql_select_db (DBS, $connection) or die ("Ошибка при выборе базы данных"); mysql_query("SET NAMES 'utf8'"); // кодировка для соединения с базой данных mysql_query("SET CHARACTER SET 'utf8'"); // кодировка для соединения с базой данных mysql_query("SET SESSION wait_timeout = 2800"); // кодировка для соединения с базой данных mysql_query("TRUNCATE `geo_new`;"); // кодировка для соединения с базой данных mysql_query("TRUNCATE `master_new`;"); // кодировка для соединения с базой данных set_time_limit(10000); } function my_ip_slave ($slave_file) { $slave_fp = file($slave_file); // Читаем строки файла в массив foreach ($slave_fp as $value) { $cell = explode("\t", iconv("windows-1251", "UTF-8", $value));// Разбиваем каждую строку на массив $query_slave = "INSERT INTO `geo_new` (`ip1`, `ip2`, `blockip`, `country`, `city_id`) VALUES ('$cell[0]','$cell[1]','$cell[2]','$cell[3]', '$cell[4]');"; $result = mysql_query ($query_slave) // выполняем запрос и заполняем базу данных ip адресами or die ("Ошибка при выполнении запроса: ".mysql_error ()); } } function my_ip_master($master_file) { $slave_fp = file($master_file); // Читаем строки файла в массив foreach ($slave_fp as $value) { $cell = explode("\t", iconv("windows-1251", "UTF-8", $value));// Разбиваем каждую строку на массив $query = "INSERT INTO master_new (city_id,city, region, okrug, coord1,coord2) VALUES ('$cell[0]','$cell[1]','$cell[2]', '$cell[3]', '$cell[4]', '$cell[5]');"; $result = mysql_query ($query) // выполняем запрос и заполняем базу данных ip адресами or die ("Ошибка при выполнении запроса: ".mysql_error ()); } } function grabGeoIpBase(){ $link = 'http://ipgeobase.ru/files/db/Main/geo_files.zip'; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $link); curl_setopt($ch, CURLOPT_HEADER, false); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_TIMEOUT, 3); curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 3); $string = curl_exec($ch); $fp = fopen('geo.zip','w'); fwrite($fp,$string); fclose($fp); $zip = new ZipArchive; if ($zip->open('geo.zip') === TRUE) { $zip->extractTo('./'); $zip->close(); return true; } else { return false; } } } $parser = new getXmltoDb(); // поехали! if($parser->grabGeoIpBase()) { $parser->my_ip_master($master_file); $parser->my_ip_slave($slave_file); } ?>

Config.php

<?php define('DBS',''); define('USER',''); define('PASS',''); ?>,

После этого осталось создать запись в файле crontab "05 04 * * * /usr/bin/php /var/www/jquery/data/parser/index.php >/dev/null 2>&1"

Полученные данные в нашем действии, о котором мы писали ранее (indexAction), будут содержаться в переменных $region и country. В примере выполняются два запроса, в действительности хватает одного запроса через функцию get_value('', false), которая будет содержать массив данных.