Elasticsearch双字段复杂排序需求及Painless脚本问题求助

需求回顾 #

我手头的商品数据包含这些字段：Price（原价）、PromotionPrice（促销价，无促销时为0）、PromotionStart/PromotionEnd（促销起止时间）。想要实现的排序逻辑是：

• 处于有效促销期（当前时间在促销起止范围内且促销价不为0）的商品必须排在最前面
• 促销商品内部支持按促销价升序/降序
• 无促销或促销过期/未开始的商品排在后面，按原价排序

现有脚本的问题 #

你之前写的脚本只返回了对应的价格，但没有区分促销和非促销商品的优先级——不管是不是促销，都只输出一个价格值，Elasticsearch没法判断谁该排前面。要实现促销优先，得先给两类商品划分不同的优先级权重，再按价格排序。

基础实现：促销商品优先 + 固定排序方向 #

这里分两个排序维度：第一个维度区分促销优先级，第二个维度按对应价格排序。示例脚本如下：

"sort": [
  // 第一维度：区分促销/非促销，促销商品权重为0（排前面），非促销为1（排后面）
  {
    "_script": {
      "type": "number",
      "script": {
        "lang": "painless",
        "params": { "now": 1604169600000 }, // 替换为当前时间的毫秒数
        "source": """
          boolean isValidPromo = doc['PromotionPrice'].value != 0 && 
                                params.now >= doc['PromotionStart'].value.getMillis() && 
                                params.now <= doc['PromotionEnd'].value.getMillis();
          return isValidPromo ? 0 : 1;
        """
      },
      "order": "asc" // 升序：0（促销）排在1（非促销）前面
    }
  },
  // 第二维度：按对应价格排序，促销用PromotionPrice，非促销用Price
  {
    "_script": {
      "type": "number",
      "script": {
        "lang": "painless",
        "params": { "now": 1604169600000 },
        "source": """
          boolean isValidPromo = doc['PromotionPrice'].value != 0 && 
                                params.now >= doc['PromotionStart'].value.getMillis() && 
                                params.now <= doc['PromotionEnd'].value.getMillis();
          return isValidPromo ? doc['PromotionPrice'].value : doc['Price'].value;
        """
      },
      "order": "asc" // 这里改成"desc"就是促销商品按价格降序
    }
  }
]

这个脚本跑起来后，就能得到你预期的排序结果：有效促销的A、B、C排在前面，然后是无促销的E，最后是促销过期的D。

延伸问题：动态传入时间和排序方向 #

你想把now（当前时间）和sort_order（升序/降序）作为参数传入，之前的脚本语法有问题（比如isPromo?这种错误写法，还有return语句的混乱结构）。这里提供一个更简洁的实现，把优先级和价格逻辑合并到一个脚本里，通过参数控制排序方向：

"sort": [
  {
    "_script": {
      "type": "number",
      "script": {
        "lang": "painless",
        "params": { 
          "now": 1604169600000, // 当前时间毫秒数
          "sort_order": "asc"   // 动态传入"asc"或"desc"
        },
        "source": """
          // 先判断是否为有效促销商品
          boolean isValidPromo = doc['PromotionPrice'].value != 0 && 
                                params.now >= doc['PromotionStart'].value.getMillis() && 
                                params.now <= doc['PromotionEnd'].value.getMillis();
          
          // 给促销商品更低的优先级值（确保排在前面）
          long priority = isValidPromo ? 0 : 1000000000; // 用一个大数值拉开优先级差距
          
          // 获取当前商品要排序的价格
          long targetPrice = isValidPromo ? doc['PromotionPrice'].value : doc['Price'].value;
          
          // 根据排序方向调整价格值：降序的话用大数减去价格，实现升序排序等于价格降序
          if (params.sort_order == 'desc') {
            targetPrice = 1000000000 - targetPrice;
          }
          
          // 返回优先级+调整后的价格，确保促销商品先排，再按指定方向排序价格
          return priority + targetPrice;
        """
      },
      "order": "asc" // 这里固定升序就行，因为脚本里已经处理了降序逻辑
    }
  }
]

这个脚本的逻辑是：用一个足够大的数值（1e9）区分促销和非促销的优先级，然后根据传入的sort_order调整价格的计算方式，这样只需要一个排序字段就能实现所有需求。

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