ch

python_parser/adapters/parsers/monitoring_fuel.py

@@ -5,7 +5,7 @@ import logging
 from typing import Dict, Tuple
 from core.ports import ParserPort
 from core.schema_utils import register_getter_from_schema, validate_params_with_schema
-from app.schemas.monitoring_fuel import MonitoringFuelTotalRequest, MonitoringFuelMonthRequest
+from app.schemas.monitoring_fuel import MonitoringFuelTotalRequest, MonitoringFuelMonthRequest, MonitoringFuelSeriesRequest
 from adapters.pconfig import data_to_json
 
 # Настройка логгера для модуля
@@ -35,6 +35,14 @@ class MonitoringFuelParser(ParserPort):
             schema_class=MonitoringFuelMonthRequest,
             description="Получение данных за конкретный месяц"
         )
+        
+        register_getter_from_schema(
+            parser_instance=self,
+            getter_name="series_by_id_and_columns",
+            method=self._get_series_by_id_and_columns,
+            schema_class=MonitoringFuelSeriesRequest,
+            description="Получение временного ряда по ID и колонкам"
+        )
 
     def _get_total_by_columns(self, params: dict):
         """Агрегация данных по колонкам"""
@@ -102,6 +110,62 @@ class MonitoringFuelParser(ParserPort):
         
         return result
 
+    def _get_series_by_id_and_columns(self, params: dict):
+        """Получение временных рядов по колонкам для всех ID"""
+        # Валидируем параметры с помощью схемы Pydantic
+        validated_params = validate_params_with_schema(params, MonitoringFuelSeriesRequest)
+        
+        columns = validated_params["columns"]
+        
+        # Проверяем, есть ли данные в data_dict (из парсинга) или в df (из загрузки)
+        if hasattr(self, 'data_dict') and self.data_dict is not None:
+            # Данные из парсинга
+            data_source = self.data_dict
+        elif hasattr(self, 'df') and self.df is not None and not self.df.empty:
+            # Данные из загрузки - преобразуем DataFrame обратно в словарь
+            data_source = self._df_to_data_dict()
+        else:
+            return {}
+        
+        # Проверяем, что все колонки существуют хотя бы в одном месяце
+        valid_columns = set()
+        for month_df in data_source.values():
+            valid_columns.update(month_df.columns)
+        
+        for col in columns:
+            if col not in valid_columns:
+                raise ValueError(f"Колонка '{col}' не найдена ни в одном месяце")
+        
+        # Подготавливаем результат: словарь id → {col: [значения по месяцам]}
+        result = {}
+        
+        # Обрабатываем месяцы от 01 до 12
+        for month_key in [f"{i:02d}" for i in range(1, 13)]:
+            if month_key not in data_source:
+                logger.warning(f"Месяц '{month_key}' не найден в df_monitorings, пропускаем.")
+                continue
+            
+            df = data_source[month_key]
+            
+            for col in columns:
+                if col not in df.columns:
+                    continue  # Пропускаем, если в этом месяце нет колонки
+                
+                for idx, value in df[col].items():
+                    if pd.isna(value):
+                        continue  # Пропускаем NaN
+                    
+                    if idx not in result:
+                        result[idx] = {c: [] for c in columns}
+                    
+                    # Добавляем значение в массив для данного ID и колонки
+                    if not pd.isna(value) and value != float('inf') and value != float('-inf'):
+                        result[idx][col].append(float(value) if isinstance(value, (int, float)) else value)
+        
+        # Преобразуем ключи id в строки (для JSON-совместимости)
+        result_str_keys = {str(k): v for k, v in result.items()}
+        return result_str_keys
+
     def _df_to_data_dict(self):
         """Преобразование DataFrame обратно в словарь данных"""
         if not hasattr(self, 'df') or self.df is None or self.df.empty:

python_parser/app/main.py

@@ -28,7 +28,7 @@ from app.schemas import (
     UploadResponse, UploadErrorResponse,
     SvodkaPMTotalOGsRequest, SvodkaPMSingleOGRequest,
     SvodkaCARequest,
-    MonitoringFuelMonthRequest, MonitoringFuelTotalRequest
+    MonitoringFuelMonthRequest, MonitoringFuelTotalRequest, MonitoringFuelSeriesRequest
 )
 from app.schemas.oper_spravka_tech_pos import OperSpravkaTechPosRequest, OperSpravkaTechPosResponse
 from app.schemas.svodka_repair_ca import SvodkaRepairCARequest
