using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using IStation.Calculation;

namespace IStation.Server
{
    /// <summary>
    /// 当前报警分析任务辅助类
    /// </summary>
    public class AlarmCurrentAnalyJobHelper : IJobHelper
    {
        private readonly RabbitMqExChangeHelper _queueHelper = new RabbitMqExChangeHelper();

        /// <summary>
        /// 开始任务
        /// </summary>
        public Task StartJob()
        {
            return Task.Run(() =>
            {
                _queueHelper.Receive<List<Model.MonitorBasicRecord>>(ConfigHelper.RunExchangeName, (list) =>
                {
                    try
                    {
                        if (list == null || list.Count < 1)
                        {
                            LogHelper.Info("当前报警分析任务中，数据序列化失败");
                            return true;
                        }
                        var service_monitor = new Service.MonitorPoint();
                        var service_signal = new Service.Signal();
                        var service_alarm_configure = new Service.MonitorAlarmConfigure();
                        var service_alarm_record = new Service.MonitorAlarmRecord();
                        var group_list = list.GroupBy(x => new { x.CorpID, x.MonitorPointID }).ToList();
                        //循环遍历
                        foreach (var group in group_list)
                        {
                            var monitor = service_monitor.GetByID(group.Key.CorpID, group.Key.MonitorPointID);
                            if (monitor == null)
                                continue;
                            if (monitor.UseStatus != Model.eUseStatus.Enable)
                                continue;
                            var configure_only_list = service_alarm_configure.GetOnlyByMonitorPointID(group.Key.CorpID, group.Key.MonitorPointID);
                            configure_only_list = configure_only_list?.Where(x => x.UseStatus == Model.eUseStatus.Enable).ToList();
                            if (configure_only_list != null&&configure_only_list.Count>0)
                            {                             
                                foreach (var configure_only in configure_only_list)
                                {
                                    if (MonitorAlarmCalcuHelper.Verify(configure_only, null,
                                        () => MonitorRecord4AlarmCacheHelper.GetFirstByMonitorPointID(monitor.CorpID, monitor.ID),
                                        () => MonitorRecord4AlarmCacheHelper.GetFirstUnChangedByMonitorPointID(monitor.CorpID, monitor.ID)))
                                    {
                                        var alarm = MonitorAlarmCalcuHelper.Create(monitor, null, configure_only, null);
                                        service_alarm_record.InsertLastRecord(alarm);
                                    }
                                }
                            }
                            foreach (var record in group)
                            {
                                var signal = service_signal.GetByID(record.CorpID, record.SignalID);
                                if (signal == null)
                                    continue;
                                var configure_list = service_alarm_configure.GetBySignalID(signal.CorpID, signal.MonitorPointID, signal.ID);
                                if (configure_list == null || configure_list.Count < 1)
                                {
                                    configure_list = service_alarm_configure.GetCommonBySignalType(signal.CorpID, signal.SignalType);
                                    if (configure_list == null || configure_list.Count < 1)
                                        continue;
                                }
                                configure_list = configure_list.Where(x => x.UseStatus == Model.eUseStatus.Enable).ToList();
                                if (configure_list != null && configure_list.Count > 0)
                                {
                                    foreach (var configure in configure_list)
                                    {
                                        if (MonitorAlarmCalcuHelper.Verify(configure, record,
                                            () => MonitorRecord4AlarmCacheHelper.GetBySignalID(signal.CorpID, signal.MonitorPointID, signal.ID),
                                            () => MonitorRecord4AlarmCacheHelper.GetUnChangedBySignalID(signal.CorpID, signal.MonitorPointID, signal.ID)))
                                        {
                                            var alarm = MonitorAlarmCalcuHelper.Create(monitor, signal, configure, record);
                                            service_alarm_record.InsertLastRecord(alarm);
                                        }
                                    }
                                }
                            }
                        }

                        //设置缓存
                        MonitorRecord4AlarmCacheHelper.Set(list);

                        return true;
                    }
                    catch (Exception ex)
                    {
                        LogHelper.Error("当前报警分析任务中,数据消息队列出错，自动跳过", ex);
                        return true;
                    }
                });
            });

        }

        /// <summary>
        /// 取消任务
        /// </summary>
        public Task CancelJob()
        {
            return Task.Run(() =>
            {
                if (_queueHelper == null)
                    return;
                _queueHelper.Close();
            });
        }


    }
}