using CMS.Plugin.WareCmsUtilityApi.Domain.Samples;
|
using Microsoft.Extensions.Logging;
|
using Volo.Abp.BackgroundJobs;
|
using Volo.Abp.DependencyInjection;
|
using Volo.Abp.Uow;
|
|
namespace CMS.Plugin.WareCmsUtilityApi.Jobs
|
{
|
/// <summary>
|
/// WareCmsUtilityApi 后台作业
|
/// </summary>
|
public class WareCmsUtilityApiJob : BackgroundJob<WareCmsUtilityApiArgs>, ITransientDependency
|
{
|
private readonly ILogger<WareCmsUtilityApiJob> _logger;
|
private readonly IUnitOfWorkManager _unitOfWorkManager;
|
private readonly ISampleRepository _sampleRepository;
|
|
/// <summary>
|
/// Initializes a new instance of the <see cref="WareCmsUtilityApiJob"/> class.
|
/// </summary>
|
/// <param name="logger">The logger.</param>
|
/// <param name="unitOfWorkManager">The unit of work manager.</param>
|
/// <param name="sampleRepository">My entity name repository.</param>
|
public WareCmsUtilityApiJob(ILogger<WareCmsUtilityApiJob> logger, IUnitOfWorkManager unitOfWorkManager, ISampleRepository sampleRepository)
|
{
|
_logger = logger;
|
_unitOfWorkManager = unitOfWorkManager;
|
_sampleRepository = sampleRepository;
|
}
|
|
/// <inheritdoc />
|
public override void Execute(WareCmsUtilityApiArgs args)
|
{
|
using var uow = _unitOfWorkManager.Begin(requiresNew: true);
|
var count = _sampleRepository.GetCountAsync().GetAwaiter().GetResult();
|
|
// 如果有更新数据库操作，需提交保存
|
// uow.SaveChangesAsync().GetAwaiter().GetResult();
|
|
_logger.LogInformation($"WareCmsUtilityApiJob Execute，Subject={args.Subject}，Body={args.Body}，Count={count}");
|
}
|
}
|
}
|
