Util/test/Util.Scheduling.Hangfire.Tests.Integration/Jobs/TestJob2.cs

using System;
using System.Threading.Tasks;
using Util.Tests.Fakes;
using Util.Tests.Repositories;
using Util.Tests.UnitOfWorks;

namespace Util.Scheduling.Hangfire.Tests.Jobs; 

/// <summary>
/// 后台任务2
/// </summary>
public class TestJob2 : JobBase {
    /// <inheritdoc />
    protected override void ConfigTrigger( IJobTrigger trigger ) {
        trigger.Delay( TimeSpan.FromSeconds( 1 ) );
    }

    /// <inheritdoc />
    protected override async Task Execute( HangfireExecutionContext context ) {
        var unitOfWork = context.GetService<ITestUnitOfWork>();
        var repository = context.GetService<ICustomerRepository>();
        var customer = CustomerFakeService.GetCustomer();
        customer.Name = "TestJob2";
        await repository.AddAsync( customer );
        await unitOfWork.CommitAsync();
    }
}