Vereinfacht: filter blank vereinfacht_contact_id in sync_members
Include members with empty string; use expr with ref for Ash filter.
This commit is contained in:
parent
8ffd842c38
commit
daaa4dc345
1 changed files with 4 additions and 1 deletions
|
|
@ -8,6 +8,7 @@ defmodule Mv.Vereinfacht do
|
||||||
- `sync_members_without_contact/0` – Bulk sync of members without a contact ID.
|
- `sync_members_without_contact/0` – Bulk sync of members without a contact ID.
|
||||||
"""
|
"""
|
||||||
require Ash.Query
|
require Ash.Query
|
||||||
|
import Ash.Expr
|
||||||
alias Mv.Vereinfacht.Client
|
alias Mv.Vereinfacht.Client
|
||||||
alias Mv.Membership.Member
|
alias Mv.Membership.Member
|
||||||
alias Mv.Helpers.SystemActor
|
alias Mv.Helpers.SystemActor
|
||||||
|
|
@ -128,7 +129,9 @@ defmodule Mv.Vereinfacht do
|
||||||
|
|
||||||
query =
|
query =
|
||||||
Member
|
Member
|
||||||
|> Ash.Query.filter(is_nil(vereinfacht_contact_id))
|
|> Ash.Query.filter(
|
||||||
|
expr(is_nil(^ref(:vereinfacht_contact_id)) or ^ref(:vereinfacht_contact_id) == "")
|
||||||
|
)
|
||||||
|
|
||||||
case Ash.read(query, opts) do
|
case Ash.read(query, opts) do
|
||||||
{:ok, members} ->
|
{:ok, members} ->
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue