如何在单个Nest查询中根据条件选择范围比较操作符

你尝试的写法存在语法问题，因为在Elasticsearch.NET的LINQ链式调用中，无法直接在中间插入三元表达式来切换Range方法。正确的做法是把Range查询的逻辑单独抽出来，根据输入的条件字符串动态构建RangeDescriptor，再传入Range方法中。

下面提供两种可行的实现方式：

方式一：使用Switch语句构建（直观易懂） #

await _elasticClient.SearchAsync<T>(s => s
    .Index(objFeasibilityRangeVM.IndexName)
    .From(objFeasibilityRangeVM.From)
    .Size(objFeasibilityRangeVM.Size)
    .Aggregations(ag => ag
        .Cardinality(objFeasibilityRangeVM.SumName, ca => ca.Field(objFeasibilityRangeVM.CardinalField)))
    .Query(q => q
        .Bool(b => b
            .Must(m => m
                    .QueryString(qs => qs
                        .Fields(objFeasibilityRangeVM.FieldNames).Query(objFeasibilityRangeVM.FieldValue)),
                  m => m.Terms(tf => tf
                       .Field(objFeasibilityRangeVM.TermField)
                       .Terms(objFeasibilityRangeVM.TermFeildVal)),
                  m => m.Range(ra => {
                      // 根据输入的条件字符串选择对应的Range方法
                      switch(objFeasibilityRangeVM.Condition)
                      {
                          case "gte":
                              ra.Field(objFeasibilityRangeVM.RangeField).GreaterThanOrEquals(objFeasibilityRangeVM.RangeVal);
                              break;
                          case "gt":
                              ra.Field(objFeasibilityRangeVM.RangeField).GreaterThan(objFeasibilityRangeVM.RangeVal);
                              break;
                          case "lte":
                              ra.Field(objFeasibilityRangeVM.RangeField).LessThanOrEquals(objFeasibilityRangeVM.RangeVal);
                              break;
                          case "lt":
                              ra.Field(objFeasibilityRangeVM.RangeField).LessThan(objFeasibilityRangeVM.RangeVal);
                              break;
                          default:
                              // 处理未知条件，比如抛出异常或跳过Range查询
                              break;
                      }
                      return ra;
                  })
            )
        )
    )
).ConfigureAwait(false);

方式二：使用字典映射方法（灵活易扩展） #

先提前定义条件与对应方法的映射关系：

// 可将此映射定义为类的静态字段，避免重复创建
private static readonly Dictionary<string, Action<RangeDescriptor<T>, string, string>> _rangeOperatorMap = new()
{
    ["gte"] = (descriptor, field, value) => descriptor.Field(field).GreaterThanOrEquals(value),
    ["gt"] = (descriptor, field, value) => descriptor.Field(field).GreaterThan(value),
    ["lte"] = (descriptor, field, value) => descriptor.Field(field).LessThanOrEquals(value),
    ["lt"] = (descriptor, field, value) => descriptor.Field(field).LessThan(value)
};

然后在查询中使用映射：

await _elasticClient.SearchAsync<T>(s => s
    .Index(objFeasibilityRangeVM.IndexName)
    .From(objFeasibilityRangeVM.From)
    .Size(objFeasibilityRangeVM.Size)
    .Aggregations(ag => ag
        .Cardinality(objFeasibilityRangeVM.SumName, ca => ca.Field(objFeasibilityRangeVM.CardinalField)))
    .Query(q => q
        .Bool(b => b
            .Must(m => m
                    .QueryString(qs => qs
                        .Fields(objFeasibilityRangeVM.FieldNames).Query(objFeasibilityRangeVM.FieldValue)),
                  m => m.Terms(tf => tf
                       .Field(objFeasibilityRangeVM.TermField)
                       .Terms(objFeasibilityRangeVM.TermFeildVal)),
                  m => m.Range(ra => {
                      if (_rangeOperatorMap.TryGetValue(objFeasibilityRangeVM.Condition, out var operatorAction))
                      {
                          operatorAction(ra, objFeasibilityRangeVM.RangeField, objFeasibilityRangeVM.RangeVal);
                      }
                      return ra;
                  })
            )
        )
    )
).ConfigureAwait(false);

两种方式都能实现根据输入字符串动态切换Range查询条件：

• Switch语句适合逻辑简单、不需要频繁扩展的场景，直观易懂；
• 字典映射方式更灵活，后续新增条件只需在映射中添加条目即可，无需修改查询逻辑。

内容的提问来源于stack exchange，提问作者Ahmed