update 优化 删除不建议继续使用的接口
This commit is contained in:
-8
@@ -12,14 +12,6 @@ import java.util.List;
|
|||||||
*/
|
*/
|
||||||
public interface RemoteFileService {
|
public interface RemoteFileService {
|
||||||
|
|
||||||
/**
|
|
||||||
* 上传文件
|
|
||||||
*
|
|
||||||
* @param file 文件信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
RemoteFile upload(String name, String originalFilename, String contentType, byte[] file) throws ServiceException;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 通过ossId查询对应的url
|
* 通过ossId查询对应的url
|
||||||
*
|
*
|
||||||
|
|||||||
-12
@@ -14,18 +14,6 @@ import java.util.List;
|
|||||||
@Slf4j
|
@Slf4j
|
||||||
public class RemoteFileServiceMock implements RemoteFileService {
|
public class RemoteFileServiceMock implements RemoteFileService {
|
||||||
|
|
||||||
/**
|
|
||||||
* 上传文件
|
|
||||||
*
|
|
||||||
* @param file 文件信息
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public RemoteFile upload(String name, String originalFilename, String contentType, byte[] file) {
|
|
||||||
log.warn("服务调用异常 -> 降级处理");
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 通过ossId查询对应的url
|
* 通过ossId查询对应的url
|
||||||
*
|
*
|
||||||
|
|||||||
-37
@@ -35,43 +35,6 @@ public class RemoteFileServiceImpl implements RemoteFileService {
|
|||||||
|
|
||||||
private final ISysOssService sysOssService;
|
private final ISysOssService sysOssService;
|
||||||
|
|
||||||
/**
|
|
||||||
* 文件上传请求
|
|
||||||
*/
|
|
||||||
@Transactional(rollbackFor = Exception.class)
|
|
||||||
@Override
|
|
||||||
public RemoteFile upload(String name, String originalFilename, String contentType, byte[] file) throws ServiceException {
|
|
||||||
try {
|
|
||||||
String suffix = StringUtils.substring(originalFilename, originalFilename.lastIndexOf("."), originalFilename.length());
|
|
||||||
OssClient instance = OssFactory.instance();
|
|
||||||
String pathKey = instance.buildPathKey(originalFilename);
|
|
||||||
PutObjectResult result = instance.upload(pathKey, file);
|
|
||||||
// 保存文件信息
|
|
||||||
SysOssBo oss = new SysOssBo();
|
|
||||||
oss.setUrl(result.url());
|
|
||||||
oss.setFileSuffix(suffix);
|
|
||||||
oss.setFileName(result.key());
|
|
||||||
oss.setOriginalName(originalFilename);
|
|
||||||
oss.setService(instance.clientId());
|
|
||||||
SysOssExt ext1 = new SysOssExt();
|
|
||||||
ext1.setFileSize((long) file.length);
|
|
||||||
String extStr = JsonUtils.toJsonString(ext1);
|
|
||||||
oss.setExt1(extStr);
|
|
||||||
sysOssService.insertByBo(oss);
|
|
||||||
RemoteFile sysFile = new RemoteFile();
|
|
||||||
sysFile.setOssId(oss.getOssId());
|
|
||||||
sysFile.setName(result.key());
|
|
||||||
sysFile.setUrl(result.url());
|
|
||||||
sysFile.setOriginalName(originalFilename);
|
|
||||||
sysFile.setFileSuffix(suffix);
|
|
||||||
sysFile.setExt1(extStr);
|
|
||||||
return sysFile;
|
|
||||||
} catch (Exception e) {
|
|
||||||
log.error("上传文件失败", e);
|
|
||||||
throw new ServiceException("上传文件失败");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 通过ossId查询对应的url
|
* 通过ossId查询对应的url
|
||||||
*
|
*
|
||||||
|
|||||||
Reference in New Issue
Block a user