OrgTJWater/TJWaterServer
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Support bianma for risk page

Browse Source
This commit is contained in:
DingZQ
2025-05-04 21:19:05 +08:00
parent 3ba4837c9e
commit 74c828cc3f
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
api/s41_pipe_risk_probability.py
View File

@@ -79,7 +79,7 @@ def get_pipe_risk_probability_geometries(name: str) -> dict[str, Any]:
} }
for col in record: for col in record:
if col != key_pipeId and col != key_geometry: if col != key_geometry:
pipe_risk_probability_geometries[id][col] = record[col] pipe_risk_probability_geometries[id][col] = record[col]
# print(len(pipe_risk_probability_geometries)) # print(len(pipe_risk_probability_geometries))

2
influxdb_api.py
View File

@@ -1747,6 +1747,7 @@ def query_filling_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str
print("{} -- Failed to connect to InfluxDB.".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S'))) print("{} -- Failed to connect to InfluxDB.".format(datetime.now().strftime('%Y-%m-%d %H:%M:%S')))
query_api = client.query_api() query_api = client.query_api()
print('start_time', start_time) print('start_time', start_time)
print('end_time', end_time) print('end_time', end_time)
# 将北京时间转换为 UTC 时间 # 将北京时间转换为 UTC 时间
@@ -1758,6 +1759,7 @@ def query_filling_SCADA_data_by_device_ID_and_timerange(query_ids_list: List[str
print('beijing_end_time', beijing_end_time) print('beijing_end_time', beijing_end_time)
utc_stop_time = time_api.to_utc_time(beijing_end_time) utc_stop_time = time_api.to_utc_time(beijing_end_time)
print('utc_stop_time', utc_stop_time) print('utc_stop_time', utc_stop_time)
SCADA_dict = {} SCADA_dict = {}
for device_id in query_ids_list: for device_id in query_ids_list:
flux_query = f''' flux_query = f'''