aswi2021tri-musketyri-gitlab/Server/ServerApp/Parser/Parsers/DataParser.cs @ f9dd116f

//
// Author: A. Konig
//

using ServerApp.DataDownload;
using ServerApp.Parser.InputData;
using ServerApp.Parser.OutputInfo;
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Threading;

namespace ServerApp.Parser.Parsers
{
    /// <summary>
    /// Class parsing data files into instances of ActivityInfo and WeatherInfo divided by given time interval
    /// Data parsed from 7am (included) to 18pm (included)
    /// </summary>
    /// <author>A. Konig</author>
    public class DataParser : IDataParser
    {
        /// <summary> Data downloader </summary>
        DataDownloader downloader;

        /// <summary> Weather data parser </summary>
        WeatherParser weatherParser;
        /// <summary> Jis data parser </summary>
        JisParser jisParser;
        /// <summary> Login data parser </summary>
        LogInParser loginParser;

        /// <summary> ActivityInfo representing jis activity </summary>
        List<ActivityInfo> jisList;
        /// <summary> ActivityInfo representing login activity</summary>
        List<ActivityInfo> loginList;

        /// <summary>
        /// Constructor
        /// </summary>
        public DataParser(DataDownloader downloader)
        {
            this.downloader = downloader;

            TagInfo.CreateDictionaries();

            IDataLoader loader = new CsvDataLoader();

            weatherParser = new WeatherParser(loader);
            jisParser = new JisParser(loader);
            loginParser = new LogInParser(loader);
        }

        /// <summary>
        /// Parse data
        /// </summary>
        /// <param name="interval">Length of an interval</param>
        /// <param name="wholeDay">Parse data as one instance per day</param>
        /// <param name="endTime">End time of related data</param>
        /// <param name="startTime">Start time of related data</param>
        override public bool Parse(DateTime startTime, DateTime endTime, int interval = 1, bool wholeDay = true)
        {
            var cultureInfo = CultureInfo.GetCultureInfo("en-GB");
            Thread.CurrentThread.CurrentCulture = cultureInfo;
            Thread.CurrentThread.CurrentUICulture = cultureInfo;

            // get path to folder w/ datafiles
            string pathWeather = downloader.DataSubDirectories[DataType.POCASI];
            string pathJis = downloader.DataSubDirectories[DataType.JIS];
            string pathLogIn = downloader.DataSubDirectories[DataType.STROJE];

            // get all files that should be parsed
            Date start = new Date((uint)startTime.Month, (uint)startTime.Year);
            Date end = new Date((uint)endTime.Month, (uint)endTime.Year);
            if (startTime == DateTime.MinValue || endTime == DateTime.MaxValue)
            {
                start = null;
                end = null;
            }

            var weatherFiles = downloader.GetData(pathWeather, start, end);
            var jisFiles = downloader.GetData(pathJis, start, end);
            var loginFiles = downloader.GetData(pathLogIn, start, end);

            WeatherDataUsed = new List<string>();
            ActivityDataUsed = new List<string>();

            WeatherDataUsed.AddRange(weatherFiles);
            ActivityDataUsed.AddRange(jisFiles);
            ActivityDataUsed.AddRange(loginFiles);

            WeatherList = weatherParser.ParseWeatherData(weatherFiles, startTime, endTime, wholeDay, interval);
            jisList = jisParser.ParseJisData(jisFiles, startTime, endTime, wholeDay, interval);
            loginList = loginParser.ParseLogInData(loginFiles, startTime, endTime, wholeDay, interval);

            //Console.WriteLine("WEATHER");
            //WriteToConsole(WeatherList);
            //Console.WriteLine("JIS");
            //WriteToConsole(jisList);
            //Console.WriteLine("LOGIN");
            //WriteToConsole(loginList);

            //WriteToConsole(AddListToOne(jisList));

            AttendanceList = MergeAttendance(jisList, loginList);

            //Console.WriteLine("MERGED IN ONE LIST");
            //WriteToConsole(AttendanceList);

            if (WeatherList.Count == 0 || AttendanceList.Count == 0)
                return false;

            return true;
        }


