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()))