Subversion Repositories Sites.tela-botanica.org

Rev

Rev 441 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
439 alex 1
<?php
2
/*vim: set expandtab tabstop=4 shiftwidth=4: */
3
// +------------------------------------------------------------------------------------------------------+
4
// | PHP version 4.1                                                                                      |
5
// +------------------------------------------------------------------------------------------------------+
6
// | Copyright (C) 2004 Tela Botanica (accueil@tela-botanica.org)                                         |
7
// +------------------------------------------------------------------------------------------------------+
8
// | This library is free software; you can redistribute it and/or                                        |
9
// | modify it under the terms of the GNU General Public                                                  |
10
// | License as published by the Free Software Foundation; either                                         |
11
// | version 2.1 of the License, or (at your option) any later version.                                   |
12
// |                                                                                                      |
13
// | This library is distributed in the hope that it will be useful,                                      |
14
// | but WITHOUT ANY WARRANTY; without even the implied warranty of                                       |
15
// | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU                                    |
16
// | General Public License for more details.                                                             |
17
// |                                                                                                      |
18
// | You should have received a copy of the GNU General Public                                            |
19
// | License along with this library; if not, write to the Free Software                                  |
20
// | Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA                            |
21
// +------------------------------------------------------------------------------------------------------+
443 alex 22
// CVS : $Id:$
439 alex 23
/**
24
* Application projet
25
*
26
* Script pour calculer les statistiques
27
*
28
*@package projet
29
//Auteur original :
30
*@author        Alexandre Granier <alexandre@tela-botanica.org>
31
//Autres auteurs :
440 alex 32
*@author        Julien Grillot <julien.grillot@gmail.com>
439 alex 33
*@copyright     Tela-Botanica 2000-2005
443 alex 34
*@version       $Revision:$
439 alex 35
// +------------------------------------------------------------------------------------------------------+
36
*/
37
 
38
// +------------------------------------------------------------------------------------------------------+
39
// |                                            ENTETE du PROGRAMME                                       |
40
// +------------------------------------------------------------------------------------------------------+
41
 
42
 
43
include_once PROJET_CHEMIN_APPLI.'classes/ezmlmAccessObject.class.php';
44
include_once PROJET_CHEMIN_BIBLIOTHEQUE_API.'pear/XML/RSS.php';
440 alex 45
 
46
// Ne pas changer : les groupes Yahoo se basent toujours sur la semaine
439 alex 47
define("NB_SEC_INSERT", 7*24*3600);
48
define("NB_SEC_UPDATE", 2*3600);
49
define("URL_WIKINI", "http://www.tela-botanica.org/wikini/");
50
 
440 alex 51
/**
443 alex 52
 * Retourne le contenu de la page $adresse de facon asynchrone
53
 * @param string $adresse URL de la page dont le contenu doit etre recupere
54
 * @param int timeout temps d'attente maximum avant abandon de la recuperation
55
 */
56
function monFileGetContents($adresse, $timeout = 30){
57
	$url = parse_url($adresse);
58
	$url['port'] = isset($url['port']) ? $url['port'] : '80';
59
	$url['scheme'] = isset($url['scheme']) ? strtoupper($url['scheme']) : 'HTTP';
60
	$fp = fsockopen($url['host'], $url['port'], $errno, $errstr, $timeout);
61
	if (!$fp) {
62
		echo "Erreur de socket: $errno - $errstr<br />\n";
63
		return false;
64
	} else {
65
		$header  = 'GET '.$url['path'].' '.$url['scheme']."/1.1\r\n";
66
 
67
		$header .= "Host: www.yahoo.com\r\n";
68
		$header .= "User-Agent: Mozilla/5.0 (X11; U; Linux i686; en-US; rv:1.2.1) Gecko/20021204\r\n";
69
		$header .= "Referer: http://www.yahoo.com/\r\n";
70
 
71
		$header .= 'Connection: Close\r\n\r\n';
72
 
73
		fputs($fp, $header);
74
		stream_set_timeout($fp, $timeout);
75
		while (!feof($fp)) {
76
			$page .= fread($fp, 262144);
77
		}
78
		$stream  = stream_get_meta_data($fp);
79
		fclose($fp);
80
		if ($stream['timed_out']) {
81
			echo 'Le d�lai de r�ponse de la page <b>'.$adresse.'</b> a d�pass� le timeout de <b>'.$timeout.'</b> sec.';
82
			return false;
83
		}else{
84
			return $page;
85
		}
86
	}
87
}
88
 
