Subversion Repositories Applications.projet

<?php

/**

 * Service fournissant des informations concernant PROJET au format RSS1, RSS2 ou ATOM.

 * Encodage en entrée : utf8

 * Encodage en sortie : utf8

 *

 * @author Grégoire Duché <gregoire@tela-botanica.org>

 * @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>

 * @license CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>

 * @version $Id: CoelSyndication.php 381 2010-05-17 17:10:37Z jpm $

 * @copyright 2009

 */

class ProjetSyndication extends ProjetService {

    private $format = null;

    private $service = null;

    private $squelette = null;

    private $squelette_dossier = null;

    private $squelette_diff = null;

    private $flux = array();

    /**

     * Méthode appelée avec une requête de type GET.

     */

    public function getElement($param = array()) {

        // Initialisation des variables

        $info = array();

        $contenu = '';

        // Pré traitement des paramètres

        $pour_bdd = false;

        $p = $this->traiterParametresUrl(array('service', 'format'), $param, $pour_bdd);

        // Récupération de la liste des flux

        $this->chargerListeDesFlux();

        // Chargement du bon type de service demandé

        if (isset($p['service'])) {

            $this->service = strtolower($p['service']);

            $methode = $this->getNomMethodeService();

            if (method_exists($this, $methode)) {

                if ($this->service != 'liste_des_flux') {

                    if (isset($p['format']) && preg_match('/^(?:rss1|rss2|atom)$/i', $p['format'])) {

                        // Multiplication par deux de la limite car nous récupérons deux lignes par item

                        $this->limit = $this->limit*2;

                        // Mise en minuscule de l'indication du format

                        $this->format = strtolower($p['format']);

                        // Définition du fichier squelette demandé

                        $this->squelette_dossier = dirname(__FILE__).DIRECTORY_SEPARATOR.'squelettes'.DIRECTORY_SEPARATOR;

                        $this->squelette = $this->squelette_dossier.$this->format.'.tpl.xml';

                        $this->squelette_diff = $this->squelette_dossier.'diff.tpl.html';

                    } else {

                        $this->format = '';

                        $this->messages[] = "Le service Projet Syndication nécessite d'indiquer en second paramètre le format : rss1, rss2 ou atom.";

                    }

                }

                // Récupération du contenu à renvoyer

                $contenu = $this->$methode();

            } else {

                $this->messages[] = "Le type d'information demandé '$this->service' n'est pas disponible.";

            }

        } else {

            $this->messages[] = "Le service Projet Syndication nécessite d'indiquer en premier paramètre le type d'information demandé.";

        }

        // Envoie sur la sortie standard

        $encodage = 'utf-8';

        $mime = $this->getTypeMime();

        $formatage_json = $this->getFormatageJson();

        $this->envoyer($contenu, $mime, $encodage, $formatage_json);

    }

    private function getUrlServiceBase() {

        $url_service = $this->config['coel']['urlBaseJrest'].'CoelSyndication/'.$this->service.'/'.$this->format;

        return $url_service;

    }

    private function getNomMethodeService() {

        $methode = '';

        $service_formate = str_replace(' ', '', ucwords(implode(' ', explode('_', $this->service))));

        $methode = 'getService'.$service_formate;

        return $methode;

    }

    private function getTypeMime() {

        $mime = '';

        switch ($this->format) {

            case 'atom' :

                $mime = 'application/atom+xml';

                break;

            case 'rss1' :

            case 'rss2' :

                $mime = 'application/rss+xml';

                break;

            default:

                $mime = 'text/html';

        }

        return $mime;

    }

    private function getFormatageJson() {

        $json = false;

        switch ($this->service) {

            case 'liste_des_flux' :

                $json = true;

                break;

            default:

                $json = false;

        }

        return $json;

    }

    private function getFlux($nom) {

        $nom = strtolower($nom);

        return isset($this->flux[$nom]) ? $this->flux[$nom] : array();

    }

    private function setFlux($nom, $titre, $description) {

        $url_base = $this->config['appli']['urlBaseJrest'].'ProjetSyndication/';

        $formats = array('atom', 'rss2', 'rss1');

        $flux = array();

        foreach ($formats as $format) {

            $url = $url_base.$nom.'/'.$format;

            $flux[$format] = $url;

        }

        $this->flux[$nom] = array('titre' => $titre, 'description' => $description, 'urls' => $flux);

    }

