Rails中调用find_each报NoMethodError，Sidekiq任务执行失败求助

错误根源 #

你遇到的NoMethodError核心原因：

• 修改前的future_orders返回ActiveRecord Relation对象（Rails查询构建器的延迟加载结果），这类对象自带find_each批量处理方法，能分批从数据库加载记录，避免内存溢出。
• 修改后的代码通过|（数组并集）和select操作，最终返回的是普通Ruby Array对象，而Array类并没有find_each方法，因此触发报错。

解决方案 #

优先推荐用ActiveRecord查询语法重构，把筛选逻辑放到数据库层面执行，既保留find_each的优势，又提升性能（避免全量加载数据到内存）。

方案1：重构为ActiveRecord Relation（推荐）

将两个查询合并为一个，用OR条件组合，同时添加status筛选，返回的仍然是Relation，可继续使用find_each：

def future_orders
  # Rails 5+支持直接用.or合并查询（需确保两个查询的表、字段兼容）
  customer_branch.ogs
    .of_future
    .or(customer_branch.ogs.recurrence_children.of_future)
    .where(status: ["Done", "InProgress"])
end

def update_orders_instruction
  OrderGroup.transaction do
    future_orders.find_each do |og|
      next if og.is_manually_updated
      instruction = [og.customer_branch&.customer.instruction, customer_branch.instruction].compact.join("\n")
      og.delivery_order.update!(instruction: instruction)
    end
  end
end

如果.or语法因查询结构不兼容报错，可改用子查询方式：

def future_orders
  recurrence_ids = customer_branch.ogs.recurrence_children.of_future.select(:id)
  normal_ids = customer_branch.ogs.of_future.select(:id)

  customer_branch.ogs
    .where(id: recurrence_ids.or(normal_ids))
    .where(status: ["Done", "InProgress"])
end

方案2：改用数组遍历（适合小数据量）

如果因业务限制必须用数组处理，直接将find_each替换为each即可：

def update_orders_instruction
  OrderGroup.transaction do
    future_orders.each do |og|
      next if og.is_manually_updated
      instruction = [og.customer_branch&.customer.instruction, customer_branch.instruction].compact.join("\n")
      og.delivery_order.update!(instruction: instruction)
    end
  end
end

若数据量较大，可手动实现分批处理避免内存压力：

def update_orders_instruction
  future_orders.each_slice(100) do |batch| # 每100条为一批
    OrderGroup.transaction do
      batch.each do |og|
        next if og.is_manually_updated
        instruction = [og.customer_branch&.customer.instruction, customer_branch.instruction].compact.join("\n")
        og.delivery_order.update!(instruction: instruction)
      end
    end
  end
end

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