using Application.Domain.Entities;
using CSScriptLib;
using Hangfire;
using Infrastructure.Data;
using Infrastructure.Events;
using Infrastructure.Extensions;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Concurrent;
using System.Linq;

namespace IoTCenter.Services
{
    public class IoTCenterEventHandler :
        IEventHander<EntityUpdatedEvent<IoTTimer>>,
        IEventHander<EntityDeletedEvent<IoTTimer>>,
        IEventHander<EntityUpdatedEvent<IoTTigger>>,
        IEventHander<EntityDeletedEvent<IoTTigger>>,
        IEventHander<EntityUpdatedEvent<Data>>
    {
        public static ConcurrentDictionary<Guid, IoTTigger> Tiggers = new ConcurrentDictionary<Guid, IoTTigger>();
        private readonly IServiceProvider _sp;

        public IoTCenterEventHandler(IServiceProvider sp)
        {
            this._sp = sp;
        }

        public void Handle(EntityUpdatedEvent<IoTTimer> message)
        {
            var timer = message.Data;
            if (timer.NodeId == null)
            {
                RecurringJob.AddOrUpdate<IoTCenterJob>(timer.Id.ToString(), o => o.TimerHanle(timer.Id), timer.Cron);
            }
        }

        public void Handle(EntityDeletedEvent<IoTTimer> message)
        {
            var timer = message.Data;
            if (timer.NodeId == null)
            {
                RecurringJob.RemoveIfExists(timer.Id.ToString());
            }
        }

        public void Handle(EntityUpdatedEvent<IoTTigger> message)
        {
            var tigger = message.Data;
            if (tigger.NodeId == null)
            {
                Tiggers.TryRemove(message.Data.Id, out IoTTigger iotTigger);
                Tiggers.TryAdd(tigger.Id, tigger);
            }
        }

        public void Handle(EntityDeletedEvent<IoTTigger> message)
        {
            var tigger = message.Data;
            if (tigger.NodeId == null)
            {
                Tiggers.TryRemove(tigger.Id, out IoTTigger iotTigger);
            }
        }

        public void Handle(EntityUpdatedEvent<Data> message)
        {
            var data = message.Data;
            using var scope = this._sp.CreateScope();
            foreach (var item in Tiggers)
            {
                var tigger = item.Value;
                if (tigger.DataId == data.Id)
                {
                    var methodText = $"bool Valid(string name,string key,{data.Type.ToString().ToLower()} value,string description){{ return {tigger.Condition};}}";
                    try
                    {
                        dynamic method = CSScript.Evaluator.LoadMethod(methodText);
                        dynamic value = data.GetValue();
                        var result = method.Valid(data.Name, data.Key, value, data.Description);
                        if (result)
                        {
                            var job = scope.ServiceProvider.GetService<IoTCenterJob>();
                            job.TiggerHandle(tigger.Id);
                        }
                    }
                    catch (Exception ex)
                    {
                        ex.PrintStack();
                    }
                }
            }
        }
    }
}