feat: 增加删除容器定时任务的动态开关，跳过刘钦的容器

web/src/main/java/cn/seecoder/web/controller/scheduler/SchedulerController.java

@@ -0,0 +1,24 @@
+package cn.seecoder.web.controller.scheduler;
+
+import cn.seecoder.web.infrastructure.SchedulerHelper;
+import cn.seecoder.web.model.vo.scheduler.StatusVO;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.*;
+
+@RestController
+@RequestMapping("/scheduler")
+@RequiredArgsConstructor
+public class SchedulerController {
+    private final SchedulerHelper schedulerHelper;
+
+    @GetMapping("/status")
+    public StatusVO getSchedulerStatus() {
+        return new StatusVO(schedulerHelper.getEnableTasks());
+    }
+
+    @PutMapping("/set")
+    public StatusVO setSchedulerStatus(@RequestBody StatusVO statusVO) {
+        schedulerHelper.setEnableTasks(statusVO.getStatus());
+        return new StatusVO(schedulerHelper.getEnableTasks());
+    }
+}

web/src/main/java/cn/seecoder/web/infrastructure/ScheduledTasks.java

@@ -5,6 +5,8 @@ import cn.seecoder.web.dao.pipeline.DeploymentMapper;
 import cn.seecoder.web.dao.pipeline.PipelineMapper;
 import cn.seecoder.web.model.po.pipeline.DeploymentPO;
 import cn.seecoder.web.model.po.pipeline.PipelinePO;
+import cn.seecoder.web.model.vo.user.UserVO;
+import cn.seecoder.web.service.devmanage.DevmanageService;
 import cn.seecoder.web.service.pipeline.DeploymentService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -13,6 +15,7 @@ import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 import java.sql.Timestamp;
+import java.util.Arrays;
 import java.util.List;
 
 @Slf4j
@@ -23,26 +26,34 @@ public class ScheduledTasks {
     private final DeploymentService deploymentService;
     private final DeploymentMapper deploymentMapper;
     private final PipelineMapper pipelineMapper;
+    private final DevmanageService devmanageService;
+    private final String[] PHONES_TO_SKIP = new String[] {"18001585267"};
+    private final SchedulerHelper schedulerHelper;
 
-//    @Scheduled(cron = "0 0 1 * * ?")
-//    public void purgeZombieDeployments() {
-//        final long ONE_DAY_MILLIS = 86400000L;
-//        final long HALF_DAY_MILLIS = 43200000L;
-//        Timestamp expireLimit = new Timestamp(System.currentTimeMillis() - HALF_DAY_MILLIS);
-//        List<DeploymentPO> deploymentPOList = deploymentMapper.selectAllDeployments();
-//        for (DeploymentPO deploymentPO: deploymentPOList) {
-//            Timestamp deployedTime = deploymentPO.getDeployedTime();
-//            if (deployedTime.before(expireLimit)) {
-//                PipelinePO pipelinePO = pipelineMapper.selectById(deploymentPO.getPipelineId());
-//                try {
-//                    deploymentService.delete(pipelinePO.getProjectId(), deploymentPO.getPipelineId());
-//                } catch (AccessDeniedException e) {
-//                    log.error(String.format("Scheduled Deployments Purge Failed for projectId: %s, pipelineId: %s, for %s",
-//                            pipelinePO.getProjectId(),
-//                            deploymentPO.getPipelineId(),
-//                            e.getMessage()));
-//                }
-//            }
-//        }
-//    }
+    @Scheduled(cron = "0 0 1 * * ?")
+    public void purgeZombieDeployments() {
+        if (schedulerHelper.getEnableTasks()) {
+            final long ONE_DAY_MILLIS = 86400000L;
+            final long HALF_DAY_MILLIS = 43200000L;
+            Timestamp expireLimit = new Timestamp(System.currentTimeMillis() - HALF_DAY_MILLIS);
+            List<DeploymentPO> deploymentPOList = deploymentMapper.selectAllDeployments();
+            for (DeploymentPO deploymentPO : deploymentPOList) {
+                Timestamp deployedTime = deploymentPO.getDeployedTime();
+                String namespace = deploymentPO.getNamespace();
+                UserVO ownerOfNamespace = devmanageService.getOwnerOfNamespace(namespace);
+                String phone = ownerOfNamespace.getPhone();
+                if (deployedTime.before(expireLimit) && !Arrays.asList(PHONES_TO_SKIP).contains(phone)) {
+                    PipelinePO pipelinePO = pipelineMapper.selectById(deploymentPO.getPipelineId());
+                    try {
+                        deploymentService.delete(pipelinePO.getProjectId(), deploymentPO.getPipelineId());
+                    } catch (AccessDeniedException e) {
+                        log.error(String.format("Scheduled Deployments Purge Failed for projectId: %s, pipelineId: %s, for %s",
+                                pipelinePO.getProjectId(),
+                                deploymentPO.getPipelineId(),
+                                e.getMessage()));
+                    }
+                }
+            }
+        }
+    }
 }

web/src/main/java/cn/seecoder/web/infrastructure/SchedulerHelper.java

@@ -0,0 +1,12 @@
+package cn.seecoder.web.infrastructure;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.stereotype.Component;
+
+@Component
+@Getter
+@Setter
+public class SchedulerHelper {
+    private Boolean enableTasks = false;
+}

web/src/main/java/cn/seecoder/web/infrastructure/config/WebSecurityConfig.java

@@ -55,6 +55,8 @@ public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
                 .addFilterBefore(filter, UsernamePasswordAuthenticationFilter.class)
 
                 .authorizeRequests()
+                // Scheduler Controller
+                .antMatchers("/scheduler/**").hasAnyRole(SEEC_ROLE)
                 // Devmanage Controller
                 .antMatchers(GET, "/devmanage/**").hasAnyRole(SEEC_ROLE)
                 // API Test Controller

web/src/main/java/cn/seecoder/web/model/vo/scheduler/StatusVO.java

@@ -0,0 +1,12 @@
+package cn.seecoder.web.model.vo.scheduler;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@AllArgsConstructor
+public class StatusVO {
+    private Boolean status;
+}