Ruby on Rails 5.1电商站：后台任务后自动删除Session下架产品ID？

这个需求在电商场景里非常合理——总不能让用户对比已经下架的产品对吧？咱们可以用几种方式来处理，这里给你推荐最实用的方案：

1. 每次读取对比数据时自动过滤（最推荐） #

这是最简单也最实时的方式，不用依赖定时任务或者复杂的回调。你可以在控制器或者Helper里封装一个方法，每次获取对比产品的时候，自动清理Session里的无效ID：

# 可以放在ApplicationHelper或者对应的控制器里
def valid_compare_products
  # 先从Session里取出存储的产品ID数组，默认是空数组
  product_ids = session[:compare_product_ids] || []
  
  # 从数据库筛选出其中还在架的产品ID
  valid_ids = Product.where(id: product_ids, active: true).pluck(:id)
  
  # 更新Session，把无效的ID直接移除
  session[:compare_product_ids] = valid_ids
  
  # 返回最终有效的产品集合
  Product.where(id: valid_ids)
end

之后你在视图或者控制器里需要用到对比产品时，直接调用valid_compare_products就行。这样每次用户访问对比页面、查看对比数据的时候，Session都会被自动清理，保证用户看到的都是上架产品，同时Session里也不会积累无效ID。

2. 定时清理（适合服务器端存储Session的场景） #

如果你的Session是存在服务器端（比如Redis、数据库），而且担心长期积累无效ID占用空间，可以写一个定时任务定期清理所有用户的Session：

# app/jobs/clean_invalid_compare_products_job.rb
class CleanInvalidCompareProductsJob < ApplicationJob
  queue_as :default

  def perform
    # 这里以数据库存储Session为例（假设你的Session存在sessions表）
    Session.find_each do |session|
      session_data = JSON.parse(session.data)
      next unless session_data["compare_product_ids"].present?
      
      # 筛选有效ID并更新Session数据
      valid_ids = Product.where(id: session_data["compare_product_ids"], active: true).pluck(:id)
      session_data["compare_product_ids"] = valid_ids
      session.update(data: session_data.to_json)
    end
  end
end

然后用whenever gem或者Rails 7+的内置定时任务，定期执行这个Job（比如每天凌晨跑一次）。不过要注意：如果你的Session是存在用户Cookie里的，服务器端没法直接修改，这种方法就不适用了。

3. 产品下架时实时清理（慎用） #

如果想在产品下架的瞬间，就把所有用户Session里的这个ID移除，可以在Product模型里加一个回调：

class Product < ApplicationRecord
  # 当产品从上架变为下架时触发
  after_update :remove_from_compare_sessions, if: -> { saved_change_to_active? && !active }

  private

  def remove_from_compare_sessions
    # 同样只适用于服务器端存储的Session
    return unless Session.table_exists?
    
    Session.find_each do |session|
      session_data = JSON.parse(session.data)
      next unless session_data["compare_product_ids"]&.include?(id)
      
      session_data["compare_product_ids"].delete(id)
      session.update(data: session_data.to_json)
    end
  end
end

注意：这个方法在用户量很大的时候会非常影响性能，因为要遍历所有Session。除非你的产品下架频率极低，否则不推荐用这种方式。

总的来说，第一种方法是性价比最高的——实现简单、实时生效，不管你的Session存在哪里都能正常工作，用户体验也最好。

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