using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using gehGassi.Core.Interfaces;
using gehGassi.Domain.Advertisements;
using gehGassi.Domain.Common;
using Microsoft.EntityFrameworkCore;
using NetTopologySuite.Geometries;
using NetTopologySuite;

namespace gehGassi.Core.Services
{
    /// <summary>
    /// Service für die Verwaltung von Werbungen
    /// </summary>
    public class AdvertisementService : ServiceBase<Advertisement>, IAdvertisementService
    {
        private readonly IRepository<AdvertisementWithNames> _namesRepository;

        /// <summary>
        /// Erstellt eine Instanz
        /// </summary>
        /// <param name="unitOfWork">Instanz einer IUnitOfWork</param>
        public AdvertisementService(IUnitOfWork unitOfWork) : base(unitOfWork)
        {
            _namesRepository = unitOfWork.GetRepository<AdvertisementWithNames>();
        }

        /// <summary>
        /// Gibt eine gefilterte Liste von Werbungen zurück
        /// </summary>
        /// <param name="filter">Filterbegriff der in bestimmten Feldern gesucht wird</param>
        /// <returns>List betroffener Werbungen</returns>
        public IQueryable<Advertisement> Filter(string filter)
        {
            return Repository.Query(c => c.NameLocalized.Contains(filter));
        }

        /// <summary>
        /// Erstellen einer Werbung
        /// </summary>
        /// <returns>Listung</returns>
        public Advertisement Create()
        {
            var item = new Advertisement()
            {
                Id = Guid.NewGuid().ToString("N"),
                Created = DateTimeOffset.UtcNow
            };
            return item;
        }

        /// <summary>
        /// Gibt eine gefilterte Liste von Werbungen zurück.
        /// </summary>
        /// <param name="filter">Filterbegriff der in bestimmten Feldern gesucht wird</param>
        /// <returns>List betroffener Werbungen</returns>
        public async Task<List<Advertisement>> SearchAsync(string filter)
        {
            return (await Repository.FindAsync(c => c.NameLocalized.Contains(filter))).ToList();
        }

        /// <summary>
        /// Gibt eine gefilterte Liste von Werbungen mit Namen zurück in einer gewählten Sprache
        /// </summary>
        /// <param name="filter">Filterbegriff der in bestimmten Feldern gesucht wird</param>
        /// <param name="language">Gewünschte Sprache</param>
        /// <param name="fallback">Fallback Sprache</param>
        /// <param name="includeDeleted">Sollen gelöschte inkludiert werden?</param>
        /// <param name="excludeDraft">Sollen Entitäten im Draft-Status (Cart) ausgeblendet werden?</param>
        /// <returns>Liste betroffener Werbungen</returns>
        public IQueryable<AdvertisementWithNames> FilterWithNames(string filter, string language, string fallback, bool includeDeleted, bool excludeDraft)
        {
            language = language.ToUpperInvariant();
            fallback = fallback.ToUpperInvariant();

            var baseQuery = _namesRepository.QueryStoredProcedure("SELECT * FROM tv_AdvertisementsWithNames({0},{1})", c => c.Name.Contains(filter) || c.CustomerName.Contains(filter), language, fallback);

            if (!includeDeleted)
                baseQuery = baseQuery.Where(c => c.Deleted == false);

            if (excludeDraft)
                baseQuery = baseQuery.Where(c => c.Status != AdvertisementStatus.Draft);

            return baseQuery;
        }

