Revize 98b568bc

re #8612 Weather parser in hourly intervals

Server/ServerApp/Parser/Parsers/WeatherParser.cs

@@ -10 +10 @@
     /// Class parsing weather files into instances of WeatherInfo divided by given time interval
     /// Data parsed from 7am (included) to 18pm (included)
     /// </summary>
+    /// <author>Alex Konig</author>
     class WeatherParser
     {
+
+        /// <summary> Datafile loader  </summary>
+        DataLoader loader;
+
+        /// <summary>
+        /// Constructor
+        /// </summary>
+        /// <param name="loader">Datafile loader</param>
+        public WeatherParser(DataLoader loader)
+        {
+            this.loader = loader;
+        }
+
         /// <summary>
         /// Parses weather data to WeatherInfo instances
         /// Data parsed from 7am (included) to 18pm (included)
@@ -39 +53 @@
                 // parse according to interval
                 else
                 {
-                    // pokud: konec dne nebo konec aktuálního intervalu -> vemu to co sem nasčítal
-                    throw new NotImplementedException();
+                    loadedData = ProcessOneWeatherFileAsIntervals(fileName, interval);
                 }
 
                 list.AddRange(loadedData);
@@ -54 +67 @@
         /// </summary>
         /// <param name="path">Path ti file</param>
         /// <returns>List with WeatherInfo instances</returns>
-        private static List<WeatherInfo> ProcessOneWeatherFileAsDays(string path)
+        private List<WeatherInfo> ProcessOneWeatherFileAsDays(string path)
         {
             if (!File.Exists(path))
                 return null;
 
             List<WeatherInfo> weatherInfo = new List<WeatherInfo>();
-            List<WeatherInstance> list = CsvDataLoader.LoadWeatherFile(path);
+            List<WeatherInstance> list = loader.LoadWeatherFile(path);
 
             // array with data [temp, rain, wind, lum]
             double[] recordedAmount = new double[4];
@@ -72 +85 @@
             // 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;
+            int values = 0, weatherValues = 0;
             for (int i = 0; i < list.Count; i++)
             {
                 int currHour = list[i].dateTime.Hour;
@@ -83 +96 @@
                 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 dayInfo = new WeatherInfo(lastStartDay, recordedAmount[0] / values, (int)(recordedAmount[1] / values * 100), recordedAmount[2] / values, recordedAmount[3] / weatherValues, range); 
                     weatherInfo.Add(dayInfo);
 
                     recordedAmount = new double[4];
                     lastStartDay = date;
                     values = 0;
+                    weatherValues = 0;
                 }
 
                 // aggregate data
                 recordedAmount[0] += list[i].temp;
                 recordedAmount[1] += list[i].rain;
                 recordedAmount[2] += list[i].wind;
-                recordedAmount[3] += list[i].lum * 1000;
+
+                if (LuxToConditions.TransferLuxToConditions(list[i].lum * 1000) != WeatherConditions.Dark)
+                    recordedAmount[3] += list[i].lum * 1000; weatherValues++;
 
                 values++;
             }
@@ -107 +123 @@
             return weatherInfo;
         }
 
-        private static List<ActivityInfo> ProcessOneWeatherFileAsIntervals(string path, int interval)
+        /// <summary>
+        /// Parses data from one data file as one instance per interval length
+        /// </summary>
+        /// <param name="path">Path to file</param>
+        /// <param name="interval">Interval length</param>
+        /// <returns>List with ActivityInfo instances</returns>
+        private List<WeatherInfo> ProcessOneWeatherFileAsIntervals(string path, int interval)
         {
-            throw new NotImplementedException();
+            if (!File.Exists(path))
+                return null;
+
+            List<WeatherInfo> loignInfo = new List<WeatherInfo>();
+            List<WeatherInstance> list = loader.LoadWeatherFile(path);
+
+            // min/max hour taken into account
+            int[] minmaxHour = new int[] { 7, 18 };
+            int range = minmaxHour[1] - minmaxHour[0];
+
+            if (interval > range)
+                return null;
+
+            int indices = (int)Math.Ceiling(range / (double)interval);
+            int[] to = new int[indices];
+            double[][] data = new double[indices][];
+            int[] count = new int[indices];
+            for (int i = 0; i < to.Length; i++)
+            {
+                to[i] = minmaxHour[0] + interval * (i + 1);
+                data[i] = new double[4];
+            }
+
+            // first day
+            DateTime lastStartTime = new DateTime(list[0].dateTime.Year, list[0].dateTime.Month, list[0].dateTime.Day, minmaxHour[0], 0, 0);
+            int index;
+            for (int i = 0; i < list.Count; i++)
+            {
+                int currHour = list[i].dateTime.Hour;
+                if (currHour < minmaxHour[0] || currHour > minmaxHour[1])
+                    continue;
+
+                // start of the day -> make an instance
+                DateTime date = new DateTime(list[i].dateTime.Year, list[i].dateTime.Month, list[i].dateTime.Day, list[i].dateTime.Hour, 0, 0);
+
+                // end of the day
+                if (!(date.Year == lastStartTime.Year && date.Month == lastStartTime.Month && date.Day == lastStartTime.Day))
+                {
+                    // note down all aggregated data
+                    for (int k = 0; k < to.Length; k++)
+                    {
+                        int raincount = 0;
+                        double rainval = 0;;
+                        for (int l = 0; l <= k; l++)
+                        {
+                            raincount += count[l];
+                            rainval += data[l][1];
+                        }
+
+                        DateTime stTime = new DateTime(lastStartTime.Year, lastStartTime.Month, lastStartTime.Day, to[k] - interval, 0, 0);
+
+                        WeatherInfo intervalInfo = new WeatherInfo(stTime, data[k][0] / count[k], (int)((rainval / raincount) * 100), data[k][2] / count[k], data[k][3] / count[k], interval);
+                        if (count[k] != 0)
+                            loignInfo.Add(intervalInfo);
+
+                    }
+
+                    lastStartTime = date;
+                    count = new int[indices];
+                    for (int l = 0; l < data.Length; l++)
+                        data[l] = new double[4];
+                }
+
+                // find index for current instance
+                index = 0;
+                for (int k = 1; k < to.Length; k++)
+                {
+                    if (to[k] > list[i].dateTime.Hour && to[k - 1] <= list[i].dateTime.Hour)
+                    {
+                        index = k;
+                        break;
+                    }
+                }
+
+                // aggregate data
+                data[index][0] += list[i].temp;
+                data[index][1] += list[i].rain;
+                data[index][2] += list[i].wind;
+                data[index][3] += list[i].lum * 1000;
+                count[index]++;
+
+            }
+
+            for (int k = 0; k < to.Length; k++)
+            {
+                int raincount = 0;
+                double rainval = 0; ;
+                for (int l = 0; l <= k; l++)
+                {
+                    raincount += count[l];
+                    rainval += data[l][1];
+                }
+
+                DateTime stTime = new DateTime(lastStartTime.Year, lastStartTime.Month, lastStartTime.Day, to[k] - interval, 0, 0);
+
+                WeatherInfo intervalInfo = new WeatherInfo(stTime, data[k][0] / count[k], (int)((rainval / raincount) * 100), data[k][2] / count[k], data[k][3] / count[k], interval);
+                if (count[k] != 0)
+                    loignInfo.Add(intervalInfo);
+            }
+
+            return loignInfo;
         }
     }
+
 }