fichecollege/CG67.FicheCollege.root/CG67.FicheCollege/Core/CG67.FicheCollege.Entrepot/EntrepotEtablissement.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Data.OracleClient;
using System.Data.OleDb;
using CG67.FicheCollege.Domaine;
using CG67.FicheCollege.Interface;

namespace CG67.FicheCollege.Entrepot
{
    public class EntrepotEtablissement : EntrepotBase, IEntrepotEtablissement
    {
        public IList<Etablissement> GetAll()
        {
            IList<Etablissement> resultat = new List<Etablissement>();
            using (SqlConnection connexion = new SqlConnection(this.ChaineDeConnexion))
            {
                try
                {
                    connexion.Open();
                    using (SqlCommand command = connexion.CreateCommand())
                    {
                        command.CommandText = "Select Etablissement.CodeRNE, Etablissement.NomCollege, Adresse.Ville from Etablissement LEFT JOIN Adresse ON (Etablissement.IdAdresse = Adresse.Id) ORDER BY Adresse.Ville, Etablissement.NomCollege ASC";
                        using (SqlDataReader dr = command.ExecuteReader())
                        {
                            while (dr.Read())
                            {
                                resultat.Add(new Etablissement(dr["CodeRNE"].ToString(), dr["NomCollege"].ToString(), dr["Ville"].ToString()));
                            }
                        }
                    }
                }
                catch
                {
                    throw;
                }
                finally
                {
                    if (connexion.State == ConnectionState.Open)
                        connexion.Close();
                }
            }

            return resultat;
        }


