lyhzzz преди 2 месеца
родител
ревизия
ca91893cc5
променени са 2 файла, в които са добавени 18 реда и са изтрити 41 реда
  1. 18 1
      src/main/java/com/fdkankan/fusion/task/InitService.java
  2. 0 40
      src/main/java/com/fdkankan/fusion/task/TaskService.java

+ 18 - 1
src/main/java/com/fdkankan/fusion/task/InitService.java

@@ -7,6 +7,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.fdkankan.fusion.common.util.LocalToOssUtil;
 import com.fdkankan.fusion.config.CacheUtil;
+import com.fdkankan.fusion.down.CaseDownService;
 import com.fdkankan.fusion.entity.*;
 import com.fdkankan.fusion.response.DownloadProcessVo;
 import com.fdkankan.fusion.service.*;
@@ -49,6 +50,7 @@ public class InitService {
         delMediaLibrary();
         writerStateFile();
         delRedisKey();
+        cleanRedisKey();
     }
 
 
@@ -183,7 +185,22 @@ public class InitService {
                 }
             }
         }catch (Exception e){
-            log.info("删除失败:{}",e);
+            log.info("删除失败-delRedisKey:{}",e);
+        }
+
+    }
+
+    public void cleanRedisKey(){
+        try {
+            String redisKey = CaseDownService.buildSceneKey +"*";
+            Set<String>  keys = redisUtil.keys(redisKey);
+            if(keys != null && !keys.isEmpty()){
+                for (String key : keys) {
+                    redisUtil.del(key);
+                }
+            }
+        }catch (Exception e){
+            log.info("删除失败-cleanRedisKey:{}",e);
         }
 
     }

+ 0 - 40
src/main/java/com/fdkankan/fusion/task/TaskService.java

@@ -1,40 +0,0 @@
-package com.fdkankan.fusion.task;
-
-import com.fdkankan.fusion.common.util.DateUtils;
-import com.fdkankan.fusion.entity.CaseLive;
-import com.fdkankan.fusion.entity.CommonUpload;
-import com.fdkankan.fusion.service.ICaseLiveService;
-import com.fdkankan.fusion.service.ICommonUploadService;
-import com.fdkankan.redis.util.RedisUtil;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Service;
-import org.springframework.web.bind.annotation.PostMapping;
-
-import javax.annotation.PostConstruct;
-import java.util.Date;
-import java.util.List;
-import java.util.Set;
-
-import static com.fdkankan.fusion.down.CaseDownService.downProcessKey;
-
-@Service
-public class TaskService {
-
-    @Autowired
-    ICaseLiveService caseLiveService;
-
-
-    @Autowired
-    RedisUtil redisUtil;
-    //@PostConstruct
-    public void cleanRedisKey(){
-        String redisKey = String.format(downProcessKey, "*");
-        Set<String>  keys = redisUtil.keys(redisKey);
-        if(keys != null && !keys.isEmpty()){
-            for (String key : keys) {
-                redisUtil.del(key);
-            }
-        }
-    }
-}