using System;
using System.Collections;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml;

namespace DaSaSo.DatabaseConverter
{
    class ConvertXML
    {
        List<Auftraggeber> auftraggeberList = new List<Auftraggeber>();
        Queue<Auftraggeber> bearbeiteteAuftraggeber = new Queue<Auftraggeber>();
        Queue<InlinerSanierung> bearbeiteInlinerSanierung = new Queue<InlinerSanierung>();
        Queue<Tuple<string, Imprägnierungen>> bearbeiteStammImpr = new Queue<Tuple<string, Imprägnierungen>>();
        List<Projekt> projekte = new List<Projekt>();
        public List<Imprägnierungen> imprägnierungListe = new List<Imprägnierungen>();
        XmlReader m_reader;
        string lastObject = "";
        public int counter = 0;

        public List<Projekt> GetProjekts => projekte;

        public void parseXML()
        {
            XmlReaderSettings setting = new XmlReaderSettings();
            setting.Async = false;
            HashSet<string> hashtable = new HashSet<string>();
            
            using (m_reader = XmlReader.Create("./TeufelDB.xaml", setting))
            {
                while (m_reader.Read())
                {
                    if (m_reader.IsStartElement("kc:AuftraggeberList"))
                    {
                        List<string> importFields = new List<string>();
                        bool flag = true;
                        while (m_reader.Read())
                        {
                            if (flag)
                            {
                                flag = HandleAuftraggeber(importFields);
                            }
                            if (m_reader.Name == "kc:AuftraggeberList" && m_reader.NodeType == XmlNodeType.EndElement)
                            {
                                break;
                            }
                        }
                        
                    }
                    if(m_reader.IsStartElement("kc:ImprägnierBericht"))
                    {
                        while(m_reader.Read())
                        {
                            //HandleImprägnierungen();
                            if (m_reader.Name == "kc:ImprägnierBericht" && m_reader.NodeType == XmlNodeType.EndElement)
                            {
                                break;
                            }
                        }
                    }
                    
                    if (m_reader.IsStartElement("Projekt"))
                    {
                        counter++;
                        bool flag = true;
                        List<Inspektionsobjekt> inspektionsobjekts = new List<Inspektionsobjekt>();
                        Projekt projekt = new Projekt();
                        if (m_reader.HasAttributes)
                        {
                            while (m_reader.MoveToNextAttribute())
                            {
                                //Console.WriteLine("/// {0} = {1}", m_reader.Name, m_reader.Value);
                                switch (m_reader.Name)
                                {
                                    case "Auftraggeber":
                                        string auftr = m_reader.Value.Trim('{').Trim('}');
                                        if (auftr.Equals("x:Null")) continue;
                                        auftr = auftr.Substring(12);
                                        //Console.WriteLine(auftr);
                                        projekt.Auftraggeber = auftraggeberList.Find(x => x.interneID.Equals(auftr));
                                        break;
                                    case "Nummer": projekt.ProjektNummer = m_reader.Value; break;
                                    case "Ort": projekt.Ort = m_reader.Value; break;
                                    case "SanierungsIDPrefix": projekt.Prefix = m_reader.Value; break;
                                    case "SanierungsIDSuffix": projekt.Suffix = m_reader.Value; break;
                                }
                            }
                        }
                        while (m_reader.Read())
                        {
                            if (flag)
                            {
                                flag = HandleProjekt(projekt,inspektionsobjekts);
                                
                            }
                            if (m_reader.Name == "Projekt" && m_reader.NodeType == XmlNodeType.EndElement)
                                break;
                                //Debugger.Break();
                        }
                        projekt.inspektionsobjekte = inspektionsobjekts;
                        projekte.Add(projekt);
                            
                    }
                }
            }
            RecreateAuftraggeber();
            RecreateInlinersanierung();
           // Debugger.Break();
        }

        

