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

namespace IStation.Service
{
    /// <summary>
    /// 
    /// </summary>
    public partial class PumpCurveExMapping
    {
        #region Query

        /// <summary>
        /// 通过 CorpID 获取
        /// </summary>
        public List<Model.PumpCurveExMapping> GetByCorpID(long CorpID)
        {
            var mapping_list = new PumpCurveMapping().GetByCorpID(CorpID);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID, mapping_list.Select(x => x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            return (from x in mapping_list join y in curve_list on x.CurveID equals y.ID select new Model.PumpCurveExMapping(y, x)).OrderBy(x => x.SortCode).ToList();
        }

        /// <summary>
        /// 通过 MappingID 获取
        /// </summary>
        public Model.PumpCurveExMapping GetByMappingID(long CorpID, long MappingID)
        {
            var mapping = new PumpCurveMapping().GetByID(CorpID,MappingID);
            if (mapping == null)
                return default;
            var curve = new PumpCurve().GetByID(CorpID,mapping.CurveID);
            if (curve == null)
                return default;
            return new Model.PumpCurveExMapping(curve,mapping);
        }

        /// <summary>
        /// 通过 MappingIds 获取
        /// </summary>
        public List<Model.PumpCurveExMapping> GetByMappingIds(long CorpID, List<long> MappingIds)
        {
            if (MappingIds == null || MappingIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().GetByIds(CorpID,MappingIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID, mapping_list.Select(x => x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            return (from x in mapping_list join y in curve_list on x.CurveID equals y.ID select new Model.PumpCurveExMapping(y, x)).OrderBy(x => x.SortCode).ToList();
        }

        /// <summary>
        /// 通过 PumpID 获取
        /// </summary>
        public List<Model.PumpCurveExMapping> GetByPumpID(long CorpID, long PumpID)
        {
            var mapping_list = new PumpCurveMapping().GetByPumpID(CorpID,PumpID);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID,mapping_list.Select(x=>x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            return (from x in mapping_list join y in curve_list on x.CurveID equals y.ID select new Model.PumpCurveExMapping(y, x)).OrderBy(x => x.SortCode).ToList();
        }

        /// <summary>
        /// 通过 PumpIds 获取
        /// </summary>
        public List<Model.PumpCurveExMapping> GetByPumpIds(long CorpID, List<long> PumpIds)
        {
            if (PumpIds == null || PumpIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().GetByPumpIds(CorpID, PumpIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID, mapping_list.Select(x => x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            return (from x in mapping_list join y in curve_list on x.CurveID equals y.ID select new Model.PumpCurveExMapping(y, x)).OrderBy(x => x.SortCode).ToList();
        }

        /// <summary>
        /// 通过 CurveID 获取
        /// </summary>
        public List<Model.PumpCurveExMapping> GetByCurveID(long CorpID, long CurveID)
        {
            var mapping_list = new PumpCurveMapping().GetByCurveID(CorpID,CurveID);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID, mapping_list.Select(x => x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            return (from x in mapping_list join y in curve_list on x.CurveID equals y.ID select new Model.PumpCurveExMapping(y, x)).ToList();
        }

        /// <summary>
        /// 通过 CurveIds 获取
        /// </summary>
        public List<Model.PumpCurveExMapping> GetByCurveIds(long CorpID, List<long> CurveIds)
        {
            if (CurveIds == null || CurveIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().GetByCurveIds(CorpID, CurveIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID, mapping_list.Select(x => x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            return (from x in mapping_list join y in curve_list on x.CurveID equals y.ID select new Model.PumpCurveExMapping(y, x)).OrderBy(x => x.SortCode).ToList();
        }

        /// <summary>
        /// 通过 PumpID 获取工作曲线
        /// </summary>
        public Model.PumpCurveExMapping GetWorkingByPumpID(long CorpID, long PumpID)
        {
            var mapping_list = new PumpCurveMapping().GetByPumpID(CorpID,PumpID);
            var mapping = mapping_list?.Find(x => x.IsWorking);
            if (mapping == null)
                return default;
            var curve = new PumpCurve().GetByID(CorpID,mapping.CurveID);
            if (curve == null)
                return default;
            return new Model.PumpCurveExMapping(curve,mapping);
        }

        /// <summary>
        /// 通过 PumpID 获取默认工作曲线
        /// </summary>
        public Model.PumpCurveExMapping GetDefaultWorkingByPumpID(long CorpID, long PumpID)
        {
            var mapping_list = new PumpCurveMapping().GetByPumpID(CorpID, PumpID);
            var mapping = mapping_list?.Find(x => x.IsWorking);
            if (mapping == null)
            {
                mapping = mapping_list?.FirstOrDefault();
            }
            if (mapping == null)
                return default;
            var curve = new PumpCurve().GetByID(CorpID, mapping.CurveID);
            if (curve == null)
                return default;
            return new Model.PumpCurveExMapping(curve, mapping);
        }

        /// <summary>
        /// 通过 PumpIds 获取工作曲线
        /// </summary>
        public List<Model.PumpCurveExMapping> GetWorkingByPumpIds(long CorpID, List<long> PumpIds)
        {
            if (PumpIds == null || PumpIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().GetByPumpIds(CorpID,PumpIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID,mapping_list.Select(x=>x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            var vm_list = new List<Model.PumpCurveExMapping>();
            foreach (var PumpID in PumpIds)
            {
                var mapping = mapping_list.Find(x => x.PumpID == PumpID && x.IsWorking);
                if (mapping != null)
                {
                    var curve = curve_list.Find(x=>x.ID==mapping.CurveID);
                    if (curve != null)
                    {
                        vm_list.Add(new Model.PumpCurveExMapping(curve,mapping));
                    }
                }
            }
            return vm_list;
        }

        /// <summary>
        /// 通过 PumpIds 获取默认工作曲线
        /// </summary>
        public List<Model.PumpCurveExMapping> GetDefaultWorkingByPumpIds(long CorpID, List<long> PumpIds)
        {
            if (PumpIds == null || PumpIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().GetByPumpIds(CorpID, PumpIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().GetByIds(CorpID, mapping_list.Select(x => x.CurveID).ToList());
            if (curve_list == null || curve_list.Count < 1)
                return default;
            var vm_list = new List<Model.PumpCurveExMapping>();
            foreach (var PumpID in PumpIds)
            {
                var mapping = mapping_list.Find(x => x.PumpID == PumpID && x.IsWorking);
                if (mapping == null)
                    mapping = mapping_list.Find(x=>x.PumpID==PumpID);
                if (mapping != null)
                {
                    var curve = curve_list.Find(x => x.ID == mapping.CurveID);
                    if (curve != null)
                    {
                        vm_list.Add(new Model.PumpCurveExMapping(curve, mapping));
                    }
                }
            }
            return vm_list;
        }


        #endregion

        #region Insert

        /// <summary>
        /// 插入
        /// </summary>
        public long Insert(Model.PumpCurveExMapping model)
        {
            if (model == null)
                return default;
            if (model.CorpID < 1)
                return default;
            var entity_curve = Model2CurveEntity(model);
            var entity_mapping = Model2MappingEntity(model);
            var dal = new DAL.PumpCurveMapping();
            var mappingId = dal.InsertEx(entity_curve,entity_mapping);
            if (mappingId > 0)
            {
                var mapping = new PumpCurveMapping().UpdateCorpCacheR(model.CorpID, mappingId);
                new PumpCurve().UpdateCorpCache(model.CorpID, mapping.CurveID);
            }
            return mappingId;
        }

        /// <summary>
        /// 批量插入
        /// </summary>
        public bool Inserts(IEnumerable<Model.PumpCurveExMapping> list)
        {
            if (list == null || list.Count() < 1)
                return default;
            var corpIds = list.Select(x => x.CorpID).Distinct().ToList();
            if (corpIds.Count != 1)
                return default;
            var dict = new Dictionary<Entity.PumpCurve, Entity.PumpCurveMapping>();
            foreach (var model in list)
            {
                var entity_curve = Model2CurveEntity(model);
                var entity_mapping = Model2MappingEntity(model);
                dict.Add(entity_curve,entity_mapping);
            }
            var dal = new DAL.PumpCurveMapping();
            var mappingIds = dal.InsertsREx(dict);
            if (mappingIds != null && mappingIds.Count > 0)
            {
                var mapping_list= new PumpCurveMapping().UpdateCorpCacheR(corpIds[0], mappingIds);
                new PumpCurve().UpdateCorpCache(corpIds[0], mapping_list.Select(x=>x.CurveID).Distinct().ToList());
                return true;
            }
            return default;

        }

        #endregion



    }
}