跨多个Campaign统计产品数量及产品分配Campaign时校验问题咨询

嘿，针对你的两个需求，我整理了实用的Ruby on Rails实现方案，分两部分来说明：

一、跨多个Campaign统计产品数量（按Project维度） #

既然你的层级是「Project → 多个Campaign → 多个Product」，核心就是按Project聚合它下面所有Campaign的产品数，这里给两种常用方式：

1. 直接关联查询（高效首选） #

用ActiveRecord的链式查询直接生成SQL，性能拉满，适合大数据量场景：

# 统计单个Project的总产品数
project = Project.find(params[:project_id])
total_products = project.campaigns.joins(:products).count

# 按Project分组，统计所有项目的产品数
Project.joins(campaigns: :products)
       .group('projects.id')
       .select('projects.id, projects.name, COUNT(products.id) as total_products')

这种方式不需要额外维护字段，直接从数据库实时取数，靠谱省心。

2. 缓存统计值（适合频繁查询） #

如果你的系统经常要查这个统计数，可以给Project加个缓存字段，用回调自动更新：

# 先执行迁移：add_column :projects, :total_products, :integer, default: 0

class Product < ActiveRecord::Base
  belongs_to :campaign

  after_create :refresh_project_product_count
  after_destroy :refresh_project_product_count

  private

  def refresh_project_product_count
    project = campaign.project
    project.update(total_products: project.campaigns.joins(:products).count)
  end
end

这样每次增删产品时，自动更新对应Project的统计值，查询时直接project.total_products就能拿到，不过批量操作产品时要注意额外处理哦。

二、分配产品给Campaign时的校验实现 #

分配产品的校验得看具体业务规则，我先举几个常见场景，再给对应的实现方案：

常见校验场景参考 #

• 同一个产品不能被分配到同一Project下的多个Campaign（避免重复）
• 某个Project下的产品总数不能超过预设上限
• 产品已经被分配到其他Campaign，不允许重复分配

具体实现方案： #

1. 模型回调（简单场景首选）

如果校验逻辑不复杂，直接在Product模型里加回调就行，代码少易维护：

class Product < ActiveRecord::Base
  belongs_to :campaign

  before_save :validate_product_assignment

  private

  def validate_product_assignment
    # 校验1：产品是否已在当前Project的其他Campaign中
    has_duplicate = Product.joins(campaign: :project)
                           .where(projects: { id: campaign.project_id })
                           .where.not(campaigns: { id: campaign.id })
                           .where(id: self.id)
                           .exists?
    if has_duplicate
      errors.add(:base, "该产品已经分配到当前项目的其他活动啦")
      throw :abort # 阻止保存操作
    end

    # 校验2：当前Project的产品总数是否超限（假设Project有max_products字段）
    current_total = campaign.project.campaigns.joins(:products).count
    if current_total >= campaign.project.max_products
      errors.add(:base, "当前项目的产品数量已经达到上限了哦")
      throw :abort
    end
  end
end

当你执行product.update(campaign_id: new_campaign_id)时，会自动触发这些校验，失败时错误信息会存在product.errors里，直接返回给UI就行。

2. 服务对象（复杂场景推荐）

如果校验逻辑复杂，或者还要做其他操作（比如日志、通知），用服务对象封装更清晰，让模型保持单一职责：

# app/services/product_assignment_service.rb
class ProductAssignmentService
  def initialize(product, target_campaign)
    @product = product
    @campaign = target_campaign
    @errors = []
  end

  def assign
    return false unless valid?

    # 用事务保证操作原子性
    ActiveRecord::Base.transaction do
      @product.update!(campaign: @campaign)
      # 这里还可以加其他操作，比如记录日志、发送通知
    end
    true
  end

  attr_reader :errors

  private

  def valid?
    # 检查产品是否已在当前Project的其他Campaign
    if Product.joins(campaign: :project)
              .where(projects: { id: @campaign.project_id })
              .where.not(campaigns: { id: @campaign.id })
              .where(id: @product.id)
              .exists?
      @errors << "该产品已分配到当前项目的其他活动"
    end

    # 检查Project产品数量上限
    current_total = @campaign.project.campaigns.joins(:products).count
    if current_total >= @campaign.project.max_products
      @errors << "当前项目产品数量已达上限"
    end

    @errors.empty?
  end
end

使用的时候就像这样：

service = ProductAssignmentService.new(product, target_campaign)
if service.assign
  # 分配成功，返回成功响应
else
  # 处理错误，比如把service.errors返回给UI
end

这种方式代码更易扩展，后期改逻辑也方便。

3. 数据库约束（兜底保障）

为了防止并发场景下的校验失效（比如两个请求同时分配同一个产品），最好加上数据库层面的约束，比如如果不允许产品重复分配到同一个Project的Campaign，可以加唯一索引：

-- PostgreSQL示例：创建函数索引，确保同一个产品在同一个Project下只能存在一次
CREATE UNIQUE INDEX idx_product_unique_per_project 
ON products ((SELECT project_id FROM campaigns WHERE id = products.campaign_id), products.id);

不同数据库语法可能略有不同，这样即使代码层面的校验漏了，数据库也会直接拒绝非法插入，给数据安全加个双保险。

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