Refine

api/s41_pipe_risk_probability.py

@@ -58,7 +58,7 @@ 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")
+        cur.execute(f"select * from gis_pipe")
         for record in cur:
             print(record['geometry'])
 

online_Analysis.py

@@ -1090,7 +1090,7 @@ if __name__ == '__main__':
     # delete_scheme_info(name='bb', scheme_name='burst_scheme')
 
     # 示例：upload_shp_to_pg
-    upload_shp_to_pg(name='bb', table_name='GIS_pipe', role='Administrator', shp_file_path='市政管线.shp')
+    upload_shp_to_pg(name='bb', table_name='gis_pipe', role='Administrator', shp_file_path='市政管线.shp')
 
     # 示例：submit_risk_probability_result
     submit_risk_probability_result(name='bb', result_file_path='./北碚市政管线风险评价结果.xlsx')