@@ -933,40 +933,6 @@ async def get_statuses_repair_ca_data(
 #         raise HTTPException(status_code=500, detail=f"Внутренняя ошибка сервера: {str(e)}")
 
 
-@app.post("/monitoring_fuel/get_data", tags=[MonitoringFuelParser.name])
-async def get_monitoring_fuel_data(
-    request_data: dict
-):
-    report_service = get_report_service()
-    """
-    Получение данных из отчета мониторинга топлива
-
-    - column: Название колонки для агрегации (normativ, total, total_svod)
-    """
-    try:
-        # Создаем запрос
-        request = DataRequest(
-            report_type='monitoring_fuel',
-            get_params=request_data
-        )
-
-        # Получаем данные
-        result = report_service.get_data(request)
-
-        if result.success:
-            return {
-                "success": True,
-                "data": result.data
-            }
-        else:
-            raise HTTPException(status_code=404, detail=result.message)
-
-    except HTTPException:
-        raise
-    except Exception as e:
-        raise HTTPException(status_code=500, detail=f"Внутренняя ошибка сервера: {str(e)}")
-
-
 # @app.post("/monitoring_fuel/upload_directory", tags=[MonitoringFuelParser.name])
 # async def upload_monitoring_fuel_directory(
 #     request_data: dict
@@ -1195,6 +1161,66 @@ async def get_monitoring_fuel_month_by_code(
         raise HTTPException(status_code=500, detail=f"Внутренняя ошибка сервера: {str(e)}")
 
 
+@app.post("/monitoring_fuel/get_series_by_id_and_columns", tags=[MonitoringFuelParser.name],
+          summary="Получение временных рядов по колонкам для всех ID")
+async def get_monitoring_fuel_series_by_id_and_columns(
+    request_data: MonitoringFuelSeriesRequest
+):
+    """Получение временных рядов данных из сводок мониторинга топлива по колонкам для всех ID
+
+    ### Структура параметров:
+    - `columns`: **Массив названий** выбираемых столбцов (обязательный)
+
+    ### Пример тела запроса:
+    ```json
+    {
+        "columns": ["total", "normativ"]
+    }
+    ```
+    
+    ### Возвращаемые данные:
+    Временные ряды в формате массивов по месяцам:
+    ```json
+    {
+        "SNPZ.VISB": {
+            "total": [23.86, 26.51, 19.66, 25.46, 24.85, 22.38, 21.48, 23.5],
+            "normativ": [19.46, 19.45, 18.57, 18.57, 18.56, 18.57, 18.57, 18.57]
+        },
+        "SNPZ.IZOM": {
+            "total": [184.01, 195.17, 203.06, 157.33, 158.30, 168.34, 162.12, 149.44],
+            "normativ": [158.02, 158.02, 162.73, 162.73, 162.73, 162.73, 162.73, 162.73]
+        }
+    }
+    ```
+    """
+    report_service = get_report_service()
+
+    try:
+        # Создаем запрос
+        request_dict = request_data.model_dump()
+        request_dict['mode'] = 'series_by_id_and_columns'
+        request = DataRequest(
+            report_type='monitoring_fuel',
+            get_params=request_dict
+        )
+
+        # Получаем данные
+        result = report_service.get_data(request)
+
+        if result.success:
+            return {
+                "success": True,
+                "data": result.data
+            }
+        else:
+            raise HTTPException(status_code=404, detail=result.message)
+
+    except HTTPException:
+        raise
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Внутренняя ошибка сервера: {str(e)}")
+
+
 # ====== MONITORING TAR ENDPOINTS ======
 
 @app.post("/monitoring_tar/upload", tags=[MonitoringTarParser.name],

python_parser/app/schemas/__init__.py

@@ -1,4 +1,4 @@
-from .monitoring_fuel import MonitoringFuelMonthRequest, MonitoringFuelTotalRequest
+from .monitoring_fuel import MonitoringFuelMonthRequest, MonitoringFuelTotalRequest, MonitoringFuelSeriesRequest
 from .svodka_ca import SvodkaCARequest
 from .svodka_pm import SvodkaPMSingleOGRequest, SvodkaPMTotalOGsRequest
 from .server import ServerInfoResponse
@@ -6,7 +6,7 @@ from .upload import UploadResponse, UploadErrorResponse
 
 
 __all__ = [
-    'MonitoringFuelMonthRequest', 'MonitoringFuelTotalRequest',
+    'MonitoringFuelMonthRequest', 'MonitoringFuelTotalRequest', 'MonitoringFuelSeriesRequest',
     'SvodkaCARequest',
     'SvodkaPMSingleOGRequest', 'SvodkaPMTotalOGsRequest',
     'ServerInfoResponse',

python_parser/app/schemas/monitoring_fuel.py

@@ -32,3 +32,19 @@ class MonitoringFuelTotalRequest(BaseModel):
                 "columns": ["total", "normativ"]
             }
         }
+
+
+class MonitoringFuelSeriesRequest(BaseModel):
+    columns: List[str] = Field(
+        ...,
+        description="Массив названий выбираемых столбцов",
+        example=["total", "normativ"],
+        min_items=1
+    )
+
+    class Config:
+        json_schema_extra = {
+            "example": {
+                "columns": ["total", "normativ"]
+            }
+        }