add nest parse

lhpqaq · Dec 16, 2024 · d511e76 · d511e76
1 parent ca05ce0
commit d511e76
Show file tree

Hide file tree

Showing 2 changed files with 22 additions and 3 deletions.
diff --git a/...rver/src/main/java/org/apache/bigtop/manager/server/command/task/CacheFileUpdateTask.java b/...rver/src/main/java/org/apache/bigtop/manager/server/command/task/CacheFileUpdateTask.java
@@ -43,6 +43,8 @@
 import org.apache.bigtop.manager.server.model.dto.StackDTO;
 import org.apache.bigtop.manager.server.utils.StackUtils;
 
+import lombok.extern.slf4j.Slf4j;
+
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -53,6 +55,7 @@
 
 import static org.apache.bigtop.manager.common.constants.Constants.ALL_HOST_KEY;
 
+@Slf4j
 public class CacheFileUpdateTask extends AbstractTask {
 
     private ClusterDao clusterDao;
@@ -98,6 +101,18 @@ private void genCaches() {
         }
     }
 
+    private Map<String, Object> parseProperties(List<Map<String, Object>> properties) {
+        return properties.stream().collect(Collectors.toMap(property -> (String) property.get("name"), property -> {
+            if (property.containsKey("values")) {
+                @SuppressWarnings("unchecked")
+                List<Map<String, Object>> nestedProperties = (List<Map<String, Object>>) property.get("values");
+                return parseProperties(nestedProperties);
+            } else {
+                return property.get("value");
+            }
+        }));
+    }
+
     @SuppressWarnings("unchecked")
     private void genFullCaches() {
         Long clusterId = taskContext.getClusterId();
@@ -119,10 +134,11 @@ private void genFullCaches() {
         serviceConfigMap = new HashMap<>();
         for (ServiceConfigPO serviceConfigPO : serviceConfigPOList) {
             List<Map<String, Object>> properties = JsonUtils.readFromString(serviceConfigPO.getPropertiesJson());
-            Map<String, String> kvMap = properties.stream()
-                    .collect(Collectors.toMap(
-                            property -> (String) property.get("name"), property -> (String) property.get("value")));
+            log.info(properties.toString());
+            Map<String, Object> kvMap = parseProperties(properties);
+            log.info(kvMap.toString());
             String kvString = JsonUtils.writeAsString(kvMap);
+            log.info(kvString);
 
             if (serviceConfigMap.containsKey(serviceConfigPO.getServiceName())) {
                 serviceConfigMap.get(serviceConfigPO.getServiceName()).put(serviceConfigPO.getName(), kvString);

diff --git a/...-manager-server/src/main/java/org/apache/bigtop/manager/server/model/req/PropertyReq.java b/...-manager-server/src/main/java/org/apache/bigtop/manager/server/model/req/PropertyReq.java
@@ -21,6 +21,7 @@
 import lombok.Data;
 
 import jakarta.validation.constraints.NotBlank;
+import java.util.List;
 
 @Data
 public class PropertyReq {
@@ -35,4 +36,6 @@ public class PropertyReq {
     private String desc;
 
     private AttrsReq attrs;
+
+    private List<PropertyReq> values;
 }