AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/DataPlatform/FileImport/S1CustomerFileImportConsumer.cs

using Admin.NET.Plugin.AiDOP.DataPlatform.S1Refresh;
using Admin.NET.Plugin.AiDOP.Order;

namespace Admin.NET.Plugin.AiDOP.DataPlatform.FileImport;

public sealed class S1CustomerFileImportConsumer : IMdpFileImportConsumer, ITransient
{
    private readonly S1MdpSyncTransformService _s1;

    public S1CustomerFileImportConsumer(S1MdpSyncTransformService s1) => _s1 = s1;

    public bool CanConsume(string entityCode) =>
        string.Equals(entityCode, "S1_CUSTOMER_FILE", StringComparison.OrdinalIgnoreCase);

    public Task ConsumeAsync(string entityCode, long tenantId, long factoryId, string batchNo, CancellationToken ct) =>
        _s1.RunPostStagingAsync(S1MdpRunScope.Create(tenantId, factoryId > 0 ? factoryId : 1), ct, "FILE_IMPORT");
}