using DiunaBIWebAPI.dataProcessors; using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4.Data; using Microsoft.EntityFrameworkCore; using WebAPI.Controllers; using WebAPI.Models; namespace WebAPI.dataProcessors { public class T3MultiSourceCopySelectedCodesProcessor { private readonly AppDbContext db; private readonly SpreadsheetsResource.ValuesResource googleSheetValues; private readonly LayersController controller; public T3MultiSourceCopySelectedCodesProcessor( AppDbContext _db, SpreadsheetsResource.ValuesResource _googleSheetValues, LayersController _controller) { db = _db; googleSheetValues = _googleSheetValues; controller = _controller; } public void process(Layer processWorker) { int year = int.Parse(processWorker!.Records?.SingleOrDefault(x => x.Code == "Year")?.Desc1!); int month = int.Parse(processWorker!.Records?.SingleOrDefault(x => x.Code == "Month")?.Desc1!); List? sources = processWorker.Records?.Where(x => x.Code == "Source").ToList(); if (sources!.Count() == 0) { throw new Exception("Source record not found"); } string? codes = processWorker.Records?.SingleOrDefault(x => x.Code == "Codes")?.Desc1; if (codes == null) { throw new Exception("Codes record not found"); } // create array of integers from string codes where: '501-503;505-505;510-512' -> [501,502,503,505,510,511,512] List codesList = ProcessHelper.parseCodes(codes); Layer? processedLayer = db.Layers .Where(x => x.ParentId == processWorker!.Id && !x.IsDeleted) .OrderByDescending(x => x.CreatedAt) .FirstOrDefault(); bool isNew = false; if (processedLayer == null) { isNew = true; processedLayer = new Layer { Id = Guid.NewGuid(), Source = "", Type = LayerType.processed, ParentId = processWorker!.Id, Number = db.Layers.Count() + 1, }; processedLayer.Name = $"L{processedLayer.Number}-P-{year}/{month}-AB-T3"; processedLayer.CreatedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D"); processedLayer.ModifiedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D"); processedLayer.CreatedAt = DateTime.UtcNow; processedLayer.ModifiedAt = DateTime.UtcNow; } processedLayer.Sources = new List(); processedLayer.ModifiedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D"); processedLayer.ModifiedAt = DateTime.UtcNow; List dataSources = new List(); foreach (Record source in sources!) { Layer? dataSource = db.Layers.Where(x => x.Type == LayerType.processed && !x.IsDeleted && x.Name != null && x.Name.Contains($"{year}/{month}-{source.Desc1}-T3") ) .Include(x => x.Records) .FirstOrDefault(); if (dataSource != null) { dataSources.Add(dataSource); } } if (dataSources.Count == 0) { throw new Exception($"DataSources are empty"); } List newRecords = dataSources .SelectMany(x => x.Records!) .Where(x => codesList.Contains(int.Parse(x.Code!))) .Select(x => { Record newRecord = new Record { Id = Guid.NewGuid(), Code = x.Code, CreatedAt = DateTime.UtcNow, ModifiedAt = DateTime.UtcNow }; for (var i = 1; i < 33; i++) { ProcessHelper.setValue(newRecord, i, ProcessHelper.getValue(x, i)); } return newRecord; }) .ToList(); if (isNew) { db.Layers.Add(processedLayer); } else { db.Layers.Update(processedLayer); } controller.SaveRecords(processedLayer.Id, newRecords, Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D")); db.SaveChanges(); } public void updateReport() { string sheetId = "1pph-XowjlK5CIaCEV_A5buK4ceJ0Z0YoUlDI4VMkhhA"; string sheetName = "Raport_AB_Eksport"; SpreadsheetsResource.ValuesResource.GetRequest request = googleSheetValues.Get(sheetId, "C4:CH4"); var response = request.Execute(); Layer? january = db.Layers .Where(x => x.Number == 572) .Include(x => x.Records) .FirstOrDefault(); Layer? february = db.Layers .Where(x => x.Number == 742) .Include(x => x.Records) .FirstOrDefault(); Layer? march = db.Layers .Where(x => x.Number == 822) .Include(x => x.Records) .FirstOrDefault(); List januaryValues = new List(); List februaryValues = new List(); List marchValues = new List(); var codesRow = response.Values[0]; foreach (string code in codesRow) { Record? januaryRecord = january!.Records?.SingleOrDefault(x => x.Code == code); Record? februaryRecord = february!.Records?.SingleOrDefault(x => x.Code == code); Record? marchRecord = march!.Records?.SingleOrDefault(x => x.Code == code); if (januaryRecord != null) { double? januaryValue = ProcessHelper.getValue(januaryRecord, 32); januaryValues.Add(januaryValue!.Value); } else { januaryValues.Add(""); } if (februaryRecord != null) { double? februaryValue = ProcessHelper.getValue(februaryRecord, 32); februaryValues.Add(februaryValue!.Value); } else { februaryValues.Add(""); } if (marchRecord != null) { double? marchValue = ProcessHelper.getValue(marchRecord, 32); marchValues.Add(marchValue!.Value); } else { marchValues.Add(""); } } ValueRange januaryValueRange = new ValueRange { Values = new List> { januaryValues } }; SpreadsheetsResource.ValuesResource.UpdateRequest updateJanuary = googleSheetValues.Update(januaryValueRange, sheetId, $"{sheetName}!C7:CH7"); updateJanuary.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED; updateJanuary.Execute(); ValueRange februaryValueRange = new ValueRange { Values = new List> { februaryValues } }; SpreadsheetsResource.ValuesResource.UpdateRequest updateFebruary = googleSheetValues.Update(februaryValueRange, sheetId, $"{sheetName}!C8:CH8"); updateFebruary.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED; updateFebruary.Execute(); ValueRange marchValueRange = new ValueRange { Values = new List> { marchValues } }; SpreadsheetsResource.ValuesResource.UpdateRequest updateMarch = googleSheetValues.Update(marchValueRange, sheetId, $"{sheetName}!C9:CH9"); updateMarch.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED; updateMarch.Execute(); } } }