feat: selectAll,返回所有数据

This commit is contained in:
sjm
2024-07-12 22:31:28 +08:00
parent 5874fe1c2a
commit 6cf096219f
45 changed files with 350 additions and 38 deletions

View File

@@ -16,6 +16,7 @@ import com.schisandra.oss.domain.bo.SchisandraOssAliBO;
import com.schisandra.oss.domain.redis.RedisUtil;
import com.schisandra.oss.domain.service.SchisandraOssAliDomainService;
import com.schisandra.oss.infra.basic.dao.SchisandraOssAliDao;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
@@ -28,6 +29,7 @@ import java.io.InputStream;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
@@ -50,6 +52,17 @@ public class SchisandraOssAliController {
@Resource
RedisUtil redisUtil;
/**
* 返回ali表所有数据
* @return
*/
@GetMapping("returnAll")
public List<SchisandraOssAliDTO> returnAll() {
return aliOssConfiguration.selectAll();
}
@GetMapping("init")
public void init(@RequestParam String userId){
if (log.isInfoEnabled()) {

View File

@@ -7,6 +7,7 @@ import com.amazonaws.util.IOUtils;
import com.google.common.base.Preconditions;
import com.google.gson.Gson;
import com.schisandra.oss.application.convert.SchisandraOssMinioDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssAliDTO;
import com.schisandra.oss.application.dto.SchisandraOssMinioDTO;
import com.schisandra.oss.application.oss.core.minio.MinioOssClient;
import com.schisandra.oss.application.oss.core.minio.MinioOssConfiguration;
@@ -55,6 +56,16 @@ public class SchisandraOssMinioController {
RedisUtil redisUtil;
/**
* 返回minio表所有数据
* @return
*/
@GetMapping("returnAll")
public List<SchisandraOssMinioDTO> returnAll() {
return minioOssConfiguration.selectAll();
}
/**
* @description: minio 初始化
* @param: []
@@ -234,7 +245,6 @@ public class SchisandraOssMinioController {
} catch (Exception e) {
return Result.fail(e.getMessage());
}
}
/**
* @description: 分享文件
@@ -301,6 +311,7 @@ public class SchisandraOssMinioController {
bean.getMinioOssConfig().setBucketName(bucket);
return Result.ok(bean.deleteBucket(bucket));
}
@PostMapping("get")
public SchisandraOssMinioDTO getMinioOss(@RequestParam String userId) {
return SchisandraOssMinioDTOConverter.INSTANCE.convertBOToDTO(schisandraOssMinioDomainService.getMinioConfig(Long.valueOf(userId)));

View File

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSON;
import com.google.common.base.Preconditions;
import com.schisandra.oss.application.convert.SchisandraOssQiniuDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssQiniuDTO;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.core.qiniu.QiNiuOssClient;
import com.schisandra.oss.application.oss.core.qiniu.QiNiuOssConfiguration;
import com.schisandra.oss.application.oss.model.OssInfo;
@@ -23,6 +24,7 @@ import java.io.InputStream;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 七牛云对象存储配置表 controller
@@ -43,6 +45,16 @@ public class SchisandraOssQiniuController {
private final String USER_OSS_PREFIX = "oss:user:heat";
@Resource
RedisUtil redisUtil;
/**
* 返回七牛表所有数据
* @return
*/
@GetMapping("returnAll")
public List<SchisandraOssQiniuDTO> returnAll() {
return qiNiuOssConfiguration.selectAll();
}
/**
* @description: 获取文件目录信息
* @param: [target, userId, dirName]

View File

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSON;
import com.google.common.base.Preconditions;
import com.schisandra.oss.application.convert.SchisandraOssSftpDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssSftpDTO;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.core.ali.AliOssClient;
import com.schisandra.oss.application.oss.core.ftp.FtpOssClient;
import com.schisandra.oss.application.oss.core.ftp.FtpOssConfiguration;
@@ -29,6 +30,7 @@ import java.io.InputStream;
import java.net.URLEncoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* sftp存储配置表 controller
@@ -51,6 +53,14 @@ public class SchisandraOssSftpController {
@Resource
RedisUtil redisUtil;
/**
* 返回up表所有数据
* @return
*/
@GetMapping("returnAll")
public List<SchisandraOssSftpDTO> returnAll() {
return sftpOssConfiguration.selectAll();
}
/**
* @description: 拷贝文件

View File

@@ -10,6 +10,7 @@ import com.qcloud.cos.model.DeleteObjectsResult;
import com.schisandra.oss.application.convert.SchisandraOssTencentDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssTencentDTO;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.core.minio.MinioOssClient;
import com.schisandra.oss.application.oss.core.tencent.TencentOssClient;
import com.schisandra.oss.application.oss.core.tencent.TencentOssConfiguration;
@@ -49,6 +50,17 @@ public class SchisandraOssTencentController {
private final String USER_OSS_PREFIX = "oss:user:heat";
@Resource
RedisUtil redisUtil;
/**
* 返回tencent表所有数据
* @return
*/
@GetMapping("returnAll")
public List<SchisandraOssTencentDTO> returnAll() {
return tencentOssConfiguration.selectAll();
}
@PostMapping("init")
public void initTencent(@RequestParam String userId) throws ServerException, InsufficientDataException, ErrorResponseException, IOException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {

View File

@@ -4,15 +4,18 @@ import com.alibaba.fastjson.JSON;
import com.google.common.base.Preconditions;
import com.schisandra.oss.application.convert.SchisandraOssUpDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.core.up.UpOssConfiguration;
import com.schisandra.oss.common.entity.Result;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.service.SchisandraOssUpDomainService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.List;
/**
* 又拍云对象存储配置表 controller
@@ -27,6 +30,17 @@ public class SchisandraOssUpController {
@Resource
private SchisandraOssUpDomainService schisandraOssUpDomainService;
@Resource
private UpOssConfiguration upOssConfiguration;
/**
* 返回up表所有数据
* @return
*/
@GetMapping("returnAll")
public List<SchisandraOssUpDTO> returnAll() {
return upOssConfiguration.selectAll();
}
/**
* 新增又拍云对象存储配置表

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.application.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
@@ -234,11 +235,14 @@ public class SchisandraOssAliDTO implements Serializable {
/**
* 创建时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date createdTime;
/**
* 更新时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.application.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
@@ -157,11 +158,13 @@ public class SchisandraOssMinioDTO implements Serializable {
/**
* 创建时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date createdTime;
/**
* 更新时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.application.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
@@ -137,11 +138,13 @@ public class SchisandraOssQiniuDTO implements Serializable {
/**
* 创建时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date createdTime;
/**
* 更新时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.application.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
@@ -102,11 +103,13 @@ public class SchisandraOssSftpDTO implements Serializable {
/**
* 创建时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date createdTime;
/**
* 更新时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.application.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
@@ -152,11 +153,13 @@ public class SchisandraOssTencentDTO implements Serializable {
/**
* 创建时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date createdTime;
/**
* 更新时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.application.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
@@ -82,11 +83,13 @@ public class SchisandraOssUpDTO implements Serializable {
/**
* 创建时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date createdTime;
/**
* 更新时间
*/
@JsonFormat(locale = "zh", timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
private Date updateTime;
/**

View File

@@ -16,7 +16,8 @@ import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.Arrays;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;
@@ -32,6 +33,16 @@ public class AliOssConfiguration {
@Resource
SchisandraOssAliDomainService schisandraOssAliDomainService;
public List<SchisandraOssAliDTO> selectAll(){
List<SchisandraOssAliBO> schisandraOssAliBO_list = schisandraOssAliDomainService.selectAll();
List<SchisandraOssAliDTO> schisandraOssAliDTO_list = new ArrayList<>();
for (SchisandraOssAliBO schisandraOssAliBO : schisandraOssAliBO_list ){
SchisandraOssAliDTO schisandraOssAliDTO = SchisandraOssAliDTOConverter.INSTANCE.convertBOToDTO(schisandraOssAliBO);
schisandraOssAliDTO_list.add(schisandraOssAliDTO);
}
return schisandraOssAliDTO_list;
}
public StandardOssClient aliOssClient(String userId) {
CompletableFuture<SchisandraOssAliDTO> futurePrice = CompletableFuture.supplyAsync(() -> {
SchisandraOssAliBO schisandraOssAliBO = schisandraOssAliDomainService.getAliOssConfig(Long.valueOf(userId));
@@ -49,33 +60,6 @@ public class AliOssConfiguration {
aliOssConfig.setAccessKeySecret(ali.getAccessKeySecret());
aliOssConfig.setBasePath(ali.getBasePath());
// if (Boolean.parseBoolean(ali.getOpenAdvancedSetup())) {
// AliOssClientConfig aliOssClientConfig = new AliOssClientConfig();
// aliOssClientConfig.setCnameExcludeList(Arrays.asList(Optional.ofNullable(ali.getCnameExcludeList()).orElse("").split(",")));
// aliOssClientConfig.setConnectionTimeout(ali.getConnectionTimeout());
// aliOssClientConfig.setConnectionTTL(ali.getConnectionTTL());
// aliOssClientConfig.setProtocol(Protocol.valueOf(ali.getProtocol()));
// aliOssClientConfig.setConnectionRequestTimeout(ali.getConnectionRequestTimeout());
// aliOssClientConfig.setMaxConnections(ali.getMaxConnections());
// aliOssClientConfig.setProxyPort(Integer.parseInt(ali.getProxyPort()));
// aliOssClientConfig.setProxyDomain(ali.getProxyDomain());
// aliOssClientConfig.setCrcCheckEnabled(Boolean.parseBoolean(ali.getCrcCheckEnabled()));
// aliOssClientConfig.setTickOffset(ali.getTickOffset());
// aliOssClientConfig.setProxyHost(ali.getProxyHost());
// aliOssClientConfig.setProxyPassword(ali.getProxyPassword());
// aliOssClientConfig.setProxyUsername(ali.getProxyUsername());
// aliOssClientConfig.setVerifySSLEnable(Boolean.parseBoolean(ali.getVerifySSLEnable()));
// aliOssClientConfig.setUseSystemPropertyValues(Boolean.parseBoolean(ali.getUseSystemPropertyValues()));
// aliOssClientConfig.setUseReaper(Boolean.parseBoolean(ali.getUseReaper()));
// aliOssClientConfig.setSupportCname(Boolean.parseBoolean(ali.getSupportCname()));
// aliOssClientConfig.setSocketTimeout(ali.getSocketTimeout());
// aliOssClientConfig.setSldEnabled(Boolean.parseBoolean(ali.getSldEnabled()));
// aliOssClientConfig.setProxyWorkstation(ali.getProxyWorkstation());
// aliOssClientConfig.setIdleConnectionTime(ali.getIdleConnectionTime());
// aliOssClientConfig.setLogConnectionPoolStats(Boolean.parseBoolean(ali.getLogConnectionPoolStats()));
// aliOssConfig.setClientConfig(aliOssClientConfig);
// }
SpringUtil.registerBean(userId, aliOssClient(aliOssConfig));
return aliOssClient(aliOssConfig);
}
@@ -84,11 +68,6 @@ public class AliOssConfiguration {
return new AliOssClient(ossClient(aliOssConfig), aliOssConfig);
}
// public OSS ossClient(AliOssConfig aliOssConfig) {
// return new OSSClientBuilder().build(aliOssConfig.getEndpoint(),
// aliOssConfig.getAccessKeyId(),
// aliOssConfig.getAccessKeySecret());
// }
public OSS ossClient(AliOssConfig aliOssConfig) {
String securityToken = aliOssConfig.getSecurityToken();
AliOssClientConfig clientConfiguration = aliOssConfig.getClientConfig();

View File

@@ -2,12 +2,15 @@ package com.schisandra.oss.application.oss.core.minio;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.extra.spring.SpringUtil;
import com.schisandra.oss.application.convert.SchisandraOssAliDTOConverter;
import com.schisandra.oss.application.convert.SchisandraOssMinioDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssAliDTO;
import com.schisandra.oss.application.dto.SchisandraOssMinioDTO;
import com.schisandra.oss.application.oss.core.StandardOssClient;
import com.schisandra.oss.application.oss.core.minio.model.MinioOssClientConfig;
import com.schisandra.oss.application.oss.core.minio.model.MinioOssConfig;
import com.schisandra.oss.common.entity.Result;
import com.schisandra.oss.domain.bo.SchisandraOssAliBO;
import com.schisandra.oss.domain.bo.SchisandraOssMinioBO;
import com.schisandra.oss.domain.service.SchisandraOssMinioDomainService;
import io.minio.MinioClient;
@@ -16,6 +19,8 @@ import okhttp3.OkHttpClient;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
@@ -34,6 +39,16 @@ public class MinioOssConfiguration {
@Resource
private SchisandraOssMinioDomainService schisandraOssMinioDomainService;
public List<SchisandraOssMinioDTO> selectAll(){
List<SchisandraOssMinioBO> schisandraOssMinioBO_list = schisandraOssMinioDomainService.selectAll();
List<SchisandraOssMinioDTO> schisandraOssAliDTO_list = new ArrayList<>();
for (SchisandraOssMinioBO schisandraOssMinioBO : schisandraOssMinioBO_list ){
SchisandraOssMinioDTO schisandraOssMinioDTO = SchisandraOssMinioDTOConverter.INSTANCE.convertBOToDTO(schisandraOssMinioBO);
schisandraOssAliDTO_list.add(schisandraOssMinioDTO);
}
return schisandraOssAliDTO_list;
}
public Result minioOssClient(String userId) {
try {
SchisandraOssMinioDTO minio = minioOssConfiguration.getSchisandraOssMinioDTO(userId);

View File

@@ -8,18 +8,23 @@ import com.qiniu.storage.Configuration;
import com.qiniu.storage.UploadManager;
import com.qiniu.util.Auth;
import com.schisandra.oss.application.convert.SchisandraOssQiniuDTOConverter;
import com.schisandra.oss.application.convert.SchisandraOssUpDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssQiniuDTO;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.core.StandardOssClient;
import com.schisandra.oss.application.oss.core.qiniu.model.QiNiuOssClientConfig;
import com.schisandra.oss.application.oss.core.qiniu.model.QiNiuOssConfig;
import com.schisandra.oss.application.oss.model.SliceConfig;
import com.schisandra.oss.common.entity.Result;
import com.schisandra.oss.domain.bo.SchisandraOssQiniuBO;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.service.SchisandraOssQiniuDomainService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import java.util.concurrent.CompletableFuture;
@@ -40,6 +45,16 @@ public class QiNiuOssConfiguration {
@Resource
private SchisandraOssQiniuDomainService schisandraOssQiniuDomainService;
public List<SchisandraOssQiniuDTO> selectAll(){
List<SchisandraOssQiniuBO> schisandraOssQiniuBO_list = schisandraOssQiniuDomainService.selectAll();
List<SchisandraOssQiniuDTO> schisandraOssQiniuDTO_list = new ArrayList<>();
for (SchisandraOssQiniuBO schisandraOssQiniuBO : schisandraOssQiniuBO_list ){
SchisandraOssQiniuDTO schisandraOssQiniuDTO = SchisandraOssQiniuDTOConverter.INSTANCE.convertBOToDTO(schisandraOssQiniuBO);
schisandraOssQiniuDTO_list.add(schisandraOssQiniuDTO);
}
return schisandraOssQiniuDTO_list;
}
public SchisandraOssQiniuDTO getSchisandraOssQiNDTO(String userId) {
CompletableFuture<SchisandraOssQiniuDTO> futurePrice = CompletableFuture.supplyAsync(() -> {

View File

@@ -3,16 +3,21 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.extra.spring.SpringUtil;
import cn.hutool.extra.ssh.Sftp;
import com.schisandra.oss.application.convert.SchisandraOssSftpDTOConverter;
import com.schisandra.oss.application.convert.SchisandraOssUpDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssSftpDTO;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.core.StandardOssClient;
import com.schisandra.oss.application.oss.core.sftp.model.SftpOssConfig;
import com.schisandra.oss.common.entity.Result;
import com.schisandra.oss.domain.bo.SchisandraOssSftpBO;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.service.SchisandraOssSftpDomainService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
@@ -28,6 +33,16 @@ public class SftpOssConfiguration {
public static final String DEFAULT_BEAN_NAME = "sftpOssClient";
public List<SchisandraOssSftpDTO> selectAll(){
List<SchisandraOssSftpBO> schisandraOssSftpBO_list = schisandraOssSftpDomainService.selectAll();
List<SchisandraOssSftpDTO> schisandraOssSdtpDTO_list = new ArrayList<>();
for (SchisandraOssSftpBO shisandraOssSftpBO : schisandraOssSftpBO_list ){
SchisandraOssSftpDTO schisandraOssSftpDTO = SchisandraOssSftpDTOConverter.INSTANCE.convertBOToDTO(shisandraOssSftpBO);
schisandraOssSdtpDTO_list.add(schisandraOssSftpDTO);
}
return schisandraOssSdtpDTO_list;
}
public SchisandraOssSftpDTO getSchisandraOssSftpDTO(String userId) {
CompletableFuture<SchisandraOssSftpDTO> futurePrice = CompletableFuture.supplyAsync(() -> {
SchisandraOssSftpBO sftpBO = schisandraOssSftpDomainService.getSftpOssConfig(userId);

View File

@@ -11,18 +11,23 @@ import com.qcloud.cos.auth.COSCredentials;
import com.qcloud.cos.http.HttpProtocol;
import com.qcloud.cos.region.Region;
import com.schisandra.oss.application.convert.SchisandraOssTencentDTOConverter;
import com.schisandra.oss.application.convert.SchisandraOssUpDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssTencentDTO;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.core.StandardOssClient;
import com.schisandra.oss.application.oss.core.tencent.model.TencentOssClientConfig;
import com.schisandra.oss.application.oss.core.tencent.model.TencentOssConfig;
import com.schisandra.oss.common.entity.Result;
import com.schisandra.oss.domain.bo.SchisandraOssTencentBO;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.service.SchisandraOssTencentDomainService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import static com.tencentcloudapi.common.profile.Region.Chengdu;
@@ -41,6 +46,15 @@ public class TencentOssConfiguration {
@Resource
private SchisandraOssTencentDomainService schisandraOssTencentDomainService;
public List<SchisandraOssTencentDTO> selectAll(){
List<SchisandraOssTencentBO> schisandraOssTencentBO_list = schisandraOssTencentDomainService.selectAll();
List<SchisandraOssTencentDTO> schisandraOssTencentDTO_list = new ArrayList<>();
for (SchisandraOssTencentBO schisandraOssTencentBO : schisandraOssTencentBO_list ){
SchisandraOssTencentDTO schisandraOssTencentDTO = SchisandraOssTencentDTOConverter.INSTANCE.convertBOToDTO(schisandraOssTencentBO);
schisandraOssTencentDTO_list.add(schisandraOssTencentDTO);
}
return schisandraOssTencentDTO_list;
}
public Result tencentOssClient(String userId) {
SchisandraOssTencentBO schisandraOssTencentBO = schisandraOssTencentDomainService.getTencentOssConfig(userId);

View File

@@ -3,8 +3,10 @@ package com.schisandra.oss.application.oss.core.up;
import cn.hutool.core.text.CharPool;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.extra.spring.SpringUtil;
import com.schisandra.oss.application.convert.SchisandraOssAliDTOConverter;
import com.schisandra.oss.application.convert.SchisandraOssUcloudDTOConverter;
import com.schisandra.oss.application.convert.SchisandraOssUpDTOConverter;
import com.schisandra.oss.application.dto.SchisandraOssAliDTO;
import com.schisandra.oss.application.dto.SchisandraOssUcloudDTO;
import com.schisandra.oss.application.dto.SchisandraOssUpDTO;
import com.schisandra.oss.application.oss.constant.OssConstant;
@@ -12,6 +14,7 @@ import com.schisandra.oss.application.oss.core.StandardOssClient;
import com.schisandra.oss.application.oss.core.up.model.UpOssClientConfig;
import com.schisandra.oss.application.oss.core.up.model.UpOssConfig;
import com.schisandra.oss.application.oss.model.SliceConfig;
import com.schisandra.oss.domain.bo.SchisandraOssAliBO;
import com.schisandra.oss.domain.bo.SchisandraOssUcloudBO;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.service.SchisandraOssUcloudDomainService;
@@ -29,6 +32,8 @@ import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Optional;
@@ -48,6 +53,17 @@ public class UpOssConfiguration {
@Resource
private SchisandraOssUpDomainService schisandraOssUpDomainService;
public List<SchisandraOssUpDTO> selectAll(){
List<SchisandraOssUpBO> schisandraOssUpBO_list = schisandraOssUpDomainService.selectAll();
List<SchisandraOssUpDTO> schisandraOssUpDTO_list = new ArrayList<>();
for (SchisandraOssUpBO schisandraOssUpBO : schisandraOssUpBO_list ){
SchisandraOssUpDTO schisandraOssUpDTO = SchisandraOssUpDTOConverter.INSTANCE.convertBOToDTO(schisandraOssUpBO);
schisandraOssUpDTO_list.add(schisandraOssUpDTO);
}
return schisandraOssUpDTO_list;
}
public StandardOssClient upOssClient(String userId) {
SchisandraOssUpBO schisandraOssUpBO = schisandraOssUpDomainService.getUpOssConfig(userId);

View File

@@ -44,6 +44,8 @@ public class SchisandraOssTencentBO implements Serializable {
*/
private String secretKey;
private String appId;
/**
* 地域
*/

View File

@@ -2,6 +2,7 @@ package com.schisandra.oss.domain.service;
import com.schisandra.oss.domain.bo.SchisandraOssAliBO;
import java.util.List;
/**
@@ -28,4 +29,6 @@ public interface SchisandraOssAliDomainService {
Boolean delete(SchisandraOssAliBO schisandraOssAliBO);
SchisandraOssAliBO getAliOssConfig(Long userId);
List<SchisandraOssAliBO> selectAll();
}

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.domain.service;
import com.schisandra.oss.domain.bo.SchisandraOssAliBO;
import com.schisandra.oss.domain.bo.SchisandraOssMinioBO;
import java.util.List;
@@ -31,4 +32,6 @@ public interface SchisandraOssMinioDomainService {
SchisandraOssMinioBO getMinioConfig(Long userId);
List<SchisandraOssMinioBO> getAllMinioInfo();
List<SchisandraOssMinioBO> selectAll();
}

View File

@@ -2,6 +2,8 @@ package com.schisandra.oss.domain.service;
import com.schisandra.oss.domain.bo.SchisandraOssQiniuBO;
import java.util.List;
/**
* 七牛云对象存储配置表 领域service
*
@@ -32,4 +34,6 @@ public interface SchisandraOssQiniuDomainService {
* @date: 2024/6/25 14:34
*/
SchisandraOssQiniuBO getQiniuOssConfig(String userId);
List<SchisandraOssQiniuBO> selectAll();
}

View File

@@ -3,6 +3,8 @@ package com.schisandra.oss.domain.service;
import com.schisandra.oss.domain.bo.SchisandraOssQiniuBO;
import com.schisandra.oss.domain.bo.SchisandraOssSftpBO;
import java.util.List;
/**
* sftp存储配置表 领域service
*
@@ -27,4 +29,6 @@ public interface SchisandraOssSftpDomainService {
Boolean delete(SchisandraOssSftpBO schisandraOssSftpBO);
SchisandraOssSftpBO getSftpOssConfig(String userId);
List<SchisandraOssSftpBO> selectAll();
}

View File

@@ -2,6 +2,8 @@ package com.schisandra.oss.domain.service;
import com.schisandra.oss.domain.bo.SchisandraOssTencentBO;
import java.util.List;
/**
* 腾讯云对象存储配置表 领域service
*
@@ -32,4 +34,6 @@ public interface SchisandraOssTencentDomainService {
* @date: 2024/6/25 14:34
*/
SchisandraOssTencentBO getTencentOssConfig(String id);
List<SchisandraOssTencentBO> selectAll();
}

View File

@@ -2,6 +2,8 @@ package com.schisandra.oss.domain.service;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import java.util.List;
/**
* 又拍云对象存储配置表 领域service
*
@@ -26,4 +28,6 @@ public interface SchisandraOssUpDomainService {
Boolean delete(SchisandraOssUpBO schisandraOssUpBO);
SchisandraOssUpBO getUpOssConfig(String userId);
List<SchisandraOssUpBO> selectAll();
}

View File

@@ -8,9 +8,12 @@ import com.schisandra.oss.domain.service.SchisandraOssAliDomainService;
import com.schisandra.oss.infra.basic.entity.SchisandraOssAli;
import com.schisandra.oss.infra.basic.service.SchisandraOssAliService;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
* 领域service实现了
@@ -53,4 +56,16 @@ public class SchisandraOssAliDomainServiceImpl implements SchisandraOssAliDomain
return schisandraOssAliBO;
}
@Override
public List<SchisandraOssAliBO> selectAll(){
List<SchisandraOssAli> list = schisandraOssAliService.selectAll();
List<SchisandraOssAliBO> schisandraOssAliBO_list = new ArrayList<>();
for (SchisandraOssAli schisandraOssAli : list) {
SchisandraOssAliBO schisandraOssAliBO = SchisandraOssAliBOConverter.INSTANCE.convertEntityToBO(schisandraOssAli);
schisandraOssAliBO_list.add(schisandraOssAliBO);
}
return schisandraOssAliBO_list;
}
}

View File

@@ -2,15 +2,19 @@ package com.schisandra.oss.domain.service.impl;
import com.schisandra.oss.common.enums.IsDeletedFlagEnum;
import com.schisandra.oss.domain.bo.SchisandraOssAliBO;
import com.schisandra.oss.domain.bo.SchisandraOssMinioBO;
import com.schisandra.oss.domain.convert.SchisandraOssAliBOConverter;
import com.schisandra.oss.domain.convert.SchisandraOssMinioBOConverter;
import com.schisandra.oss.domain.service.SchisandraOssMinioDomainService;
import com.schisandra.oss.infra.basic.entity.SchisandraOssAli;
import com.schisandra.oss.infra.basic.entity.SchisandraOssMinio;
import com.schisandra.oss.infra.basic.service.SchisandraOssMinioService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
@@ -61,4 +65,15 @@ public class SchisandraOssMinioDomainServiceImpl implements SchisandraOssMinioDo
return schisandraOssMinioBOS;
}
@Override
public List<SchisandraOssMinioBO> selectAll(){
List<SchisandraOssMinio> list = schisandraOssMinioService.selectAll();
List<SchisandraOssMinioBO> schisandraOssMinioBO_list = new ArrayList<>();
for (SchisandraOssMinio schisandraOssMinio : list) {
SchisandraOssMinioBO schisandraOssMinioBO = SchisandraOssMinioBOConverter.INSTANCE.convertEntityToBO(schisandraOssMinio);
schisandraOssMinioBO_list.add(schisandraOssMinioBO);
}
return schisandraOssMinioBO_list;
}
}

View File

@@ -2,17 +2,22 @@ package com.schisandra.oss.domain.service.impl;
import com.schisandra.oss.common.enums.IsDeletedFlagEnum;
import com.schisandra.oss.domain.bo.SchisandraOssJdBO;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.convert.SchisandraOssJdBOConverter;
import com.schisandra.oss.domain.convert.SchisandraOssQiniuBOConverter;
import com.schisandra.oss.domain.bo.SchisandraOssQiniuBO;
import com.schisandra.oss.domain.convert.SchisandraOssUpBOConverter;
import com.schisandra.oss.domain.service.SchisandraOssQiniuDomainService;
import com.schisandra.oss.infra.basic.entity.SchisandraOssJd;
import com.schisandra.oss.infra.basic.entity.SchisandraOssQiniu;
import com.schisandra.oss.infra.basic.entity.SchisandraOssUp;
import com.schisandra.oss.infra.basic.service.SchisandraOssQiniuService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
* 七牛云对象存储配置表 领域service实现了
@@ -55,4 +60,14 @@ public class SchisandraOssQiniuDomainServiceImpl implements SchisandraOssQiniuDo
return schisandraOssQiniuBO;
}
@Override
public List<SchisandraOssQiniuBO> selectAll(){
List<SchisandraOssQiniu> list = schisandraOssQiniuService.selectAll();
List<SchisandraOssQiniuBO> SchisandraOssQiniuBO_list = new ArrayList<>();
for (SchisandraOssQiniu schisandraOssQiniu : list) {
SchisandraOssQiniuBO schisandraOssQiniuBO = SchisandraOssQiniuBOConverter.INSTANCE.convertEntityToBO(schisandraOssQiniu);
SchisandraOssQiniuBO_list.add(schisandraOssQiniuBO);
}
return SchisandraOssQiniuBO_list;
}
}

View File

@@ -2,17 +2,22 @@ package com.schisandra.oss.domain.service.impl;
import com.schisandra.oss.common.enums.IsDeletedFlagEnum;
import com.schisandra.oss.domain.bo.SchisandraOssFtpBO;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.convert.SchisandraOssFtpBOConverter;
import com.schisandra.oss.domain.convert.SchisandraOssSftpBOConverter;
import com.schisandra.oss.domain.bo.SchisandraOssSftpBO;
import com.schisandra.oss.domain.convert.SchisandraOssUpBOConverter;
import com.schisandra.oss.domain.service.SchisandraOssSftpDomainService;
import com.schisandra.oss.infra.basic.entity.SchisandraOssFtp;
import com.schisandra.oss.infra.basic.entity.SchisandraOssSftp;
import com.schisandra.oss.infra.basic.entity.SchisandraOssUp;
import com.schisandra.oss.infra.basic.service.SchisandraOssSftpService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
* sftp存储配置表 领域service实现了
@@ -55,4 +60,14 @@ public class SchisandraOssSftpDomainServiceImpl implements SchisandraOssSftpDoma
return schisandraOssSftpBO;
}
@Override
public List<SchisandraOssSftpBO> selectAll(){
List<SchisandraOssSftp> list = schisandraOssSftpService.selectAll();
List<SchisandraOssSftpBO> SchisandraOssSftpBO_list = new ArrayList<>();
for (SchisandraOssSftp schisandraOssSftp : list) {
SchisandraOssSftpBO schisandraOssSftpBO = SchisandraOssSftpBOConverter.INSTANCE.convertEntityToBO(schisandraOssSftp);
SchisandraOssSftpBO_list.add(schisandraOssSftpBO);
}
return SchisandraOssSftpBO_list;
}
}

View File

@@ -2,17 +2,22 @@ package com.schisandra.oss.domain.service.impl;
import com.schisandra.oss.common.enums.IsDeletedFlagEnum;
import com.schisandra.oss.domain.bo.SchisandraOssQiniuBO;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.convert.SchisandraOssQiniuBOConverter;
import com.schisandra.oss.domain.convert.SchisandraOssTencentBOConverter;
import com.schisandra.oss.domain.bo.SchisandraOssTencentBO;
import com.schisandra.oss.domain.convert.SchisandraOssUpBOConverter;
import com.schisandra.oss.domain.service.SchisandraOssTencentDomainService;
import com.schisandra.oss.infra.basic.entity.SchisandraOssQiniu;
import com.schisandra.oss.infra.basic.entity.SchisandraOssTencent;
import com.schisandra.oss.infra.basic.entity.SchisandraOssUp;
import com.schisandra.oss.infra.basic.service.SchisandraOssTencentService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
* 腾讯云对象存储配置表 领域service实现了
@@ -55,5 +60,14 @@ public class SchisandraOssTencentDomainServiceImpl implements SchisandraOssTence
return schisandraOssTencentBO;
}
@Override
public List<SchisandraOssTencentBO> selectAll(){
List<SchisandraOssTencent> list = schisandraOssTencentService.selectAll();
List<SchisandraOssTencentBO> SchisandraOssTencentBO_list = new ArrayList<>();
for (SchisandraOssTencent schisandraOssTencent : list) {
SchisandraOssTencentBO schisandraOssUpBO = SchisandraOssTencentBOConverter.INSTANCE.convertEntityToBO(schisandraOssTencent);
SchisandraOssTencentBO_list.add(schisandraOssUpBO);
}
return SchisandraOssTencentBO_list;
}
}

View File

@@ -1,15 +1,20 @@
package com.schisandra.oss.domain.service.impl;
import com.schisandra.oss.common.enums.IsDeletedFlagEnum;
import com.schisandra.oss.domain.bo.SchisandraOssMinioBO;
import com.schisandra.oss.domain.convert.SchisandraOssMinioBOConverter;
import com.schisandra.oss.domain.convert.SchisandraOssUpBOConverter;
import com.schisandra.oss.domain.bo.SchisandraOssUpBO;
import com.schisandra.oss.domain.service.SchisandraOssUpDomainService;
import com.schisandra.oss.infra.basic.entity.SchisandraOssMinio;
import com.schisandra.oss.infra.basic.entity.SchisandraOssUp;
import com.schisandra.oss.infra.basic.service.SchisandraOssUpService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
/**
* 又拍云对象存储配置表 领域service实现了
@@ -51,4 +56,15 @@ public class SchisandraOssUpDomainServiceImpl implements SchisandraOssUpDomainSe
return SchisandraOssUpBOConverter.INSTANCE.convertEntityToBO(schisandraOssUp);
}
@Override
public List<SchisandraOssUpBO> selectAll(){
List<SchisandraOssUp> list = schisandraOssUpService.selectAll();
List<SchisandraOssUpBO> SchisandraOssUpBO_list = new ArrayList<>();
for (SchisandraOssUp schisandraOssUp : list) {
SchisandraOssUpBO schisandraOssUpBO = SchisandraOssUpBOConverter.INSTANCE.convertEntityToBO(schisandraOssUp);
SchisandraOssUpBO_list.add(schisandraOssUpBO);
}
return SchisandraOssUpBO_list;
}
}

View File

@@ -1,5 +1,6 @@
package com.schisandra.oss.infra.basic.entity;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.mybatisflex.annotation.Column;
import com.mybatisflex.annotation.Id;
import com.mybatisflex.annotation.KeyType;

View File

@@ -59,6 +59,9 @@ public class SchisandraOssTencent implements Serializable {
/**
* 地域
*/
@Column("app_id")
private String appId;
@Column("region")
private String region;

View File

@@ -2,6 +2,8 @@ package com.schisandra.oss.infra.basic.service;
import com.schisandra.oss.infra.basic.entity.SchisandraOssAli;
import java.util.List;
/**
* 表服务接口
@@ -45,4 +47,6 @@ public interface SchisandraOssAliService {
SchisandraOssAli getAliOssConfig(Long userId);
List<SchisandraOssAli> selectAll();
}

View File

@@ -50,4 +50,6 @@ public interface SchisandraOssMinioService {
SchisandraOssMinio getMinioConfig(Long userId);
List<SchisandraOssMinio> getAllMinioInfo();
List<SchisandraOssMinio> selectAll();
}

View File

@@ -1,6 +1,9 @@
package com.schisandra.oss.infra.basic.service;
import com.schisandra.oss.infra.basic.entity.SchisandraOssQiniu;
import com.schisandra.oss.infra.basic.entity.SchisandraOssTencent;
import java.util.List;
/**
* 七牛云对象存储配置表 表服务接口
@@ -51,4 +54,6 @@ public interface SchisandraOssQiniuService {
*/
SchisandraOssQiniu getQiniuOssConfig(String userId);
List<SchisandraOssQiniu> selectAll();
}

View File

@@ -3,6 +3,8 @@ package com.schisandra.oss.infra.basic.service;
import com.schisandra.oss.infra.basic.entity.SchisandraOssFtp;
import com.schisandra.oss.infra.basic.entity.SchisandraOssSftp;
import java.util.List;
/**
* sftp存储配置表 表服务接口
*
@@ -44,4 +46,6 @@ public interface SchisandraOssSftpService {
boolean deleteById(Long id);
SchisandraOssSftp getSftpOssConfig(String userId);
List<SchisandraOssSftp> selectAll();
}

View File

@@ -2,6 +2,8 @@ package com.schisandra.oss.infra.basic.service;
import com.schisandra.oss.infra.basic.entity.SchisandraOssTencent;
import java.util.List;
/**
* 腾讯云对象存储配置表 表服务接口
*
@@ -51,4 +53,5 @@ public interface SchisandraOssTencentService {
*/
SchisandraOssTencent getTencentOssConfig(String userId);
List<SchisandraOssTencent> selectAll();
}

View File

@@ -2,6 +2,8 @@ package com.schisandra.oss.infra.basic.service;
import com.schisandra.oss.infra.basic.entity.SchisandraOssUp;
import java.util.List;
/**
* 又拍云对象存储配置表 表服务接口
*
@@ -43,4 +45,6 @@ public interface SchisandraOssUpService {
boolean deleteById(Long id);
SchisandraOssUp getUpOssConfig(String userId);
List<SchisandraOssUp> selectAll();
}

View File

@@ -7,6 +7,7 @@ import com.schisandra.oss.infra.basic.service.SchisandraOssAliService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
/**
* 表服务实现类
@@ -20,6 +21,14 @@ public class SchisandraOssAliServiceImpl implements SchisandraOssAliService {
@Resource
private SchisandraOssAliDao schisandraOssAliDao;
/**
* 获取数据库所有数据
* @return
*/
@Override
public List<SchisandraOssAli> selectAll(){return schisandraOssAliDao.selectAll();}
/**
* 通过ID查询单条数据
*

View File

@@ -9,6 +9,8 @@ import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
@@ -82,4 +84,7 @@ public class SchisandraOssMinioServiceImpl implements SchisandraOssMinioService
return schisandraOssMinioDao.selectAll();
}
@Override
public List<SchisandraOssMinio> selectAll(){return schisandraOssMinioDao.selectAll();}
}

View File

@@ -7,6 +7,7 @@ import com.schisandra.oss.infra.basic.service.SchisandraOssQiniuService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
/**
* 七牛云对象存储配置表 表服务实现类
@@ -67,8 +68,8 @@ public class SchisandraOssQiniuServiceImpl implements SchisandraOssQiniuService
@Override
public SchisandraOssQiniu getQiniuOssConfig(String userId) {
return schisandraOssQiniuDao.selectOneByCondition(SchisandraOssQiniuTableDef.SCHISANDRA_OSS_QINIU.USER_ID.eq(userId));
}
@Override
public List<SchisandraOssQiniu> selectAll() {return this.schisandraOssQiniuDao.selectAll();}
}

View File

@@ -9,6 +9,7 @@ import com.schisandra.oss.infra.basic.service.SchisandraOssSftpService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
/**
* sftp存储配置表 表服务实现类
@@ -70,4 +71,7 @@ public class SchisandraOssSftpServiceImpl implements SchisandraOssSftpService {
public SchisandraOssSftp getSftpOssConfig(String userId) {
return schisandraOssSftpDao.selectOneByCondition(SchisandraOssSftpTableDef.SCHISANDRA_OSS_SFTP.USER_ID.eq(userId));
}
@Override
public List<SchisandraOssSftp> selectAll() {return schisandraOssSftpDao.selectAll();}
}

View File

@@ -8,6 +8,7 @@ import com.schisandra.oss.infra.basic.service.SchisandraOssTencentService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
/**
* 腾讯云对象存储配置表 表服务实现类
@@ -70,5 +71,6 @@ public class SchisandraOssTencentServiceImpl implements SchisandraOssTencentServ
return schisandraOssTencentDao.selectOneByCondition(SchisandraOssTencentTableDef.SCHISANDRA_OSS_TENCENT.USER_ID.eq(userId));
}
@Override
public List<SchisandraOssTencent> selectAll(){return this.schisandraOssTencentDao.selectAll();}
}

View File

@@ -7,6 +7,8 @@ import com.schisandra.oss.infra.basic.service.SchisandraOssUpService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
/**
* 又拍云对象存储配置表 表服务实现类
@@ -72,4 +74,8 @@ public class SchisandraOssUpServiceImpl implements SchisandraOssUpService {
}
@Override
public List<SchisandraOssUp> selectAll() {return schisandraOssUpDao.selectAll();}
}