feat(mailer): notify admin user for new content

Author: mydearxym

lib/groupher_server/cms/delegates/article_curd.ex

@@ -8,15 +8,14 @@ defmodule GroupherServer.CMS.Delegate.ArticleCURD do
   import Helper.ErrorCode
   import ShortMaps
 
-  alias GroupherServer.Repo
+  alias GroupherServer.{Accounts, CMS, Delivery, Email, Repo, Statistics}
 
-  alias GroupherServer.Accounts.User
-  alias GroupherServer.{CMS, Delivery, Statistics}
+  alias Accounts.User
+  alias CMS.{Author, Community, Delegate, Tag, Topic}
 
-  alias CMS.Delegate.ArticleOperation
-  alias Helper.{ORM, QueryBuilder}
+  alias Delegate.ArticleOperation
+  alias Helper.{Later, ORM, QueryBuilder}
 
-  alias CMS.{Author, Community, Tag, Topic}
   alias Ecto.Multi
 
   @doc """
@@ -398,7 +397,30 @@ defmodule GroupherServer.CMS.Delegate.ArticleCURD do
     end
   end
 
-  defp create_content_result({:ok, %{create_content: result}}), do: {:ok, result}
+  defp create_content_result({:ok, %{create_content: result}}) do
+    # Later.exec({__MODULE__, :nofify_admin_new_content, [result]})
+    nofify_admin_new_content(result)
+    {:ok, result}
+  end
+
+  def nofify_admin_new_content(%{id: id} = result) do
+    target = result.__struct__
+    preload = [:origial_community, author: :user]
+
+    with {:ok, content} <- ORM.find(target, id, preload: preload) do
+      info = %{
+        id: content.id,
+        title: content.title,
+        digest: content.digest,
+        author_name: content.author.user.nickname,
+        community_raw: content.origial_community.raw,
+        type:
+          result.__struct__ |> to_string |> String.split(".") |> List.last() |> String.downcase()
+      }
+
+      Email.notify_admin(info, :new_content)
+    end
+  end
 
   defp create_content_result({:error, :create_content, %Ecto.Changeset{} = result, _steps}) do
     {:error, result}

lib/groupher_server/mailer/email.ex

@@ -7,10 +7,11 @@ defmodule GroupherServer.Email do
   import Bamboo.Email
   import Helper.Utils, only: [get_config: 2]
 
-  alias GroupherServer.{Accounts, Billing, Email, Mailer}
+  alias GroupherServer.{Accounts, Billing, CMS, Email, Mailer}
 
   alias Accounts.User
   alias Billing.BillRecord
+  alias CMS.{Post, Job, Repo, Video}
   alias Email.Templates
   alias Mailer
 
@@ -86,15 +87,16 @@ defmodule GroupherServer.Email do
   end
 
   #  notify admin when new post has created
-  def notify_admin(:create, _post) do
+  def notify_admin(%{type: type, title: title} = info, :new_content) do
     case @conf_notify_admin_on_content_created do
       true ->
-        base_mail()
-        |> to(@admin_email)
-        |> subject("新帖子: ... ")
-        # |> html_body(Templates.NotifyAdminRegister.html(user))
-        # |> text_body(Templates.NotifyAdminRegister.text())
-        |> Mailer.deliver_later()
+        hello =
+          base_mail()
+          |> to(@admin_email)
+          |> subject("new #{type}: #{title}")
+          |> html_body(Templates.NotifyAdminOnContentCreated.html(info))
+          |> text_body(Templates.NotifyAdminRegister.text())
+          |> Mailer.deliver_later()
 
       false ->
         {:ok, :pass}