using CMS.Plugin.PipeLineLems.Abstractions;
using CMS.Plugin.PipeLineLems.Domain.MyTestEntityNames;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using SYC.Flow.Kernel;
using Volo.Abp.DependencyInjection;
using Volo.Abp.Uow;

namespace CMS.Plugin.PipeLineLems.Services
{
    /// <inheritdoc />
    public class PipeLineLemsFlowService : IPipeLineLemsFlowService, ITransientDependency
    {
        private readonly ILogger<PipeLineLemsFlowService> _logger;
        private readonly IServiceProvider _serviceProvider;

        /// <summary>
        /// Initializes a new instance of the <see cref="PipeLineLemsFlowService"/> class.
        /// </summary>
        /// <param name="logger">The logger.</param>
        public PipeLineLemsFlowService(ILogger<PipeLineLemsFlowService> 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 mytestentitynameRepository = scope.ServiceProvider.GetRequiredService<IMyTestEntityNameRepository>();
            var count = await mytestentitynameRepository.GetCountAsync();

            // 如果有更新数据库操作，需提交保存
            // await uow.SaveChangesAsync();

            // 输出日志
            _logger.LogInformation($"PipeLineLemsFlowService：ProcessAsync()");
        }
    }
}