98 lines
3.5 KiB
C#
98 lines
3.5 KiB
C#
using DiunaBIWebAPI.dataProcessors;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using WebAPI.Controllers;
|
|
using WebAPI.Models;
|
|
|
|
namespace WebAPI.dataProcessors;
|
|
|
|
public class T3MultiSourceCopySelectedCodesProcessor(
|
|
AppDbContext db,
|
|
LayersController controller)
|
|
{
|
|
public void Process(Layer processWorker)
|
|
{
|
|
var year = int.Parse(processWorker.Records?.SingleOrDefault(x => x.Code == "Year")?.Desc1!);
|
|
var month = int.Parse(processWorker.Records?.SingleOrDefault(x => x.Code == "Month")?.Desc1!);
|
|
var sources = processWorker.Records?.Where(x => x.Code == "Source").ToList();
|
|
if (sources!.Count == 0)
|
|
{
|
|
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}/{month:D2}-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.ModifiedById = Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D");
|
|
processedLayer.ModifiedAt = DateTime.UtcNow;
|
|
|
|
var dataSources = sources.Select(source => db.Layers
|
|
.Where(x => x.Type == LayerType.Processed && !x.IsDeleted && x.Name != null && x.Name.Contains($"{year}/{month:D2}-{source.Desc1}-T3"))
|
|
.Include(x => x.Records).AsNoTracking()
|
|
.FirstOrDefault())
|
|
.OfType<Layer>()
|
|
.ToList();
|
|
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 newRecord = new Record
|
|
{
|
|
Id = Guid.NewGuid(),
|
|
Code = x.Code,
|
|
CreatedAt = DateTime.UtcNow,
|
|
ModifiedAt = DateTime.UtcNow
|
|
};
|
|
for (var i = 1; i < 33; i++)
|
|
{
|
|
ProcessHelper.SetValue(newRecord, i, ProcessHelper.GetValue(x, i));
|
|
}
|
|
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();
|
|
}
|
|
} |