OrgTJWater/TJWaterServerBinary
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

明确时间模拟需要 scheme_name 参数

Browse Source
This commit is contained in:
Jiang
2026-06-03 17:31:44 +08:00
parent b9410b0ff3
commit 233960d8db
2 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/algorithms/simulation/scenarios.py
+1 -1
View File
@@ -662,7 +662,7 @@ def age_analysis(
new_name, new_name,
"realtime", "realtime",
modify_pattern_start_time, modify_pattern_start_time,
modify_total_duration, duration=modify_total_duration,
downloading_prohibition=True, downloading_prohibition=True,
) )
simulation_result = json.loads(result) simulation_result = json.loads(result)
app/api/v1/endpoints/simulation.py
+7 -4
View File
@@ -226,6 +226,7 @@ async def fastapi_valve_close_analysis(
start_time: str = Query(..., description="阀门关闭开始时间（ISO 8601格式）"), start_time: str = Query(..., description="阀门关闭开始时间（ISO 8601格式）"),
valves: List[str] = Query(..., description="要关闭的阀门ID列表"), valves: List[str] = Query(..., description="要关闭的阀门ID列表"),
duration: int | None = Query(None, description="模拟持续时间（秒），默认900秒"), duration: int | None = Query(None, description="模拟持续时间（秒），默认900秒"),
scheme_name: str = Query(..., description="阀门关闭方案名称"),
) -> str: ) -> str:
""" """
阀门关闭分析（高级版本） 阀门关闭分析（高级版本）
@@ -234,6 +235,7 @@ async def fastapi_valve_close_analysis(
- **start_time**: 阀门关闭开始时间 - **start_time**: 阀门关闭开始时间
- **valves**: 要关闭的阀门ID列表 - **valves**: 要关闭的阀门ID列表
- **duration**: 模拟持续时间（秒，可选，默认900） - **duration**: 模拟持续时间（秒，可选，默认900）
- **scheme_name**: 阀门关闭方案名称
支持同时关闭多个阀门进行分析。 支持同时关闭多个阀门进行分析。
""" """
@@ -242,6 +244,7 @@ async def fastapi_valve_close_analysis(
modify_pattern_start_time=start_time, modify_pattern_start_time=start_time,
modify_total_duration=duration or 900, modify_total_duration=duration or 900,
modify_valve_opening={valve_id: 0.0 for valve_id in valves}, modify_valve_opening={valve_id: 0.0 for valve_id in valves},
scheme_name=scheme_name,
) )
return result or "success" return result or "success"
@@ -295,7 +298,7 @@ async def fastapi_flushing_analysis(
drainage_node_ID: str = Query(..., description="排污节点ID"), drainage_node_ID: str = Query(..., description="排污节点ID"),
flush_flow: float = Query(0, description="冲洗流量（L/s），0表示自动计算"), flush_flow: float = Query(0, description="冲洗流量（L/s），0表示自动计算"),
duration: int | None = Query(None, description="模拟持续时间（秒），默认900秒"), duration: int | None = Query(None, description="模拟持续时间（秒），默认900秒"),
scheme_name: str | None = Query(None, description="冲洗方案名称（可选）"), scheme_name: str = Query(..., description="冲洗方案名称"),
) -> str: ) -> str:
""" """
冲洗分析（高级版本） 冲洗分析（高级版本）
@@ -307,7 +310,7 @@ async def fastapi_flushing_analysis(
- **drainage_node_ID**: 排污节点ID - **drainage_node_ID**: 排污节点ID
- **flush_flow**: 冲洗流量（L/s） - **flush_flow**: 冲洗流量（L/s）
- **duration**: 模拟持续时间（秒，可选，默认900） - **duration**: 模拟持续时间（秒，可选，默认900）
- **scheme_name**: 冲洗方案名称（可选） - **scheme_name**: 冲洗方案名称
支持多阀联合冲洗操作。 支持多阀联合冲洗操作。
""" """
@@ -333,7 +336,7 @@ async def fastapi_contaminant_simulation(
source: str = Query(..., description="污染源节点ID"), source: str = Query(..., description="污染源节点ID"),
concentration: float = Query(..., description="污染浓度（mg/L）"), concentration: float = Query(..., description="污染浓度（mg/L）"),
duration: int = Query(..., description="模拟持续时间（秒）"), duration: int = Query(..., description="模拟持续时间（秒）"),
scheme_name: str | None = Query(None, description="模拟方案名称（可选）"), scheme_name: str = Query(..., description="模拟方案名称"),
pattern: str | None = Query(None, description="污染源模式ID（可选）"), pattern: str | None = Query(None, description="污染源模式ID（可选）"),
) -> str: ) -> str:
""" """
@@ -344,7 +347,7 @@ async def fastapi_contaminant_simulation(
- **source**: 污染源节点ID - **source**: 污染源节点ID
- **concentration**: 污染浓度（mg/L） - **concentration**: 污染浓度（mg/L）
- **duration**: 模拟持续时间（秒） - **duration**: 模拟持续时间（秒）
- **scheme_name**: 模拟方案名称（可选） - **scheme_name**: 模拟方案名称
- **pattern**: 污染源模式ID（可选） - **pattern**: 污染源模式ID（可选）
用于评估管网中污染物的传播和影响范围。 用于评估管网中污染物的传播和影响范围。