Subversion Repositories eFlore/Applications.cel

<?php

/**
* @category  PHP
* @package   jrest
* @author    Raphaël Droz <raphael@tela-botania.org>
* @copyright 2013 Tela-Botanica
* @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
* @license GPL v3 <http://www.gnu.org/licenses/gpl.txt>
*/

/**
 * Service d'import de données d'observation du CEL au format XLS
 */

// sont define()'d commme n° de colonne tous les slugs retournés par ExportXLS::fieldSetsToColumns()
// préfixés par C_  cf: detectionEntete()

set_include_path(get_include_path() . PATH_SEPARATOR . dirname(dirname(realpath(__FILE__))) . '/lib');
// TERM
error_reporting(-1);
ini_set('html_errors', 0);
ini_set('xdebug.cli_color', 2);
require_once('lib/PHPExcel/Classes/PHPExcel.php');
require_once('ExportXLS.php');

class MyReadFilter implements PHPExcel_Reader_IReadFilter {
        public $excludes = array();
        public function __construct() {}
    public function readCell($column, $row, $worksheetName = '') {
                if(@$this->excludes[$column]) return false;
                if($row == 1) return false;
                return true;
    } 
} 

class ImportXLS extends Cel  {

        static $ordre_BDD = Array(
                "ce_utilisateur",
                "prenom_utilisateur",
                "nom_utilisateur",
                "courriel_utilisateur",
                "ordre",
                "nom_sel",
                "nom_sel_nn",
                "nom_ret",
                "nom_ret_nn",
                "nt",
                "famille",
                "nom_referentiel",
                "zone_geo",
                "ce_zone_geo",
                "date_observation",
                "lieudit",
                "station",
                "milieu",
                "commentaire",
                "transmission",
                "date_creation",
                "date_modification",
                "latitude",
                "longitude");

        function ExportXLS($config) {
                parent::__construct($config);
        }

        function createElement($pairs) {
                if(!isset($pairs['utilisateur']) || trim($pairs['utilisateur']) == '') {
                        echo '0'; exit;
                }
                if(!isset($_SESSION)) session_start();
        $this->controleUtilisateur($pairs['utilisateur']);

        $this->utilisateur = $this->getInfosComplementairesUtilisateur($pairs['utilisateur']);

                $infos_fichier = array_pop($_FILES);
                
                /*$objPHPExcel = PHPExcel_IOFactory::load($infos_fichier['tmp_name']);
                  $sheetData = $objPHPExcel->getActiveSheet()->toArray(NULL,FALSE,FALSE,TRUE);*/

                /*$objReader = PHPExcel_IOFactory::createReader("Excel5");
                $objReader->setReadDataOnly(true);
                $objPHPExcel = $objReader->load($infos_fichier['tmp_name']);*/

                //var_dump($sheetData);

                $objReader = PHPExcel_IOFactory::createReader("Excel5");
                $objReader->setReadDataOnly(true);
                $objPHPExcel = $objReader->load($infos_fichier['tmp_name']);
                $sheetData = $objPHPExcel->getActiveSheet()->toArray(NULL,FALSE,FALSE,TRUE);

                $filterSubset = new MyReadFilter();
                $filterSubset->excludes = self::detectionEntete($sheetData[1]);
                $objReader->setReadFilter($filterSubset);

                // recharge avec le filtre sur colonnes actif
                // (exclue les colonnes inutiles/inutilisables)
                $objPHPExcel = $objReader->load($infos_fichier['tmp_name']);
                $sheetData = $objPHPExcel->getActiveSheet()->toArray(NULL,FALSE,FALSE,TRUE);
                self::charger($sheetData);
        }

