删除 store-api 中的 disk package

oss-store/src/main/java/cn/reghao/oss/store/rpc/disk/DiskServiceImpl.java

@@ -1,64 +0,0 @@
-package cn.reghao.oss.store.rpc.disk;
-
-import cn.reghao.oss.store.api.dto.FileInfo;
-import cn.reghao.oss.store.api.iface.disk.DiskService;
-import cn.reghao.oss.store.db.mapper.FileMetaMapper;
-import cn.reghao.oss.store.service.PutObjectService;
-import cn.reghao.jutil.jdk.db.Page;
-import cn.reghao.jutil.jdk.db.PageList;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboService;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-
-/**
- * @author reghao
- * @date 2023-05-18 20:39:45
- */
-@Slf4j
-@DubboService
-@Service
-public class DiskServiceImpl implements DiskService {
-    private PutObjectService putObjectService;
-    private final FileMetaMapper fileMetaMapper;
-    private final int pageSize = 10;
-
-    public DiskServiceImpl(PutObjectService putObjectService, FileMetaMapper fileMetaMapper) {
-        this.fileMetaMapper = fileMetaMapper;
-        this.putObjectService = putObjectService;
-    }
-
-    @Override
-    public PageList<FileInfo> getFileList(String pid, int pageNumber) {
-        Page page = new Page(pageNumber, pageSize);
-        int total = fileMetaMapper.countByPid(pid);
-        List<FileInfo> list = fileMetaMapper.findFileInfoByPage(page, pid);
-        PageList<FileInfo> pageList = PageList.pageList(pageNumber, pageSize, total, list);
-        return pageList;
-    }
-
-    @Override
-    public PageList<FileInfo> getFileCard(String pid, int pageNumber) {
-        Page page = new Page(pageNumber, pageSize);
-        int total = fileMetaMapper.countByPid(pid);
-        List<FileInfo> list = fileMetaMapper.findFileInfo1ByPage(page, pid);
-        PageList<FileInfo> pageList = PageList.pageList(pageNumber, pageSize, total, list);
-        return pageList;
-    }
-
-    @Override
-    public List<FileInfo> getDirectories(String pid) {
-        List<FileInfo> list = fileMetaMapper.findDirectories(pid);
-        return list;
-    }
-
-    @Override
-    public PageList<FileInfo> search(String keyword, int pageNumber) {
-        Page page = new Page(pageNumber, pageSize);
-        int total = fileMetaMapper.countByKeyword(keyword);
-        List<FileInfo> list = fileMetaMapper.findKeywordByPage(page, keyword);
-        PageList<FileInfo> pageList = PageList.pageList(pageNumber, pageSize, total, list);
-        return pageList;
-    }
-}

oss-store/src/main/java/cn/reghao/oss/store/rpc/disk/FileServiceImpl.java

