Merge branch 'billing' into dev

Author: mydearxym

config/config.exs

@@ -44,6 +44,8 @@ config :mastani_server, :general,
   publish_throttle_interval_minutes: 3,
   publish_throttle_hour_limit: 20,
   publish_throttle_day_limit: 30,
+  # membership
+  seninor_amount_threshold: 51.2,
   # user achievements
   user_achieve_star_weight: 1,
   user_achieve_watch_weight: 1,

lib/helper/certification.ex

@@ -34,6 +34,7 @@ defmodule Helper.Certification do
   def all_rules(:cms) do
     %{
       general: [
+        "system_accountant",
         "system_notification.publish",
         "stamp_passport",
         # community

lib/helper/error_code.ex

@@ -24,6 +24,9 @@ defmodule Helper.ErrorCode do
   def ecode(:update_fails), do: @default_base + 8
   def ecode(:delete_fails), do: @default_base + 9
   def ecode(:create_fails), do: @default_base + 10
+  def ecode(:exsit_pending_bill), do: @default_base + 11
+  def ecode(:bill_state), do: @default_base + 12
+  def ecode(:bill_action), do: @default_base + 13
   # throttle
   def ecode(:throttle_inverval), do: @throttle_base + 1
   def ecode(:throttle_hour), do: @throttle_base + 2

lib/helper/utils.ex

@@ -84,7 +84,7 @@ defmodule Helper.Utils do
   Recursivly camelize the map keys
   usage: convert factory attrs to used for simu Graphql parmas
   """
-  def camelize_map_key(map) do
+  def camelize_map_key(map, v_trans \\ :ignore) do
     map_list =
       Enum.map(map, fn {k, v} ->
         v =
@@ -95,6 +95,9 @@ defmodule Helper.Utils do
             is_map(v) ->
               camelize_map_key(safe_map(v))
 
+            is_binary(v) ->
+              handle_camelize_value_trans(v, v_trans)
+
             true ->
               v
           end
@@ -105,6 +108,10 @@ defmodule Helper.Utils do
     Enum.into(map_list, %{})
   end
 
+  defp handle_camelize_value_trans(v, :ignore), do: v
+  defp handle_camelize_value_trans(v, :downcase), do: String.downcase(v)
+  defp handle_camelize_value_trans(v, :upcase), do: String.upcase(v)
+
   defp safe_map(%{__struct__: _} = map), do: Map.from_struct(map)
   defp safe_map(map), do: map
 

lib/mastani_server/accounts/accounts.ex

@@ -3,7 +3,6 @@ defmodule MastaniServer.Accounts do
 
   alias MastaniServer.Accounts.Delegate.{
     Achievements,
-    Billing,
     Customization,
     Fans,
     FavoriteCategory,
@@ -61,15 +60,11 @@ defmodule MastaniServer.Accounts do
   defdelegate mark_mail_read_all(user, opt), to: Mails
   defdelegate mark_mail_read(mail, user), to: Mails
 
-  # purchase
-  defdelegate purchase_service(user, key, value), to: Billing
-  defdelegate purchase_service(user, key), to: Billing
-  defdelegate has_purchased?(user, key), to: Billing
-
   # customization
   defdelegate get_customization(user), to: Customization
   defdelegate set_customization(user, key, value), to: Customization
   defdelegate set_customization(user, options), to: Customization
+  defdelegate upgrade_by_plan(user, plan), to: Customization
 
   defdelegate search_users(args), to: Search
 end

lib/mastani_server/accounts/achievement.ex

@@ -4,10 +4,11 @@ defmodule MastaniServer.Accounts.Achievement do
 
   use Ecto.Schema
   import Ecto.Changeset
+
   alias MastaniServer.Accounts.{User, SourceContribute}
 
   @required_fields ~w(user_id)a
-  @optional_fields ~w(contents_stared_count contents_favorited_count contents_watched_count followers_count reputation)a
+  @optional_fields ~w(contents_stared_count contents_favorited_count contents_watched_count followers_count reputation donate_member seninor_member sponsor_member)a
 
   @type t :: %Achievement{}
   schema "user_achievements" do
@@ -21,6 +22,10 @@ defmodule MastaniServer.Accounts.Achievement do
     # source_contribute
     embeds_one(:source_contribute, SourceContribute, on_replace: :delete)
 
+    field(:donate_member, :boolean)
+    field(:seninor_member, :boolean)
+    field(:sponsor_member, :boolean)
+
     timestamps(type: :utc_datetime)
   end
 

lib/mastani_server/accounts/delegates/achievements.ex

@@ -99,14 +99,16 @@ defmodule MastaniServer.Accounts.Delegate.Achievements do
     end
   end
 
-  # def achieve(%User{} = _user, :+, :watch) do
-  # end
-
-  # def achieve(%User{} = _user, :+, key) do
-  # end
+  def set_member(%User{} = user, :donate), do: do_set_member(user, %{donate_member: true})
+  def set_member(%User{} = user, :seninor), do: do_set_member(user, %{seninor_member: true})
+  def set_member(%User{} = user, :sponsor), do: do_set_member(user, %{sponsor_member: true})
+  def set_member(_user, _plan), do: {:error, "no such plan"}
 
-  # def achieve(%User{} = _user, :-, _key) do
-  # end
+  def do_set_member(%User{id: user_id}, attrs) do
+    with {:ok, achievement} <- ORM.findby_or_insert(Achievement, ~m(user_id)a, ~m(user_id)a) do
+      achievement |> ORM.update(attrs)
+    end
+  end
 
   @doc """
   only used for user delete the farorited category, other case is auto

lib/mastani_server/accounts/delegates/billing.ex

@@ -7,10 +7,28 @@ defmodule MastaniServer.Accounts.Delegate.Customization do
 
   alias Helper.ORM
   alias MastaniServer.Accounts
-  alias MastaniServer.Accounts.{User, Customization}
+
+  alias Accounts.{User, Customization}
+  alias Accounts.Delegate.Achievements
 
   @default_customization get_config(:customization, :all) |> Enum.into(%{})
 
+  def upgrade_by_plan(%User{} = user, :donate) do
+    Achievements.set_member(user, :donate)
+  end
+
+  def upgrade_by_plan(%User{} = user, :seninor) do
+    Achievements.set_member(user, :seninor)
+  end
+
+  def upgrade_by_plan(%User{} = user, :sponsor) do
+    Achievements.set_member(user, :sponsor)
+  end
+
+  def upgrade_by_plan(%User{} = _user, plan) do
+    {:error, "no such plan"}
+  end
+
   @doc """
   get user's customization, if not have, return default customization
   """
@@ -30,80 +48,63 @@ defmodule MastaniServer.Accounts.Delegate.Customization do
   """
   # for map_size
   # see https://stackoverflow.com/questions/33248816/pattern-match-function-against-empty-map
+
   def set_customization(%User{} = _user, map) when map_size(map) == 0 do
-    {:error, "AccountCustomization: invalid option or not purchased"}
+    {:error, "AccountCustomization: invalid option or not member"}
   end
 
-  def set_customization(%User{} = user, map) when is_map(map) do
-    map = map |> map_atom_value(:string)
+  def set_customization(%User{id: user_id} = user, map) when is_map(map) do
+    with {:ok, %{achievement: achievement}} <- ORM.find(User, user_id, preload: :achievement) do
+      map = map |> map_atom_value(:string)
 
-    valid? =
-      map
-      |> Map.keys()
-      |> Enum.all?(&can_set?(user, &1, :boolean))
+      valid? =
+        map
+        |> Map.keys()
+        |> Enum.all?(&c11n_item_require?(&1, achievement))
 
-    case valid? do
-      true ->
-        attrs = Map.merge(%{user_id: user.id}, map)
-        Customization |> ORM.upsert_by([user_id: user.id], attrs)
+      case valid? do
+        true ->
+          attrs = Map.merge(%{user_id: user.id}, map)
+          Customization |> ORM.upsert_by([user_id: user.id], attrs)
 
-      false ->
-        {:error, "AccountCustomization: invalid option or not purchased"}
+        false ->
+          {:error, "AccountCustomization: invalid option or not member"}
+      end
     end
   end
 
   def set_customization(%User{} = user, key, value \\ true) do
-    with {:ok, key} <- can_set?(user, key) do
-      attrs = Map.put(%{user_id: user.id}, key, value)
-      Customization |> ORM.upsert_by([user_id: user.id], attrs)
+    with {:ok, %{achievement: achievement}} <- ORM.find(User, user.id, preload: :achievement) do
+      case c11n_item_require?(key, achievement) do
+        true ->
+          attrs = Map.put(%{user_id: user.id}, key, value)
+          Customization |> ORM.upsert_by([user_id: user.id], attrs)
+
+        false ->
+          {:error, "AccountCustomization: invalid option or not member"}
+      end
     end
   end
 
-  defp can_set?(%User{} = user, key, :boolean) do
-    case can_set?(%User{} = user, key) do
-      {:ok, _} -> true
-      {:error, _} -> false
-    end
+  defp c11n_item_require?(:theme, %{
+         donate_member: donate_member,
+         seninor_member: seninor_member,
+         sponsor_member: sponsor_member
+       }) do
+    donate_member or seninor_member or sponsor_member
   end
 
-  def can_set?(%User{} = user, key) do
-    cond do
-      key in valid_custom_items(:free) ->
-        {:ok, key}
-
-      key in valid_custom_items(:advance) ->
-        Accounts.has_purchased?(user, key)
-
-      true ->
-        {:error, "AccountCustomization: invalid option"}
-    end
-  end
-
-  @doc """
-  # theme           --  user can set a default theme
-  # sidebar_layout  --  user can arrange subscribed community index
-  """
-  def valid_custom_items(:free) do
-    [
-      :sidebar_layout,
-      :sidebar_communities_index,
-      :banner_layout,
-      :contents_layout,
-      :content_divider,
-      :mark_viewed,
-      :display_density
-    ]
-  end
-
-  @doc """
-  # :brainwash_free    --  ads free
-  # ::community_chart  --  user can access comunity charts
-  """
-  def valid_custom_items(:advance) do
-    # NOTE: :brainwash_free aka. "ads_free"
-    # use brainwash to avoid brower-block-plugins
-    [:theme, :brainwash_free, :community_chart]
-  end
+  defp c11n_item_require?(:banner_layout, _), do: true
+  defp c11n_item_require?(:contents_layout, _), do: true
+  defp c11n_item_require?(:content_divider, _), do: true
+  defp c11n_item_require?(:mark_viewed, _), do: true
+  defp c11n_item_require?(:display_density, _), do: true
+  defp c11n_item_require?(:sidebar_layout, _), do: true
+  defp c11n_item_require?(:sidebar_communities_index, _), do: true
+  # defp c11n_item_require?(:brainwash_free, _), do: true
+  # defp c11n_item_require?(:community_chart, _), do: true
+
+  defp c11n_item_require?(_, _), do: false
 
   defp filter_nil_value(map) do
     for {k, v} <- map, !is_nil(v), into: %{}, do: {k, v}

lib/mastani_server/accounts/delegates/customization.ex

@@ -0,0 +1,44 @@
+defmodule MastaniServer.Billing.BillRecord do
+  @moduledoc """
+  bill records for investors
+  """
+  alias __MODULE__
+
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  alias MastaniServer.Accounts
+
+  @required_fields ~w(user_id hash_id state amount payment_usage payment_method)a
+  @optional_fields ~w(note)a
+
+  schema "bill_records" do
+    belongs_to(:user, Accounts.User, foreign_key: :user_id)
+
+    field(:state, :string)
+    field(:amount, :float)
+
+    field(:hash_id, :string)
+    field(:payment_usage, :string)
+    field(:payment_method, :string)
+
+    field(:note, :string)
+
+    timestamps(type: :utc_datetime)
+  end
+
+  def changeset(%BillRecord{} = bill_record, attrs) do
+    bill_record
+    # |> cast(attrs, @optional_fields ++ @required_fields)
+    |> cast(attrs, @required_fields ++ @optional_fields)
+    |> validate_required(@required_fields)
+    # |> validate_length(:title, min: 1, max: 30)
+    |> foreign_key_constraint(:user_id)
+  end
+
+  def state_changeset(bill_record, attrs) do
+    bill_record
+    |> cast(attrs, [:state])
+    |> validate_required([:state])
+  end
+end