Add comments

api/s41_pipe_risk_probability.py

@@ -54,8 +54,12 @@ def get_pipes_risk_probability(name: str, pipe_ids: list[str]) -> list[dict[str,
 
     return pipe_risk_probability_list
 
-# node : {}, link : {}
 def get_pipe_risk_probability_geometries(name: str) -> dict[str, Any]:
+    '''
+    获取管道的几何信息
+    返回一个字典，key 是管道的 id，value 是管道的几何信息
+    几何信息是一个字典，包含 start 和 end 两个 key，value 是管道的起点和终点的坐标
+    '''
     pipe_risk_probability_geometries = {}
 
     key_pipeId = '编码'
@@ -68,8 +72,6 @@ def get_pipe_risk_probability_geometries(name: str) -> dict[str, Any]:
         for record in cur:
             id = record[key_pipeId]
             geom = json.loads(record[key_geometry])
-            print(geom)
-            print(geom['coordinates'])
 
             pipe_risk_probability_geometries[id] = {
                 'start': geom['coordinates'][0], 

main.py

@@ -2219,6 +2219,19 @@ 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)
 
+# 返回一个字典，key 是管道的 id，value 是管道的几何信息
+# 几何信息是一个字典，包含 start 和 end 两个 key，value 是管道的起点和终点的坐标
+# 例如：
+# "GSD240730154246A51D2C324D1A": {
+# 		"start": [
+# 			106.424759007,
+# 			29.815104642
+# 		],
+# 		"end": [
+# 			106.424824186,
+# 			29.814950582
+# 		]
+# 	},
 @app.get('/getpiperiskprobabilitygeometries/')
 async def fastapi_get_pipe_risk_probability_geometries(network: str) -> dict[str, Any]:
     return get_pipe_risk_probability_geometries(network)