WebSVN – Sites.tela-botanica.org – Diff – //trunk/client/projet/services/projet_statistiques.php

+*
 *@package projet
 //Auteur original :
 *@author        Alexandre Granier <alexandre@tela-botanica.org>
 //Autres auteurs :
-*@author        Aucun
+*@author        Julien Grillot <julien.grillot@gmail.com>
 *@copyright     Tela-Botanica 2000-2005
 *@version       $Revision:$
 // +------------------------------------------------------------------------------------------------------+
 */
 // +------------------------------------------------------------------------------------------------------+
+include_once PROJET_CHEMIN_APPLI.'classes/ezmlmAccessObject.class.php';
+include_once PROJET_CHEMIN_BIBLIOTHEQUE_API.'pear/XML/RSS.php';
 include_once PROJET_CHEMIN_APPLI.'classes/ezmlmAccessObject.class.php';
-include_once PROJET_CHEMIN_BIBLIOTHEQUE_API.'pear/XML/RSS.php';
+// Ne pas changer : les groupes Yahoo se basent toujours sur la semaine
-define("NB_SEC_INSERT", 7*24*3600);
-define("NB_SEC_UPDATE", 2*3600);
-//if(!set_time_limit(100))return 'Impossible de changer le temps max d\execution';
+define("NB_SEC_INSERT", 7*24*3600);
+define("NB_SEC_UPDATE", 2*3600);
-//define("URL_WIKINI", "http://www.outils-reseaux.org/wikini/");
+define("URL_WIKINI", "http://www.tela-botanica.org/wikini/");
-define("URL_WIKINI", "http://www.tela-botanica.org/wikini/");
-function CurlFileGetContents($adresse, $timeout = 30){
-  $ch = curl_init($adresse);
-  curl_setopt($ch, CURLOPT_HEADER, 0);
+/**
-  curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
-  curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1)");
-  curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
-  $page    = curl_exec($ch);
-  $CurlErr = curl_error($ch);
-  curl_close($ch);
-  if ($CurlErr){
-    echo $CurlErr;
-    return false;
+ * Retourne le contenu de la page $adresse de facon asynchrone
-  }else{
-    return $page;
  * @param string $adresse URL de la page dont le contenu doit etre recupere
  * @param int timeout temps d'attente maximum avant abandon de la recuperation
  */
 function monFileGetContents($adresse, $timeout = 30){
 	$url = parse_url($adresse);
 	$url['port'] = isset($url['port']) ? $url['port'] : '80';
 	$url['scheme'] = isset($url['scheme']) ? strtoupper($url['scheme']) : 'HTTP';
 	$fp = fsockopen($url['host'], $url['port'], $errno, $errstr, $timeout);
 	if (!$fp) {
 		echo "Erreur de socket: $errno - $errstr<br />\n";
 		return false;
-	} else {
-		$header  = 'GET '.$url['path'].' '.$url['scheme']."/1.1\r\n";
-		//$header .= 'Host: '.$url['host']."\r\n";
+	} else {
-		//$header .= "User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1)\r\n";
+		$header  = 'GET '.$url['path'].' '.$url['scheme']."/1.1\r\n";
 		$header .= "Host: www.yahoo.com\r\n";
 		fclose($fp);
 		if ($stream['timed_out']) {
 			echo 'Le délai de réponse de la page <b>'.$adresse.'</b> a dépassé le timeout de <b>'.$timeout.'</b> sec.';
 			return false;
 		}else{
-			//séparation du header
-    		//$page = substr($page, strpos($page, "\r\n\r\n"));
-    		//$page = trim($page);
-			return 1;
+			return $page;
+		}
+	}
+}
+/**
+ * Procedure retrouvant le nombre de contribution, de message et le contenu de la page a partir des informations de la BDD
+ * @param object $ligne resultat d'un fetch row contenant l'url du document a analyser
+ * @param int $nombre_contrib recupere le nombre de contributions du projet
+ * @param int $nombre_message recupere le nombre de nouveaux messages du projet
+ * @return false si la fonction echoue lors de la tentative de recuperation des donnees utiles
+ */
-function scanner($ligne, &$nombre_contrib, &$nombre_message, &$res) {
+function analyser($ligne, &$nombre_contrib, &$nombre_message) {
 	$nombre_contrib='0';
 	$nombre_msg='0';
 	$r=false;
 	$xml_parser->parse();
 	$nombre_message = ob_get_contents();
 	if(!$nombre_message)$nombre_message='0';
 	ob_end_clean();
-	// Parse le flux RSS généré par wikini
+	// Si AGO_A_NOMGRP alors il n'y a pas de flux RSS (groupe Yahoo, cad pas Tela)
 	if($ligne->AGO_A_NOMGRP) {
-		$url='http://fr.groups.yahoo.com/group/'.$ligne->AGO_A_NOMGRP;
-		$pattern='>([0-9]+)</span> nouveau';
-		$contenu=file_get_contents($url);
-		//$contenu=CurlFileGetContents($url);
+		$url='http://fr.groups.yahoo.com/group/'.$ligne->AGO_A_NOMGRP;
-		//$contenu=monFileGetContents($url);
+		// Recherche du schema retrouvant le nombre de nouveaux message dans la semaine
 		$pattern='>([0-9]+)</span> nouveau';
-		$res.=$contenu;
+		$contenu=monFileGetContents($url);
-		$r=($contenu?true:false);
+		$r=($contenu?true:false);
 		ereg($pattern, $contenu, $no);
+		$nombre_message=$no[1];
 		$nombre_message=$no[1];
-		//$rss =& new XML_RSS($url.'/rss');
+	} else {
-	} else {
+		// Parse le flux RSS généré par wikini
+	}
 	return $r;
+}
 // Pour calculer le temps d'execution du script
 $start=microtime(true);
 if (DB::isError($resultat)) {
 	return ("Echec de la requete<br />".$resultat->getMessage()."<br />".$resultat->getDebugInfo()) ;
+}
 $res .= '<h1>Statistiques des projets</h1>';
 // Un tableau c'est bien mais un beau tableau c'est mieux.
 $res .= '<style type="text/css">';
 $res .= '.stats { border-spacing: 0px; }';
 $res .= '.stats .stat_nb { text-align: center; }';
 $res .= '.stats th { font-weight: bold; }';
 $res .= '.stats td { border-bottom: 1px #ddd solid; }';
 $res .= '.warning { color: #800; font-weight: bold; }';
 $res .= '</style>';
 $calculs=false;
 $calculs=false;
 //*
 $res .= '<table cellspacing="0" class="stats" style="width: 100%"><tr><th>Nom du projet</th><th>Nom liste</th><th>Inscrits</th><th>Utilisateurs</th><th>Nb msg</th><th>Nb doc</th><th>Nb contrib</th></tr>';
 $nombre_contrib = 0;
 $nombre_message = 0;
 while ($ligne = $resultat->fetchRow(DB_FETCHMODE_OBJECT)) {
 	$nombre_contrib = 0;
 	$nombre_message = 0;
-	// On vérifie la date de derniere mise à jour
+	// On verifie la date de derniere mise à jour
 	$requete_verif='SELECT * FROM projet_statistiques WHERE ps_ce_projet="'.$ligne->p_id.'" ORDER BY ps_date DESC LIMIT 1';
 	$resultat_verif = $this->_db->query($requete_verif);
 	if (DB::isError($resultat_verif)) {
 		return $resultat_verif->getMessage().$resultat_verif;
 	}
 	$ligne_verif = $resultat_verif->fetchRow(DB_FETCHMODE_OBJECT);
-	// Si elle remonte à plus de deux heure, on sauvegarde, et à plus de 7 jours, on archive et créé une nouvelle entrée
+	// Si elle remonte a plus de deux heure, on sauvegarde, et a plus de 7 jours, on archive et créé une nouvelle entrée
 	if($ligne_verif->ps_date > date("Y-m-d H:i:s", time()-NB_SEC_INSERT)) {
+		}
 	} else {
 		// Recupere nombre_contrib et nombre_message
-		$calculs=scanner($ligne, $nombre_contrib, $nombre_message, $res);
+		$calculs=analyser($ligne, $nombre_contrib, $nombre_message);
 		$requete_maj = 'INSERT INTO projet_statistiques (ps_ce_projet, ps_msg_derniere_semaine, ps_doc_derniere_semaine, ps_nombre_inscrit, ps_nombre_inscrit_liste, ps_modifwiki_derniere_semaine, ps_date, ps_maj) '.
 	// Et on affiche les stats courantes
 	$res .= '<tr><td>'.$ligne->p_titre.'</td><td>'.($ligne->pl_nom_liste?$ligne->pl_nom_liste:$ligne->AGO_A_NOMGRP.' (Yahoo)').'</td><td class="stat_nb">'.$ligne->nb_utilisateur_liste.'</td><td class="stat_nb">'.$ligne->nb_utilisateur.'</td><td class="stat_nb">'.$nombre_message.'</td><td class="stat_nb">'.$ligne->nb_doc.'</td><td class="stat_nb">'.$nombre_contrib.'</td></tr>';
+}
-$res .= '</table>';
+$res .= '</table>';
 //*/
 // Met a jour les statistiques et somme d'activite
 $sql="update `projet_statistiques` set ps_somme=(ps_msg_derniere_semaine +ps_doc_derniere_semaine+ps_nombre_inscrit_liste+ps_modifwiki_derniere_semaine);";
 $resultat = $this->_db->query($sql);
 if (DB::isError($resultat)) {
+	return $resultat->getMessage().$sql;
 	return $resultat->getMessage().$sql;
 // On cherche le max pour ponderer les sommes
 $sql='SELECT MAX( ps_somme ) AS max FROM projet_statistiques WHERE ps_date>=CURDATE()';
 $resultat = $this->_db->query($sql);
 if (DB::isError($resultat)) {
+	return $resultat->getMessage().$sql;
 	return $resultat->getMessage().$sql;
 $tresultat = $resultat->fetchRow(DB_FETCHMODE_OBJECT);
 $tresultat = $resultat->fetchRow(DB_FETCHMODE_OBJECT);
 // On pondere
 $sql="UPDATE `projet_statistiques` SET ps_pourcent=ps_somme / ".($tresultat->max?$tresultat->max:1)." * 100 WHERE ps_date>=CURDATE();";
+$resultat = $this->_db->query($sql);
-$resultat = $this->_db->query($sql);
+if (DB::isError($resultat)) {
-if (DB::isError($resultat)) {
+	return $resultat->getMessage().$sql;
 	return $resultat->getMessage().$sql;
-}
-$res .= '<p>';
+// On affiche quelques infos inutiles mais indispensables
-if(!$calculs)$res .= '<span class="warning">Les variables nb_msg et nb_contrib n\'ont pas &eacute;t&eacute; calcul&eacute;es (datent de moins de '.round(NB_SEC_UPDATE/3600).' heures)</span><br />';
+$res .= '<p>';
-$res .= 'Execut&eacute; en '.(round((microtime(true)-$start)*1000)/1000).' secondes.</p>';
+if(!$calculs)$res .= '<span class="warning">Les variables nb_msg et nb_contrib n\'ont pas &eacute;t&eacute; calcul&eacute;es (datent de moins de '.round(NB_SEC_UPDATE/3600).' heures)</span><br />';

Subversion Repositories Sites.tela-botanica.org

(root)//trunk/client/projet/services/projet_statistiques.php – Rev 439 → 440