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

Refine

Browse Source
This commit is contained in:
DingZQ
2025-04-17 23:12:07 +08:00
parent 97f73a3521
commit e23761195e
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
api/s41_pipe_risk_probability.py
View File

@@ -42,13 +42,13 @@ def get_network_pipe_risk_probability_now(name: str) -> list[dict[str, Any]]:
def get_pipes_risk_probability(name: str, pipe_ids: list[str]) -> list[dict[str, Any]]: def get_pipes_risk_probability(name: str, pipe_ids: list[str]) -> list[dict[str, Any]]:
pipe_risk_probability_list = [] pipe_risk_probability_list = []
with conn[name].cursor(row_factory=dict_row) as cur: with conn[name].cursor(row_factory=dict_row) as cur:
cur.execute(f"select * from pipe_risk_probability where pipeid in ({','.join(pipe_ids)})") cur.execute(f"select * from pipe_risk_probability")
for record in cur: for record in cur:
#pipe_risk_probability_list.append(record) if record['pipeid'] in pipe_ids:
t = {} t = {}
t['pipeid'] = record['pipeid'] t['pipeid'] = record['pipeid']
t['x'] = record['y'] t['x'] = record['x']
t['y'] = record['y'] t['y'] = record['y']
pipe_risk_probability_list.append(t) pipe_risk_probability_list.append(t)
return pipe_risk_probability_list return pipe_risk_probability_list