add method pressure_sensor_placement_sensitivity

main.py

@@ -3212,6 +3212,28 @@ async def fastapi_pump_failure(data: PumpFailureState) -> str:
     return json.dumps('SUCCESS')
 
 
+############################################################
+# pressure_sensor_placement_sensitivity api 50
+############################################################
+# 2025/05/17
+class Pressure_Sensor_Placement_Sensitivity(BaseModel):
+    name: str
+    scheme_name: str
+    sensor_number: int
+    min_diameter: int = 0
+    username: str
+
+
+@app.post("/pressure_sensor_placement_sensitivity/")
+async def fastapi_pressure_sensor_placement_sensitivity(data: Pressure_Sensor_Placement_Sensitivity) -> None:
+    item = data.dict()
+    pressure_sensor_placement_sensitivity(name=item['name'],
+                                          scheme_name=item['scheme_name'],
+                                          sensor_number=item['sensor_number'],
+                                          min_diameter=item['min_diameter'],
+                                          username=item['username']
+    )
+
 class Item(BaseModel):
     str_info: str
     dict_info: Optional[dict] = None

online_Analysis.py

@@ -17,6 +17,7 @@ import simulation
 import geopandas as gpd
 from sqlalchemy import create_engine
 import ast
+import sensitivity
 
 
 ############################################################
@@ -1081,10 +1082,10 @@ if __name__ == '__main__':
 #         f.write(str_dump)
 
     # 更新inp文件，并插入history_patterns_flows
-    network_update('20250309beibei_v2.inp')
+    # network_update('20250309beibei_v2.inp')
 
     # 更新scada_info文件
-    submit_scada_info('bb', '4490')
+    # submit_scada_info('bb', '4490')
 
     # 示例：scheme_name_exists
     # if scheme_name_exists(name='bb', scheme_name='burst_scheme'):
@@ -1097,7 +1098,7 @@ if __name__ == '__main__':
     #                burst_ID='GSD230112144241FA18292A84CB', burst_size=400, modify_total_duration=1800, scheme_Name='GSD230112144241FA18292A84CB_400')
 
     # 示例：create_user
-    create_user(name='bb', username='admin', password='123456')
+    # create_user(name='bb', username='admin', password='123456')
 
     # 示例：delete_user
     # delete_user(name='bb', username='admin_test')
@@ -1110,10 +1111,10 @@ 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='86158', shp_file_path='市政管线.shp')
 
     # 示例：submit_risk_probability_result
-    submit_risk_probability_result(name='bb', result_file_path='./北碚市政管线风险评价结果.xlsx')
+    # submit_risk_probability_result(name='bb', result_file_path='./北碚市政管线风险评价结果.xlsx')
 
     # 示例：pressure_sensor_placement_sensitivity
     pressure_sensor_placement_sensitivity(name='bb', scheme_name='20250517', sensor_number=10,