        private void HandleImprägnierungen()
        {
            m_reader.Read();
            m_reader.Read();
            
            //Debugger.Break();
            if(m_reader.HasAttributes)
            {
                Imprägnierungen imp = new Imprägnierungen();
                while(m_reader.MoveToNextAttribute())
                {
                    switch(m_reader.Name)
                    {
                        
                        case "x:Name": imp.interneID = m_reader.Value; break;              
                        case "DN": imp.DN = Convert.ToInt32(m_reader.Value); break;
                        case "Imprägniernummer": imp.Imprägniernummer = m_reader.Value; break;    
                        case "LinerLänge": imp.LinerLänge = Convert.ToDecimal(m_reader.Value); break;
                        case "NochVorhanden": imp.NochVorhanden = Convert.ToBoolean(m_reader.Value); break;
                        case "Schlauchnummer": imp.Schlauchnummer = m_reader.Value; break;     
                        case "Wanddicke": imp.Wanddicke = Convert.ToDecimal(m_reader.Value.Replace('.', ',')); break; 

                        case "Länge":               // wird aktuell nicht gebraucht
                        case "LagerungKorrekt":     // wird aktuell nicht gebraucht
                        case "HarzTemperatur":      // wird aktuell nicht gebraucht
                        case "Harzmenge":           // wird aktuell nicht gebraucht
                        case "Vakuum":              // wird aktuell nicht gebraucht
                        case "Walzenabstand":       // wird aktuell nicht gebraucht
                        case "Bediener":            // wird aktuell nicht gebraucht
                        case "HarzTyp":             // wird aktuell nicht gebraucht 
                        case "ImprägnierungEnde":   // wird aktuell nicht gebraucht
                        case "LängeCode": break;          // wird aktuell nicht gebraucht

                        default: throw new Exception();       
                    }
                }
                imprägnierungListe.Add(imp);
                if(lastObject != "")
                {
                    Tuple<string, Imprägnierungen> t = new Tuple<string, Imprägnierungen>(lastObject, imp);
                    
                    bearbeiteStammImpr.Enqueue(t);
                    lastObject = "";
                }
                //Debugger.Break();
                
                
            }
        }

        private void RecreateAuftraggeber()
        {
            while(bearbeiteteAuftraggeber.Count > 0)
            {
                Auftraggeber _auftraggeber = bearbeiteteAuftraggeber.Dequeue();
                if(_auftraggeber.Ansprechpartner == null && _auftraggeber.Name == null && _auftraggeber.Ort == null && _auftraggeber.Strasse == null)
                {
                    Debugger.Break();
                }
                
                Auftraggeber auftraggeber = auftraggeberList.Find(x => x.interneID.Equals(_auftraggeber.interneID));
                if (auftraggeber == null)
                {
                    auftraggeberList.Add(_auftraggeber);
                    continue;
                }
                if (auftraggeber.Ansprechpartner != null || auftraggeber.Name != null || auftraggeber.Ort != null || auftraggeber.Strasse != null)
                    continue;
                auftraggeber.Ansprechpartner = _auftraggeber.Ansprechpartner;
                auftraggeber.Name = _auftraggeber.Name;
                auftraggeber.Ort = _auftraggeber.Ort;
                auftraggeber.Strasse = _auftraggeber.Strasse;
            }
        }
        private void RecreateInlinersanierung()
        {
            while(bearbeiteInlinerSanierung.Count > 0)
            {
                InlinerSanierung inlinerSanierung = bearbeiteInlinerSanierung.Dequeue();
                if (inlinerSanierung.tempImprägnierung.Equals("{x:Null}")) continue;
                //{x:Reference __ReferenceID61}
                string id = inlinerSanierung.tempImprägnierung.Trim('{').Trim('}').Substring(12);
                inlinerSanierung.Impraeg = imprägnierungListe.Find(x => x.interneID.Equals(id));
                if (inlinerSanierung.Impraeg == null) throw new Exception();
            }
            while(bearbeiteStammImpr.Count > 0)
            {
                Tuple<string, Imprägnierungen>? s = bearbeiteStammImpr.Dequeue();
                
                Inspektionsobjekt inspektionsobjekt = null;
                foreach(Projekt prj in projekte)
                {
                    foreach(Inspektionsobjekt insp in prj.inspektionsobjekte)
                    {
                        if (insp.Objektbezeichnung.Equals(s.Item1))
                            inspektionsobjekt = insp;
                    }
                }
                inspektionsobjekt.InlinerSanierung.Impraeg = s.Item2;

            }
           
        }

        private void HandleInspektionsobjekt(List<Inspektionsobjekt> inspektionsobjekts)
        {
            Inspektionsobjekt insp = new Inspektionsobjekt();
            if (m_reader.HasAttributes)
            {
                while (m_reader.MoveToNextAttribute())
                {

                    switch (m_reader.Name)
                    {
                        case "x:Name": insp.interneID = m_reader.Value; break;
                        case "Bemerkung": insp.Bemerkung = m_reader.Value; break;
                        case "VonPunkt": insp.VonPunkt = m_reader.Value; break;
                        case "BisPunkt": insp.BisPunkt = m_reader.Value; break;
                        case "Objektbezeichnung": insp.Objektbezeichnung = m_reader.Value; break;
                        case "StrasseName": insp.StrasseName = m_reader.Value; break;
                        case "RohrMaterial": insp.RohrMaterial = m_reader.Value; break;
                        case "Projektnummer": insp.Projektnummer = m_reader.Value; break;
                        case "OrtName": insp.OrtName = m_reader.Value; break;
                        case "Kanalrohrweite": insp.Kanalrohrweite = Convert.ToInt32(m_reader.Value); break;
                        case "Hausnummer": insp.Hausnummer = m_reader.Value; break;
                        case "Haltungslaenge": insp.Haltungslaenge = Convert.ToDecimal(m_reader.Value.Replace('.', ',')); break;
                        case "GeschlossenesEnde": insp.GeschlossenesEnde = Convert.ToBoolean(m_reader.Value); break;
                    }
                }
                inspektionsobjekts.Add(insp);
            }
        }

