From f85d14c31c19336bc096ae545632c3dbee3d2001 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Micha=C5=82=20Zieli=C5=84ski?= Date: Mon, 25 Mar 2024 10:43:05 +0100 Subject: [PATCH] New process type; refactor auto process --- Utils/SQL_HELPERS.sql | 117 +++++---- WebAPI/Controllers/LayersController.cs | 114 +++++---- ....MultiSourceCopySelectedCodes.processor.cs | 85 ------- ...eCopySelectedCodesYearSummary.processor.cs | 227 ++++++++++++++++++ 4 files changed, 358 insertions(+), 185 deletions(-) create mode 100644 WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodesYearSummary.processor.cs diff --git a/Utils/SQL_HELPERS.sql b/Utils/SQL_HELPERS.sql index 256beab..c92cdad 100644 --- a/Utils/SQL_HELPERS.sql +++ b/Utils/SQL_HELPERS.sql @@ -180,62 +180,61 @@ -- T3-MultiSourceCopySelectedCodes ---DECLARE @LayerId UNIQUEIDENTIFIER; ---SET @LayerId = '76a86f96-5d3b-41aa-96fe-ae5c647a060c'; --- ---INSERT INTO [diunabi-morska].[dbo].[Layers] ---([Id], [Number], [Source], [Name], [CreatedAt], [ModifiedAt], [IsDeleted], ---[CreatedById], [ModifiedById], [Type]) ---VALUES ((SELECT @LayerId), 800, 'Manual', 'L800-A-PW_AB-2024/03-202402292027', ---GETDATE(), GETDATE(), 0, '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 2); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Source', 'K5', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Source', 'M7', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Source', 'PU', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Source', 'FK', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Type', 'ProcessWorker', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'ProcessType', 'T3-MultiSourceCopySelectedCodes', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'IsEnabled', 'True', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Year', '2024', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Month', '03', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- ---INSERT INTO [diunabi-morska].[dbo].[Records] ---([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ---VALUES ((SELECT NEWID()), 'Codes', '5000-5003;5005;5081-5095;6000-6003;6005;6081-6095;7000-7003;7005;7081-7095;8000-8003;8005;8081-8095', ---GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); --- \ No newline at end of file +DECLARE @LayerId UNIQUEIDENTIFIER; +SET @LayerId = '76a86f96-5d3b-41aa-96fe-ae5c647a060c'; + +INSERT INTO [diunabi-morska].[dbo].[Layers] +([Id], [Number], [Source], [Name], [CreatedAt], [ModifiedAt], [IsDeleted], +[CreatedById], [ModifiedById], [Type]) +VALUES ((SELECT @LayerId), 800, 'Manual', 'L800-A-PW_AB-2024/03-202402292027', +GETDATE(), GETDATE(), 0, '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 2); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Source', 'K5', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Source', 'M7', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Source', 'PU', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Source', 'FK', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Type', 'ProcessWorker', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'ProcessType', 'T3-MultiSourceCopySelectedCodes', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'IsEnabled', 'True', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Year', '2024', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Month', '03', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); + +INSERT INTO [diunabi-morska].[dbo].[Records] +([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) +VALUES ((SELECT NEWID()), 'Codes', '5000-5003;5005;5081-5095;6000-6003;6005;6081-6095;7000-7003;7005;7081-7095;8000-8003;8005;8081-8095', +GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, (SELECT @LayerId)); diff --git a/WebAPI/Controllers/LayersController.cs b/WebAPI/Controllers/LayersController.cs index ee8595b..d129aa8 100644 --- a/WebAPI/Controllers/LayersController.cs +++ b/WebAPI/Controllers/LayersController.cs @@ -238,9 +238,9 @@ namespace WebAPI.Controllers } } [HttpGet] - [Route("AutoProcess/{apiKey}/{type}")] + [Route("AutoProcess/{apiKey}")] [AllowAnonymous] - public IActionResult AutoProcess(string apiKey, string type) + public IActionResult AutoProcess(string apiKey) { if (Request.Host.Value != configuration["apiLocalUrl"] || apiKey != configuration["apiKey"]) { @@ -251,62 +251,80 @@ namespace WebAPI.Controllers throw new Exception("Google Sheets API not initialized"); } - try - { - List processWorkerLayers = db.Layers - .Include(x => x.Records) - .Where(x => - x.Records!.Any(x => x.Code == "Type" && x.Desc1 == "ProcessWorker") && - x.Records!.Any(x => x.Code == "IsEnabled" && x.Desc1 == "True") && - x.Records!.Any(x => x.Code == "ProcessType" && x.Desc1 == type) - ) - .OrderBy(x => x.CreatedAt) - .ToList(); + string[] processTypes = new string[] { + "T3-SingleSource", + "T3-MultiSourceSummary", + "T3-SourceYearSummary", + "T3-MultiSourceYearSummary", + "T3-MultiSourceCopySelectedCodes", + "T3-MultiSourceCopySelectedCodesYearSummary" + }; - if (processWorkerLayers.Count() == 0) + foreach (string type in processTypes) + { + try { logsController.AddEntry(new LogEntry { - Title = "No Layers to process.", + Title = $"Processing: {type}", Type = LogEntryType.info, LogType = LogType.process, CreatedAt = DateTime.UtcNow, }); - return Ok(); - } - foreach (Layer processWorker in processWorkerLayers) - { - try - { - ProcessLayer(processWorker); - } - catch (Exception e) + List processWorkerLayers = db.Layers + .Include(x => x.Records) + .Where(x => + x.Records!.Any(x => x.Code == "Type" && x.Desc1 == "ProcessWorker") && + x.Records!.Any(x => x.Code == "IsEnabled" && x.Desc1 == "True") && + x.Records!.Any(x => x.Code == "ProcessType" && x.Desc1 == type) + ) + .OrderBy(x => x.CreatedAt) + .ToList(); + + if (processWorkerLayers.Count() == 0) { logsController.AddEntry(new LogEntry { - Title = $"{processWorker!.Name}, {processWorker.Id}", - Type = LogEntryType.error, + Title = "No Layers to process.", + Type = LogEntryType.info, LogType = LogType.process, - Message = e.ToString(), - CreatedAt = DateTime.UtcNow + CreatedAt = DateTime.UtcNow, }); } + + foreach (Layer processWorker in processWorkerLayers) + { + try + { + ProcessLayer(processWorker); + } + catch (Exception e) + { + logsController.AddEntry(new LogEntry + { + Title = $"{processWorker!.Name}, {processWorker.Id}", + Type = LogEntryType.error, + LogType = LogType.process, + Message = e.ToString(), + CreatedAt = DateTime.UtcNow + }); + } + } } - return Ok(); - } - catch (Exception e) - { - logsController.AddEntry(new LogEntry + catch (Exception e) { - Title = "Process error", - Type = LogEntryType.error, - LogType = LogType.process, - Message = e.ToString(), - CreatedAt = DateTime.UtcNow - }); - return BadRequest(e.ToString()); + logsController.AddEntry(new LogEntry + { + Title = "Process error", + Type = LogEntryType.error, + LogType = LogType.process, + Message = e.ToString(), + CreatedAt = DateTime.UtcNow + }); + } } + return Ok(); } internal void ProcessLayer(Layer processWorker) { @@ -356,6 +374,21 @@ namespace WebAPI.Controllers }); return; } + if (processType == "T3-MultiSourceCopySelectedCodesYearSummary") + { + T3MultiSourceCopySelectedCodesYearSummaryProcessor processor = new T3MultiSourceCopySelectedCodesYearSummaryProcessor(db, googleSheetValues, this); + processor.process(processWorker!); + + logsController.AddEntry(new LogEntry + { + Title = $"{processWorker!.Name}, {processWorker.Id}", + Type = LogEntryType.info, + LogType = LogType.process, + Message = "Success", + CreatedAt = DateTime.UtcNow + }); + return; + } string? month = processWorker?.Records?.SingleOrDefault(x => x.Code == "Month")?.Desc1; if (month == null) { @@ -379,7 +412,6 @@ namespace WebAPI.Controllers { T3MultiSourceCopySelectedCodesProcessor processor = new T3MultiSourceCopySelectedCodesProcessor(db, googleSheetValues, this); processor.process(processWorker!); - processor.updateReport(); break; } } diff --git a/WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodes.processor.cs b/WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodes.processor.cs index a6ebba4..84b6b0e 100644 --- a/WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodes.processor.cs +++ b/WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodes.processor.cs @@ -119,90 +119,5 @@ namespace WebAPI.dataProcessors 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(); - } } } diff --git a/WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodesYearSummary.processor.cs b/WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodesYearSummary.processor.cs new file mode 100644 index 0000000..193bc27 --- /dev/null +++ b/WebAPI/dataProcessors/t3.MultiSourceCopySelectedCodesYearSummary.processor.cs @@ -0,0 +1,227 @@ +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 T3MultiSourceCopySelectedCodesYearSummaryProcessor + { + private readonly AppDbContext db; + private readonly SpreadsheetsResource.ValuesResource googleSheetValues; + private readonly LayersController controller; + + public T3MultiSourceCopySelectedCodesYearSummaryProcessor( + 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!); + + 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}/13-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 newRecords = new List(); + + List dataSources = new List(); + + for (int i = 1; i < 13; i++) + { + Layer? dataSource = db.Layers.Where(x => + x.Type == LayerType.processed + && !x.IsDeleted + && x.Name != null && x.Name.Contains($"{year}/{i}-AB-T3")) + .Include(x => x.Records) + .FirstOrDefault(); + if (dataSource != null) + { + dataSources.Add(dataSource!); + } + } + + if (dataSources.Count == 0) + { + throw new Exception("DataSources are empty"); + } + + List allRecords = dataSources.SelectMany(x => x.Records!).ToList(); + + foreach (Record baseRecord in dataSources.Last()?.Records!) + { + List codeRecords = allRecords.Where(x => x.Code == baseRecord.Code).ToList(); + Record processedRecord = new Record + { + Id = Guid.NewGuid(), + Code = baseRecord.Code, + CreatedAt = DateTime.UtcNow, + ModifiedAt = DateTime.UtcNow + }; + for (var i = 1; i < 33; i++) + { + ProcessHelper.setValue(processedRecord, i, + codeRecords.Sum(x => ProcessHelper.getValue(x, i))); + } + newRecords.Add(processedRecord); + } + + 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(); + updateReport(); + } + + 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(); + + Layer? sum = db.Layers + .Where(x => x.Number == 955) + .Include(x => x.Records) + .FirstOrDefault(); + + List januaryValues = new List(); + List februaryValues = new List(); + List marchValues = new List(); + + List sumValues = 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); + Record? sumRecord = sum!.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(""); + } + if (sumRecord != null) + { + double? sumValue = ProcessHelper.getValue(sumRecord, 32); + sumValues.Add(sumValue!.Value); + } + else + { + sumValues.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(); + + ValueRange sumValueRange = new ValueRange + { + Values = new List> { sumValues } + }; + SpreadsheetsResource.ValuesResource.UpdateRequest updateSum = googleSheetValues.Update(sumValueRange, sheetId, $"{sheetName}!C12:CH12"); + updateSum.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED; + updateSum.Execute(); + } + + } +}