2010-10-14 14:06:05 +00:00
< ?
include_once ( FWK_PATH . 'common/strings.php' );
include_once ( FWK_PATH . 'sphinx/sphinxapi2.php' );
function search2 ( $index , $findMe , $tabFiltres = array (), $deb = 0 , $nbRep = 20 , $max = 200 , $any = false ) {
$deb = $deb * 1 ;
$nbRep = $nbRep * 1 ;
$max = $max * 1 ;
debugLog ( 'I' , " Search Sphinx dans $index de $findMe ( $deb , $nbRep , $max ) avec " . implode ( ',' , $tabFiltres ), __LINE__ , __FILE__ , __FUNCTION__ , __CLASS__ );
$iDb = new WDB ();
/*
$cl = new SphinxClient ();
$cl -> SetServer ( $host , $port );
$cl -> SetWeights ( array ( 100 , 1 ) );
$cl -> SetMatchMode ( $mode );
if ( count ( $filtervals ) ) $cl -> SetFilter ( $filter , $filtervals );
if ( $groupby ) $cl -> SetGroupBy ( $groupby , SPH_GROUPBY_ATTR , $groupsort );
if ( $sortby ) $cl -> SetSortMode ( SPH_SORT_EXTENDED , $sortby );
if ( $sortexpr ) $cl -> SetSortMode ( SPH_SORT_EXPR , $sortexpr );
if ( $distinct ) $cl -> SetGroupDistinct ( $distinct );
if ( $limit ) $cl -> SetLimits ( 0 , $limit , ( $limit > 1000 ) ? $limit : 1000 );
$res = $cl -> Query ( $q , $index );
*/
//$any = false; // si false $index='xxx'
$cl = new SphinxClient ();
$cl -> SetServer ( SPHINX_HOST , SPHINX_PORT );
$cl -> SetConnectTimeout ( 1 );
$cl -> SetLimits ( $deb , $nbRep , $max ); //0, $nbRep*10);
//$cl->SetSortMode(SPH_SORT_ATTR_DESC, 'actif');//siege');
if ( substr ( $index , 0 , 4 ) == 'etab' )
$cl -> SetSortMode ( SPH_SORT_EXTENDED , 'rang DESC, actif DESC, siege DESC' ); //, nic DESC
//$cl->SetWeights ( array ( 100, 1 ) );
//$cl->SetMatchMode ( $any ? SPH_MATCH_ANY : SPH_MATCH_ALL );
$cl -> SetMatchMode ( SPH_MATCH_EXTENDED );
foreach ( $tabFiltres as $nomFiltre => $valFiltre )
$cl -> SetFilter ( $nomFiltre , array ( 0 => $valFiltre ));
$cl -> SetRankingMode ( SPH_RANK_PROXIMITY_BM25 );
//$cl->SetArrayResult ( true );
$res = $cl -> Query ( $findMe , $index );
//@sendMail('production@scores-decisions.com', 'ylenaour@scores-decisions.com', "Debug", print_r($res,true)) ;
if ( $res === false ) {
2010-10-15 07:25:50 +00:00
debugLog ( 'I' , " Search Sphinx : Pas de réponse pour $findMe avec " . implode ( ',' , $tabFiltres ) . ' (' . $cl -> GetLastError () . ')' , __LINE__ , __FILE__ , __FUNCTION__ , __CLASS__ );
2010-10-14 14:06:05 +00:00
return array ( 'results' => false ,
'nbRet' => 0 ,
'nbTot' => 0 ,
'duration' => $res [ time ]); //return false;
2010-10-15 07:25:50 +00:00
} else { // Le moteur est opérationel
2010-10-14 14:06:05 +00:00
if ( $cl -> GetLastWarning () ) {
debugLog ( 'I' , " Search Sphinx : Warning pour $findMe - " . $cl -> GetLastWarning (), __LINE__ , __FILE__ , __FUNCTION__ , __CLASS__ );
print " WARNING: " . $cl -> GetLastWarning () . " \n \n " ;
}
/* print " Query ' $findMe ' retrieved $res[total] of $res[total_found] matches in $res[time] sec. \n " ;
print " Query stats : \n " ;
if ( is_array ( $res [ " words " ]) )
foreach ( $res [ " words " ] as $word => $info )
print " - ' $word ' found $info[hits] times in $info[docs] documents \n " ;
print " \n " ; */
debugLog ( 'I' , " 'Search Sphinx dans $index de $findMe (Filtre= " . implode ( ',' , $tabFiltres ) . " ), Deb= $deb , nbRep= $nbRep , max= $max , any= $any " , __LINE__ , __FILE__ , __FUNCTION__ , __CLASS__ );
// debugLog('I',"Search Sphinx dans $index ". print_r($tabFiltres, true));
$tabRet = array ();
2010-10-15 07:25:50 +00:00
if ( @ is_array ( $res [ 'matches' ])) { // il y a des données à renvoyer
if ( substr ( $index , 0 , 4 ) == 'etab' ) { // Recherche par étab
2010-10-14 14:06:05 +00:00
foreach ( $res [ 'matches' ] as $doc => $docinfo ) { // On balaye chaque ligne
$listeEtab = $iDb -> select ( 'etablissements e' ,
" 'Etab' as Loc, e.id, e.source, e.source_id, e.triCode, e.autre_id, e.siren, e.nic, e.siege, " .
" e.raisonSociale, e.enseigne, e.sigle, e.adr_num, e.adr_btq, e.adr_typeVoie, e.adr_libVoie, " .
" e.adr_comp, e.adr_cp, e.adr_ville, e.tel, e.fax, e.cj, e.ape_etab, e.ape_entrep, " .
" CONCAT(e.siren, e.nic) as siret, e.actif " ,
" id= $doc LIMIT 0,1 " , true );
$etab = $listeEtab [ 0 ];
$tabRet [] = array ( 'Localisation' => $etab [ 'Loc' ],
'id' => $doc ,
'Pertinence' => $docinfo [ 'weight' ],
'Siret' => $etab [ 'siret' ],
'Siege' => $etab [ 'siege' ],
'Nom' => $etab [ 'raisonSociale' ],
'Sigle' => $etab [ 'sigle' ],
'Enseigne' => $etab [ 'enseigne' ],
'Adresse' => trim ( $etab [ 'adr_num' ] . ' ' .
$etab [ 'adr_btq' ] . ' ' .
$etab [ 'adr_typeVoie' ] . ' ' .
$etab [ 'adr_libVoie' ] . ' ' .
$etab [ 'adr_comp' ]),
'CP' => $etab [ 'adr_cp' ],
'Ville' => $etab [ 'adr_ville' ],
'Tel' => $etab [ 'tel' ],
'Fax' => $etab [ 'fax' ],
'FJ' => $etab [ 'cj' ],
'Siren' => $etab [ 'siren' ],
'Nic' => $etab [ 'nic' ],
'Actif' => $etab [ 'actif' ],
'NafEtab' => $etab [ 'ape_etab' ], // Etablissement
//'NafEtabLib'=>$etab['LibNafEt'],
'NafEnt' => $etab [ 'ape_entrep' ], // Entreprise
//'NafEntLib'=>$etab['LibNafEt'],
);
}
} elseif ( $index == 'idx_histo' ) {
foreach ( $res [ 'matches' ] as $doc => $docinfo ) {
$listeEtab = $iDb -> select ( 'histobodacc.bodacc_ocr' ,
" 'Histo' as Loc, id, nomFichier, annee1, bod, texte " ,
" id= $doc " );
$etab = $listeEtab [ 0 ];
$tabRet [] = array ( 'Localisation' => $etab [ 'Loc' ],
'id' => $doc ,
'Pertinence' => $docinfo [ 'weight' ],
'Fichier' => $etab [ 'nomFichier' ],
'Annee' => $etab [ 'annee1' ],
'Code' => $etab [ 'bod' ],
'Texte' => $etab [ 'texte' ],
);
}
} else { // Recherche par dirigeant
$findMe4 = trim ( substr ( $findMe , 0 , 4 ));
foreach ( $res [ 'matches' ] as $doc => $docinfo ) { // On balaye chaque ligne dirigeant
/* $listeEtab = $iDb -> select ( 'bodacc_dirigeants d, bodacc_detail b, etablissements e' ,
" 'Etab' as Loc, e.id, e.source, e.source_id, e.triCode, e.autre_id, e.siren, e.nic, e.siege, " .
" e.raisonSociale, e.enseigne, e.sigle, e.adr_num, e.adr_btq, e.adr_typeVoie, e.adr_libVoie, " .
" e.adr_comp, e.adr_cp, e.adr_ville, e.tel, e.fax, e.cj, e.ape_etab, e.ape_entrep, " .
" CONCAT(e.siren, e.nic) as siret, d.rs, d.nom, d.prenom, d.nomUsage, " .
" d.dateEffet, d.fonction, d.depart, e.actif " ,
" d.id= $doc AND d.id=b.id AND b.siren=e.siren AND (d.nom LIKE '% $findMe4 %' OR d.prenom LIKE '% $findMe4 %' OR d.nomUsage LIKE '% $findMe4 %' OR d.rs LIKE '% $findMe4 %') LIMIT 0,1 " , true );
if ( count ( $listeEtab ) == 0 )
$listeEtab = $iDb -> select ( 'bodacc_dirigeants d, bodacc_detail b, etablissements e' ,
" 'Etab' as Loc, e.id, e.source, e.source_id, e.triCode, e.autre_id, e.siren, e.nic, e.siege, " .
" e.raisonSociale, e.enseigne, e.sigle, e.adr_num, e.adr_btq, e.adr_typeVoie, e.adr_libVoie, " .
" e.adr_comp, e.adr_cp, e.adr_ville, e.tel, e.fax, e.cj, e.ape_etab, e.ape_entrep, " .
" CONCAT(e.siren, e.nic) as siret, d.rs, d.nom, d.prenom, d.nomUsage, " .
" d.dateEffet, d.fonction, d.depart, e.actif " ,
" d.id= $doc AND d.id=b.id AND b.siren=e.siren LIMIT 0,1 " , true );
$etab = $listeEtab [ 0 ];
$tabRet [] = array ( 'Localisation' => $etab [ 'Loc' ],
'id' => $doc ,
'Pertinence' => $docinfo [ 'weight' ],
'Siret' => $etab [ 'siret' ],
'Siege' => $etab [ 'siege' ],
'Nom' => $etab [ 'raisonSociale' ],
'Sigle' => $etab [ 'sigle' ],
'Enseigne' => $etab [ 'enseigne' ],
'Adresse' => trim ( $etab [ 'adr_num' ] . ' ' .
$etab [ 'adr_btq' ] . ' ' .
$etab [ 'adr_typeVoie' ] . ' ' .
$etab [ 'adr_libVoie' ] . ' ' .
$etab [ 'adr_comp' ]),
'CP' => $etab [ 'adr_cp' ],
'Ville' => $etab [ 'adr_ville' ],
'Tel' => $etab [ 'tel' ],
'Fax' => $etab [ 'fax' ],
'FJ' => $etab [ 'cj' ],
'Siren' => $etab [ 'siren' ],
'Nic' => $etab [ 'nic' ],
'Actif' => $etab [ 'actif' ],
'NafEtab' => $etab [ 'ape_etab' ], // Etablissement
'NafEnt' => $etab [ 'ape_entrep' ], // Entreprise
'rs' => $etab [ 'rs' ],
'nomD' => $etab [ 'nom' ],
'prenom' => $etab [ 'prenom' ],
'nomUsage' => $etab [ 'nomUsage' ],
'dateEffet' => $etab [ 'dateEffet' ],
'fonction' => $etab [ 'fonction' ],
'depart' => $etab [ 'depart' ],
);
}
*/
//print_r($tabRet);
//die();
$listeEtab = $iDb -> select ( 'rncs_dirigeants d, etablissements e' ,
" 'Etab' as Loc, e.id, e.source, e.source_id, e.triCode, e.autre_id, e.siren, e.nic, e.siege, " .
" e.raisonSociale, e.enseigne, e.sigle, e.adr_num, e.adr_btq, e.adr_typeVoie, e.adr_libVoie, " .
" e.adr_comp, e.adr_cp, e.adr_ville, e.tel, e.fax, e.cj, e.ape_etab, e.ape_entrep, " .
" CONCAT(e.siren, e.nic) as siret, /*d.rs,*/ d.nom, d.prenom, /*d.nomUsage,*/ d.naissance_date, d.naissance_lieu, " .
" d.fonction_lib, /*d.depart,*/ e.actif " ,
" d.id= $doc AND d.siren=e.siren AND e.siege=1 ORDER BY e.actif DESC LIMIT 0,1 " , true );
//die(print_r($listeEtab));
$etab = $listeEtab [ 0 ];
$tabRet [] = array ( 'Localisation' => $etab [ 'Loc' ],
'id' => $doc ,
'Pertinence' => $docinfo [ 'weight' ],
'Siret' => $etab [ 'siret' ],
'Siege' => $etab [ 'siege' ],
'Nom' => $etab [ 'raisonSociale' ],
'Sigle' => $etab [ 'sigle' ],
'Enseigne' => $etab [ 'enseigne' ],
'Adresse' => trim ( $etab [ 'adr_num' ] . ' ' .
$etab [ 'adr_btq' ] . ' ' .
$etab [ 'adr_typeVoie' ] . ' ' .
$etab [ 'adr_libVoie' ] . ' ' .
$etab [ 'adr_comp' ]),
'CP' => $etab [ 'adr_cp' ],
'Ville' => $etab [ 'adr_ville' ],
'Tel' => $etab [ 'tel' ],
'Fax' => $etab [ 'fax' ],
'FJ' => $etab [ 'cj' ],
'Siren' => $etab [ 'siren' ],
'Nic' => $etab [ 'nic' ],
'Actif' => $etab [ 'actif' ],
'NafEtab' => $etab [ 'ape_etab' ], // Etablissement
'NafEnt' => $etab [ 'ape_entrep' ], // Entreprise
'rs' => '' , //$etab['rs'],
'nomD' => $etab [ 'nom' ],
'prenom' => $etab [ 'prenom' ],
'nomUsage' => '' , //$etab['nomUsage'],
'dateEffet' => '' , //$etab['dateEffet'],
'fonction' => $etab [ 'fonction_lib' ],
'depart' => 0 , //$etab['depart'],
);
}
}
}
}
debugLog ( 'I' , 'Search Sphinx : Retourne ' . $res [ total ] . '/' . $res [ total_found ] . ' en ' . $res [ time ] . 'secondes' , __LINE__ , __FILE__ , __FUNCTION__ , __CLASS__ );
return array ( 'results' => $tabRet ,
'nbRet' => $res [ total ],
'nbTot' => $res [ total_found ],
'duration' => $res [ time ],
'words' => $res [ 'words' ],
);
}
?>