        private bool HandleProjekt(Projekt projekt, List<Inspektionsobjekt> inspektionsobjekts)
        {
            bool result = true;
            if (m_reader.IsStartElement("Auftraggeber"))
            {
                // Get Auftraggeber
                if(m_reader.HasAttributes)
                {
                    Auftraggeber auftraggeber = new Auftraggeber();
                    while(m_reader.MoveToNextAttribute())
                    {
                        switch(m_reader.Name)
                        {
                            case "x:Name": auftraggeber.interneID = m_reader.Value; break;
                            case "Ansprechpartner": auftraggeber.Ansprechpartner = m_reader.Value; break;
                            case "Name": auftraggeber.Name = m_reader.Value; break;
                            case "Ort": auftraggeber.Ort = m_reader.Value; break;
                            case "Strasse": auftraggeber.Strasse = m_reader.Value; break;
                        }
                        
                        //Console.WriteLine("{0} = {1}", m_reader.Name, m_reader.Value);
                    }
                    if (auftraggeber.interneID == null)
                    {
                        auftraggeberList.Add(auftraggeber);
                    }
                    else
                    {
                        bearbeiteteAuftraggeber.Enqueue(auftraggeber);
                    }
                    projekt.Auftraggeber = auftraggeber;
                }
                
            }
            if (m_reader.IsStartElement("Inspektionsobjekt"))
            {
                HandleInspektionsobjekt(inspektionsobjekts);
            }
            if (m_reader.IsStartElement("InlinerSanierung"))
            {
                HandleInlinerSanierung(inspektionsobjekts);
            }
            if (m_reader.IsStartElement("InlinerSanierung.Imprägnierungsbericht"))
            {
                HandleImprägnierungen();
            }
            if (m_reader.IsStartElement("SchachtAnbindung"))
            {

            }
            //Console.WriteLine(m_reader.Name);

            return result;
        }

        private void HandleInlinerSanierung(List<Inspektionsobjekt> inspektionsobjekts)
        {
            Inspektionsobjekt objekt = null;
            InlinerSanierung san = new InlinerSanierung();
            
            if (m_reader.HasAttributes)
            {
                bool recreate = false;
                while (m_reader.MoveToNextAttribute())
                {
                    //Console.WriteLine("{0} = {1}", m_reader.Name, m_reader.Value);
                    string interneObjektbezeichnung;
                    switch(m_reader.Name)
                    {
                        case "Inspektionsobjekt": 
                            interneObjektbezeichnung = m_reader.Value.Substring(13).Trim('}');
                            objekt = inspektionsobjekts.Find(x => x.interneID != null && x.interneID.Equals(interneObjektbezeichnung));
                            //if (objekt.Objektbezeichnung.Equals("00450HR01")) Debugger.Break();
                            break;
                        case "Wetter": san.Wetter = m_reader.Value; break;
                        case "WasserhaltungEingerichtet": san.Wasserhaltung = Convert.ToBoolean(m_reader.Value); break;
                        case "VorbereitetRoboter": san.VorbereitetRoborter = Convert.ToBoolean(m_reader.Value); break;
                        case "VorbereitetMechanisch": san.VorbereitetMechanisch = Convert.ToBoolean(m_reader.Value); break;
                        case "STVOAbsicherung": san.SVTO = Convert.ToBoolean(m_reader.Value); break;
                        case "Preliner": san.Preliner = Convert.ToBoolean(m_reader.Value); break;
                        case "HDReinigung": san.HDReinigung = Convert.ToBoolean(m_reader.Value); break;
                        case "GenehmigungVorhanden": san.GenehmigungVorhanden = Convert.ToBoolean(m_reader.Value); break;
                        case "Fertig": san.Fertig = Convert.ToBoolean(m_reader.Value); break;
                        case "GeschlosseneEnde": san.GeschlosseneEnde = Convert.ToBoolean(m_reader.Value); break;
                        case "TempAusen": san.TempAusssen = Convert.ToInt32(m_reader.Value); break;
                        case "TempKanal": san.TempKanal = Convert.ToInt32(m_reader.Value); break;
                        case "LagerungTemperatur": san.LagerungsTemperatur = m_reader.Value; break;
                        case "InversionsDruck": san.InversionsDruck = Convert.ToDecimal(m_reader.Value.Replace('.', ',')); break;
                        case "EndeAushaertung": san.EndeAushaertung = Convert.ToDateTime(m_reader.Value); break;
                        case "EinbauTemperatur": san.EinbauTemperatur = m_reader.Value; break;
                        case "Besatzung": san.Besatzung = m_reader.Value; break;
                        case "Datum": san.Datum = Convert.ToDateTime(m_reader.Value); break;
                        case "Ort": san.Ort = m_reader.Value; break;
                        case "Imprägnierungsbericht":
                            san.tempImprägnierung = m_reader.Value;
                            recreate = true;
                            Trace.WriteLine(san.tempImprägnierung);
                            break;
                        case "Offset": break; // Use this

                        
                        case "Rueckholgeschwindigkeit":
                        case "DatumKalibrierung":
                        case "AnfangAushaertung":
                        case "AnfangKalibrierung":
                        case "EndeKalibirierung":
                        case "HDReinigungDatum":
                        case "HarzChargenummer":
                        case "HarzKalibrierTemperatur":
                        case "HarzTyp":
                        case "Harzbedarf":
                        case "KalibierWalzenAbstand":
                        case "HarzBedarf":
                        case "LinerTyp":
                        case "KalibrierUnterdruck":
                        case "Guid":
                        case "LinerChargenummer":
                        case "Bediener": break;
                        default: throw new NotImplementedException(m_reader.Name); break;
                    }

                }
                if (recreate)
                    bearbeiteInlinerSanierung.Enqueue(san);
                else
                    lastObject = objekt.Objektbezeichnung;
                objekt.InlinerSanierung = san;
            }
            
            
            //Debugger.Break();
        }

