274 lines
10 KiB
C#
274 lines
10 KiB
C#
using System.Globalization;
|
|
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 T1R1Processor
|
|
{
|
|
private readonly AppDbContext _db;
|
|
private readonly SpreadsheetsResource.ValuesResource _googleSheetValues;
|
|
private readonly LayersController _controller;
|
|
private readonly LogsController _logsController;
|
|
|
|
public T1R1Processor(
|
|
AppDbContext db,
|
|
SpreadsheetsResource.ValuesResource googleSheetValues,
|
|
LayersController controller,
|
|
LogsController logsController)
|
|
{
|
|
_db = db;
|
|
_googleSheetValues = googleSheetValues;
|
|
_controller = controller;
|
|
_logsController = logsController;
|
|
}
|
|
|
|
public void Process(Layer processWorker)
|
|
{
|
|
var year = int.Parse(processWorker.Records?.SingleOrDefault(x => x.Code == "Year")?.Desc1!);
|
|
var sources = processWorker.Records?.Where(x => x.Code == "Source").ToList();
|
|
if (!sources!.Any())
|
|
{
|
|
throw new Exception("Source record not found");
|
|
}
|
|
var codes = processWorker.Records?.SingleOrDefault(x => x.Code == "Codes")?.Desc1;
|
|
if (codes == null)
|
|
{
|
|
throw new Exception("Codes record not found");
|
|
}
|
|
var codesList = ProcessHelper.ParseCodes(codes);
|
|
|
|
var processedLayer = _db.Layers
|
|
.Where(x => x.ParentId == processWorker.Id
|
|
&& !x.IsDeleted)
|
|
.OrderByDescending(x => x.CreatedAt)
|
|
.FirstOrDefault();
|
|
|
|
var isNew = false;
|
|
if (processedLayer == null)
|
|
{
|
|
isNew = true;
|
|
processedLayer = new Layer
|
|
{
|
|
Id = Guid.NewGuid(),
|
|
Type = LayerType.Processed,
|
|
ParentId = processWorker.Id,
|
|
Number = _db.Layers.Count() + 1
|
|
};
|
|
processedLayer.Name = $"L{processedLayer.Number}-P-{year}-R1-T1";
|
|
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.ModifiedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D");
|
|
processedLayer.ModifiedAt = DateTime.UtcNow;
|
|
|
|
var dataSources = new List<Layer>();
|
|
|
|
foreach (var source in sources!)
|
|
{
|
|
for (var month = 1; month <= DateTime.UtcNow.Month; month++)
|
|
{
|
|
var monthCopy = month;
|
|
var dataSource = _db.Layers.Where(x =>
|
|
x.Type == LayerType.Processed &&
|
|
!x.IsDeleted &&
|
|
x.Name != null && x.Name.Contains($"{year}/{monthCopy}-{source.Desc1}-T3")
|
|
)
|
|
.Include(x => x.Records)
|
|
.FirstOrDefault();
|
|
if (dataSource != null)
|
|
{
|
|
dataSources.Add(dataSource);
|
|
}
|
|
else
|
|
{
|
|
_logsController.AddEntry(new LogEntry
|
|
{
|
|
Title = $"{processWorker.Name}, {processWorker.Id}",
|
|
Type = LogEntryType.Warning,
|
|
LogType = LogType.Process,
|
|
Message = $"Data source {year}/{month}-{source.Desc1}-T3 not found",
|
|
CreatedAt = DateTime.UtcNow
|
|
});
|
|
}
|
|
}
|
|
// year summary
|
|
var dataSourceSum = _db.Layers.Where(x =>
|
|
x.Type == LayerType.Processed &&
|
|
!x.IsDeleted &&
|
|
x.Name != null && x.Name.Contains($"{year}/13-{source.Desc1}-T3")
|
|
)
|
|
.Include(x => x.Records)
|
|
.FirstOrDefault();
|
|
if (dataSourceSum != null)
|
|
{
|
|
dataSources.Add(dataSourceSum);
|
|
}
|
|
else
|
|
{
|
|
_logsController.AddEntry(new LogEntry
|
|
{
|
|
Title = $"{processWorker.Name}, {processWorker.Id}",
|
|
Type = LogEntryType.Warning,
|
|
LogType = LogType.Process,
|
|
Message = $"Data source {year}/13-{source.Desc1}-T3 not found",
|
|
CreatedAt = DateTime.UtcNow
|
|
});
|
|
}
|
|
}
|
|
|
|
|
|
if (dataSources.Count == 0)
|
|
{
|
|
throw new Exception("DataSources are empty");
|
|
}
|
|
|
|
var newRecords = dataSources
|
|
.SelectMany(x => x.Records!)
|
|
.Where(x => codesList.Contains(int.Parse(x.Code!)))
|
|
.Select(x =>
|
|
{
|
|
var layer = dataSources.SingleOrDefault(y => y.Id == x.LayerId);
|
|
var postFix = layer!.Name!.Split("/")[1].Split("-")[0];
|
|
if (postFix.Length == 1)
|
|
{
|
|
postFix = "0" + postFix;
|
|
}
|
|
|
|
var newRecord = new Record
|
|
{
|
|
Id = Guid.NewGuid(),
|
|
Code = x.Code + postFix,
|
|
CreatedAt = DateTime.UtcNow,
|
|
ModifiedAt = DateTime.UtcNow,
|
|
Value1 = x.Value32
|
|
};
|
|
|
|
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();
|
|
|
|
UpdateReport();
|
|
}
|
|
|
|
private void UpdateReport()
|
|
{
|
|
const string sheetId = "1pph-XowjlK5CIaCEV_A5buK4ceJ0Z0YoUlDI4VMkhhA";
|
|
const string sheetName = "Raport_R1_Eksport";
|
|
var request = _googleSheetValues.Get(sheetId, "C4:EX4");
|
|
var response = request.Execute();
|
|
|
|
var r1 = _db.Layers
|
|
.Where(x => x.Number == 1205)
|
|
.Include(x => x.Records)
|
|
.FirstOrDefault();
|
|
|
|
const int startRow = 6;
|
|
|
|
var codesRow = response.Values[0];
|
|
for (var i = 1; i <= DateTime.UtcNow.Month; i++)
|
|
{
|
|
var values = new List<object>();
|
|
var month = i < 10 ? $"0{i}" : i.ToString();
|
|
var row = (startRow + i).ToString();
|
|
foreach (string code in codesRow)
|
|
{
|
|
var record = r1!.Records?.SingleOrDefault(x => x.Code == $"{code}{month}");
|
|
if (record != null)
|
|
{
|
|
values.Add(record.Value1!.Value);
|
|
}
|
|
else
|
|
{
|
|
values.Add("0");
|
|
}
|
|
}
|
|
var valueRange = new ValueRange
|
|
{
|
|
Values = new List<IList<object>> { values }
|
|
};
|
|
var update = _googleSheetValues.Update(valueRange, sheetId, $"{sheetName}!C{row}:XZ{row}");
|
|
update.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED;
|
|
update.Execute();
|
|
}
|
|
|
|
// sum
|
|
var valuesSum = new List<object>();
|
|
var emptyRow = new List<object>();
|
|
var rowEmpty = (startRow + DateTime.UtcNow.Month + 1).ToString();
|
|
var rowSum = (startRow + DateTime.UtcNow.Month + 2).ToString();
|
|
foreach (string code in codesRow)
|
|
{
|
|
var record = r1!.Records?.SingleOrDefault(x => x.Code == $"{code}13");
|
|
emptyRow.Add("");
|
|
if (record != null)
|
|
{
|
|
valuesSum.Add(record.Value1!.Value);
|
|
}
|
|
else
|
|
{
|
|
valuesSum.Add("0");
|
|
}
|
|
}
|
|
// insert empty row before sum
|
|
var valueRangeEmpty = new ValueRange
|
|
{
|
|
Values = new List<IList<object>> { emptyRow }
|
|
};
|
|
var updateEmpty = _googleSheetValues.Update(valueRangeEmpty, sheetId, $"{sheetName}!C{rowEmpty}:XZ{rowEmpty}");
|
|
updateEmpty.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED;
|
|
updateEmpty.Execute();
|
|
|
|
var valueRangeSum = new ValueRange
|
|
{
|
|
Values = new List<IList<object>> { valuesSum }
|
|
};
|
|
var updateSum = _googleSheetValues.Update(valueRangeSum, sheetId, $"{sheetName}!C{rowSum}:XZ{rowSum}");
|
|
updateSum.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED;
|
|
updateSum.Execute();
|
|
|
|
// update time
|
|
var timeUtc = new List<object>
|
|
{
|
|
r1!.ModifiedAt.ToString(CultureInfo.InvariantCulture)
|
|
};
|
|
var valueRangeUtcTime = new ValueRange
|
|
{
|
|
Values = new List<IList<object>> { timeUtc }
|
|
};
|
|
var updateTimeUtc = _googleSheetValues.Update(valueRangeUtcTime, sheetId, $"{sheetName}!G1");
|
|
updateTimeUtc.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED;
|
|
updateTimeUtc.Execute();
|
|
|
|
var warsawTimeZone = TimeZoneInfo.FindSystemTimeZoneById("Central European Standard Time");
|
|
var warsawTime = TimeZoneInfo.ConvertTimeFromUtc(r1.ModifiedAt.ToUniversalTime(), warsawTimeZone);
|
|
var timeWarsaw = new List<object>
|
|
{
|
|
warsawTime.ToString(CultureInfo.InvariantCulture)
|
|
};
|
|
var valueRangeWarsawTime = new ValueRange
|
|
{
|
|
Values = new List<IList<object>> { timeWarsaw }
|
|
};
|
|
var updateTimeWarsaw = _googleSheetValues.Update(valueRangeWarsawTime, sheetId, $"{sheetName}!G2");
|
|
updateTimeWarsaw.ValueInputOption = SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED;
|
|
updateTimeWarsaw.Execute();
|
|
}
|
|
} |