using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Mvc;
using NHibernate;
using NHibernate.Linq;
using Sleis.Models;
using Sleis.Infrastructure;

namespace Sleis.Data
{
    public class PublicReleasePointData : ReleasePointData<PublicReleasePoint>, IReleasePointData
    {

        public List<ReleasePoint> GetReleasePointsByFacility(int facilityId)
        {
            using (ISession session = GetSession())
            {
                /*ISQLQuery query = session.CreateSQLQuery(@"SELECT REL_PT_ID, FAC_SITE_ID, E_REL_PT_TYPE_CD
                                                                , E_REL_PT_STAT_CD, REL_PT_DESC, REL_PT_IDEN 
                                                            FROM P_REL_PT WHERE FAC_SITE_ID = :facilityId");
                query.SetInt32("facilityId", facilityId);
                query.AddEntity(typeof(PublicReleasePoint));
                return query.List<ReleasePoint>().ToList<ReleasePoint>();
                */
                return (from d in GetSession().Query<PublicReleasePoint>()
                            where d.FacilityId == facilityId
                            select d).Distinct().ToList<ReleasePoint>();
                
            }
          
        }
        /// <summary>
        /// Will fetch Release Points based on AgencyReport Id.  
        /// </summary>
        /// <param name="agencyReportId">Agency Report Id</param>
        /// <returns></returns>
        public List<ReleasePoint> GetReleasePointsByReport(int agencyReportId)
        {
            using (ISession session = GetSession())
            {
               
                return (from rp in GetSession().Query<PublicReleasePoint>()
                            join f in GetSession().Query<PublicFacilityModel>() on rp.FacilityId equals f.Id
                            join pr in GetSession().Query<PublicReportModel>() on f.ReportId equals pr.Id
                            where pr.ReportId == agencyReportId
                            select rp).Distinct().ToList<ReleasePoint>();
                
            }
          
        }
        
        public ReleasePoint GetReleasePoint(int id)
        {
            return GetSession().Query<PublicReleasePoint>().SingleOrDefault(r => r.Id == id);
        }

        public List<ReleasePoint> GetReleasePointsByUnitProcess(int unitProcessId)
        {

            using (ISession session = GetSession())
            {
                return (from uprp in session.Query<PublicUnitProcessReleasePoint>()						
                        join rp in session.Query<PublicReleasePoint>()
                        on uprp.ReleasePointId equals rp.Id                        
                        where uprp.UnitProcessId == unitProcessId 
                        select rp).Distinct().ToList<ReleasePoint>();
            }

        }
        public List<ReleasePoint> GetReleasePointsByEmissionUnit(int emissionUnitId)
        {
            using (ISession session = GetSession())
            {
                return (from uprp in session.Query<PublicUnitProcessReleasePoint>()
                        join rp in session.Query<PublicReleasePoint>()
                        on uprp.ReleasePointId equals rp.Id
                        join up in session.Query<PublicUnitProcess>() on uprp.UnitProcessId equals up.Id
                        where up.EmissionUnitId == emissionUnitId
                        select rp).Distinct().ToList<ReleasePoint>();
            }
        }
        public bool CanDelete(int id)
        {
            throw new NotImplementedException();
        }
		public bool IsIdentifierUnique(ReleasePoint releasePoint)
		{
			using (ISession session = GetSession())
			{
				return (from rp in session.Query<PublicReleasePoint>()
						where rp.Identifier == releasePoint.Identifier && rp.Id != releasePoint.Id && rp.FacilityId == releasePoint.FacilityId
						select rp).Count() == 0;
			}
		}
    }
}