diff --git a/api/s41_pipe_risk_probability.py b/api/s41_pipe_risk_probability.py index f748085..15291fc 100644 --- a/api/s41_pipe_risk_probability.py +++ b/api/s41_pipe_risk_probability.py @@ -13,4 +13,14 @@ def get_pipe_risk_probability_now(name: str, pipe_id: str) -> dict[str, Any]: return d +def get_pipe_risk_probability(name: str, pipe_id: str) -> dict[str, Any]: + t = try_read(name, f"select * from pipe_risk_probability where pipeid = '{pipe_id}'") + if t == None: + return {} + d = {} + d['pipeid'] = t['pipeid'] + d['x'] = t['x'] + d['y'] = t['y'] + + return d \ No newline at end of file diff --git a/main.py b/main.py index 81a85db..3bc068b 100644 --- a/main.py +++ b/main.py @@ -2206,6 +2206,11 @@ async def fastapi_get_all_schemes(network: str) -> list[dict[Any, Any]]: async def fastapi_get_pipe_risk_probability_now(network: str, pipe_id: str) -> dict[str, Any]: return get_pipe_risk_probability_now(network, pipe_id) +@app.get('/getpiperiskprobability/') +async def fastapi_get_pipe_risk_probability(network: str, pipe_id: str) -> dict[str, Any]: + return get_pipe_risk_probability(network, pipe_id) + + diff --git a/tjnetwork.py b/tjnetwork.py index e65ab3b..1555038 100644 --- a/tjnetwork.py +++ b/tjnetwork.py @@ -1320,4 +1320,5 @@ def get_all_schemes(name: str) -> list[dict[str, Any]]: def get_pipe_risk_probability_now(name: str, pipe_id: str) -> dict[str, Any]: return api.get_pipe_risk_probability_now(name, pipe_id) - +def get_pipe_risk_probability(name: str, pipe_id: str) -> dict[str, Any]: + return api.get_pipe_risk_probability(name, pipe_id)