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

namespace IStation.DAL
{
    /// <summary>
    /// 监测报警记录 
    /// </summary>
    public partial class MonitorAlarmRecord : CorpDAL<Entity.MonitorAlarmRecord>
    {
        /// <summary>
        /// 
        /// </summary>
        public override ConnectionConfig ConnectionConfig
        {
            get { return ConfigHelper.MonitorRecordConnectionConfig; }
        }

        /// <summary>
        /// 通过 ConfigureID 获取
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetByConfigureID(long CorpID, long ConfigureID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && x.ConfigureID == ConfigureID)
                    .OrderBy(x => x.AlarmTime,OrderByType.Asc).ToList();
            }
        }

        /// <summary>
        /// 通过 ConfigureID 获取某天的报警数据
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetByConfigureIDOfDay(long CorpID, long ConfigureID, DateTime Day)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && x.ConfigureID == ConfigureID && x.AlarmTime >= Day.Date && x.AlarmTime < Day.AddDays(1).Date)
                    .OrderBy(x => x.AlarmTime, OrderByType.Asc).ToList();
            }
        }

        /// <summary>
        /// 通过 MonitorPointID 获取
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetByMonitorPointID(long CorpID, long MonitorPointID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
                    .OrderBy(x => x.AlarmTime, OrderByType.Asc).ToList();
            }
        }

        /// <summary>
        /// 通过 MonitorPointID 获取某天的数据
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetByMonitorPointIDOfDay(long CorpID, long MonitorPointID, DateTime Day)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.AlarmTime >= Day.Date && x.AlarmTime < Day.AddDays(1).Date)
                    .OrderBy(x => x.AlarmTime, OrderByType.Asc).ToList();
            }
        }

        /// <summary>
        /// 通过 CorpID 获取最后几条数据
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetLastByCorpID(long CorpID, int Number)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID)
                    .OrderBy(x => x.AlarmTime, OrderByType.Desc).Take(Number).ToList();
            }
        }

        /// <summary>
        /// 通过 MonitorPointID 获取最后几条数据
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetLastByMonitorPointID(long CorpID, long MonitorPointID, int Number)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID)
                    .OrderBy(x => x.AlarmTime, OrderByType.Desc).Take(Number).ToList();
            }
        }

        /// <summary>
        /// 获取数量
        /// </summary>
        public int GetCount
            (long CorpID, List<long> MonitorPointIds, string AlarmType, int? AlarmLevel, int? HandleStatus, DateTime? StartTime, DateTime? EndTime)
        {
            var exp = Expressionable.Create<Entity.MonitorAlarmRecord>();
            exp.And(x => x.CorpID == CorpID);
            exp.AndIF(MonitorPointIds!=null&&MonitorPointIds.Count>0,x=>MonitorPointIds.Contains(x.MonitorPointID));
            exp.AndIF(!string.IsNullOrEmpty(AlarmType), x => x.AlarmType == AlarmType);
            exp.AndIF(AlarmLevel.HasValue, x => x.AlarmLevel == AlarmLevel.Value);
            exp.AndIF(HandleStatus.HasValue, x => x.HandleStatus == HandleStatus);
            exp.AndIF(StartTime.HasValue, x => x.AlarmTime >= StartTime.Value);
            exp.AndIF(EndTime.HasValue, x => x.AlarmTime <= EndTime.Value);

            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>().Where(exp.ToExpression()).Count();
            }
        }

        /// <summary>
        /// 更新处理状态
        /// </summary>
        public bool UpdateHandleStatus(long CorpID, long ID, int HandleStatus)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Updateable<Entity.MonitorAlarmRecord>()
                    .SetColumns(x => x.HandleStatus == HandleStatus)
                    .Where(x => x.CorpID == CorpID && x.ID == ID)
                    .ExecuteCommand() > 0;
            }
        }

        /// <summary>
        /// 获取模糊列表
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetFluzzyList
            (long CorpID,long? MonitorPointID,string AlarmType,int? AlarmLevel,int? HandleStatus,DateTime? StartTime,DateTime? EndTime)
        {
            var exp = Expressionable.Create<Entity.MonitorAlarmRecord>();
            exp.And(x => x.CorpID == CorpID);
            exp.AndIF(MonitorPointID.HasValue, x => x.MonitorPointID==MonitorPointID.Value);
            exp.AndIF(!string.IsNullOrEmpty(AlarmType), x => x.AlarmType == AlarmType);
            exp.AndIF(AlarmLevel.HasValue, x => x.AlarmLevel == AlarmLevel.Value);
            exp.AndIF(HandleStatus.HasValue, x => x.HandleStatus == HandleStatus);
            exp.AndIF(StartTime.HasValue, x => x.AlarmTime >= StartTime.Value);
            exp.AndIF(EndTime.HasValue, x => x.AlarmTime <= EndTime.Value);
            
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>().Where(exp.ToExpression()).ToList();
            }
        }

        /// <summary>
        /// 获取模糊分页列表
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetFluzzyPageList
              (long CorpID, List<long> MonitorPointIds, string AlarmType, int? AlarmLevel, int? HandleStatus, DateTime? StartTime, DateTime? EndTime,int PageIndex,int PageSize,ref int Total)
        {
            if (PageIndex < 1)
                PageIndex = 1;
            if (PageSize < 1)
                PageSize = 1;
            var exp = Expressionable.Create<Entity.MonitorAlarmRecord>();
            exp.And(x => x.CorpID == CorpID);
            exp.AndIF(MonitorPointIds!=null&&MonitorPointIds.Count>0, x => MonitorPointIds.Contains(x.MonitorPointID));
            exp.AndIF(!string.IsNullOrEmpty(AlarmType), x => x.AlarmType == AlarmType);
            exp.AndIF(AlarmLevel.HasValue, x => x.AlarmLevel == AlarmLevel.Value);
            exp.AndIF(HandleStatus.HasValue, x => x.HandleStatus == HandleStatus);
            exp.AndIF(StartTime.HasValue, x => x.AlarmTime >= StartTime.Value);
            exp.AndIF(EndTime.HasValue, x => x.AlarmTime <= EndTime.Value);

            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(exp.ToExpression())
                    .OrderBy(x => x.AlarmTime, OrderByType.Desc)
                    .ToPageList(PageIndex, PageSize, ref Total); ;
            }
        }


        /// <summary>
        /// 通过 CorpID 获取分页列表
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetPageListByCorpID
            (long CorpID, DateTime StartTime, DateTime EndTime, int PageIndex, int PageSize, ref int Total)
        {
            if (EndTime < StartTime)
            {
                return default;
            }
            if (PageIndex < 1)
                PageIndex = 1;
            if (PageSize < 1)
                PageSize = 1;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && x.AlarmTime >= StartTime && x.AlarmTime <= EndTime)
                    .OrderBy(x => x.AlarmTime, OrderByType.Desc)
                    .ToPageList(PageIndex, PageSize, ref Total);
            }
        }

        /// <summary>
        /// 通过 MonitorPointID 获取分页列表
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetPageListByMonitorPointID
            (long CorpID, long MonitorPointID, DateTime StartTime, DateTime EndTime, int PageIndex, int PageSize, ref int Total)
        {
            if (EndTime < StartTime)
            {
                return default;
            }
            if (PageIndex < 1)
                PageIndex = 1;
            if (PageSize < 1)
                PageSize = 1;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && x.MonitorPointID == MonitorPointID && x.AlarmTime >= StartTime && x.AlarmTime <= EndTime)
                    .OrderBy(x => x.AlarmTime, OrderByType.Desc)
                    .ToPageList(PageIndex, PageSize, ref Total);
            }
        }

        /// <summary>
        /// 通过 MonitorPointIds 获取分页列表
        /// </summary>
        public List<Entity.MonitorAlarmRecord> GetPageListByMonitorPointIds
             (long CorpID, List<long> MonitorPointIds, DateTime StartTime, DateTime EndTime, int PageIndex, int PageSize, ref int Total)
        {
            if (MonitorPointIds == null || MonitorPointIds.Count() < 1)
            {
                return default;
            }
            if (EndTime < StartTime)
            {
                return default;
            }
            if (PageIndex < 1)
                PageIndex = 1;
            if (PageSize < 1)
                PageSize = 1;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorAlarmRecord>()
                    .Where(x => x.CorpID == CorpID && MonitorPointIds.Contains(x.MonitorPointID) && x.AlarmTime >= StartTime && x.AlarmTime <= EndTime)
                    .OrderBy(x => x.AlarmTime, OrderByType.Desc)
                    .ToPageList(PageIndex, PageSize, ref Total);
            }
        }



    }
}