update

pom.xml

@@ -22,13 +22,6 @@
                 <type>pom</type>
                 <scope>import</scope>
             </dependency>
-            <dependency>
-                <groupId>org.springframework.cloud</groupId>
-                <artifactId>spring-cloud-dependencies</artifactId>
-                <version>Hoxton.SR10</version>
-                <type>pom</type>
-                <scope>import</scope>
-            </dependency>
         </dependencies>
     </dependencyManagement>
 
@@ -177,16 +170,16 @@
             <version>2.7.8</version>
         </dependency>
         <dependency>
-            <groupId>org.springframework.cloud</groupId>
-            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
-            <exclusions>
-                <exclusion>
-                    <groupId>org.apache.zookeeper</groupId>
-                    <artifactId>zookeeper</artifactId>
-                </exclusion>
-            </exclusions>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-framework</artifactId>
+            <version>4.0.1</version>
         </dependency>
         <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-recipes</artifactId>
+            <version>4.0.1</version>
+        </dependency>
+        <!--<dependency>
             <groupId>org.apache.zookeeper</groupId>
             <artifactId>zookeeper</artifactId>
             <version>3.4.6</version>
@@ -196,7 +189,7 @@
                     <artifactId>slf4j-log4j12</artifactId>
                 </exclusion>
             </exclusions>
-        </dependency>
+        </dependency>-->
     </dependencies>
 
     <profiles>

src/main/java/cn/reghao/dfs/store/db/mapper/FilePathMapper.java

@@ -0,0 +1,13 @@
+package cn.reghao.dfs.store.db.mapper;
+
+import cn.reghao.dfs.store.model.po.FilePath;
+import cn.reghao.jutil.jdk.db.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @author reghao
+ * @date 2022-08-16 21:29:13
+ */
+@Mapper
+public interface FilePathMapper extends BaseMapper<FilePath> {
+}

src/main/java/cn/reghao/dfs/store/model/po/FilePath.java

@@ -0,0 +1,15 @@
+package cn.reghao.dfs.store.model.po;
+
+import cn.reghao.jutil.jdk.db.BaseObject;
+
+/**
+ * @author reghao
+ * @date 2022-08-16 21:24:02
+ */
+public class FilePath extends BaseObject<Integer> {
+    private String fileId;
+    private String blockId;
+    private String absolutePath;
+    private int group;
+    private int node;
+}

src/main/java/cn/reghao/dfs/store/model/po/FileUrl.java

@@ -1,7 +1,6 @@
 package cn.reghao.dfs.store.model.po;
 
 import cn.reghao.jutil.jdk.db.BaseObject;
-import lombok.AllArgsConstructor;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 import lombok.Setter;

src/main/java/cn/reghao/dfs/store/rpc/MediaUrlServiceImpl.java

@@ -33,7 +33,7 @@ public class MediaUrlServiceImpl implements MediaUrlService {
     }
 
     @Override
-    public List<VideoUrlDto> getEncryptMp4Urls(String key) throws NoSuchAlgorithmException {
+    public List<VideoUrlDto> getEncryptMp4Urls(String videoFileId, String key) throws NoSuchAlgorithmException {
         long timestamp = System.currentTimeMillis() + 8*3600*1000;
         byte[] bytes = (key + timestamp).getBytes(StandardCharsets.UTF_8);
         String sign = DigestUtil.md5sum(bytes);

src/main/java/cn/reghao/dfs/store/sync/FileSync.java

@@ -0,0 +1,33 @@
+package cn.reghao.dfs.store.sync;
+
+import cn.reghao.dfs.store.model.po.FilePath;
+import cn.reghao.dfs.store.model.po.FileUrl;
+import cn.reghao.dfs.store.service.FileStoreService;
+import cn.reghao.dfs.store.service.FileUrlService;
+import org.springframework.stereotype.Service;
+
+import java.io.InputStream;
+
+/**
+ * @author reghao
+ * @date 2022-08-16 20:15:13
+ */
+@Service
+public class FileSync {
+    private FileUrlService fileUrlService;
+    private FileStoreService fileStoreService;
+
+    public FileSync(FileUrlService fileUrlService, FileStoreService fileStoreService) {
+        this.fileUrlService = fileUrlService;
+        this.fileStoreService = fileStoreService;
+    }
+
+    public void send(String fileId, String absolutePath) {
+
+    }
+
+    public void receive(String fileId, InputStream inputStream) {
+
+        FilePath filePath = new FilePath();
+    }
+}

src/main/resources/mapper/FilePathMapper.xml

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+
+<mapper namespace="cn.reghao.dfs.store.db.mapper.FilePathMapper">
+    <insert id="save" useGeneratedKeys="true" keyProperty="id">
+        insert into file_path
+        (`id`,`deleted`,`create_time`,`update_time`,`file_id`,`block_id`,`absolute_path`,`group`,`node`)
+        values 
+        (#{id},#{deleted},#{createTime},#{updateTime},#{fileId},#{blockId},#{absolutePath},#{group},#{node})
+    </insert>
+
+    <select id="findAll" resultType="cn.reghao.dfs.store.model.po.FilePath">
+        select * from file_path
+    </select>
+</mapper>