فهرست منبع

fix(系统配置): 修复可能无法报错系统配置

zhouhao 2 سال پیش
والد
کامیت
3f3f06a8e6

+ 5 - 11
jetlinks-components/common-component/src/main/java/org/jetlinks/community/config/SimpleConfigManager.java

@@ -73,17 +73,11 @@ public class SimpleConfigManager implements ConfigManager, ConfigScopeManager {
 
     @Override
     public Mono<Void> setProperties(String scope, Map<String, Object> values) {
-        return Flux
-            .fromIterable(values.entrySet())
-            .map(e -> {
-                ConfigEntity entity = new ConfigEntity();
-                entity.setProperties(values);
-                entity.setScope(scope);
-                entity.getId();
-                return entity;
-            })
-            .as(repository::save)
-            .then();
+        ConfigEntity entity = new ConfigEntity();
+        entity.setProperties(values);
+        entity.setScope(scope);
+        entity.getId();
+        return repository.save(entity).then();
     }
 
 }