73 lines
3.2 KiB
C#
73 lines
3.2 KiB
C#
using TrafagSalesExporter.Models;
|
|
|
|
namespace TrafagSalesExporter.Services;
|
|
|
|
public class SapCompositionService : ISapCompositionService
|
|
{
|
|
private readonly ISapGatewayService _sapGatewayService;
|
|
private readonly IMappedSalesRecordComposer _composer;
|
|
private readonly IAppEventLogService _appEventLogService;
|
|
|
|
public SapCompositionService(
|
|
ISapGatewayService sapGatewayService,
|
|
IMappedSalesRecordComposer composer,
|
|
IAppEventLogService appEventLogService)
|
|
{
|
|
_sapGatewayService = sapGatewayService;
|
|
_composer = composer;
|
|
_appEventLogService = appEventLogService;
|
|
}
|
|
|
|
public async Task<List<SalesRecord>> BuildSalesRecordsAsync(
|
|
Site site,
|
|
IReadOnlyList<SapSourceDefinition> sources,
|
|
IReadOnlyList<SapJoinDefinition> joins,
|
|
IReadOnlyList<SapFieldMapping> mappings,
|
|
string username,
|
|
string password,
|
|
int? preferredYear = null,
|
|
CancellationToken cancellationToken = default)
|
|
{
|
|
if (string.IsNullOrWhiteSpace(site.SapServiceUrl))
|
|
throw new InvalidOperationException($"Standort '{site.Land}' hat keine SAP Service URL.");
|
|
|
|
var activeSources = sources
|
|
.Where(s => s.IsActive)
|
|
.OrderBy(s => s.SortOrder)
|
|
.ThenBy(s => s.Id)
|
|
.ToList();
|
|
if (activeSources.Count == 0)
|
|
throw new InvalidOperationException($"Standort '{site.Land}' hat keine aktiven SAP-Quellen.");
|
|
|
|
var primarySource = activeSources.FirstOrDefault(s => s.IsPrimary) ?? activeSources.First();
|
|
var sourceRows = new Dictionary<string, List<Dictionary<string, object?>>>(StringComparer.OrdinalIgnoreCase);
|
|
foreach (var source in activeSources)
|
|
{
|
|
await _appEventLogService.WriteDebugAsync("SAP", "Quelle wird gelesen", site.Id, site.Land,
|
|
$"Alias={source.Alias} | EntitySet={source.EntitySet}");
|
|
var filter = BuildODataYearFilter(source.EntitySet, preferredYear);
|
|
var rows = await _sapGatewayService.GetEntityRowsAsync(site.SapServiceUrl, source.EntitySet, username, password, filter, cancellationToken);
|
|
sourceRows[source.Alias] = rows;
|
|
await _appEventLogService.WriteDebugAsync("SAP", "Quelle gelesen", site.Id, site.Land,
|
|
$"Alias={source.Alias} | EntitySet={source.EntitySet} | Zeilen={rows.Count}");
|
|
}
|
|
|
|
await _appEventLogService.WriteDebugAsync("SAP", "Mapping ins Zielschema gestartet", site.Id, site.Land,
|
|
$"Primaerquelle={primarySource.Alias} | Mappings={mappings.Count(x => x.IsActive)}");
|
|
var result = _composer.Compose(site, activeSources, joins, mappings, sourceRows, "SAP");
|
|
await _appEventLogService.WriteDebugAsync("SAP", "Mapping ins Zielschema beendet", site.Id, site.Land,
|
|
$"SalesRecords={result.Count} | Mappings={mappings.Count(x => x.IsActive)}");
|
|
return result;
|
|
}
|
|
|
|
private static string? BuildODataYearFilter(string entitySet, int? preferredYear)
|
|
{
|
|
if (preferredYear is null)
|
|
return null;
|
|
|
|
return string.Equals(entitySet, "FinanzdataSchweizOeSet", StringComparison.OrdinalIgnoreCase)
|
|
? $"Gjahr eq '{preferredYear.Value}'"
|
|
: null;
|
|
}
|
|
}
|