Add API getpiperiskprobabilitygeometries

api/s41_pipe_risk_probability.py

@@ -52,3 +52,14 @@ def get_pipes_risk_probability(name: str, pipe_ids: list[str]) -> list[dict[str,
                 pipe_risk_probability_list.append(t)
 
     return pipe_risk_probability_list
+
+# node : {}, link : {}
+def get_pipe_risk_probability_geometries(name: str) -> dict[str, Any]:
+    pipe_risk_probability_geometries = {}
+
+    with conn[name].cursor(row_factory=dict_row) as cur:
+        cur.execute(f"select * from GIS_pipe")
+        for record in cur:
+            print(record['geometry'])
+
+    return pipe_risk_probability_geometries

main.py

@@ -2219,6 +2219,10 @@ async def fastapi_get_pipes_risk_probability(network: str, pipe_ids: str) -> lis
 async def fastapi_get_network_pipe_risk_probability_now(network: str) -> list[dict[str, Any]]:
     return get_network_pipe_risk_probability_now(network)
 
+@app.get('/getpiperiskprobabilitygeometries/')
+async def fastapi_get_pipe_risk_probability_geometries(network: str) -> dict[str, Any]:
+    return get_pipe_risk_probability_geometries(network)
+
 
 
 

tjnetwork.py

@@ -1329,3 +1329,5 @@ def get_pipes_risk_probability(name: str, pipe_ids: list[str]) -> list[dict[str,
 def get_network_pipe_risk_probability_now(name: str) -> list[dict[str, Any]]:
     return api.get_network_pipe_risk_probability_now(name)
 
+def get_pipe_risk_probability_geometries(name: str) -> dict[str, Any]:
+    return api.get_pipe_risk_probability_geometries(name)