mz/DiunaBI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

R1_V2 reduce GSheet API calls

Browse Source
This commit is contained in:
Michał Zieliski
2024-08-20 12:18:17 +02:00
parent 7af4317522
commit dbc5920a7f
1 changed files with 28 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
WebAPI/dataProcessors/t1.r1_v2.processor.cs
View File

@@ -15,9 +15,6 @@ public class T1R1V2Processor(
LayersController controller, LayersController controller,
LogsController logsController) LogsController logsController)
{ {
private readonly SpreadsheetsResource.ValuesResource _googleSheetValues = googleSheetValues;
private readonly LogsController _logsController = logsController;
public void Process(Layer processWorker) public void Process(Layer processWorker)
{ {
var year = int.Parse(processWorker.Records?.SingleOrDefault(x => x.Code == "Year")?.Desc1!); var year = int.Parse(processWorker.Records?.SingleOrDefault(x => x.Code == "Year")?.Desc1!);
@@ -103,7 +100,7 @@ public class T1R1V2Processor(
{ {
if (dynamicCode.Desc1 == null) if (dynamicCode.Desc1 == null)
{ {
_logsController.AddEntry(new LogEntry logsController.AddEntry(new LogEntry
{ {
Title = $"{processWorker.Name}, {processWorker.Id}", Title = $"{processWorker.Name}, {processWorker.Id}",
Type = LogEntryType.Warning, Type = LogEntryType.Warning,
@@ -117,7 +114,7 @@ public class T1R1V2Processor(
var calc = new BaseCalc(dynamicCode.Desc1); var calc = new BaseCalc(dynamicCode.Desc1);
if (!calc.IsFormulaCorrect()) if (!calc.IsFormulaCorrect())
{ {
_logsController.AddEntry(new LogEntry logsController.AddEntry(new LogEntry
{ {
Title = $"{processWorker.Name}, {processWorker.Id}", Title = $"{processWorker.Name}, {processWorker.Id}",
Type = LogEntryType.Warning, Type = LogEntryType.Warning,
@@ -134,7 +131,7 @@ public class T1R1V2Processor(
} }
catch (Exception e) catch (Exception e)
{ {
_logsController.AddEntry(new LogEntry logsController.AddEntry(new LogEntry
{ {
Title = $"{processWorker.Name}, {processWorker.Id}", Title = $"{processWorker.Name}, {processWorker.Id}",
Type = LogEntryType.Warning, Type = LogEntryType.Warning,
@@ -147,7 +144,7 @@ public class T1R1V2Processor(
} }
catch (Exception e) catch (Exception e)
{ {
_logsController.AddEntry(new LogEntry logsController.AddEntry(new LogEntry
{ {
Title = $"{processWorker.Name}, {processWorker.Id}", Title = $"{processWorker.Name}, {processWorker.Id}",
Type = LogEntryType.Warning, Type = LogEntryType.Warning,
@@ -189,7 +186,7 @@ public class T1R1V2Processor(
{ {
const string sheetId = "1pph-XowjlK5CIaCEV_A5buK4ceJ0Z0YoUlDI4VMkhhA"; const string sheetId = "1pph-XowjlK5CIaCEV_A5buK4ceJ0Z0YoUlDI4VMkhhA";
const string sheetName = "Raport_R1_V2_Eksport"; const string sheetName = "Raport_R1_V2_Eksport";
var request = _googleSheetValues.Get(sheetId, "C4:EX4"); var request = googleSheetValues.Get(sheetId, $"{sheetName}!C4:CL4");
var response = request.Execute(); var response = request.Execute();
var r1 = db.Layers var r1 = db.Layers
@@ -200,6 +197,12 @@ public class T1R1V2Processor(
const int startRow = 6; const int startRow = 6;
var codesRow = response.Values[0]; var codesRow = response.Values[0];
var valueRange = new ValueRange
{
Values = new List<IList<object>>()
};
for (var i = 1; i <= 12; i++) for (var i = 1; i <= 12; i++)
{ {
var values = new List<object>(); var values = new List<object>();
@@ -217,18 +220,9 @@ public class T1R1V2Processor(
values.Add("0"); values.Add("0");
} }
} }
valueRange.Values.Add(values);
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();
Thread.Sleep(1000);
} }
// sum // sum
var valuesSum = new List<object>(); var valuesSum = new List<object>();
var emptyRow = new List<object>(); var emptyRow = new List<object>();
@@ -247,55 +241,36 @@ public class T1R1V2Processor(
valuesSum.Add("0"); valuesSum.Add("0");
} }
} }
// insert empty row before sum valueRange.Values.Add(emptyRow);
var valueRangeEmpty = new ValueRange valueRange.Values.Add(valuesSum);
{
Values = new List<IList<object>> { emptyRow } var update = googleSheetValues.Update(valueRange, sheetId, $"{sheetName}!C7:CL20");
}; update.ValueInputOption =
var updateEmpty = _googleSheetValues.Update(valueRangeEmpty, sheetId, $"{sheetName}!C{rowEmpty}:XZ{rowEmpty}");
updateEmpty.ValueInputOption =
SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED; SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED;
updateEmpty.Execute(); update.Execute();
Thread.Sleep(1000);
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();
Thread.Sleep(1000);
// update time // update time
var timeUtc = new List<object> var timeUtc = new List<object>
{ {
r1!.ModifiedAt.ToString("dd.MM.yyyy HH:mm:ss", CultureInfo.GetCultureInfo("pl-PL")) r1!.ModifiedAt.ToString("dd.MM.yyyy HH:mm:ss", CultureInfo.GetCultureInfo("pl-PL"))
}; };
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();
Thread.Sleep(1000);
var warsawTimeZone = TimeZoneInfo.FindSystemTimeZoneById("Central European Standard Time"); var warsawTimeZone = TimeZoneInfo.FindSystemTimeZoneById("Central European Standard Time");
var warsawTime = TimeZoneInfo.ConvertTimeFromUtc(r1.ModifiedAt.ToUniversalTime(), warsawTimeZone); var warsawTime = TimeZoneInfo.ConvertTimeFromUtc(r1.ModifiedAt.ToUniversalTime(), warsawTimeZone);
var timeWarsaw = new List<object> var timeWarsaw = new List<object>
{ {
warsawTime.ToString("dd.MM.yyyy HH:mm:ss", CultureInfo.GetCultureInfo("pl-PL")) warsawTime.ToString("dd.MM.yyyy HH:mm:ss", CultureInfo.GetCultureInfo("pl-PL"))
}; };
var valueRangeWarsawTime = new ValueRange var valueRangeTime = new ValueRange
{ {
Values = new List<IList<object>> { timeWarsaw } Values = new List<IList<object>> ()
}; };
var updateTimeWarsaw = _googleSheetValues.Update(valueRangeWarsawTime, sheetId, $"{sheetName}!G2"); valueRangeTime.Values.Add(timeUtc);
updateTimeWarsaw.ValueInputOption = valueRangeTime.Values.Add(timeWarsaw);
var updateTimeUtc = googleSheetValues.Update(valueRangeTime, sheetId, $"{sheetName}!G1:G2");
updateTimeUtc.ValueInputOption =
SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED; SpreadsheetsResource.ValuesResource.UpdateRequest.ValueInputOptionEnum.USERENTERED;
updateTimeWarsaw.Execute(); updateTimeUtc.Execute();
} }
} }