suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: 优化

This commit is contained in:
zhouhao 2025-07-09 21:04:32 +08:00
parent 6e3c92dc48
commit 2c891e5d20
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
jetlinks-manager/device-manager/src/main/java/org/jetlinks/community/device/service/DeviceCategoryService.java
View File

@ -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<Void> 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();
}