@@ -1,125 +0,0 @@
-package cn.reghao.oss.store.rpc.disk;
-
-import cn.reghao.oss.store.api.constant.ObjectScope;
-import cn.reghao.oss.store.api.dto.DirProp;
-import cn.reghao.oss.store.api.dto.FileProp;
-import cn.reghao.oss.store.api.iface.disk.FileService;
-import cn.reghao.oss.store.db.mapper.FileMetaMapper;
-import cn.reghao.oss.store.model.po.FileMeta;
-import cn.reghao.oss.store.service.PutObjectService;
-import cn.reghao.oss.store.service.StoreLocalCache;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboService;
-import org.springframework.stereotype.Service;
-
-import java.nio.charset.StandardCharsets;
-import java.util.List;
-import java.util.UUID;
-
-/**
- * @author reghao
- * @date 2023-05-18 20:39:45
- */
-@Slf4j
-@DubboService
-@Service
-public class FileServiceImpl implements FileService {
-    private final PutObjectService putObjectService;
-    private final FileMetaMapper fileMetaMapper;
-    private final StoreLocalCache storeLocalCache;
-
-    public FileServiceImpl(PutObjectService putObjectService, FileMetaMapper fileMetaMapper, StoreLocalCache storeLocalCache) {
-        this.fileMetaMapper = fileMetaMapper;
-        this.putObjectService = putObjectService;
-        this.storeLocalCache = storeLocalCache;
-    }
-
-    @Override
-    public String checkFilename(String pid, String filename) {
-        List<FileMeta> list = fileMetaMapper.findByFilename(pid, filename);
-        if (!list.isEmpty()) {
-            filename += list.size();
-        }
-        return filename;
-    }
-
-    @Override
-    public void createDirectory(String pid, String filename) {
-        String filename1 = checkFilename(pid, filename);
-        String fileId = UUID.randomUUID().toString().replace("-", "");
-        String objectName = String.format("disk/0/1/%s/", fileId);
-        FileMeta fileMeta = new FileMeta(objectName, fileId, filename1, pid, ObjectScope.PRIVATE.getCode());
-        fileMetaMapper.save(fileMeta);
-    }
-
-    @Override
-    public String createFile(String pid, String filename, String content) {
-        String fileId = UUID.randomUUID().toString().replace("-", "");
-        String objectName = "";
-        byte[] bytes = content.getBytes(StandardCharsets.UTF_8);
-        putObjectService.putObject(objectName, bytes);
-        return fileId;
-    }
-
-    @Override
-    public void copyFile(List<String> fileIds, String toPid) {
-        List<FileMeta> list = fileMetaMapper.findFileInfos(fileIds);
-    }
-
-    @Override
-    public void moveFile(List<String> fileIds, String toPid) {
-        List<FileMeta> list = fileMetaMapper.findFileInfos(fileIds);
-        list.forEach(fileInfo -> {
-            fileMetaMapper.updateParent(fileInfo.getObjectId(), toPid);
-        });
-    }
-
-    @Override
-    public void renameFile(String fileId, String newFilename) {
-        FileMeta fileMeta = fileMetaMapper.findByObjectId(fileId);
-        String pid = fileMeta.getPid();
-        String filename1 = checkFilename(pid, newFilename);
-        fileMetaMapper.updateFilename(fileId, filename1);
-    }
-
-    @Override
-    public void deleteFiles(List<String> fileIds) {
-    }
-
-    @Override
-    public FileProp getFileProp(String fileId) {
-        FileMeta fileMeta = fileMetaMapper.findByObjectId(fileId);
-        String pid = fileMeta.getPid();
-        String path = "";
-
-        String filename = fileMeta.getFilename();
-        long size = fileMeta.getSize();
-        String contentType = fileMeta.getContentType();
-        String sha256sum = fileMeta.getSha256sum();
-        String url = String.format("https://%s/%s", storeLocalCache.getDomain(), fileMeta.getObjectName());
-        return new FileProp(path, filename, size, contentType, sha256sum, url);
-    }
-
-    @Override
-    public DirProp getDirProp(String fileId) {
-        // 当前目录下的文件和子目录
-        List<FileMeta> list = fileMetaMapper.findByPid(fileId);
-        DirProp dirProp = getDirProp(list);
-        return dirProp;
-    }
-
-    private DirProp getDirProp(List<FileMeta> list) {
-        long totalSize = 0;
-        long totalDirs = list.stream().filter(fileInfo -> fileInfo.getFileType() == 1000).count();
-        long totalFiles = list.stream().filter(fileInfo -> fileInfo.getFileType() != 1000).count();
-        for (FileMeta fileMeta : list) {
-            int fileType = fileMeta.getFileType();
-            if (fileType != 1000) {
-                totalSize += fileMeta.getSize();
-            } else {
-                // getDirProp(fileInfo.getFileId());
-            }
-        }
-        return new DirProp(totalDirs, totalFiles, totalSize);
-    }
-}

