manager/c-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增获取磁盘主机的信息

Browse Source
This commit is contained in:
gaoxq
2025-08-24 21:16:27 +08:00
parent db93f2a952
commit da2b2cf14c
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/mini/capi/job/taskEnable.java
View File

@@ -1,6 +1,6 @@
package com.mini.capi.job; package com.mini.capi.job;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.mini.capi.biz.domain.*; import com.mini.capi.biz.domain.*;
import com.mini.capi.biz.service.*; import com.mini.capi.biz.service.*;
import com.mini.capi.utils.HostInfo; import com.mini.capi.utils.HostInfo;
@@ -8,13 +8,16 @@ import com.mini.capi.utils.vDate;
import com.mini.capi.utils.vId; import com.mini.capi.utils.vId;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.springframework.scheduling.annotation.Scheduled; 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.*;
import java.util.function.Function; import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Controller @RestController
@RequestMapping("/Sys/jobs")
public class taskEnable { public class taskEnable {
@@ -35,6 +38,7 @@ public class taskEnable {
@Scheduled(cron = "0 0/10 * * * ?") @Scheduled(cron = "0 0/10 * * * ?")
@GetMapping("/getTaskDockerDiskInfo")
public void jobHostDisk() { public void jobHostDisk() {
List<DockerHost> dockerHosts = dockerHostService.list(); List<DockerHost> dockerHosts = dockerHostService.list();
for (DockerHost host : dockerHosts) { for (DockerHost host : dockerHosts) {
@@ -79,10 +83,8 @@ public class taskEnable {
d.setUpdateTime(vDate.getNow()); d.setUpdateTime(vDate.getNow());
toSaveOrUpdate.add(d); toSaveOrUpdate.add(d);
} }
/* 4. 批量保存/更新 */ /* 4. 批量保存/更新 */
diskMountService.saveOrUpdateBatch(toSaveOrUpdate); diskMountService.saveOrUpdateBatch(toSaveOrUpdate);
/* 5. 删除实时已消失的盘 */ /* 5. 删除实时已消失的盘 */
List<String> delIds = dbDisks.stream() List<String> delIds = dbDisks.stream()
.filter(d -> !liveMountPoint.contains(d.getMountPoint())) .filter(d -> !liveMountPoint.contains(d.getMountPoint()))