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



namespace IStation.DAL
{
    /// <summary>
    /// 测点
    /// </summary>
    public partial class MonitorPoint : CorpDAL_Sorter_UseStatus_TagName_TerminalId<Entity.MonitorPoint>
    {
        /// <summary>
        /// 
        /// </summary>
        public override ConnectionConfig ConnectionConfig
        {
            get { return ConfigHelper.DefaultConnectionConfig; }

        }

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

        /// <summary>
        /// 插入拓展
        /// </summary>
        public long InsertEx(Entity.MonitorPoint entity, List<Entity.Signal> 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.MonitorPointID = 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.MonitorPoint, List<Entity.Signal>> 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.MonitorPointID = 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.MonitorPoint, List<Entity.Signal>> 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.MonitorPointID = 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.MonitorPoint entity, List<Entity.Signal> 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.MonitorPoint, List<Entity.Signal>> 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.MonitorPoint>()
                        .Where(x => x.CorpID == CorpID && x.ID == ID)
                        .ExecuteCommandHasChange();
                    if (!result)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    result = db.Deleteable<Entity.Signal>()
                        .Where(x => x.CorpID == CorpID && x.MonitorPointID == ID)
                        .ExecuteCommandHasChange();
                    if (!result)
                    {
                        db.RollbackTran();
                        return default;
                    }
                    db.CommitTran();
                    return true;
                }
                catch
                {
                    db.RollbackTran();
                    throw;
                }
            }
        }

        /// <summary>
        /// 更新 GroupID
        /// </summary>
        public bool UpdateGroupID(long CorpID, long ID, long GroupID)
        {
            using (SqlSugarClient db = new SqlSugarClient(ConnectionConfig))
            {
                return db.Updateable<Entity.MonitorPoint>()
                    .SetColumns(x => x.GroupID == GroupID)
                    .Where(x =>x.CorpID==CorpID&& x.ID == ID)
                    .ExecuteCommand() > 0;
            }
        }

    }
}