若依阿里云OSS对象储存文件附件上传功能开发

[复制链接]
admin 发表于 5 天前 | 显示全部楼层 |阅读模式
若依阿里云OSS对象储存文件附件上传功能开发

游客,如果您要查看本帖隐藏内容请回复


若依 common/upload改造后的代码如下:
  1. package com.jinhei.web.controller.common;

  2. import java.time.LocalDate;
  3. import java.time.format.DateTimeFormatter;
  4. import java.util.ArrayList;
  5. import java.util.List;
  6. import jakarta.servlet.http.HttpServletRequest;
  7. import jakarta.servlet.http.HttpServletResponse;
  8. import org.dromara.x.file.storage.core.FileInfo;
  9. import org.dromara.x.file.storage.core.FileStorageService;
  10. import org.slf4j.Logger;
  11. import org.slf4j.LoggerFactory;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.http.MediaType;
  14. import org.springframework.web.bind.annotation.GetMapping;
  15. import org.springframework.web.bind.annotation.PostMapping;
  16. import org.springframework.web.bind.annotation.RequestMapping;
  17. import org.springframework.web.bind.annotation.RestController;
  18. import org.springframework.web.multipart.MultipartFile;
  19. import com.jinhei.common.config.RuoYiConfig;
  20. import com.jinhei.common.core.domain.AjaxResult;
  21. import com.jinhei.common.utils.StringUtils;
  22. import com.jinhei.common.utils.file.FileUploadUtils;
  23. import com.jinhei.common.utils.file.FileUtils;
  24. import com.jinhei.framework.config.ServerConfig;

  25. /**
  26. * 通用请求处理
  27. *
  28. * @author ruoyi
  29. */
  30. @RestController
  31. @RequestMapping("/common")
  32. public class CommonController
  33. {
  34.     private static final Logger log = LoggerFactory.getLogger(CommonController.class);

  35.     @Autowired
  36.     private ServerConfig serverConfig;
  37.     @Autowired
  38.     private FileStorageService fileStorageService;//注入实列

  39.     private static final String FILE_DELIMETER = ",";

  40.     /**
  41.      * 通用下载请求
  42.      *
  43.      * @param fileName 文件名称
  44.      * @param delete 是否删除
  45.      */
  46.     @GetMapping("/download")
  47.     public void fileDownload(String fileName, Boolean delete, HttpServletResponse response, HttpServletRequest request)
  48.     {
  49.         try
  50.         {
  51.             if (!FileUtils.checkAllowDownload(fileName))
  52.             {
  53.                 throw new Exception(StringUtils.format("文件名称({})非法,不允许下载。 ", fileName));
  54.             }
  55.             String realFileName = System.currentTimeMillis() + fileName.substring(fileName.indexOf("_") + 1);
  56.             String filePath = RuoYiConfig.getDownloadPath() + fileName;

  57.             response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
  58.             FileUtils.setAttachmentResponseHeader(response, realFileName);
  59.             FileUtils.writeBytes(filePath, response.getOutputStream());
  60.             if (delete)
  61.             {
  62.                 FileUtils.deleteFile(filePath);
  63.             }
  64.         }
  65.         catch (Exception e)
  66.         {
  67.             log.error("下载文件失败", e);
  68.         }
  69.     }

  70.     /**
  71.      * 通用上传请求(单个)
  72.      */
  73.     @PostMapping("/upload")
  74.     public AjaxResult uploadFile(MultipartFile file) throws Exception
  75.     {
  76.         try
  77.         {
  78.             // 上传文件路径
  79. //            String filePath = RuoYiConfig.getUploadPath();
  80. //            // 上传并返回新文件名称
  81. //            String fileName = FileUploadUtils.upload(filePath, file);
  82. //            String url = serverConfig.getUrl() + fileName;
  83.             //指定OSS保存文件路径 2025/05/05
  84.             String objectName = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd")) + "/";
  85.             // 上传图片,返回文件信息
  86.             FileInfo fileInfo = fileStorageService.of(file).setPath(objectName).upload();
  87.             AjaxResult ajax = AjaxResult.success();
  88.             ajax.put("url", fileInfo.getUrl());
  89.             ajax.put("fileName", fileInfo.getUrl());
  90.             ajax.put("newFileName", fileInfo.getUrl());
  91.             ajax.put("originalFilename", file.getOriginalFilename());
  92.             return ajax;
  93.         }
  94.         catch (Exception e)
  95.         {
  96.             return AjaxResult.error(e.getMessage());
  97.         }
  98.     }

  99.     /**
  100.      * 通用上传请求(多个)
  101.      */
  102.     @PostMapping("/uploads")
  103.     public AjaxResult uploadFiles(List<MultipartFile> files) throws Exception
  104.     {
  105.         try
  106.         {
  107.             // 上传文件路径
  108.             String filePath = RuoYiConfig.getUploadPath();
  109.             List<String> urls = new ArrayList<String>();
  110.             List<String> fileNames = new ArrayList<String>();
  111.             List<String> newFileNames = new ArrayList<String>();
  112.             List<String> originalFilenames = new ArrayList<String>();
  113.             for (MultipartFile file : files)
  114.             {
  115.                 // 上传并返回新文件名称
  116.                 String fileName = FileUploadUtils.upload(filePath, file);
  117.                 String url = serverConfig.getUrl() + fileName;
  118.                 urls.add(url);
  119.                 fileNames.add(fileName);
  120.                 newFileNames.add(FileUtils.getName(fileName));
  121.                 originalFilenames.add(file.getOriginalFilename());
  122.             }
  123.             AjaxResult ajax = AjaxResult.success();
  124.             ajax.put("urls", StringUtils.join(urls, FILE_DELIMETER));
  125.             ajax.put("fileNames", StringUtils.join(fileNames, FILE_DELIMETER));
  126.             ajax.put("newFileNames", StringUtils.join(newFileNames, FILE_DELIMETER));
  127.             ajax.put("originalFilenames", StringUtils.join(originalFilenames, FILE_DELIMETER));
  128.             return ajax;
  129.         }
  130.         catch (Exception e)
  131.         {
  132.             return AjaxResult.error(e.getMessage());
  133.         }
  134.     }

  135.     /**
  136.      * 本地资源通用下载
  137.      */
  138.     @GetMapping("/download/resource")
  139.     public void resourceDownload(String resource, HttpServletRequest request, HttpServletResponse response)
  140.             throws Exception
  141.     {
  142.         try
  143.         {
  144.             if (!FileUtils.checkAllowDownload(resource))
  145.             {
  146.                 throw new Exception(StringUtils.format("资源文件({})非法,不允许下载。 ", resource));
  147.             }
  148.             // 本地资源路径
  149.             String localPath = RuoYiConfig.getProfile();
  150.             // 数据库资源地址
  151.             String downloadPath = localPath + FileUtils.stripPrefix(resource);
  152.             // 下载名称
  153.             String downloadName = StringUtils.substringAfterLast(downloadPath, "/");
  154.             response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE);
  155.             FileUtils.setAttachmentResponseHeader(response, downloadName);
  156.             FileUtils.writeBytes(downloadPath, response.getOutputStream());
  157.         }
  158.         catch (Exception e)
  159.         {
  160.             log.error("下载文件失败", e);
  161.         }
  162.     }
  163. }
复制代码






网站建设,公众号小程序开发,多商户单商户小程序制作,高端系统定制开发,App软件开发联系我们【手机/微信:17817817816
微信扫码

网站建设,公众号小程序开发,商城小程序,系统定制开发,App软件开发等

粤ICP备2024252464号

在本版发帖
微信扫码
QQ客服返回顶部
快速回复 返回顶部 返回列表