update FileTask

dfs-store/src/main/java/cn/reghao/dfs/store/config/spring/FileLifecycle.java

@@ -1,6 +1,7 @@
 package cn.reghao.dfs.store.config.spring;
 
 import cn.reghao.dfs.store.config.OssProperties;
+import cn.reghao.dfs.store.task.FileTask;
 import cn.reghao.dfs.store.util.store.LocalStores;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.DisposableBean;
@@ -16,9 +17,11 @@ import org.springframework.stereotype.Component;
 @Component
 public class FileLifecycle implements ApplicationRunner, DisposableBean {
     private final OssProperties ossProperties;
+    private final FileTask fileTask;
 
-    public FileLifecycle(OssProperties ossProperties) {
+    public FileLifecycle(OssProperties ossProperties, FileTask fileTask) {
         this.ossProperties = ossProperties;
+        this.fileTask = fileTask;
     }
 
     @Override
@@ -26,6 +29,10 @@ public class FileLifecycle implements ApplicationRunner, DisposableBean {
         log.info("加载本地磁盘数据...");
         LocalStores.init(ossProperties);
         log.info("本地磁盘数据加载完成...");
+
+        log.info("执行文件任务...");
+        fileTask.exec();
+        log.info("文件任务执行完成...");
     }
 
     @Override

dfs-store/src/main/java/cn/reghao/dfs/store/task/FileTask.java

@@ -1,27 +1,41 @@
 package cn.reghao.dfs.store.task;
 
-import cn.reghao.dfs.store.db.mapper.ImageFileMapper;
 import cn.reghao.dfs.store.db.repository.ObjectRepository;
-import lombok.extern.slf4j.Slf4j;
+import cn.reghao.dfs.store.model.vo.ObjectResult;
+import cn.reghao.dfs.store.task.processor.AudioFileProcessor;
+import cn.reghao.oss.api.dto.ObjectMeta;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import javax.annotation.PostConstruct;
+import java.util.List;
 
 /**
  * @author reghao
  * @date 2023-08-29 18:03:39
  */
-@Slf4j
 @Service
 @Deprecated
 public class FileTask {
-    @Autowired
-    ImageFileMapper imageFileMapper;
     @Autowired
     ObjectRepository objectRepository;
+    @Autowired
+    AudioFileProcessor audioFileProcessor;
+
+    public void exec() {
+    }
+
+    private void execTask() {
+        List<String> objectNames = List.of(
+                "audio/playback/vJPA6ZGzV2.mp3"
+        );
 
-    //@PostConstruct
-    public void update() {
+        for (String objectName : objectNames) {
+            ObjectMeta objectMeta = objectRepository.getObjectMeta(objectName);
+            String objectId = objectMeta.getObjectId();
+            int fileType = 1003;
+            String absolutePath = objectMeta.getAbsolutePath();
+            ObjectResult objectResult = new ObjectResult(objectName, objectId, fileType, absolutePath);
+            audioFileProcessor.process(objectResult);
+        }
     }
 }