feat: 调整规则节点添加，新增添加场景联动的规则节点

 package org.thingsboard.server.controller.yunteng;
 
-import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.fasterxml.jackson.databind.JsonNode;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
@@ -26,7 +26,7 @@ import org.thingsboard.server.common.data.yunteng.core.exception.YtDataValidatio
 import org.thingsboard.server.common.data.yunteng.core.message.ErrorMessage;
 import org.thingsboard.server.common.data.yunteng.dto.ConvertConfigDTO;
 import org.thingsboard.server.common.data.yunteng.dto.ConvertConfigReqDTO;
-import org.thingsboard.server.common.data.yunteng.dto.ConvertJSReqDTO;
+import org.thingsboard.server.common.data.yunteng.dto.ConvertReqDTO;
 import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
 import org.thingsboard.server.common.data.yunteng.enums.OrderTypeEnum;
 import org.thingsboard.server.common.data.yunteng.utils.tools.YtPageData;
@@ -36,7 +36,6 @@ import org.thingsboard.server.dao.yunteng.service.YtRuleChainService;
 
 import java.util.*;
 import java.util.concurrent.ConcurrentMap;
-import java.util.concurrent.atomic.AtomicInteger;
 
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.*;
 import static org.thingsboard.server.common.data.yunteng.constant.QueryConstant.ORDER_TYPE;
