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

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

        /// <summary>
        ///  查询全部
        /// </summary>
        public List<Model.PumpCurveExMapping> QueryAll(long projectId)
        {
            var mapping_list = new PumpCurveMapping().QueryAll(projectId);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId, 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 QueryByMappingId(long projectId, long MappingId)
        {
            var mapping = new PumpCurveMapping().QueryById(projectId,MappingId);
            if (mapping == null)
                return default;
            var curve = new PumpCurve().QueryById(projectId,mapping.CurveId);
            if (curve == null)
                return default;
            return new Model.PumpCurveExMapping(curve,mapping);
        }

        /// <summary>
        /// 根据MappingIds查询
        /// </summary>
        public List<Model.PumpCurveExMapping> QueryByMappingIds(long projectId, List<long> mappingIds)
        {
            if (mappingIds == null || mappingIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().QueryByIds(projectId,mappingIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId, 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> QueryByPumpId(long projectId, long pumpId)
        {
            var mapping_list = new PumpCurveMapping().QueryByPumpId(projectId,pumpId);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId,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> QueryByPumpIds(long projectId, List<long> PumpIds)
        {
            if (PumpIds == null || PumpIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().QueryByPumpIds(projectId, PumpIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId, 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> QueryByCurveID(long projectId, long CurveID)
        {
            var mapping_list = new PumpCurveMapping().QueryByCurveID(projectId,CurveID);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId, 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> QueryByCurveIds(long projectId, List<long> CurveIds)
        {
            if (CurveIds == null || CurveIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().QueryByCurveIds(projectId, CurveIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId, 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 QueryWorkingByPumpID(long projectId, long PumpID)
        {
            var mapping_list = new PumpCurveMapping().QueryByPumpID(projectId,PumpID);
            var mapping = mapping_list?.Find(x => x.IsWorking);
            if (mapping == null)
                return default;
            var curve = new PumpCurve().QueryByID(projectId,mapping.CurveID);
            if (curve == null)
                return default;
            return new Model.PumpCurveExMapping(curve,mapping);
        }

        /// <summary>
        /// 通过 PumpID 获取默认工作曲线
        /// </summary>
        public Model.PumpCurveExMapping QueryDefaultWorkingByPumpID(long projectId, long PumpID)
        {
            var mapping_list = new PumpCurveMapping().QueryByPumpID(projectId, 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().QueryByID(projectId, mapping.CurveID);
            if (curve == null)
                return default;
            return new Model.PumpCurveExMapping(curve, mapping);
        }

        /// <summary>
        /// 通过 PumpIds 获取工作曲线
        /// </summary>
        public List<Model.PumpCurveExMapping> QueryWorkingByPumpIds(long projectId, List<long> PumpIds)
        {
            if (PumpIds == null || PumpIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().QueryByPumpIds(projectId,PumpIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId,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> QueryDefaultWorkingByPumpIds(long projectId, List<long> PumpIds)
        {
            if (PumpIds == null || PumpIds.Count() < 1)
                return default;
            var mapping_list = new PumpCurveMapping().QueryByPumpIds(projectId, PumpIds);
            if (mapping_list == null || mapping_list.Count < 1)
                return default;
            var curve_list = new PumpCurve().QueryByIds(projectId, 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.projectId < 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.projectId, mappingId);
                new PumpCurve().UpdateCorpCache(model.projectId, 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.projectId).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



    }
}