src.db.utils.reports

 1"""Функционал для работы с БД. Отчеты и обращения"""
 2
 3import logging
 4
 5from sqlalchemy import insert
 6
 7from core.metric import async_speed_metric
 8from db.database import execute_query
 9from db.models import Reports
10
11logger = logging.getLogger()
12
13
14@async_speed_metric
15async def add_report(report: dict):
16    """Добавляет новый отчет в базу данных.
17
18    Эта функция принимает словарь, представляющий отчет, и добавляет его в таблицу Reports.
19    Возвращает добавленный отчет или None, если добавление не удалось.
20
21    Args:
22        report (dict): Словарь, содержащий информацию об отчете, который нужно добавить.
23
24    Returns:
25        Reports: Добавленный отчет, если он успешно добавлен, иначе None.
26    """
27    query = insert(Reports).values(report).returning(Reports)
28    result: Reports = (await execute_query(query)).scalar_one_or_none()
29    return result