@@ -52,8 +51,6 @@ public class YtConvertDataToController extends BaseController {
   @Value("${actors.rule.chain.debug_mode_rate_limits_per_tenant.enabled}")
   private boolean debugPerTenantEnabled;
 
-  private final String connectionType = "Success";
-
   @Autowired(required = false)
   private ActorSystemContext actorContext;
 
@@ -158,7 +155,7 @@ public class YtConvertDataToController extends BaseController {
   @PostMapping("update/js")
   @ApiOperation("启用或禁用转换脚本")
   public RuleChainMetaData updateJs(
-      @Validated(UpdateGroup.class) @RequestBody ConvertJSReqDTO convertJSReqDTO)
+      @Validated(UpdateGroup.class) @RequestBody ConvertReqDTO convertJSReqDTO)
       throws ThingsboardException {
     int status = convertJSReqDTO.getStatus();
     if (status == FastIotConstants.StateValue.ENABLE
@@ -178,6 +175,30 @@ public class YtConvertDataToController extends BaseController {
     return ruleChainMetaData;
   }
 
+  @PostMapping("update/scene")
+  @ApiOperation("启用或禁用场景联动")
+  public RuleChainMetaData updateScene(
+      @Validated(UpdateGroup.class) @RequestBody ConvertReqDTO convertReqDTO)
+      throws ThingsboardException {
+    //TODO 通过接口获取JsonNode
+    JsonNode configuration = convertReqDTO.getConfiguration();
+    int status = -1;
+    boolean noValue = configuration == null;
+    if (noValue && convertReqDTO.getStatus() == FastIotConstants.StateValue.DISABLE) {
+      status = FastIotConstants.StateValue.DISABLE;
+    }
+    if (!noValue) {
+      status = FastIotConstants.StateValue.ENABLE;
+    }
+    List<RuleNode> ruleNodes = new ArrayList<>();
+    RuleNode scene = new RuleNode();
+    scene.setName("Scene");
+    scene.setType("org.thingsboard.rule.engine.yunteng.scene.TbSceneReactNode");
+    scene.setConfiguration(configuration);
+    ruleNodes.add(scene);
+    return saveRuleChain(ruleNodes, status, FastIotConstants.SCENE_REACT);
+  }
+
   /**
    * 保存规则链
    *
@@ -196,9 +217,9 @@ public class YtConvertDataToController extends BaseController {
         ruleChainService.loadRuleChainMetaData(getTenantId(), ruleChain.getId());
     // 3. SETUP CONNECTION AND ADD OR DELETE RULE NODE
     if (status == FastIotConstants.MagicNumber.ZERO) {
-      needSaveRuleNode = deleteRuleNode(nodes, ruleChainMetaData, nodeType);
+      needSaveRuleNode = convertConfigService.deleteRuleNode(nodes, ruleChainMetaData, nodeType);
     } else {
-      addRuleNode(nodes, ruleChainMetaData, nodeType);
+      convertConfigService.addRuleNode(nodes, ruleChainMetaData, nodeType);
       needSaveRuleNode = true;
     }
     // 4. SAVE METADATA
@@ -226,174 +247,6 @@ public class YtConvertDataToController extends BaseController {
     return savedRuleChainMetaData;
   }
 
-  private void addRuleNode(
-      List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData, Integer nodeType) {
-    if (nodeType.intValue() == FastIotConstants.CONVERT_DATA.intValue()) {
-      addConvertConfigRuleNode(nodes, ruleChainMetaData);
-    } else {
-      // 1. Get Device Profile nodeIndex
-      int firstNodeIndex = ruleChainMetaData.getFirstNodeIndex();
-      // 2. Add Rule Node
-      RuleNode ruleNode = nodes.get(0);
-      int randomNum = new Random().nextInt(50);
-      int layoutX = 202;
-      int layoutY = 53;
-      ObjectNode objectNode = JacksonUtil.newObjectNode();
-      objectNode.put("description", "");
-      objectNode.put("layoutX", layoutX + randomNum);
-      objectNode.put("layoutY", layoutY + randomNum);
-      ruleNode.setAdditionalInfo(objectNode);
-      ruleChainMetaData.getNodes().add(ruleNode);
-      int newFirstNodeIndex = ruleChainMetaData.getNodes().size() - 1;
-      ruleChainMetaData.setFirstNodeIndex(newFirstNodeIndex);
-      // 3. Add Connection
-      NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo();
-      nodeConnectionInfo.setFromIndex(newFirstNodeIndex);
-      nodeConnectionInfo.setType(connectionType);
-      nodeConnectionInfo.setToIndex(firstNodeIndex);
-      ruleChainMetaData.getConnections().add(nodeConnectionInfo);
-    }
-  }
-
-  private void addConvertConfigRuleNode(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData) {
-    // 1. GET SAVE TIMESERIES‘S NODE INDEX
-    int seriesIndex = 0;
-    for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
-      if (ruleNode.getType().equals("org.thingsboard.rule.engine.telemetry.TbMsgTimeseriesNode")) {
-        break;
-      }
-      seriesIndex++;
-    }
-    // 2. SETUP CONNECTION
-    // 3. ADD RULE NODE
-    int finalSeriesIndex = seriesIndex;
-    int layoutX = 1140;
-    int layoutY = 170;
-    nodes.forEach(
-        ruleNode -> {
-          int randomNum = new Random().nextInt(50);
-          NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo();
-          nodeConnectionInfo.setFromIndex(finalSeriesIndex);
-          nodeConnectionInfo.setType(connectionType);
-          nodeConnectionInfo.setToIndex(ruleChainMetaData.getNodes().size());
-          ObjectNode objectNode = JacksonUtil.newObjectNode();
-          objectNode.put("description", "");
-          objectNode.put("layoutX", layoutX + randomNum);
-          objectNode.put("layoutY", layoutY + randomNum);
-          ruleNode.setAdditionalInfo(objectNode);
-          ruleChainMetaData.getConnections().add(nodeConnectionInfo);
-          ruleChainMetaData.getNodes().add(ruleNode);
-        });
-  }
-  /**
-   * 删除规则节点
-   *
-   * @param nodes 要删除的规则节点
-   * @param ruleChainMetaData 规则链元数据
-   */
-  private boolean deleteRuleNode(
-      List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData, Integer nodeType) {
-    boolean needDelete;
-    if (nodeType.intValue() == FastIotConstants.CONVERT_DATA.intValue()) {
-      needDelete = deleteConvertConfig(nodes, ruleChainMetaData);
-    } else {
-      needDelete = deleteConvertJS(nodes, ruleChainMetaData);
-    }
-    return needDelete;
-  }
-
-  private boolean deleteConvertConfig(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData) {
-    boolean needDelete = true;
-    // refactoring RuleChainMetaData
-    AtomicInteger matchNode = new AtomicInteger(0);
-    nodes.forEach(
-        deleteRuleNode -> {
-          int deleteFlag = 0;
-          List<RuleNode> normalRuleNode = new ArrayList<>();
-          List<NodeConnectionInfo> nodeConnectionInfos = ruleChainMetaData.getConnections();
-          for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
-            if (deleteRuleNode.getName().equals(ruleNode.getName())
-                && deleteRuleNode.getType().equals(ruleNode.getType())) {
-              ruleChainMetaData.setFirstNodeIndex(ruleChainMetaData.getFirstNodeIndex() - 1);
-              List<NodeConnectionInfo> normalConnectionInfos = new ArrayList<>();
-              for (NodeConnectionInfo nodeConnectionInfo : nodeConnectionInfos) {
-                int fromIndex = nodeConnectionInfo.getFromIndex();
-                int toIndex = nodeConnectionInfo.getToIndex();
-                if (fromIndex != deleteFlag && toIndex != deleteFlag) {
-                  nodeConnectionInfo.setFromIndex(
-                      Math.max(fromIndex > deleteFlag ? fromIndex - 1 : fromIndex, 0));
-                  nodeConnectionInfo.setToIndex(
-                      Math.max(toIndex > deleteFlag ? toIndex - 1 : toIndex, 0));
-                  normalConnectionInfos.add(nodeConnectionInfo);
-                }
-              }
-              ruleChainMetaData.setConnections(normalConnectionInfos);
-              matchNode.getAndIncrement();
-            } else {
-              normalRuleNode.add(ruleNode);
-            }
-            deleteFlag++;
-          }
-          ruleChainMetaData.setNodes(normalRuleNode);
-        });
-    if (matchNode.get() == 0) {
-      needDelete = false;
-    }
-    return needDelete;
-  }
-
-  private boolean deleteConvertJS(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData) {
-    boolean needDelete = false;
-    // 1. Get firstNodeIndex
-    int firstNodeIndex = ruleChainMetaData.getFirstNodeIndex();
-    // 2. Get Delete Rule Node
-    RuleNode deleteRuleNode = nodes.get(0);
-    // 3. RuleChainMetaData Delete Rule Node
-    int deleteFlag = 0;
-    for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
-      if (ruleNode.getName().equals(deleteRuleNode.getName())
-          && ruleNode.getType().equals(deleteRuleNode.getType())) {
-        needDelete = true;
-        break;
-      }
-      deleteFlag++;
-    }
-    if (needDelete) {
-      ruleChainMetaData.getNodes().remove(deleteFlag);
-      // 4. Delete Connection
-      List<NodeConnectionInfo> newConnections = new ArrayList<>();
-      ruleChainMetaData
-          .getConnections()
-          .forEach(
-              connectionInfo -> {
-                int toIndex = connectionInfo.getToIndex();
-                int fromIndex = connectionInfo.getFromIndex();
-                if (firstNodeIndex != connectionInfo.getToIndex() && fromIndex != firstNodeIndex) {
-                  connectionInfo.setFromIndex(
-                      Math.max(fromIndex > firstNodeIndex ? fromIndex - 1 : fromIndex, 0));
-                  connectionInfo.setToIndex(
-                      Math.max(toIndex > firstNodeIndex ? toIndex - 1 : toIndex, 0));
-                  newConnections.add(connectionInfo);
-                }
-              });
-
-      int deviceProfileNodeIndex = 0;
-      ruleChainMetaData.setConnections(newConnections);
-      // 5. Set firstNodeIndex
-      for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
-        if (ruleNode.getName().equals("Device Profile Node")
-            && ruleNode
-                .getType()
-                .equals("org.thingsboard.rule.engine.profile.TbDeviceProfileNode")) {
-          ruleChainMetaData.setFirstNodeIndex(deviceProfileNodeIndex);
-          break;
-        }
-        deviceProfileNodeIndex++;
-      }
-    }
-    return needDelete;
-  }
-
   private ResponseEntity<Boolean> delete(DeleteDTO deleteDTO, Integer nodeType)
       throws ThingsboardException {
     List<RuleNode> nodes =

 package org.thingsboard.server.common.data.yunteng.dto;
 
+import com.fasterxml.jackson.databind.JsonNode;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import org.thingsboard.server.common.data.yunteng.common.UpdateGroup;
 
 import javax.validation.constraints.NotEmpty;
 import javax.validation.constraints.NotNull;
-import java.util.List;
 
 @Data
-public class ConvertJSReqDTO {
+public class ConvertReqDTO {
 
-    @ApiModelProperty(value = "转换脚本id",required = true)
+    @ApiModelProperty(value = "id",required = true)
     @NotEmpty(message = "id不能为null",groups = UpdateGroup.class)
     private String id;
 
     @ApiModelProperty(value = "状态：0禁用 1启用",required = true)
     @NotNull(message = "状态不能为空",groups = UpdateGroup.class)
     private Integer status;
+
+    private JsonNode configuration;
 }

@@ -2,11 +2,15 @@ package org.thingsboard.server.dao.yunteng.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.fasterxml.jackson.databind.node.ObjectNode;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.thingsboard.common.util.JacksonUtil;
+import org.thingsboard.server.common.data.rule.NodeConnectionInfo;
+import org.thingsboard.server.common.data.rule.RuleChainMetaData;
 import org.thingsboard.server.common.data.rule.RuleNode;
 import org.thingsboard.server.common.data.yunteng.constant.FastIotConstants;
 import org.thingsboard.server.common.data.yunteng.core.exception.YtDataValidationException;
@@ -22,6 +26,8 @@ import org.thingsboard.server.dao.yunteng.service.ConvertConfigService;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.Random;
+import java.util.concurrent.atomic.AtomicInteger;
 
 @Slf4j
 @Service
@@ -29,6 +35,7 @@ import java.util.Map;
 public class ConvertConfigServiceImpl
     extends AbstractBaseService<ConvertConfigMapper, ConvertConfig>
     implements ConvertConfigService {
+  private final String connectionType = "Success";
 
   @Override
   public YtPageData<ConvertConfigDTO> page(String tenantId, Map<String, Object> queryMap) {
@@ -165,4 +172,264 @@ public class ConvertConfigServiceImpl
             .size()
         > FastIotConstants.MagicNumber.ZERO;
   }
+  /**
+   * 删除规则节点
+   *
+   * @param nodes 要删除的规则节点
+   * @param ruleChainMetaData 规则链元数据
+   */
+  @Override
+  public boolean deleteRuleNode(
+      List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData, Integer nodeType) {
+    boolean needDelete;
+    if (nodeType.intValue() == FastIotConstants.CONVERT_DATA.intValue()) {
+      needDelete = deleteConvertConfig(nodes, ruleChainMetaData);
+    } else if (nodeType.intValue() == FastIotConstants.JAVA_SCRIPT.intValue()) {
+      needDelete = deleteConvertJS(nodes, ruleChainMetaData);
+    } else {
+      needDelete = deleteScene(nodes.get(0), ruleChainMetaData);
+    }
+    return needDelete;
+  }
+
+  @Override
+  public void addRuleNode(
+      List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData, Integer nodeType) {
+    if (nodeType.intValue() == FastIotConstants.CONVERT_DATA.intValue()) {
+      addConvertConfigRuleNode(nodes, ruleChainMetaData);
+    } else if (nodeType.intValue() == FastIotConstants.JAVA_SCRIPT.intValue()) {
+      addConvertJSRuleNode(nodes, ruleChainMetaData);
+    } else {
+      addSceneRuleNode(nodes.get(0), ruleChainMetaData);
+    }
+  }
+
+  private boolean deleteConvertJS(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData) {
+    boolean needDelete = false;
+    // 1. Get firstNodeIndex
+    int firstNodeIndex = ruleChainMetaData.getFirstNodeIndex();
+    // 2. Get Delete Rule Node
+    RuleNode deleteRuleNode = nodes.get(0);
+    // 3. RuleChainMetaData Delete Rule Node
+    int deleteFlag = 0;
+    for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
+      if (ruleNode.getName().equals(deleteRuleNode.getName())
+          && ruleNode.getType().equals(deleteRuleNode.getType())) {
+        needDelete = true;
+        break;
+      }
+      deleteFlag++;
+    }
+    if (needDelete) {
+      ruleChainMetaData.getNodes().remove(deleteFlag);
+      // 4. Delete Connection
+      List<NodeConnectionInfo> newConnections = new ArrayList<>();
+      ruleChainMetaData
+          .getConnections()
+          .forEach(
+              connectionInfo -> {
+                int toIndex = connectionInfo.getToIndex();
+                int fromIndex = connectionInfo.getFromIndex();
+                if (firstNodeIndex != connectionInfo.getToIndex() && fromIndex != firstNodeIndex) {
+                  connectionInfo.setFromIndex(
+                      Math.max(fromIndex > firstNodeIndex ? fromIndex - 1 : fromIndex, 0));
+                  connectionInfo.setToIndex(
+                      Math.max(toIndex > firstNodeIndex ? toIndex - 1 : toIndex, 0));
+                  newConnections.add(connectionInfo);
+                }
+              });
+
+      int deviceProfileNodeIndex = 0;
+      ruleChainMetaData.setConnections(newConnections);
+      // 5. Set firstNodeIndex
+      for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
+        if (ruleNode.getName().equals("Device Profile Node")
+            && ruleNode
+                .getType()
+                .equals("org.thingsboard.rule.engine.profile.TbDeviceProfileNode")) {
+          ruleChainMetaData.setFirstNodeIndex(deviceProfileNodeIndex);
+          break;
+        }
+        deviceProfileNodeIndex++;
+      }
+    }
+    return needDelete;
+  }
+
+  private boolean deleteConvertConfig(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData) {
+    boolean needDelete = true;
+    // refactoring RuleChainMetaData
+    AtomicInteger matchNode = new AtomicInteger(0);
+    nodes.forEach(
+        deleteRuleNode -> {
+          int deleteFlag = 0;
+          List<RuleNode> normalRuleNode = new ArrayList<>();
+          List<NodeConnectionInfo> nodeConnectionInfos = ruleChainMetaData.getConnections();
+          for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
+            if (deleteRuleNode.getName().equals(ruleNode.getName())
+                && deleteRuleNode.getType().equals(ruleNode.getType())) {
+              ruleChainMetaData.setFirstNodeIndex(ruleChainMetaData.getFirstNodeIndex() - 1);
+              List<NodeConnectionInfo> normalConnectionInfos = new ArrayList<>();
+              for (NodeConnectionInfo nodeConnectionInfo : nodeConnectionInfos) {
+                int fromIndex = nodeConnectionInfo.getFromIndex();
+                int toIndex = nodeConnectionInfo.getToIndex();
+                if (fromIndex != deleteFlag && toIndex != deleteFlag) {
+                  nodeConnectionInfo.setFromIndex(
+                      Math.max(fromIndex > deleteFlag ? fromIndex - 1 : fromIndex, 0));
+                  nodeConnectionInfo.setToIndex(
+                      Math.max(toIndex > deleteFlag ? toIndex - 1 : toIndex, 0));
+                  normalConnectionInfos.add(nodeConnectionInfo);
+                }
+              }
+              ruleChainMetaData.setConnections(normalConnectionInfos);
+              matchNode.getAndIncrement();
+            } else {
+              normalRuleNode.add(ruleNode);
+            }
+            deleteFlag++;
+          }
+          ruleChainMetaData.setNodes(normalRuleNode);
+        });
+    if (matchNode.get() == 0) {
+      needDelete = false;
+    }
+    return needDelete;
+  }
+
+  private boolean deleteScene(RuleNode node, RuleChainMetaData ruleChainMetaData) {
+    int deleteIndex = 0;
+    boolean needDelete = false;
+    for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
+      if (ruleNode.getName().equals(node.getName()) && ruleNode.getType().equals(node.getType())) {
+        needDelete = true;
+        break;
+      }
+      deleteIndex++;
+    }
+    if (needDelete) {
+      // Delete Rule Node
+      ruleChainMetaData.getNodes().remove(deleteIndex);
+      List<NodeConnectionInfo> newConnections = new ArrayList<>();
+      int finalDeleteIndex = deleteIndex;
+      // refactor connection
+      ruleChainMetaData
+          .getConnections()
+          .forEach(
+              nodeConnectionInfo -> {
+                int fromIndex = nodeConnectionInfo.getFromIndex();
+                int toIndex = nodeConnectionInfo.getToIndex();
+                if (finalDeleteIndex != nodeConnectionInfo.getToIndex()
+                    && nodeConnectionInfo.getFromIndex() != finalDeleteIndex) {
+                  nodeConnectionInfo.setFromIndex(
+                      Math.max(fromIndex > finalDeleteIndex ? fromIndex - 1 : fromIndex, 0));
+                  nodeConnectionInfo.setToIndex(
+                      Math.max(toIndex > finalDeleteIndex ? toIndex - 1 : toIndex, 0));
+                  newConnections.add(nodeConnectionInfo);
+                }
+              });
+      ruleChainMetaData.setConnections(newConnections);
+      ruleChainMetaData.setFirstNodeIndex(ruleChainMetaData.getFirstNodeIndex() - 1);
+    }
+    return needDelete;
+  }
+
+  private void addConvertConfigRuleNode(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData) {
+    // 1. GET SAVE TIMESERIES‘S NODE INDEX
+    int seriesIndex = 0;
+    for (RuleNode ruleNode : ruleChainMetaData.getNodes()) {
+      if (ruleNode.getType().equals("org.thingsboard.rule.engine.telemetry.TbMsgTimeseriesNode")) {
+        break;
+      }
+      seriesIndex++;
+    }
+    // 2. SETUP CONNECTION
+    // 3. ADD RULE NODE
+    int finalSeriesIndex = seriesIndex;
+    int layoutX = 1140;
+    int layoutY = 170;
+    nodes.forEach(
+        ruleNode -> {
+          NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo();
+          nodeConnectionInfo.setFromIndex(finalSeriesIndex);
+          nodeConnectionInfo.setType(connectionType);
+          nodeConnectionInfo.setToIndex(ruleChainMetaData.getNodes().size());
+          ObjectNode objectNode = setAdditionalInfo(layoutX, layoutY);
+          ruleNode.setAdditionalInfo(objectNode);
+          ruleChainMetaData.getConnections().add(nodeConnectionInfo);
+          ruleChainMetaData.getNodes().add(ruleNode);
+        });
+  }
+
+  private void addConvertJSRuleNode(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData) {
+    // 1. Get Device Profile nodeIndex
+    int firstNodeIndex = ruleChainMetaData.getFirstNodeIndex();
+    // 2. Add Rule Node
+    RuleNode ruleNode = nodes.get(0);
+    int layoutX = 202;
+    int layoutY = 53;
+    ObjectNode objectNode = setAdditionalInfo(layoutX, layoutY);
+    ruleNode.setAdditionalInfo(objectNode);
+    ruleChainMetaData.getNodes().add(ruleNode);
+    int newFirstNodeIndex = ruleChainMetaData.getNodes().size() - 1;
+    ruleChainMetaData.setFirstNodeIndex(newFirstNodeIndex);
+    // 3. Add Connection
+    NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo();
+    nodeConnectionInfo.setFromIndex(newFirstNodeIndex);
+    nodeConnectionInfo.setType(connectionType);
+    nodeConnectionInfo.setToIndex(firstNodeIndex);
+    ruleChainMetaData.getConnections().add(nodeConnectionInfo);
+  }
+
+  private void addSceneRuleNode(RuleNode ruleNode, RuleChainMetaData ruleChainMetaData) {
+    boolean existScene = false;
+    // check scene exist
+    for (RuleNode node : ruleChainMetaData.getNodes()) {
+      if (ruleNode.getName().equals(node.getName()) && ruleNode.getType().equals(node.getType())) {
+        node.setConfiguration(ruleNode.getConfiguration());
+        existScene = true;
+        break;
+      }
+    }
+    if (!existScene) {
+      // get Save Timeseries Save Client Attributes
+      AtomicInteger ruleNodeIndex = new AtomicInteger();
+      int layoutX = 1128;
+      int layoutY = 132;
+      ObjectNode objectNode = setAdditionalInfo(layoutX, layoutY);
+      ruleNode.setAdditionalInfo(objectNode);
+      ruleChainMetaData.getNodes().add(ruleNode);
+      ruleChainMetaData
+          .getNodes()
+          .forEach(
+              node -> {
+                if (node.getType()
+                        .equals("org.thingsboard.rule.engine.telemetry.TbMsgTimeseriesNode")
+                    || node.getType()
+                        .equals("org.thingsboard.rule.engine.telemetry.TbMsgAttributesNode")) {
+                  NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo();
+                  nodeConnectionInfo.setFromIndex(ruleNodeIndex.get());
+                  nodeConnectionInfo.setToIndex(ruleChainMetaData.getNodes().size() - 1);
+                  nodeConnectionInfo.setType(connectionType);
+                  ruleChainMetaData.getConnections().add(nodeConnectionInfo);
+                }
+                if (node.getType().equals("org.thingsboard.rule.engine.rpc.TbSendRPCRequestNode")) {
+                  NodeConnectionInfo nodeConnectionInfo = new NodeConnectionInfo();
+                  nodeConnectionInfo.setFromIndex(ruleChainMetaData.getNodes().size() - 1);
+                  nodeConnectionInfo.setToIndex(ruleNodeIndex.get());
+                  nodeConnectionInfo.setType("RPC Request");
+                  ruleChainMetaData.getConnections().add(nodeConnectionInfo);
+                }
+                ruleNodeIndex.getAndIncrement();
+              });
+    }
+  }
+
+  private ObjectNode setAdditionalInfo(int layoutX, int layoutY) {
+    int randomNum = new Random().nextInt(50);
+    ObjectNode objectNode = JacksonUtil.newObjectNode();
+    objectNode.put("description", "");
+    objectNode.put("layoutX", layoutX + randomNum);
+    objectNode.put("layoutY", layoutY + randomNum);
+    return objectNode;
+  }
 }

 package org.thingsboard.server.dao.yunteng.service;
 
+import org.thingsboard.server.common.data.rule.RuleChainMetaData;
 import org.thingsboard.server.common.data.rule.RuleNode;
 import org.thingsboard.server.common.data.yunteng.dto.ConvertConfigDTO;
 import org.thingsboard.server.common.data.yunteng.dto.DeleteDTO;
@@ -54,4 +55,9 @@ public interface ConvertConfigService extends BaseService<ConvertConfig> {
    * @return true已启用 false未启用
    */
   boolean checkConvertJSStatusEnable(String tenantId);
+
+  boolean deleteRuleNode(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData, Integer nodeType);
+
+  void addRuleNode(List<RuleNode> nodes, RuleChainMetaData ruleChainMetaData, Integer nodeType);
+
 }

@@ -25,7 +25,8 @@ public class TbSceneReactNodeConfig implements NodeConfiguration<TbSceneReactNod
     @Override
     public TbSceneReactNodeConfig defaultConfiguration() {
         TbSceneReactNodeConfig config = new TbSceneReactNodeConfig();
-        config.setScenes(new HashMap<>());
+        Map<String, List<String>> sceneMap = new HashMap<>();
+        config.setScenes(sceneMap);
         return config;
     }
 }