@@ -110,24 +110,40 @@ defmodule GroupherServer.CMS.Delegate.CommentCurd do
110110@ spec paged_comments_participants ( T . article_thread ( ) , Integer . t ( ) , T . paged_filter ( ) ) ::
111111{ :ok , T . paged_users ( ) }
112112def paged_comments_participants ( thread , article_id , filters ) do
113- % { page: page , size: size } = filters
113+ with { :ok , thread_query } <- match ( thread , :query , article_id ) ,
114+ { :ok , info } <- match ( thread ) ,
115+ { :ok , article } <- ORM . find ( info . model , article_id ) ,
116+ { :ok , paged_data } <- do_paged_comments_participants ( thread_query , filters ) do
117+ # check participants_count if history data do not match
118+ case article . comments_participants_count !== paged_data . total_count do
119+ true ->
120+ article |> ORM . update ( % { comments_participants_count: paged_data . total_count } )
121+
122+ false ->
123+ { :ok , :pass }
124+ end
114125
115- with { :ok , thread_query } <- match ( thread , :query , article_id ) do
116- Comment
117- |> where ( ^ thread_query )
118- |> QueryBuilder . filter_pack ( Map . merge ( filters , % { sort: :desc_inserted } ) )
119- |> join ( :inner , [ c ] , a in assoc ( c , :author ) )
120- |> distinct ( [ c , a ] , a . id )
121- # group_by
122- |> group_by ( [ c , a ] , a . id )
123- |> group_by ( [ c , a ] , c . inserted_at )
124- |> group_by ( [ c , a ] , c . id )
125- |> select ( [ c , a ] , a )
126- |> ORM . paginator ( ~m( page size) a )
127- |> done ( )
126+ paged_data |> done
128127end
129128end
130129
130+ defp do_paged_comments_participants ( query , filters ) do
131+ % { page: page , size: size } = filters
132+
133+ Comment
134+ |> where ( ^ query )
135+ |> QueryBuilder . filter_pack ( Map . merge ( filters , % { sort: :desc_inserted } ) )
136+ |> join ( :inner , [ c ] , a in assoc ( c , :author ) )
137+ |> distinct ( [ c , a ] , a . id )
138+ # group_by
139+ |> group_by ( [ c , a ] , a . id )
140+ |> group_by ( [ c , a ] , c . inserted_at )
141+ |> group_by ( [ c , a ] , c . id )
142+ |> select ( [ c , a ] , a )
143+ |> ORM . paginator ( ~m( page size) a )
144+ |> done ( )
145+ end
146+
131147@ doc """
132148 creates a comment for article like psot, job ...
133149 """
@@ -273,10 +289,10 @@ defmodule GroupherServer.CMS.Delegate.CommentCurd do
273289
274290# add participator to article-like(Post, Job ...) and update count
275291def add_participant_to_article ( % { comments_participants: participants } = article , % User { } = user ) do
276- total_participants = participants |> List . insert_at ( 0 , user ) |> Enum . uniq_by ( & & 1 . id )
292+ cur_participants = participants |> List . insert_at ( 0 , user ) |> Enum . uniq_by ( & & 1 . id )
277293
278- latest_participants = total_participants |> Enum . slice ( 0 , @ max_participator_count )
279- total_participants_count = length ( total_participants )
294+ latest_participants = cur_participants |> Enum . slice ( 0 , @ max_participator_count )
295+ total_participants_count = article . comments_participants_count + 1
280296
281297article
282298|> Ecto.Changeset . change ( )