Refine

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

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)
+
+
 
 
 

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)