更新与 cast_assoc 的关联

Question

我有两张桌子Users 和Companies。用户属于一个公司，一个公司有很多用户。

我有一个表单，我可以在其中将用户添加到公司，它被实现为嵌套表单 (inputs_for)，所以在公司的变更集中，我调用了 cast_assoc

def changeset(company, attrs) do
    company
    |> cast(attrs, [:name, :email])
    |> validate_required([:name, :email])
    |> cast_assoc(:users, with: &User.company_admin_changeset/2)
  end

我想要做的是，当我将已经存在的用户添加到公司时，它应该更新用户的 company_id(foreign_key)。如果用户不存在，只需创建一个。

看着我的要求，我开始认为不可能从 cast_assoc 中做到这一点。所以，我用了transaction

  def create_company(attrs \\ %{}) do
    Repo.transaction(fn ->
      cmp =
        Company.changeset(%Company{}, %{name: attrs["name"], email: attrs["email"]})
        |> Repo.insert!()

      Enum.each(attrs["users"], fn {_, user} ->
        case Accounts.get_user_by_email(user["email"]) do
          nil ->
            User.company_admin_changeset(%User{}, %{email: user["email"], company_id: cmp.id})
            |> Repo.insert!()

          account ->
            account |> Ecto.Changeset.change(company_id: cmp.id) |> Repo.update!()
        end
      end)
    end)
  end

但如果可能的话，你能告诉我该怎么做吗？

Answer 1

我使用了 upserts，但我必须根据用户是否存在来运行自定义方法，所以我仍在使用旧代码进行事务处理