From 2c891e5d208615295c4b433a5082051bfdb8a40e Mon Sep 17 00:00:00 2001 From: zhouhao Date: Wed, 9 Jul 2025 21:04:32 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../community/device/service/DeviceCategoryService.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceCategoryService.java b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceCategoryService.java index 88e7633e..cc5a169a 100755 --- a/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceCategoryService.java +++ b/jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceCategoryService.java @@ -28,6 +28,7 @@ import org.springframework.stereotype.Service; import org.springframework.util.StreamUtils; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; +import reactor.core.scheduler.Schedulers; import java.io.InputStream; import java.nio.charset.StandardCharsets; @@ -79,7 +80,8 @@ public class DeviceCategoryService extends GenericReactiveTreeSupportCrudService private Mono initDefaultData() { return Mono .fromCallable(() -> { - ClassPathResource resource = new ClassPathResource("device-category.json"); + ClassPathResource resource = new ClassPathResource("device-category.json", + DeviceCategoryService.class.getClassLoader()); try (InputStream stream = resource.getInputStream()) { String json = StreamUtils.copyToString(stream, StandardCharsets.UTF_8); @@ -103,6 +105,7 @@ public class DeviceCategoryService extends GenericReactiveTreeSupportCrudService } }) + .subscribeOn(Schedulers.boundedElastic()) .flatMap(all -> save(Flux.fromIterable(all))) .then(); }