Support scada batch operation

api/batch_cmd.py

@@ -28,6 +28,9 @@ from .s25_vertices import set_vertex_cmd, add_vertex_cmd, delete_vertex_cmd
 from .s26_labels import set_label_cmd, add_label_cmd, delete_label_cmd
 from .s27_backdrop import set_backdrop_cmd
 # from .s28_end import *
+from .s29_scada_device import set_scada_device_cmd, add_scada_device_cmd, delete_scada_device_cmd
+from .s30_scada_device_data import set_scada_device_data_cmd, add_scada_device_data_cmd, delete_scada_device_data_cmd
+from .s31_scada_element import set_scada_element_cmd, add_scada_element_cmd, delete_scada_element_cmd
 from .del_cmd_raw import del_cascade_cmd
 
 
@@ -96,6 +99,12 @@ def add_cmd(name: str, cs: ChangeSet) -> DbChangeSet | None:
         return None
     elif type == s28_end:
         return None
+    elif type == s29_scada_device:
+        return add_scada_device_cmd(name, cs)
+    elif type == s30_scada_device_data:
+        return add_scada_device_data_cmd(name, cs)
+    elif type == s31_scada_element:
+        return add_scada_element_cmd(name, cs)
 
     return None
 
@@ -165,6 +174,12 @@ def set_cmd(name: str, cs: ChangeSet) -> DbChangeSet | None:
         return set_backdrop_cmd(name, cs)
     elif type == s28_end: # end
         return None
+    elif type == s29_scada_device:
+        return set_scada_device_cmd(name, cs)
+    elif type == s30_scada_device_data:
+        return set_scada_device_data_cmd(name, cs)
+    elif type == s31_scada_element:
+        return set_scada_element_cmd(name, cs)
 
     return None
 
@@ -234,6 +249,12 @@ def del_cmd(name: str, cs: ChangeSet) -> DbChangeSet | None:
         return None
     elif type == s28_end:
         return None
+    elif type == s29_scada_device:
+        return delete_scada_device_cmd(name, cs)
+    elif type == s30_scada_device_data:
+        return delete_scada_device_data_cmd(name, cs)
+    elif type == s31_scada_element:
+        return delete_scada_element_cmd(name, cs)
 
     return None
 

api/batch_cmds.py

@@ -28,6 +28,9 @@ from .s25_vertices import set_vertex, add_vertex, delete_vertex
 from .s26_labels import set_label, add_label, delete_label
 from .s27_backdrop import set_backdrop
 # from .s28_end import *
+from .s29_scada_device import set_scada_device, add_scada_device, delete_scada_device
+from .s30_scada_device_data import set_scada_device_data, add_scada_device_data, delete_scada_device_data
+from .s31_scada_element import set_scada_element, add_scada_element, delete_scada_element
 from .del_cmd_raw import del_cascade_cmd
 
 
@@ -96,6 +99,12 @@ def execute_add_command(name: str, cs: ChangeSet) -> ChangeSet:
         return ChangeSet()
     elif type == s28_end:
         return ChangeSet()
+    elif type == s29_scada_device:
+        return add_scada_device(name, cs)
+    elif type == s30_scada_device_data:
+        return add_scada_device_data(name, cs)
+    elif type == s31_scada_element:
+        return add_scada_element(name, cs)
 
     return ChangeSet()
 
@@ -165,6 +174,12 @@ def execute_update_command(name: str, cs: ChangeSet) -> ChangeSet:
         return set_backdrop(name, cs)
     elif type == s28_end: # end
         return ChangeSet()
+    elif type == s29_scada_device:
+        return set_scada_device(name, cs)
+    elif type == s30_scada_device_data:
+        return set_scada_device_data(name, cs)
+    elif type == s31_scada_element:
+        return set_scada_element(name, cs)
 
     return ChangeSet()
 
@@ -234,6 +249,12 @@ def execute_delete_command(name: str, cs: ChangeSet) -> ChangeSet:
         return ChangeSet()
     elif type == s28_end:
         return ChangeSet()
+    elif type == s29_scada_device:
+        return delete_scada_device(name, cs)
+    elif type == s30_scada_device_data:
+        return delete_scada_device_data(name, cs)
+    elif type == s31_scada_element:
+        return delete_scada_element(name, cs)
 
     return ChangeSet()
 

api/sections.py

@@ -28,4 +28,7 @@ s24_coordinate = 'coordinate'
 s25_vertex = 'vertex'
 s26_label = 'label'
 s27_backdrop = 'backdrop'
-s28_end = 'end'
+s28_end = 'end'
+s29_scada_device = 'scada_device'
+s30_scada_device_data = 'scada_device_data'
+s31_scada_element = 'scada_element'