update test case

dfs-store/src/main/resources/mapper/ImageFileMapper.xml

@@ -17,9 +17,14 @@
         </foreach>
     </insert>
 
+    <update id="update">
+        update image_file
+        set jpeg_object_id=#{jpegObjectId}
+        where id=#{id}
+    </update>
+
     <select id="findAll" resultType="cn.reghao.dfs.store.model.po.ImageFile">
         select * from image_file
-        where jpeg_url is null
     </select>
     <select id="findByImageFileId" resultType="cn.reghao.dfs.store.model.po.ImageFile">
         select * from image_file

dfs-store/src/main/resources/mapper/VideoUrlMapper.xml

@@ -10,8 +10,7 @@
     </insert>
 
     <select id="findAll" resultType="cn.reghao.dfs.store.model.po.VideoUrl">
-        select *
-        from video_url
+        select * from video_url
     </select>
     <select id="findVideoUrls" resultType="cn.reghao.oss.api.dto.VideoUrlDto">
         select url_type as type,url,width,height,quality

dfs-store/src/test/java/FileMetaTest.java

@@ -1,15 +1,12 @@
 import cn.reghao.dfs.store.DfsStoreApplication;
-import cn.reghao.dfs.store.db.mapper.DataBlockMapper;
-import cn.reghao.dfs.store.db.mapper.FileMetaMapper;
-import cn.reghao.dfs.store.model.po.DataBlock;
-import cn.reghao.dfs.store.model.po.FileMeta;
+import cn.reghao.dfs.store.db.mapper.*;
+import cn.reghao.dfs.store.model.po.*;
 import cn.reghao.dfs.store.service.ObjectNameService;
 import cn.reghao.jutil.jdk.db.Page;
 import cn.reghao.jutil.jdk.security.DigestUtil;
 import cn.reghao.jutil.jdk.thread.ThreadPoolWrapper;
 import cn.reghao.oss.api.constant.ObjectACL;
 import cn.reghao.oss.api.constant.UploadChannel;
-import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.io.FileUtils;
 import org.junit.Test;
@@ -32,7 +29,7 @@ import java.util.concurrent.ExecutorService;
 
 /**
  * @author reghao
- * @date 2023-03-22 16:19:12
+ * @date 2023-07-16 19:19:12
  */
 @Slf4j
 @ActiveProfiles("dev")

dfs-store/src/test/java/FileTest.java → dfs-store/src/test/java/LocalFileTest.java

@@ -27,7 +27,7 @@ import java.util.Map;
  * @date 2023-03-22 16:19:12
  */
 @Slf4j
-public class FileTest {
+public class LocalFileTest {
     public void walkDir(Path path) throws IOException {
         Files.walkFileTree(path, new FileVisitor<>() {
             @Override

dfs-store/src/test/java/MediaFileTest.java

@@ -0,0 +1,84 @@
+import cn.reghao.dfs.store.DfsStoreApplication;
+import cn.reghao.dfs.store.db.mapper.*;
+import cn.reghao.dfs.store.model.po.*;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.List;
+
+/**
+ * @author reghao
+ * @date 2023-03-22 16:19:12
+ */
+@Slf4j
+@ActiveProfiles("dev")
+@SpringBootTest(classes = DfsStoreApplication.class)
+@RunWith(SpringRunner.class)
+public class MediaFileTest {
+    @Autowired
+    VideoFileMapper videoFileMapper;
+    @Autowired
+    VideoUrlMapper videoUrlMapper;
+    @Autowired
+    FileMetaMapper fileMetaMapper;
+
+    public void mediaTest() {
+        videoUrlTest();
+        log.info("------------------------------------------------------------");
+        imageFileTest();
+    }
+
+    @Test
+    public void videoUrlTest() {
+        List<VideoUrl> list = videoUrlMapper.findAll();
+        for (VideoUrl videoUrl : list) {
+            process(videoUrl);
+        }
+    }
+
+    private void process(VideoUrl videoUrl) {
+        String videoFileId = videoUrl.getVideoFileId();
+        VideoFile videoFile = videoFileMapper.findByVideoFileId(videoFileId);
+        if (videoFile == null) {
+            log.error("videoFileId {} not exist in video_file", videoFileId);
+            return;
+        }
+
+        String objectId = videoUrl.getObjectId();
+        FileMeta fileMeta = fileMetaMapper.findByObjectId(objectId);
+        if (fileMeta == null) {
+            log.error("objectId {} not exist in file_meta", objectId);
+        }
+    }
+
+    @Autowired
+    ImageFileMapper imageFileMapper;
+    @Test
+    public void imageFileTest() {
+        List<ImageFile> list = imageFileMapper.findAll();
+        for (ImageFile imageFile : list) {
+            process(imageFile);
+        }
+    }
+
+    private void process(ImageFile imageFile) {
+        String jpegObjectId = imageFile.getJpegObjectId();
+        FileMeta fileMeta = fileMetaMapper.findByObjectId(jpegObjectId);
+        if (fileMeta == null) {
+            log.error("jpegObjectId {} not exist in file_meta", jpegObjectId);
+        }
+
+        String webpObjectId = imageFile.getWebpObjectId();
+        if (webpObjectId != null) {
+            FileMeta fileMeta1 = fileMetaMapper.findByObjectId(webpObjectId);
+            if (fileMeta1 == null) {
+                log.error("webpObjectId {} not exist in file_meta", webpObjectId);
+            }
+        }
+    }
+}