🔖 发布 2.2 版

.github/ISSUE_TEMPLATE/bug_report.md

@@ -0,0 +1,48 @@
+---
+name: BUG 反馈
+about: 事情不像预期的那样工作吗？
+title: ''
+labels: 'bug'
+assignees: ''
+---
+
+<!--
+  你好！感谢你正在考虑为 ZFile 提交一个 bug。请花一点点时间尽量详细地回答以下基础问题。
+
+  谢谢！
+-->
+
+<!--
+  请确认你已经做了下面这些事情，若 bug 还是未解决，那么请尽可详细地描述你的问题。
+
+  - 我已经安装了最新版的 ZFile
+  - 我已经阅读了 ZFile 的文档：http://docs.zhaojun.im/zfile
+  - 我已经搜索了已有的 Issues 列表中有关的信息
+  - 我已经清理过浏览器缓存并重试
+-->
+
+## 我的环境
+
+<!--
+  请登录到管理后台，点击左侧系统监控, 复制或截图此页内容.
+-->
+
+## 错误日志
+
+<!--
+  请登录到管理后台，点击左侧系统监控, 点击右上角诊断日志下载, 然后上传到此 Issue 中.
+-->
+
+## 期望行为
+
+<!--
+  你期望会发生什么？
+-->
+
+## 当前行为
+
+<!--
+  描述 bug 细节，确认出现此问题的复现步骤，例如点击了哪里，发生了什么情况？
+
+  你可以粘贴截图或附件。
+-->

.github/ISSUE_TEMPLATE/feature_request.md

@@ -0,0 +1,34 @@
+---
+name: 功能建议
+about: 想让我们为 ZFile 增加什么功能吗？
+title: 'feat: '
+labels: 'Feature Request'
+assignees: ''
+
+---
+
+<!--
+  你好！感谢你愿意考虑希望 ZFile 增加某个新功能。请花一点点时间尽量详细地回答以下基础问题。
+
+  谢谢！
+-->
+
+## 概述
+
+<!--
+  对这个新功能的一段描述
+-->
+
+## 动机
+
+<!--
+  为什么你希望在 ZFile 中使用这个功能？
+-->
+
+## 详细解释
+
+<!--
+  详细描述这个新功能。
+
+  如果这是一个小功能，你可以忽略这部分。
+-->

.github/ISSUE_TEMPLATE/question.md

@@ -0,0 +1,14 @@
+---
+name: Question
+about: 对 ZFile 有任何问题吗？
+title: ''
+labels: 'question'
+assignees: ''
+
+---
+
+<!--
+  如果你有任何问题也可以通过此渠道来向我们反馈。
+
+  谢谢！
+-->

README.md

