소스 검색

项目中止

martin 2 년 전
부모
커밋
41300663d3
1개의 변경된 파일3개의 추가작업 그리고 7개의 파일을 삭제
  1. 3 7
      simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/service/ProjectService.java

+ 3 - 7
simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/service/ProjectService.java

@@ -399,13 +399,9 @@ public class ProjectService {
         KubernetesUtil.deleteJob(apiClient, kubernetesNamespace, prefix);
 
         //3 删除所有 redis key
-//        PrefixTO redisPrefix = projectUtil.getRedisPrefixByProjectIdAndProjectType(projectId, type);
-//        Set<String> keys = stringRedisTemplate.keys(redisPrefix.getProjectRunningKey() + "*");
-//        if (CollectionUtil.isNotEmpty(keys)) {
-//            for (String key : keys) {
-//                stringRedisTemplate.delete(key);
-//            }
-//        }
+        PrefixTO redisPrefix = projectUtil.getRedisPrefixByProjectIdAndProjectType(projectId, projectType);
+        RedisUtil.deleteByPrefix(stringRedisTemplate, redisPrefix.getProjectRunningKey());
+        RedisUtil.deleteByPrefix(stringRedisTemplate, redisPrefix.getProjectWaitingKey());
     }