refactor: 优化设备会话持久化逻辑

Author: zhou-hao

jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/cluster/Cluster.java

@@ -1,11 +1,66 @@
 package org.jetlinks.community.configure.cluster;
 
+import org.apache.commons.collections4.MapUtils;
+import org.springframework.core.env.Environment;
+
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+
 public class Cluster {
 
-    static String ID = "default";
+    public static final String TAG_NAME = "name";
+    public static final String TAG_ID = "id";
+    private static String ID = "default";
+    private static String SAFE_ID = "default";
 
+    private static String NAME = "default";
+    private static Map<String, String> TAGS = Collections.emptyMap();
 
     public static String id() {
         return ID;
     }
+
+    public static String name() {
+        return NAME;
+    }
+
+    public static String safeId() {
+        return SAFE_ID;
+    }
+
+    public static Map<String, String> tags() {
+        return TAGS;
+    }
+
+    public static boolean hasTag(Map<String, String> tag) {
+        if (MapUtils.isEmpty(tag)) {
+            return false;
+        }
+        for (Map.Entry<String, String> entry : tag.entrySet()) {
+            if (!Objects.equals(TAGS.get(entry.getKey()), entry.getValue())) {
+                return false;
+            }
+        }
+        return true;
+    }
+
+    public static synchronized void setup(Environment env){
+        Map<String, String> _tags = new HashMap<>(TAGS);
+        _tags.put("port",env.getProperty("server.port"));
+
+    }
+
+    public static synchronized void setup(String id, String name, Map<String, String> tags) {
+        ID = id;
+        SAFE_ID = ID.replaceAll("[\\s\\\\/:*?\"<>|]", "_");
+
+        NAME = name;
+        Map<String, String> _tags = new HashMap<>(tags);
+        _tags.putIfAbsent(TAG_NAME, name);
+        _tags.putIfAbsent(TAG_ID, id);
+        TAGS = Collections.unmodifiableMap(_tags);
+    }
+
 }