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

namespace CMS.Plugin.WareCmsUtilityApi.Services
{
    /// <inheritdoc />
    public class WareCmsUtilityApiFlowService : IWareCmsUtilityApiFlowService, ITransientDependency
    {
        private readonly ILogger<WareCmsUtilityApiFlowService> _logger;
        private readonly IServiceProvider _serviceProvider;

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

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

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