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

fasternomyreate
All checks were successful
Deploy on push / deploy (push) Successful in 7s
Details

Browse Source
This commit is contained in:
Untone 2024-11-18 22:24:54 +03:00
parent e9f9582110
commit 283ad80632
1 changed files with 11 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
resolvers/reader.py
View File

@ -145,8 +145,6 @@ def query_with_stat(info):
q = q.add_columns(authors_subquery.c.authors) q = q.add_columns(authors_subquery.c.authors)
if has_field(info, "stat"): if has_field(info, "stat"):
logger.info("Начало построения запроса статистики")
# Подзапрос для статистики реакций # Подзапрос для статистики реакций
stats_subquery = ( stats_subquery = (
select( select(
@ -169,46 +167,17 @@ def query_with_stat(info):
.group_by(Reaction.shout) .group_by(Reaction.shout)
.subquery() .subquery()
) )
logger.info("Подзапрос статистики построен") q = q.outerjoin(stats_subquery, stats_subquery.c.shout == Shout.id)
q = q.add_columns(
# Извлечение author_id из контекста json_builder(
logger.info(f"info.context: {info.context}") "comments_count",
author_dict = info.context.get("author") if info.context else None func.coalesce(stats_subquery.c.comments_count, 0),
author_id = author_dict.get("id") if author_dict else None "rating",
logger.info(f"Полученный author_id: {author_id}") func.coalesce(stats_subquery.c.rating, 0),
"last_reacted_at",
if author_id: None,
logger.info(f"Построение подзапроса реакций пользователя с ID: {author_id}") ).label("stat")
)
logger.info("Соединение основного запроса с подзапросом статистики")
q = q.outerjoin(stats_subquery, stats_subquery.c.shout == Shout.id)
logger.info("Добавление колонок статистики в основной запрос")
q = q.add_columns(
json_builder(
"comments_count",
func.coalesce(stats_subquery.c.comments_count, 0),
"rating",
func.coalesce(stats_subquery.c.rating, 0),
"last_reacted_at",
stats_subquery.c.last_reacted_at,
).label("stat")
)
logger.info("Колонки статистики добавлены")
else:
logger.info("Автор не найден, строим запрос без подзапроса реакций пользователя")
q = q.outerjoin(stats_subquery, stats_subquery.c.shout == Shout.id)
q = q.add_columns(
json_builder(
"comments_count",
func.coalesce(stats_subquery.c.comments_count, 0),
"rating",
func.coalesce(stats_subquery.c.rating, 0),
"last_reacted_at",
None,
).label("stat")
)
logger.info("Колонки статистики без my_rate добавлены")
return q return q