Sanya-ips/ipstool/ipssps2/Ips.Sps.Host.Win/Store/PesStore.cs

using DevExpress.Data.Filtering;
using DevExpress.DataAccess.DataFederation;
using DevExpress.Mvvm;
using DevExpress.Xpo;
using Ips.Library.DxpLib;
using Ips.Sps.TskResults.Peses;
using Ips.Sps.TskResults.Poses;
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 PesStore : StoreBase
    {
        public PesStore(SynchronizationContext context) : base(context)
        {
            _queryModel = new PesQueryModel()
            {
                TskId = TskManager.Default.SelectTskId,
                SigId = TskManager.Default.SelectSigId
            };
            SubMessages();
        }

        private readonly PesQueryModel _queryModel;
        public PesQueryModel 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 = CreateFilter();
            if (ListSource != null)
            {
                if (ListSource is IDisposable)
                {
                    ((IDisposable)ListSource).Dispose();
                }
                ListSource = null;
            }

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

        public CriteriaOperator CreateFilter()
        {
            CriteriaOperator result = null;

            List<CriteriaOperator> queryList = new List<CriteriaOperator>();
            if (_queryModel.TskId > 0)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.TskId == _queryModel.TskId));
            }
            if (_queryModel.SigId > 0)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.SigId == _queryModel.SigId));
            }
            if (_queryModel.SigCategory.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.Category == _queryModel.SigCategory));
            }
            if (_queryModel.StartTime.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.SigTime >= _queryModel.StartTime));
            }
            if (_queryModel.EndTime.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.SigTime <= _queryModel.EndTime));
            }
            if (_queryModel.SigType.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.SigType == _queryModel.SigType));
            }
            if (_queryModel.MainSatId.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.MainSatId == _queryModel.MainSatId));
            }
            if (_queryModel.AdjaSatId.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.AdjaSatId == _queryModel.AdjaSatId));
            }
            if (_queryModel.DtoMin.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.Dt >= _queryModel.DtoMin));
            }
            if(_queryModel.DtoMax.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.Dt <= _queryModel.DtoMax));
            }
            if(_queryModel.DfoMin.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.Df >= _queryModel.DfoMin));
            }
            if(_queryModel.DfoMax.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.Df <= _queryModel.DfoMax));
            }
            if(_queryModel.SnrMin.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.Snr >= _queryModel.SnrMin));
            }
            if (_queryModel.IsValid.HasValue)
            {
                queryList.Add(CriteriaOperator.FromLambda<Pes>(m => m.IsValid == _queryModel.IsValid));
            }
            if (queryList.Count > 0)
            {
                result = CriteriaOperator.And(queryList);
            }
            return result;
        }
    }
}