diff --git a/DD.Persistence.Database.Postgres/Extensions/SpecificationExtensions.cs b/DD.Persistence.Database.Postgres/Extensions/SpecificationExtensions.cs deleted file mode 100644 index 2c13c10..0000000 --- a/DD.Persistence.Database.Postgres/Extensions/SpecificationExtensions.cs +++ /dev/null @@ -1,83 +0,0 @@ -using Ardalis.Specification; -using DD.Persistence.Database.Specifications; -using System.Linq.Expressions; - -namespace DD.Persistence.Database.Postgres.Extensions; - -// ToDo: рассмотреть возможность вынести логику в спецификации -public static class SpecificationExtensions -{ - public static ISpecification Or(this ISpecification spec, ISpecification otherSpec) - { - var newSpec = new EmptySpecification(); - - var parameter = Expression.Parameter(typeof(T), "x"); - - var exprSpec1 = CombineWhereExpressions(spec.WhereExpressions, parameter); - var exprSpec2 = CombineWhereExpressions(otherSpec.WhereExpressions, parameter); - - Expression? orExpression = exprSpec1 is not null && exprSpec2 is not null - ? Expression.OrElse(exprSpec1, exprSpec2) - : exprSpec1 ?? exprSpec2; - - if (orExpression is null) return newSpec; - - var lambdaExpr = Expression.Lambda>(orExpression, parameter); - - newSpec.Query.Where(lambdaExpr); - - return newSpec; - } - - // ToDo: Рефакторинг - public static ISpecification And(this ISpecification spec, ISpecification otherSpec) - { - var newSpec = new EmptySpecification(); - - var parameter = Expression.Parameter(typeof(T), "x"); - - var exprSpec1 = CombineWhereExpressions(spec.WhereExpressions, parameter); - var exprSpec2 = CombineWhereExpressions(otherSpec.WhereExpressions, parameter); - - Expression? andExpression = exprSpec1 is not null && exprSpec2 is not null - ? Expression.AndAlso(exprSpec1, exprSpec2) - : exprSpec1 ?? exprSpec2; - - if (andExpression is null) return newSpec; - - var lambdaExpr = Expression.Lambda>(andExpression, parameter); - - newSpec.Query.Where(lambdaExpr); - - return newSpec; - } - - public static Expression? CombineWhereExpressions(IEnumerable> whereExpressions, ParameterExpression parameter) - { - Expression? newExpr = null; - foreach (var where in whereExpressions) - { - var expr = ParameterReplacerVisitor.Replace(where.Filter.Body, where.Filter.Parameters[0], parameter); - newExpr = newExpr is null ? expr : Expression.AndAlso(newExpr, expr); - } - return newExpr; - } -} - -public class ParameterReplacerVisitor : ExpressionVisitor -{ - private readonly Expression _newExpression; - private readonly ParameterExpression _oldParameter; - - private ParameterReplacerVisitor(ParameterExpression oldParameter, Expression newExpression) - { - _oldParameter = oldParameter; - _newExpression = newExpression; - } - - internal static Expression Replace(Expression expression, ParameterExpression oldParameter, Expression newExpression) - => new ParameterReplacerVisitor(oldParameter, newExpression).Visit(expression); - - protected override Expression VisitParameter(ParameterExpression p) - => p == _oldParameter ? _newExpression : p; -} diff --git a/DD.Persistence.Database.Postgres/Helpers/FilterBuilder.cs b/DD.Persistence.Database.Postgres/Helpers/FilterBuilder.cs deleted file mode 100644 index e8a7f57..0000000 --- a/DD.Persistence.Database.Postgres/Helpers/FilterBuilder.cs +++ /dev/null @@ -1,137 +0,0 @@ -using Ardalis.Specification; -using DD.Persistence.Database.Entity; -using DD.Persistence.Database.EntityAbstractions; -using DD.Persistence.Database.Postgres.Extensions; -using DD.Persistence.Database.Specifications.ValuesItem; -using DD.Persistence.Filter.Models.Abstractions; -using DD.Persistence.Filter.Models.Enumerations; -using DD.Persistence.Filter.Visitors; -using DD.Persistence.Models; - -namespace DD.Persistence.Database.Postgres.Helpers; -public static class FilterBuilder -{ - public static ISpecification? BuildFilter(this DataScheme dataScheme, TNode root) - where TEntity : IValuesItem - { - var result = dataScheme.BuildSpecificationByNextNode(root); - - return result; - } - - private static ISpecification? BuildSpecificationByNextNode(this DataScheme dataScheme, TNode node) - where TEntity : IValuesItem - { - var propIndexMap = dataScheme.PropNames - .Select((name, index) => new { name, index }) - .ToDictionary(x => x.name, x => x.index); - - var visitor = new NodeVisitor?>( - v => - { - var leftSpecification = dataScheme.BuildSpecificationByNextNode(v.Left); - var rigthSpecification = dataScheme.BuildSpecificationByNextNode(v.Rigth); - if (leftSpecification is null) - return rigthSpecification; - if (rigthSpecification is null) - return leftSpecification; - - ISpecification? result = null; - switch (v.Operation) - { - case OperationEnum.And: - result = leftSpecification.And(rigthSpecification); - break; - case OperationEnum.Or: - result = leftSpecification.Or(rigthSpecification); - break; - } - - return result; - }, - t => - { - int keyIndex; - if (!propIndexMap.TryGetValue(t.PropName, out keyIndex)) - throw new ArgumentException($"Свойство {t.PropName} не найдено в схеме данных"); - var type = dataScheme.PropTypes[keyIndex]; - - ISpecification? result = null; - switch (type) - { - case PropTypeEnum.String: - var stringValue = Convert.ToString(t.Value); - switch (t.Operation) - { - case OperationEnum.Equal: - result = new ValueEqaulSpecification(keyIndex, stringValue); - break; - case OperationEnum.NotEqual: - result = new ValueNotEqaulSpecification(keyIndex, stringValue); - break; - } - break; - case PropTypeEnum.Double: - var doubleValue = Convert.ToDouble(t.Value); - switch (t.Operation) - // ToDo: можно схлопнуть в один Generic - метод, где TValue : struct - // Но в таком случае придётся продумать аналогичное решение на уровне спецификаций - { - case OperationEnum.Equal: - result = new ValueEqaulSpecification(keyIndex, doubleValue); - break; - case OperationEnum.NotEqual: - result = new ValueNotEqaulSpecification(keyIndex, doubleValue); - break; - case OperationEnum.Greate: - result = new ValueGreateSpecification(keyIndex, doubleValue); - break; - case OperationEnum.GreateOrEqual: - result = new ValueGreateOrEqualSpecification(keyIndex, doubleValue); - break; - case OperationEnum.Less: - result = new ValueLessSpecification(keyIndex, doubleValue); - break; - case OperationEnum.LessOrEqual: - result = new ValueLessOrEqualSpecification(keyIndex, doubleValue); - break; - } - break; - case PropTypeEnum.DateTime: - stringValue = Convert.ToString(t.Value); - DateTimeOffset? dateTimeValue = string.IsNullOrEmpty(stringValue) - ? null - : DateTimeOffset.Parse(stringValue); - switch (t.Operation) - { - case OperationEnum.Equal: - result = new ValueEqaulSpecification(keyIndex, dateTimeValue); - break; - case OperationEnum.NotEqual: - result = new ValueNotEqaulSpecification(keyIndex, dateTimeValue); - break; - case OperationEnum.Greate: - result = new ValueGreateSpecification(keyIndex, dateTimeValue); - break; - case OperationEnum.GreateOrEqual: - result = new ValueGreateOrEqualSpecification(keyIndex, dateTimeValue); - break; - case OperationEnum.Less: - result = new ValueLessSpecification(keyIndex, dateTimeValue); - break; - case OperationEnum.LessOrEqual: - result = new ValueLessOrEqualSpecification(keyIndex, dateTimeValue); - break; - } - break; - } - - return result; - } - ); - - var result = node.AcceptVisitor(visitor); - - return result; - } -} diff --git a/DD.Persistence.Database/DD.Persistence.Database.csproj b/DD.Persistence.Database/DD.Persistence.Database.csproj index 4d751e4..5a34ccc 100644 --- a/DD.Persistence.Database/DD.Persistence.Database.csproj +++ b/DD.Persistence.Database/DD.Persistence.Database.csproj @@ -7,6 +7,8 @@ + + all diff --git a/DD.Persistence.Database/EntityAbstractions/IValuesItem.cs b/DD.Persistence.Database/EntityAbstractions/IValuesItem.cs index f2a801c..0f2d219 100644 --- a/DD.Persistence.Database/EntityAbstractions/IValuesItem.cs +++ b/DD.Persistence.Database/EntityAbstractions/IValuesItem.cs @@ -7,11 +7,6 @@ namespace DD.Persistence.Database.EntityAbstractions; /// public interface IValuesItem { - /// - /// Схема данных - /// - DataScheme? DataScheme { get; set; } - /// /// Значения /// diff --git a/DD.Persistence.Database/Extensions/SpecificationExtensions.cs b/DD.Persistence.Database/Extensions/SpecificationExtensions.cs new file mode 100644 index 0000000..3bb0bc3 --- /dev/null +++ b/DD.Persistence.Database/Extensions/SpecificationExtensions.cs @@ -0,0 +1,38 @@ +using Ardalis.Specification; +using DD.Persistence.Database.Helpers; +using System.Linq.Expressions; + +namespace DD.Persistence.Database.Postgres.Extensions; + +public static class SpecificationExtensions +{ + public static Expression>? Or(this ISpecification spec, ISpecification otherSpec) + { + var parameter = Expression.Parameter(typeof(T), "x"); + + var exprSpec1 = CombineWhereExpressions(spec.WhereExpressions, parameter); + var exprSpec2 = CombineWhereExpressions(otherSpec.WhereExpressions, parameter); + + Expression? orExpression = exprSpec1 is not null && exprSpec2 is not null + ? Expression.OrElse(exprSpec1, exprSpec2) + : exprSpec1 ?? exprSpec2; + + if (orExpression is null) + return null; + + var lambdaExpr = Expression.Lambda>(orExpression, parameter); + + return lambdaExpr; + } + + public static Expression? CombineWhereExpressions(IEnumerable> whereExpressions, ParameterExpression parameter) + { + Expression? newExpr = null; + foreach (var where in whereExpressions) + { + var expr = ParameterReplacerVisitor.Replace(where.Filter.Body, where.Filter.Parameters[0], parameter); + newExpr = newExpr is null ? expr : Expression.AndAlso(newExpr, expr); + } + return newExpr; + } +} diff --git a/DD.Persistence.Database/Helpers/FilterBuilder.cs b/DD.Persistence.Database/Helpers/FilterBuilder.cs new file mode 100644 index 0000000..2d90284 --- /dev/null +++ b/DD.Persistence.Database/Helpers/FilterBuilder.cs @@ -0,0 +1,106 @@ +using Ardalis.Specification; +using DD.Persistence.Database.EntityAbstractions; +using DD.Persistence.Database.Postgres.Extensions; +using DD.Persistence.Database.Specifications; +using DD.Persistence.Database.Specifications.ValuesItem; +using DD.Persistence.Filter.Models; +using DD.Persistence.Filter.Models.Abstractions; +using DD.Persistence.Filter.Models.Enumerations; +using DD.Persistence.Filter.Visitors; +using DD.Persistence.Models; +using System.Text.Json; + +namespace DD.Persistence.Database.Postgres.Helpers; +public static class FilterBuilder +{ + public static ISpecification? BuildFilter(this DataSchemeDto dataSchemeDto, TNode root) + where TEntity : IValuesItem + { + var result = dataSchemeDto.BuildSpecificationByNextNode(root); + + return result; + } + + private static ISpecification? BuildSpecificationByNextNode(this DataSchemeDto dataSchemeDto, TNode node) + where TEntity : IValuesItem + { + var visitor = new NodeVisitor?>( + dataSchemeDto.VertexProcessing, + dataSchemeDto.LeafProcessing + ); + + var result = node.AcceptVisitor(visitor); + + return result; + } + + private static ISpecification? VertexProcessing(this DataSchemeDto dataSchemeDto, TVertex vertex) + where TEntity : IValuesItem + { + var leftSpecification = dataSchemeDto.BuildSpecificationByNextNode(vertex.Left); + var rigthSpecification = dataSchemeDto.BuildSpecificationByNextNode(vertex.Rigth); + if (leftSpecification is null) + return rigthSpecification; + if (rigthSpecification is null) + return leftSpecification; + + ISpecification? result = null; + switch (vertex.Operation) + { + case OperationEnum.And: + result = new AndSpecification(leftSpecification, rigthSpecification); + break; + case OperationEnum.Or: + result = new OrSpecification(leftSpecification, rigthSpecification); + break; + } + + return result; + } + + private static ISpecification? LeafProcessing(this DataSchemeDto dataSchemeDto, TLeaf leaf) + where TEntity : IValuesItem + { + var schemeProperty = dataSchemeDto.FirstOrDefault(e => e.PropertyName.Equals(leaf.PropName)); + if (schemeProperty is null) + throw new ArgumentException($"Свойство {leaf.PropName} не найдено в схеме данных"); + + ISpecification? result = null; + switch (schemeProperty.PropertyKind) + { + case JsonValueKind.String: + var stringValue = Convert.ToString(leaf.Value); + var stringSpecifications = StringSpecifications(); + result = stringSpecifications[leaf.Operation](schemeProperty.Index, stringValue); + break; + case JsonValueKind.Number: + var doubleValue = Convert.ToDouble(leaf.Value); + var doubleSpecifications = DoubleSpecifications(); + result = doubleSpecifications[leaf.Operation](schemeProperty.Index, doubleValue); + break; + } + + return result; + } + + private static Dictionary>> StringSpecifications() + where TEntity : IValuesItem => new() + { + { OperationEnum.Equal, (int index, string? value) => new ValueEqaulSpecification(index, value) }, + { OperationEnum.NotEqual, (int index, string? value) => new ValueNotEqualSpecification(index, value) }, + { OperationEnum.Greate, (int index, string? value) => new ValueGreateSpecification(index, value) }, + { OperationEnum.GreateOrEqual, (int index, string? value) => new ValueGreateOrEqualSpecification(index, value) }, + { OperationEnum.Less, (int index, string? value) => new ValueLessSpecification(index, value) }, + { OperationEnum.LessOrEqual, (int index, string? value) => new ValueLessOrEqualSpecification(index, value) } + }; + private static Dictionary>> DoubleSpecifications() + where TEntity : IValuesItem => new() + { + { OperationEnum.Equal, (int index, double? value) => new ValueEqaulSpecification(index, value) }, + { OperationEnum.NotEqual, (int index, double? value) => new ValueNotEqualSpecification(index, value) }, + { OperationEnum.Greate, (int index, double? value) => new ValueGreateSpecification(index, value) }, + { OperationEnum.GreateOrEqual, (int index, double? value) => new ValueGreateOrEqualSpecification(index, value) }, + { OperationEnum.Less, (int index, double? value) => new ValueLessSpecification(index, value) }, + { OperationEnum.LessOrEqual, (int index, double? value) => new ValueLessOrEqualSpecification(index, value) } + }; +} diff --git a/DD.Persistence.Database/Helpers/ParameterReplacerVisitor.cs b/DD.Persistence.Database/Helpers/ParameterReplacerVisitor.cs new file mode 100644 index 0000000..d64ac11 --- /dev/null +++ b/DD.Persistence.Database/Helpers/ParameterReplacerVisitor.cs @@ -0,0 +1,20 @@ +using System.Linq.Expressions; + +namespace DD.Persistence.Database.Helpers; +public class ParameterReplacerVisitor : ExpressionVisitor +{ + private readonly Expression _newExpression; + private readonly ParameterExpression _oldParameter; + + private ParameterReplacerVisitor(ParameterExpression oldParameter, Expression newExpression) + { + _oldParameter = oldParameter; + _newExpression = newExpression; + } + + internal static Expression Replace(Expression expression, ParameterExpression oldParameter, Expression newExpression) + => new ParameterReplacerVisitor(oldParameter, newExpression).Visit(expression); + + protected override Expression VisitParameter(ParameterExpression p) + => p == _oldParameter ? _newExpression : p; +} diff --git a/DD.Persistence.Database/Helpers/QueryBuilders.cs b/DD.Persistence.Database/Helpers/QueryBuilders.cs index 8529230..64783b0 100644 --- a/DD.Persistence.Database/Helpers/QueryBuilders.cs +++ b/DD.Persistence.Database/Helpers/QueryBuilders.cs @@ -23,7 +23,6 @@ public static class QueryBuilders return query; } - public static async Task> ApplyPagination( this IQueryable query, PaginationRequest request, diff --git a/DD.Persistence.Database/Specifications/AndSpecification.cs b/DD.Persistence.Database/Specifications/AndSpecification.cs new file mode 100644 index 0000000..776ce3a --- /dev/null +++ b/DD.Persistence.Database/Specifications/AndSpecification.cs @@ -0,0 +1,22 @@ +using Ardalis.Specification; + +namespace DD.Persistence.Database.Specifications; +public class AndSpecification : Specification +{ + public AndSpecification(ISpecification first, ISpecification second) + { + if (first is null || second is null) + return; + + ApplyCriteria(first); + ApplyCriteria(second); + } + + private void ApplyCriteria(ISpecification specification) + { + foreach (var criteria in specification.WhereExpressions) + { + Query.Where(criteria.Filter); + } + } +} diff --git a/DD.Persistence.Database/Specifications/EmptySpecification.cs b/DD.Persistence.Database/Specifications/EmptySpecification.cs deleted file mode 100644 index 010d0a9..0000000 --- a/DD.Persistence.Database/Specifications/EmptySpecification.cs +++ /dev/null @@ -1,14 +0,0 @@ -using Ardalis.Specification; - -namespace DD.Persistence.Database.Specifications; - -/// -/// Пустая спецификация (вспомогательная) -/// -/// -public class EmptySpecification : Specification -{ - public EmptySpecification() - { - } -} \ No newline at end of file diff --git a/DD.Persistence.Database/Specifications/OrSpecification.cs b/DD.Persistence.Database/Specifications/OrSpecification.cs new file mode 100644 index 0000000..75e573e --- /dev/null +++ b/DD.Persistence.Database/Specifications/OrSpecification.cs @@ -0,0 +1,15 @@ +using Ardalis.Specification; +using DD.Persistence.Database.Postgres.Extensions; + +namespace DD.Persistence.Database.Specifications; +public class OrSpecification : Specification +{ + public OrSpecification(ISpecification first, ISpecification second) + { + var orExpression = first.Or(second); + if (orExpression == null) + return; + + Query.Where(orExpression); + } +} diff --git a/DD.Persistence.Database/Specifications/ValuesItem/ValueEqaulSpecification.cs b/DD.Persistence.Database/Specifications/ValuesItem/ValueEqaulSpecification.cs index f5fd385..f85153f 100644 --- a/DD.Persistence.Database/Specifications/ValuesItem/ValueEqaulSpecification.cs +++ b/DD.Persistence.Database/Specifications/ValuesItem/ValueEqaulSpecification.cs @@ -19,10 +19,4 @@ public class ValueEqaulSpecification : Specification { Query.Where(e => Convert.ToDouble(e.Values[index]) == value); } - - public ValueEqaulSpecification(int index, DateTimeOffset? value) - { - // ToDo: рассмотреть возможность более вменяемого парсинга для даты - Query.Where(e => DateTimeOffset.Parse(Convert.ToString(e.Values[index])!) == value); - } } diff --git a/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateOrEqualSpecification.cs b/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateOrEqualSpecification.cs index ada97ad..695bffe 100644 --- a/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateOrEqualSpecification.cs +++ b/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateOrEqualSpecification.cs @@ -10,13 +10,13 @@ namespace DD.Persistence.Database.Specifications.ValuesItem; public class ValueGreateOrEqualSpecification : Specification where TEntity : IValuesItem { + public ValueGreateOrEqualSpecification(int index, string? value) + { + Query.Where(e => string.Compare(Convert.ToString(e.Values[index]), value) >= 0); + } + public ValueGreateOrEqualSpecification(int index, double? value) { Query.Where(e => Convert.ToDouble(e.Values[index]) >= value); } - - public ValueGreateOrEqualSpecification(int index, DateTimeOffset? value) - { - Query.Where(e => DateTimeOffset.Parse(Convert.ToString(e.Values[index])!) >= value); - } } diff --git a/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateSpecification.cs b/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateSpecification.cs index c0ee199..f42a7e2 100644 --- a/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateSpecification.cs +++ b/DD.Persistence.Database/Specifications/ValuesItem/ValueGreateSpecification.cs @@ -10,13 +10,13 @@ namespace DD.Persistence.Database.Specifications.ValuesItem; public class ValueGreateSpecification : Specification where TEntity : IValuesItem { + public ValueGreateSpecification(int index, string? value) + { + Query.Where(e => string.Compare(Convert.ToString(e.Values[index]), value) > 0); + } + public ValueGreateSpecification(int index, double? value) { Query.Where(e => Convert.ToDouble(e.Values[index]) > value); } - - public ValueGreateSpecification(int index, DateTimeOffset? value) - { - Query.Where(e => DateTimeOffset.Parse(Convert.ToString(e.Values[index])!) > value); - } } diff --git a/DD.Persistence.Database/Specifications/ValuesItem/ValueLessOrEqualSpecification.cs b/DD.Persistence.Database/Specifications/ValuesItem/ValueLessOrEqualSpecification.cs index c749955..81709f0 100644 --- a/DD.Persistence.Database/Specifications/ValuesItem/ValueLessOrEqualSpecification.cs +++ b/DD.Persistence.Database/Specifications/ValuesItem/ValueLessOrEqualSpecification.cs @@ -10,13 +10,13 @@ namespace DD.Persistence.Database.Specifications.ValuesItem; public class ValueLessOrEqualSpecification : Specification where TEntity : IValuesItem { + public ValueLessOrEqualSpecification(int index, string? value) + { + Query.Where(e => string.Compare(Convert.ToString(e.Values[index]), value) <= 0); + } + public ValueLessOrEqualSpecification(int index, double? value) { Query.Where(e => Convert.ToDouble(e.Values[index]) <= value); } - - public ValueLessOrEqualSpecification(int index, DateTimeOffset? value) - { - Query.Where(e => DateTimeOffset.Parse(Convert.ToString(e.Values[index])!) <= value); - } } diff --git a/DD.Persistence.Database/Specifications/ValuesItem/ValueLessSpecification.cs b/DD.Persistence.Database/Specifications/ValuesItem/ValueLessSpecification.cs index ac29eb2..4c308d4 100644 --- a/DD.Persistence.Database/Specifications/ValuesItem/ValueLessSpecification.cs +++ b/DD.Persistence.Database/Specifications/ValuesItem/ValueLessSpecification.cs @@ -10,13 +10,13 @@ namespace DD.Persistence.Database.Specifications.ValuesItem; public class ValueLessSpecification : Specification where TEntity : IValuesItem { + public ValueLessSpecification(int index, string? value) + { + Query.Where(e => string.Compare(Convert.ToString(e.Values[index]), value) < 0); + } + public ValueLessSpecification(int index, double? value) { Query.Where(e => Convert.ToDouble(e.Values[index]) < value); } - - public ValueLessSpecification(int index, DateTimeOffset? value) - { - Query.Where(e => DateTimeOffset.Parse(Convert.ToString(e.Values[index])!) < value); - } } diff --git a/DD.Persistence.Database/Specifications/ValuesItem/ValueNotEqaulSpecification.cs b/DD.Persistence.Database/Specifications/ValuesItem/ValueNotEqualSpecification.cs similarity index 60% rename from DD.Persistence.Database/Specifications/ValuesItem/ValueNotEqaulSpecification.cs rename to DD.Persistence.Database/Specifications/ValuesItem/ValueNotEqualSpecification.cs index bbe65d7..668d415 100644 --- a/DD.Persistence.Database/Specifications/ValuesItem/ValueNotEqaulSpecification.cs +++ b/DD.Persistence.Database/Specifications/ValuesItem/ValueNotEqualSpecification.cs @@ -7,21 +7,16 @@ namespace DD.Persistence.Database.Specifications.ValuesItem; /// Спецификация неравенства значений IValuesItem в соответствии с индексацией /// /// -public class ValueNotEqaulSpecification : Specification +public class ValueNotEqualSpecification : Specification where TEntity : IValuesItem { - public ValueNotEqaulSpecification(int index, string? value) + public ValueNotEqualSpecification(int index, string? value) { Query.Where(e => Convert.ToString(e.Values[index]) != value); } - public ValueNotEqaulSpecification(int index, double? value) + public ValueNotEqualSpecification(int index, double? value) { Query.Where(e => Convert.ToDouble(e.Values[index]) != value); } - - public ValueNotEqaulSpecification(int index, DateTimeOffset? value) - { - Query.Where(e => DateTimeOffset.Parse(Convert.ToString(e.Values[index])!) != value); - } } diff --git a/DD.Persistence.Test/FilterBuilderShould.cs b/DD.Persistence.Test/FilterBuilderShould.cs index f32f09c..09735c3 100644 --- a/DD.Persistence.Test/FilterBuilderShould.cs +++ b/DD.Persistence.Test/FilterBuilderShould.cs @@ -4,8 +4,11 @@ using DD.Persistence.Filter.Models; using DD.Persistence.Filter.Models.Enumerations; using DD.Persistence.Models; using DD.Persistence.Database.Postgres.Helpers; +using System.Text.Json; namespace DD.Persistence.Test; + +/// ToDo: переписать под Theory public class FilterBuilderShould { private readonly SpecificationEvaluator SpecificationEvaluator; @@ -19,12 +22,28 @@ public class FilterBuilderShould { //arrange var discriminatorId = Guid.NewGuid(); - var dataScheme = new DataScheme() + var dataSchemeProperties = new SchemePropertyDto[] { - DiscriminatorId = discriminatorId, - PropNames = ["A", "B", "C"], - PropTypes = [PropTypeEnum.DateTime, PropTypeEnum.Double, PropTypeEnum.String] + new SchemePropertyDto() + { + Index = 0, + PropertyName = "A", + PropertyKind = JsonValueKind.String + }, + new SchemePropertyDto() + { + Index = 1, + PropertyName = "B", + PropertyKind = JsonValueKind.Number + }, + new SchemePropertyDto() + { + Index = 2, + PropertyName = "C", + PropertyKind = JsonValueKind.String + } }; + var dataScheme = new DataSchemeDto(discriminatorId, dataSchemeProperties); var filterDate = DateTime.Now.AddMinutes(-1); var root = new TVertex( OperationEnum.Or, @@ -40,26 +59,22 @@ public class FilterBuilderShould new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-1), - Values = new object[] { filterDate.AddMinutes(-1), 200, "IsEqualText" }, // true - DataScheme = dataScheme + Values = new object[] { filterDate.AddMinutes(-1), 200, "IsEqualText" } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-2), - Values = new object[] { filterDate.AddMinutes(1), 2.21, "IsNotEqualText" }, // true - DataScheme = dataScheme + Values = new object[] { filterDate.AddMinutes(1), 2.21, "IsNotEqualText" } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-3), - Values = new object[] { filterDate.AddMinutes(-1), 2.22, "IsNotEqualText" }, // false - DataScheme = dataScheme + Values = new object[] { filterDate.AddMinutes(-1), 2.22, "IsNotEqualText" } // false }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-4), - Values = new object[] { filterDate.AddMinutes(-1), 2.21, "IsNotEqualText" }, // false - DataScheme = dataScheme + Values = new object[] { filterDate.AddMinutes(-1), 2.21, "IsNotEqualText" } // false } } .AsQueryable(); @@ -86,12 +101,16 @@ public class FilterBuilderShould { //arrange var discriminatorId = Guid.NewGuid(); - var dataScheme = new DataScheme() + var dataSchemeProperties = new SchemePropertyDto[] { - DiscriminatorId = discriminatorId, - PropNames = ["A"], - PropTypes = [PropTypeEnum.Double] + new SchemePropertyDto() + { + Index = 0, + PropertyName = "A", + PropertyKind = JsonValueKind.Number + } }; + var dataScheme = new DataSchemeDto(discriminatorId, dataSchemeProperties); var root = new TVertex( OperationEnum.Or, new TVertex( @@ -118,38 +137,32 @@ public class FilterBuilderShould new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-1), - Values = new object[] { 1 }, // true - DataScheme = dataScheme + Values = new object[] { 1 } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-2), - Values = new object[] { 1.96 }, // false - DataScheme = dataScheme + Values = new object[] { 1.96 } // false }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-3), - Values = new object[] { 1.97 }, // true - DataScheme = dataScheme + Values = new object[] { 1.97 } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-4), - Values = new object[] { 1.98 }, // false - DataScheme = dataScheme + Values = new object[] { 1.98 } // false }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-5), - Values = new object[] { 1.99 }, // true - DataScheme = dataScheme + Values = new object[] { 1.99 } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-6), - Values = new object[] { 2 }, // false - DataScheme = dataScheme + Values = new object[] { 2 } // false } } .AsQueryable(); @@ -177,12 +190,35 @@ public class FilterBuilderShould //arrange var discriminatorId = Guid.NewGuid(); var filterDate = DateTimeOffset.Now; - var dataScheme = new DataScheme() + var dataSchemeProperties = new SchemePropertyDto[] { - DiscriminatorId = discriminatorId, - PropNames = ["A", "B", "C", "D"], - PropTypes = [PropTypeEnum.Double, PropTypeEnum.Double, PropTypeEnum.String, PropTypeEnum.DateTime] + new SchemePropertyDto() + { + Index = 0, + PropertyName = "A", + PropertyKind = JsonValueKind.Number + }, + new SchemePropertyDto() + { + Index = 1, + PropertyName = "B", + PropertyKind = JsonValueKind.Number + }, + new SchemePropertyDto() + { + Index = 2, + PropertyName = "C", + PropertyKind = JsonValueKind.String + }, + new SchemePropertyDto() + { + Index = 3, + PropertyName = "D", + PropertyKind = JsonValueKind.String + } }; + var dataScheme = new DataSchemeDto(discriminatorId, dataSchemeProperties); + var root = new TVertex( OperationEnum.Or, new TVertex( @@ -201,32 +237,27 @@ public class FilterBuilderShould new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-1), - Values = new object[] { 1, 2.22, "IsNotEqualText", DateTimeOffset.Now.AddMinutes(-1) }, // true - DataScheme = dataScheme + Values = new object[] { 1, 2.22, "IsNotEqualText", DateTimeOffset.Now.AddMinutes(-1) } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-2), - Values = new object[] { 2, 1.11, "IsNotEqualText", DateTimeOffset.Now.AddMinutes(-1) }, // true - DataScheme = dataScheme + Values = new object[] { 2, 1.11, "IsNotEqualText", DateTimeOffset.Now.AddMinutes(-1) } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-3), - Values = new object[] { 2, 2.22, "IsEqualText", DateTimeOffset.Now.AddMinutes(-1) }, // true - DataScheme = dataScheme + Values = new object[] { 2, 2.22, "IsEqualText", DateTimeOffset.Now.AddMinutes(-1) } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-4), - Values = new object[] { 2, 2.22, "IsNotEqualText", filterDate }, // true - DataScheme = dataScheme + Values = new object[] { 2, 2.22, "IsNotEqualText", filterDate } // true }, new TimestampedValues { DiscriminatorId = discriminatorId, Timestamp = DateTimeOffset.Now.AddMinutes(-1), - Values = new object[] { 2, 2.22, "IsNotEqualText", DateTimeOffset.Now.AddMinutes(-1) }, // false - DataScheme = dataScheme + Values = new object[] { 2, 2.22, "IsNotEqualText", DateTimeOffset.Now.AddMinutes(-1) } // false } } .AsQueryable(); diff --git a/DD.Persistence.Test/TimestampedValuesServiceShould.cs b/DD.Persistence.Test/TimestampedValuesServiceShould.cs index 1a51eb1..e1e7cdc 100644 --- a/DD.Persistence.Test/TimestampedValuesServiceShould.cs +++ b/DD.Persistence.Test/TimestampedValuesServiceShould.cs @@ -2,6 +2,7 @@ using DD.Persistence.Models; using DD.Persistence.Repositories; using DD.Persistence.Services; using NSubstitute; +using System.Text.Json; namespace DD.Persistence.Test; public class TimestampedValuesServiceShould @@ -44,10 +45,10 @@ public class TimestampedValuesServiceShould { var values = new Dictionary() { - { "A", i }, - { "B", i * 1.1 }, - { "C", $"Any{i}" }, - { "D", DateTimeOffset.Now }, + { "A", GetJsonFromObject(i) }, + { "B", GetJsonFromObject(i * 1.1) }, + { "C", GetJsonFromObject($"Any{i}") }, + { "D", GetJsonFromObject(DateTimeOffset.Now) } }; yield return new TimestampedValuesDto() @@ -57,4 +58,11 @@ public class TimestampedValuesServiceShould }; } } + + private static JsonElement GetJsonFromObject(object value) + { + var jsonString = JsonSerializer.Serialize(value); + var doc = JsonDocument.Parse(jsonString); + return doc.RootElement; + } }