src/utils/data_processor.py - main - Hetvild/Bitrix24-Report-Bot

src/utils/data_processor.py
79 строк3 KB
bil
init
28 янв 2026, 08:08
28 янв 2026, 08:08b32e627
from utils.filter_data import processing_status_task


async def build_final_json(
    res_open_tasks_with_deadline_week: list,
    res_open_tasks_with_deadline_month: list,
    res_open_tasks_with_deadline_year: list,
    res_open_tasks_without_deadline: list,
) -> dict:
    """
    Формирует итоговый JSON с отфильтрованными задачами и мета-информацией

    Args:
        res_open_tasks_with_deadline_week: Список задач с deadline на неделю
        res_open_tasks_with_deadline_month: Список задач с deadline на месяц
        res_open_tasks_with_deadline_year: Список задач с deadline на год
        res_open_tasks_without_deadline: Список задач без deadline

    Returns:
        {
        "weekly": [...],
        "monthly": [...],
        "yearly": [...],
        "unprocessed": [...],
        }
    """

    # Собираем список week через список
    weekly = [
        {
            "task": week["title"],
            "status": await processing_status_task(week.get("status")),
            "deadline": week["deadline"][:10],
        }
        for week in res_open_tasks_with_deadline_week
        if isinstance(week, dict)
    ]

    # Собираем список month через список
    monthly = [
        {
            "task": month["title"],
            "status": await processing_status_task(month.get("status")),
            "deadline": month["deadline"][:10],
        }
        for month in res_open_tasks_with_deadline_month
        if isinstance(month, dict)
    ]

    # Собираем список year
    yearly = [
        {
            "task": year["title"],
            "status": await processing_status_task(year.get("status")),
            "deadline": year["deadline"][:10],
        }
        for year in res_open_tasks_with_deadline_year
        if isinstance(year, dict)
    ]

    # Собираем список необработанных задача
    unprocessed_tasks = [
        {
            "task": unprocessed["title"],
            "status": await processing_status_task(unprocessed.get("status")),
            "deadline": "Дата не указана",
        }
        for unprocessed in res_open_tasks_without_deadline
        if isinstance(unprocessed, dict)
    ]

    data_json = {
        "weekly": weekly or [],
        "monthly": monthly or [],
        "yearly": yearly or [],
        "unprocessed": unprocessed_tasks or [],
    }

    return data_json