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


namespace IStation.DAL
{
    /// <summary>
    /// 监测单元
    /// </summary>
    public partial class MonitorUnit : CorpDAL_Sorter_UseStatus_TagName<Entity.MonitorUnit>
    {
        /// <summary>
        /// 
        /// </summary>
        public override ConnectionConfig ConnectionConfig
        {
            get { return ConfigHelper.DefaultConnectionConfig; }
        }

        /// <summary>
        /// 通过 BelongType 和 BelongID 获取
        /// </summary>
        public List<Entity.MonitorUnit> GetByBelongTypeAndBelongID(long CorpID, string BelongType, long BelongID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Queryable<Entity.MonitorUnit>()
                    .Where(x => x.CorpID == CorpID && x.BelongType == BelongType && x.BelongID == BelongID).ToList();
            }
        }

        /// <summary>
        /// 插入拓展
        /// </summary>
        public long InsertEx(Entity.MonitorUnit entity, List<Entity.SignalUnit> signals)
        {
            if (entity == null)
                return default;
            if (signals == null || signals.Count() < 1)
                return default;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.BeginTran();
                    var id = db.Insertable(entity).ExecuteReturnSnowflakeId();
                    if (id < 1)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    signals.ForEach(x => x.MonitorUnitID = id);
                    var bol = db.Insertable(signals).ExecuteReturnSnowflakeIdList().Count() > 0;
                    if (!bol)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    db.CommitTran();
                    return id;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }
        }

        /// <summary>
        /// 批量插入拓展
        /// </summary>
        public bool InsertsEx(Dictionary<Entity.MonitorUnit, List<Entity.SignalUnit>> dict)
        {
            if (dict == null || dict.Count < 1)
                return default;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.BeginTran();
                    foreach (var kvp in dict)
                    {
                        var id = db.Insertable(kvp.Key).ExecuteReturnSnowflakeId();
                        if (id < 1)
                        {
                            db.RollbackTran();
                            return default;
                        }
                        kvp.Value.ForEach(x => x.MonitorUnitID = id);
                        var bol = db.Insertable(kvp.Value).ExecuteReturnSnowflakeIdList().Count() > 0;
                        if (!bol)
                        {
                            db.RollbackTran();
                            return default;
                        }
                    }
                    db.CommitTran();
                    return true;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }
        }

        /// <summary>
        /// 批量插入拓展
        /// </summary>
        public List<long> InsertsREx(Dictionary<Entity.MonitorUnit, List<Entity.SignalUnit>> dict)
        {
            if (dict == null || dict.Count < 1)
                return default;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.BeginTran();
                    var list = new List<long>();
                    foreach (var kvp in dict)
                    {
                        var id = db.Insertable(kvp.Key).ExecuteReturnSnowflakeId();
                        if (id < 1)
                        {
                            db.RollbackTran();
                            return default;
                        }
                        kvp.Value.ForEach(x => x.MonitorUnitID = id);
                        var bol = db.Insertable(kvp.Value).ExecuteReturnSnowflakeIdList().Count() > 0;
                        if (!bol)
                        {
                            db.RollbackTran();
                            return default;
                        }
                        list.Add(id);
                    }
                    db.CommitTran();
                    return list;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }
        }

        /// <summary>
        /// 更新拓展
        /// </summary>
        public bool UpdateEx(Entity.MonitorUnit entity, List<Entity.SignalUnit> signals)
        {
            if (entity == null)
                return default;
            if (signals == null || signals.Count() < 1)
                return default;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.BeginTran();
                    var result = db.Updateable(entity).ExecuteCommandHasChange();
                    if (!result)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    result = db.Updateable(signals).ExecuteCommandHasChange();
                    if (!result)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    db.CommitTran();
                    return true;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }

        }

        /// <summary>
        /// 批量更新拓展
        /// </summary>
        public bool UpdatesEx(Dictionary<Entity.MonitorUnit, List<Entity.SignalUnit>> dict)
        {
            if (dict == null || dict.Count < 1)
                return default;
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.BeginTran();
                    foreach (var kvp in dict)
                    {
                        var result = db.Updateable(kvp.Key).ExecuteCommandHasChange();
                        if (!result)
                        {
                            db.RollbackTran();
                            return default;
                        }
                        result = db.Insertable(kvp.Value).ExecuteCommand() > 0;
                        if (!result)
                        {
                            db.RollbackTran();
                            return default;
                        }
                    }
                    db.CommitTran();
                    return true;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }
        }

        /// <summary>
        /// 通过 ID 删除
        /// </summary>
        public override bool DeleteByID(long CorpID, long ID)
        {
            using (var db = new SqlSugarClient(ConnectionConfig))
            {
                try
                {
                    db.BeginTran();
                    var result = db.Deleteable<Entity.MonitorUnit>()
                        .Where(x => x.CorpID == CorpID && x.ID == ID)
                        .ExecuteCommandHasChange();
                    if (!result)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    result = db.Deleteable<Entity.SignalUnit>()
                        .Where(x => x.CorpID == CorpID && x.MonitorUnitID == ID)
                        .ExecuteCommandHasChange();
                    if (!result)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    db.CommitTran();
                    return true;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }
        }








    }
}