kmx git

defmodule Kmxcrm.OrganisationManager do

  import Ecto.Query, warn: false

  alias Kmxcrm.IndexParams
  alias Kmxcrm.OrganisationManager.Contact
  alias Kmxcrm.OrganisationManager.Organisation
  alias Kmxcrm.Pagination
  alias Kmxcrm.Repo
  alias Kmxcrm.UserManager

  @preload [:contacts, :users]

  def list_organisations(params \\ %IndexParams{}) do
    from(org in Organisation)
    |> search(params)
    |> index_order_by(params)
    |> Pagination.page(params, preload: [])
  end

  def search(query, %IndexParams{search: search}) do
    expr = "%#{search}%"
    query
    |> where([org], ilike(org.name, ^expr) or ilike(org.slug, ^expr))
  end

  def index_order_by(query, %{column: "id", reverse: true}) do
    order_by(query, [desc: :id])
  end
  def index_order_by(query, %{column: "id"}) do
    order_by(query, :id)
  end
  def index_order_by(query, %{column: "name", reverse: true}) do
    order_by(query, [org], [desc_nulls_last: fragment("lower(?)", org.name)])
  end
  def index_order_by(query, %{column: "name"}) do
    order_by(query, [org], [asc_nulls_last: fragment("lower(?)", org.name)])
  end
  def index_order_by(query, %{column: "slug", reverse: true}) do
    order_by(query, [org], [desc_nulls_last: fragment("lower(?)", org.slug)])
  end
  def index_order_by(query, %{column: "slug"}) do
    order_by(query, [org], [asc_nulls_last: fragment("lower(?)", org.slug)])
  end

  def count_organisations do
    Repo.one from org in Organisation, select: count()
  end

  def get_organisation(id) do
    Repo.one from organisation in Organisation,
      where: [id: ^id],
      preload: ^@preload,
      limit: 1
  end

  def get_organisation!(id) do
    get_organisation(id) || raise Ecto.NoResultsError
  end

  def change_organisation(organisation \\ %Organisation{}) do
    Organisation.changeset(organisation, %{})
  end

  def create_organisation(user, attrs \\ %{}) do
    %Organisation{}
    |> Organisation.changeset(attrs)
    |> Ecto.Changeset.put_assoc(:users, [user])
    |> Repo.insert()
  end

  def update_organisation(organisation, attrs \\ %{}) do
    organisation
    |> Organisation.changeset(attrs)
    |> Repo.update()
  end

  def get_organisation_by_slug(slug) do
    Repo.one from o in Organisation,
      where: fragment("lower(?)", o.slug) == ^String.downcase(slug),
      preload: ^@preload,
      limit: 1
  end

  def add_user(%Organisation{} = org, login) do
    user = UserManager.get_user_by_login(login)
    if user do
      users = [user | org.users]
      org
      |> Organisation.changeset(%{})
      |> Ecto.Changeset.put_assoc(:users, users)
      |> Repo.update()
    else
      {:error, :not_found}
    end
  end

  def remove_user(%Organisation{} = org, login) do
    user = UserManager.get_user_by_login(login)
    if user do
      users = Enum.reject(org.users, &(&1.id == user.id))
      org
      |> Organisation.changeset(%{})
      |> Ecto.Changeset.put_assoc(:users, users)
      |> Repo.update()
    else
      {:error, :not_found}
    end
  end

  def delete_organisation(%Organisation{} = organisation) do
    organisation
    |> Organisation.changeset(%{})
    |> Repo.delete()
  end

  def admin_create_organisation(attrs \\ %{}) do
    %Organisation{}
    |> Organisation.changeset(attrs)
    |> Repo.insert()
  end

  # contacts

  def change_contact(contact \\ %Contact{}, params \\ %{}) do
    contact
    |> Contact.changeset(params)
  end

  def create_contact(org = %Organisation{}, attrs \\ %{}) do
    %Contact{}
    |> Contact.changeset(attrs)
    |> Ecto.Changeset.put_assoc(:organisation, org)
    |> Repo.insert()
  end

  def get_contact(org = %Organisation{}, id) do
    Repo.one from c in Contact,
      where: c.id == ^id and c.organisation_id == ^org.id,
      limit: 1
  end

  def update_contact(contact = %Contact{}, attrs \\ %{}) do
    contact
    |> Contact.changeset(attrs)
    |> Repo.update()
  end
end
kmx.io/kmxcrm/lib/kmxcrm/organisation_manager.ex

Commit

lib/kmxcrm/organisation_manager.ex
