langchat-大模型

/* * Copyright (c) 2024 LangChat. TyCoding All Rights Reserved. * * Licensed under the GNU Affero General Public License, Version 3 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * https://www.gnu.org/licenses/agpl-3.0.html * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package cn.tycoding.langchat.common.oss.config; import lombok.Data; import lombok.EqualsAndHashCode; import lombok.experimental.Accessors; import org.dromara.x.file.storage.core.FileStorageProperties; import org.dromara.x.file.storage.core.FileStorageProperties.*; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.stereotype.Component; import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; @Data @Accessors(chain = true) @Component @ConditionalOnMissingBean(SpringFileStorageProperties.class) @ConfigurationProperties(prefix = "langchat.oss") public class SpringFileStorageProperties { /** * 默认存储平台 */ private String defaultPlatform = "local"; /** * 缩略图后缀，例如【.min.jpg】【.png】 */ private String thumbnailSuffix = ".min.jpg"; /** * 上传时不支持元数据时抛出异常 */ private Boolean uploadNotSupportMetadataThrowException = true; /** * 上传时不支持 ACL 时抛出异常 */ private Boolean uploadNotSupportAclThrowException = true; /** * 复制时不支持元数据时抛出异常 */ private Boolean copyNotSupportMetadataThrowException = true; /** * 复制时不支持 ACL 时抛出异常 */ private Boolean copyNotSupportAclThrowException = true; /** * 移动时不支持元数据时抛出异常 */ private Boolean moveNotSupportMetadataThrowException = true; /** * 移动时不支持 ACL 时抛出异常 */ private Boolean moveNotSupportAclThrowException = true; /** * 启用 byte[] 文件包装适配器 */ private Boolean enableByteFileWrapper = true; /** * 启用 URI 文件包装适配器，包含 URL 和 String */ private Boolean enableUriFileWrapper = true; /** * 启用 InputStream 文件包装适配器 */ private Boolean enableInputStreamFileWrapper = true; /** * 启用本地文件包装适配器 */ private Boolean enableLocalFileWrapper = true; /** * 启用 HttpServletRequest 文件包装适配器 */ private Boolean enableHttpServletRequestFileWrapper = true; /** * 启用 MultipartFile 文件包装适配器 */ private Boolean enableMultipartFileWrapper = true; /** * 本地存储 */ @Deprecated private List<? extends SpringLocalConfig> local = new ArrayList<>(); /** * 本地存储 */ private List<? extends SpringLocalPlusConfig> localPlus = new ArrayList<>(); /** * 华为云 OBS */ private List<? extends SpringHuaweiObsConfig> huaweiObs = new ArrayList<>(); /** * 阿里云 OSS */ private List<? extends SpringAliyunOssConfig> aliyunOss = new ArrayList<>(); /** * 七牛云 Kodo */ private List<? extends SpringQiniuKodoConfig> qiniuKodo = new ArrayList<>(); /** * 腾讯云 COS */ private List<? extends SpringTencentCosConfig> tencentCos = new ArrayList<>(); /** * 百度云 BOS */ private List<? extends SpringBaiduBosConfig> baiduBos = new ArrayList<>(); /** * 又拍云 USS */ private List<? extends SpringUpyunUssConfig> upyunUss = new ArrayList<>(); /** * MinIO USS */ private List<? extends SpringMinioConfig> minio = new ArrayList<>(); /** * Amazon S3 */ private List<? extends SpringAmazonS3Config> amazonS3 = new ArrayList<>(); /** * FTP */ private List<? extends SpringFtpConfig> ftp = new ArrayList<>(); /** * FTP */ private List<? extends SpringSftpConfig> sftp = new ArrayList<>(); /** * WebDAV */ private List<? extends SpringWebDavConfig> webdav = new ArrayList<>(); /** * GoogleCloud Storage */ private List<? extends SpringGoogleCloudStorageConfig> googleCloudStorage = new ArrayList<>(); /** * FastDFS */ private List<? extends SpringFastDfsConfig> fastdfs = new ArrayList<>(); /** * Azure Blob Storage */ private List<? extends SpringAzureBlobStorageConfig> azureBlob = new ArrayList<>(); /** * 转换成 FileStorageProperties ，并过滤掉没有启用的存储平台 */ public FileStorageProperties toFileStorageProperties() { FileStorageProperties properties = new FileStorageProperties(); properties.setDefaultPlatform(defaultPlatform); properties.setThumbnailSuffix(thumbnailSuffix); properties.setUploadNotSupportMetadataThrowException(uploadNotSupportMetadataThrowException); properties.setUploadNotSupportAclThrowException(uploadNotSupportAclThrowException); properties.setCopyNotSupportMetadataThrowException(copyNotSupportMetadataThrowException); properties.setCopyNotSupportAclThrowException(copyNotSupportAclThrowException); properties.setMoveNotSupportMetadataThrowException(moveNotSupportMetadataThrowException); properties.setMoveNotSupportAclThrowException(moveNotSupportAclThrowException); properties.setLocal( local.stream().filter(SpringLocalConfig::getEnableStorage).collect(Collectors.toList())); properties.setLocalPlus(localPlus.stream() .filter(SpringLocalPlusConfig::getEnableStorage) .collect(Collectors.toList())); properties.setHuaweiObs(huaweiObs.stream() .filter(SpringHuaweiObsConfig::getEnableStorage) .collect(Collectors.toList())); properties.setAliyunOss(aliyunOss.stream() .filter(SpringAliyunOssConfig::getEnableStorage) .collect(Collectors.toList())); properties.setQiniuKodo(qiniuKodo.stream() .filter(SpringQiniuKodoConfig::getEnableStorage) .collect(Collectors.toList())); properties.setTencentCos(tencentCos.stream() .filter(SpringTencentCosConfig::getEnableStorage) .collect(Collectors.toList())); properties.setBaiduBos( baiduBos.stream().filter(SpringBaiduBosConfig::getEnableStorage).collect(Collectors.toList())); properties.setUpyunUss( upyunUss.stream().filter(SpringUpyunUssConfig::getEnableStorage).collect(Collectors.toList())); properties.setMinio( minio.stream().filter(SpringMinioConfig::getEnableStorage).collect(Collectors.toList())); properties.setAmazonS3( amazonS3.stream().filter(SpringAmazonS3Config::getEnableStorage).collect(Collectors.toList())); properties.setFtp(ftp.stream().filter(SpringFtpConfig::getEnableStorage).collect(Collectors.toList())); properties.setSftp( sftp.stream().filter(SpringSftpConfig::getEnableStorage).collect(Collectors.toList())); properties.setWebdav( webdav.stream().filter(SpringWebDavConfig::getEnableStorage).collect(Collectors.toList())); properties.setGoogleCloudStorage(googleCloudStorage.stream() .filter(SpringGoogleCloudStorageConfig::getEnableStorage) .collect(Collectors.toList())); properties.setFastdfs(