        static function detectionEntete($entete) {
                $colonnes_reconnues = Array();
                $cols = ExportXLS::fieldSetsToColumns('standard');
                foreach($entete as $k => $v) {
                        $entete_simple = iconv('UTF-8', 'ASCII//TRANSLIT', strtolower(trim($v)));
                        foreach($cols as $col) {
                                $entete_officiel_simple = iconv('UTF-8', 'ASCII//TRANSLIT', strtolower(trim($col['nom'])));
                                $entete_officiel_slug = $col['slug'];
                                if($entete_simple == $entete_officiel_simple || $entete_simple == $entete_officiel_slug) {
                                        define("C_" . strtoupper($entete_officiel_slug), $k);
                                        $colonnes_reconnues[$k] = 1;
                                        break;
                                }
                        }
                }

                // eg: 'I' => "rien"
                $colonnesID_non_reconnues = array_diff_key($entete, $colonnes_reconnues);

                $colonnes_automatiques = array_filter($cols, function($v) {     return !$v['importable']; });
                // ne conserve que le nom long pour matcher avec la ligne XLS d'entête
                array_walk($colonnes_automatiques, function(&$v) {      $v = $v['nom']; });
                $colonnesID_a_exclure = array_intersect($entete, $colonnes_automatiques);
                // TODO: pourquoi ne pas comparer avec les slugs aussi

                return array_merge($colonnesID_non_reconnues, $colonnesID_a_exclure);
        }

        static function charger($donnees) {     
                // TODO: chunkfilter
                $chunks = 30;
                $i = 2;
                $end = $i + $chunks;
                while($i < $end && isset($donnees[$i])) {
                        $record = self::chargerLigne($donnees[$i]);
                        $req = implode(', ', self::sortArrayByArray($record, self::$ordre_BDD));
                        $i++;
                }
        }

        // TODO: bouger les valeurs fixes comme valeurs de self::$ordre_BDD
        // et compter sur un array_merge()

        // TODO, théoriquement, l'ordre des index peut-être changé si nécessaire car
        // nous utilisons self::sortArrayByArray()
        static function chargerLigne($ligne) {
                // en premier car le résultat est utile pour
                // traiter longitude et latitude (traiterLonLat())
                $referentiel = self::identReferentiel($ligne[C_REFERENTIEL]);

                return Array(
                        "ce_utilisateur" => XXX,
                        "prenom_utilisateur" => XXX,
                        "nom_utilisateur" => XXX,
                        "courriel_utilisateur" => XXX,
                        "ordre" => YYY,
                        "nom_sel" => TODO,
                        "nom_sel_nn" => TODO,
                        "nom_ret" => TODO,
                        "nom_ret_nn" => TODO,
                        "nt" => TODO,
                        "famille" => TODO,
                        "nom_referentiel" => $referentiel,
                        "zone_geo" => TODO,
                        "ce_zone_geo" => TODO,
                        "date_observation" => self::traiterDateObs($ligne[C_DATE_OBSERVATION]),
                        "lieudit" => trim($ligne[C_LIEUDIT]),
                        "station" => trim($ligne[C_STATION]),
                        "milieu" => trim($ligne[C_MILIEU]),
                        "commentaire" => trim($ligne[C_COMMENTAIRE]),

                        // XXX: fixe
                        "transmission" => 0, // cf commentaire dans ExportXLS::fieldSetsToColumns()
                        "date_creation" => date("Y-m-d H:i:s"),
                        "date_modification" => date("Y-m-d H:i:s"),

                        "latitude" => self::traiterLonLat(NULL, $ligne[C_LATITUDE], $referentiel),
                        "longitude" => self::traiterLonLat($ligne[C_LONGITUDE], NULL, $referentiel)
                );
        }

        static function traiterDateObs($date) {
                return NULL; // TODO
        }

        static function identReferentiel($referentiel) {
                return NULL; // TODO
        }

        static function traiterLonLat($lon = NULL, $lat = NULL, $referentiel = 'bdtfx:v1.01') {
                // verifier format decimal +
                // + limite france si bdtfx ou bdtxa
        }

        // http://stackoverflow.com/questions/348410/sort-an-array-based-on-another-array
        static function sortArrayByArray($array,$orderArray) {
                $ordered = array();
                foreach($orderArray as $key) {
                        if(array_key_exists($key, $array)) {
                                $ordered[$key] = $array[$key];
                                unset($array[$key]);
                        }
                }
                return $ordered + $array;
        }
}