    private function chargerListeDesFlux() {

        $this->setFlux('actifs', 'Flux de syndication des projets les plus actifs',

            'Ce flux fournit des informations sur les  projets les plus actifs de l\'espace projet');

        $this->setFlux('derniers_messages', 'Flux de syndication des derniers messages',

            'Ce flux fournit des informations sur les  derniers messages de l\'espace projet');

    }

    private function getServiceListeDesFlux() {

        return $this->flux;

    }

    private function getServiceActifs() {

        // Construction de la requête

        $requete_projets =  ' select p_id, p_titre as titre, p_resume as description, pl_id_liste, plle_id_liste, p_avoir_document, ps_nombre_inscrit, ps_pourcent,'.

						' p_wikini, ps_doc_derniere_semaine, p_avoir_document, ps_nombre_inscrit_derniere_semaine, '.

						' ps_nombre_membre_yahoo, ps_msg_derniere_semaine, ps_modifwiki_derniere_semaine, p_en_dormance from'.

						' projet left join projet_lien_liste on p_id=pl_id_projet'.

						' left join projet_lien_liste_externe on p_id=plle_id_projet'.

						' left join projet_statistiques on p_id=ps_ce_projet and ps_dernier=1'.

						' WHERE p_en_dormance = 0'.

						' group by p_id order by ps_pourcent desc';

        $elements = $this->executerRequete($requete_projets);

        // Création du contenu

        $contenu = $this->executerService('cpr_nom', $elements);

        return $contenu;

    }

    private function getServiceDerniersMessages() {

	/*include_once("lib/ezmlmAccessObject.class.php");

	$xml_parser = &new ezmlmAccessObject('list_info', 'tela-botanica.org',

			'determination_plantes', 'fr', 'http://localhost') ;

	$xml_parser->load();

	ob_start();

	$resultat = $xml_parser->parse() ;

	$calendrier = ob_get_contents();

	ob_end_clean();*/

    }

    private function executerRequete($requete) {

        try {

            $infos = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);

            if ($infos === false) {

                $this->messages[] = "La requête a retourné aucun résultat.";

            }

        } catch (PDOException $e) {

            $this->messages[] = sprintf($this->getTxt('sql_erreur'), $e->getFile(), $e->getLine(), $e->getMessage());

        }

