fix: 组态相关逻辑优化

1、更新或新增，同时刷新组件数据。
2、删除时，同时清空组件数据。

@@ -8,6 +8,7 @@ import org.thingsboard.server.common.data.yunteng.common.UpdateGroup;
 
 import javax.validation.constraints.NotEmpty;
 import javax.validation.constraints.NotNull;
+import java.util.List;
 
 @EqualsAndHashCode(callSuper = true)
 @Data
@@ -38,4 +39,6 @@ public class ConfigurationContentDTO extends TenantDTO {
       message = "类型不能为空",
       groups = {UpdateGroup.class, AddGroup.class})
   private Integer type;
+
+  private List<String> nodeIds;
 }

@@ -37,10 +37,55 @@ public class YtConfigurationContentServiceImpl
   @Transactional
   public ConfigurationContentDTO saveConfigurationContent(
       ConfigurationContentDTO configurationContentDTO) {
+    freshNodeData(configurationContentDTO.getTenantId(), configurationContentDTO.getId(), configurationContentDTO.getNodeIds());
     baseMapper.insert(configurationContentDTO.getEntity(ConfigurationContent.class));
     return configurationContentDTO;
   }
 
+  /**
+   * 刷新组态的结点数据
+   * @param tenantId    租户ID
+   * @param contentId   页签ID
+   * @param nodeIds     页面内组件集合
+   */
+  private void freshNodeData(String tenantId,String contentId,List<String> nodeIds){
+    LambdaQueryWrapper<ConfigurationDatasource> datasourceFilter = new QueryWrapper<ConfigurationDatasource>().lambda()
+            .eq(ConfigurationDatasource::getTenantId,tenantId)
+            .eq(ConfigurationDatasource::getContentId,contentId);
+    List<ConfigurationDatasource>  datasources =datasourceMapper.selectList(datasourceFilter);
+    datasources.forEach(item ->{
+      if(nodeIds == null
+              || nodeIds.isEmpty()
+              || !nodeIds.contains(item.getNodeId())){
+        datasourceMapper.deleteById(item.getId());
+      }
+    });
+
+    LambdaQueryWrapper<ConfigurationEvent> eventFilter = new QueryWrapper<ConfigurationEvent>().lambda()
+            .eq(ConfigurationEvent::getTenantId,tenantId)
+            .eq(ConfigurationEvent::getContentId,contentId);
+    List<ConfigurationEvent>  events =eventMapper.selectList(eventFilter);
+    events.forEach(item ->{
+      if(nodeIds == null
+              || nodeIds.isEmpty()
+              || !nodeIds.contains(item.getId())){
+        eventMapper.deleteById(item.getId());
+      }
+    });
+
+    LambdaQueryWrapper<ConfigurationAct> actFilter = new QueryWrapper<ConfigurationAct>().lambda()
+            .eq(ConfigurationAct::getTenantId,tenantId)
+            .eq(ConfigurationAct::getContentId,contentId);
+    List<ConfigurationAct>  acts =actMapper.selectList(actFilter);
+    acts.forEach(item ->{
+      if(nodeIds == null
+              || nodeIds.isEmpty()
+              || !nodeIds.contains(item.getId())){
+        actMapper.deleteById(item.getId());
+      }
+    });
+  }
+
   @Override
   @Transactional
   public ConfigurationContentDTO updateConfigurationContent(
@@ -50,6 +95,7 @@ public class YtConfigurationContentServiceImpl
     if (!configurationContent.getTenantId().equals(configurationContentDTO.getTenantId())) {
       throw new YtDataValidationException(ErrorMessage.TENANT_MISMATCHING.getMessage());
     }
+    freshNodeData(configurationContentDTO.getTenantId(), configurationContentDTO.getId(), configurationContentDTO.getNodeIds());
     baseMapper.updateById(configurationContentDTO.getEntity(ConfigurationContent.class));
     return configurationContentDTO;
   }
@@ -66,27 +112,39 @@ public class YtConfigurationContentServiceImpl
         throw new YtDataValidationException(ErrorMessage.TENANT_MISMATCHING.getMessage());
       }
     }
+    deleteNodeDatas(null,deleteDTO.getIds());
     return baseMapper.deleteBatchIds(deleteDTO.getIds()) > FastIotConstants.MagicNumber.ZERO;
   }
 
   @Override
   @Transactional
   public boolean deleteConfigurationContentByCenterId(Set<String> configurationCenterIds) {
+    deleteNodeDatas(configurationCenterIds,null);
+    return baseMapper.delete(
+            new LambdaQueryWrapper<ConfigurationContent>()
+                .in(ConfigurationContent::getConfigurationId, configurationCenterIds))
+        > FastIotConstants.MagicNumber.ZERO;
+  }
+
+  /**
+   * 清除组件数据
+   * @param configIds
+   * @param contentIds
+   */
+  private void deleteNodeDatas(Set<String> configIds,Set<String> contentIds) {
     LambdaQueryWrapper<ConfigurationDatasource> dataFilter = new QueryWrapper<ConfigurationDatasource>().lambda()
-            .in(ConfigurationDatasource::getConfigurationId,configurationCenterIds);
+            .in(configIds!=null,ConfigurationDatasource::getConfigurationId, configIds)
+            .in(contentIds!=null,ConfigurationDatasource::getContentId, contentIds);
     datasourceMapper.delete(dataFilter);
 
     LambdaQueryWrapper<ConfigurationEvent> eventFilter = new QueryWrapper<ConfigurationEvent>().lambda()
-            .in(ConfigurationEvent::getConfigurationId,configurationCenterIds);
+            .in(contentIds!=null,ConfigurationEvent::getContentId, contentIds)
+            .in(configIds!=null,ConfigurationEvent::getConfigurationId, configIds);
     eventMapper.delete(eventFilter);
 
     LambdaQueryWrapper<ConfigurationAct> actFilter = new QueryWrapper<ConfigurationAct>().lambda()
-            .in(ConfigurationAct::getConfigurationId,configurationCenterIds);
+            .in(contentIds!=null,ConfigurationAct::getContentId, contentIds)
+            .in(configIds!=null,ConfigurationAct::getConfigurationId, configIds);
     actMapper.delete(actFilter);
-
-    return baseMapper.delete(
-            new LambdaQueryWrapper<ConfigurationContent>()
-                .in(ConfigurationContent::getConfigurationId, configurationCenterIds))
-        > FastIotConstants.MagicNumber.ZERO;
   }
 }