WZC2/be/DataExchange/Fawtyg/Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent/Outgoing/EosOutgoingBackgroundWorker.cs

using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Volo.Abp.BackgroundWorkers;
using Volo.Abp.Threading;
using Volo.Abp.Uow;

namespace Win_in.Sfs.Wms.DataExchange.Fawtyg.EosAgent;

public class EosOutgoingBackgroundWorker : AsyncPeriodicBackgroundWorkerBase
{
    private readonly string Outgoing = "EOS发送";

    private readonly IOptions<EosOptions> _options;

    public EosOutgoingBackgroundWorker(
        AbpAsyncTimer timer
        , IOptions<EosOptions> options
        , IServiceScopeFactory serviceScopeFactory
    ) : base(timer, serviceScopeFactory)
    {
        _options = options;
        Timer.Period = options.Value.OutgoingOptions.PeriodSeconds * 1000; //default 10 minutes

    }

    [UnitOfWork]
    protected override async Task DoWorkAsync(PeriodicBackgroundWorkerContext workerContext)
    {
        Logger.LogInformation($"开始: 执行 {Outgoing}");
        if (!_options.Value.IncomingOptions.Active)
        {
            Logger.LogInformation($"{Outgoing} 已关闭没有执行!");
            return;
        }

        Logger.LogInformation($"传出 采购上架单");
        var arriveConvert = workerContext.ServiceProvider.GetRequiredService<ArriveConverter>();
        var arriveNoteList = await arriveConvert.ConvertAsync().ConfigureAwait(false);
        var arriveWriter = workerContext.ServiceProvider.GetRequiredService<ArriveNoteWriter>();
        await arriveWriter.WriteAsync(arriveNoteList).ConfigureAwait(false);
        Logger.LogInformation($"处理采购上架单【{arriveNoteList.Count}】条数据");

        Logger.LogInformation($"传出 采购退货单");
        var returnConvert = workerContext.ServiceProvider.GetRequiredService<ReturnConverter>();
        var returnNoteList = await returnConvert.ConvertAsync().ConfigureAwait(false);
        var returnWriter = workerContext.ServiceProvider.GetRequiredService<ReturnNoteWriter>();
        await returnWriter.WriteAsync(returnNoteList).ConfigureAwait(false);
        Logger.LogInformation($"处理采购退货单【{returnNoteList.Count}】条数据");

        Logger.LogInformation($"提交: 执行 {Outgoing}");
    }

}