MinIo文件上传

pom.xml

@@ -87,6 +87,28 @@
             <artifactId>fastjson</artifactId>
             <version>1.2.37</version>
         </dependency>
+        <!--minio上传文件客户端-->
+        <dependency>
+            <groupId>io.minio</groupId>
+            <artifactId>minio</artifactId>
+            <version>8.5.2</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>okhttp</artifactId>
+                    <groupId>com.squareup.okhttp3</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>4.10.0</version>
+        </dependency>
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.8.12</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-actuator</artifactId>

src/main/java/com/chinaitop/DepotSmartStorageQinghaiApplication.java

@@ -1,8 +1,10 @@
 package com.chinaitop;
 
+import com.chinaitop.depot.intelligent.file.entity.MinIoProperties;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.context.annotation.Bean;
 import org.springframework.web.client.RestTemplate;
@@ -12,6 +14,7 @@ import org.springframework.web.client.RestTemplate;
 @MapperScan({
         "com.chinaitop.depot.intelligent.*.mapper"
 })
+@EnableConfigurationProperties(MinIoProperties.class)
 public class DepotSmartStorageQinghaiApplication {
 
     public static void main(String[] args) {

src/main/java/com/chinaitop/depot/intelligent/file/controller/CommonCacheOperator.java

@@ -0,0 +1,93 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.controller;
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.map.MapUtil;
+import cn.hutool.core.util.StrUtil;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
+
+/**
+ * 通用Redis缓存操作器
+ *
+ * @author xuyuxiang
+ * @date 2022/6/21 16:00
+ **/
+@Component
+public class CommonCacheOperator {
+
+    /** 所有缓存Key的前缀 */
+    private static final String CACHE_KEY_PREFIX = "Cache:";
+
+    @Resource
+    private RedisTemplate<String, Object> redisTemplate;
+
+    public void put(String key, Object value) {
+        redisTemplate.boundValueOps(CACHE_KEY_PREFIX + key).set(value);
+    }
+
+    public void put(String key, Object value, long timeoutSeconds) {
+        redisTemplate.boundValueOps(CACHE_KEY_PREFIX + key).set(value, timeoutSeconds, TimeUnit.SECONDS);
+    }
+
+    public Object get(String key) {
+        return redisTemplate.boundValueOps(CACHE_KEY_PREFIX + key).get();
+    }
+
+    public void remove(String... key) {
+        ArrayList<String> keys = CollectionUtil.toList(key);
+        List<String> withPrefixKeys = keys.stream().map(i -> CACHE_KEY_PREFIX + i).collect(Collectors.toList());
+        redisTemplate.delete(withPrefixKeys);
+    }
+
+    public Collection<String> getAllKeys() {
+        Set<String> keys = redisTemplate.keys(CACHE_KEY_PREFIX + "*");
+        if (keys != null) {
+            // 去掉缓存key的common prefix前缀
+            return keys.stream().map(key -> StrUtil.removePrefix(key, CACHE_KEY_PREFIX)).collect(Collectors.toSet());
+        } else {
+            return CollectionUtil.newHashSet();
+        }
+    }
+
+    public Collection<Object> getAllValues() {
+        Set<String> keys = redisTemplate.keys(CACHE_KEY_PREFIX + "*");
+        if (keys != null) {
+            return redisTemplate.opsForValue().multiGet(keys);
+        } else {
+            return CollectionUtil.newArrayList();
+        }
+    }
+
+    public Map<String, Object> getAllKeyValues() {
+        Collection<String> allKeys = this.getAllKeys();
+        HashMap<String, Object> results = MapUtil.newHashMap();
+        for (String key : allKeys) {
+            results.put(key, this.get(key));
+        }
+        return results;
+    }
+
+    public void removeBatch(String pattern) {
+        Set<String> keys = redisTemplate.keys(CACHE_KEY_PREFIX + pattern);
+        if (keys != null) {
+            redisTemplate.delete(keys);
+        }
+    }
+}

src/main/java/com/chinaitop/depot/intelligent/file/controller/DevFileController.java

@@ -0,0 +1,63 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.controller;
+
+
+
+import com.chinaitop.depot.intelligent.file.enums.DevFileEngineTypeEnum;
+import com.chinaitop.depot.intelligent.file.service.DevFileService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.http.MediaType;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+
+import javax.annotation.Resource;
+
+
+/**
+ * 文件控制器
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:26
+ **/
+@Api(tags = "文件控制器")
+@RestController
+@Validated
+public class DevFileController<DevConfigApi> {
+
+    /** 默认文件引擎 */
+    private static final String SNOWY_SYS_DEFAULT_FILE_ENGINE_KEY = "SNOWY_SYS_DEFAULT_FILE_ENGINE";
+
+
+    @Resource
+    private DevFileService devFileService;
+
+
+    /**
+     * MINIO文件上传，返回文件Url
+     *
+     * @author xuyuxiang
+     * @date 2021/10/13 14:01
+     **/
+    @ApiOperation("上传MINIO文件返回url")
+    @PostMapping("/dev/file/uploadMinioReturnUrl")
+    public String uploadMinioReturnUrl(@RequestPart("file") MultipartFile file) {
+        return devFileService.uploadReturnUrl(DevFileEngineTypeEnum.MINIO.getValue(), file);
+    }
+
+
+
+}

src/main/java/com/chinaitop/depot/intelligent/file/entity/CommonEntity.java

@@ -0,0 +1,68 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableLogic;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * <p>
+ *     通用基础字段实体：创建时间、创建人、修改时间、修改人，需要此通用字段的实体可继承此类，
+ *     继承此类要求数据表有对应的字段
+ * </p>
+ *
+ * @author xuyuxiang
+ * @date 2020/3/10 16:02
+ */
+@Getter
+@Setter
+public class CommonEntity implements Serializable{
+
+    /** 删除标志 */
+    @JsonIgnore
+    @TableLogic
+    @ApiModelProperty(value = "删除标志", position = 999)
+    @TableField(fill = FieldFill.INSERT)
+    private String deleteFlag;
+
+    /** 创建时间 */
+    @ApiModelProperty(value = "创建时间", position = 1000)
+    @TableField(fill = FieldFill.INSERT)
+    private Date createTime;
+
+
+
+    /** 创建人名称 */
+    @ApiModelProperty(value = "创建人名称", position = 1002)
+    @TableField(exist = false)
+    private String createUserName;
+
+    /** 更新时间 */
+    @ApiModelProperty(value = "更新时间", position = 1003)
+    @TableField(fill = FieldFill.UPDATE)
+    private Date updateTime;
+
+
+    /** 更新人名称 */
+    @ApiModelProperty(value = "更新人名称", position = 1005)
+    @TableField(exist = false)
+    private String updateUserName;
+}

src/main/java/com/chinaitop/depot/intelligent/file/entity/DevConfig.java

@@ -0,0 +1,61 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldStrategy;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 配置实体
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:27
+ **/
+@Getter
+@Setter
+@TableName("DEV_CONFIG")
+public class DevConfig extends CommonEntity {
+
+    /** id */
+    @ApiModelProperty(value = "id", position = 1)
+    private String id;
+
+    /** 配置键 */
+    @ApiModelProperty(value = "配置键", position = 2)
+    private String configKey;
+
+    /** 配置值 */
+    @ApiModelProperty(value = "配置值", position = 3)
+    private String configValue;
+
+    /** 分类 */
+    @ApiModelProperty(value = "分类", position = 4)
+    private String category;
+
+    /** 备注 */
+    @ApiModelProperty(value = "备注", position = 5)
+    private String remark;
+
+    /** 排序码 */
+    @ApiModelProperty(value = "排序码", position = 6)
+    private Integer sortCode;
+
+    /** 扩展信息 */
+    @ApiModelProperty(value = "扩展信息", position = 7)
+    @TableField(insertStrategy = FieldStrategy.IGNORED, updateStrategy = FieldStrategy.IGNORED)
+    private String extJson;
+}

src/main/java/com/chinaitop/depot/intelligent/file/entity/DevFile.java

@@ -0,0 +1,78 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 文件实体
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:27
+ **/
+@Getter
+@Setter
+@TableName("DEV_FILE")
+public class DevFile extends CommonEntity {
+
+    /** id */
+    @ApiModelProperty(value = "id", position = 1)
+    private String id;
+
+    /** 存储引擎 */
+    @ApiModelProperty(value = "存储引擎", position = 2)
+    private String engine;
+
+    /** 存储桶 */
+    @ApiModelProperty(value = "存储桶", position = 3)
+    private String bucket;
+
+    /** 文件名称 */
+    @ApiModelProperty(value = "文件名称", position = 4)
+    private String name;
+
+    /** 文件后缀 */
+    @ApiModelProperty(value = "文件后缀", position = 5)
+    private String suffix;
+
+    /** 文件大小kb */
+    @ApiModelProperty(value = "文件大小kb", position = 6)
+    private String sizeKb;
+
+    /** 文件大小（格式化后） */
+    @ApiModelProperty(value = "文件大小（格式化后）", position = 7)
+    private String sizeInfo;
+
+    /** 文件的对象名（唯一名称） */
+    @ApiModelProperty(value = "文件的对象名（唯一名称）", position = 8)
+    private String objName;
+
+    /** 文件存储路径 */
+    @ApiModelProperty(value = "文件存储路径", position = 9)
+    private String storagePath;
+
+    /** 文件下载路径 */
+    @ApiModelProperty(value = "文件下载路径", position = 10)
+    private String downloadPath;
+
+    /** 图片缩略图 */
+    @ApiModelProperty(value = "图片缩略图", position = 11)
+    private String thumbnail;
+
+    /** 扩展信息 */
+    @ApiModelProperty(value = "扩展信息", position = 12)
+    private String extJson;
+}

src/main/java/com/chinaitop/depot/intelligent/file/entity/MinIoProperties.java

@@ -0,0 +1,52 @@
+package com.chinaitop.depot.intelligent.file.entity;
+
+
+import io.lettuce.core.ConnectionBuilder;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+
+@ConfigurationProperties(prefix = "minio")
+public class MinIoProperties {
+    @Value("${minio.endpoint}")
+    private String endpoint;
+    @Value("${minio.access-key}")
+    private String accessKey;
+    @Value("${minio.secret-key}")
+    private String secretKey;
+    @Value("${minio.bucket-name}")
+    private String bucketName;
+
+    public String getEndpoint() {
+        return endpoint;
+    }
+
+    public void setEndpoint(String endpoint) {
+        this.endpoint = endpoint;
+    }
+
+    public String getAccessKey() {
+        return accessKey;
+    }
+
+    public void setAccessKey(String accessKey) {
+        this.accessKey = accessKey;
+    }
+
+    public String getSecretKey() {
+        return secretKey;
+    }
+
+    public void setSecretKey(String secretKey) {
+        this.secretKey = secretKey;
+    }
+
+    public String getBucketName() {
+        return bucketName;
+    }
+
+    public void setBucketName(String bucketName) {
+        this.bucketName = bucketName;
+    }
+}

src/main/java/com/chinaitop/depot/intelligent/file/enums/DevFileBucketAuthEnum.java

@@ -0,0 +1,38 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.enums;
+
+/**
+ * 文件存储桶的权限策略枚举
+ *
+ * @author xuyuxiang
+ * @date 2022/1/5 23:29
+ */
+public enum DevFileBucketAuthEnum {
+
+    /**
+     * 私有的（仅有 owner 可以读写）
+     */
+    PRIVATE,
+
+    /**
+     * 公有读，私有写（ owner 可以读写， 其他客户可以读）
+     */
+    PUBLIC_READ,
+
+    /**
+     * 公共读写（即所有人都可以读写，慎用）
+     */
+    PUBLIC_READ_WRITE
+
+}

src/main/java/com/chinaitop/depot/intelligent/file/enums/DevFileEngineTypeEnum.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.enums;
+
+import lombok.Getter;
+
+/**
+ * 文件存储引擎类型枚举
+ *
+ * @author xuyuxiang
+ * @date 2022/6/16 16:14
+ **/
+@Getter
+public enum DevFileEngineTypeEnum {
+
+    /** 本地 */
+    LOCAL("LOCAL"),
+
+    /** 阿里云 */
+    ALIYUN("ALIYUN"),
+
+    /** 腾讯云 */
+    TENCENT("TENCENT"),
+
+    /** MINIO */
+    MINIO("MINIO");
+
+    private final String value;
+
+    DevFileEngineTypeEnum(String value) {
+        this.value = value;
+    }
+}

src/main/java/com/chinaitop/depot/intelligent/file/mapper/DevConfigMapper.java

@@ -0,0 +1,25 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.chinaitop.depot.intelligent.file.entity.DevConfig;
+
+/**
+ * 配置Mapper接口
+ *
+ * @author xuyuxiang
+ * @date 2022/4/22 10:43
+ **/
+public interface DevConfigMapper extends BaseMapper<DevConfig> {
+}

src/main/java/com/chinaitop/depot/intelligent/file/mapper/DevFileMapper.java

@@ -0,0 +1,26 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.chinaitop.depot.intelligent.file.entity.DevFile;
+
+/**
+ * 文件Mapper接口
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:40
+ **/
+public interface DevFileMapper extends BaseMapper<DevFile> {
+}

src/main/java/com/chinaitop/depot/intelligent/file/mapper/mapping/DevConfigMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.unis.dev.modular.config.mapper.DevConfigMapper">
+
+
+</mapper>

src/main/java/com/chinaitop/depot/intelligent/file/mapper/mapping/DevFileMapper.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.chinaitop.depot.intelligent.file.mapper.DevFileMapper">
+
+
+</mapper>

src/main/java/com/chinaitop/depot/intelligent/file/param/DevFileIdParam.java

@@ -0,0 +1,35 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+import javax.validation.constraints.NotBlank;
+
+/**
+ * 文件Id参数
+ *
+ * @author xuyuxiang
+ * @date 2022/7/31 10:24
+ */
+@Getter
+@Setter
+public class DevFileIdParam {
+
+    /** id */
+    @ApiModelProperty(value = "id", required = true)
+    @NotBlank(message = "id不能为空")
+    private String id;
+}

src/main/java/com/chinaitop/depot/intelligent/file/param/DevFileListParam.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 文件列表参数
+ *
+ * @author xuyuxiang
+ * @date 2022/7/31 10:24
+ */
+@Getter
+@Setter
+public class DevFileListParam {
+
+    /** 文件引擎 */
+    @ApiModelProperty(value = "文件引擎")
+    private String engine;
+
+    /** 文件名关键词 */
+    @ApiModelProperty(value = "文件名关键词")
+    private String searchKey;
+}

src/main/java/com/chinaitop/depot/intelligent/file/param/DevFilePageParam.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 文件分页列表参数
+ *
+ * @author xuyuxiang
+ * @date 2022/7/31 10:24
+ */
+@Getter
+@Setter
+public class DevFilePageParam {
+
+    /** 文件引擎 */
+    @ApiModelProperty(value = "文件引擎")
+    private String engine;
+
+    /** 文件名关键词 */
+    @ApiModelProperty(value = "文件名关键词")
+    private String searchKey;
+}

src/main/java/com/chinaitop/depot/intelligent/file/service/DevConfigService.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.service;
+
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.chinaitop.depot.intelligent.file.entity.DevConfig;
+
+import java.util.List;
+
+/**
+ * 配置Service接口
+ *
+ * @author xuyuxiang
+ * @date 2022/4/22 10:41
+ **/
+public interface DevConfigService extends IService<DevConfig> {
+
+    /**
+     * 根据键获取值
+     *
+     * @author xuyuxiang
+     * @date 2022/4/22 14:52
+     **/
+    String getValueByKey(String key);
+
+
+}

src/main/java/com/chinaitop/depot/intelligent/file/service/DevFileService.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.service;
+
+import org.springframework.web.multipart.MultipartFile;
+
+
+/**
+ * 文件Service接口
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:27
+ **/
+public interface DevFileService {
+
+    /**
+     * MultipartFile文件上传，返回文件Url
+     *
+     * @author xuyuxiang
+     * @date 2022/4/22 15:53
+     **/
+    String uploadReturnUrl(String engine, MultipartFile file);
+
+}

src/main/java/com/chinaitop/depot/intelligent/file/service/impl/DevConfigApiProvider.java

@@ -0,0 +1,36 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.service.impl;
+
+import com.chinaitop.depot.intelligent.file.service.DevConfigService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+/**
+ * 配置API接口实现类
+ *
+ * @author xuyuxiang
+ * @date 2022/6/17 14:43
+ **/
+@Service
+public class DevConfigApiProvider implements DevConfigApi {
+
+    @Resource
+    private DevConfigService devConfigService;
+
+    @Override
+    public String getValueByKey(String key) {
+        return devConfigService.getValueByKey(key);
+    }
+}

src/main/java/com/chinaitop/depot/intelligent/file/service/impl/DevConfigServiceImpl.java

@@ -0,0 +1,64 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.service.impl;
+
+
+import cn.hutool.core.convert.Convert;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.chinaitop.depot.intelligent.file.controller.CommonCacheOperator;
+import com.chinaitop.depot.intelligent.file.entity.DevConfig;
+import com.chinaitop.depot.intelligent.file.mapper.DevConfigMapper;
+import com.chinaitop.depot.intelligent.file.service.DevConfigService;
+
+import org.springframework.stereotype.Service;
+
+
+import javax.annotation.Resource;
+
+/**
+ * 配置Service接口实现类
+ *
+ * @author xuyuxiang
+ * @date 2022/4/22 10:41
+ **/
+@Service
+public class DevConfigServiceImpl extends ServiceImpl<DevConfigMapper, DevConfig> implements DevConfigService {
+
+    private static final String CONFIG_CACHE_KEY = "dev-config:";
+
+    private static final String SNOWY_SYS_DEFAULT_PASSWORD_KEY = "SNOWY_SYS_DEFAULT_PASSWORD";
+
+    @Resource
+    private CommonCacheOperator commonCacheOperator;
+
+    @Override
+    public String getValueByKey(String key) {
+        // 从缓存中取
+        Object cacheValue = commonCacheOperator.get(CONFIG_CACHE_KEY + key);
+        if(ObjectUtil.isNotEmpty(cacheValue)) {
+            return Convert.toStr(cacheValue);
+        }
+        DevConfig devConfig = this.getOne(new LambdaQueryWrapper<DevConfig>().eq(DevConfig::getConfigKey, key));
+        if(ObjectUtil.isNotEmpty(devConfig)) {
+            // 更新到缓存
+            commonCacheOperator.put(CONFIG_CACHE_KEY + key, devConfig.getConfigValue());
+            return devConfig.getConfigValue();
+        }
+        return null;
+    }
+
+}

src/main/java/com/chinaitop/depot/intelligent/file/service/impl/DevFileServiceImpl.java

@@ -0,0 +1,195 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.service.impl;
+
+import cn.hutool.core.convert.Convert;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.img.ImgUtil;
+import cn.hutool.core.io.FileUtil;
+
+import cn.hutool.core.util.NumberUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+
+import com.baomidou.mybatisplus.core.toolkit.IdWorker;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.chinaitop.depot.intelligent.file.entity.DevFile;
+import com.chinaitop.depot.intelligent.file.enums.DevFileEngineTypeEnum;
+import com.chinaitop.depot.intelligent.file.mapper.DevFileMapper;
+import com.chinaitop.depot.intelligent.file.service.DevFileService;
+
+import com.chinaitop.depot.intelligent.file.util.CommonProperties;
+import com.chinaitop.depot.intelligent.file.util.DevFileMinIoUtil;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+
+import javax.annotation.Resource;
+import java.math.BigDecimal;
+
+
+/**
+ * 文件Service接口实现类
+ *
+ * @author xuyuxiang
+ * @date 2022/2/23 18:43
+ **/
+@Service
+public class DevFileServiceImpl extends ServiceImpl<DevFileMapper, DevFile> implements DevFileService {
+
+    @Resource
+    private CommonProperties commonProperties;
+
+
+    @Override
+    public String uploadReturnUrl(String engine, MultipartFile file) {
+        return this.storageFile(engine, file, false);
+    }
+
+
+    /**
+     * 存储文件
+     *
+     * @author xuyuxiang
+     * @date 2022/6/16 16:24
+     **/
+    private String storageFile(String engine, MultipartFile file, boolean returnFileId) {
+
+        // 如果引擎为空，默认使用本地
+        if(ObjectUtil.isEmpty(engine)) {
+            engine = DevFileEngineTypeEnum.LOCAL.getValue();
+        }
+
+        // 生成id
+        String fileId = IdWorker.getIdStr();
+
+        // 存储桶名称
+        String bucketName = null;
+
+        // 定义存储的url，本地文件返回文件实际路径，其他引擎返回网络地址
+        String storageUrl = null;
+
+        // 根据引擎类型执行不同方法
+       if(engine.equals(DevFileEngineTypeEnum.MINIO.getValue())) {
+
+            // 使用MINIO默认配置的bucketName
+            bucketName = DevFileMinIoUtil.getDefaultBucketName();
+            storageUrl = DevFileMinIoUtil.storageFileWithReturnUrl(bucketName, genFileKey(fileId, file), file);
+        } else {
+            //throw new CommonException("不支持的文件引擎：{}", engine);
+        }
+
+        // 将文件信息保存到数据库
+        DevFile devFile = new DevFile();
+
+        // 设置文件id
+        devFile.setId(fileId);
+
+        // 设置存储引擎类型
+        devFile.setEngine(engine);
+        devFile.setBucket(bucketName);
+        devFile.setName(file.getOriginalFilename());
+        String suffix = ObjectUtil.isNotEmpty(file.getOriginalFilename())?StrUtil.subAfter(file.getOriginalFilename(),
+                StrUtil.DOT, true):null;
+        devFile.setSuffix(suffix);
+        devFile.setSizeKb(Convert.toStr(NumberUtil.div(new BigDecimal(file.getSize()), BigDecimal.valueOf(1024))
+                .setScale(0, BigDecimal.ROUND_HALF_UP)));
+        devFile.setSizeInfo(FileUtil.readableFileSize(file.getSize()));
+        devFile.setObjName(ObjectUtil.isNotEmpty(devFile.getSuffix())?fileId + StrUtil.DOT + devFile.getSuffix():null);
+        // 如果是图片，则压缩生成缩略图
+        if(ObjectUtil.isNotEmpty(suffix)) {
+            if(isPic(suffix)) {
+                try {
+                    devFile.setThumbnail(ImgUtil.toBase64DataUri(ImgUtil.scale(ImgUtil.toImage(file.getBytes()),
+                            100, 100, null), suffix));
+                } catch (Exception ignored) {
+                }
+            }
+        }
+        // 存储路径
+        devFile.setStoragePath(storageUrl);
+
+        // 定义下载地址
+        String downloadUrl = null;
+
+        // 下载路径，注意：本地文件下载地址设置为下载接口地址 + 文件id
+        if(engine.equals(DevFileEngineTypeEnum.LOCAL.getValue())) {
+            String apiUrl = commonProperties.getBackendUrl();
+//            if(ObjectUtil.isEmpty(apiUrl)) {
+//                throw new CommonException("后端域名地址未正确配置：snowy.config.common.backend-url为空");
+//            }
+            downloadUrl= apiUrl + "/dev/file/download?id=" + fileId;
+            devFile.setDownloadPath(downloadUrl);
+        } else {
+            // 阿里云、腾讯云、MINIO可以直接使用存储地址（公网）作为下载地址
+            downloadUrl= storageUrl;
+            devFile.setDownloadPath(devFile.getStoragePath());
+        }
+
+        this.save(devFile);
+
+        // 如果是返回id则返回文件id
+        if(returnFileId) {
+            return fileId;
+        } else {
+            // 否则返回下载地址
+            return downloadUrl;
+        }
+    }
+
+
+    /**
+     * 生成文件的key，格式如 2021/10/11/1377109572375810050.docx
+     *
+     * @author xuyuxiang
+     * @date 2022/4/22 15:58
+     **/
+    public String genFileKey(String fileId, MultipartFile file) {
+
+        // 获取文件原始名称
+        String originalFileName = file.getOriginalFilename();
+
+        // 获取文件后缀
+        String fileSuffix = FileUtil.getSuffix(originalFileName);
+
+        // 生成文件的对象名称，格式如:1377109572375810050.docx
+        String fileObjectName = fileId + StrUtil.DOT + fileSuffix;
+
+        // 获取日期文件夹，格式如，2021/10/11/
+        String dateFolderPath = DateUtil.thisYear() + StrUtil.SLASH +
+                (DateUtil.thisMonth() + 1) + StrUtil.SLASH +
+                DateUtil.thisDayOfMonth() + StrUtil.SLASH;
+
+        // 返回
+        return dateFolderPath + fileObjectName;
+    }
+
+
+    /**
+     * 根据文件后缀判断是否图片
+     *
+     * @author xuyuxiang
+     * @date 2020/7/6 15:31
+     */
+    private static boolean isPic(String fileSuffix) {
+        fileSuffix = fileSuffix.toLowerCase();
+        return ImgUtil.IMAGE_TYPE_GIF.equals(fileSuffix)
+                || ImgUtil.IMAGE_TYPE_JPG.equals(fileSuffix)
+                || ImgUtil.IMAGE_TYPE_JPEG.equals(fileSuffix)
+                || ImgUtil.IMAGE_TYPE_BMP.equals(fileSuffix)
+                || ImgUtil.IMAGE_TYPE_PNG.equals(fileSuffix)
+                || ImgUtil.IMAGE_TYPE_PSD.equals(fileSuffix);
+    }
+}

src/main/java/com/chinaitop/depot/intelligent/file/util/CommonProperties.java

@@ -0,0 +1,37 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.util;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * 通用基础配置
+ *
+ * @author xuyuxiang
+ * @date 2022/1/2 17:03
+ */
+@Getter
+@Setter
+@Component
+@ConfigurationProperties(prefix = "snowy.config.common")
+public class CommonProperties {
+
+    /** 前端地址 */
+    private String frontUrl;
+
+    /** 后端地址 */
+    private String backendUrl;
+}

src/main/java/com/chinaitop/depot/intelligent/file/util/DevFileLocalUtil.java

@@ -0,0 +1,259 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.util;
+
+import cn.hutool.core.io.FileUtil;
+import cn.hutool.extra.spring.SpringUtil;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import cn.hutool.system.SystemUtil;
+
+import lombok.extern.slf4j.Slf4j;
+
+
+
+import java.io.File;
+import java.io.InputStream;
+
+/**
+ * 本地文件工具类
+ *
+ * @author xuyuxiang
+ * @date 2022/1/2 18:13
+ */
+@Slf4j
+public class DevFileLocalUtil {
+
+    private static JSONObject client;
+
+    private static final String SNOWY_FILE_LOCAL_FOLDER_FOR_WINDOWS_KEY = "SNOWY_FILE_LOCAL_FOLDER_FOR_WINDOWS";
+    private static final String SNOWY_FILE_LOCAL_FOLDER_FOR_UNIX_KEY = "SNOWY_FILE_LOCAL_FOLDER_FOR_UNIX";
+
+    /**
+     * 初始化操作的客户端
+     *
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    private static void initClient() {
+
+        String uploadFileFolder;
+
+        DevConfigApi devConfigApi = SpringUtil.getBean(DevConfigApi.class);
+
+        if(SystemUtil.getOsInfo().isWindows()) {
+
+            /* 本地文件上传的位置 windows系统 */
+            String localFolderForWindows = devConfigApi.getValueByKey(SNOWY_FILE_LOCAL_FOLDER_FOR_WINDOWS_KEY);
+
+//            if(ObjectUtil.isEmpty(localFolderForWindows)) {
+//                throw new CommonException("本地文件操作客户端未正确配置：SNOWY_FILE_LOCAL_FOLDER_FOR_WINDOWS为空");
+//            }
+            uploadFileFolder = localFolderForWindows;
+        } else {
+
+            /* 本地文件上传的位置 unix系列系统（linux、mac等） */
+            String localFolderForUnix = devConfigApi.getValueByKey(SNOWY_FILE_LOCAL_FOLDER_FOR_UNIX_KEY);
+
+//            if(ObjectUtil.isEmpty(localFolderForUnix)) {
+//                throw new CommonException("本地文件操作客户端未正确配置：SNOWY_FILE_LOCAL_FOLDER_FOR_UNIX为空");
+//            }
+            uploadFileFolder = localFolderForUnix;
+        }
+        if(!FileUtil.exist(uploadFileFolder)) {
+            FileUtil.mkdir(uploadFileFolder);
+        }
+        client = JSONUtil.createObj();
+        client.set("localFileUploadFolder", uploadFileFolder);
+    }
+
+    /**
+     * 销毁操作的客户端
+     *
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void destroyClient() {
+        client.clear();
+    }
+
+    /**
+     * 获取操作的客户端
+     *
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static JSONObject getClient() {
+        return client;
+    }
+
+    /**
+     * 获取上传地址
+     *
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static String getUploadFileFolder() {
+        return client.getStr("localFileUploadFolder");
+    }
+
+    /**
+     * 查询存储桶是否存在
+     * 例如：传入参数examplebucket-1250000000，返回true代表存在此桶
+     *
+     * @param bucketName 桶名称
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static boolean doesBucketExist(String bucketName) {
+        initClient();
+        return FileUtil.exist(getUploadFileFolder() + FileUtil.FILE_SEPARATOR + bucketName);
+    }
+
+
+
+
+
+    /**
+     * 存储文件，不返回地址
+     *
+     * @param bucketName 桶名称
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @param bytes      文件字节数组
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void storageFile(String bucketName, String key, byte[] bytes) {
+        initClient();
+        FileUtil.writeBytes(bytes, getUploadFileFolder() + FileUtil.FILE_SEPARATOR + bucketName + FileUtil.FILE_SEPARATOR + key);
+    }
+
+    /**
+     * 存储文件，不返回地址
+     *
+     * @param bucketName  桶名称
+     * @param key         唯一标示id，例如a.txt, doc/a.txt
+     * @param inputStream 文件流
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void storageFile(String bucketName, String key, InputStream inputStream) {
+        initClient();
+        FileUtil.writeFromStream(inputStream, getUploadFileFolder() + FileUtil.FILE_SEPARATOR + bucketName + FileUtil.FILE_SEPARATOR + key);
+    }
+
+
+
+
+
+    /**
+     * 存储文件，返回存储的地址
+     *
+     * @param bucketName 桶名称
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @param bytes      文件字节数组
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static String storageFileWithReturnUrl(String bucketName, String key, byte[] bytes) {
+        storageFile(bucketName, key, bytes);
+        return getFileAuthUrl(bucketName, key);
+    }
+
+    /**
+     * 存储文件，返回存储的地址
+     *
+     * @param bucketName  桶名称
+     * @param key         唯一标示id，例如a.txt, doc/a.txt
+     * @param inputStream 文件流
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static String storageFileWithReturnUrl(String bucketName, String key, InputStream inputStream) {
+        storageFile(bucketName, key, inputStream);
+        return getFileAuthUrl(bucketName, key);
+    }
+
+    /**
+     * 获取某个bucket下的文件字节
+     *
+     * @param bucketName 桶名称
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static byte[] getFileBytes(String bucketName, String key) {
+        File file = getFileByBucketNameAndKey(bucketName, key);
+        return FileUtil.readBytes(file);
+    }
+
+
+    /**
+     * 拷贝文件
+     *
+     * @param originBucketName 源文件桶
+     * @param originFileKey    源文件名称
+     * @param newBucketName    新文件桶
+     * @param newFileKey       新文件名称
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void copyFile(String originBucketName, String originFileKey, String newBucketName, String newFileKey) {
+        initClient();
+        File file = getFileByBucketNameAndKey(originBucketName, originFileKey);
+        File newFile = FileUtil.file(getUploadFileFolder() + FileUtil.FILE_SEPARATOR + newBucketName + FileUtil.FILE_SEPARATOR + newFileKey);
+        FileUtil.copy(file, newFile, true);
+    }
+
+    /**
+     * 获取文件的实际存储地址
+     *
+     * @param bucketName 文件桶
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static String getFileAuthUrl(String bucketName, String key) {
+        initClient();
+        File file = getFileByBucketNameAndKey(bucketName, key);
+        return file.getAbsolutePath();
+    }
+
+    /**
+     * 删除文件
+     *
+     * @param bucketName 文件桶
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void deleteFile(String bucketName, String key) {
+        File file = getFileByBucketNameAndKey(bucketName, key);
+        FileUtil.del(file);
+    }
+
+    /**
+     * 根据桶名称和文件key获取文件
+     *
+     * @param bucketName 文件桶
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static File getFileByBucketNameAndKey(String bucketName, String key) {
+        initClient();
+        String path = getUploadFileFolder() + FileUtil.FILE_SEPARATOR + bucketName + FileUtil.FILE_SEPARATOR + key;
+        File file = FileUtil.file(path);
+        return file;
+    }
+}

src/main/java/com/chinaitop/depot/intelligent/file/util/DevFileMinIoUtil.java

@@ -0,0 +1,219 @@
+/*
+ * Copyright [2022] [https://www.xiaonuo.vip]
+ *
+ * Snowy采用APACHE LICENSE 2.0开源协议，您在使用过程中，需要注意以下几点：
+ *
+ * 1.请不要删除和修改根目录下的LICENSE文件。
+ * 2.请不要删除和修改Snowy源码头部的版权声明。
+ * 3.本项目代码可免费商业使用，商业使用请保留源码和相关描述文件的项目出处，作者声明等。
+ * 4.分发源码时候，请注明软件出处 https://www.xiaonuo.vip
+ * 5.不可二次分发开源参与同类竞品，如有想法可联系团队xiaonuobase@qq.com商议合作。
+ * 6.若您的项目无法满足以上几点，需要更多功能代码，获取Snowy商业授权许可，请在官网购买授权，地址为 https://www.xiaonuo.vip
+ */
+package com.chinaitop.depot.intelligent.file.util;
+
+import cn.hutool.core.io.IoUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.extra.spring.SpringUtil;
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.chinaitop.depot.intelligent.file.entity.MinIoProperties;
+import com.chinaitop.depot.intelligent.file.enums.DevFileBucketAuthEnum;
+import io.minio.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.activation.MimetypesFileTypeMap;
+import java.io.IOException;
+import java.io.InputStream;
+
+/**
+ * MINIO文件工具类
+ * 参考文档：http://docs.minio.org.cn/docs/master/java-client-quickstart-guide
+ *
+ * @author xuyuxiang
+ * @date 2022/1/2 18:13
+ */
+@Slf4j
+@Component
+public class DevFileMinIoUtil {
+
+
+    private static MinioClient client;
+
+    private static String defaultBucketName;
+
+    private static final String SNOWY_FILE_MINIO_ACCESS_KEY_KEY = "SNOWY_FILE_MINIO_ACCESS_KEY";
+    private static final String SNOWY_FILE_MINIO_SECRET_KEY_KEY = "SNOWY_FILE_MINIO_SECRET_KEY";
+    private static final String SNOWY_FILE_MINIO_END_POINT_KEY = "SNOWY_FILE_MINIO_END_POINT";
+    /**
+     * 文件访问前缀
+     *
+     * @author: ybw
+     * @date: 2024/5/31
+     **/
+    private static final String SNOWY_FILE_MINIO_ACCESS_PREFIX = "SNOWY_FILE_MINIO_ACCESS_PREFIX";
+    private static final String SNOWY_FILE_MINIO_DEFAULT_BUCKET_NAME = "SNOWY_FILE_MINIO_DEFAULT_BUCKET_NAME";
+    private static MinIoProperties minIoProperties;
+    @Autowired
+    public DevFileMinIoUtil(MinIoProperties minIoProperties) {
+        this.minIoProperties = minIoProperties;
+    }
+
+    /**
+     * 初始化操作的客户端
+     *
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    private static void initClient() {
+
+
+        /* 默认BucketName */
+       String defaultBucketName = minIoProperties.getBucketName();
+       String endpoint=minIoProperties.getEndpoint();
+       String accessKey= minIoProperties.getAccessKey();
+        String secretKey =minIoProperties.getSecretKey();
+        client = MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();
+
+    }
+
+    /**
+     * 获取默认存储桶名称
+     *
+     * @author xuyuxiang
+     * @date 2022/6/22 18:05
+     **/
+    public static  String getDefaultBucketName() {
+        initClient();
+
+        return minIoProperties.getBucketName();
+
+    }
+
+
+    /**
+     * 存储文件，返回外网地址
+     *
+     * @param bucketName 桶名称
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @param multipartFile      文件
+     * @author xuyuxiang
+     * @date 2022/1/5 23:45
+     */
+    public static String storageFileWithReturnUrl(String bucketName, String key, MultipartFile multipartFile) {
+        storageFile(bucketName, key, multipartFile);
+        setFileAcl(bucketName, key, DevFileBucketAuthEnum.PUBLIC_READ);
+        return getFileAuthUrl(bucketName, key);
+    }
+
+
+
+    /**
+     * 获取文件的下载地址（永久的，文件必须为公有读），生成外网地址
+     *
+     * @param bucketName 文件桶
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static String getFileAuthUrl(String bucketName, String key) {
+
+            initClient();
+            return minIoProperties.getEndpoint() + StrUtil.SLASH + bucketName + StrUtil.SLASH + key;
+
+    }
+    /**
+     * 存储文件，不返回地址
+     *
+     * @param bucketName 桶名称
+     * @param key        唯一标示id，例如a.txt, doc/a.txt
+     * @param multipartFile      文件
+     * @author xuyuxiang
+     * @date 2022/1/5 23:45
+     */
+    public static void storageFile(String bucketName, String key, MultipartFile multipartFile) {
+        InputStream inputStream = null;
+        try {
+            inputStream = multipartFile.getInputStream();
+        } catch (IOException e) {
+   
+        }
+        storageFile(bucketName, key, inputStream);
+    }
+
+    /**
+     * 设置文件访问权限管理
+     *
+     * @param bucketName     桶名称
+     * @param key             唯一标示id，例如a.txt, doc/a.txt
+     * @param devFileBucketAuthEnum 文件权限
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void setFileAcl(String bucketName, String key, DevFileBucketAuthEnum devFileBucketAuthEnum) {
+        try {
+            JSONObject configObject = JSONUtil.createObj().set("Version", "2012-10-17");
+            JSONArray statementArray = JSONUtil.createArray();
+            JSONArray actionArray = JSONUtil.createArray();
+            if(devFileBucketAuthEnum.equals(DevFileBucketAuthEnum.PUBLIC_READ)) {
+                actionArray.put("s3:GetObject");
+            }
+            if(devFileBucketAuthEnum.equals(DevFileBucketAuthEnum.PUBLIC_READ_WRITE)) {
+                actionArray.put("s3:GetObject");
+                actionArray.put("s3:PutObject");
+            }
+            JSONObject statementObject = JSONUtil.createObj();
+            statementObject.set("Effect", "Allow").set("Principal", JSONUtil.createObj().set("AWS", JSONUtil.createArray().put("*")))
+                    .set("Action", actionArray).set("Resource", JSONUtil.createArray().put("arn:aws:s3:::" + bucketName + "/*"));
+            statementArray.put(statementObject);
+            configObject.set("Statement", statementArray);
+            String config = JSONUtil.toJsonStr(configObject);
+            SetBucketPolicyArgs setBucketPolicyArgs = SetBucketPolicyArgs.builder().bucket(bucketName).config(config).build();
+            client.setBucketPolicy(setBucketPolicyArgs);
+        } catch (Exception e) {
+          
+        }
+    }
+
+    /**
+     * 存储文件，不返回地址
+     *
+     * @param bucketName  桶名称
+     * @param key         唯一标示id，例如a.txt, doc/a.txt
+     * @param inputStream 文件流
+     * @author xuyuxiang
+     * @date 2022/1/5 23:24
+     */
+    public static void storageFile(String bucketName, String key, InputStream inputStream) {
+        try {
+            initClient();
+            PutObjectArgs putObjectArgs = PutObjectArgs.builder().bucket(bucketName).object(key)
+                    .contentType(getFileContentType(key)).stream(inputStream, inputStream.available(), -1).build();
+            client.putObject(putObjectArgs);
+        } catch (Exception e) {
+           
+        } finally {
+            IoUtil.close(inputStream);
+        }
+    }
+
+    /**
+     * 根据文件名获取ContentType
+     *
+     * @author xuyuxiang
+     * @date 2022/1/6 11:27
+     **/
+    private static String getFileContentType(String key) {
+        // 根据文件名获取contentType
+        String contentType = "application/octet-stream";
+        if (key.contains(".")) {
+            contentType = MimetypesFileTypeMap.getDefaultFileTypeMap().getContentType(key);
+        }
+        return contentType;
+    }
+
+}

src/main/resources/bootstrap-dev.yml

@@ -43,8 +43,14 @@ spring:
         max-wait: -1ms
         max-idle: 8
         min-idle: 0
+minio:
+  endpoint: http://172.16.0.36:15772
+  access-key: 4vFQhyfxcwcqAXHPOV57
+  secret-key: 3kB9RIsEqXuHMG6FDDp4f299LACEwztgybwYTAmg
+  bucket-name: depot-qinghai
 web:
   upload-path: /home/depot/depot-web/apache-tomcat-8.0.53/webapps/ROOT/WEB-INF/classes/static
+
 mybatis-plus:
   mapper-locations: classpath:/mapper/*/*.xml
   configuration: