From 2f8e1f1fc745e7413005ec86bb6c6a39d4fd17c6 Mon Sep 17 00:00:00 2001
From: DingZQ <zqding@hotmail.com>
Date: Sat, 19 Apr 2025 12:22:08 +0800
Subject: [PATCH] Refine

---
 api/s41_pipe_risk_probability.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/api/s41_pipe_risk_probability.py b/api/s41_pipe_risk_probability.py
index 48009d3..73464d6 100644
--- a/api/s41_pipe_risk_probability.py
+++ b/api/s41_pipe_risk_probability.py
@@ -58,8 +58,11 @@ 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 ST_AsGeoJSON(geometry) AS geometry from gis_pipe")
+        cur.execute(f"select '编码' AS Id, '上游节点' AS startnode, '下游节点' AS endnode, ST_AsGeoJSON(geometry) AS geometry from gis_pipe")
         for record in cur:
+            print(record['Id'])
+            print(record['startnode'])
+            print(record['endnode'])
             print(record['geometry'])
 
     return pipe_risk_probability_geometries
\ No newline at end of file