        public Etablissement GetByCodeRNEAndAnnee(string codeRNE, int annee)
        {
            Etablissement resultat = null;
            using (SqlConnection connexion = new SqlConnection(this.ChaineDeConnexion))
            {
                //try
                {
                    connexion.Open();
                    using (SqlCommand command = connexion.CreateCommand())
                    {
                        command.CommandText = "Select * from Etablissement LEFT JOIN Adresse ON (Etablissement.IdAdresse = Adresse.Id) WHERE Etablissement.CodeRNE = @RNE";
                        command.Parameters.AddWithValue("@RNE", codeRNE);
                        command.Parameters.AddWithValue("@Annee", annee);
                        using (SqlDataReader dr = command.ExecuteReader())
                        {
                            if (dr.Read())
                            {
                                string adresse = dr["NumRue"].ToString() + ", " + dr["TypeDeVoie"].ToString() + " " + dr["Voie"].ToString();
                                
                                resultat = new Etablissement(codeRNE, annee, dr["NomCollege"].ToString(),
                                    dr["TypeEtablissement"].ToString(), Convert.ToInt16(dr["AnneeConstruction"].ToString()),
                                    dr["Telephone"].ToString(), dr["Email"].ToString(), dr["Fax"].ToString(),
                                    dr["NomPropriétaire"].ToString(), adresse, dr["ComplementAdresse"].ToString(),
                                    Convert.ToInt32(dr["CodePostal"].ToString()), dr["Ville"].ToString(), dr["LienPhoto"].ToString(),
                                    dr.GetBoolean(dr.GetOrdinal("DemiPension")),  dr.GetBoolean(dr.GetOrdinal("Internat")),int.Parse(dr["CapaciteTheorique"].ToString()),
                                    EntrepotFactory.GetEntrepotActionEducative().GetByCodeRNEAndAnnee,
                                    EntrepotFactory.GetEntrepotATC().GetByCodeRNE,
                                    EntrepotFactory.GetEntrepotBilinguisme().GetByCodeRNEAndAnnee,
                                    EntrepotFactory.GetEntrepotCommentaires().GetByCodeRNEAndAnnee,
                                    EntrepotFactory.GetEntrepotContact().GetAllContactByCodeRNE,
                                    EntrepotFactory.GetEntrepotDotation().GetByCodeRNEAndAnnee,
                                    EntrepotFactory.GetEntrepotEquipement().GetByCodeRNEAndAnnee,
                                    EntrepotFactory.GetEntrepotInvestissement().GetByCodeRNEAndAnnee,
                                    EntrepotFactory.GetEntrepotMCG().GetByCodeRNE,
                                    EntrepotFactory.GetEntrepotLogement().GetByCodeRNE, 
                                    EntrepotFactory.GetEntrepotProgTravaux().GetByCodeRNEAndAnnee, 
                                    EntrepotFactory.GetEntrepotProjetPilote().GetByCodeRNEAndAnnee,
                                    EntrepotFactory.GetEntrepotRestauration().GetByRNEAndAnnee);
                            }
                        }
                        
                        // liste chargées d'office. pourquoi ?

                        command.CommandText = "SELECT * FROM EtpTheorique WHERE CodeRNE = @RNE AND Annee = @Annee";
                        using (SqlDataReader dr2 = command.ExecuteReader())
                        {
                            if (dr2.Read())
                            {
                                resultat.ValeurETPTheorique = Convert.ToInt32(dr2["Valeur"].ToString());
                            }
                        }

                        command.CommandText = "SELECT * from SecteurRecrutement WHERE CodeRNE = @RNE and Annee=@annee";
                        using (SqlDataReader dr7 = command.ExecuteReader())
                        {
                            IList<EtablissementRecrutement> lstSecteurRecrut = new List<EtablissementRecrutement>();
                            while (dr7.Read())
                            {
                                lstSecteurRecrut.Add(new EtablissementRecrutement(dr7["Libelle"].ToString()));
                            }
                            resultat.LstSecteurRecrutement = lstSecteurRecrut;
                        }

                        command.CommandText = "SELECT * FROM Reserve WHERE CodeRNE = @RNE AND Annee = @Annee";
                        using (SqlDataReader dr3 = command.ExecuteReader())
                        {
                            if (dr3.Read())
                            {
                                resultat.Reserve = Convert.ToInt32(dr3["Montant"].ToString());
                            }
                        }

                        command.CommandText = "SELECT Annee, TypeDonnees,EffectifTotal FROM EffectifTotal WHERE CodeRNE = @RNE AND Annee > @AnneeMoins10 ORDER BY Annee ASC";
                        command.Parameters.AddWithValue("@AnneeMoins10", annee - 10);
                        using (SqlDataReader dr4 = command.ExecuteReader())
                        {
                            resultat.LstEffectif = new List<Effectif>();
                            IList<Effectif> lstEffectifReel = new List<Effectif>();
                            while (dr4.Read())
                            {
                                lstEffectifReel.Add(new Effectif(dr4["Annee"].ToString(),dr4["TypeDonnees"].ToString(),  Convert.ToInt32(dr4["EffectifTotal"].ToString())));
                            }

                            foreach (Effectif e in lstEffectifReel)
                            {
                                if (e.TypeEffectif == "R") 
                                    resultat.LstEffectif.Add(e);  
                            }

                            foreach (Effectif e in lstEffectifReel)
                            {
                                bool trouve = false;
                                if (e.TypeEffectif == "P")
                                {
                                    foreach (Effectif e1 in resultat.LstEffectif)
                                        if (e1.Annee == e.Annee)
                                            trouve = true;
                                    if (!trouve)
                                        resultat.LstEffectif.Add(e);
                                }
                            }
                        }

                        

                        command.CommandText = "SELECT * from Restructuration WHERE CodeRNE = @RNE";
                        using (SqlDataReader dr6 = command.ExecuteReader())
                        {
                            IList<int> lstRestructuration = new List<int>();
                            while (dr6.Read())
                            {
                                lstRestructuration.Add(Convert.ToInt32(dr6["Annee"].ToString()));
                            }
                            resultat.LstRestructuration = lstRestructuration;
                        }

                       
                        command.CommandText = "SELECT * from Remplacement INNER JOIN ATC ON (ATC.Id = Remplacement.IdATCRemplace) INNER JOIN Contact ON (ATC.Id = Contact.Id) WHERE CodeRNE = @RNE AND Remplacement.DateDebut + DureeEnSemaine >= GETDATE()";
                        using (SqlDataReader dr8 = command.ExecuteReader())
                        {
                            int nbrRemplacements = 0;
                            while (dr8.Read())
                            {
                                nbrRemplacements++; ;
                            }
                            resultat.NbrRemplacementsATC = nbrRemplacements;
                        }

                        

                    }
                }
                //catch
                //{
                //    throw;
                //}
                //finally
                //{
                //    if (connexion.State == ConnectionState.Open)
                //        connexion.Close();
                //}
            }
          

            resultat.Surface = 0;

            using (SqlConnection connexion = new SqlConnection(this.ChaineDeConnexion))
            {
                try
                {
                    connexion.Open();
                    using (SqlCommand command = connexion.CreateCommand())
                    {
                        command.CommandText= "select SUM(superficie) from dbo.salle where codeRNE =@RNE  and typeValeur= 'm2'";
                        command.Parameters.AddWithValue("@rne", codeRNE);
                        string sum = command.ExecuteScalar().ToString();
                        resultat.Surface = string.IsNullOrEmpty(sum) ? 0 : Convert.ToDouble(sum);
                    }
                }
                catch
                {
                    throw;
                }
                finally
                {
                    if (connexion.State == ConnectionState.Open)
                        connexion.Close();
                }
            }

            //using (OracleConnection connexion = new OracleConnection(this.ChaineDeConnexion))
            //{
            //    try
            //    {
            //        connexion.Open();
            //        using (OracleCommand command = connexion.CreateCommand())
            //        {
            //            command.CommandText = "SELECT Sum(Externat_Enseignementgeneral + Externat_Labochimie_sciencenat + Externat_Labophysique + Externat_Salleinformatique + Externat_Batimentsdemontables + Externat_Administration + Gymnaseatelier_Gymnases + Gymnaseatelier_Ateliers + Restauration_internats_internats + Restauration_internats_Restauration + Logements_et_exterieur_Logements + Logements_et_exterieur_Autres + Logements_et_exterieur_Logautres + Logements_et_exterieur_Cours + Logements_et_exterieur_Parkings + Logements_et_exterieur_Espacesverts + Logements_et_exterieur_Airessportives + Logements_et_exterieur_Consouvertes) as SurfaceTotale FROM [T_EDL Surfaces données du rectorat] LEFT JOIN T_COLLEGE ON ([T_EDL Surfaces données du rectorat].Lien_T_College = T_COLLEGE.REF_COLLEGE) WHERE T_COLLEGE.CODE_COLLEGE = :RNE";
            //            command.Parameters.AddWithValue(":RNE", codeRNE);
            //            using (OracleDataReader reader = command.ExecuteReader())
            //            {
            //                if (reader.Read())
            //                {
            //                    resultat.Surface = Convert.ToDouble(reader["SurfaceTotale"].ToString());
            //                }
            //            }
            //        }
            //    }
            //    catch
            //    {
            //        throw;
            //    }
            //    finally
            //    {
            //        if (connexion.State == ConnectionState.Open)
            //            connexion.Close();
            //    }
            //}

            return resultat;
        }
    }
}