From da2b2cf14c9f06b93889f126beb0cce644d0e4ef Mon Sep 17 00:00:00 2001 From: gaoxq <376340421@qq.com> Date: Sun, 24 Aug 2025 21:16:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E8=8E=B7=E5=8F=96=E7=A3=81?= =?UTF-8?q?=E7=9B=98=E4=B8=BB=E6=9C=BA=E7=9A=84=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/mini/capi/job/taskEnable.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/mini/capi/job/taskEnable.java b/src/main/java/com/mini/capi/job/taskEnable.java index c515c15..da910c0 100644 --- a/src/main/java/com/mini/capi/job/taskEnable.java +++ b/src/main/java/com/mini/capi/job/taskEnable.java @@ -1,6 +1,6 @@ package com.mini.capi.job; -import com.baomidou.mybatisplus.core.toolkit.Wrappers; + import com.mini.capi.biz.domain.*; import com.mini.capi.biz.service.*; import com.mini.capi.utils.HostInfo; @@ -8,13 +8,16 @@ import com.mini.capi.utils.vDate; import com.mini.capi.utils.vId; import jakarta.annotation.Resource; import org.springframework.scheduling.annotation.Scheduled; -import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; import java.util.*; import java.util.function.Function; import java.util.stream.Collectors; -@Controller +@RestController +@RequestMapping("/Sys/jobs") public class taskEnable { @@ -35,6 +38,7 @@ public class taskEnable { @Scheduled(cron = "0 0/10 * * * ?") + @GetMapping("/getTaskDockerDiskInfo") public void jobHostDisk() { List dockerHosts = dockerHostService.list(); for (DockerHost host : dockerHosts) { @@ -79,10 +83,8 @@ public class taskEnable { d.setUpdateTime(vDate.getNow()); toSaveOrUpdate.add(d); } - /* 4. 批量保存/更新 */ diskMountService.saveOrUpdateBatch(toSaveOrUpdate); - /* 5. 删除实时已消失的盘 */ List delIds = dbDisks.stream() .filter(d -> !liveMountPoint.contains(d.getMountPoint()))