using System; using System.Globalization; using Google.Apis.Sheets.v4; using WebAPI; using WebAPI.Controllers; using WebAPI.Models; namespace DiunaBIWebAPI.dataImporters { public class MorskaImporter { private readonly AppDbContext db; private readonly SpreadsheetsResource.ValuesResource googleSheetValues; private readonly LayersController controller; public MorskaImporter( AppDbContext _db, SpreadsheetsResource.ValuesResource _googleSheetValues, LayersController _controller) { db = _db; googleSheetValues = _googleSheetValues; controller = _controller; } public void import(Layer importWorker) { string? sheetId = importWorker.Records!.Where(x => x.Code == "SheetId").FirstOrDefault()?.Desc1; if (sheetId == null) { throw new Exception($"SheetId not found, {importWorker.Name}"); } string? sheetTabName = importWorker.Records!.Where(x => x.Code == "SheetTabName").FirstOrDefault()?.Desc1; if (sheetTabName == null) { throw new Exception($"SheetTabName not found, {importWorker.Name}"); } string? importYearCell = importWorker.Records!.Where(x => x.Code == "ImportYear").FirstOrDefault()?.Desc1; if (importYearCell == null) { throw new Exception($"ImportYear not found, {importWorker.Name}"); } string? importMonthCell = importWorker.Records!.Where(x => x.Code == "ImportMonth").FirstOrDefault()?.Desc1; if (importMonthCell == null) { throw new Exception($"ImportMonth not found, {importWorker.Name}"); } string? importNameCell = importWorker.Records!.Where(x => x.Code == "ImportName").FirstOrDefault()?.Desc1; if (importNameCell == null) { throw new Exception($"ImportName not found, {importWorker.Name}"); } string? checkSumCell = importWorker.Records!.Where(x => x.Code == "SheetId").FirstOrDefault()?.Desc1; if (checkSumCell == null) { throw new Exception($"SheetId not found, {importWorker.Name}"); } string? dataRange = importWorker.Records!.Where(x => x.Code == "DataRange").FirstOrDefault()?.Desc1; if (dataRange == null) { throw new Exception($"DataRange not found, {importWorker.Name}"); } var nameResponse = googleSheetValues.Get(sheetId, $"{sheetTabName}!{importNameCell}:{importNameCell}").Execute(); string? name = nameResponse.Values?[0][0].ToString(); if (name == null) { throw new Exception($"ImportName cell is empty, {importWorker.Name}"); } var yearResponse = googleSheetValues.Get(sheetId, $"{sheetTabName}!{importYearCell}:{importYearCell}").Execute(); string? year = yearResponse.Values[0][0].ToString(); if (year == null) { throw new Exception($"ImportYear cell is empty, {importWorker.Name}"); } var monthResponse = googleSheetValues.Get(sheetId, $"{sheetTabName}!{importMonthCell}:{importMonthCell}").Execute(); string? month = monthResponse.Values[0][0].ToString(); if (month == null) { throw new Exception($"ImportMonth cell is empty, {importWorker.Name}"); } Layer layer = new Layer { Source = "GoogleSheet", Number = db.Layers.Count() + 1, ParentId = importWorker.Id, Type = LayerType.import, CreatedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D"), ModifiedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D"), CreatedAt = DateTime.UtcNow, ModifiedAt = DateTime.UtcNow }; layer.Name = $"L{layer.Number}-I-{name}-{year}/{month}-{DateTime.Now.ToString("yyyyMMddHHmm")}"; List newRecords = new List(); var dataRangeResponse = googleSheetValues.Get(sheetId, $"{sheetTabName}!{dataRange}").Execute(); var data = dataRangeResponse.Values; for (int i = 0; i < data[1].Count; i++) { double value; if ( data[0][i].ToString()?.Length > 0 && double.TryParse(data[1][i].ToString(), CultureInfo.GetCultureInfo("pl-PL"), out value)) { Record record = new Record { Id = Guid.NewGuid(), Code = data[0][i].ToString(), Value1 = value, CreatedAt = DateTime.UtcNow, ModifiedAt = DateTime.UtcNow }; newRecords.Add(record); }; } db.Layers.Add(layer); controller.SaveRecords(layer.Id, newRecords, Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D")); db.SaveChanges(); } } }