        return $infos;

    }

    private function executerService($champ_titre, $elements) {

        // Prétraitement des données

        $donnees = $this->construireDonneesCommunesAuFlux($elements);

        foreach ($elements as $element) {

            //$xml = $this->getXmlHisto($element);

            //$enrg = $this->getTableauDepuisXmlHisto($xml);

            //$diff = $this->getDiffInfos($element);

            //$diff['differences'] = $this->getDiff($element);

            //$diff_html = (!is_null($diff['differences'])) ? Coel::traiterSquelettePhp($this->squelette_diff, $diff) : '';

            $item = $this->construireDonneesCommunesAuxItems($element);

            $item['titre'] = $this->creerTitre($champ_titre, $element, $enrg);

            $item['guid'] = sprintf($this->config['appli']['guid'], 'projet', $element['p_id']);

            $item['lien'] = $this->config['appli']['url_base_projet'].'?id_projet='.urlencode($element['p_id']);

	    $item['description'] = "<h4>".$element['ps_nombre_inscrit'].' inscrits - '.$element['ps_msg_derniere_semaine'].' nouveaux messages</h4>';

            $item['description'] .= '<p>'.$this->creerDescription($element, $enrg).'</p>';

            $item['description'] .= $diff_html;

            $item['description'] = $this->nettoyerTexte($item['description']);

            $item['description_encodee'] = htmlspecialchars($item['description']);

            $donnees['items'][] = $item;

        }

        // Création du contenu à partir d'un template PHP

        $contenu = ProjetService::traiterSquelettePhp($this->squelette, $donnees);

        return $contenu;

    }

    private function creerTitre($champ, $element, $enrg) {

        $titre = '';

        if (isset($element['titre'])) {

            $titre = $element['titre'];

        } else if (isset($element[$champ])) {

            $titre = $element[$champ];

        } else if (isset($enrg[$champ])) {

            $titre = $enrg[$champ];

        }

        $titre = $this->nettoyerTexte($titre);

        return $titre;

    }

    private function creerDescription($element, $enrg) {

        $description = '';

        if (isset($element['description'])) {

            $description = strip_tags($element['description']);

        }

        return $description;

    }

    private function nettoyerNomChamps($infos) {

        $sortie = array();

        foreach ($infos as $champ => $valeur) {

            if (preg_match('/^__(.+)$/', $champ, $match)) {

                $sortie[$match[1]] = $valeur;

            } else {

                $sortie[$champ] = $valeur;

            }

        }

        return $sortie;

    }

    private function traiterInfosPrecedentes($infos_courantes, $infos_precedentes) {

        $infos_precedentes_traitees = array();

        foreach ($infos_precedentes as $champ => $valeur) {

            if ($champ == 'cmhl_date_modification') {

                $infos_precedentes_traitees['date_prec'] = $valeur;

            } else if ($champ == 'cmhl_enregistrement') {

                $infos_precedentes_traitees['enrg_prec'] = $valeur;

            } else if (preg_match('/^__(.+)$/', $champ, $match)) {

                $infos_precedentes_traitees[$match[1].'_prec'] = $valeur;

            }

        }

        $sortie = array_merge($infos_courantes, $infos_precedentes_traitees);

        return $sortie;

    }

    private function nettoyerTexte($txt) {

        $txt = preg_replace('/&(?!amp;)/i', '&', $txt, -1);

        return $txt;

    }

    private function getMessageModif($item) {

        $message = $item['etat'].' le '.$item['date_maj_simple'].' par '.$item['modifier_par'].' depuis l\'IP '.$item['ip'];

        return $message;

    }

    private function construireDonneesCommunesAuxItems($info) {

        $item = array();

        $date_modification_timestamp = strtotime($info['cmhl_date_modification']);

        $item['date_maj_simple'] = strftime('%A %d %B %Y à %H:%M', $date_modification_timestamp);

        $item['date_maj_RSS'] = date(DATE_RSS, $date_modification_timestamp);

        $item['date_maj_ATOM'] = date(DATE_ATOM, $date_modification_timestamp);

        $item['date_maj_W3C'] = date(DATE_W3C, $date_modification_timestamp);

        $item['guid'] = $info['cmhl_id_historique_ligne'];

        $item['cle'] = $info['cmhl_cle_ligne'];

        $item['ip'] = $info['cmhl_ip'];

        $item['modifier_par'] = $info['modifier_par'];

        $item['etat'] = isset($info['cmhl_ce_etat']) ? $this->getTexteEtat($info['cmhl_ce_etat']) : '';

        return $item;

    }

    private function getTexteEtat($code) {

        $etat = '';

        switch ($code) {

            case '1' :

                $etat = 'Ajouté';

                break;

            case '2' :

                $etat = 'Modifié';

                break;

            case '3' :

                $etat = 'Supprimé';

                break;

            default :

                $etat = '!Problème!';

                $e = "Le champ cmhl_ce_etat possède une valeur innatendue : $code";

                $this->messages[] = $e;

        }

        return $etat;

    }

    private function construireDonneesCommunesAuFlux($infos) {

        $donnees = $this->getFlux($this->service);

        $donnees['guid'] = $this->getUrlServiceBase();

        $donnees['lien_service'] = $this->creerUrlService();

        $donnees['lien_projet'] = $this->config['appli']['url_base_projet'];

        $donnees['editeur'] = $this->config['coel']['editeur'];

        $derniere_info_en_date = reset($infos);

        $date_modification_timestamp = strtotime($derniere_info_en_date['cmhl_date_modification']);

        $donnees['date_maj_RSS'] = date(DATE_RSS, $date_modification_timestamp);

        $donnees['date_maj_ATOM'] = date(DATE_ATOM, $date_modification_timestamp);

        $donnees['date_maj_W3C'] = date(DATE_W3C, $date_modification_timestamp);

        $donnees['annee_courante'] = date('Y');

        $donnees['generateur'] = 'COEL - Jrest';

        preg_match('/([0-9]+)/', '$Revision: 381 $', $match);

        $donnees['generateur_version'] = $match[1];

        return $donnees;

    }

    private function creerUrlService() {

        $url_service = $this->getUrlServiceBase();

        if (isset($this->start) || isset($this->limit)) {

            $arguments = array();

            if (isset($this->start) && isset($_GET['start'])) {

                $arguments[] = 'start='.$this->start;

            }

            if (isset($this->limit) && isset($_GET['limit'])) {

                $arguments[] = 'limit='.($this->limit/2);

            }

            if (count($arguments) > 0) {

                $url_service .= '?'.implode('&', $arguments);

            }

        }

        return $url_service;

    }

}