117 lines
4.4 KiB
C#
117 lines
4.4 KiB
C#
using DiunaBIWebAPI.dataProcessors;
|
|
using Google.Apis.Sheets.v4;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using System;
|
|
using System.Globalization;
|
|
using WebAPI.Controllers;
|
|
using WebAPI.Models;
|
|
|
|
namespace WebAPI.dataProcessors
|
|
{
|
|
public class T4SingleSourceProcessor
|
|
{
|
|
private readonly AppDbContext db;
|
|
private readonly SpreadsheetsResource.ValuesResource googleSheetValues;
|
|
private readonly LayersController controller;
|
|
|
|
public T4SingleSourceProcessor(
|
|
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!);
|
|
string? sourceLayer = processWorker?.Records?.SingleOrDefault(x => x.Code == "SourceLayer")?.Desc1;
|
|
if (sourceLayer == null)
|
|
{
|
|
throw new Exception("SourceLayer record not found");
|
|
}
|
|
Layer? sourceImportWorker = db.Layers.SingleOrDefault(x => x.Name == sourceLayer);
|
|
if (sourceImportWorker == null)
|
|
{
|
|
throw new Exception("SourceImportWorkerL layer not found");
|
|
}
|
|
string? source= processWorker?.Records?.SingleOrDefault(x => x.Code == "Source")?.Desc1;
|
|
if (sourceLayer == null)
|
|
{
|
|
throw new Exception("Source record not found");
|
|
}
|
|
|
|
Layer? processedLayer = db.Layers
|
|
.Where(x => x.ParentId == processWorker!.Id)
|
|
.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}-{source}-T4";
|
|
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<ProcessSource>();
|
|
processedLayer.ModifiedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D");
|
|
processedLayer.ModifiedAt = DateTime.UtcNow;
|
|
|
|
|
|
List<Record> newRecords = new List<Record>();
|
|
|
|
Layer? dataSource = db.Layers
|
|
.Include(x => x.Records)
|
|
.Where(x => x.ParentId == sourceImportWorker.Id
|
|
&& !x.IsDeleted)
|
|
.OrderByDescending(x => x.CreatedAt)
|
|
.FirstOrDefault();
|
|
|
|
if (dataSource == null)
|
|
{
|
|
throw new Exception($"DataSource not found, {sourceImportWorker.Name}");
|
|
}
|
|
|
|
foreach (Record record in dataSource.Records!)
|
|
{
|
|
Record processedRecord = new Record
|
|
{
|
|
Id = Guid.NewGuid(),
|
|
Code = record.Code,
|
|
Desc1 = record.Desc1,
|
|
Value1 = record.Value1,
|
|
CreatedAt = DateTime.UtcNow,
|
|
ModifiedAt = DateTime.UtcNow
|
|
};
|
|
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();
|
|
}
|
|
|
|
}
|
|
}
|