namespace Yw.DAL
{
    /// <summary>
    /// 运行实时记录
    /// </summary>
    public class RunRealRecord
    {
        /// <summary>
        /// 
        /// </summary>
        public ConnectionConfig ConnectionConfig
        {
            get { return ConfigHelper.RecordConnectionConfig; }
        }

        /// <summary>
        /// 通过 Day 获取
        /// </summary>
        public List<Entity.RunRealRecord> GetOfDay(DateTime Day)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.DataTime >= Day.Date && x.DataTime < Day.Date.AddDays(1))
                    .OrderBy(x => x.DataTime).ToList();
            }
        }

        /// <summary>
        /// 通过 ObjectType 和 ObjectID 获取
        /// </summary>
        public List<Entity.RunRealRecord> GetByObjectTypeAndObjectID(string ObjectType, long ObjectID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .OrderBy(x => x.DataTime).ToList();
            }
        }

        /// <summary>
        /// 通过 ObjectType 和 ObjectID 获取某日的数据
        /// </summary>
        public List<Entity.RunRealRecord> GetByObjectTypeAndObjectIDOfDay(string ObjectType, long ObjectID, DateTime Day)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.DataTime >= Day.Date && x.DataTime < Day.Date.AddDays(1))
                    .Where(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .OrderBy(x => x.DataTime).ToList();
            }
        }

        /// <summary>
        /// 通过 ObjectType 和 ObjectID 获取某日的运行数据
        /// </summary>
        public List<Entity.RunRealRecord> GetRunByObjectTypeAndObjectIDOfDay(string ObjectType, long ObjectID, DateTime Day)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.DataTime >= Day.Date && x.DataTime < Day.Date.AddDays(1))
                    .Where(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .Where(x => x.RSa == RunStatus.Run)
                    .OrderBy(x => x.DataTime).ToList();
            }
        }

        /// <summary>
        /// 通过 ObjectType 和 ObjectID 获取日期区间内的数据
        /// </summary>
        public List<Entity.RunRealRecord> GetByObjectTypeAndObjectIDOfDayRange(string ObjectType, long ObjectID, DateTime StartDay, DateTime EndDay)
        {
            if (StartDay.Date > EndDay.Date)
            {
                return default;
            }

            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.DataTime >= StartDay.Date && x.DataTime < EndDay.Date.AddDays(1))
                    .Where(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .OrderBy(x => x.DataTime)
                    .ToList();
            }
        }

        /// <summary>
        /// 通过 ObjectType 和 ObjectID 获取日期区间内的运行数据
        /// </summary>
        public List<Entity.RunRealRecord> GetRunByObjectTypeAndObjectIDOfDayRange(string ObjectType, long ObjectID, DateTime StartDay, DateTime EndDay)
        {
            if (StartDay.Date > EndDay.Date)
            {
                return default;
            }

            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.DataTime >= StartDay.Date && x.DataTime < EndDay.Date.AddDays(1))
                    .Where(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .Where(x => x.RSa == RunStatus.Run)
                    .OrderBy(x => x.DataTime)
                    .ToList();
            }
        }

        /// <summary>
        /// 通过 ObjectType 和 ObjectID 获取时间区间内的数据
        /// </summary>
        public List<Entity.RunRealRecord> GetByObjectTypeAndObjectIDOfTimeRange(string ObjectType, long ObjectID, DateTime StartTime, DateTime EndTime)
        {
            if (StartTime > EndTime)
            {
                return default;
            }

            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.DataTime > StartTime.AddSeconds(-1) && x.DataTime < EndTime.AddSeconds(1))
                    .Where(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .OrderBy(x => x.DataTime)
                    .ToList();
            }
        }

        /// <summary>
        /// 通过 ObjectType 和 ObjectID 获取时间区间内的运行数据
        /// </summary>
        public List<Entity.RunRealRecord> GetRunByObjectTypeAndObjectIDOfTimeRange(string ObjectType, long ObjectID, DateTime StartTime, DateTime EndTime)
        {
            if (StartTime > EndTime)
            {
                return default;
            }

            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.RunRealRecord>()
                    .Where(x => x.DataTime > StartTime.AddSeconds(-1) && x.DataTime < EndTime.AddSeconds(1))
                    .Where(x => x.ObjectType == ObjectType && x.ObjectID == ObjectID)
                    .Where(x => x.RSa == RunStatus.Run)
                    .OrderBy(x => x.DataTime)
                    .ToList();
            }
        }

        #region InsertOrUpdate

        /// <summary>
        /// 插入
        /// </summary>
        public bool InsertOrUpdate(Entity.RunRealRecord entity)
        {
            if (entity == null)
                return false;

            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                var sql = CreateSql();
                var paras = CreateParameters(entity);
                return db.Ado.ExecuteCommand(sql, paras) > 0;
            }
        }

        /// <summary>
        /// 批量插入
        /// </summary>
        public bool InsertOrUpdate(List<Entity.RunRealRecord> list)
        {
            if (list == null || list.Count < 1)
                return false;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.Ado.BeginTran();
                    var sql = CreateSql();
                    foreach (var item in list)
                    {
                        var paras = CreateParameters(item);
                        var bol = db.Ado.ExecuteCommand(sql, paras) > 0;
                        if (!bol)
                        {
                            db.Ado.RollbackTran();
                            return false;
                        }
                    }
                    db.Ado.CommitTran();
                    return true;
                }
                catch
                {
                    db.Ado.RollbackTran();
                    throw;
                }
            }
        }

        //创建sql
        private string CreateSql()
        {
            var sb = new StringBuilder();
            sb.AppendLine("INSERT INTO run_real_record");
            sb.AppendLine($" VALUES(@objecttype,@objectid,@datatime,@rsa,@continueruntime,@totalruntime,@boottimes,@analystatus,@analyinfo)");
            sb.AppendLine("ON CONFLICT(objecttype, objectid, datatime) DO UPDATE");
            sb.AppendLine("SET rsa = excluded.rsa,");
            sb.AppendLine("continueruntime = excluded.continueruntime,");
            sb.AppendLine("totalruntime = excluded.totalruntime,");
            sb.AppendLine("boottimes = excluded.boottimes,");
            sb.AppendLine("analystatus = excluded.analystatus,");
            sb.AppendLine("analyinfo = excluded.analyinfo;");
            return sb.ToString();
        }

        //创建参数
        private List<SugarParameter> CreateParameters(Entity.RunRealRecord entity)
        {
            var list = new List<SugarParameter>();
            list.Add(new SugarParameter("@objecttype", entity.ObjectType));
            list.Add(new SugarParameter("@objectid", entity.ObjectID));
            list.Add(new SugarParameter("@datatime", entity.DataTime));
            list.Add(new SugarParameter("@rsa", entity.RSa));
            list.Add(new SugarParameter("@continueruntime", entity.ContinueRunTime));
            list.Add(new SugarParameter("@totalruntime", entity.TotalRunTime));
            list.Add(new SugarParameter("@boottimes", entity.BootTimes));
            list.Add(new SugarParameter("@analystatus", entity.AnalyStatus));
            list.Add(new SugarParameter("@analyinfo", entity.AnalyInfo));
            return list;
        }

        #endregion




    }
}