Compare commits
5 Commits
4624442991
...
hotfix
| Author | SHA1 | Date | |
|---|---|---|---|
| b01320acde | |||
| db3788ac69 | |||
| 31fad98133 | |||
| 88294de506 | |||
| cb8e8b2483 |
@@ -164,10 +164,25 @@ async def get_server_info():
|
|||||||
"""Получение подробной информации о сервере"""
|
"""Получение подробной информации о сервере"""
|
||||||
import platform
|
import platform
|
||||||
import sys
|
import sys
|
||||||
|
import os
|
||||||
|
import psutil
|
||||||
|
|
||||||
|
# Получаем информацию о процессе
|
||||||
|
process = psutil.Process()
|
||||||
|
parent_process = process.parent()
|
||||||
|
|
||||||
|
# Получаем информацию о системе
|
||||||
|
cpu_cores = psutil.cpu_count()
|
||||||
|
memory_info = psutil.virtual_memory()
|
||||||
|
memory_mb = memory_info.total / (1024 * 1024) # Конвертируем в MB
|
||||||
|
|
||||||
return {
|
return {
|
||||||
"message": "Svodka Parser API",
|
"message": "Svodka Parser API",
|
||||||
"version": "1.0.0",
|
"version": "1.0.0",
|
||||||
|
"process_id": process.pid,
|
||||||
|
"parent_id": parent_process.pid if parent_process else None,
|
||||||
|
"cpu_cores": cpu_cores,
|
||||||
|
"memory_mb": memory_mb,
|
||||||
"python_version": sys.version,
|
"python_version": sys.version,
|
||||||
"platform": platform.platform(),
|
"platform": platform.platform(),
|
||||||
"available_parsers": list(PARSERS.keys())
|
"available_parsers": list(PARSERS.keys())
|
||||||
|
|||||||
@@ -268,6 +268,7 @@ async def get_monitoring_fuel_series_by_id_and_columns(
|
|||||||
@router.post("/async/monitoring_fuel/upload-zip", tags=[MonitoringFuelParser.name],
|
@router.post("/async/monitoring_fuel/upload-zip", tags=[MonitoringFuelParser.name],
|
||||||
summary="Асинхронная загрузка файлов сводок мониторинга топлива одним ZIP-архивом",
|
summary="Асинхронная загрузка файлов сводок мониторинга топлива одним ZIP-архивом",
|
||||||
response_model=UploadResponse,
|
response_model=UploadResponse,
|
||||||
|
include_in_schema=False,
|
||||||
responses={
|
responses={
|
||||||
400: {"model": UploadErrorResponse, "description": "Неверный формат архива или файлов"},
|
400: {"model": UploadErrorResponse, "description": "Неверный формат архива или файлов"},
|
||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
|
|||||||
@@ -161,6 +161,7 @@ async def get_monitoring_tar_full_data(
|
|||||||
@router.post("/async/monitoring_tar/upload", tags=[MonitoringTarParser.name],
|
@router.post("/async/monitoring_tar/upload", tags=[MonitoringTarParser.name],
|
||||||
summary="Асинхронная загрузка файла отчета мониторинга ТАР",
|
summary="Асинхронная загрузка файла отчета мониторинга ТАР",
|
||||||
response_model=UploadResponse,
|
response_model=UploadResponse,
|
||||||
|
include_in_schema=False,
|
||||||
responses={
|
responses={
|
||||||
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
|
|||||||
@@ -41,20 +41,20 @@ def get_async_report_service() -> AsyncReportService:
|
|||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
},)
|
},)
|
||||||
async def upload_oper_spravka_tech_pos(
|
async def upload_oper_spravka_tech_pos(
|
||||||
file: UploadFile = File(..., description="Excel файл оперативной справки техпос (.xlsx, .xlsm, .xls)")
|
file: UploadFile = File(..., description="ZIP архив с файлами оперативной справки техпос (.zip)")
|
||||||
):
|
):
|
||||||
"""Загрузка и обработка отчета оперативной справки техпос"""
|
"""Загрузка и обработка отчета оперативной справки техпос"""
|
||||||
report_service = get_report_service()
|
report_service = get_report_service()
|
||||||
|
|
||||||
try:
|
try:
|
||||||
if not file.filename.endswith(('.xlsx', '.xlsm', '.xls')):
|
if not file.filename.endswith('.zip'):
|
||||||
return JSONResponse(
|
return JSONResponse(
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
status_code=status.HTTP_400_BAD_REQUEST,
|
||||||
content=UploadErrorResponse(
|
content=UploadErrorResponse(
|
||||||
message="Поддерживаются только Excel файлы (.xlsx, .xlsm, .xls)",
|
message="Поддерживаются только ZIP архивы (.zip)",
|
||||||
error_code="INVALID_FILE_TYPE",
|
error_code="INVALID_FILE_TYPE",
|
||||||
details={
|
details={
|
||||||
"expected_formats": [".xlsx", ".xlsm", ".xls"],
|
"expected_formats": [".zip"],
|
||||||
"received_format": file.filename.split('.')[-1] if '.' in file.filename else "unknown"
|
"received_format": file.filename.split('.')[-1] if '.' in file.filename else "unknown"
|
||||||
}
|
}
|
||||||
).model_dump()
|
).model_dump()
|
||||||
@@ -115,9 +115,11 @@ async def get_oper_spravka_tech_pos_data(
|
|||||||
result = report_service.get_data(request)
|
result = report_service.get_data(request)
|
||||||
|
|
||||||
if result.success:
|
if result.success:
|
||||||
|
# Извлекаем данные из result.data["value"]
|
||||||
|
data = result.data.get("value", []) if isinstance(result.data, dict) else result.data
|
||||||
return OperSpravkaTechPosResponse(
|
return OperSpravkaTechPosResponse(
|
||||||
success=True,
|
success=True,
|
||||||
data=result.data
|
data=data
|
||||||
)
|
)
|
||||||
else:
|
else:
|
||||||
raise HTTPException(status_code=404, detail=result.message)
|
raise HTTPException(status_code=404, detail=result.message)
|
||||||
@@ -131,25 +133,26 @@ async def get_oper_spravka_tech_pos_data(
|
|||||||
@router.post("/async/oper_spravka_tech_pos/upload", tags=[OperSpravkaTechPosParser.name],
|
@router.post("/async/oper_spravka_tech_pos/upload", tags=[OperSpravkaTechPosParser.name],
|
||||||
summary="Асинхронная загрузка файла отчета оперативной справки техпос",
|
summary="Асинхронная загрузка файла отчета оперативной справки техпос",
|
||||||
response_model=UploadResponse,
|
response_model=UploadResponse,
|
||||||
|
include_in_schema=False,
|
||||||
responses={
|
responses={
|
||||||
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
},)
|
},)
|
||||||
async def async_upload_oper_spravka_tech_pos(
|
async def async_upload_oper_spravka_tech_pos(
|
||||||
file: UploadFile = File(..., description="Excel файл оперативной справки техпос (.xlsx, .xlsm, .xls)")
|
file: UploadFile = File(..., description="ZIP архив с файлами оперативной справки техпос (.zip)")
|
||||||
):
|
):
|
||||||
"""Асинхронная загрузка и обработка отчета оперативной справки техпос"""
|
"""Асинхронная загрузка и обработка отчета оперативной справки техпос"""
|
||||||
async_service = get_async_report_service()
|
async_service = get_async_report_service()
|
||||||
|
|
||||||
try:
|
try:
|
||||||
if not file.filename.endswith(('.xlsx', '.xlsm', '.xls')):
|
if not file.filename.endswith('.zip'):
|
||||||
return JSONResponse(
|
return JSONResponse(
|
||||||
status_code=status.HTTP_400_BAD_REQUEST,
|
status_code=status.HTTP_400_BAD_REQUEST,
|
||||||
content=UploadErrorResponse(
|
content=UploadErrorResponse(
|
||||||
message="Поддерживаются только Excel файлы (.xlsx, .xlsm, .xls)",
|
message="Поддерживаются только ZIP архивы (.zip)",
|
||||||
error_code="INVALID_FILE_TYPE",
|
error_code="INVALID_FILE_TYPE",
|
||||||
details={
|
details={
|
||||||
"expected_formats": [".xlsx", ".xlsm", ".xls"],
|
"expected_formats": [".zip"],
|
||||||
"received_format": file.filename.split('.')[-1] if '.' in file.filename else "unknown"
|
"received_format": file.filename.split('.')[-1] if '.' in file.filename else "unknown"
|
||||||
}
|
}
|
||||||
).model_dump()
|
).model_dump()
|
||||||
|
|||||||
@@ -130,6 +130,7 @@ async def get_statuses_repair_ca_data(
|
|||||||
@router.post("/async/statuses_repair_ca/upload", tags=[StatusesRepairCAParser.name],
|
@router.post("/async/statuses_repair_ca/upload", tags=[StatusesRepairCAParser.name],
|
||||||
summary="Асинхронная загрузка файла отчета статусов ремонта СА",
|
summary="Асинхронная загрузка файла отчета статусов ремонта СА",
|
||||||
response_model=UploadResponse,
|
response_model=UploadResponse,
|
||||||
|
include_in_schema=False,
|
||||||
responses={
|
responses={
|
||||||
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
|
|||||||
@@ -163,6 +163,7 @@ async def get_svodka_ca_data(
|
|||||||
@router.post("/async/svodka_ca/upload", tags=[SvodkaCAParser.name],
|
@router.post("/async/svodka_ca/upload", tags=[SvodkaCAParser.name],
|
||||||
summary="Асинхронная загрузка файла отчета сводки СА",
|
summary="Асинхронная загрузка файла отчета сводки СА",
|
||||||
response_model=UploadResponse,
|
response_model=UploadResponse,
|
||||||
|
include_in_schema=False,
|
||||||
responses={
|
responses={
|
||||||
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
|
|||||||
@@ -262,6 +262,7 @@ async def get_svodka_pm_data(
|
|||||||
@router.post("/async/svodka_pm/upload-zip", tags=[SvodkaPMParser.name],
|
@router.post("/async/svodka_pm/upload-zip", tags=[SvodkaPMParser.name],
|
||||||
summary="Асинхронная загрузка файлов сводок ПМ одним ZIP-архивом",
|
summary="Асинхронная загрузка файлов сводок ПМ одним ZIP-архивом",
|
||||||
response_model=UploadResponse,
|
response_model=UploadResponse,
|
||||||
|
include_in_schema=False,
|
||||||
responses={
|
responses={
|
||||||
400: {"model": UploadErrorResponse, "description": "Неверный формат архива или файлов"},
|
400: {"model": UploadErrorResponse, "description": "Неверный формат архива или файлов"},
|
||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
|
|||||||
@@ -130,6 +130,7 @@ async def get_svodka_repair_ca_data(
|
|||||||
@router.post("/async/svodka_repair_ca/upload", tags=[SvodkaRepairCAParser.name],
|
@router.post("/async/svodka_repair_ca/upload", tags=[SvodkaRepairCAParser.name],
|
||||||
summary="Асинхронная загрузка файла отчета сводки ремонта СА",
|
summary="Асинхронная загрузка файла отчета сводки ремонта СА",
|
||||||
response_model=UploadResponse,
|
response_model=UploadResponse,
|
||||||
|
include_in_schema=False,
|
||||||
responses={
|
responses={
|
||||||
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
400: {"model": UploadErrorResponse, "description": "Неверный формат файла"},
|
||||||
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
500: {"model": UploadErrorResponse, "description": "Внутренняя ошибка сервера"}
|
||||||
|
|||||||
@@ -12,3 +12,4 @@ requests>=2.31.0
|
|||||||
# pytest-mock>=3.10.0
|
# pytest-mock>=3.10.0
|
||||||
httpx>=0.24.0
|
httpx>=0.24.0
|
||||||
numpy
|
numpy
|
||||||
|
psutil>=5.9.0
|
||||||
Reference in New Issue
Block a user