Revize 0da0ac88

Parse data as days - averages, sums

Server/Parser 1.0/Parsers/WeatherParser.cs

@@ -1 @@
-using System;
+using Parser_1._0.InputData;
+using Parser_1._0.OutputInfo;
+using System;
 using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
+using System.IO;
 
 namespace Parser_1._0.Parsers
 {
     class WeatherParser
     {
+        
+        public List<WeatherInfo> ParseWeatherData(string folder, bool wholeDay = true, int interval = 1)
+        {
+            List<WeatherInfo> list = new List<WeatherInfo>();
+
+            // najít složku, ve složce sou data co se budou parsovat
+
+            if (!Directory.Exists(folder))
+                return null;
+
+            // když v jednej složce budou všechny jis data co chci zpracovat
+            // pro každej soubor budu spouštět parsování
+            string[] fileEntries = Directory.GetFiles(folder);
+            foreach (string fileName in fileEntries)
+            {
+                List<WeatherInfo> loadedData = null;
+                // pokud po jednom dni
+                if (wholeDay)
+                    loadedData = ProcessOneWeatherFileAsDays(fileName);
+                // pokud po hodinách
+                else
+                {
+                    // pokud: konec dne nebo konec aktuálního intervalu -> vemu to co sem nasčítal
+                    throw new NotImplementedException();
+                }
+
+                list.AddRange(loadedData);
+            }
+
+            return list;
+        }
+
+        private static List<WeatherInfo> ProcessOneWeatherFileAsDays(string path)
+        {
+            List<WeatherInfo> weatherInfo = new List<WeatherInfo>();
+
+            // načíst data ze souboru
+            List<WeatherInstance> list = CsvDataLoader.LoadWeatherFile(path);
+
+            //temp, rain, wind, lum
+            double[] recordedAmount = new double[4];
+            int[] minmaxHour = new int[] { 7, 18 };
+            int range = minmaxHour[1] - minmaxHour[0];
+
+            // procházet data ze souboru
+            DateTime lastStartDay = new DateTime(list[0].dateTime.Year, list[0].dateTime.Month, list[0].dateTime.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;
+
+                // v každym dni agreguju
+                DateTime date = new DateTime(list[i].dateTime.Year, list[i].dateTime.Month, list[i].dateTime.Day);
+                if (!date.Equals(lastStartDay))
+                {
+                    Console.WriteLine(values);
+                    Console.WriteLine(recordedAmount[0]);
+
+                    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;
+                }
+
+                // tady nasčítávát data
+                recordedAmount[0] += list[i].temp;
+                recordedAmount[1] += list[i].rain;
+                recordedAmount[2] += list[i].wind;
+                recordedAmount[3] += list[i].lum * 1000;
+                values++;
+            }
+
+            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<JisInfo> ProcessOneWeatherFileAsIntervals(string path, int interval)
+        {
+            throw new NotImplementedException();
+        }
     }
 }