discours.io/core
5
0
Fork 0
Code Pull Requests Actions 1 Projects Activity

ratings-subquery-fix

Browse Source
This commit is contained in:
Untone 2024-02-25 13:43:12 +03:00
parent c216161ece
commit 8d47c02511
1 changed files with 15 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
resolvers/stat.py
View File

@ -70,58 +70,24 @@ def add_author_stat_columns(q):
def add_author_ratings(q): def add_author_ratings(q):
ratings_subquery = ( ratings_subquery = (
select( select([
[
Author.id, Author.id,
func.count() func.count().filter(and_(
.filter(
and_(
Reaction.created_by == Author.id, Reaction.created_by == Author.id,
Reaction.kind == ReactionKind.COMMENT.value, Reaction.kind == ReactionKind.COMMENT.value,
Reaction.deleted_at.is_(None), Reaction.deleted_at.is_(None),
) )).label('comments_count'),
) func.sum(case((AuthorRating.plus == true(), 1), else_=0)).label('likes_count'),
.label('comments_count'), func.sum(case((AuthorRating.plus != true(), 1), else_=0)).label('dislikes_count'),
func.sum(case([(AuthorRating.plus == true(), 1)], else_=0)).label( func.sum(case((and_(Reaction.kind == ReactionKind.LIKE.value, Shout.authors.any(id=Author.id)), 1), else_=0)).label('shouts_likes'),
'likes_count' func.sum(case((and_(Reaction.kind == ReactionKind.DISLIKE.value, Shout.authors.any(id=Author.id)), 1), else_=0)).label('shouts_dislikes')
), ])
func.sum(case([(AuthorRating.plus != true(), 1)], else_=0)).label(
'dislikes_count'
),
func.sum(
case(
[
(
and_(
Reaction.kind == ReactionKind.LIKE.value,
Shout.authors.any(id=Author.id),
),
1,
)
],
else_=0,
)
).label('shouts_likes'),
func.sum(
case(
[
(
and_(
Reaction.kind == ReactionKind.DISLIKE.value,
Shout.authors.any(id=Author.id),
),
1,
)
],
else_=0,
)
).label('shouts_dislikes'),
]
)
.select_from(Author) .select_from(Author)
.join(AuthorRating, AuthorRating.author == Author.id) .join(AuthorRating, AuthorRating.author == Author.id)
.outerjoin(Shout, Shout.authors.any(id=Author.id)) .outerjoin(Shout, Shout.authors.any(id=Author.id))
.filter(Reaction.deleted_at.is_(None)) .filter(
Reaction.deleted_at.is_(None)
)
.group_by(Author.id) .group_by(Author.id)
.alias('ratings_subquery') .alias('ratings_subquery')
) )