source: ether_megapoli/trunk/service/implementation/com/medias/integration/prevalidation/PreValidationMETEOFILE.java @ 488

package com.medias.integration.prevalidation;

import com.medias.Constantes;
import com.medias.DateTime;
import com.medias.EcritureLog;
import com.medias.database.objects.Capteur;
import com.medias.database.objects.Parametre;
import com.medias.integration.lecture_ecriture.LectureCapteurs;
import com.medias.integration.lecture_ecriture.LectureParametres;
import com.medias.integration.lecture_ecriture.LectureUnites;
import com.medias.integration.vues.ParametreModele;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.Date;

/**
 * Prévalidation d'un jeu ayant des données de type METEO
 *
 */
public class PreValidationMETEOFILE extends PreValidation
{
        public PreValidationMETEOFILE(File fichier) {
                super(fichier);
        }

        /**
         * Méthode de prévalidation permmettent de distinguer l'entéte et les données d'un fichier METEO
         * NB: La premiére ligne ne commenéant pas par # indique la ligne é laquelle commence la série de données
         * @return 
         */

        public void lireFichier(LectureParametres lectureParametres, LectureUnites lectureUnites, LectureCapteurs lectureCapteurs
                        , ArrayList<Parametre> parametres, ArrayList<Capteur> capteurs) {
                try {
                        //**************************************************************************************
                        // On récupére le contenu du fichier pour le lire.
                        //****************************************************************************************
                        FileInputStream fis = new FileInputStream(fichier);
                        InputStreamReader isr = new InputStreamReader(fis, "UTF-8");
                        BufferedReader buf = new BufferedReader(isr);
                        // Lecture du fichier ligne aprés ligne
                        String ligne = buf.readLine();
                        while (ligne != null) {
                                if (!ligne.startsWith("#")) {
                                        mesures.add(ligne);                                      
                                } else {
                                        entete.add(ligne);
                                }
                                ligne = buf.readLine();
                        }
                        // Récupération des informations de l'entéte
                        // Dates de début et de fin
                        int nbLignesMesures = mesures.size();
                        Date dateDeb = DateTime.stringToDate( mesures.get( 0 ).substring( 0, 10 ).trim(), "yyyy MM dd" );
                        Date dateFin = DateTime.stringToDate(mesures.get(nbLignesMesures-1).substring(0,10).trim(), "yyyy MM dd");
//                      System.out.println("deb="+dateDeb+", fin="+dateFin);
                        // Infos supplémentaires (pour trouver les capteurs)
                        infoSup = new ArrayList<String>();
                        infoSup.add(entete.get(1));
                        // On recherche les capteurs apparaissant dans les infos supplémentaires du fichier
                        ArrayList<Integer> indicesCaptInFile = findIndicesCaptInFile(lectureCapteurs,capteurs);
                        // Infos sur les paramétres et la valeur absente
                        infoParams = new ArrayList<ParametreModele>();
                        ParametreModele infoParam;
                        int nbLignesEntete = entete.size();
                        int diff;
                        String ligneEntete, nombre1, nombre2, valAbs = null;
                        ArrayList<String> lignesParam = new ArrayList<String>();
                        for(int numL=0; numL < nbLignesEntete;numL++){
                                ligneEntete = entete.get(numL).trim();
                                // Recherche des lignes de description des paramétres
                                if(ligneEntete.toLowerCase().startsWith("# col.")){
                                        if (ligneEntete.indexOf("->") == -1) {
                                                lignesParam.add(ligneEntete);
                                                nbParams++;
                                        } else {
                                                nombre1 = ligneEntete.substring(ligneEntete.indexOf("ol.")+3,ligneEntete.indexOf("->")).trim();
                                                nombre2 = ligneEntete.substring(ligneEntete.indexOf("->")+2, ligneEntete.indexOf(":")).trim();
                                                diff = Integer.parseInt(nombre2)-Integer.parseInt(nombre1)+1;
                                                nbParams += diff;
                                                for (int i = 0; i < diff; i++) {
                                                        lignesParam.add("# col. x : none (no unit)");
                                                }
                                        }
                                }
                                // Recherche de la ligne oé est indiquée la valeur absente
                                else if (ligneEntete.indexOf("corresponds to missed data") != -1){
                                        valAbs = ligneEntete.substring(ligneEntete.indexOf("\"")+1, ligneEntete.lastIndexOf("\""));
                                }
                        }
                        String nomParam, nomUnite, codeParam;
                        String[] unite;
                        int indiceParam, indiceCapt;
                        for (int numParam = 0; numParam < nbParams; numParam++) {
                                infoParam = new ParametreModele();
                                nomParam = lignesParam.get(numParam);
                                nomUnite = nomParam.substring(nomParam.indexOf("(")+1,nomParam.indexOf(")")).trim();
                                nomParam = nomParam.substring(nomParam.indexOf(":")+1,nomParam.indexOf("(")).trim();
                                infoParam.setNom(nomParam);
                                infoParam.setValAbsente(valAbs);
                                infoParam.setCoef("1");
                                unite = findUnite(nomUnite, lectureUnites);
                                infoParam.setNomUnite(unite[0]);
                                infoParam.setType(unite[1]);
                                if (nomParam.toLowerCase().equals( Constantes.nomParametreLatitude) || nomParam.toLowerCase().equals(Constantes.nomParametreLongitude)
                                                || nomParam.toLowerCase().equals(Constantes.nomParametreAltitude) || nomParam.toLowerCase().equals("height")) {
                                        infoParam.setFonction(Constantes.nomFonctionInsererLoc);
                                } else if (nomParam.startsWith("none") || nomParam.startsWith("Altitude") || nomParam.startsWith("QF")
                                                || nomParam.startsWith("Quality")) {
                                        infoParam.setFonction(Constantes.nomFonctionNone);
                                } else if (nomParam.startsWith("Year") || nomParam.startsWith("Month") || nomParam.startsWith("Day") 
                                                || nomParam.startsWith("Hour") || nomParam.startsWith("Minute") || nomParam.startsWith("Second")) {
                                        infoParam.setDateDeb(dateDeb);
                                        infoParam.setDateFin(dateFin);
                                        infoParam.setDateSince(null);
                                        infoParam.setFonction(Constantes.nomFonctionDate);
                                        infoParam.setFormat(nomUnite);
                                        infoParam.setType(nomParam);
                                } else {
                                        infoParam.setFonction(Constantes.nomFonctionInsererVal);
                                        // Nom des paramétres correspondant aux variables primaires
                                        indiceParam = findIndiceParam(nomParam,lectureParametres,parametres);
                                        infoParam.setIndiceParam(indiceParam);
                                        if (indiceParam == -1) {
                                                codeParam = "???";
                                                EcritureLog.ecrire("\nErreur : le paramétre '"+nomParam+"' n'a pas été trouvé","err");
                                        } else {
                                                codeParam = parametres.get(indiceParam).getParametreCode();
                                                infoParam.setDelta(parametres.get(indiceParam).getDelta());
                                                infoParam.setLod(parametres.get(indiceParam).getLod());
                                        }
                                        indiceCapt = findIndiceCapt(codeParam,indicesCaptInFile,capteurs);
                                        infoParam.setIndiceCapt(indiceCapt);
                                }
//                              EcritureLog.ecrire("param="+infoParam.getNom()+", format="+infoParam.getFormat()+", fct="+infoParam.getFonction()+", type="+infoParam.getType()+", unite="+infoParam.getNomUnite(), "out");
                                infoParams.add(infoParam);
                        }
                } catch (IOException e) {
                        System.out.println(e.getMessage()+ "\nErreur dans la lecture du fichier "+ fichier.getName() + " !");
                }
        }
}