odea/library/Scores/Ciblage.php

<?php
/**
 * Ciblage construct the request send to Sphinx
 */
class Ciblage
{
	/**
	 * Name of the index store in Sphinx
	 * @var string
	 */
	protected $index = 'ciblage';

	/**
	 * Sphinx instantiation
	 * @var object
	 */
	protected $sphinx;

	/**
	 * Construct request
	 * @var string
	 */
	protected $alpha = '';

	/**
	 *
	 * @param array $structure
	 * @param boolean $need
	 */
	public function __construct($structure, $need = false)
	{
		Zend_Registry::get('firebug')->info($structure);

		/*
		 * First of all we need to load the Sphinx API
		 * @todo : Make a test and load the right version of API
		 */
		require_once 'sphinxapi/sphinxapi-2.0.4.php';

		$this->need = true;

		//Load configuration from registry
		$configuration = Zend_Registry::get('configuration');

		//Sphinx init
		$this->sphinx = new SphinxClient();
		$this->sphinx->SetServer(
			$configuration->sphinx->host,
			intval($configuration->sphinx->port)
		);
		$this->sphinx->SetMatchMode(SPH_MATCH_EXTENDED2);
		$this->sphinx->ResetFilters();

		//
		if ( count($structure)>0 ) {
			foreach($structure as $key => $valeur) {
				if ($key!= 'NB' && method_exists($this, $key)) {
					$this->{$key}($valeur);
				}
			}
		}
	}

	protected function setFilter($name, $valeur, $ex = false)
	{
		//All values must be integer
		if ( is_array($valeur) ) {
			$valeur = array_map('intval', $valeur);
		} else {
			$valeur = array(intval($valeur));
		}
		$this->sphinx->SetFilter($name, $valeur, $ex);
	}

	protected function setFilterRange($name, $min, $max)
	{
		$this->sphinx->SetFilterRange($name, intval($min), intval($max));
	}

	protected function setAlpha($name, $valeur)
	{
		if ( $this->alpha!='' ) $this->alpha.= ' ';
		$this->alpha.= '@'.$name.' '.$valeur;
	}








	public function extract()
	{
		$resultats		= $this->execute(true);
		$siret = array();
		foreach ($resutlats['matches'] as $element) {
			$siret[] = $element['attrs']['siren'].$element['attrs']['nic'];
		}
		$total = array(
			'total' => count($resultats),
			'insee' => $this->calculRedevanceInsee(),
			'result'=> $siret
		);
		return $total;
	}

	public function calculRedevanceInsee()
	{
		$this->sphinx->SetFilter('presentrcs', array(0));
		$resSphinx = $this->sphinx->Query($this->alpha, $this->index);
		return ($resSphinx['total_found']);
	}

	protected function getSiret($structure)
	{
		$siret = array();
		if(count($structure['matches'])>0) {
			foreach($structure['matches'] as $element){
				$siret[] = $element['attrs']['siren'].$element['attrs']['nic'];
			}
			return ($siret);
		} else
			return (array());
	}
	public function execute($need = false, $limitD = false)
	{
		if($need) {
			$return = array();
			$limit = 0;
			do {
				$this->sphinx->SetLimits($limit, (($limitD!=false)?10:1000), 50000);
				$resSphinx = $this->sphinx->Query($this->alpha, $this->index);
				if(is_array($resSphinx))
					$return = array_merge($return, $this->getSiret($resSphinx));
				$limit = $limit + 1000;
			}while($limit < (($limitD!=false)?10:$resSphinx['total_found']));
			return ($return);
		} else {
			$this->sphinx->SetLimits(0, 1);
			$resSphinx = $this->sphinx->Query($this->alpha, $this->index);
		}
		Zend_Registry::get('firebug')->info("Sphinx : ".$this->alpha);
		Zend_Registry::get('firebug')->info($resSphinx);
		return $resSphinx['total_found'];
	}

	protected function siege($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('siege', $value);
		}
	}

	//Valeur NULL dans BDD
	protected function groupe($value)
	{
		if ( array_key_exists('in', $value) ) {
			//$this->setFilter('sirenGrp', $value);
		}
	}

	protected function tel($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('tel', $value);
		}
	}

	protected function fax($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('fax', $value);
		}
	}

	protected function web($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('web', $value);
		}
	}

	protected function mail($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('mail', $value);
		}
	}

	protected function presentRcs($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('presentRcs', $value);
		}
	}

	protected function adrDom($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('adrDom', $value);
		}
	}

	protected function dirNom($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('dirNom', $value);
		}
	}

	protected function participation($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('part', $value);
		}
	}

	protected function action($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('actio', $value);
		}
	}

	//Don't work
	protected function dateCrea_etab($value)
	{

	}

	//Don't work
	protected function dateCrea_ent($value)
	{

	}

	protected function nbActio($value)
	{
		if ( array_key_exists('in', $value) ) {
			$min = $value['in'][0];
			$max = $value['in'][1];
			$this->setFilterRange('nbActio', $min, $max);
		}
	}

	protected function nbPart($value)
	{
		if ( array_key_exists('in', $value) ) {
			$min = $value['in'][0];
			$max = $value['in'][1];
			$this->setFilterRange('nbPart', $min, $max);
		}
	}

	protected function nbMPubli($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('nbMPubli', $value);
		}
	}

	protected function capital($value)
	{
		if ( array_key_exists('in', $value) ) {
			$min = $value['in'][0];
			$max = $value['in'][1];
			$this->setFilterRange('capital', $min, $max);
		}
	}

	protected function age_entrep($value)
	{
		if ( array_key_exists('in', $value) ) {
			$min = $value['in'][0];
			$max = $value['in'][1];
			$this->setFilterRange('age_entrep', $min, $max);
		}
	}

	protected function age_etab($value)
	{
		if ( array_key_exists('in', $value) ) {
			$min = $value['in'][0];
			$max = $value['in'][1];
			$this->setFilterRange('age_etab', $min, $max);
		}
	}

	protected function teff_entrep($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('teff_entrep', $value);
		}
		if ( array_key_exists('ex', $value) ) {
			$this->setFilter('teff_entrep', $value, true);
		}
	}

	protected function teff_etab($value)
	{
		if ( array_key_exists('in', $value) ) {
			$this->setFilter('teff_etab', $value);
		}
		if ( array_key_exists('ex', $value) ) {
			$this->setFilter('teff_etab', $value, true);
		}
	}

	protected function geo_domtom($value)
	{
		if( $value['in']==1 ) {
			$this->setFilter('adr_dep', array(971, 972, 973, 974, 976), true);
		}
	}
	protected function geo_etranger($value)
	{
		if( $value['in']==1 ) {
			$this->setFilter('adr_dep', array(986, 987, 988), true);
		}
	}
	protected function geo_corse($value)
	{
		if( $value['in']==1 ) {
			$this->setFilter('adr_dep', array(201, 202), true);
		}
	}
}