Compare commits

...

2 Commits

Author SHA1 Message Date
dc38313cdc 修复scheme计算属性无法显示的问题 2026-02-06 11:32:47 +08:00
f19962510a 为flushing_analysis新增scheme_name参数 2026-02-05 16:13:41 +08:00
3 changed files with 6 additions and 3 deletions

View File

@@ -1,6 +1,5 @@
from collections import defaultdict, deque
from functools import lru_cache
import time
from typing import Any
from app.services.tjnetwork import (

View File

@@ -280,6 +280,7 @@ async def fastapi_flushing_analysis(
drainage_node_ID: str = Query(...),
flush_flow: float = 0,
duration: int | None = None,
scheme_name: str | None = None,
) -> str:
valve_opening = {
valve_id: float(valves_k[idx]) for idx, valve_id in enumerate(valves)
@@ -291,6 +292,7 @@ async def fastapi_flushing_analysis(
modify_valve_opening=valve_opening,
drainage_node_ID=drainage_node_ID,
flushing_flow=flush_flow,
scheme_name=scheme_name,
)
return result or "success"

View File

@@ -8,7 +8,9 @@ from .schemas.realtime import RealtimeRepository
from .schemas.scheme import SchemeRepository
from .schemas.scada import ScadaRepository
from .composite_queries import CompositeQueries
from app.infra.db.postgresql.database import get_database_instance as get_postgres_database_instance
from app.infra.db.postgresql.database import (
get_database_instance as get_postgres_database_instance,
)
router = APIRouter()
@@ -152,7 +154,7 @@ async def query_realtime_simulation_by_id_time(
results = await RealtimeRepository.query_simulation_result_by_id_time(
conn, id, type, query_time
)
return {"results": results}
return {"result": results}
except ValueError as e:
raise HTTPException(status_code=400, detail=str(e))