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

stat-fix
All checks were successful
Deploy to core / deploy (push) Successful in 3m59s
Details

Browse Source
This commit is contained in:
Untone 2024-02-23 14:34:43 +03:00
parent a55fa8d2ff
commit cc80c92ad3
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
resolvers/stat.py
View File

@ -13,11 +13,11 @@ def add_topic_stat_columns(q):
aliased_topic = aliased(Topic) aliased_topic = aliased(Topic)
q = ( q = (
q.outerjoin(ShoutTopic, aliased_topic.id == ShoutTopic.topic) q.outerjoin(ShoutTopic, aliased_topic.id == ShoutTopic.topic)
.add_columns(func.count(distinct(ShoutTopic.shout)).label('shouts_stat')) .with_entities(func.count(distinct(ShoutTopic.shout)).label('shouts_stat'))
.outerjoin(aliased_shout_authors, ShoutTopic.shout == aliased_shout_authors.shout) .outerjoin(aliased_shout_authors, ShoutTopic.shout == aliased_shout_authors.shout)
.add_columns(func.count(distinct(aliased_shout_authors.author)).label('authors_stat')) .with_entities(func.count(distinct(aliased_shout_authors.author)).label('authors_stat'))
.outerjoin(aliased_topic_followers, aliased_topic.id == aliased_topic_followers.topic) .outerjoin(aliased_topic_followers, aliased_topic.id == aliased_topic_followers.topic)
.add_columns(func.count(distinct(aliased_topic_followers.follower)).label('followers_stat')) .with_entities(func.count(distinct(aliased_topic_followers.follower)).label('followers_stat'))
) )
q = q.group_by(aliased_topic.id) q = q.group_by(aliased_topic.id)
@ -27,15 +27,15 @@ def add_topic_stat_columns(q):
def add_author_stat_columns(q): def add_author_stat_columns(q):
aliased_author_authors = aliased(AuthorFollower, name='af_authors') aliased_author_authors = aliased(AuthorFollower, name='af_authors')
aliased_author_followers = aliased(AuthorFollower, name='af_followers') # Добавлен второй псевдоним aliased_author_followers = aliased(AuthorFollower, name='af_followers')
aliased_author = aliased(Author) aliased_author = aliased(Author)
q = ( q = (
q.outerjoin(ShoutAuthor, aliased_author.id == ShoutAuthor.author) q.outerjoin(ShoutAuthor, aliased_author.id == ShoutAuthor.author)
.add_columns(func.count(distinct(ShoutAuthor.shout)).label('shouts_stat')) .with_entities(func.count(distinct(ShoutAuthor.shout)).label('shouts_stat'))
.outerjoin(aliased_author_authors, AuthorFollower.follower == aliased_author.id) .outerjoin(aliased_author_authors, AuthorFollower.follower == aliased_author.id)
.add_columns(func.count(distinct(aliased_author_authors.author)).label('authors_stat')) .with_entities(func.count(distinct(aliased_author_authors.author)).label('authors_stat'))
.outerjoin(aliased_author_followers, AuthorFollower.author == aliased_author.id) # Используется второй псевдоним .outerjoin(aliased_author_followers, AuthorFollower.author == aliased_author.id)
.add_columns(func.count(distinct(aliased_author_followers.follower)).label('followers_stat')) # Используется второй псевдоним .with_entities(func.count(distinct(aliased_author_followers.follower)).label('followers_stat'))
) )
q = q.group_by(aliased_author.id) q = q.group_by(aliased_author.id)
@ -46,13 +46,13 @@ def add_author_stat_columns(q):
def execute_with_ministat(q): def execute_with_ministat(q):
records = [] records = []
with local_session() as session: with local_session() as session:
for [entity, shouts_stat, authors_stat, followers_stat] in session.execute(q): for [r, shouts_stat, authors_stat, followers_stat] in session.execute(q):
entity.stat = { r.stat = {
'shouts': shouts_stat, 'shouts': shouts_stat,
'authors': authors_stat, 'authors': authors_stat,
'followers': followers_stat 'followers': followers_stat
} }
records.append(entity) records.append(r)
return records return records