aswi2021tri-musketyri-gitlab/Server/ServerApp/Parser/Parsers/WeatherParser.cs @ 734533a8

using ServerApp.Parser.InputData;
using ServerApp.Parser.OutputInfo;
using System;
using System.Collections.Generic;
using System.IO;

namespace ServerApp.Parser.Parsers
{
    /// <summary>
    /// Class parsing weather files into instances of WeatherInfo divided by given time interval
    /// Data parsed from 7am (included) to 18pm (included)
    /// </summary>
    class WeatherParser
    {
        /// <summary>
        /// Parses weather data to WeatherInfo instances
        /// Data parsed from 7am (included) to 18pm (included)
        /// </summary>
        /// <param name="folder">Folder with weather data files</param>
        /// <param name="wholeDay">Should data be parsed as one instance per day (if true parameter interval will be ignored)</param>
        /// <param name="interval">Time interval to divide days by, minimum is 1h</param>
        /// <returns></returns>
        public List<WeatherInfo> ParseWeatherData(string folder, bool wholeDay = true, int interval = 1)
        {
            if (!Directory.Exists(folder))
                return null;

            List<WeatherInfo> list = new List<WeatherInfo>();

            // get all files in folder
            string[] fileEntries = Directory.GetFiles(folder);
            foreach (string fileName in fileEntries)
            {
                List<WeatherInfo> loadedData = null;
                
                // parse as one instance per day
                if (wholeDay)
                    loadedData = ProcessOneWeatherFileAsDays(fileName);
                // parse according to interval
                else
                {
                    // pokud: konec dne nebo konec aktuálního intervalu -> vemu to co sem nasčítal
                    throw new NotImplementedException();
                }

                list.AddRange(loadedData);
            }

            return list;
        }

        /// <summary>
        /// Parses data from one data file as one instance per day
        /// </summary>
        /// <param name="path">Path ti file</param>
        /// <returns>List with WeatherInfo instances</returns>
        private static List<WeatherInfo> ProcessOneWeatherFileAsDays(string path)
        {
            if (!File.Exists(path))
                return null;

            List<WeatherInfo> weatherInfo = new List<WeatherInfo>();
            List<WeatherInstance> list = CsvDataLoader.LoadWeatherFile(path);

            // array with data [temp, rain, wind, lum]
            double[] recordedAmount = new double[4];
            // min/max hour taken into account
            int[] minmaxHour = new int[] { 7, 18 };
            // interval length
            int range = minmaxHour[1] - minmaxHour[0];

            // first day
            DateTime lastStartDay = new DateTime(list[0].dateTime.Year, list[0].dateTime.Month, list[0].dateTime.Day, minmaxHour[0], 0, 0);
            // number of values in day
            int values = 0;
            for (int i = 0; i < list.Count; i++)
            {
                int currHour = list[i].dateTime.Hour;
                if (currHour < minmaxHour[0] || currHour > minmaxHour[1])
                    continue;

                // start of new day -> make a new instance
                DateTime date = new DateTime(list[i].dateTime.Year, list[i].dateTime.Month, list[i].dateTime.Day, minmaxHour[0], 0, 0);
                if (!date.Equals(lastStartDay))
                {
                    WeatherInfo dayInfo = new WeatherInfo(lastStartDay, recordedAmount[0] / values, (int)(recordedAmount[1] / values * 100), recordedAmount[2] / values, recordedAmount[3] / values, range); 
                    weatherInfo.Add(dayInfo);

                    recordedAmount = new double[4];
                    lastStartDay = date;
                    values = 0;
                }

                // aggregate data
                recordedAmount[0] += list[i].temp;
                recordedAmount[1] += list[i].rain;
                recordedAmount[2] += list[i].wind;
                recordedAmount[3] += list[i].lum * 1000;

                values++;
            }

            // data from last day
            WeatherInfo dayInfo2 = new WeatherInfo(lastStartDay, recordedAmount[0] / values, (int)(recordedAmount[1] / values * 100), recordedAmount[2] / values, recordedAmount[3] / values, range); 
            weatherInfo.Add(dayInfo2);

            return weatherInfo;
        }

        private static List<ActivityInfo> ProcessOneWeatherFileAsIntervals(string path, int interval)
        {
            throw new NotImplementedException();
        }
    }
}