using CMS.Extensions.Variable;
using CMS.Project.Abstractions;
using KissUtil.Extensions;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Volo.Abp.BackgroundWorkers;
using Volo.Abp.Threading;

namespace CMS.Plugin.PipeLineLems.Workers
{
    /// <summary>
    /// PipeLineLems后台工作者
    /// </summary>
    public class PipeLineLemsWorker : AsyncPeriodicBackgroundWorkerBase
    {
        private readonly ILogger<PipeLineLemsWorker> _logger;
        private readonly VariableService _variableService;

        /// <summary>
        /// Initializes a new instance of the <see cref="PipeLineLemsWorker"/> class.
        /// </summary>
        /// <param name="timer">The timer.</param>
        /// <param name="serviceScopeFactory">The service scope factory.</param>
        public PipeLineLemsWorker(ILogger<PipeLineLemsWorker> logger, AbpAsyncTimer timer, VariableService variableService, IServiceScopeFactory serviceScopeFactory) : base(timer, serviceScopeFactory)
        {
            _logger = logger;
            _variableService = variableService;
            Timer.Period = 1 * 300 * 1000; // 每隔 300 秒 执行一次
            Timer.RunOnStart = true;
        }

        /// <inheritdoc />
        protected override async Task DoWorkAsync(PeriodicBackgroundWorkerContext workerContext)
        {
            var projectAccessor = workerContext.ServiceProvider.GetRequiredService<IProjectAccessor>();
            var project = await projectAccessor.GetProjectAsync();
            if (project?.Info == null)
            {
                return;
            }

            //_logger.LogInformation($"PipeLineLemsWorker is working for project {project.Info.Id}");

            //// 计算OEE
            //double oee = await CalculateOEEAsync();

            //// 使用百分比格式 打印结果日志
            //_logger.LogInformation($"OEE:{oee:P2}");

            //// 写入变量
            //await _variableService.WriteValueAsync(new Dictionary<string, object> {{ "OEE", oee } });
        }

        // 计算OEE=可用性×性能×质量
        public async Task<double> CalculateOEEAsync()
        {
            // 读取OEE计算所需的值  
            double availability = await ReadDoubleValueAsync("Availability");
            double performance = await ReadDoubleValueAsync("Performance");
            double quality = await ReadDoubleValueAsync("Quality");

            // 计算OEE  
            double oee = availability * performance * quality;

            // 返回计算结果  
            return oee;
        }

        // 提供一个泛型方法，方便直接获取double类型的值  
        public async Task<double> ReadDoubleValueAsync(string variableName)
        {
            var variable = await _variableService.ReadValueAsync(variableName);
            return (variable?.Content?.Value).SafeString().ToDoubleOrNull().GetValueOrDefault();
        }
    }
}