using CMS.Plugin.HIAWms.Abstractions;
|
using CMS.Plugin.HIAWms.Domain.WmsContainers;
|
using Microsoft.Extensions.DependencyInjection;
|
using Microsoft.Extensions.Logging;
|
using SYC.Flow.Kernel;
|
using Volo.Abp.DependencyInjection;
|
using Volo.Abp.Uow;
|
|
namespace CMS.Plugin.HIAWms.Services
|
{
|
/// <inheritdoc />
|
public class HIAWmsFlowService : IHIAWmsFlowService, ITransientDependency
|
{
|
private readonly ILogger<HIAWmsFlowService> _logger;
|
private readonly IServiceProvider _serviceProvider;
|
|
/// <summary>
|
/// Initializes a new instance of the <see cref="HIAWmsFlowService"/> class.
|
/// </summary>
|
/// <param name="logger">The logger.</param>
|
public HIAWmsFlowService(ILogger<HIAWmsFlowService> logger, IServiceProvider serviceProvider)
|
{
|
_logger = logger;
|
_serviceProvider = serviceProvider;
|
}
|
|
/// <inheritdoc />
|
public async Task ProcessAsync(ProcessflowEventArgs args)
|
{
|
using var scope = _serviceProvider.CreateScope();
|
var unitOfWorkManager = scope.ServiceProvider.GetRequiredService<IUnitOfWorkManager>();
|
using var uow = unitOfWorkManager.Begin(requiresNew: true);
|
var wmscontainerRepository = scope.ServiceProvider.GetRequiredService<IWmsContainerRepository>();
|
var count = await wmscontainerRepository.GetCountAsync();
|
|
// 如果有更新数据库操作，需提交保存
|
// await uow.SaveChangesAsync();
|
|
// 输出日志
|
_logger.LogInformation($"HIAWmsFlowService：ProcessAsync()");
|
}
|
}
|
}
|
