myems /
myems-api
| @@ 174-193 (lines=20) @@ | ||
| 171 | rows_links = cursor_system.fetchall() |
|
| 172 | ||
| 173 | link_list_dict = dict() |
|
| 174 | if rows_links is not None and len(rows_links) > 0: |
|
| 175 | for row in rows_links: |
|
| 176 | # find meter by uuid |
|
| 177 | meter = meter_dict.get(row['meter_uuid'], None) |
|
| 178 | if meter is None: |
|
| 179 | meter = virtual_meter_dict.get(row['meter_uuid'], None) |
|
| 180 | if meter is None: |
|
| 181 | meter = offline_meter_dict.get(row['meter_uuid'], None) |
|
| 182 | ||
| 183 | if link_list_dict.get(row['energy_flow_diagram_id']) is None: |
|
| 184 | link_list_dict[row['energy_flow_diagram_id']] = list() |
|
| 185 | link_list_dict[row['energy_flow_diagram_id']].append({"id": row['id'], |
|
| 186 | "source_node": { |
|
| 187 | "id": row['source_node_id'], |
|
| 188 | "name": node_dict.get(row['source_node_id'])}, |
|
| 189 | "target_node": { |
|
| 190 | "id": row['target_node_id'], |
|
| 191 | "name": node_dict.get(row['target_node_id'])}, |
|
| 192 | "meter": meter, |
|
| 193 | "value": None}) |
|
| 194 | ||
| 195 | meta_result = {"id": energy_flow_diagram_id, |
|
| 196 | "name": energy_flow_diagram_name, |
|
| @@ 240-258 (lines=19) @@ | ||
| 237 | rows_links = cursor.fetchall() |
|
| 238 | ||
| 239 | link_list_dict = dict() |
|
| 240 | if rows_links is not None and len(rows_links) > 0: |
|
| 241 | for row in rows_links: |
|
| 242 | # find meter by uuid |
|
| 243 | meter = meter_dict.get(row['meter_uuid'], None) |
|
| 244 | if meter is None: |
|
| 245 | meter = virtual_meter_dict.get(row['meter_uuid'], None) |
|
| 246 | if meter is None: |
|
| 247 | meter = offline_meter_dict.get(row['meter_uuid'], None) |
|
| 248 | ||
| 249 | if link_list_dict.get(row['energy_flow_diagram_id']) is None: |
|
| 250 | link_list_dict[row['energy_flow_diagram_id']] = list() |
|
| 251 | link_list_dict[row['energy_flow_diagram_id']].append({"id": row['id'], |
|
| 252 | "source_node": { |
|
| 253 | "id": row['source_node_id'], |
|
| 254 | "name": node_dict.get(row['source_node_id'])}, |
|
| 255 | "target_node": { |
|
| 256 | "id": row['target_node_id'], |
|
| 257 | "name": node_dict.get(row['target_node_id'])}, |
|
| 258 | "meter": meter}) |
|
| 259 | ||
| 260 | query = (" SELECT id, name, uuid " |
|
| 261 | " FROM tbl_energy_flow_diagrams " |
|
| @@ 80-98 (lines=19) @@ | ||
| 77 | rows_links = cursor.fetchall() |
|
| 78 | ||
| 79 | link_list_dict = dict() |
|
| 80 | if rows_links is not None and len(rows_links) > 0: |
|
| 81 | for row in rows_links: |
|
| 82 | # find meter by uuid |
|
| 83 | meter = meter_dict.get(row['meter_uuid'], None) |
|
| 84 | if meter is None: |
|
| 85 | meter = virtual_meter_dict.get(row['meter_uuid'], None) |
|
| 86 | if meter is None: |
|
| 87 | meter = offline_meter_dict.get(row['meter_uuid'], None) |
|
| 88 | ||
| 89 | if link_list_dict.get(row['energy_flow_diagram_id']) is None: |
|
| 90 | link_list_dict[row['energy_flow_diagram_id']] = list() |
|
| 91 | link_list_dict[row['energy_flow_diagram_id']].append({"id": row['id'], |
|
| 92 | "source_node": { |
|
| 93 | "id": row['source_node_id'], |
|
| 94 | "name": node_dict.get(row['source_node_id'])}, |
|
| 95 | "target_node": { |
|
| 96 | "id": row['target_node_id'], |
|
| 97 | "name": node_dict.get(row['target_node_id'])}, |
|
| 98 | "meter": meter}) |
|
| 99 | ||
| 100 | query = (" SELECT id, name, uuid " |
|
| 101 | " FROM tbl_energy_flow_diagrams " |
|
