using DevExpress.Data.Filtering;
using DevExpress.Mvvm;
using DevExpress.Xpo;
using Ips.Library.DxpLib;
using Ips.Sps.TskResults.Pases;
using Ips.Sps.TskResults.Peses;
using Ips.Sps.Tsks;
using Ips.Sps.Tsks.Commands;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Ips.Sps.Store
{
    public class PasStore : StoreBase
    {
        public PasStore(SynchronizationContext context) : base(context)
        {
            _queryModel = new PasQueryModel()
            {
                TskId = TskManager.Default.SelectTskId,
                SigId = TskManager.Default.SelectSigId
            };
            SubMessages();
        }

        private readonly PasQueryModel _queryModel;
        public PasQueryModel QueryModel => _queryModel;
        public IListSource ListSource { get; private set; }

        public event EventHandler ListSourceChanged;

        private void SubMessages()
        {
            Messenger.Default.Register<TskSelectedMessage>(this, msg =>
            {
                _queryModel.TskId = msg.TskId;
                _queryModel.SigId = msg.SigId;
                BindList();
            });
        }

        public void BindList()
        {
            var query = GetQuery();
            if (ListSource != null)
            {
                if (ListSource is IDisposable)
                {
                    ((IDisposable)ListSource).Dispose();
                }
                ListSource = null;
            }

            XPInstantFeedbackSource xpiSource = new XPInstantFeedbackSource(typeof(Pas), null, query);
            xpiSource.DefaultSorting = $"{nameof(Pas.SigTime)} desc";
            ListSource = xpiSource;
            ListSourceChanged?.Invoke(this, EventArgs.Empty);
        }

        public CriteriaOperator GetQuery()
        {
            CriteriaOperator result = null;

            List<CriteriaOperator> queryList = new List<CriteriaOperator>();
            if (_queryModel.TskId > 0)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pas>(m => m.TskId == _queryModel.TskId));
            }
            if (_queryModel.SigId > 0)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pas>(m => m.SigId == _queryModel.SigId));
            }
            if (_queryModel.SigCategory.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pas>(m => m.SigCategory == _queryModel.SigCategory));
            }
            if (_queryModel.StartTime.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pas>(m => m.SigTime >= _queryModel.StartTime));
            }
            if (_queryModel.EndTime.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pas>(m => m.SigTime <= _queryModel.EndTime));
            }
            if (_queryModel.SigType.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pas>(m => m.SigType == _queryModel.SigType));
            }
            if (_queryModel.SatId.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pas>(m => m.SatId == _queryModel.SatId));
            }
            if (queryList.Count > 0)
            {
                result = CriteriaOperator.And(queryList);
            }
            return result;
        }
    }
}