        /// <summary>
        /// Gibt eine gefilterte Liste von Werbungen mit Namen für Kunden zurück in einer gewählten Sprache
        /// </summary>
        /// <param name="customerId">Id des Kunden</param>
        /// <param name="filter">Filterbegriff der in bestimmten Feldern gesucht wird</param>
        /// <param name="language">Gewünschte Sprache</param>
        /// <param name="fallback">Fallback Sprache</param>
        /// <param name="includeDeleted">Sollen gelöschte inkludiert werden?</param>
        /// <param name="excludeDraft">Sollen Entitäten im Draft-Status (Cart) ausgeblendet werden?</param>
        /// <returns>Liste betroffener Werbungen</returns>
        public IQueryable<AdvertisementWithNames> FilterWithNamesCustomer(long customerId, string filter, string language, string fallback, bool includeDeleted, bool excludeDraft)
        {
            language = language.ToUpperInvariant();
            fallback = fallback.ToUpperInvariant();

            var baseQuery = _namesRepository.QueryStoredProcedure("SELECT * FROM tv_AdvertisementsWithNames({0},{1})", c => c.CustomerId == customerId && (c.Name.Contains(filter) || c.CustomerName.Contains(filter)), language, fallback);

            if (!includeDeleted)
                baseQuery = baseQuery.Where(c => c.Deleted == false);

            if (excludeDraft)
                baseQuery = baseQuery.Where(c => c.Status != AdvertisementStatus.Draft);

            return baseQuery;
        }

        /// <summary>
        /// Löschen von Werbungen basierend auf einer Rubrik
        /// </summary>
        /// <param name="categoryId">Id der Rubrik</param>
        /// <param name="forceDelete">Wenn true, dann wirklich löschen, auf gelöscht setzen sonst</param>
        /// <returns>Task</returns>
        public async Task DeleteByCategoryAsync(string categoryId, bool forceDelete)
        {
            var items = await Repository.FindAsync(c => c.AdvertisementCategoryId == categoryId).ConfigureAwait(false);
            foreach (var listing in items)
            {
                if (!forceDelete)
                    listing.Deleted = true;
                else
                    Repository.Remove(listing);
            }
        }

        /// <summary>
        /// Gibt die Anzahl von Werbungen zurück
        /// </summary>
        /// <param name="includeDeleted">Sollen gelöschte inkludiert werden?</param>
        /// <param name="excludeDraft">Sollen Entitäten im Draft-Status (Cart) ausgeblendet werden?</param>
        /// <returns>Anzahl Werbungen</returns>
        public async Task<int> CountAsync(bool includeDeleted, bool excludeDraft)
        {
            var query = Repository.Query(c => c.Id != "");
            if (!includeDeleted)
                query = query.Where(c => c.Deleted == false);
            if (excludeDraft)
                query = query.Where(c => c.Status != AdvertisementStatus.Draft);
            return await query.CountAsync().ConfigureAwait(false);
        }

        /// <summary>
        /// Gibt die Anzahl von Werbungen in einem Status zurück
        /// </summary>
        /// <param name="status">Gesuchter Status</param>
        /// <param name="includeDeleted">Sollen gelöschte inkludiert werden?</param>
        /// <returns>Anzahl Werbungen</returns>
        public async Task<int> CountAsync(AdvertisementStatus status, bool includeDeleted)
        {
            var query = Repository.Query(c => c.Status == status);
            if (!includeDeleted)
                query = query.Where(c => c.Deleted == false);
            return await query.CountAsync().ConfigureAwait(false);
        }

        /// <summary>
        /// Gibt eine Werbung für einen Artikel im Warenkorb zurück
        /// </summary>
        /// <param name="cartItemId">Id des Artikels im Warenkorb</param>
        /// <returns>Werbung oder null, wenn nicht gefunden</returns>
        public async Task<Advertisement> GetByCartItemAsync(long cartItemId)
        {
            return await Repository.FirstOrDefaultAsync(c => c.CartItemId == cartItemId && c.Status == AdvertisementStatus.Draft);
        }

        /// <summary>
        /// Gibt eine Werbung für einen Artikel in einer Bestellung zurück
        /// </summary>
        /// <param name="orderItemId">Id des Artikels in der Bestellung</param>
        /// <returns>Werbung oder null, wenn nicht gefunden</returns>
        public async Task<Advertisement> GetByOrderItemAsync(long orderItemId)
        {
            return await Repository.FirstOrDefaultAsync(c => c.OrderItemId == orderItemId);
        }