89
/**
440 alex 90
 * Procedure retrouvant le nombre de contribution, de message et le contenu de la page a partir des informations de la BDD
91
 * @param object $ligne resultat d'un fetch row contenant l'url du document a analyser
92
 * @param int $nombre_contrib recupere le nombre de contributions du projet
93
 * @param int $nombre_message recupere le nombre de nouveaux messages du projet
443 alex 94
 * @param int $nombre_membre recupere le nombre de nouveaux messages du projet
95
 * @param int $nombre_photo recupere le nombre de nouveaux messages du projet
440 alex 96
 * @return false si la fonction echoue lors de la tentative de recuperation des donnees utiles
97
 */
443 alex 98
function analyser($ligne, &$res, &$nombre_contrib, &$nombre_message, &$nombre_membre, &$nombre_photo) {
439 alex 99
	$nombre_contrib='0';
100
	$nombre_msg='0';
101
	$r=false;
102
 
103
	// Recuperation du nbre de message
104
	$xml_parser = &new ezmlmAccessObject('nombre_messages', $ligne->pl_domaine, $ligne->pl_nom_liste, $GLOBALS['lang']) ;
105
	$xml_parser->load();
106
 
107
	ob_start();
108
	$xml_parser->parse();
109
	$nombre_message = ob_get_contents();
110
	if(!$nombre_message)$nombre_message='0';
111
	ob_end_clean();
112
 
440 alex 113
	// Si AGO_A_NOMGRP alors il n'y a pas de flux RSS (groupe Yahoo, cad pas Tela)
439 alex 114
	if($ligne->AGO_A_NOMGRP) {
115
		$url='http://fr.groups.yahoo.com/group/'.$ligne->AGO_A_NOMGRP;
440 alex 116
 
117
		// Recherche du schema retrouvant le nombre de nouveaux message dans la semaine
443 alex 118
		$pattern1='>([0-9]+)</span> .ouveaux? .embres?';
119
		$pattern2='>([0-9]+)</span> .ouveaux? .essages?';
120
		$pattern3='>([0-9]+)</span> .ouvelles? .hotos?';
439 alex 121
 
443 alex 122
		// Quelques soucis avec la version asynchrone
123
		//$contenu=monFileGetContents($url);
441 alex 124
		$contenu=file_get_contents($url);
443 alex 125
		usleep(3000000);
439 alex 126
		$r=($contenu?true:false);
443 alex 127
		ereg($pattern2, $contenu, $no);
439 alex 128
		$nombre_message=$no[1];
440 alex 129
 
443 alex 130
		ereg($pattern1, $contenu, $no);
131
		$nombre_membre=$no[1];
132
 
133
		ereg($pattern3, $contenu, $no);
134
		$nombre_photo=$no[1];
135
 
439 alex 136
	} else {
443 alex 137
		// Parse le flux RSS g�n�r� par wikini
439 alex 138
		$rss =& new XML_RSS(URL_WIKINI.$ligne->p_wikini.'/wakka.php?wiki=DerniersChangementsRSS/xml');
139
		$rss->parse();
140
 
141
		// On va compter le nombre de modification depuis les x derniers jours (voirs constantes)
142
		foreach ($rss->getItems() as $item) {
443 alex 143
			// Le script doit �tre compatiable avec plusieurs formats de date
439 alex 144
			if ($item['pubDate']) {
145
				if (strtotime($item['pubDate'])>time()-NB_SEC_INSERT) $nombre_contrib++;
146
 
147
			} else {
148
				$date = substr($item['title'], strlen($item['title'])-18);
149
				if ($date>date("Y m d - H:i", time()-NB_SEC_INSERT)) $nombre_contrib++;
150
			}
151
		}
152
 
153
		$r=true;
154
 
155
	}
156
 
157
	return $r;
158
}
159
 