        private bool HandleAuftraggeber(List<string> importFields)
        {
            bool result = true;
            if (m_reader.IsStartElement("x:Reference"))
            {
                m_reader.Read();
                auftraggeberList.Add(new Auftraggeber()
                {
                    interneID = m_reader.Value
                });
                //string text = m_reader.Value;
                //Console.WriteLine(text);
            }
            //Debugger.Break();
            return result;
        }
    }

    internal class Imprägnierungen
    {
        
        public string interneID { get; set; }
        public int DN { get; set; }
        public string Imprägniernummer { get; set; }
        public decimal LinerLänge { get; set; }
        public bool NochVorhanden { get; set; }
        public string Schlauchnummer { get; set; }
        public decimal Wanddicke { get; set; }
    }

    internal class Projekt
    {
        public string ProjektNummer { get; set; }
        public string Ort { get; set; }
        public string Prefix { get; set; }
        public string Suffix { get; set; }
        public Auftraggeber Auftraggeber { get; set; }
        public List<Inspektionsobjekt> inspektionsobjekte = new List<Inspektionsobjekt>();
        public override string ToString()
        {
            return ProjektNummer + " " + Ort;
        }
    }

    internal class Inspektionsobjekt
    {
        public string interneID { get; set; }
        public string Bemerkung { get; set; }
        public string Objektbezeichnung { get; set; }
        public string VonPunkt { get; set; }
        public string BisPunkt { get; set; }
        public string StrasseName { get; set; }
        public string RohrMaterial { get; set; }
        public string Projektnummer { get; set; }
        public string OrtName { get; set; }
        public int Kanalrohrweite { get; set; }
        public string Hausnummer { get; set; }
        public decimal Haltungslaenge { get; set; }
        public bool GeschlossenesEnde { get; set; }
        public InlinerSanierung InlinerSanierung {get; set;}
        public override string ToString()
        {
            return Objektbezeichnung;
        }
    }

    internal class InlinerSanierung
    {
        public string Besatzung { get; set; }
        public DateTime Datum { get; set; }
        public string EinbauTemperatur { get; set; }
        public DateTime EndeAushaertung { get; set; }
        public bool GeschlosseneEnde { get; set; }
        public bool Fertig { get; set; }
        public bool GenehmigungVorhanden { get; set; }
        public bool HDReinigung { get; set; }
        public decimal InversionsDruck { get; set; }
        public string LagerungsTemperatur { get; set; }
        public string Ort { get; set; }
        public bool SVTO { get; set; }
        public bool VorbereitetMechanisch { get; set; }
        public int TempAusssen { get; set; }
        public int TempKanal { get; set; }
        public bool VorbereitetRoborter { get; set; }
        public bool Preliner { get; set; }
        public bool Wasserhaltung { get; set; }
        public string Wetter { get; set; }
        public string tempImprägnierung { get; set; }
        public Imprägnierungen Impraeg { get; set; }
    }

    internal class Auftraggeber
    {
        public string interneID { get; set; }
        public string Ansprechpartner { get; set; }
        public string Name { get; set; }
        public string Ort { get; set; }
        public string Strasse { get; set; }
    }
}