        /// <summary>
        /// Setzen des Status von Werbungen nach Bestellung
        /// </summary>
        /// <param name="orderId">Id der Bestellung</param>
        /// <param name="status">Zu setzender Status</param>
        /// <returns>Anzahl betroffener Werbungen</returns>
        public async Task<int> SetStatusByOrderAsync(long orderId, AdvertisementStatus status)
        {
            var items = await Repository.FindAsync(c => c.OrderId == orderId);
            foreach (var item in items)
            {
                item.Status = status;
            }

            return items.Count();
        }

        /// <summary>
        /// Setzen des Bezahlstatus von Werbungen nach Bestellung
        /// </summary>
        /// <param name="orderId">Id der Bestellung</param>
        /// <param name="status">Zu setzender Status</param>
        /// <returns>Anzahl betroffener Werbungen</returns>
        public async Task<int> SetPaymentStatusByOrderAsync(long orderId, PaymentStatus status)
        {
            var items = await Repository.FindAsync(c => c.OrderId == orderId);
            foreach (var item in items)
            {
                item.PaymentStatus = status;
            }

            return items.Count();
        }

        /// <summary>
        /// Gibt eine Liste von Werbungen zurück für die Anzeige der Werbungen die bald enden und  in der Nähe sind
        /// </summary>
        /// <param name="country">Land</param>
        /// <param name="state">Bundesland</param>
        /// <param name="lat">Optional: Breitengrad</param>
        /// <param name="lng">Optional: Längengrad</param>
        /// <param name="language">Gewünschte Sprache</param>
        /// <param name="fallback">Fallback Sprache</param>
        /// <param name="skip">Datensätze auslassen</param>
        /// <param name="take">Datensätze nehmen</param>
        /// <returns>Liste passender Listungen</returns>
        public async Task<(int total, List<AdvertisementWithNames> list)> GetNearEndForAppAsync(string country, string state, double lat, double lng, string language, string fallback, int skip, int take)
        {
            language = language.ToUpperInvariant();
            fallback = fallback.ToUpperInvariant();
            if (!string.IsNullOrWhiteSpace(country))
                country = country.ToUpperInvariant();
            if (!string.IsNullOrWhiteSpace(state))
                state = state.ToUpperInvariant();
            var geometryFactory = NtsGeometryServices.Instance.CreateGeometryFactory(srid: 4326);
            var location = geometryFactory.CreatePoint(new Coordinate(lng, lat));

            var baseQuery = _namesRepository.QueryStoredProcedure("SELECT * FROM tv_AdvertisementsWithNames({0},{1})", c => c.Deleted == false && c.Status == AdvertisementStatus.Running && c.EndDate > DateTimeOffset.UtcNow &&
                                                                                                                      (c.GeoMode == GeoMode.None ||
                                                                                                                       (c.GeoMode == GeoMode.Country && c.Address_CountryCode == country) ||
                                                                                                                       (c.GeoMode == GeoMode.CountryAndState && c.Address_CountryCode == country && c.Address_State == state) ||
                                                                                                                       (c.GeoMode == GeoMode.Location && c.Location.IsWithinDistance(location, c.Radius * 1000))), language, fallback);

            var total = await baseQuery.CountAsync().ConfigureAwait(false);
            //TODO: noch überlegen wie wir eine Lokalisierung machen können
            var list = await baseQuery.OrderBy(c => c.EndDate).Skip(skip).Take(take).ToListAsync().ConfigureAwait(false);
            return (total, list);
        }

