Revize 0da0ac88

Parse data as days - averages, sums

Server/Parser 1.0/Parsers/LogInParser.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 LogInParser
     {
+        public List<LogInInfo> ParseLogInData(string folder, bool wholeDay = true, int interval = 1)
+        {
+            List<LogInInfo> list = new List<LogInInfo>();
+
+            // 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<LogInInfo> loadedData = null;
+                // pokud po jednom dni
+                if (wholeDay)
+                    loadedData = ProcessOneLogInFileAsDays(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<LogInInfo> ProcessOneLogInFileAsDays(string path)
+        {
+            List<LogInInfo> loginInfo = new List<LogInInfo>();
+
+            // načíst data ze souboru
+            List<LogInInstance> list = CsvDataLoader.LoadLoginFile(path);
+
+            int[] recordedAmount = new int[TagInfo.faculties.Length];
+            int[] minmaxHour = new int[] { 7, 18 };
+            int range = minmaxHour[1] - minmaxHour[0];
+
+            // procházet data ze souboru
+            DateTime lastStartDay = new DateTime(list[0].date.Year, list[0].date.Month, list[0].date.Day);
+            for (int i = 0; i < list.Count; i++)
+            {
+                int currHour = list[i].date.Hour;
+                if (currHour < minmaxHour[0] || currHour > minmaxHour[1])
+                    continue;
+
+                // v každym dni agreguju
+                string place = list[i].building;
+                DateTime date = new DateTime(list[i].date.Year, list[i].date.Month, list[i].date.Day);
+                if (!date.Equals(lastStartDay))
+                {
+                    for (int k = 0; k < TagInfo.faculties.Length; k++)
+                    {
+                        LogInInfo dayInfo = new LogInInfo(TagInfo.faculties[k], recordedAmount[k], lastStartDay, range); 
+                        loginInfo.Add(dayInfo);
+                    }
+
+                    recordedAmount = new int[TagInfo.faculties.Length];
+                    lastStartDay = date;
+                }
+
+                // tady nasčítávát podle místa
+                if (TagInfo.buildingTags.ContainsKey(place))
+                {
+                    int index = TagInfo.buildingTags[place];
+                    if (index == -1)
+                        for (int l = 0; l < TagInfo.faculties.Length; l++)
+                            recordedAmount[l] += list[i].amount;
+                    else if (index == -2)
+                    {
+                        recordedAmount[0] += list[i].amount;
+                        recordedAmount[1] += list[i].amount;
+                    }
+                    else
+                        recordedAmount[index] += list[i].amount;
+
+                }
+                else
+                {
+                    Console.WriteLine("Unknown code " + list[i].building);
+                }
+
+            }
+
+            for (int k = 0; k < TagInfo.faculties.Length; k++)
+            {
+                LogInInfo dayInfo = new LogInInfo(TagInfo.faculties[k], recordedAmount[k], lastStartDay, range);
+                loginInfo.Add(dayInfo);
+            }
+
+            return loginInfo;
+        }
+
+        private static List<JisInfo> ProcessOneLoginFileAsIntervals(string path, int interval)
+        {
+            throw new NotImplementedException();
+        }
+
     }
 }