文件上传删除，下载功能
/**
* @description: 样品制作单上传附件到存储桶，返回url给前端
* @param: [file]
* @return: com.bsn.common.core.domain.AjaxResult
* @author 沈三靖
* @date: 2024/9/19 16:44
*/
@ApiOperation(value = "上传附件", notes = "上传附件（图片）", httpMethod = "POST")
@Log(title = "上传附件", businessType = BusinessType.UPDATE)
@PostMapping("/imgUrl")
public AjaxResult avatar(@RequestParam("imgUrl") MultipartFile file) throws IOException {
if (!file.isEmpty()) {
String avatar = FileUploadUtils.uploadMinio(file);
if (avatar != null&&avatar.length()>0) {
AjaxResult ajax = AjaxResult.success();
ajax.put("imgUrl", avatar);
return ajax;
}
}
return AjaxResult.error("上传图片异常，请联系管理员");
}
/**
* @description: 样品制作单根据制作单id修改上传附件到存储桶，返回url给前端
* @param: [file]
* @return: com.bsn.common.core.domain.AjaxResult
* @author 沈三靖
* @date: 2024/9/19 16:44
*/
@ApiOperation(value = "根据样品制作单id修改上传附件", notes = "根据样品制作单id修改上传附件（图片）", httpMethod = "POST")
@Log(title = "根据样品制作单id修改上传附件", businessType = BusinessType.UPDATE)
@PostMapping("/updateImgUrl")
public AjaxResult updateavatar(@RequestParam("imgUrl") MultipartFile file,@RequestParam("prototypeMakeId") String prototypeMakeId) throws IOException {
Long aLong=0l;
if (!prototypeMakeId.isEmpty()&&!prototypeMakeId.equals("")){
aLong = Long.valueOf(prototypeMakeId);
}
if (!file.isEmpty()) {
String avatar = FileUploadUtils.uploadMinio(file);
if (proPrototypeMakeService.updatImageUrl(aLong,avatar)) {
AjaxResult ajax = AjaxResult.success();
ajax.put("imgUrl", avatar);
return ajax;
}
}else{
if (proPrototypeMakeService.updatImageUrl(aLong,"")) {
AjaxResult ajax = AjaxResult.success();
ajax.put("imgUrl", "");
return ajax;
}
}
return AjaxResult.error("上传图片异常，请联系管理员");
}
@ApiOperation(value = "下载附件", notes = "下载附件（图片）", httpMethod = "GET")
@Log(title = "下载附件", businessType = BusinessType.UPDATE)
@GetMapping("/download")
public void downloadAvatar(@RequestParam("imgUrl") String imgUrl,HttpServletResponse response) throws IOException {
// 创建URL对象
URL url = new URL(imgUrl);
//打开链接
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
// 设置应用程序要从网络连接读取数据
conn.setDoInput(true);
//设置请求方式为"GET"
conn.setRequestMethod("GET");
// 获取 Content-Type
String contentType = conn.getContentType();
response.setContentType(contentType);
// 根据 URL 获取文件名
String fileName = imgUrl.substring(imgUrl.lastIndexOf('/') + 1);
response.setHeader("Content-Disposition", "attachment; filename=\"" + fileName + "\"");
InputStream inputStream = conn.getInputStream();
OutputStream outputStream = response.getOutputStream();
byte[] buffer = new byte[1024];
int length;
while ((length = inputStream.read(buffer)) > 0) {
outputStream.write(buffer, 0, length);
}
}
文件上传工具类
/**
* 文件上传工具类
*/
public class FileUploadUtils {
/**
* 默认大小 50M
*/
public static final long DEFAULT_MAX_SIZE = 50 * 1024 * 1024;
/**
* 默认的文件名最大长度 100
*/
public static final int DEFAULT_FILE_NAME_LENGTH = 100;
/**
* 默认上传的地址
*/
private static String defaultBaseDir = BsnEpConfig.getProfile();
public static void setDefaultBaseDir(String defaultBaseDir) {
FileUploadUtils.defaultBaseDir = defaultBaseDir;
}
public static String getDefaultBaseDir() {
return defaultBaseDir;
}
/**
* Minio默认上传的地址
*/
private static String bucketName = MinioConfig.getBucketName();
public static String getBucketName() {
return bucketName;
}
/**
* 以默认配置进行文件上传
*
* @param file 上传的文件
* @return 文件名称
* @throws Exception
*/
public static final String upload(MultipartFile file) throws IOException {
try {
return upload(getDefaultBaseDir(), file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
} catch (Exception e) {
throw new IOException(e.getMessage(), e);
}
}
/**
* 根据文件路径上传
*
* @param baseDir 相对应用的基目录
* @param file 上传的文件
* @return 文件名称
* @throws IOException
*/
public static final String upload(String baseDir, MultipartFile file) throws IOException {
try {
return upload(baseDir, file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
} catch (Exception e) {
throw new IOException(e.getMessage(), e);
}
}
/**
* 文件上传
*
* @param baseDir 相对应用的基目录
* @param file 上传的文件
* @param allowedExtension 上传文件类型
* @return 返回上传成功的文件名
* @throws FileSizeLimitExceededException 如果超出最大大小
* @throws FileNameLengthLimitExceededException 文件名太长
* @throws IOException 比如读写文件出错时
* @throws InvalidExtensionException 文件校验异常
*/
public static final String upload(String baseDir, MultipartFile file, String[] allowedExtension)
throws FileSizeLimitExceededException, IOException, FileNameLengthLimitExceededException,
InvalidExtensionException {
int fileNamelength = Objects.requireNonNull(file.getOriginalFilename()).length();
if (fileNamelength > FileUploadUtils.DEFAULT_FILE_NAME_LENGTH) {
throw new FileNameLengthLimitExceededException(FileUploadUtils.DEFAULT_FILE_NAME_LENGTH);
}
assertAllowed(file, allowedExtension);
String fileName = extractFilename(file);
String absPath = getAbsoluteFile(baseDir, fileName).getAbsolutePath();
file.transferTo(Paths.get(absPath));
return getPathFileName(baseDir, fileName);
}
/**
* 以默认BucketName配置上传到Minio服务器
*
* @param file 上传的文件
* @return 文件名称
* @throws Exception
*/
public static final String uploadMinio(MultipartFile file) throws IOException {
try {
return uploadMinino(getBucketName(), file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
} catch (Exception e) {
throw new IOException(e.getMessage(), e);
}
}
/**
* 自定义bucketName配置上传到Minio服务器
*
* @param file 上传的文件
* @return 文件名称
* @throws Exception
*/
public static final String uploadMinio(MultipartFile file, String bucketName) throws IOException {
try {
return uploadMinino(bucketName, file, MimeTypeUtils.DEFAULT_ALLOWED_EXTENSION);
} catch (Exception e) {
throw new IOException(e.getMessage(), e);
}
}
private static final String uploadMinino(String bucketName, MultipartFile file, String[] allowedExtension)
throws FileSizeLimitExceededException, IOException, FileNameLengthLimitExceededException,
InvalidExtensionException {
int fileNamelength = file.getOriginalFilename().length();
if (fileNamelength > FileUploadUtils.DEFAULT_FILE_NAME_LENGTH) {
throw new FileNameLengthLimitExceededException(FileUploadUtils.DEFAULT_FILE_NAME_LENGTH);
}
assertAllowed(file, allowedExtension);
try {
String fileName = extractFilename2(file);
String pathFileName = MinioUtil.uploadFile(bucketName, fileName, file);
return pathFileName;
} catch (Exception e) {
throw new IOException(e.getMessage(), e);
}
}
/**
* 编码文件名
*/
public static final String extractFilename(MultipartFile file) {
return StringUtils.format("{}/{}_{}.{}", DateUtils.datePath(),
FilenameUtils.getBaseName(file.getOriginalFilename()), Seq.getId(Seq.uploadSeqType), getExtension(file));
}
/**
* 编码文件名
*/
public static String extractFilename2(MultipartFile file) {
final String suffix = FileUtil.getSuffix(file.getOriginalFilename());
final String s = StrUtil.emptyToDefault(suffix, MimeTypeUtils.getExtension(StrUtil.nullToDefault(file.getContentType(), MimeTypeUtils.IMAGE_PNG)));
String newFile = DateTime.now().toString(DatePattern.PURE_DATETIME_MS_PATTERN + RandomUtil.randomNumbers(6)) + StrUtil.DOT + s;
return StringUtils.format("{}/{}", DateUtils.datePath(), newFile);
}
public static final File getAbsoluteFile(String uploadDir, String fileName) throws IOException {
File desc = new File(uploadDir + File.separator + fileName);
if (!desc.exists()) {
if (!desc.getParentFile().exists()) {
desc.getParentFile().mkdirs();
}
}
return desc;
}
public static final String getPathFileName(String uploadDir, String fileName) throws IOException {
int dirLastIndex = BsnEpConfig.getProfile().length() + 1;
String currentDir = StringUtils.substring(uploadDir, dirLastIndex);
return Constants.RESOURCE_PREFIX + "/" + currentDir + "/" + fileName;
}
/**
* 文件大小校验
*
* @param file 上传的文件
* @return
* @throws FileSizeLimitExceededException 如果超出最大大小
* @throws InvalidExtensionException
*/
public static final void assertAllowed(MultipartFile file, String[] allowedExtension)
throws FileSizeLimitExceededException, InvalidExtensionException {
long size = file.getSize();
if (size > DEFAULT_MAX_SIZE) {
throw new FileSizeLimitExceededException(DEFAULT_MAX_SIZE / 1024 / 1024);
}
String fileName = file.getOriginalFilename();
String extension = getExtension(file);
if (allowedExtension != null && !isAllowedExtension(extension, allowedExtension)) {
if (allowedExtension == MimeTypeUtils.IMAGE_EXTENSION) {
throw new InvalidExtensionException.InvalidImageExtensionException(allowedExtension, extension,
fileName);
} else if (allowedExtension == MimeTypeUtils.FLASH_EXTENSION) {
throw new InvalidExtensionException.InvalidFlashExtensionException(allowedExtension, extension,
fileName);
} else if (allowedExtension == MimeTypeUtils.MEDIA_EXTENSION) {
throw new InvalidExtensionException.InvalidMediaExtensionException(allowedExtension, extension,
fileName);
} else if (allowedExtension == MimeTypeUtils.VIDEO_EXTENSION) {
throw new InvalidExtensionException.InvalidVideoExtensionException(allowedExtension, extension,
fileName);
} else {
throw new InvalidExtensionException(allowedExtension, extension, fileName);
}
}
}
/**
* 判断MIME类型是否是允许的MIME类型
*
* @param extension
* @param allowedExtension
* @return
*/
public static final boolean isAllowedExtension(String extension, String[] allowedExtension) {
for (String str : allowedExtension) {
if (str.equalsIgnoreCase(extension)) {
return true;
}
}
return false;
}
/**
* 获取文件名的后缀
*
* @param file 表单文件
* @return 后缀名
*/
public static final String getExtension(MultipartFile file) {
String extension = FilenameUtils.getExtension(file.getOriginalFilename());
if (StringUtils.isEmpty(extension)) {
extension = MimeTypeUtils.getExtension(Objects.requireNonNull(file.getContentType()));
}
return extension;
}
}
![[PTA]7-1 谁管谁叫爹](https://i-blog.csdnimg.cn/direct/27800ed6adb8401b92499f18e4199efc.png)
