2024-11-28 20:52:42 +03:00
|
|
|
|
import yaml
|
2024-10-22 16:46:39 +04:00
|
|
|
|
from fastapi import APIRouter, HTTPException
|
2024-11-28 20:52:42 +03:00
|
|
|
|
from scipy.stats import alpha
|
2024-10-27 23:29:52 +04:00
|
|
|
|
|
|
|
|
|
from db.crud import *
|
|
|
|
|
from db.models import LoadParameters
|
2024-10-28 13:30:02 +04:00
|
|
|
|
from db.repositories import get_exp_parameters_by_category, get_exp_parameters_by_exp_hash
|
2024-11-28 20:52:42 +03:00
|
|
|
|
from macros_generator import load_calculation, recycling_calculation
|
2024-10-22 16:46:39 +04:00
|
|
|
|
from network.schemas import ExperimentParametersBody
|
|
|
|
|
|
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
2024-10-27 23:29:52 +04:00
|
|
|
|
|
2024-10-22 16:46:39 +04:00
|
|
|
|
@router.post('/create')
|
2024-10-27 23:29:52 +04:00
|
|
|
|
async def create_experiment_parameters(body: ExperimentParametersBody):
|
2024-10-22 16:46:39 +04:00
|
|
|
|
try:
|
2024-10-27 23:29:52 +04:00
|
|
|
|
await create(ExperimentParameters,
|
|
|
|
|
outer_blades_count=body.outer_blades_count,
|
|
|
|
|
outer_blades_length=body.outer_blades_length,
|
|
|
|
|
outer_blades_angle=body.outer_blades_angle,
|
|
|
|
|
middle_blades_count=body.middle_blades_count,
|
|
|
|
|
load_id=body.load_id,
|
|
|
|
|
recycling_id=body.recycling_id,
|
2024-12-11 13:41:58 +04:00
|
|
|
|
experiment_hash=body.experiment_hash,
|
|
|
|
|
experiment_category_id=body.experiment_category_id
|
2024-10-27 23:29:52 +04:00
|
|
|
|
)
|
|
|
|
|
|
2024-10-22 16:46:39 +04:00
|
|
|
|
return {"message": "Новая запись <ExperimentParameters> успешно добавлена"}
|
|
|
|
|
except Exception as e:
|
|
|
|
|
raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
|
|
|
|
|
|
2024-10-27 23:29:52 +04:00
|
|
|
|
|
2024-10-22 16:46:39 +04:00
|
|
|
|
@router.get('/all')
|
|
|
|
|
async def get_all_experiment_parameters():
|
|
|
|
|
try:
|
2024-10-27 23:29:52 +04:00
|
|
|
|
result = await get_all(ExperimentParameters)
|
|
|
|
|
|
|
|
|
|
if result is not None:
|
|
|
|
|
return result
|
|
|
|
|
else:
|
|
|
|
|
return {"message": "Нет записей в <ExperimentParameters>"}
|
|
|
|
|
except Exception as e:
|
|
|
|
|
raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@router.get('/{id}')
|
|
|
|
|
async def get_by_id_experiment_parameters(id: int):
|
|
|
|
|
try:
|
|
|
|
|
result = await get_by_id(ExperimentParameters, id)
|
2024-10-22 16:46:39 +04:00
|
|
|
|
|
2024-10-27 23:29:52 +04:00
|
|
|
|
if result is not None:
|
2024-10-22 16:46:39 +04:00
|
|
|
|
return result
|
|
|
|
|
else:
|
2024-10-27 23:29:52 +04:00
|
|
|
|
return {"message": "Запись <ExperimentParameters> не найдена"}
|
|
|
|
|
except Exception as e:
|
|
|
|
|
raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
|
|
|
|
|
|
|
|
|
|
|
2024-10-28 13:30:02 +04:00
|
|
|
|
@router.get('/by_category/{id}')
|
|
|
|
|
async def get_experiment_parameters_by_exp_category(id: int):
|
|
|
|
|
try:
|
|
|
|
|
result = await get_exp_parameters_by_category(id)
|
|
|
|
|
|
|
|
|
|
if result is not None:
|
|
|
|
|
return result
|
|
|
|
|
else:
|
|
|
|
|
return {"message": f'<ExperimentParameters> с идентификатором категории - {id} - не найдены'}
|
|
|
|
|
except Exception as e:
|
|
|
|
|
raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@router.get('/by_exp_hash/{hash}')
|
|
|
|
|
async def get_experiment_parameters_by_exp_category(hash: str):
|
|
|
|
|
try:
|
|
|
|
|
result = await get_exp_parameters_by_exp_hash(hash)
|
|
|
|
|
|
|
|
|
|
if result is not None:
|
|
|
|
|
return result
|
|
|
|
|
else:
|
|
|
|
|
return {"message": f'<ExperimentParameters> с experiment_hash = {id} - не найдены'}
|
|
|
|
|
except Exception as e:
|
|
|
|
|
raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
|
|
|
|
|
|
|
|
|
|
|
2024-10-27 23:29:52 +04:00
|
|
|
|
@router.delete('/{id}/delete')
|
|
|
|
|
async def delete_experiment_parameters(id: int):
|
|
|
|
|
try:
|
2024-11-19 16:24:05 +04:00
|
|
|
|
is_deleted = await delete(ExperimentParameters, id)
|
|
|
|
|
|
2024-10-27 23:29:52 +04:00
|
|
|
|
if is_deleted:
|
|
|
|
|
return {"message": "Запись <ExperimentParameters> успешно удалена"}
|
|
|
|
|
else:
|
|
|
|
|
return {"message": "Запись <ExperimentParameters> не найдена"}
|
2024-10-22 16:46:39 +04:00
|
|
|
|
except Exception as e:
|
|
|
|
|
raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
|
2024-11-20 00:11:58 +04:00
|
|
|
|
|
2024-11-28 20:52:42 +03:00
|
|
|
|
# @router.post('/process_and_save/{id}') было нужно для проверки
|
|
|
|
|
async def process_and_save_experiment_data(id: int, load: float, recycling_level: float) -> dict:
|
2024-11-20 00:11:58 +04:00
|
|
|
|
try:
|
|
|
|
|
experiment = await get_by_id(ExperimentParameters, id)
|
|
|
|
|
if experiment is None:
|
|
|
|
|
raise HTTPException(status_code=404, detail=f"ExperimentParameters с id {id} не найден.")
|
|
|
|
|
|
2024-11-28 20:52:42 +03:00
|
|
|
|
yaml_file_path = "config.yaml"
|
2024-11-20 00:11:58 +04:00
|
|
|
|
|
2024-11-28 20:52:42 +03:00
|
|
|
|
with open(yaml_file_path, "r", encoding="utf-8") as file:
|
|
|
|
|
data = yaml.safe_load(file)
|
|
|
|
|
|
|
|
|
|
diameters = data["parameters"]["diameters"]
|
|
|
|
|
|
|
|
|
|
dict_load = load_calculation(load, diameters, None)
|
|
|
|
|
|
|
|
|
|
primary_air_consumption = dict_load["primary_air_consumption"]
|
|
|
|
|
secondary_air_consumption = dict_load["secondary_air_consumption"]
|
|
|
|
|
gas_inlet_consumption = dict_load["gas_inlet_consumption"]
|
|
|
|
|
alpha = dict_load["alpha"]
|
|
|
|
|
gas_consumption = dict_load["gas_consumption"]
|
|
|
|
|
air_consumption = dict_load["air_consumption"]
|
|
|
|
|
|
|
|
|
|
dict_recycling = recycling_calculation(alpha, gas_consumption, air_consumption, recycling_level)
|
|
|
|
|
|
|
|
|
|
co2 = dict_recycling["CO2"]
|
|
|
|
|
n2 = dict_recycling["N2"]
|
|
|
|
|
h2o = dict_recycling["H2O"]
|
|
|
|
|
o2 = dict_recycling["O2"]
|
2024-11-20 00:11:58 +04:00
|
|
|
|
|
|
|
|
|
load_params = await create(
|
|
|
|
|
LoadParameters,
|
2024-11-28 20:52:42 +03:00
|
|
|
|
load=int(load),
|
2024-11-20 00:11:58 +04:00
|
|
|
|
primary_air_consumption=primary_air_consumption,
|
|
|
|
|
secondary_air_consumption=secondary_air_consumption,
|
|
|
|
|
gas_inlet_consumption=gas_inlet_consumption
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
recycling_params = await create(
|
|
|
|
|
RecyclingParameters,
|
|
|
|
|
load_id=load_params.id,
|
|
|
|
|
recycling_level=int(recycling_level),
|
|
|
|
|
co2=co2,
|
|
|
|
|
n2=n2,
|
|
|
|
|
h2o=h2o,
|
|
|
|
|
o2=o2
|
|
|
|
|
)
|
|
|
|
|
|
2024-11-28 20:52:42 +03:00
|
|
|
|
await update_exp(
|
2024-11-20 00:21:24 +04:00
|
|
|
|
ExperimentParameters,
|
|
|
|
|
id=experiment.id,
|
|
|
|
|
updated_data={
|
|
|
|
|
"load_id": load_params.id,
|
|
|
|
|
"recycling_id": recycling_params.id
|
|
|
|
|
}
|
|
|
|
|
)
|
2024-11-20 00:11:58 +04:00
|
|
|
|
|
|
|
|
|
return {
|
|
|
|
|
"message": "Данные успешно обработаны и сохранены.",
|
|
|
|
|
"load_parameters": load_params,
|
2024-11-28 20:52:42 +03:00
|
|
|
|
"recycling_parameters": recycling_params
|
2024-11-20 00:11:58 +04:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
except Exception as e:
|
|
|
|
|
raise HTTPException(status_code=500, detail=f"An error occurred: {str(e)}")
|