440 alex 160
// Pour calculer le temps d'execution du script
439 alex 161
$start=microtime(true);
162
 
163
 
164
// +------------------------------------------------------------------------------------------------------+
165
// |                                            CORPS du PROGRAMME                                       |
166
// +------------------------------------------------------------------------------------------------------+
167
 
168
 
169
// requete pour recuperer la liste des projets
170
$requete = 'select count(distinct psu_id_utilisateur) as nb_utilisateur, count(distinct pil_id_utilisateur) as nb_utilisateur_liste, count(distinct projet_documents.pd_id) as nb_doc, p_wikini, ' .
171
		'p_id, p_titre, p_resume, projet_lien_liste.pl_id_liste, pl_domaine,pl_nom_liste,AGO_A_NOMGRP ' .
172
		'from projet left join projet_lien_liste on p_id=projet_lien_liste.pl_id_projet ' .
173
		'left join projet_liste on projet_lien_liste.pl_id_liste=projet_liste.pl_id_liste ' .
174
		'left join projet_inscription_liste on (projet_inscription_liste.pil_id_liste=projet_liste.pl_id_liste and pil_date_inscription > date_sub(now(), interval 1 week)) ' .
175
		'left join projet_documents on (p_id=pd_ce_projet and  pd_date_de_mise_a_jour > date_sub(now(), interval 1 week)) ' .
176
		'left join projet_statut_utilisateurs on p_id=psu_id_projet ' .
177
		'left join projet_lien_liste_externe on plle_id_projet=p_id ' .
178
		'left join agora on plle_id_liste=AGO_A_ID ' .
443 alex 179
		'group by p_id order by p_titre limit 0,15' ;
441 alex 180
 
439 alex 181
$resultat = $this->_db->query($requete) ;
182
if (DB::isError($resultat)) {
183
	return ("Echec de la requete<br />".$resultat->getMessage()."<br />".$resultat->getDebugInfo()) ;
184
}
185
$res .= '<h1>Statistiques des projets</h1>';
186
 
440 alex 187
// Un tableau c'est bien mais un beau tableau c'est mieux.
439 alex 188
$res .= '<style type="text/css">';
189
$res .= '.stats { border-spacing: 0px; }';
190
$res .= '.stats .stat_nb { text-align: center; }';
191
$res .= '.stats th { font-weight: bold; }';
192
$res .= '.stats td { border-bottom: 1px #ddd solid; }';
193
$res .= '.warning { color: #800; font-weight: bold; }';
194
$res .= '</style>';
195
 
196
$calculs=false;
197
 
198
$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>';
199
 
200
$nombre_contrib = 0;
201
$nombre_message = 0;
202
 
