DaSaSo/DaSaSo.DatabaseConverter/ConvertXML.cs

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>();
        List<Projekt> projekte = new List<Projekt>();
        XmlReader m_reader;
        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("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();
            //Debugger.Break();
        }

        private void RecreateAuftraggeber()
        {
            while(bearbeiteteAuftraggeber.Count > 1)
            {
                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 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);
                
            }
            //Console.WriteLine(m_reader.Name);
            
            return result;
        }

        private void HandleInlinerSanierung(List<Inspektionsobjekt> inspektionsobjekts)
        {
            Inspektionsobjekt objekt = null;
            InlinerSanierung san = new InlinerSanierung();
            if (m_reader.HasAttributes)
            {
                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));
                            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;
                    }

                }
                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 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 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 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; }
    }

    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; }
    }
}