        /// <summary>
        /// Merges two lists into one
        /// Adds information from the same time period together, doesn't change the rest
        /// </summary>
        /// <param name="jisList">List to merge</param>
        /// <param name="loginList">List to merge</param>
        /// <returns>Merged list</returns>
        private List<ActivityInfo> MergeAttendance(List<ActivityInfo> jisList, List<ActivityInfo> loginList)
        {
            List<ActivityInfo> res = new List<ActivityInfo>();

            if (jisList == null && loginList == null)
                return res;
            else if (jisList == null)
                return loginList;
            else if (loginList == null)
                return jisList;

            int indexJis = 0, indexLogin = 0;
            while (true)
            {
                if (indexJis >= jisList.Count || indexLogin >= loginList.Count)
                    break;

                ActivityInfo jis = jisList[indexJis];
                int jisTag = TagInfo.IndexOfBuilding(jis.building);
                ActivityInfo login = loginList[indexLogin];
                int loginTag = TagInfo.IndexOfBuilding(login.building);

                // if same time times -> add to one info
                if (jis.startTime == login.startTime)
                {
                    // need to have same building tags
                    if (jisTag == loginTag)
                    {
                        jis.amount += login.amount;
                        res.Add(jis);
                        indexJis++; indexLogin++;
                    }

                    else if (jisTag < loginTag)
                    {
                        indexJis++;
                        res.Add(jis);
                    }

                    else if (jisTag > loginTag)
                    {
                        indexLogin++;
                        res.Add(login);
                    }

                }

                // if jis time is smaller -> add jis and move
                else if (jis.startTime < login.startTime)
                {
                    indexJis++;
                    res.Add(jis);
                }

                // if login time is smaller -> add login and move
                else if (login.startTime < jis.startTime)
                {
                    indexLogin++;
                    res.Add(login);
                }

            }

            // add all not yet processed
            if (indexJis < jisList.Count)
                res.AddRange(jisList.GetRange(indexJis, jisList.Count - indexJis));
                    
                    
            if (indexLogin < loginList.Count)
                res.AddRange(loginList.GetRange(indexLogin, loginList.Count - indexLogin));

            return res;
        }

        /// <summary>
        /// Sum all info for separate intervals in the list to the appropriate day
        /// </summary>
        /// <param name="list">List with activity info, info separated into buildings and intervals</param>
        /// <returns></returns>
        private List<ActivityInfo> AddListToOne(List<ActivityInfo> list)
        {
            List<ActivityInfo> a2 = new List<ActivityInfo>();
            for (int i = 0; i < list.Count; i+=TagInfo.buildings.Length)
            {
                int amount = 0;
                for (int j = 0; j < TagInfo.buildings.Length; j++)
                {
                    amount += list[i + j].amount;
                }
                ActivityInfo info = new ActivityInfo("ALL", amount, list[i].startTime, list[i].intervalLength);
                a2.Add(info);
            }
            return a2;
        }

        /// <summary>
        /// Debug method - writing lists to console
        /// </summary>
        private void WriteToConsole(List<ActivityInfo> list)
        {
            if (list == null)
            {
                Console.WriteLine("Unsuccessful parsing");
                return;
            }
            Console.WriteLine(list.Count);

            for (int i = 0; i < list.Count; i++)
            {
                if (list[i].startTime.Year >= 2019)
                    Console.WriteLine(list[i].ToString());
            }
        }

        /// <summary>
        /// Debug method - writing lists to console
        /// </summary>
        private void WriteToConsole(List<WeatherInfo> list)
        {
            if (list == null)
            {
                Console.WriteLine("Unsuccessful parsing");
                return;
            }
            Console.WriteLine(list.Count);

            for (int i = 0; i < list.Count; i++)
                Console.WriteLine(list[i].ToString());
        }

    }
}