@@ -10,6 +10,7 @@
 前端基于 [h5ai](https://larsjung.de/h5ai/) 的原有功能使用 Vue 重新开发了一遍. 后端采用 SpringBoot, 数据库采用内嵌数据库.
 
 预览地址: [https://zfile.jun6.net](https://zfile.jun6.net)
+
 文档地址: [http://docs.zhaojun.im/zfile](http://docs.zhaojun.im/zfile)
 
 ## 系统特色
@@ -39,15 +40,15 @@ apt update
 apt install -y openjdk-8-jre-headless unzip
 ```
 
-> 如为更新程序, 则请先执行 `rm -rf ~/zfile` 清理旧程序. 首次安装请忽略此选项.
+> 如为更新程序, 则请先执行 `~/zfile/bin/stop.sh && rm -rf ~/zfile` 清理旧程序. 首次安装请忽略此选项.
 
 下载项目:
 
 ```bash
-wget -P ~ https://c.jun6.net/ZFILE/zfile-release.war
 cd ~
+wget https://c.jun6.net/ZFILE/zfile-release.war
 mkdir zfile && unzip zfile-release.war -d zfile && rm -rf zfile-release.war
-chmod +x ~/zfile/bin/*.sh
+chmod +x zfile/bin/*.sh
 ```
 
 程序的目录结构为:
@@ -100,7 +101,6 @@ https://login.chinacloudapi.cn/common/oauth2/v2.0/authorize?client_id=4a72d927-1
 ## 运行环境
 
 * JDK: `1.8`
-* 缓存: `caffeine`
 * 数据库: `h2/mysql`
 
 ## 预览
@@ -132,11 +132,11 @@ https://login.chinacloudapi.cn/common/oauth2/v2.0/authorize?client_id=4a72d927-1
 - [x] 布局优化 - 自定义操作按钮 (现为右键实现)
 - [x] 后台优化 - 设置按照其功能进行分离
 - [x] 体验优化 - 支持前后端分离部署
+- [x] 体验优化 - 文本预览更换 vscode 同款编辑器 monaco editor
 - [ ] 新功能 - 后台支持上传、编辑、删除等操作
 - [ ] 新功能 - WebDav 支持
 - [ ] 新功能 - Docker 支持
 - [ ] 新功能 - 离线下载 (aria2)
-- [ ] 体验优化 - 文本预览更换 vscode 同款编辑器 monaco editor
 - [ ] 体验优化 - 忽略文件列表 (正则表达式)
 - [ ] 体验优化 - 自定义支持预览的文件后缀 (正则表达式)
 - [ ] 架构调整 - 支持多存储策略

pom.xml

@@ -12,7 +12,7 @@
 
     <groupId>im.zhaojun</groupId>
     <artifactId>zfile</artifactId>
-    <version>1.8</version>
+    <version>2.2</version>
     <name>zfile</name>
     <packaging>war</packaging>
     <description>一个在线的文件浏览系统</description>
@@ -45,6 +45,10 @@
             <artifactId>spring-boot-configuration-processor</artifactId>
             <optional>true</optional>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-cache</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -106,23 +110,9 @@
         </dependency>
 
         <dependency>
-            <groupId>com.alicp.jetcache</groupId>
-            <artifactId>jetcache-starter-redis</artifactId>
-            <version>2.5.14</version>
-            <exclusions>
-                <exclusion>
-                    <groupId>com.alicp.jetcache</groupId>
-                    <artifactId>jetcache-redis</artifactId>
-                </exclusion>
-                <exclusion>
-                    <groupId>redis.clients</groupId>
-                    <artifactId>jedis</artifactId>
-                </exclusion>
-                <exclusion>
-                    <groupId>com.esotericsoftware</groupId>
-                    <artifactId>kryo</artifactId>
-                </exclusion>
-            </exclusions>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.61</version>
         </dependency>
 
     </dependencies>

src/main/java/im/zhaojun/common/config/GlobalScheduleTask.java

@@ -1,81 +0,0 @@
-package im.zhaojun.common.config;
-
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.common.service.SystemConfigService;
-import im.zhaojun.onedrive.china.service.OneDriveChinaServiceImpl;
-import im.zhaojun.onedrive.international.service.OneDriveServiceImpl;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.scheduling.annotation.EnableScheduling;
-import org.springframework.scheduling.annotation.Scheduled;
-
-import javax.annotation.Resource;
-import java.time.LocalDateTime;
-import java.util.Objects;
-
-/**
- * @author zhaojun
- */
-@Configuration
-@EnableScheduling
-@Slf4j
-public class GlobalScheduleTask {
-
-    @Resource
-    private StorageConfigService storageConfigService;
-
-    @Resource
-    private OneDriveServiceImpl oneDriveServiceImpl;
-
-    @Resource
-    private OneDriveChinaServiceImpl oneDriveChinaServiceImpl;
-
-    @Resource
-    private SystemConfigService systemConfigService;
-
-    /**
-     * 项目启动 30 秒后, 每 15 分钟执行一次刷新 OneDrive Token 的定时任务.
-     */
-    @Scheduled(fixedRate = 1000 * 60 * 15, initialDelay = 1000 * 30)
-    public void autoRefreshOneDriveToken() {
-
-        AbstractFileService currentFileService = systemConfigService.getCurrentFileService();
-
-        if (!(currentFileService instanceof OneDriveServiceImpl
-            || currentFileService instanceof OneDriveChinaServiceImpl)) {
-            log.debug("当前启用存储类型, 不是 OneDrive, 跳过自动刷新 AccessToken");
-            return;
-        }
-
-        if (currentFileService.getIsUnInitialized()) {
-            log.debug("当前启用 OneDrive 未初始化成功, 跳过自动刷新 AccessToken");
-            return;
-        }
-
-        try {
-            refreshOneDriveToken(StorageTypeEnum.ONE_DRIVE);
-        } catch (Exception e) {
-            log.debug("刷新 OneDrive Token 失败.", e);
-        }
-
-        try {
-            refreshOneDriveToken(StorageTypeEnum.ONE_DRIVE_CHINA);
-        } catch (Exception e) {
-            log.debug("刷新 OneDrive 世纪互联 Token 失败.", e);
-        }
-    }
-
-    /**
-     * 调用刷新 OneDrive Token
-     */
-    public void refreshOneDriveToken(StorageTypeEnum storageType) {
-        if (Objects.equals(storageType, StorageTypeEnum.ONE_DRIVE_CHINA)) {
-            oneDriveChinaServiceImpl.refreshOneDriveToken();
-        } else {
-            oneDriveServiceImpl.refreshOneDriveToken();
-        }
-        log.info("刷新 {} key 时间: {}", storageType.getDescription(), LocalDateTime.now());
-    }
-}

src/main/java/im/zhaojun/common/service/AbstractFileService.java

@@ -1,245 +0,0 @@
-package im.zhaojun.common.service;
-
-import cn.hutool.core.util.BooleanUtil;
-import cn.hutool.core.util.StrUtil;
-import com.alicp.jetcache.Cache;
-import com.alicp.jetcache.RefreshPolicy;
-import com.alicp.jetcache.anno.CacheRefresh;
-import com.alicp.jetcache.anno.CacheType;
-import com.alicp.jetcache.anno.Cached;
-import com.alicp.jetcache.anno.CreateCache;
-import im.zhaojun.common.model.constant.ZFileConstant;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.dto.SystemConfigDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.util.StringUtils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.aop.framework.AopContext;
-import org.springframework.beans.factory.annotation.Value;
-
-import javax.annotation.PostConstruct;
-import javax.annotation.Resource;
-import java.util.ArrayDeque;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Objects;
-import java.util.Set;
-import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
-
-/**
- * @author zhaojun
- */
-@Slf4j
-public abstract class AbstractFileService extends FileCacheService implements FileService {
-
-    private static final String SYSTEM_CONFIG_CACHE_PREFIX = "zfile-cache:";
-
-    @Value("${zfile.cache.timeout}")
-    protected Long timeout;
-
-    protected boolean isInitialized = false;
-
-    protected String basePath;
-
-    @Resource
-    private SystemConfigService systemConfigService;
-
-    @Resource
-    private FileAsyncCacheService fileAsyncCacheService;
-
-    @CreateCache(name = SYSTEM_CONFIG_CACHE_PREFIX, cacheType = CacheType.LOCAL)
-    private Cache<String, List<FileItemDTO>> cache;
-
-    /***
-     * 获取指定路径下的文件及文件夹, 默认缓存 60 分钟，每隔 30 分钟刷新一次.
-     * @param path 文件路径
-     * @return     文件及文件夹列表
-     * @throws Exception  获取文件列表中出现的异常
-     */
-    @Override
-    @Cached(name = SYSTEM_CONFIG_CACHE_PREFIX,
-            key =  "args[0]",
-            cacheType = CacheType.LOCAL, localLimit = 100000, condition = "mvel{bean('systemConfigService').enableCache}")
-    @CacheRefresh(refresh = 30, timeUnit = TimeUnit.MINUTES)
-    public abstract List<FileItemDTO> fileList(String path) throws Exception;
-
-    /**
-     * 清理当前存储策略的缓存
-     * 1. 删除全部缓存
-     * 2. 关闭自动刷新
-     * 3. 重置缓存个数
-     * 4. 标记为当前处于未完成缓存状态
-     */
-    public void clearFileCache() throws Exception {
-        Set<String> cacheKeys = getCacheKeys();
-        cache.removeAll(cacheKeys);
-        closeCacheAutoRefresh();
-        fileAsyncCacheService.resetCacheCount();
-        fileAsyncCacheService.setCacheFinish(false);
-    }
-
-    /**
-     * 初始化方法, 启动时自动调用实现类的此方法进行初始化.
-     */
-    @PostConstruct
-    public abstract void init();
-
-    protected boolean testConnection() {
-        boolean flag = true;
-        try {
-            fileList("/");
-        } catch (Exception e) {
-            log.debug(getStorageTypeEnum().getDescription() + " 初始化异常", e);
-            flag = false;
-        }
-        return flag;
-    }
-
-    /**
-     * 获取是否初始化成功
-     * @return              初始化成功与否
-     */
-    public boolean getIsUnInitialized() {
-        return !isInitialized;
-    }
-
-    /**
-     * 获取是否初始化成功
-     * @return              初始化成功与否
-     */
-    public boolean getIsInitialized() {
-        return isInitialized;
-    }
-
-    /**
-     * 获取存储策略类型
-     * @return              存储策略类型枚举
-     */
-    public abstract StorageTypeEnum getStorageTypeEnum();
-
-    /**
-     * 搜索文件
-     * @param name          文件名
-     * @return              包含该文件名的所有文件或文件夹
-     */
-    public List<FileItemDTO> search(String name) {
-        List<FileItemDTO> result = new ArrayList<>();
-
-        boolean searchIgnoreCase = systemConfigService.getSearchIgnoreCase();
-
-        List<FileItemDTO> fileItemList = selectAllFileList();
-        for (FileItemDTO fileItemDTO : fileItemList) {
-
-            boolean testResult;
-
-            if (searchIgnoreCase) {
-                testResult = StrUtil.containsIgnoreCase(fileItemDTO.getName(), name);
-            } else {
-                testResult = fileItemDTO.getName().contains(name);
-            }
-
-            if (testResult) {
-                result.add(fileItemDTO);
-            }
-        }
-
-        return result;
-    }
-
-    /**
-     * 查询所有文件, 仅去缓存中查询.
-     * @return              所有文件
-     */
-    public List<FileItemDTO> selectAllFileList() {
-        List<FileItemDTO> result = new ArrayList<>();
-        boolean enableCache = systemConfigService.getEnableCache();
-        if (!enableCache) {
-            log.debug("未开启缓存, 不支持查询所有文件.");
-            return null;
-        }
-        String path = "/";
-
-        List<FileItemDTO> fileItemList = cache.get(path);
-        fileItemList = fileItemList == null ? new ArrayList<>() : fileItemList;
-        ArrayDeque<FileItemDTO> queue = new ArrayDeque<>(fileItemList);
-
-        while (!queue.isEmpty()) {
-            FileItemDTO fileItemDTO = queue.pop();
-            result.add(fileItemDTO);
-            if (fileItemDTO.getType() == FileTypeEnum.FOLDER) {
-                String filePath = StringUtils.removeDuplicateSeparator("/" + fileItemDTO.getPath() + "/" + fileItemDTO.getName() + "/");
-                List<FileItemDTO> cacheList = cache.get(filePath);
-                if (cacheList != null && isNotEncryptedFolder(cacheList)) {
-                    queue.addAll(cacheList);
-                }
-            }
-
-        }
-        return result;
-    }
-
-    /**
-     * 不是加密文件夹
-     * @param list      文件夹中的内容
-     * @return          返回此文件夹是否加密.
-     */
-    private boolean isNotEncryptedFolder(List<FileItemDTO> list) {
-        // 如果开启了 "搜索包含加密文件" 选项, 则直接返回 true.
-        SystemConfigDTO systemConfig = systemConfigService.getSystemConfig();
-        if (BooleanUtil.isFalse(systemConfig.getSearchContainEncryptedFile())) {
-            return true;
-        }
-
-        // 遍历文件判断是否包含
-        for (FileItemDTO fileItemDTO : list) {
-            if (Objects.equals(ZFileConstant.PASSWORD_FILE_NAME, fileItemDTO.getName())) {
-                return false;
-            }
-        }
-        return true;
-    }
-
-    /**
-     * 获取所有缓存的 Key, 仅当开启缓存, 且缓存完成时, 可获取.
-     * @return              所有缓存的 Key
-     */
-    public Set<String> getCacheKeys() {
-        if (systemConfigService.getEnableCache() && fileAsyncCacheService.isCacheFinish()) {
-            Set<String> collect = selectAllFileList().stream().map(fileItemDTO -> {
-                if (fileItemDTO.getType() == FileTypeEnum.FOLDER) {
-                    return StringUtils.removeDuplicateSeparator("/" + fileItemDTO.getPath() + "/" + fileItemDTO.getName() + "/");
-                }
-                return null;
-            }).collect(Collectors.toSet());
-            collect.remove(null);
-            collect.add("/");
-            return collect;
-        } else {
-            return Collections.emptySet();
-        }
-    }
-
-    /**
-     * 刷新缓存
-     */
-    public void refreshCache(String key) throws Exception {
-        cache.remove(key);
-        FileService currentFileService = (FileService) AopContext.currentProxy();
-        currentFileService.fileList(key);
-    }
-
-    public void closeCacheAutoRefresh() {
-        cache.config().setRefreshPolicy(null);
-    }
-
-    public void openCacheAutoRefresh() {
-        RefreshPolicy refreshPolicy = RefreshPolicy.newPolicy(30, TimeUnit.MINUTES);
-        cache.config().setRefreshPolicy(refreshPolicy);
-    }
-
-    public abstract FileItemDTO getFileItem(String path);
-
-}

src/main/java/im/zhaojun/common/service/FileAsyncCacheService.java

@@ -1,140 +0,0 @@
-package im.zhaojun.common.service;
-
-import cn.hutool.core.util.ObjectUtil;
-import com.alicp.jetcache.Cache;
-import com.alicp.jetcache.anno.CacheType;
-import com.alicp.jetcache.anno.CreateCache;
-import im.zhaojun.common.config.StorageTypeFactory;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.util.StringUtils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.scheduling.annotation.Async;
-import org.springframework.stereotype.Service;
-
-import javax.annotation.Resource;
-import java.util.ArrayDeque;
-import java.util.List;
-
-/**
- * @author zhaojun
- */
-@Slf4j
-@Service
-public class FileAsyncCacheService {
-
-    public static final String CACHE_PROCESS_PREFIX = "zfile-process-cache:";
-
-    public static final String CACHE_FILE_COUNT_KEY = "file-count";
-
-    public static final String CACHE_DIRECTORY_COUNT_KEY = "directory-count";
-
-    @CreateCache(name = "SYSTEM_CONFIG_CACHE_PREFIX", cacheType = CacheType.LOCAL)
-    private Cache<String, Integer> cache;
-    
-    private boolean cacheFinish;
-
-    @Resource
-    private SystemConfigService systemConfigService;
-
-    @Async
-    public void cacheGlobalFile() {
-        StorageTypeEnum storageStrategy = systemConfigService.getCurrentStorageStrategy();
-
-        if (storageStrategy == null) {
-            log.debug("尚未配置存储策略. 跳过启动缓存.");
-            return;
-        }
-
-        boolean enableCache = systemConfigService.getEnableCache();
-        if (!enableCache) {
-            log.debug("存储策略 {} 未启用缓存, 跳过缓存.", storageStrategy.getDescription());
-            return;
-        }
-
-        AbstractFileService fileService = StorageTypeFactory.getStorageTypeService(storageStrategy);
-
-        if (fileService.getIsUnInitialized()) {
-            log.debug("存储策略 {} 未初始化成功, 跳过缓存.", storageStrategy.getDescription());
-            return;
-        }
-
-        Integer cacheDirectoryCount = cache.get(CACHE_DIRECTORY_COUNT_KEY);
-        if (cacheDirectoryCount == null) {
-            cacheDirectoryCount = 0;
-        }
-
-        Integer cacheFileCount = cache.get(CACHE_FILE_COUNT_KEY);
-        if (cacheFileCount == null) {
-            cacheFileCount = 0;
-        }
-
-        log.info("缓存 {} 所有文件开始", storageStrategy.getDescription());
-        long startTime = System.currentTimeMillis();
-        try {
-            FileService currentFileService = systemConfigService.getCurrentFileService();
-            List<FileItemDTO> rootFileItems = currentFileService.fileList("/");
-            ArrayDeque<FileItemDTO> queue = new ArrayDeque<>(rootFileItems);
-
-            while (!queue.isEmpty()) {
-                FileItemDTO fileItemDTO = queue.pop();
-
-                if (FileTypeEnum.FOLDER.equals(fileItemDTO.getType())) {
-                    cacheDirectoryCount++;
-                }
-                if (FileTypeEnum.FILE.equals(fileItemDTO.getType())) {
-                    cacheFileCount++;
-                }
-
-                log.debug("已缓存 {} 个文件夹", cacheDirectoryCount);
-                cache.put(CACHE_DIRECTORY_COUNT_KEY, cacheDirectoryCount);
-
-                log.debug("已缓存 {} 个文件", cacheFileCount);
-                cache.put(CACHE_FILE_COUNT_KEY, cacheFileCount);
-
-                if (fileItemDTO.getType() == FileTypeEnum.FOLDER) {
-                    String filePath = StringUtils.removeDuplicateSeparator("/" + fileItemDTO.getPath() + "/" + fileItemDTO.getName() + "/");
-
-                    List<FileItemDTO> fileItems = currentFileService.fileList(filePath);
-                    queue.addAll(fileItems);
-                }
-            }
-            cache.put(CACHE_DIRECTORY_COUNT_KEY, cacheDirectoryCount);
-            cache.put(CACHE_FILE_COUNT_KEY, cacheFileCount);
-        } catch (Exception e) {
-            log.error("缓存所有文件失败", e);
-            e.printStackTrace();
-        }
-        long endTime = System.currentTimeMillis();
-        log.info("缓存 {} 所有文件结束, 用时: {} 秒, 文件夹共 {} 个, 文件共 {} 个",
-                storageStrategy.getDescription(),
-                ( (endTime - startTime) / 1000 ), cacheDirectoryCount, cacheFileCount);
-        cacheFinish = true;
-    }
-
-
-    /**
-     * 清理缓存的文件/文件夹数量统计
-     */
-    public void resetCacheCount() {
-        cache.remove(CACHE_DIRECTORY_COUNT_KEY);
-        cache.remove(CACHE_FILE_COUNT_KEY);
-    }
-
-    public Integer getCacheDirectoryCount() {
-        return ObjectUtil.defaultIfNull(cache.get(CACHE_DIRECTORY_COUNT_KEY), 0);
-    }
-
-    public Integer getCacheFileCount() {
-        return ObjectUtil.defaultIfNull(cache.get(CACHE_FILE_COUNT_KEY), 0);
-    }
-
-    public boolean isCacheFinish() {
-        return cacheFinish;
-    }
-
-    public void setCacheFinish(boolean cacheFinish) {
-        this.cacheFinish = cacheFinish;
-    }
-}

src/main/java/im/zhaojun/common/service/SystemService.java

@@ -1,40 +0,0 @@
-package im.zhaojun.common.service;
-
-import im.zhaojun.common.model.constant.ZFileConstant;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.dto.SiteConfigDTO;
-import im.zhaojun.common.util.HttpUtil;
-import org.springframework.stereotype.Service;
-
-import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * @author zhaojun
- */
-@Service
-public class SystemService {
-
-    @Resource
-    private SystemConfigService systemConfigService;
-
-    /**
-     * 构建指定路径下标题, 页面文档信息
-     * @param path          路径
-     */
-    public synchronized SiteConfigDTO getConfig(String path) throws Exception {
-
-        SiteConfigDTO siteConfigDTO = new SiteConfigDTO();
-        AbstractFileService fileService = systemConfigService.getCurrentFileService();
-
-        List<FileItemDTO> fileItemList = new ArrayList<>(fileService.fileList(path));
-        for (FileItemDTO fileItemDTO : fileItemList) {
-            if (ZFileConstant.README_FILE_NAME.equalsIgnoreCase(fileItemDTO.getName())) {
-                siteConfigDTO.setReadme(HttpUtil.getTextContent(fileItemDTO.getUrl()));
-            }
-        }
-        return siteConfigDTO;
-    }
-
-}

src/main/java/im/zhaojun/zfile/ZfileApplication.java

@@ -1,7 +1,5 @@
-package im.zhaojun;
+package im.zhaojun.zfile;
 
-import com.alicp.jetcache.anno.config.EnableCreateCacheAnnotation;
-import com.alicp.jetcache.anno.config.EnableMethodCache;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.context.annotation.EnableAspectJAutoProxy;
@@ -12,8 +10,6 @@ import org.springframework.scheduling.annotation.EnableAsync;
  */
 @EnableAsync
 @SpringBootApplication
-@EnableMethodCache(basePackages = "im.zhaojun", proxyTargetClass = true)
-@EnableCreateCacheAnnotation
 @EnableAspectJAutoProxy(exposeProxy = true)
 public class ZfileApplication {
 

src/main/java/im/zhaojun/zfile/cache/ZFileCache.java

@@ -0,0 +1,112 @@
+package im.zhaojun.zfile.cache;
+
+import cn.hutool.core.util.StrUtil;
+import im.zhaojun.zfile.model.constant.ZFileConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.dto.SystemConfigDTO;
+import org.springframework.stereotype.Component;
+
+import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+
+/**
+ * @author zhaojun
+ */
+@Component
+public class ZFileCache {
+
+    private ConcurrentMap<String, List<FileItemDTO>> fileCache = new ConcurrentHashMap<>();
+
+    private SystemConfigDTO systemConfigCache;
+
+    public Date lastCacheAutoRefreshDate;
+
+    public synchronized void put(String key, List<FileItemDTO> value) {
+        fileCache.put(key, value);
+    }
+
+    public List<FileItemDTO> get(String key) {
+        return fileCache.get(key);
+    }
+
+    public void clear() {
+        fileCache.clear();
+    }
+
+    public int cacheCount() {
+        return fileCache.size();
+    }
+
+    public List<FileItemDTO> find(String key, boolean ignoreCase, boolean searchContainEncryptedFile) {
+        List<FileItemDTO> result = new ArrayList<>();
+
+        Collection<List<FileItemDTO>> values = fileCache.values();
+        for (List<FileItemDTO> fileItemList : values) {
+
+            // 如果开启了 "搜索包含加密文件" 选项, 则直接返回 true.
+            if (!searchContainEncryptedFile && isEncryptedFolder(fileItemList)) {
+                continue;
+            }
+
+            for (FileItemDTO fileItemDTO : fileItemList) {
+                boolean testResult;
+
+                if (ignoreCase) {
+                    testResult = StrUtil.containsIgnoreCase(fileItemDTO.getName(), key);
+                } else {
+                    testResult = fileItemDTO.getName().contains(key);
+                }
+
+                if (testResult) {
+                    result.add(fileItemDTO);
+                }
+            }
+        }
+        return result;
+    }
+
+    public Set<String> keySet() {
+        return fileCache.keySet();
+    }
+
+    public void remove(String key) {
+        fileCache.remove(key);
+    }
+
+    public void updateConfig(SystemConfigDTO systemConfigCache) {
+        this.systemConfigCache = systemConfigCache;
+    }
+
+    public SystemConfigDTO getConfig() {
+        return this.systemConfigCache;
+    }
+
+    public void removeConfig() {
+        this.systemConfigCache = null;
+    }
+
+    public Date getLastCacheAutoRefreshDate() {
+        return lastCacheAutoRefreshDate;
+    }
+
+    public void setLastCacheAutoRefreshDate(Date lastCacheAutoRefreshDate) {
+        this.lastCacheAutoRefreshDate = lastCacheAutoRefreshDate;
+    }
+
+
+    /**
+     * 不是加密文件夹
+     * @param list      文件夹中的内容
+     * @return          返回此文件夹是否加密.
+     */
+    private boolean isEncryptedFolder(List<FileItemDTO> list) {
+        // 遍历文件判断是否包含
+        for (FileItemDTO fileItemDTO : list) {
+            if (Objects.equals(ZFileConstant.PASSWORD_FILE_NAME, fileItemDTO.getName())) {
+                return true;
+            }
+        }
+        return false;
+    }
+}

src/main/java/im/zhaojun/zfile/config/CacheConfig.java

@@ -0,0 +1,21 @@
+package im.zhaojun.zfile.config;
+
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.List;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+
+/**
+ * @author zhaojun
+ */
+@Configuration
+public class CacheConfig {
+
+    @Bean
+    public ConcurrentMap<String, List<FileItemDTO>> concurrentMapCache() {
+        return new ConcurrentHashMap<>();
+    }
+}

src/main/java/im/zhaojun/zfile/config/ContentTypeTextToTextJson.java

@@ -0,0 +1,26 @@
+package im.zhaojun.zfile.config;
+
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpRequest;
+import org.springframework.http.client.ClientHttpRequestExecution;
+import org.springframework.http.client.ClientHttpRequestInterceptor;
+import org.springframework.http.client.ClientHttpResponse;
+
+import java.io.IOException;
+import java.util.Collections;
+
+/**
+ * @author zhaojun
+ */
+public class ContentTypeTextToTextJson implements ClientHttpRequestInterceptor {
+
+    @Override
+    public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution)
+            throws IOException {
+        ClientHttpResponse response = execution.execute(request, body);
+        HttpHeaders headers = response.getHeaders();
+        headers.put("Content-Type", Collections.singletonList("application/text"));
+        return response;
+    }
+
+} 

src/main/java/im/zhaojun/zfile/config/CorsFilter.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.config;
+package im.zhaojun.zfile.config;
 
 import org.springframework.http.HttpHeaders;
 import org.springframework.web.cors.CorsUtils;

src/main/java/im/zhaojun/zfile/config/GlobalScheduleTask.java

@@ -0,0 +1,81 @@
+package im.zhaojun.zfile.config;
+
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.impl.OneDriveChinaServiceImpl;
+import im.zhaojun.zfile.service.impl.OneDriveServiceImpl;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.util.Objects;
+
+/**
+ * @author zhaojun
+ */
+@Configuration
+@EnableScheduling
+@Slf4j
+public class GlobalScheduleTask {
+
+    @Resource
+    private OneDriveServiceImpl oneDriveServiceImpl;
+
+    @Resource
+    private OneDriveChinaServiceImpl oneDriveChinaServiceImpl;
+
+    @Resource
+    private SystemConfigService systemConfigService;
+
+    /**
+     * 项目启动 30 秒后, 每 15 分钟执行一次刷新 OneDrive Token 的定时任务.
+     */
+    @Scheduled(fixedRate = 1000 * 60 * 10, initialDelay = 1000 * 30)
+    public void autoRefreshOneDriveToken() {
+
+        try {
+            log.debug("尝试调用 OneDrive 自动刷新 AccessToken 定时任务");
+
+            AbstractBaseFileService currentFileService = systemConfigService.getCurrentFileService();
+
+            if (!(currentFileService instanceof OneDriveServiceImpl
+                    || currentFileService instanceof OneDriveChinaServiceImpl)) {
+                log.debug("当前启用存储类型, 不是 OneDrive, 跳过自动刷新 AccessToken");
+                return;
+            }
+
+            if (currentFileService.getIsUnInitialized()) {
+                log.debug("当前启用 OneDrive 未初始化成功, 跳过自动刷新 AccessToken");
+                return;
+            }
+
+            StorageTypeEnum currentStorageTypeEnum = currentFileService.getStorageTypeEnum();
+
+            try {
+                refreshOneDriveToken(currentStorageTypeEnum);
+            } catch (Exception e) {
+                log.debug("刷新 " + currentStorageTypeEnum.getDescription() + " Token 失败.", e);
+            }
+        } catch (Throwable e) {
+            log.debug("尝试调用 OneDrive 自动刷新 AccessToken 定时任务出现未知异常", e);
+        }
+
+    }
+
+    /**
+     * 调用刷新 OneDrive Token
+     */
+    public void refreshOneDriveToken(StorageTypeEnum storageType) {
+        if (Objects.equals(storageType, StorageTypeEnum.ONE_DRIVE_CHINA)) {
+            oneDriveChinaServiceImpl.refreshOneDriveToken();
+        } else {
+            oneDriveServiceImpl.refreshOneDriveToken();
+        }
+        log.info("刷新 {} key 时间: {}", storageType.getDescription(), LocalDateTime.now());
+    }
+
+}

src/main/java/im/zhaojun/zfile/config/OneDriveConfig.java

@@ -1,11 +1,11 @@
-package im.zhaojun.onedrive.common.config;
+package im.zhaojun.zfile.config;
 
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.onedrive.china.service.OneDriveChinaServiceImpl;
-import im.zhaojun.onedrive.international.service.OneDriveServiceImpl;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.service.impl.OneDriveChinaServiceImpl;
+import im.zhaojun.zfile.service.impl.OneDriveServiceImpl;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Lazy;

src/main/java/im/zhaojun/zfile/config/StorageTypeFactory.java

@@ -1,7 +1,7 @@
-package im.zhaojun.common.config;
+package im.zhaojun.zfile.config;
 
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractFileService;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
@@ -15,7 +15,7 @@ import java.util.Map;
 @Component
 public class StorageTypeFactory implements ApplicationContextAware {
 
-    private static Map<String, AbstractFileService> storageTypeEnumFileServiceMap;
+    private static Map<String, AbstractBaseFileService> storageTypeEnumFileServiceMap;
 
     private static ApplicationContext applicationContext;
 
@@ -27,15 +27,15 @@ public class StorageTypeFactory implements ApplicationContextAware {
         applicationContext = act;
 
         // 获取 Spring 容器中所有 FileService 类型的类
-        storageTypeEnumFileServiceMap = act.getBeansOfType(AbstractFileService.class);
+        storageTypeEnumFileServiceMap = act.getBeansOfType(AbstractBaseFileService.class);
     }
 
     /**
      * 获取指定存储类型 Service
      */
-    public static AbstractFileService getStorageTypeService(StorageTypeEnum type) {
-        AbstractFileService result = null;
-        for (AbstractFileService fileService : storageTypeEnumFileServiceMap.values()) {
+    public static AbstractBaseFileService getStorageTypeService(StorageTypeEnum type) {
+        AbstractBaseFileService result = null;
+        for (AbstractBaseFileService fileService : storageTypeEnumFileServiceMap.values()) {
             if (fileService.getStorageTypeEnum() == type) {
                 result = fileService;
                 break;

src/main/java/im/zhaojun/zfile/config/WebMvcConfig.java

@@ -1,6 +1,6 @@
-package im.zhaojun.common.config;
+package im.zhaojun.zfile.config;
 
-import im.zhaojun.common.model.enums.StorageTypeEnumDeSerializerConvert;
+import im.zhaojun.zfile.model.enums.StorageTypeEnumDeSerializerConvert;
 import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
 import org.springframework.boot.web.servlet.server.ServletWebServerFactory;
 import org.springframework.context.annotation.Bean;

src/main/java/im/zhaojun/zfile/config/ZFileConfiguration.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.config;
+package im.zhaojun.zfile.config;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -6,6 +6,7 @@ import org.springframework.http.converter.StringHttpMessageConverter;
 import org.springframework.web.client.RestTemplate;
 
 import java.nio.charset.StandardCharsets;
+import java.util.Collections;
 
 /**
  * @author zhaojun
@@ -17,6 +18,7 @@ public class ZFileConfiguration {
     public RestTemplate restTemplate(){
         RestTemplate restTemplate = new RestTemplate();
         restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
+        restTemplate.setInterceptors(Collections.singletonList(new ContentTypeTextToTextJson()));
         return restTemplate;
     }
 

src/main/java/im/zhaojun/zfile/controller/AdminController.java

@@ -1,19 +1,19 @@
-package im.zhaojun.common.controller;
+package im.zhaojun.zfile.controller;
 
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ZipUtil;
-import im.zhaojun.common.config.StorageTypeFactory;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.SystemMonitorInfo;
-import im.zhaojun.common.model.dto.ResultBean;
-import im.zhaojun.common.model.dto.StorageStrategyDTO;
-import im.zhaojun.common.model.dto.SystemConfigDTO;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.FileAsyncCacheService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.common.service.SystemConfigService;
-import im.zhaojun.common.util.FileUtil;
+import im.zhaojun.zfile.config.StorageTypeFactory;
+import im.zhaojun.zfile.model.dto.ResultBean;
+import im.zhaojun.zfile.model.dto.StorageStrategyDTO;
+import im.zhaojun.zfile.model.dto.SystemConfigDTO;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.model.support.SystemMonitorInfo;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.support.FileAsyncCacheService;
+import im.zhaojun.zfile.util.FileUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.http.ResponseEntity;
@@ -26,11 +26,7 @@ import org.springframework.web.bind.annotation.RestController;
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
 import java.io.File;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.util.*;
 
 /**
  * 后台管理
@@ -65,18 +61,20 @@ public class AdminController {
      */
     @PostMapping("/config")
     public ResultBean updateConfig(SystemConfigDTO systemConfigDTO) throws Exception {
-        AbstractFileService currentFileService = systemConfigService.getCurrentFileService();
-        systemConfigDTO.setId(1);
-        systemConfigService.updateSystemConfig(systemConfigDTO);
-
-        StorageTypeEnum currentStorageStrategy = currentFileService.getStorageTypeEnum();
+        StorageTypeEnum currentStorageStrategy = systemConfigService.getCurrentStorageStrategy();
         if (!Objects.equals(currentStorageStrategy, systemConfigDTO.getStorageStrategy())) {
+            if (systemConfigService.getEnableCache()) {
+                return ResultBean.error("不支持缓存开启状态下, 切换存储策略, 请先手动关闭缓存");
+            }
             log.info("已将存储策略由 {} 切换为 {}",
                     currentStorageStrategy.getDescription(),
                     systemConfigDTO.getStorageStrategy().getDescription());
             refreshStorageStrategy();
         }
 
+        systemConfigDTO.setId(1);
+        systemConfigService.updateSystemConfig(systemConfigDTO);
+
         return ResultBean.success();
     }
 
@@ -108,7 +106,7 @@ public class AdminController {
         List<StorageStrategyDTO> result = new ArrayList<>();
         StorageTypeEnum[] values = StorageTypeEnum.values();
         for (StorageTypeEnum value : values) {
-            AbstractFileService storageTypeService = StorageTypeFactory.getStorageTypeService(value);
+            AbstractBaseFileService storageTypeService = StorageTypeFactory.getStorageTypeService(value);
             result.add(new StorageStrategyDTO(value.getKey(),
                                     value.getDescription(),
                                     storageTypeService.getIsInitialized()));
@@ -121,10 +119,9 @@ public class AdminController {
      * @param storageStrategyConfig     保存表单值
      * @param storageStrategy           所属策略
      * @return                          操作结果
-     * @throws Exception                表单解析出错异常
      */
     @PostMapping("/storage-strategy")
-    public ResultBean save(@RequestParam Map<String, String> storageStrategyConfig, StorageTypeEnum storageStrategy) throws Exception {
+    public ResultBean save(@RequestParam Map<String, String> storageStrategyConfig, StorageTypeEnum storageStrategy) {
         // 保存设置.
         List<StorageConfig> storageConfigList = storageConfigService.selectStorageConfigByType(storageStrategy);
         for (StorageConfig storageConfig : storageConfigList) {
@@ -135,7 +132,7 @@ public class AdminController {
         storageConfigService.updateStorageConfig(storageConfigList);
 
         // 获取当前修改的存储策略 Service, 尝试调用初始化.
-        AbstractFileService updateStorageStrategyService = StorageTypeFactory.getStorageTypeService(storageStrategy);
+        AbstractBaseFileService updateStorageStrategyService = StorageTypeFactory.getStorageTypeService(storageStrategy);
         updateStorageStrategyService.init();
 
         // 如果修改的为当前启用的缓存, 则重新进行缓存.
@@ -145,7 +142,7 @@ public class AdminController {
                 log.debug("检测到更新了当前启用的存储策略 {}, 已清理缓存.", currentStorageStrategy);
             }
 
-            AbstractFileService fileService = systemConfigService.getCurrentFileService();
+            AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
             fileService.clearFileCache();
             fileAsyncCacheService.cacheGlobalFile();
         }
@@ -161,7 +158,7 @@ public class AdminController {
     /**
      * 更新存储策略
      */
-    public void refreshStorageStrategy() throws Exception {
+    public void refreshStorageStrategy() {
         StorageTypeEnum storageStrategy = systemConfigService.getCurrentStorageStrategy();
         refreshStorageStrategy(storageStrategy);
     }
@@ -169,11 +166,11 @@ public class AdminController {
     /**
      * 更新存储策略
      */
-    public void refreshStorageStrategy(StorageTypeEnum storageStrategy) throws Exception {
+    private void refreshStorageStrategy(StorageTypeEnum storageStrategy) {
         if (storageStrategy == null) {
             log.info("尚未配置存储策略.");
         } else {
-            AbstractFileService fileService = systemConfigService.getCurrentFileService();
+            AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
             fileService.init();
             fileService.clearFileCache();
             log.info("切换至存储类型: {}", storageStrategy.getDescription());

src/main/java/im/zhaojun/zfile/controller/CacheController.java

@@ -1,18 +1,18 @@
-package im.zhaojun.common.controller;
+package im.zhaojun.zfile.controller;
 
-import im.zhaojun.common.model.dto.CacheConfigDTO;
-import im.zhaojun.common.model.dto.ResultBean;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.FileAsyncCacheService;
-import im.zhaojun.common.service.FileCacheService;
-import im.zhaojun.common.service.SystemConfigService;
+import im.zhaojun.zfile.cache.ZFileCache;
+import im.zhaojun.zfile.model.dto.CacheConfigDTO;
+import im.zhaojun.zfile.model.dto.ResultBean;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.support.FileAsyncCacheService;
+import im.zhaojun.zfile.service.support.FileCacheService;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
-import java.util.Set;
 
 /**
  * @author zhaojun
@@ -30,51 +30,55 @@ public class CacheController {
     @Resource
     private FileCacheService fileCacheService;
 
+    @Resource
+    private ZFileCache zFileCache;
+
     @PostMapping("/enable")
-    public ResultBean enableCache() throws Exception {
+    public ResultBean enableCache() {
         fileCacheService.enableCache();
         return ResultBean.success();
     }
 
     @PostMapping("/disable")
-    public ResultBean disableCache() throws Exception {
+    public ResultBean disableCache() {
         fileCacheService.disableCache();
         return ResultBean.success();
     }
 
     @GetMapping("/config")
-    public ResultBean cacheConfig() throws Exception {
-        AbstractFileService fileService = systemConfigService.getCurrentFileService();
-        Set<String> cacheKeys = fileService.getCacheKeys();
-
+    public ResultBean cacheConfig() {
         CacheConfigDTO cacheConfigDTO = new CacheConfigDTO();
         cacheConfigDTO.setEnableCache(systemConfigService.getEnableCache());
         cacheConfigDTO.setCacheFinish(fileAsyncCacheService.isCacheFinish());
-        cacheConfigDTO.setCacheKeys(cacheKeys);
-        cacheConfigDTO.setCacheDirectoryCount(fileAsyncCacheService.getCacheDirectoryCount());
-        cacheConfigDTO.setCacheFileCount(fileAsyncCacheService.getCacheFileCount());
+        cacheConfigDTO.setCacheKeys(zFileCache.keySet());
+        cacheConfigDTO.setCacheDirectoryCount(zFileCache.cacheCount());
+        cacheConfigDTO.setLastCacheAutoRefreshDate(zFileCache.getLastCacheAutoRefreshDate());
         return ResultBean.success(cacheConfigDTO);
     }
 
+
     @PostMapping("/refresh")
     public ResultBean refreshCache(String key) throws Exception {
-        AbstractFileService fileService = systemConfigService.getCurrentFileService();
+        AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
         fileService.refreshCache(key);
         return ResultBean.success();
     }
 
+    /*
     @PostMapping("/clear")
-    public ResultBean clearCache(String key) throws Exception {
+    public ResultBean clearCache(String key) {
         AbstractFileService fileService = systemConfigService.getCurrentFileService();
         fileService.clearFileCache();
         return ResultBean.success();
     }
 
+
     @PostMapping("/all")
-    public ResultBean cacheAll() throws Exception {
+    public ResultBean cacheAll()  {
         AbstractFileService fileService = systemConfigService.getCurrentFileService();
         fileService.clearFileCache();
         fileAsyncCacheService.cacheGlobalFile();
         return ResultBean.success();
     }
+    */
 }

src/main/java/im/zhaojun/zfile/controller/CommonController.java

@@ -1,9 +1,9 @@
-package im.zhaojun.common.controller;
+package im.zhaojun.zfile.controller;
 
-import im.zhaojun.common.model.dto.ResultBean;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.util.AudioHelper;
-import im.zhaojun.common.util.HttpUtil;
+import im.zhaojun.zfile.model.dto.ResultBean;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.util.AudioHelper;
+import im.zhaojun.zfile.util.HttpUtil;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;

src/main/java/im/zhaojun/zfile/controller/FileController.java

@@ -1,36 +1,37 @@
-package im.zhaojun.common.controller;
+package im.zhaojun.zfile.controller;
 
 import cn.hutool.core.util.BooleanUtil;
 import cn.hutool.core.util.URLUtil;
-import im.zhaojun.common.annotation.CheckStorageStrategyInit;
-import im.zhaojun.common.exception.SearchDisableException;
-import im.zhaojun.common.model.constant.ZFileConstant;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.dto.ResultBean;
-import im.zhaojun.common.model.dto.SiteConfigDTO;
-import im.zhaojun.common.model.dto.SystemConfigDTO;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.FileAsyncCacheService;
-import im.zhaojun.common.service.SystemConfigService;
-import im.zhaojun.common.service.SystemService;
-import im.zhaojun.common.util.FileComparator;
-import im.zhaojun.common.util.HttpUtil;
-import im.zhaojun.common.util.StringUtils;
+import im.zhaojun.zfile.model.annotation.CheckStorageStrategyInit;
+import im.zhaojun.zfile.exception.SearchDisableException;
+import im.zhaojun.zfile.model.support.FilePageModel;
+import im.zhaojun.zfile.model.constant.ZFileConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.dto.ResultBean;
+import im.zhaojun.zfile.model.dto.SiteConfigDTO;
+import im.zhaojun.zfile.model.dto.SystemConfigDTO;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.support.FileAsyncCacheService;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.service.SystemService;
+import im.zhaojun.zfile.util.FileComparator;
+import im.zhaojun.zfile.util.HttpUtil;
+import im.zhaojun.zfile.util.StringUtils;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.client.HttpClientErrorException;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.List;
+import java.util.*;
 
 /**
  * 前台文件管理
  * @author zhaojun
  */
+@Slf4j
 @RequestMapping("/api")
 @RestController
 public class FileController {
@@ -56,20 +57,37 @@ public class FileController {
                            @RequestParam(defaultValue = "asc") String order,
                            @RequestParam(required = false) String password,
                            @RequestParam(defaultValue = "1") Integer page) throws Exception {
-        AbstractFileService fileService = systemConfigService.getCurrentFileService();
+        AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
         List<FileItemDTO> fileItemList = fileService.fileList(StringUtils.removeDuplicateSeparator("/" + path + "/"));
         for (FileItemDTO fileItemDTO : fileItemList) {
-            if (ZFileConstant.PASSWORD_FILE_NAME.equals(fileItemDTO.getName())
-                && !HttpUtil.getTextContent(fileItemDTO.getUrl()).equals(password)) {
+            if (ZFileConstant.PASSWORD_FILE_NAME.equals(fileItemDTO.getName())) {
+                String expectedPasswordContent;
+                try {
+                    expectedPasswordContent = HttpUtil.getTextContent(fileItemDTO.getUrl() + '1');
+                } catch (HttpClientErrorException httpClientErrorException) {
+                    log.debug("尝试重新获取密码文件缓存中链接后仍失败", httpClientErrorException);
+                    try {
+                        String fullPath = StringUtils.removeDuplicateSeparator(fileItemDTO.getPath() + "/" + fileItemDTO.getName());
+                        FileItemDTO fileItem = fileService.getFileItem(fullPath);
+                        expectedPasswordContent = HttpUtil.getTextContent(fileItem.getUrl());
+                    } catch (Exception e) {
+                        log.debug("尝试重新获取密码文件链接后仍失败, 已暂时取消密码", e);
+                        break;
+                    }
+                }
+
+                if (Objects.equals(expectedPasswordContent, password)) {
+                    break;
+                }
+
                 if (password != null && !"".equals(password)) {
-                    return ResultBean.error("密码错误.");
+                    return ResultBean.error("密码错误.", ResultBean.INVALID_PASSWORD);
                 }
                 return ResultBean.error("此文件夹需要密码.", ResultBean.REQUIRED_PASSWORD);
             }
         }
 
-        List<FileItemDTO> sortedPagingData = getSortedPagingData(fileItemList, page);
-        return ResultBean.successData(sortedPagingData);
+        return ResultBean.successData(getSortedPagingData(fileItemList, page));
     }
 
 
@@ -92,7 +110,7 @@ public class FileController {
                              @RequestParam(defaultValue = "name") String sortBy,
                              @RequestParam(defaultValue = "asc") String order,
                              @RequestParam(defaultValue = "1") Integer page) {
-        AbstractFileService fileService = systemConfigService.getCurrentFileService();
+        AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
         SystemConfigDTO systemConfigDTO = systemConfigService.getSystemConfig();
         if (BooleanUtil.isFalse(systemConfigDTO.getSearchEnable())) {
             throw new SearchDisableException("搜索功能未开启");
@@ -101,8 +119,7 @@ public class FileController {
             throw new SearchDisableException("搜索功能缓存预热中, 请稍后再试");
         }
         List<FileItemDTO> fileItemList = fileService.search(URLUtil.decode(name));
-        List<FileItemDTO> sortedPagingData = getSortedPagingData(fileItemList, page);
-        return ResultBean.successData(sortedPagingData);
+        return ResultBean.successData(getSortedPagingData(fileItemList, page));
     }
 
 
@@ -119,7 +136,7 @@ public class FileController {
     }
 
 
-    private List<FileItemDTO> getSortedPagingData(List<FileItemDTO> fileItemList, Integer page) {
+    private FilePageModel getSortedPagingData(List<FileItemDTO> fileItemList, Integer page) {
         ArrayList<FileItemDTO> copy = new ArrayList<>(Arrays.asList(new FileItemDTO[fileItemList.size()]));
         Collections.copy(copy, fileItemList);
 
@@ -131,13 +148,13 @@ public class FileController {
         int totalPage = (total + PAGE_SIZE - 1) / PAGE_SIZE;
 
         if (page > totalPage) {
-            return new ArrayList<>();
+            return new FilePageModel(total, totalPage, Collections.emptyList());
         }
 
         int start = (page - 1) * PAGE_SIZE;
         int end = page * PAGE_SIZE;
         end = Math.min(end, total);
-        return new ArrayList<>(copy.subList(start, end));
+        return new FilePageModel(total, totalPage, copy.subList(start, end));
     }
 
 
@@ -149,7 +166,7 @@ public class FileController {
     @CheckStorageStrategyInit
     @GetMapping("/directlink")
     public ResultBean directlink(String path) {
-        AbstractFileService fileService = systemConfigService.getCurrentFileService();
+        AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
         return ResultBean.successData(fileService.getFileItem(path));
     }
 }

src/main/java/im/zhaojun/zfile/controller/InstallController.java

@@ -1,13 +1,13 @@
-package im.zhaojun.common.controller;
+package im.zhaojun.zfile.controller;
 
 import cn.hutool.crypto.SecureUtil;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.dto.InstallModelDTO;
-import im.zhaojun.common.model.dto.ResultBean;
-import im.zhaojun.common.model.dto.SystemConfigDTO;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.common.service.SystemConfigService;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.dto.InstallModelDTO;
+import im.zhaojun.zfile.model.dto.ResultBean;
+import im.zhaojun.zfile.model.dto.SystemConfigDTO;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.service.SystemConfigService;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RestController;

src/main/java/im/zhaojun/zfile/controller/LocalController.java

@@ -1,8 +1,8 @@
-package im.zhaojun.local.controller;
+package im.zhaojun.zfile.controller;
 
-import im.zhaojun.common.util.FileUtil;
-import im.zhaojun.common.util.StringUtils;
-import im.zhaojun.local.service.LocalServiceImpl;
+import im.zhaojun.zfile.util.FileUtil;
+import im.zhaojun.zfile.util.StringUtils;
+import im.zhaojun.zfile.service.impl.LocalServiceImpl;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.util.AntPathMatcher;

src/main/java/im/zhaojun/zfile/controller/OneDriveController.java

@@ -1,8 +1,8 @@
-package im.zhaojun.onedrive.common.controller;
+package im.zhaojun.zfile.controller;
 
-import im.zhaojun.onedrive.china.service.OneDriveChinaServiceImpl;
-import im.zhaojun.onedrive.common.model.OneDriveToken;
-import im.zhaojun.onedrive.international.service.OneDriveServiceImpl;
+import im.zhaojun.zfile.service.impl.OneDriveChinaServiceImpl;
+import im.zhaojun.zfile.model.support.OneDriveToken;
+import im.zhaojun.zfile.service.impl.OneDriveServiceImpl;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.GetMapping;

src/main/java/im/zhaojun/zfile/controller/PageController.java

@@ -1,10 +1,11 @@
-package im.zhaojun.common.controller;
+package im.zhaojun.zfile.controller;
 
 import cn.hutool.core.util.URLUtil;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.SystemConfigService;
+import im.zhaojun.zfile.model.constant.ZFileConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
 import org.springframework.stereotype.Controller;
 import org.springframework.util.AntPathMatcher;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -12,7 +13,6 @@ import org.springframework.web.servlet.HandlerMapping;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
-import java.net.MalformedURLException;
 import java.util.Objects;
 
 /**
@@ -26,18 +26,18 @@ public class PageController {
     private SystemConfigService systemConfigService;
 
     @GetMapping("/directlink/**")
-    public String directlink(final HttpServletRequest request) throws MalformedURLException {
+    public String directlink(final HttpServletRequest request) {
         String path = (String) request.getAttribute(
                 HandlerMapping.PATH_WITHIN_HANDLER_MAPPING_ATTRIBUTE);
         String bestMatchPattern = (String) request.getAttribute(HandlerMapping.BEST_MATCHING_PATTERN_ATTRIBUTE);
         AntPathMatcher apm = new AntPathMatcher();
         String filePath = apm.extractPathWithinPattern(bestMatchPattern, path);
 
-        if (filePath.length() > 0 && filePath.charAt(0) != '/') {
+        if (filePath.length() > 0 && filePath.charAt(0) != ZFileConstant.PATH_SEPARATOR_CHAR) {
             filePath = "/" + filePath;
         }
 
-        AbstractFileService fileService = systemConfigService.getCurrentFileService();
+        AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
         FileItemDTO fileItem = fileService.getFileItem(filePath);
 
         String url = fileItem.getUrl();

src/main/java/im/zhaojun/zfile/core/FileListCacheAop.java

@@ -0,0 +1,51 @@
+package im.zhaojun.zfile.core;
+
+import im.zhaojun.zfile.cache.ZFileCache;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.service.SystemConfigService;
+import org.aspectj.lang.ProceedingJoinPoint;
+import org.aspectj.lang.annotation.Around;
+import org.aspectj.lang.annotation.Aspect;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @author zhaojun
+ * 缓存切面类, 用于访问文件夹时, 缓存文件列表内容.
+ */
+@Aspect
+@Component
+public class FileListCacheAop {
+
+    @Resource
+    private ZFileCache zFileCache;
+
+    @Resource
+    private SystemConfigService systemConfigService;
+
+    @Around(value = "execution(public * im.zhaojun.zfile.service.base.AbstractBaseFileService.fileList(..))")
+    public Object around(ProceedingJoinPoint point) throws Throwable {
+        List<FileItemDTO> result;
+
+        Object[] args = point.getArgs();
+        String path = String.valueOf(args[0]);
+
+        boolean enableCache = systemConfigService.getEnableCache();
+
+        if (enableCache) {
+            List<FileItemDTO> cacheFileList = zFileCache.get(path);
+            if (CollectionUtils.isEmpty(cacheFileList)) {
+                result = (List<FileItemDTO>) point.proceed();
+                zFileCache.put(path, result);
+            } else {
+                result = cacheFileList;
+            }
+        } else {
+            result = (List<FileItemDTO>) point.proceed();
+        }
+        return result;
+    }
+}

src/main/java/im/zhaojun/zfile/core/StorageStrategyInitCheckAop.java

@@ -1,9 +1,9 @@
-package im.zhaojun.common.aspect;
+package im.zhaojun.zfile.core;
 
-import im.zhaojun.common.exception.StorageStrategyUninitializedException;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.SystemConfigService;
-import im.zhaojun.common.util.SpringContextHolder;
+import im.zhaojun.zfile.exception.StorageStrategyUninitializedException;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.util.SpringContextHolder;
 import org.aspectj.lang.annotation.Aspect;
 import org.aspectj.lang.annotation.Before;
 import org.springframework.stereotype.Component;
@@ -13,12 +13,12 @@ import org.springframework.stereotype.Component;
  */
 @Aspect
 @Component
-public class StorageStrategyInitCheckAspect {
+public class StorageStrategyInitCheckAop {
 
-    @Before("@annotation(im.zhaojun.common.annotation.CheckStorageStrategyInit)")
+    @Before("@annotation(im.zhaojun.zfile.model.annotation.CheckStorageStrategyInit)")
     public void logStart() {
         SystemConfigService systemConfigService = SpringContextHolder.getBean(SystemConfigService.class);
-        AbstractFileService currentFileService = systemConfigService.getCurrentFileService();
+        AbstractBaseFileService currentFileService = systemConfigService.getCurrentFileService();
         if (currentFileService == null) {
             throw new StorageStrategyUninitializedException("存储策略尚未初始化, 请联系管理员!");
         }

src/main/java/im/zhaojun/zfile/exception/GlobleExceptionHandler.java

@@ -1,6 +1,6 @@
-package im.zhaojun.common.exception;
+package im.zhaojun.zfile.exception;
 
-import im.zhaojun.common.model.dto.ResultBean;
+import im.zhaojun.zfile.model.dto.ResultBean;
 import org.apache.catalina.connector.ClientAbortException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

src/main/java/im/zhaojun/zfile/exception/InitializeException.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.exception;
+package im.zhaojun.zfile.exception;
 
 /**
  * 对象存储初始化异常

src/main/java/im/zhaojun/zfile/exception/NotExistFileException.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.exception;
+package im.zhaojun.zfile.exception;
 
 /**
  * @author zhaojun

src/main/java/im/zhaojun/zfile/exception/SearchDisableException.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.exception;
+package im.zhaojun.zfile.exception;
 
 /**
  * @author zhaojun

src/main/java/im/zhaojun/zfile/exception/StorageStrategyUninitializedException.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.exception;
+package im.zhaojun.zfile.exception;
 
 /**
  * 存储策略未初始化异常

src/main/java/im/zhaojun/zfile/exception/UnknownStorageTypeException.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.exception;
+package im.zhaojun.zfile.exception;
 
 /**
  * 未知的存储类型异常

src/main/java/im/zhaojun/zfile/filter/MyCorsFilter.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.security;
+package im.zhaojun.zfile.filter;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

src/main/java/im/zhaojun/zfile/model/annotation/CheckStorageStrategyInit.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.annotation;
+package im.zhaojun.zfile.model.annotation;
 
 import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;

src/main/java/im/zhaojun/zfile/model/constant/StorageConfigConstant.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.constant;
+package im.zhaojun.zfile.model.constant;
 
 /**
  * @author zhaojun

src/main/java/im/zhaojun/zfile/model/constant/SystemConfigConstant.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.constant;
+package im.zhaojun.zfile.model.constant;
 
 /**
  * @author zhaojun

src/main/java/im/zhaojun/zfile/model/constant/ZFileConstant.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.constant;
+package im.zhaojun.zfile.model.constant;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -14,6 +14,10 @@ public class ZFileConstant {
 
     public static final String AUDIO_TMP_PATH = "/.zfile/tmp/audio/";
 
+    public static final Character PATH_SEPARATOR_CHAR = '/';
+
+    public static final String PATH_SEPARATOR = "/";
+
     /**
      * 页面文档文件
      */

src/main/java/im/zhaojun/zfile/model/dto/AudioInfoDTO.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
 /**
  * @author zhaojun

src/main/java/im/zhaojun/zfile/model/dto/CacheConfigDTO.java

@@ -1,7 +1,8 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
 import lombok.Data;
 
+import java.util.Date;
 import java.util.Set;
 
 /**
@@ -14,4 +15,5 @@ public class CacheConfigDTO {
     private Set<String> cacheKeys;
     private Integer cacheDirectoryCount;
     private Integer cacheFileCount;
+    private Date lastCacheAutoRefreshDate;
 }

src/main/java/im/zhaojun/zfile/model/dto/FileItemDTO.java

@@ -1,6 +1,6 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
-import im.zhaojun.common.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
 
 import java.io.Serializable;
 import java.util.Date;

src/main/java/im/zhaojun/zfile/model/dto/InstallModelDTO.java

@@ -1,6 +1,6 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
-import im.zhaojun.common.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
 
 import java.util.Map;
 

src/main/java/im/zhaojun/zfile/model/dto/ResultBean.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
 import java.io.Serializable;
 
@@ -15,6 +15,8 @@ public class ResultBean implements Serializable {
 
     public static final int REQUIRED_PASSWORD = -2;
 
+    public static final int INVALID_PASSWORD = -3;
+
     private String msg = "操作成功";
 
     private int code = SUCCESS;
@@ -43,6 +45,10 @@ public class ResultBean implements Serializable {
         return success("操作成功", data);
     }
 
+    public static ResultBean successPage(Object data, Long total) {
+        return success("操作成功", data);
+    }
+
     public static ResultBean success(Object data) {
         return success("操作成功", data);
     }

src/main/java/im/zhaojun/zfile/model/dto/SiteConfigDTO.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
 import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.Data;

src/main/java/im/zhaojun/zfile/model/dto/StorageStrategyDTO.java

@@ -1,5 +1,6 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
+import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
@@ -16,6 +17,7 @@ public class StorageStrategyDTO {
 
     private String description;
 
-    private boolean available;
+    @JsonProperty(defaultValue = "false")
+    private Boolean available;
 
 }

src/main/java/im/zhaojun/zfile/model/dto/SystemConfigDTO.java

@@ -1,9 +1,9 @@
-package im.zhaojun.common.model.dto;
+package im.zhaojun.zfile.model.dto;
 
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.databind.annotation.JsonSerialize;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.model.enums.StorageTypeEnumSerializerConvert;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.model.enums.StorageTypeEnumSerializerConvert;
 import lombok.Data;
 import lombok.ToString;
 

src/main/java/im/zhaojun/zfile/model/entity/StorageConfig.java

@@ -1,6 +1,6 @@
-package im.zhaojun.common.model;
+package im.zhaojun.zfile.model.entity;
 
-import im.zhaojun.common.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
 import lombok.Data;
 
 import javax.persistence.Column;

src/main/java/im/zhaojun/zfile/model/entity/SystemConfig.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model;
+package im.zhaojun.zfile.model.entity;
 
 import lombok.Data;
 

src/main/java/im/zhaojun/zfile/model/enums/FileTypeEnum.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.enums;
+package im.zhaojun.zfile.model.enums;
 
 /**
  * @author zhaojun

src/main/java/im/zhaojun/zfile/model/enums/StorageTypeEnum.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.enums;
+package im.zhaojun.zfile.model.enums;
 
 import com.fasterxml.jackson.annotation.JsonFormat;
 
@@ -14,18 +14,18 @@ public enum StorageTypeEnum {
     /**
      * 当前系统支持的所有存储策略
      */
-    ALIYUN("aliyun", "阿里云 OSS"),
-    FTP("ftp", "FTP"),
-    HUAWEI("huawei", "华为云 OBS"),
     LOCAL("local", "本地存储"),
+    ALIYUN("aliyun", "阿里云 OSS"),
+    TENCENT("tencent", "腾讯云 COS"),
+    UPYUN("upyun", "又拍云 USS"),
+    FTP("ftp", "FTP"),
+    UFILE("ufile", "UFile"),
+    HUAWEI("huawei", "华为云 OBS"),
     MINIO("minio", "MINIO"),
     S3("s3", "S3通用协议"),
     ONE_DRIVE("onedrive", "OneDrive"),
     ONE_DRIVE_CHINA("onedrive-china", "OneDrive 世纪互联"),
-    QINIU("qiniu", "七牛云 KODO"),
-    TENCENT("tencent", "腾讯云 COS"),
-    UPYUN("upyun", "又拍云 USS");
-
+    QINIU("qiniu", "七牛云 KODO");
 
     private String key;
     private String description;

src/main/java/im/zhaojun/zfile/model/enums/StorageTypeEnumConvert.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.enums;
+package im.zhaojun.zfile.model.enums;
 
 import javax.persistence.AttributeConverter;
 import javax.persistence.Converter;

src/main/java/im/zhaojun/zfile/model/enums/StorageTypeEnumDeSerializerConvert.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.enums;
+package im.zhaojun.zfile.model.enums;
 
 import org.springframework.core.convert.converter.Converter;
 import org.springframework.lang.NonNull;

src/main/java/im/zhaojun/zfile/model/enums/StorageTypeEnumSerializerConvert.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model.enums;
+package im.zhaojun.zfile.model.enums;
 
 import com.fasterxml.jackson.core.JsonGenerator;
 import com.fasterxml.jackson.databind.JsonSerializer;

src/main/java/im/zhaojun/zfile/model/support/FilePageModel.java

@@ -0,0 +1,22 @@
+package im.zhaojun.zfile.model.support;
+
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author zhaojun
+ */
+@Data
+@AllArgsConstructor
+public class FilePageModel {
+
+    private int total;
+
+    private int totalPage;
+
+    private List<FileItemDTO> fileList;
+
+}

src/main/java/im/zhaojun/zfile/model/support/Jvm.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model;
+package im.zhaojun.zfile.model.support;
 
 import lombok.Data;
 

src/main/java/im/zhaojun/zfile/model/support/Mem.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model;
+package im.zhaojun.zfile.model.support;
 
 import com.sun.management.OperatingSystemMXBean;
 import lombok.Data;
@@ -27,11 +27,11 @@ public class Mem {
     private double free;
 
     public Mem() {
-        OperatingSystemMXBean operatingSystemMXBean = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
+        OperatingSystemMXBean osb = (OperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean();
         // 总的物理内存+虚拟内存
-        long totalVirtualMemory = operatingSystemMXBean.getTotalSwapSpaceSize();
+        long totalVirtualMemory = osb.getTotalSwapSpaceSize();
         // 剩余的物理内存
-        long freePhysicalMemorySize = operatingSystemMXBean.getFreePhysicalMemorySize();
+        long freePhysicalMemorySize = osb.getFreePhysicalMemorySize();
         this.total = totalVirtualMemory;
         this.free = freePhysicalMemorySize;
         this.used = totalVirtualMemory - freePhysicalMemorySize;

src/main/java/im/zhaojun/zfile/model/support/OneDriveToken.java

@@ -1,4 +1,4 @@
-package im.zhaojun.onedrive.common.model;
+package im.zhaojun.zfile.model.support;
 
 import com.alibaba.fastjson.annotation.JSONField;
 import lombok.Data;

src/main/java/im/zhaojun/zfile/model/support/Sys.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.model;
+package im.zhaojun.zfile.model.support;
 
 import cn.hutool.core.date.BetweenFormater;
 import cn.hutool.core.date.DateUtil;

src/main/java/im/zhaojun/zfile/model/support/SystemMonitorInfo.java

@@ -1,5 +1,8 @@
-package im.zhaojun.common.model;
+package im.zhaojun.zfile.model.support;
 
+import im.zhaojun.zfile.model.support.Jvm;
+import im.zhaojun.zfile.model.support.Mem;
+import im.zhaojun.zfile.model.support.Sys;
 import lombok.Data;
 
 import java.io.Serializable;

src/main/java/im/zhaojun/zfile/repository/StorageConfigRepository.java

@@ -1,7 +1,7 @@
-package im.zhaojun.common.repository;
+package im.zhaojun.zfile.repository;
 
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 

src/main/java/im/zhaojun/zfile/repository/SystemConfigRepository.java

@@ -1,6 +1,6 @@
-package im.zhaojun.common.repository;
+package im.zhaojun.zfile.repository;
 
-import im.zhaojun.common.model.SystemConfig;
+import im.zhaojun.zfile.model.entity.SystemConfig;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 

src/main/java/im/zhaojun/zfile/security/Md5PasswordEncoder.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.security;
+package im.zhaojun.zfile.security;
 
 import cn.hutool.crypto.SecureUtil;
 import org.springframework.security.crypto.password.PasswordEncoder;

src/main/java/im/zhaojun/zfile/security/MySecurityConfig.java

@@ -1,7 +1,7 @@
-package im.zhaojun.common.security;
+package im.zhaojun.zfile.security;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
-import im.zhaojun.common.model.dto.ResultBean;
+import im.zhaojun.zfile.model.dto.ResultBean;
 import org.springframework.context.annotation.Bean;
 import org.springframework.http.HttpMethod;
 import org.springframework.security.authentication.BadCredentialsException;
@@ -21,6 +21,7 @@ import java.io.PrintWriter;
 
 /**
  * 自定义 Security 配置类
+ *
  * @author zhaojun
  */
 @EnableWebSecurity
@@ -34,7 +35,7 @@ public class MySecurityConfig extends WebSecurityConfigurerAdapter {
         http
                 // .authenticationProvider(authenticationProvider())
                 .exceptionHandling()
-                //未登录时，进行json格式的提示，很喜欢这种写法，不用单独写一个又一个的类
+                // 未登录时，进行 json 格式的提示.
                 .authenticationEntryPoint((request, response, authException) -> {
                     response.setContentType("application/json;charset=utf-8");
                     response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
@@ -48,8 +49,8 @@ public class MySecurityConfig extends WebSecurityConfigurerAdapter {
                 .antMatchers("/").permitAll()
                 .antMatchers("/admin/**").authenticated()
                 .and()
-                .formLogin() //使用自带的登录
-                //登录失败，返回json
+                .formLogin() // 使用自带的登录
+                // 登录失败，返回json
                 .failureHandler((request, response, ex) -> {
                     response.setContentType("application/json;charset=utf-8");
                     response.setStatus(HttpServletResponse.SC_FORBIDDEN);
@@ -64,7 +65,7 @@ public class MySecurityConfig extends WebSecurityConfigurerAdapter {
                     out.flush();
                     out.close();
                 })
-                //登录成功，返回json
+                // 登录成功，返回json
                 .successHandler((request, response, authentication) -> {
                     response.setContentType("application/json;charset=utf-8");
                     PrintWriter out = response.getWriter();
@@ -74,7 +75,7 @@ public class MySecurityConfig extends WebSecurityConfigurerAdapter {
                 })
                 .and()
                 .exceptionHandling()
-                //没有权限，返回json
+                // 没有权限，返回json
                 .accessDeniedHandler((request, response, ex) -> {
                     response.setContentType("application/json;charset=utf-8");
                     response.setStatus(HttpServletResponse.SC_FORBIDDEN);
@@ -85,7 +86,7 @@ public class MySecurityConfig extends WebSecurityConfigurerAdapter {
                 })
                 .and()
                 .logout()
-                //退出成功，返回json
+                // 退出成功，返回 json
                 .logoutSuccessHandler((request, response, authentication) -> {
                     response.setContentType("application/json;charset=utf-8");
                     PrintWriter out = response.getWriter();
@@ -120,7 +121,7 @@ public class MySecurityConfig extends WebSecurityConfigurerAdapter {
 
     @Override
     public void configure(WebSecurity web) {
-        //对于在header里面增加token等类似情况，放行所有OPTIONS请求。
+        // 对于在 header 里面增加 token 等类似情况，放行所有 OPTIONS 请求。
         web.ignoring().antMatchers(HttpMethod.OPTIONS, "/**");
         web.httpFirewall(allowUrlEncodedSlashHttpFirewall());
     }

src/main/java/im/zhaojun/zfile/security/MyUserDetailsServiceImpl.java

@@ -1,7 +1,7 @@
-package im.zhaojun.common.security;
+package im.zhaojun.zfile.security;
 
-import im.zhaojun.common.model.dto.SystemConfigDTO;
-import im.zhaojun.common.service.SystemConfigService;
+import im.zhaojun.zfile.model.dto.SystemConfigDTO;
+import im.zhaojun.zfile.service.SystemConfigService;
 import org.springframework.security.core.userdetails.User;
 import org.springframework.security.core.userdetails.UserDetails;
 import org.springframework.security.core.userdetails.UserDetailsService;
@@ -9,6 +9,7 @@ import org.springframework.security.core.userdetails.UsernameNotFoundException;
 
 import javax.annotation.Resource;
 import java.util.Collections;
+import java.util.Objects;
 
 /**
  * @author zhaojun
@@ -24,6 +25,9 @@ public class MyUserDetailsServiceImpl implements UserDetailsService {
     @Override
     public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
         SystemConfigDTO systemConfig = systemConfigService.getSystemConfig();
+        if (!Objects.equals(systemConfig.getUsername(), username)) {
+            throw new UsernameNotFoundException("用户名不存在");
+        }
         return new User(systemConfig.getUsername(), systemConfig.getPassword(), Collections.emptyList());
     }
 }

src/main/java/im/zhaojun/zfile/service/StorageConfigService.java

@@ -1,8 +1,8 @@
-package im.zhaojun.common.service;
+package im.zhaojun.zfile.service;
 
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.repository.StorageConfigRepository;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.repository.StorageConfigRepository;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;

src/main/java/im/zhaojun/zfile/service/SystemConfigService.java

@@ -1,17 +1,16 @@
-package im.zhaojun.common.service;
+package im.zhaojun.zfile.service;
 
 import cn.hutool.core.convert.Convert;
 import cn.hutool.core.util.BooleanUtil;
 import cn.hutool.crypto.SecureUtil;
-import com.alicp.jetcache.Cache;
-import com.alicp.jetcache.anno.CacheType;
-import com.alicp.jetcache.anno.CreateCache;
-import im.zhaojun.common.config.StorageTypeFactory;
-import im.zhaojun.common.model.SystemConfig;
-import im.zhaojun.common.model.constant.SystemConfigConstant;
-import im.zhaojun.common.model.dto.SystemConfigDTO;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.repository.SystemConfigRepository;
+import im.zhaojun.zfile.cache.ZFileCache;
+import im.zhaojun.zfile.config.StorageTypeFactory;
+import im.zhaojun.zfile.model.constant.SystemConfigConstant;
+import im.zhaojun.zfile.model.dto.SystemConfigDTO;
+import im.zhaojun.zfile.model.entity.SystemConfig;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.repository.SystemConfigRepository;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
@@ -27,25 +26,18 @@ import java.util.List;
 @Service
 public class SystemConfigService {
 
-    public static final String SYSTEM_CONFIG_CACHE_PREFIX = "zfile-config-cache:";
-
-    public static final String SYSTEM_CONFIG_CACHE_KEY = "1";
-
-    @CreateCache(name = SYSTEM_CONFIG_CACHE_PREFIX, cacheType = CacheType.LOCAL)
-    private Cache<String, Object> configCache;
+    @Resource
+    private ZFileCache zFileCache;
 
     @Resource
     private SystemConfigRepository systemConfigRepository;
 
-    @Resource
-    private FileCacheService fileCacheService;
-
-    private Class<SystemConfigDTO> systemConfigDTOClass = SystemConfigDTO.class;
+    private Class<SystemConfigDTO> systemConfigClazz = SystemConfigDTO.class;
 
     public SystemConfigDTO getSystemConfig() {
-        Object cache = configCache.get(SYSTEM_CONFIG_CACHE_KEY);
-        if (configCache.get(SYSTEM_CONFIG_CACHE_KEY) != null) {
-            return (SystemConfigDTO) cache;
+        SystemConfigDTO cacheConfig = zFileCache.getConfig();
+        if (cacheConfig != null) {
+            return cacheConfig;
         }
 
         SystemConfigDTO systemConfigDTO = new SystemConfigDTO();
@@ -55,7 +47,7 @@ public class SystemConfigService {
             String key = systemConfig.getKey();
 
             try {
-                Field field = systemConfigDTOClass.getDeclaredField(key);
+                Field field = systemConfigClazz.getDeclaredField(key);
                 if (field != null) {
                     field.setAccessible(true);
                     String strVal = systemConfig.getValue();
@@ -69,7 +61,7 @@ public class SystemConfigService {
             }
         }
 
-        configCache.put(SYSTEM_CONFIG_CACHE_KEY, systemConfigDTO);
+        zFileCache.updateConfig(systemConfigDTO);
         return systemConfigDTO;
     }
 
@@ -77,7 +69,7 @@ public class SystemConfigService {
     public void updateSystemConfig(SystemConfigDTO systemConfigDTO) throws Exception {
         List<SystemConfig> systemConfigList = new ArrayList<>();
 
-        Field[] fields = systemConfigDTOClass.getDeclaredFields();
+        Field[] fields = systemConfigClazz.getDeclaredFields();
         for (Field field : fields) {
             String key = field.getName();
             SystemConfig systemConfig = systemConfigRepository.findByKey(key);
@@ -91,22 +83,8 @@ public class SystemConfigService {
             }
         }
 
-        boolean oldEnableCache = getEnableCache();
-        boolean curEnableCache = BooleanUtil.isTrue(systemConfigDTO.getEnableCache());
-
-        configCache.remove(SYSTEM_CONFIG_CACHE_KEY);
-
+        zFileCache.removeConfig();
         systemConfigRepository.saveAll(systemConfigList);
-
-        if (!oldEnableCache && curEnableCache) {
-            log.debug("检测到开启了缓存, 开启预热缓存");
-            fileCacheService.enableCache();
-        }
-
-        if (oldEnableCache && !curEnableCache) {
-            log.debug("检测到关闭了缓存, 正在清理缓存数据及关闭自动刷新");
-            fileCacheService.disableCache();
-        }
     }
 
 
@@ -119,7 +97,7 @@ public class SystemConfigService {
         SystemConfig systemConfig = systemConfigRepository.findByKey(SystemConfigConstant.PASSWORD);
         systemConfig.setValue(encryptionPassword);
 
-        configCache.remove(SYSTEM_CONFIG_CACHE_KEY);
+        zFileCache.removeConfig();
 
         systemConfigRepository.save(systemConfig);
     }
@@ -129,11 +107,11 @@ public class SystemConfigService {
         SystemConfig enableConfig = systemConfigRepository.findByKey(SystemConfigConstant.ENABLE_CACHE);
         enableConfig.setValue(isEnable.toString());
         systemConfigRepository.save(enableConfig);
-        configCache.remove(SYSTEM_CONFIG_CACHE_KEY);
+        zFileCache.removeConfig();
     }
 
 
-    public AbstractFileService getCurrentFileService() {
+    public AbstractBaseFileService getCurrentFileService() {
         StorageTypeEnum storageStrategy = getCurrentStorageStrategy();
         return StorageTypeFactory.getStorageTypeService(storageStrategy);
     }

src/main/java/im/zhaojun/zfile/service/SystemService.java

@@ -0,0 +1,67 @@
+package im.zhaojun.zfile.service;
+
+import im.zhaojun.zfile.model.constant.ZFileConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.dto.SiteConfigDTO;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.util.HttpUtil;
+import im.zhaojun.zfile.util.StringUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.HttpClientErrorException;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * @author zhaojun
+ */
+@Slf4j
+@Service
+public class SystemService {
+
+    @Resource
+    private SystemConfigService systemConfigService;
+
+    /**
+     * 构建指定路径下标题, 页面文档信息
+     * @param path          路径
+     */
+    public SiteConfigDTO getConfig(String path) throws Exception {
+
+        SiteConfigDTO siteConfigDTO = new SiteConfigDTO();
+        AbstractBaseFileService fileService = systemConfigService.getCurrentFileService();
+
+        List<FileItemDTO> fileItemList;
+
+        if (Objects.equals(systemConfigService.getSystemConfig().getStorageStrategy(), StorageTypeEnum.FTP)) {
+            fileItemList = new ArrayList<>();
+        } else {
+            fileItemList = fileService.fileList(path);
+        }
+
+        for (FileItemDTO fileItemDTO : fileItemList) {
+            if (ZFileConstant.README_FILE_NAME.equalsIgnoreCase(fileItemDTO.getName())) {
+                String textContent = null;
+                try {
+                    textContent = HttpUtil.getTextContent(fileItemDTO.getUrl());
+                } catch (HttpClientErrorException httpClientErrorException) {
+                    log.debug("尝试重新获取文档区缓存中链接后仍失败", httpClientErrorException);
+                    try {
+                        String fullPath = StringUtils.removeDuplicateSeparator(fileItemDTO.getPath() + "/" + fileItemDTO.getName());
+                        FileItemDTO fileItem = fileService.getFileItem(fullPath);
+                        textContent = HttpUtil.getTextContent(fileItem.getUrl());
+                    } catch (Exception e) {
+                        log.debug("尝试重新获取文档区链接后仍失败, 已置为空", e);
+                    }
+                }
+                siteConfigDTO.setReadme(textContent);
+            }
+        }
+        return siteConfigDTO;
+    }
+
+}

src/main/java/im/zhaojun/zfile/service/base/AbstractBaseFileService.java

@@ -0,0 +1,128 @@
+package im.zhaojun.zfile.service.base;
+
+import cn.hutool.core.util.BooleanUtil;
+import im.zhaojun.zfile.cache.ZFileCache;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.dto.SystemConfigDTO;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.service.support.FileAsyncCacheService;
+import im.zhaojun.zfile.service.support.FileCacheService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.aop.framework.AopContext;
+import org.springframework.beans.factory.annotation.Value;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @author zhaojun
+ */
+@Slf4j
+public abstract class AbstractBaseFileService extends FileCacheService implements BaseFileService {
+
+    @Value("${zfile.cache.timeout}")
+    protected Long timeout;
+
+    protected boolean isInitialized = false;
+
+    protected String basePath;
+
+    @Resource
+    private SystemConfigService systemConfigService;
+
+    @Resource
+    private FileAsyncCacheService fileAsyncCacheService;
+
+    @Resource
+    private ZFileCache zFileCache;
+
+    /***
+     * 获取指定路径下的文件及文件夹, 默认缓存 60 分钟，每隔 30 分钟刷新一次.
+     * @param path 文件路径
+     * @return     文件及文件夹列表
+     * @throws Exception  获取文件列表中出现的异常
+     */
+    @Override
+    public abstract List<FileItemDTO> fileList(String path) throws Exception;
+
+    /**
+     * 清理当前存储策略的缓存
+     * 1. 删除全部缓存
+     * 2. 标记为当前处于未完成缓存状态
+     */
+    public void clearFileCache() {
+        zFileCache.clear();
+        fileAsyncCacheService.setCacheFinish(false);
+    }
+
+    /**
+     * 初始化方法, 启动时自动调用实现类的此方法进行初始化.
+     */
+    @PostConstruct
+    public abstract void init();
+
+    protected boolean testConnection() {
+        boolean flag = true;
+        try {
+            fileList("/");
+        } catch (Exception e) {
+            log.debug(getStorageTypeEnum().getDescription() + " 初始化异常", e);
+            flag = false;
+        }
+        return flag;
+    }
+
+    /**
+     * 获取是否初始化成功
+     * @return              初始化成功与否
+     */
+    public boolean getIsUnInitialized() {
+        return !isInitialized;
+    }
+
+    /**
+     * 获取是否初始化成功
+     * @return              初始化成功与否
+     */
+    public boolean getIsInitialized() {
+        return isInitialized;
+    }
+
+    /**
+     * 获取存储策略类型
+     * @return              存储策略类型枚举
+     */
+    public abstract StorageTypeEnum getStorageTypeEnum();
+
+    /**
+     * 搜索文件
+     * @param name          文件名
+     * @return              包含该文件名的所有文件或文件夹
+     */
+    public List<FileItemDTO> search(String name) {
+        SystemConfigDTO systemConfig = systemConfigService.getSystemConfig();
+
+        boolean searchIgnoreCase = BooleanUtil.isTrue(systemConfig.getSearchIgnoreCase());
+        boolean searchContainEncryptedFile = BooleanUtil.isTrue(systemConfig.getSearchContainEncryptedFile());
+        return zFileCache.find(name, searchIgnoreCase, searchContainEncryptedFile);
+    }
+
+    /**
+     * 刷新缓存
+     */
+    public void refreshCache(String key) throws Exception {
+        zFileCache.remove(key);
+        BaseFileService currentFileService = (BaseFileService) AopContext.currentProxy();
+        currentFileService.fileList(key);
+    }
+
+    /**
+     * 获取单个文件信息
+     * @param path 文件路径
+     * @return  单个文件的内容.
+     */
+    public abstract FileItemDTO getFileItem(String path);
+
+}

src/main/java/im/zhaojun/zfile/service/base/AbstractOneDriveServiceBase.java

@@ -1,4 +1,4 @@
-package im.zhaojun.onedrive.common.service;
+package im.zhaojun.zfile.service.base;
 
 import cn.hutool.core.util.URLUtil;
 import cn.hutool.http.HttpRequest;
@@ -7,21 +7,21 @@ import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.repository.StorageConfigRepository;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.common.util.StringUtils;
-import im.zhaojun.onedrive.common.model.OneDriveToken;
+import im.zhaojun.zfile.model.constant.ZFileConstant;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.repository.StorageConfigRepository;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.util.StringUtils;
+import im.zhaojun.zfile.model.support.OneDriveToken;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.ResponseEntity;
+import org.springframework.web.client.HttpClientErrorException;
 import org.springframework.web.client.RestTemplate;
 
 import javax.annotation.Resource;
-import java.net.URLDecoder;
-import java.net.URLEncoder;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
@@ -30,7 +30,8 @@ import java.util.List;
  * @author Zhao Jun
  * 2020/1/29 11:54
  */
-public abstract class AbstractOneDriveService extends AbstractFileService {
+@Slf4j
+public abstract class AbstractOneDriveServiceBase extends AbstractBaseFileService {
 
     protected static final String DRIVER_INFO_URL = "https://{graphEndPoint}/v1.0/me/drives";
 
@@ -42,6 +43,8 @@ public abstract class AbstractOneDriveService extends AbstractFileService {
 
     protected static final String AUTHENTICATE_URL = "https://{authenticateEndPoint}/common/oauth2/v2.0/token";
 
+    private static final String ONE_DRIVE_FILE_FLAG = "file";
+
     @Resource
     private RestTemplate oneDriveRestTemplate;
 
@@ -104,14 +107,22 @@ public abstract class AbstractOneDriveService extends AbstractFileService {
             if (nextLink != null) {
                 nextLink = nextLink.replace("+", "%2B");
                 requestUrl = URLUtil.decode(nextLink);
-            }else if ("/".equalsIgnoreCase(fullPath) || "".equalsIgnoreCase(fullPath)) {
+            }else if (ZFileConstant.PATH_SEPARATOR.equalsIgnoreCase(fullPath) || "".equalsIgnoreCase(fullPath)) {
                 requestUrl = DRIVER_ROOT_URL;
             } else {
                 requestUrl = DRIVER_ITEMS_URL;
             }
             fullPath = StringUtils.removeLastSeparator(fullPath);
 
-            ResponseEntity<String> responseEntity = oneDriveRestTemplate.getForEntity(requestUrl, String.class, getGraphEndPoint(), fullPath);
+            ResponseEntity<String> responseEntity;
+            try {
+                responseEntity = oneDriveRestTemplate.getForEntity(requestUrl, String.class, getGraphEndPoint(), fullPath);
+            } catch (HttpClientErrorException e) {
+                log.debug("调用 OneDrive 时出现了网络异常: {} , 已尝试重新刷新 token 后再试.", e.getMessage());
+                refreshOneDriveToken();
+                responseEntity = oneDriveRestTemplate.getForEntity(requestUrl, String.class, getGraphEndPoint(), fullPath);
+            }
+
             String body = responseEntity.getBody();
 
             JSONObject root = JSON.parseObject(body);
@@ -160,7 +171,7 @@ public abstract class AbstractOneDriveService extends AbstractFileService {
         fileItemDTO.setSize(fileItem.getLong("size"));
         fileItemDTO.setTime(fileItem.getDate("lastModifiedDateTime"));
 
-        if (fileItem.containsKey("file")) {
+        if (fileItem.containsKey(ONE_DRIVE_FILE_FLAG)) {
             fileItemDTO.setUrl(fileItem.getString("@microsoft.graph.downloadUrl"));
             fileItemDTO.setType(FileTypeEnum.FILE);
         } else {

src/main/java/im/zhaojun/zfile/service/base/AbstractS3BaseFileService.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.service;
+package im.zhaojun.zfile.service.base;
 
 import cn.hutool.core.util.BooleanUtil;
 import cn.hutool.core.util.URLUtil;
@@ -6,10 +6,11 @@ import com.amazonaws.services.s3.AmazonS3;
 import com.amazonaws.services.s3.model.ListObjectsRequest;
 import com.amazonaws.services.s3.model.ObjectListing;
 import com.amazonaws.services.s3.model.S3ObjectSummary;
-import im.zhaojun.common.exception.NotExistFileException;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.util.StringUtils;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.exception.NotExistFileException;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.util.StringUtils;
 
 import javax.annotation.Resource;
 import java.net.URL;
@@ -21,7 +22,7 @@ import java.util.Objects;
 /**
  * @author zhaojun
  */
-public abstract class AbstractS3FileService extends AbstractFileService {
+public abstract class AbstractS3BaseFileService extends AbstractBaseFileService {
 
     @Resource
     protected StorageConfigService storageConfigService;

src/main/java/im/zhaojun/zfile/service/base/BaseFileService.java

@@ -1,13 +1,13 @@
-package im.zhaojun.common.service;
+package im.zhaojun.zfile.service.base;
 
-import im.zhaojun.common.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
 
 import java.util.List;
 
 /**
  * @author zhaojun
  */
-public interface FileService {
+public interface BaseFileService {
 
     /***
      * 获取指定路径下的文件及文件夹

src/main/java/im/zhaojun/zfile/service/impl/AliyunServiceImpl.java

@@ -1,14 +1,15 @@
-package im.zhaojun.aliyun.service;
+package im.zhaojun.zfile.service.impl;
 
+import cn.hutool.core.convert.Convert;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractS3FileService;
-import im.zhaojun.common.service.FileService;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractS3BaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -20,7 +21,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class AliyunServiceImpl extends AbstractS3FileService implements FileService {
+public class AliyunServiceImpl extends AbstractS3BaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(AliyunServiceImpl.class);
 
@@ -36,6 +37,7 @@ public class AliyunServiceImpl extends AbstractS3FileService implements FileServ
             super.domain = stringStorageConfigMap.get(StorageConfigConstant.DOMAIN_KEY).getValue();
             super.basePath = stringStorageConfigMap.get(StorageConfigConstant.BASE_PATH).getValue();
             super.bucketName = stringStorageConfigMap.get(StorageConfigConstant.BUCKET_NAME_KEY).getValue();
+            super.isPrivate = Convert.toBool(stringStorageConfigMap.get(StorageConfigConstant.IS_PRIVATE).getValue(), true);
 
             if (Objects.isNull(accessKey) || Objects.isNull(secretKey) || Objects.isNull(endPoint) || Objects.isNull(bucketName)) {
                 log.debug("初始化存储策略 [{}] 失败: 参数不完整", getStorageTypeEnum().getDescription());

src/main/java/im/zhaojun/zfile/service/impl/FtpServiceImpl.java

@@ -1,23 +1,25 @@
-package im.zhaojun.ftp.service;
+package im.zhaojun.zfile.service.impl;
 
 import cn.hutool.core.util.URLUtil;
 import cn.hutool.extra.ftp.Ftp;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.FileService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.common.util.StringUtils;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
+import im.zhaojun.zfile.util.StringUtils;
+import org.apache.commons.net.ftp.FTP;
+import org.apache.commons.net.ftp.FTPClientConfig;
 import org.apache.commons.net.ftp.FTPFile;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.io.IOException;
+import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -27,7 +29,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class FtpServiceImpl extends AbstractFileService implements FileService {
+public class FtpServiceImpl extends AbstractBaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(FtpServiceImpl.class);
 
@@ -56,23 +58,33 @@ public class FtpServiceImpl extends AbstractFileService implements FileService {
             username = stringStorageConfigMap.get(StorageConfigConstant.USERNAME_KEY).getValue();
             password = stringStorageConfigMap.get(StorageConfigConstant.PASSWORD_KEY).getValue();
             domain = stringStorageConfigMap.get(StorageConfigConstant.DOMAIN_KEY).getValue();
-            super.basePath = stringStorageConfigMap.get(StorageConfigConstant.BASE_PATH).getValue();;
+            super.basePath = stringStorageConfigMap.get(StorageConfigConstant.BASE_PATH).getValue();
             if (Objects.isNull(host) || Objects.isNull(port) || Objects.isNull(username) || Objects.isNull(password)) {
                 isInitialized = false;
             } else {
-                ftp = new Ftp(host, Integer.parseInt(port), username, password);
+                ftp = new Ftp(host, Integer.parseInt(port), username, password, StandardCharsets.UTF_8);
+                ftp.getClient().configure(new FTPClientConfig(FTPClientConfig.SYST_UNIX));
+                ftp.getClient().type(FTP.BINARY_FILE_TYPE);
                 isInitialized = testConnection();
             }
-
         } catch (Exception e) {
             log.debug(getStorageTypeEnum().getDescription() + " 初始化异常, 已跳过");
         }
     }
 
     @Override
-    public synchronized List<FileItemDTO> fileList(String path) throws IOException {
+    public List<FileItemDTO> fileList(String path) {
+        ftp.reconnectIfTimeout();
         String fullPath = StringUtils.getFullPath(basePath, path);
-        FTPFile[] ftpFiles = ftp.lsFiles(fullPath);
+        ftp.cd(fullPath);
+        FTPFile[] ftpFiles = new FTPFile[]{};
+        try {
+            ftp.getClient().changeWorkingDirectory("/");
+            ftpFiles = ftp.getClient().listFiles(fullPath);
+        } catch (Exception e) {
+            e.printStackTrace();
+            // ignore
+        }
 
         List<FileItemDTO> fileItemList = new ArrayList<>();
 
@@ -117,5 +129,4 @@ public class FtpServiceImpl extends AbstractFileService implements FileService {
         fileItemDTO.setUrl(getDownloadUrl(path));
         return fileItemDTO;
     }
-
-}
+}

src/main/java/im/zhaojun/zfile/service/impl/HuaweiServiceImpl.java

@@ -1,14 +1,15 @@
-package im.zhaojun.huawei.service;
+package im.zhaojun.zfile.service.impl;
 
+import cn.hutool.core.convert.Convert;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractS3FileService;
-import im.zhaojun.common.service.FileService;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractS3BaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -20,7 +21,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class HuaweiServiceImpl extends AbstractS3FileService implements FileService {
+public class HuaweiServiceImpl extends AbstractS3BaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(HuaweiServiceImpl.class);
 
@@ -36,6 +37,7 @@ public class HuaweiServiceImpl extends AbstractS3FileService implements FileServ
             bucketName = stringStorageConfigMap.get(StorageConfigConstant.BUCKET_NAME_KEY).getValue();
             domain = stringStorageConfigMap.get(StorageConfigConstant.DOMAIN_KEY).getValue();
             basePath = stringStorageConfigMap.get(StorageConfigConstant.BASE_PATH).getValue();
+            isPrivate = Convert.toBool(stringStorageConfigMap.get(StorageConfigConstant.IS_PRIVATE).getValue(), true);
 
             if (Objects.isNull(accessKey) || Objects.isNull(secretKey) || Objects.isNull(endPoint) || Objects.isNull(bucketName)) {
                 log.debug("初始化存储策略 [{}] 失败: 参数不完整", getStorageTypeEnum().getDescription());

src/main/java/im/zhaojun/zfile/service/impl/LocalServiceImpl.java

@@ -1,19 +1,18 @@
-package im.zhaojun.local.service;
+package im.zhaojun.zfile.service.impl;
 
-import cn.hutool.core.util.URLUtil;
-import im.zhaojun.common.exception.NotExistFileException;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.SystemConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.constant.SystemConfigConstant;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.repository.SystemConfigRepository;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.FileService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.common.util.StringUtils;
+import im.zhaojun.zfile.exception.NotExistFileException;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.entity.SystemConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.constant.SystemConfigConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.repository.SystemConfigRepository;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.util.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -30,7 +29,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class LocalServiceImpl extends AbstractFileService implements FileService {
+public class LocalServiceImpl extends AbstractBaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(LocalServiceImpl.class);
 

src/main/java/im/zhaojun/zfile/service/impl/MinIOServiceImpl.java

@@ -1,14 +1,15 @@
-package im.zhaojun.minio;
+package im.zhaojun.zfile.service.impl;
 
+import cn.hutool.core.convert.Convert;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractS3FileService;
-import im.zhaojun.common.service.FileService;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractS3BaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -20,7 +21,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class MinIOServiceImpl extends AbstractS3FileService implements FileService {
+public class MinIOServiceImpl extends AbstractS3BaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(MinIOServiceImpl.class);
 
@@ -34,6 +35,7 @@ public class MinIOServiceImpl extends AbstractS3FileService implements FileServi
             String endPoint = stringStorageConfigMap.get(StorageConfigConstant.ENDPOINT_KEY).getValue();
             bucketName = stringStorageConfigMap.get(StorageConfigConstant.BUCKET_NAME_KEY).getValue();
             basePath = stringStorageConfigMap.get(StorageConfigConstant.BASE_PATH).getValue();
+            isPrivate = Convert.toBool(stringStorageConfigMap.get(StorageConfigConstant.IS_PRIVATE).getValue(), true);
 
             if (Objects.isNull(accessKey) || Objects.isNull(secretKey) || Objects.isNull(endPoint) || Objects.isNull(bucketName)) {
                 log.debug("初始化存储策略 [{}] 失败: 参数不完整", getStorageTypeEnum().getDescription());

src/main/java/im/zhaojun/zfile/service/impl/OneDriveChinaServiceImpl.java

@@ -1,12 +1,11 @@
-package im.zhaojun.onedrive.china.service;
+package im.zhaojun.zfile.service.impl;
 
-import im.zhaojun.common.config.GlobalScheduleTask;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.FileService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.onedrive.common.service.AbstractOneDriveService;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.service.base.AbstractOneDriveServiceBase;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -20,10 +19,7 @@ import java.util.Map;
  */
 @Service
 @Slf4j
-public class OneDriveChinaServiceImpl extends AbstractOneDriveService implements FileService {
-
-    @Resource
-    private GlobalScheduleTask globalScheduleTask;
+public class OneDriveChinaServiceImpl extends AbstractOneDriveServiceBase implements BaseFileService {
 
     @Resource
     private StorageConfigService storageConfigService;

src/main/java/im/zhaojun/zfile/service/impl/OneDriveServiceImpl.java

@@ -1,12 +1,11 @@
-package im.zhaojun.onedrive.international.service;
+package im.zhaojun.zfile.service.impl;
 
-import im.zhaojun.common.config.GlobalScheduleTask;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.FileService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.onedrive.common.service.AbstractOneDriveService;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.service.base.AbstractOneDriveServiceBase;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
@@ -20,10 +19,7 @@ import java.util.Map;
  */
 @Service
 @Slf4j
-public class OneDriveServiceImpl extends AbstractOneDriveService implements FileService {
-
-    @Resource
-    private GlobalScheduleTask globalScheduleTask;
+public class OneDriveServiceImpl extends AbstractOneDriveServiceBase implements BaseFileService {
 
     @Resource
     private StorageConfigService storageConfigService;

src/main/java/im/zhaojun/zfile/service/impl/QiniuServiceImpl.java

@@ -1,14 +1,15 @@
-package im.zhaojun.qiniu.service;
+package im.zhaojun.zfile.service.impl;
 
+import cn.hutool.core.convert.Convert;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractS3FileService;
-import im.zhaojun.common.service.FileService;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractS3BaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -20,7 +21,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class QiniuServiceImpl extends AbstractS3FileService implements FileService {
+public class QiniuServiceImpl extends AbstractS3BaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(QiniuServiceImpl.class);
 
@@ -36,6 +37,7 @@ public class QiniuServiceImpl extends AbstractS3FileService implements FileServi
             bucketName = stringStorageConfigMap.get(StorageConfigConstant.BUCKET_NAME_KEY).getValue();
             domain = stringStorageConfigMap.get(StorageConfigConstant.DOMAIN_KEY).getValue();
             basePath = stringStorageConfigMap.get(StorageConfigConstant.BASE_PATH).getValue();
+            isPrivate = Convert.toBool(stringStorageConfigMap.get(StorageConfigConstant.IS_PRIVATE).getValue(), true);
 
             if (Objects.isNull(accessKey) || Objects.isNull(secretKey) || Objects.isNull(endPoint) || Objects.isNull(bucketName)) {
                 log.debug("初始化存储策略 [{}] 失败: 参数不完整", getStorageTypeEnum().getDescription());

src/main/java/im/zhaojun/zfile/service/impl/S3ServiceImpl.java

@@ -1,15 +1,15 @@
-package im.zhaojun.s3;
+package im.zhaojun.zfile.service.impl;
 
 import cn.hutool.core.convert.Convert;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractS3FileService;
-import im.zhaojun.common.service.FileService;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractS3BaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -21,7 +21,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class S3ServiceImpl extends AbstractS3FileService implements FileService {
+public class S3ServiceImpl extends AbstractS3BaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(S3ServiceImpl.class);
 

src/main/java/im/zhaojun/zfile/service/impl/TencentServiceImpl.java

@@ -1,14 +1,15 @@
-package im.zhaojun.tencent;
+package im.zhaojun.zfile.service.impl;
 
+import cn.hutool.core.convert.Convert;
 import com.amazonaws.auth.AWSStaticCredentialsProvider;
 import com.amazonaws.auth.BasicAWSCredentials;
 import com.amazonaws.client.builder.AwsClientBuilder;
 import com.amazonaws.services.s3.AmazonS3ClientBuilder;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractS3FileService;
-import im.zhaojun.common.service.FileService;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractS3BaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
@@ -20,7 +21,7 @@ import java.util.Objects;
  * @author zhaojun
  */
 @Service
-public class TencentServiceImpl extends AbstractS3FileService implements FileService {
+public class TencentServiceImpl extends AbstractS3BaseFileService implements BaseFileService {
 
     private static final Logger log = LoggerFactory.getLogger(TencentServiceImpl.class);
 
@@ -35,6 +36,7 @@ public class TencentServiceImpl extends AbstractS3FileService implements FileSer
             bucketName = stringStorageConfigMap.get(StorageConfigConstant.BUCKET_NAME_KEY).getValue();
             domain = stringStorageConfigMap.get(StorageConfigConstant.DOMAIN_KEY).getValue();
             basePath = stringStorageConfigMap.get(StorageConfigConstant.BASE_PATH).getValue();
+            isPrivate = Convert.toBool(stringStorageConfigMap.get(StorageConfigConstant.IS_PRIVATE).getValue(), true);
 
             if (Objects.isNull(secretId) || Objects.isNull(secretKey) || Objects.isNull(endPoint) || Objects.isNull(bucketName)) {
                 log.debug("初始化存储策略 [{}] 失败: 参数不完整", getStorageTypeEnum().getDescription());

src/main/java/im/zhaojun/zfile/service/impl/UFileServiceImpl.java

@@ -0,0 +1,17 @@
+package im.zhaojun.zfile.service.impl;
+
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author zhaojun
+ */
+@Service
+public class UFileServiceImpl extends UpYunServiceImpl {
+
+    @Override
+    public StorageTypeEnum getStorageTypeEnum() {
+        return StorageTypeEnum.UFILE;
+    }
+
+}

src/main/java/im/zhaojun/zfile/service/impl/UpYunServiceImpl.java

@@ -1,18 +1,18 @@
-package im.zhaojun.upyun.service;
+package im.zhaojun.zfile.service.impl;
 
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.URLUtil;
 import com.UpYun;
-import im.zhaojun.common.exception.NotExistFileException;
-import im.zhaojun.common.model.StorageConfig;
-import im.zhaojun.common.model.constant.StorageConfigConstant;
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
-import im.zhaojun.common.model.enums.StorageTypeEnum;
-import im.zhaojun.common.service.AbstractFileService;
-import im.zhaojun.common.service.FileService;
-import im.zhaojun.common.service.StorageConfigService;
-import im.zhaojun.common.util.StringUtils;
+import im.zhaojun.zfile.exception.NotExistFileException;
+import im.zhaojun.zfile.model.entity.StorageConfig;
+import im.zhaojun.zfile.model.constant.StorageConfigConstant;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
+import im.zhaojun.zfile.service.StorageConfigService;
+import im.zhaojun.zfile.util.StringUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
@@ -28,7 +28,7 @@ import java.util.Objects;
  */
 @Service
 @Slf4j
-public class UpYunServiceImpl extends AbstractFileService implements FileService {
+public class UpYunServiceImpl extends AbstractBaseFileService implements BaseFileService {
 
     private static final String END_MARK = "g2gCZAAEbmV4dGQAA2VvZg";
 

src/main/java/im/zhaojun/zfile/service/support/FileAsyncCacheService.java

@@ -0,0 +1,191 @@
+package im.zhaojun.zfile.service.support;
+
+import im.zhaojun.zfile.cache.ZFileCache;
+import im.zhaojun.zfile.config.StorageTypeFactory;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.model.enums.StorageTypeEnum;
+import im.zhaojun.zfile.service.SystemConfigService;
+import im.zhaojun.zfile.service.base.AbstractBaseFileService;
+import im.zhaojun.zfile.service.base.BaseFileService;
+import im.zhaojun.zfile.util.StringUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayDeque;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Objects;
+import java.util.Set;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author zhaojun
+ */
+@Slf4j
+@Service
+public class FileAsyncCacheService {
+
+    public static final String CACHE_PROCESS_PREFIX = "zfile-process-cache:";
+
+    private boolean cacheFinish;
+
+    @Resource
+    private SystemConfigService systemConfigService;
+
+    private volatile boolean stopFlag = false;
+
+    @Resource
+    private ZFileCache zFileCache;
+
+    @Value("${zfile.cache.auto-refresh.enable}")
+    protected boolean enableAutoRefreshCache;
+
+    @Value("${zfile.cache.auto-refresh.delay}")
+    protected Long delay;
+
+    @Value("${zfile.cache.auto-refresh.interval}")
+    protected Long interval;
+
+    @Async
+    public void cacheGlobalFile() {
+        stopFlag = false;
+        StorageTypeEnum storageStrategy = systemConfigService.getCurrentStorageStrategy();
+
+        if (storageStrategy == null) {
+            log.debug("尚未配置存储策略. 跳过启动缓存.");
+            return;
+        }
+
+        boolean enableCache = systemConfigService.getEnableCache();
+        if (!enableCache) {
+            log.debug("存储策略 {} 未启用缓存, 跳过缓存.", storageStrategy.getDescription());
+            return;
+        }
+
+        AbstractBaseFileService fileService = StorageTypeFactory.getStorageTypeService(storageStrategy);
+
+        if (fileService.getIsUnInitialized()) {
+            log.debug("存储策略 {} 未初始化成功, 跳过缓存.", storageStrategy.getDescription());
+            return;
+        }
+
+        log.info("缓存 {} 所有文件开始", storageStrategy.getDescription());
+        long startTime = System.currentTimeMillis();
+        try {
+            BaseFileService currentFileService = systemConfigService.getCurrentFileService();
+            List<FileItemDTO> rootFileItems = currentFileService.fileList("/");
+            ArrayDeque<FileItemDTO> queue = new ArrayDeque<>(rootFileItems);
+
+            while (!queue.isEmpty()) {
+                FileItemDTO fileItemDTO = queue.pop();
+
+                if (stopFlag) {
+                    zFileCache.clear();
+                    break;
+                }
+
+                if (fileItemDTO.getType() == FileTypeEnum.FOLDER) {
+                    String filePath = StringUtils.removeDuplicateSeparator("/" + fileItemDTO.getPath() + "/" + fileItemDTO.getName() + "/");
+
+                    List<FileItemDTO> fileItems = currentFileService.fileList(filePath);
+                    queue.addAll(fileItems);
+                }
+            }
+        } catch (Exception e) {
+            log.error("缓存所有文件失败", e);
+            e.printStackTrace();
+        }
+        long endTime = System.currentTimeMillis();
+
+        if (stopFlag) {
+            log.info("缓存 {} 所有文件被强制结束, 用时: {} 秒", storageStrategy.getDescription(), ((endTime - startTime) / 1000));
+            cacheFinish = false;
+            stopFlag = false;
+        } else {
+            log.info("缓存 {} 所有文件结束, 用时: {} 秒", storageStrategy.getDescription(), ((endTime - startTime) / 1000));
+            enableCacheAutoRefreshTask();
+            cacheFinish = true;
+            stopFlag = false;
+        }
+    }
+
+    private void enableCacheAutoRefreshTask() {
+        StorageTypeEnum currentStorageStrategy = systemConfigService.getCurrentStorageStrategy();
+
+        if (enableAutoRefreshCache) {
+            ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor();
+            scheduledExecutorService.scheduleWithFixedDelay(() -> {
+                zFileCache.setLastCacheAutoRefreshDate(new Date());
+
+                boolean enableCache = systemConfigService.getEnableCache();
+
+                if (!enableCache) {
+                    log.debug("当前存储引擎未开启缓存, 跳过自动刷新缓存");
+                    zFileCache.clear();
+                    return;
+                }
+
+                log.debug("开始调用自动刷新缓存");
+
+                Set<String> keySet = zFileCache.keySet();
+
+                ArrayList<String> keys = new ArrayList<>(keySet);
+
+
+                for (String key : keys) {
+                    try {
+                        Thread.sleep(300);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+
+                    if (stopFlag) {
+                        break;
+                    }
+
+                    zFileCache.remove(key);
+                    AbstractBaseFileService currentFileService = systemConfigService.getCurrentFileService();
+                    try {
+                        if (Objects.equals(currentStorageStrategy, systemConfigService.getCurrentStorageStrategy())) {
+                            currentFileService.fileList(key);
+                        }
+                    } catch (Exception e) {
+                        log.error("刷新过程中出错 : [" + key + "]", e);
+                    }
+                }
+
+                if (stopFlag) {
+                    log.debug("检测到停止 [{}] 缓存指令, 已停止自动刷新任务", currentStorageStrategy);
+                    scheduledExecutorService.shutdownNow();
+                    stopFlag = false;
+                } else {
+                    log.debug("自动刷新缓存完成");
+                }
+            }, delay, interval, TimeUnit.SECONDS);
+        }
+    }
+
+    public void stopScheduled() {
+        this.stopFlag = true;
+    }
+
+    public void enableScheduled() {
+        this.stopFlag = false;
+    }
+
+    public boolean isCacheFinish() {
+        return cacheFinish;
+    }
+
+    public void setCacheFinish(boolean cacheFinish) {
+        this.cacheFinish = cacheFinish;
+    }
+
+}

src/main/java/im/zhaojun/zfile/service/support/FileCacheService.java

@@ -1,5 +1,7 @@
-package im.zhaojun.common.service;
+package im.zhaojun.zfile.service.support;
 
+import im.zhaojun.zfile.cache.ZFileCache;
+import im.zhaojun.zfile.service.SystemConfigService;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.stereotype.Service;
 
@@ -18,21 +20,19 @@ public class FileCacheService {
     @Lazy
     private FileAsyncCacheService fileAsyncCacheService;
 
+    @Resource
+    private ZFileCache zFileCache;
+
     public void enableCache() {
         systemConfigService.updateCacheEnableConfig(true);
-
-        AbstractFileService currentFileService = systemConfigService.getCurrentFileService();
-        currentFileService.openCacheAutoRefresh();
         fileAsyncCacheService.cacheGlobalFile();
     }
 
-
-    public void disableCache() throws Exception {
+    public void disableCache() {
         systemConfigService.updateCacheEnableConfig(false);
-
-        AbstractFileService currentFileService = systemConfigService.getCurrentFileService();
-        currentFileService.clearFileCache();
-        fileAsyncCacheService.resetCacheCount();
+        zFileCache.clear();
+        fileAsyncCacheService.setCacheFinish(false);
+        fileAsyncCacheService.stopScheduled();
     }
 
 }

src/main/java/im/zhaojun/zfile/service/support/SystemMonitorService.java

@@ -1,6 +1,6 @@
-package im.zhaojun.common.service;
+package im.zhaojun.zfile.service.support;
 
-import im.zhaojun.common.model.SystemMonitorInfo;
+import im.zhaojun.zfile.model.support.SystemMonitorInfo;
 import org.springframework.stereotype.Service;
 
 /**
@@ -12,4 +12,5 @@ public class SystemMonitorService {
     public SystemMonitorInfo systemMonitorInfo() {
         return new SystemMonitorInfo();
     }
-}
+
+}

src/main/java/im/zhaojun/zfile/util/AudioHelper.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 
 import cn.hutool.core.codec.Base64;
 import cn.hutool.core.io.FileUtil;
@@ -10,8 +10,8 @@ import com.mpatric.mp3agic.ID3v2;
 import com.mpatric.mp3agic.InvalidDataException;
 import com.mpatric.mp3agic.Mp3File;
 import com.mpatric.mp3agic.UnsupportedTagException;
-import im.zhaojun.common.model.constant.ZFileConstant;
-import im.zhaojun.common.model.dto.AudioInfoDTO;
+import im.zhaojun.zfile.model.constant.ZFileConstant;
+import im.zhaojun.zfile.model.dto.AudioInfoDTO;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

src/main/java/im/zhaojun/zfile/util/FileComparator.java

@@ -1,7 +1,7 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 
-import im.zhaojun.common.model.dto.FileItemDTO;
-import im.zhaojun.common.model.enums.FileTypeEnum;
+import im.zhaojun.zfile.model.dto.FileItemDTO;
+import im.zhaojun.zfile.model.enums.FileTypeEnum;
 
 import java.util.Comparator;
 

src/main/java/im/zhaojun/zfile/util/FileUtil.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 
 import cn.hutool.core.util.URLUtil;
 import org.springframework.core.io.FileSystemResource;

src/main/java/im/zhaojun/zfile/util/HttpUtil.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.client.RestClientException;

src/main/java/im/zhaojun/zfile/util/NaturalOrderComparator.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 /*
  NaturalOrderComparator.java -- Perform 'natural order' comparisons of strings in Java.
  Copyright (C) 2003 by Pierre-Luc Paour <natorder@paour.com>
@@ -25,8 +25,13 @@ package im.zhaojun.common.util;
 
 import java.util.Comparator;
 
+/**
+ * @author zhaojun
+ */
 public class NaturalOrderComparator implements Comparator<String> {
 
+    private static final char ZERO_CHAR = '0';
+
     private int compareRight(String a, String b) {
         int bias = 0, ia = 0, ib = 0;
 
@@ -61,9 +66,10 @@ public class NaturalOrderComparator implements Comparator<String> {
         }
     }
 
+    @Override
     public int compare(String a, String b) {
         int ia = 0, ib = 0;
-        int nza = 0, nzb = 0;
+        int nza, nzb;
         char ca, cb;
 
         while (true) {
@@ -74,8 +80,8 @@ public class NaturalOrderComparator implements Comparator<String> {
             cb = charAt(b, ib);
 
             // skip over leading spaces or zeros
-            while (Character.isSpaceChar(ca) || ca == '0') {
-                if (ca == '0') {
+            while (Character.isSpaceChar(ca) || ca == ZERO_CHAR) {
+                if (ca == ZERO_CHAR) {
                     nza++;
                 } else {
                     // Only count consecutive zeroes
@@ -130,11 +136,13 @@ public class NaturalOrderComparator implements Comparator<String> {
     }
 
     private static int compareEqual(String a, String b, int nza, int nzb) {
-        if (nza - nzb != 0)
+        if (nza - nzb != 0) {
             return nza - nzb;
+        }
 
-        if (a.length() == b.length())
+        if (a.length() == b.length()) {
             return a.compareTo(b);
+        }
 
         return a.length() - b.length();
     }

src/main/java/im/zhaojun/zfile/util/SpringContextHolder.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

src/main/java/im/zhaojun/zfile/util/StartupListener.java

@@ -1,8 +1,8 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 
 import cn.hutool.core.net.NetUtil;
-import im.zhaojun.common.exception.InitializeException;
-import im.zhaojun.common.service.FileAsyncCacheService;
+import im.zhaojun.zfile.exception.InitializeException;
+import im.zhaojun.zfile.service.support.FileAsyncCacheService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.context.event.ApplicationStartedEvent;
 import org.springframework.context.ApplicationListener;
@@ -33,6 +33,7 @@ public class StartupListener implements ApplicationListener<ApplicationStartedEv
         cacheAllFile();
     }
 
+
     private void printStartInfo() {
         String serverPort = environment.getProperty("server.port", "8080");
 

src/main/java/im/zhaojun/zfile/util/StringUtils.java

@@ -1,4 +1,4 @@
-package im.zhaojun.common.util;
+package im.zhaojun.zfile.util;
 
 import cn.hutool.core.util.ObjectUtil;
 

src/main/resources/META-INF/additional-spring-configuration-metadata.json

@@ -5,6 +5,21 @@
             "type": "java.lang.Long",
             "description": "目录缓存过期时间 和 下载地址过期时间. 单位为秒."
         },
+        {
+            "name": "zfile.cache.auto-refresh.enable",
+            "type": "java.lang.Boolean",
+            "description": "是否开启自动刷新缓存."
+        },
+        {
+            "name": "zfile.cache.auto-refresh.delay",
+            "type": "java.lang.Long",
+            "description": "启动项目后多久开始自动刷新缓存, 推荐与 interval 一致, 因为项目启动时会缓存所有文件. 单位为秒.."
+        },
+        {
+            "name": "zfile.cache.auto-refresh.interval",
+            "type": "java.lang.Long",
+            "description": "任务间隔时间, 也就是每多长时间会自动刷新缓存一次.."
+        },
         {
             "name": "zfile.constant.readme",
             "type": "java.lang.String",
@@ -36,6 +51,26 @@
             "name": "zfile.onedrive.scope",
             "type": "java.lang.String",
             "description": "OneDrive 认证权限."
+        },
+        {
+            "name": "zfile.onedrive-china.clientId",
+            "type": "java.lang.String",
+            "description": "OneDrive China ClientId."
+        },
+        {
+            "name": "zfile.onedrive-china.clientSecret",
+            "type": "java.lang.String",
+            "description": "OneDrive China ClientSecret."
+        },
+        {
+            "name": "zfile.onedrive-china.redirectUri",
+            "type": "java.lang.String",
+            "description": "OneDrive China 认证重定向地址."
+        },
+        {
+            "name": "zfile.onedrive-china.scope",
+            "type": "java.lang.String",
+            "description": "OneDrive China 认证权限."
         }
     ]
 }

src/main/resources/application.yml

@@ -30,9 +30,9 @@ spring:
 
     # MySQL 配置
   #    driver-class-name: com.mysql.jdbc.Driver
-#    url: jdbc:mysql://127.0.0.1:3306/zfile?characterEncoding=utf8&serverTimezone=Asia/Shanghai&useSSL=false
-#    username: root
-#    password: 123456
+  #    url: jdbc:mysql://127.0.0.1:3306/zfile?characterEncoding=utf8&serverTimezone=Asia/Shanghai&useSSL=false
+  #    username: root
+  #    password: 123456
   jackson:
     date-format: yyyy-MM-dd HH:mm
     time-zone: GMT+8
@@ -49,12 +49,13 @@ spring:
   profiles:
     active: prod
 
-  boot:
-    admin:
-      context-path: /act
 zfile:
   cache:
-    timeout: 300
+    auto-refresh:
+      enable: true   # 是否开启自动刷新缓存.
+      delay: 1800    # 启动项目后多久开始自动刷新缓存, 推荐与 interval 一致, 因为项目启动时会缓存所有文件.
+      interval: 1800 # 任务间隔时间, 也就是每多长时间会自动刷新缓存一次.
+    timeout: 1800
   constant:
     readme: readme.md
     password: password.txt
@@ -68,14 +69,3 @@ zfile:
     clientSecret: Y9CEA=82da5n-y_]KAWAgLH3?R9xf7Uw
     redirectUri: https://zfile.jun6.net/onedrive/china-callback
     scope: offline_access User.Read Files.ReadWrite.All
-
-jetcache:
-  statIntervalMinutes: 0
-  areaInCacheName: false
-  local:
-    default:
-      type: caffeine
-      keyConvertor: fastjson
-
-
-

src/main/resources/db/data.sql

@@ -71,4 +71,16 @@ INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (51, 'domain', '
 INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (52, 'pathStyle', '域名风格', 's3');
 INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (53, 'isPrivate', '是否是私有空间', 's3');
 INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (54, 'base-path', '基路径', 'onedrive');
-INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (55, 'base-path', '基路径', 'onedrive-china');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (55, 'base-path', '基路径', 'onedrive-china');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (56, 'bucket-name', '云存储服务名称', 'ufile');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (57, 'username', '操作员名称', 'ufile');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (58, 'password', '操作员密码', 'ufile');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (59, 'domain', '加速域名', 'ufile');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (60, 'base-path', '基路径', 'ufile');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (61, 'isPrivate', '是否是私有空间', 'tencent');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (62, 'isPrivate', '是否是私有空间', 'aliyun');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (63, 'isPrivate', '是否是私有空间', 'huawei');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (64, 'isPrivate', '是否是私有空间', 'minio');
+INSERT INTO STORAGE_CONFIG (`ID`, `k`, `TITLE`, `TYPE`) VALUES (65, 'isPrivate', '是否是私有空间', 'qiniu');
+
+

src/main/resources/static/css/adminIndex.c226568b.css

@@ -1 +0,0 @@
-.el-menu[data-v-7e0eaa89],.el-row[data-v-7e0eaa89]{height:100vh}