203
while ($ligne = $resultat->fetchRow(DB_FETCHMODE_OBJECT)) {
204
	$nombre_contrib = 0;
205
	$nombre_message = 0;
206
 
443 alex 207
	// On verifie la date de derniere mise � jour
439 alex 208
	$requete_verif='SELECT * FROM projet_statistiques WHERE ps_ce_projet="'.$ligne->p_id.'" ORDER BY ps_date DESC LIMIT 1';
209
	$resultat_verif = $this->_db->query($requete_verif);
210
	if (DB::isError($resultat_verif)) {
211
		return $resultat_verif->getMessage().$resultat_verif;
212
	}
213
	$ligne_verif = $resultat_verif->fetchRow(DB_FETCHMODE_OBJECT);
214
 
443 alex 215
	// Si elle remonte a plus de deux heure, on sauvegarde, et a plus de 7 jours, on archive et cr�� une nouvelle entr�e
439 alex 216
	if($ligne_verif->ps_date > date("Y-m-d H:i:s", time()-NB_SEC_INSERT)) {
217
		if($ligne_verif->ps_maj < date("Y-m-d H:i:s", time()-NB_SEC_UPDATE)) {
218
 
219
			// Recupere nombre_contrib et nombre_message
443 alex 220
			$calculs=analyser($ligne, $res, $nombre_contrib, $nombre_message, $nombre_membre, $nombre_photo);
439 alex 221
 
222
			$requete_maj = 'UPDATE projet_statistiques SET ps_msg_derniere_semaine="'.$nombre_message.'", ps_doc_derniere_semaine="'.$ligne->nb_doc.'", ps_nombre_inscrit="'.$ligne->nb_utilisateur.'", ps_nombre_inscrit_liste="'.$ligne->nb_utilisateur_liste.'", ps_modifwiki_derniere_semaine="'.$nombre_contrib.'", ps_maj=NOW() WHERE ps_ce_projet="'.$ligne->p_id.'" AND ps_date="'.$ligne->ps_date.'"';
223
			$resultat_maj = $this->_db->query($requete_maj);
224
			if (DB::isError($resultat_maj)) {
225
				return $resultat_maj->getMessage().$requete_maj;
226
			}
227
		} else {
228
 
229
			$nombre_contrib = $ligne_verif->ps_modifwiki_derniere_semaine;
230
			$nombre_message = $ligne_verif->ps_msg_derniere_semaine;
231
 
232
		}
233
 
234
	} else {
235
 
236
		// Recupere nombre_contrib et nombre_message
440 alex 237
		$calculs=analyser($ligne, $nombre_contrib, $nombre_message);
439 alex 238
 
239
		$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) '.
240
						'VALUES ("'.$ligne->p_id.'", "'.$nombre_message.'", "'.$ligne->nb_doc.'", "'.$ligne->nb_utilisateur.'", "'.$ligne->nb_utilisateur_liste.'", "'.$nombre_contrib.'", NOW(), NOW())';
241
		$resultat_maj = $this->_db->query($requete_maj);
242
		if (DB::isError($resultat_maj)) {
243
			return $resultat_maj->getMessage().$requete_maj;
244
		}
245
	}
246
 
247
	// Et on affiche les stats courantes
248
	$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>';
249
}
250
$res .= '</table>';
251
 
440 alex 252
// Met a jour les statistiques et somme d'activite
439 alex 253
$sql="update `projet_statistiques` set ps_somme=(ps_msg_derniere_semaine +ps_doc_derniere_semaine+ps_nombre_inscrit_liste+ps_modifwiki_derniere_semaine);";
254
$resultat = $this->_db->query($sql);
255
if (DB::isError($resultat)) {
256
	return $resultat->getMessage().$sql;
257
}
258
 
440 alex 259
// On cherche le max pour ponderer les sommes
439 alex 260
$sql='SELECT MAX( ps_somme ) AS max FROM projet_statistiques WHERE ps_date>=CURDATE()';
261
$resultat = $this->_db->query($sql);
262
if (DB::isError($resultat)) {
263
	return $resultat->getMessage().$sql;
264
}
265
$tresultat = $resultat->fetchRow(DB_FETCHMODE_OBJECT);
266
 
440 alex 267
// On pondere
439 alex 268
$sql="UPDATE `projet_statistiques` SET ps_pourcent=ps_somme / ".($tresultat->max?$tresultat->max:1)." * 100 WHERE ps_date>=CURDATE();";
269
$resultat = $this->_db->query($sql);
270
if (DB::isError($resultat)) {
271
	return $resultat->getMessage().$sql;
272
}
273
 
440 alex 274
// On affiche quelques infos inutiles mais indispensables
439 alex 275
$res .= '<p>';
276
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 />';
277
$res .= 'Execut&eacute; en '.(round((microtime(true)-$start)*1000)/1000).' secondes.</p>';
278
 
279
return $res;
280
 
281
/* +--Fin du code ---------------------------------------------------------------------------------------+
443 alex 282
* $Log:$
439 alex 283
* +--Fin du code ----------------------------------------------------------------------------------------+
284
*/
285
?>