oss-store/src/main/java/cn/reghao/oss/store/rpc/disk/TrashServiceImpl.java

@@ -1,40 +0,0 @@
-package cn.reghao.oss.store.rpc.disk;
-
-import cn.reghao.oss.store.api.dto.DeleteFile;
-import cn.reghao.oss.store.api.iface.disk.TrashService;
-import cn.reghao.oss.store.db.mapper.FileMetaMapper;
-import cn.reghao.oss.store.service.PutObjectService;
-import cn.reghao.jutil.jdk.db.Page;
-import cn.reghao.jutil.jdk.db.PageList;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboService;
-import org.springframework.stereotype.Service;
-
-import java.util.List;
-
-/**
- * @author reghao
- * @date 2023-05-18 20:39:45
- */
-@Slf4j
-@DubboService
-@Service
-public class TrashServiceImpl implements TrashService {
-    private PutObjectService putObjectService;
-    private final FileMetaMapper fileMetaMapper;
-    private final int pageSize = 10;
-
-    public TrashServiceImpl(PutObjectService putObjectService, FileMetaMapper fileMetaMapper) {
-        this.fileMetaMapper = fileMetaMapper;
-        this.putObjectService = putObjectService;
-    }
-
-    @Override
-    public PageList<DeleteFile> getTrashList(int pageNumber, int pageSize) {
-        int total = fileMetaMapper.countDeletedFiles();
-        Page page = new Page(pageNumber, pageSize);
-        List<DeleteFile> list = fileMetaMapper.findDeletedFileByPage(page);
-        PageList<DeleteFile> pageList = PageList.pageList(pageNumber, pageSize, total, list);
-        return pageList;
-    }
-}

store-api/src/main/java/cn/reghao/oss/store/api/iface/disk/DiskService.java

@@ -1,17 +0,0 @@
-package cn.reghao.oss.store.api.iface.disk;
-
-import cn.reghao.oss.store.api.dto.FileInfo;
-import cn.reghao.jutil.jdk.db.PageList;
-
-import java.util.List;
-
-/**
- * @author reghao
- * @date 2023-05-22 15:57:51
- */
-public interface DiskService {
-    PageList<FileInfo> getFileList(String pid, int pageNumber);
-    PageList<FileInfo> getFileCard(String pid, int pageNumber);
-    List<FileInfo> getDirectories(String pid);
-    PageList<FileInfo> search(String keyword, int pageNumber);
-}

store-api/src/main/java/cn/reghao/oss/store/api/iface/disk/FileService.java

@@ -1,22 +0,0 @@
-package cn.reghao.oss.store.api.iface.disk;
-
-import cn.reghao.oss.store.api.dto.DirProp;
-import cn.reghao.oss.store.api.dto.FileProp;
-
-import java.util.List;
-
-/**
- * @author reghao
- * @date 2023-05-18 19:23:07
- */
-public interface FileService {
-    String checkFilename(String pid, String filename);
-    void createDirectory(String pid, String filename);
-    String createFile(String pid, String filename, String content);
-    void copyFile(List<String> fileIds, String toPid);
-    void moveFile(List<String> fileIds, String toPid);
-    void renameFile(String fileId, String newFilename);
-    void deleteFiles(List<String> fileIds);
-    FileProp getFileProp(String fileId);
-    DirProp getDirProp(String fileId);
-}

store-api/src/main/java/cn/reghao/oss/store/api/iface/disk/TrashService.java

@@ -1,12 +0,0 @@
-package cn.reghao.oss.store.api.iface.disk;
-
-import cn.reghao.oss.store.api.dto.DeleteFile;
-import cn.reghao.jutil.jdk.db.PageList;
-
-/**
- * @author reghao
- * @date 2023-05-22 15:57:57
- */
-public interface TrashService {
-    PageList<DeleteFile> getTrashList(int pageNumber, int pageSize);
-}