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

namespace IStation.RedisCache
{
    /// <summary>
    /// 监测报警记录缓存辅助类
    /// </summary>
    public class MonitorAlarmRecordCacheHelper
    {
        //监测记录
        private const string _flag = "monitor-alarm-record";
        //最后一条报警记录
        private const string _lastRecord = "last-record";
        //Redis客户端辅助类对象
        private readonly RedisClientHelper _redisClient = new RedisClientHelper();

        //获取 RedisKey
        private static string CreateRedisKey(long CorpID, long MonitorPointID)
        {
            return $"{RedisKeyHelper.CreateKey(_flag)}:{CorpID}-{MonitorPointID}-";
        }

        //获取 RedisKey
        private static string CreateRedisKey(long CorpID, long MonitorPointID, long SignalID)
        {
            return $"{CreateRedisKey(CorpID,MonitorPointID)}{SignalID}";
        }

        //创建 报警HashKey
        private static string CreateHashKey(long ConfigureID)
        {
            return $"{_lastRecord}_{ConfigureID}";
        }

        #region 报警记录

        /// <summary>
        /// 设置最后一条记录
        /// </summary>
        public void SetLastRecord(Model.MonitorAlarmRecordPure model)
        {
            if (model == null)
                return;
            string redisKey;
            if (model.SignalID.HasValue)
            {
                redisKey= CreateRedisKey(model.CorpID, model.MonitorPointID,model.SignalID.Value);
            }
            else
            {
                redisKey = CreateRedisKey(model.CorpID, model.MonitorPointID);
            }
            var hashKey = CreateHashKey(model.ConfigureID);
            _redisClient.HashSetJosn(redisKey, hashKey, model);
        }

        /// <summary>
        /// 设置最后一条记录
        /// </summary>
        public void SetLastRecord(IEnumerable<Model.MonitorAlarmRecordPure> list)
        {
            if (list == null || list.Count() < 1)
                return;
            foreach (var item in list)
            {
                SetLastRecord(item);
            }
        }

        /// <summary>
        /// 获取最后一条记录列表
        /// </summary>
        public List<Model.MonitorAlarmRecordPure> GetLastRecordList(long CorpID, long MonitorPointID)
        {
            var key = CreateRedisKey(CorpID,MonitorPointID);
            var allKeys = _redisClient.AllKeyStartWidth(key);
            if (allKeys == null || allKeys.Count < 1)
                return default;
            var vm_list = new List<Model.MonitorAlarmRecordPure>();
            foreach (var redisKey in allKeys)
            {
                var vm_sub_list = _redisClient.HashGetJsonAll<Model.MonitorAlarmRecordPure>(redisKey);
                if (vm_sub_list != null&&vm_sub_list.Count>0)
                {
                    vm_list.AddRange(vm_sub_list);
                }
            }
            return vm_list;
        }

        /// <summary>
        /// 获取最后一条记录
        /// </summary>
        public Model.MonitorAlarmRecordPure GetLastRecord(long CorpID, long MonitorPointID, long ConfigureID)
        {
            var redisKey = CreateRedisKey(CorpID, MonitorPointID);
            var hashKey = CreateHashKey(ConfigureID);
            return _redisClient.HashGetJson<Model.MonitorAlarmRecordPure>(redisKey,hashKey);
        }

        /// <summary>
        /// 设置最后一条记录列表
        /// </summary>
        public List<Model.MonitorAlarmRecordPure> GetLastRecordList(long CorpID, long MonitorPointID,long SignalID)
        {
            var redisKey = CreateRedisKey(CorpID, MonitorPointID, SignalID);
            return _redisClient.HashGetJsonAll<Model.MonitorAlarmRecordPure>(redisKey);
        }

        /// <summary>
        /// 获取最后一条记录
        /// </summary>
        public Model.MonitorAlarmRecordPure GetLastRecord(long CorpID, long MonitorPointID,long SignalID, long ConfigureID)
        {
            var redisKey = CreateRedisKey(CorpID, MonitorPointID, SignalID);
            var hashKey = CreateHashKey(ConfigureID);
            return _redisClient.HashGetJson<Model.MonitorAlarmRecordPure>(redisKey, hashKey);
        }

        /// <summary>
        /// 删除最后一条记录
        /// </summary>
        public void DeleteLastRecord(long CorpID, long MonitorPointID, long ConfigureID)
        {
            var redisKey = CreateRedisKey(CorpID,MonitorPointID);
            var hasKey = CreateHashKey(ConfigureID);
            _redisClient.HashDelete(redisKey, hasKey);
        }

        /// <summary>
        /// 删除最后一条记录
        /// </summary>
        public void DeleteLastRecord(long CorpID, long MonitorPointID, long SignalID, long ConfigureID)
        {
            var redisKey = CreateRedisKey(CorpID, MonitorPointID,SignalID);
            var hasKey = CreateHashKey(ConfigureID);
            _redisClient.HashDelete(redisKey, hasKey);
        }



        #endregion
    }
}