From 6f9d1f14d54fa59fe876daa999c0484841bd4cf3 Mon Sep 17 00:00:00 2001 From: lihongjie0209 Date: Sat, 6 Apr 2024 21:57:59 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=88=9B=E5=BB=BA=E9=98=9F?= =?UTF-8?q?=E5=88=97=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/DataCollectorController.java | 9 +++++++++ .../coal/dataCollector/service/DataCollectorService.java | 2 +- 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/src/main/java/cn/lihongjie/coal/dataCollector/controller/DataCollectorController.java b/src/main/java/cn/lihongjie/coal/dataCollector/controller/DataCollectorController.java index f524451c..820f4334 100644 --- a/src/main/java/cn/lihongjie/coal/dataCollector/controller/DataCollectorController.java +++ b/src/main/java/cn/lihongjie/coal/dataCollector/controller/DataCollectorController.java @@ -31,6 +31,9 @@ public class DataCollectorController { return this.service.create(request); } + + + @PostMapping("/update") public DataCollectorDto update(@RequestBody UpdateDataCollectorDto request) { return this.service.update(request); @@ -42,6 +45,12 @@ public class DataCollectorController { return true; } + @PostMapping("/createQueue") + public Object createQueue(@RequestBody IdRequest request) { + this.service.createQueue(request); + return true; + } + @PostMapping("/getById") public DataCollectorDto getById(@RequestBody IdRequest request) { return this.service.getById(request.getId()); diff --git a/src/main/java/cn/lihongjie/coal/dataCollector/service/DataCollectorService.java b/src/main/java/cn/lihongjie/coal/dataCollector/service/DataCollectorService.java index a5248fa4..4b30f585 100644 --- a/src/main/java/cn/lihongjie/coal/dataCollector/service/DataCollectorService.java +++ b/src/main/java/cn/lihongjie/coal/dataCollector/service/DataCollectorService.java @@ -83,7 +83,7 @@ public class DataCollectorService this.repository.deleteAllById(request.getIds()); } public void createQueue(IdRequest request) { - this.repository.deleteAllById(request.getIds()); + this.repository.findAllById(request.getIds()).forEach(this::createQueue); } public DataCollectorDto getById(String id) {