        /// <summary>
        /// Gibt eine Liste von Werbungen je Kategorie zurück
        /// </summary>
        /// <param name="categoryId">Id der Kategorie</param>
        /// <param name="country">Land</param>
        /// <param name="state">Bundesland</param>
        /// <param name="lat">Optional: Breitengrad</param>
        /// <param name="lng">Optional: Längengrad</param>
        /// <param name="language">Gewünschte Sprache</param>
        /// <param name="fallback">Fallback Sprache</param>
        /// <param name="skip">Datensätze auslassen</param>
        /// <param name="take">Datensätze nehmen</param>
        /// <returns>Liste passender Listungen</returns>
        public async Task<(int total, List<AdvertisementWithNames> list)> GetByCategoryForAppAsync(string categoryId, string country, string state, double lat, double lng, string language, string fallback, int skip, int take)
        {
            language = language.ToUpperInvariant();
            fallback = fallback.ToUpperInvariant();
            if (!string.IsNullOrWhiteSpace(country))
                country = country.ToUpperInvariant();
            if (!string.IsNullOrWhiteSpace(state))
                state = state.ToUpperInvariant();
            var geometryFactory = NtsGeometryServices.Instance.CreateGeometryFactory(srid: 4326);
            var location = geometryFactory.CreatePoint(new Coordinate(lng, lat));

            var baseQuery = _namesRepository.QueryStoredProcedure("SELECT * FROM tv_AdvertisementsWithNames({0},{1})", c => c.Deleted == false && c.Status == AdvertisementStatus.Running && c.EndDate > DateTimeOffset.UtcNow && c.AdvertisementCategoryId == categoryId &&
                                                                                                                            (c.GeoMode == GeoMode.None ||
                                                                                                                             (c.GeoMode == GeoMode.Country && c.Address_CountryCode == country) ||
                                                                                                                             (c.GeoMode == GeoMode.CountryAndState && c.Address_CountryCode == country && c.Address_State == state) ||
                                                                                                                             (c.GeoMode == GeoMode.Location && c.Location.IsWithinDistance(location, c.Radius * 1000))), language, fallback);

            var total = await baseQuery.CountAsync().ConfigureAwait(false);
            //TODO: noch überlegen wie wir eine Lokalisierung machen können
            var list = await baseQuery.OrderBy(c => c.EndDate).Skip(skip).Take(take).ToListAsync().ConfigureAwait(false);
            return (total, list);
        }

        /// <summary>
        /// Gibt eine Werbung in einer gewünschten Sprache zurück
        /// </summary>
        /// <param name="id">Id der Werbung</param>
        /// <param name="language">Gewünschte Sprache</param>
        /// <param name="fallback">Fallback Sprache</param>
        /// <returns>Gefundene Werbung, null sonst</returns>
        public async Task<AdvertisementWithNames> GetRunningWithNamesAsync(string id, string language, string fallback)
        {
            language = language.ToUpperInvariant();
            fallback = fallback.ToUpperInvariant();

            var baseQuery = _namesRepository.QueryStoredProcedure("SELECT * FROM tv_AdvertisementsWithNames({0},{1})", c => c.Id == id && c.Deleted == false && c.Status == AdvertisementStatus.Running && c.EndDate > DateTimeOffset.UtcNow, language, fallback);
            var result = await baseQuery.FirstOrDefaultAsync().ConfigureAwait(false);
            return result;
        }

        /// <summary>
        /// Starten von gebuchten Werbungen wenn diese das Start-Datum erreicht haben
        /// </summary>
        /// <returns>Anzahl gestartete Werbungen</returns>
        public async Task<int> StartBookedAsnyc()
        {
            var items = await Repository.FindAsync(c => c.Status == AdvertisementStatus.Booked && c.Deleted == false && c.StartDate <= DateTimeOffset.UtcNow && c.EndDate.Value >= DateTimeOffset.UtcNow);
            foreach (var item in items)
            {
                item.Status = AdvertisementStatus.Running;
            }

            return items.Count();
        }

        /// <summary>
        /// Stoppen von abgelaufenen Werbungen wenn diese das Enddatum erreicht haben
        /// </summary>
        /// <returns>Anzahl gestoppte Werbungen</returns>
        public async Task<int> StopRunningAsync()
        {
            var items = await Repository.FindAsync(c => c.Status == AdvertisementStatus.Running && c.Deleted == false && c.EndDate.Value <= DateTimeOffset.UtcNow);
            foreach (var item in items)
            {
                item.Status = AdvertisementStatus.Ended;
            }

            return items.Count();
        }
    }
}