local-it/mitgliederverwaltung
2
3
Fork 0
Code Issues 72 Pull requests 5 Projects 4 Releases Packages 1 Activity Actions

Cycle Management & Member Integration closes #279 #294

Merged
moritz merged 22 commits from feature/279_cycle_management into main 2025-12-18 15:01:58 +01:00
Conversation 0 Commits 22 Files changed 12 +10 -20
1 changed files with 10 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 69c9746974 - Show all commits

30
lib/membership/member.ex
View file

@ -191,33 +191,23 @@ defmodule Mv.Membership.Member do
# Trigger cycle regeneration when membership_fee_type_id changes # Trigger cycle regeneration when membership_fee_type_id changes
# This deletes future unpaid cycles and regenerates them with the new type/amount # This deletes future unpaid cycles and regenerates them with the new type/amount
# Note: Cycle regeneration runs asynchronously to not block the action, # Note: Cycle regeneration runs synchronously in the same transaction to ensure atomicity
# but in test environment it runs synchronously for DB sandbox compatibility # CycleGenerator uses advisory locks and transactions internally to prevent race conditions
change after_action(fn changeset, member, _context -> change after_action(fn changeset, member, _context ->
fee_type_changed = fee_type_changed =
Ash.Changeset.changing_attribute?(changeset, :membership_fee_type_id) Ash.Changeset.changing_attribute?(changeset, :membership_fee_type_id)
if fee_type_changed && member.membership_fee_type_id && member.join_date do if fee_type_changed && member.membership_fee_type_id && member.join_date do
regenerate_fn = fn -> case regenerate_cycles_on_type_change(member) do
case regenerate_cycles_on_type_change(member) do :ok ->
:ok -> :ok
:ok
{:error, reason} -> {:error, reason} ->
require Logger require Logger
Logger.warning( Logger.warning(
"Failed to regenerate cycles for member #{member.id}: #{inspect(reason)}" "Failed to regenerate cycles for member #{member.id}: #{inspect(reason)}"
) )
end
end
if Application.get_env(:mv, :sql_sandbox, false) do
# Run synchronously in test environment for DB sandbox compatibility
regenerate_fn.()
else
# Run asynchronously in other environments
Task.start(regenerate_fn)
end end
end end