SysOssController.java 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. package com.ruoyi.web.controller.system;
  2. import cn.hutool.core.convert.Convert;
  3. import cn.hutool.http.HttpUtil;
  4. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  5. import com.ruoyi.common.annotation.Log;
  6. import com.ruoyi.common.annotation.RepeatSubmit;
  7. import com.ruoyi.common.core.controller.BaseController;
  8. import com.ruoyi.common.core.domain.AjaxResult;
  9. import com.ruoyi.common.core.page.TableDataInfo;
  10. import com.ruoyi.common.enums.BusinessType;
  11. import com.ruoyi.common.exception.CustomException;
  12. import com.ruoyi.common.utils.JsonUtils;
  13. import com.ruoyi.common.utils.file.FileUtils;
  14. import com.ruoyi.oss.constant.CloudConstant;
  15. import com.ruoyi.system.domain.SysConfig;
  16. import com.ruoyi.system.domain.SysOss;
  17. import com.ruoyi.system.domain.bo.SysOssBo;
  18. import com.ruoyi.system.domain.vo.SysOssVo;
  19. import com.ruoyi.system.service.ISysConfigService;
  20. import com.ruoyi.system.service.ISysOssService;
  21. import io.swagger.annotations.Api;
  22. import io.swagger.annotations.ApiImplicitParam;
  23. import io.swagger.annotations.ApiImplicitParams;
  24. import io.swagger.annotations.ApiOperation;
  25. import lombok.RequiredArgsConstructor;
  26. import org.springframework.beans.factory.annotation.Autowired;
  27. import org.springframework.http.MediaType;
  28. import org.springframework.security.access.prepost.PreAuthorize;
  29. import org.springframework.validation.annotation.Validated;
  30. import org.springframework.web.bind.annotation.*;
  31. import org.springframework.web.multipart.MultipartFile;
  32. import javax.servlet.http.HttpServletResponse;
  33. import javax.validation.constraints.NotEmpty;
  34. import java.io.IOException;
  35. import java.net.URLEncoder;
  36. import java.nio.charset.StandardCharsets;
  37. import java.util.Arrays;
  38. import java.util.HashMap;
  39. import java.util.Map;
  40. /**
  41. * 文件上传 控制层
  42. *
  43. * @author Lion Li
  44. */
  45. @Validated
  46. @Api(value = "OSS云存储控制器", tags = {"OSS云存储管理"})
  47. @RequiredArgsConstructor(onConstructor_ = @Autowired)
  48. @RestController
  49. @RequestMapping("/system/oss")
  50. public class SysOssController extends BaseController {
  51. private final ISysOssService iSysOssService;
  52. private final ISysConfigService iSysConfigService;
  53. /**
  54. * 查询OSS云存储列表
  55. */
  56. @ApiOperation("查询OSS云存储列表")
  57. @PreAuthorize("@ss.hasPermi('system:oss:list')")
  58. @GetMapping("/list")
  59. public TableDataInfo<SysOssVo> list(@Validated SysOssBo bo) {
  60. return iSysOssService.queryPageList(bo);
  61. }
  62. /**
  63. * 上传OSS云存储
  64. */
  65. @ApiOperation("上传OSS云存储")
  66. @ApiImplicitParams({
  67. @ApiImplicitParam(name = "file", value = "文件", dataType = "java.io.File", required = true),
  68. })
  69. @PreAuthorize("@ss.hasPermi('system:oss:upload')")
  70. @Log(title = "OSS云存储", businessType = BusinessType.INSERT)
  71. @RepeatSubmit
  72. @PostMapping("/upload")
  73. public AjaxResult<Map<String, String>> upload(@RequestPart("file") MultipartFile file) {
  74. if (file.isEmpty()) {
  75. throw new CustomException("上传文件不能为空");
  76. }
  77. SysOss oss = iSysOssService.upload(file);
  78. Map<String, String> map = new HashMap<>(2);
  79. map.put("url", oss.getUrl());
  80. map.put("fileName", oss.getFileName());
  81. return AjaxResult.success(map);
  82. }
  83. @ApiOperation("下载OSS云存储")
  84. @PreAuthorize("@ss.hasPermi('system:oss:download')")
  85. @GetMapping("/download/{ossId}")
  86. public void download(@PathVariable Long ossId, HttpServletResponse response) throws IOException {
  87. SysOss sysOss = iSysOssService.getById(ossId);
  88. if (sysOss == null) {
  89. throw new CustomException("文件数据不存在!");
  90. }
  91. response.reset();
  92. response.addHeader("Access-Control-Allow-Origin", "*");
  93. response.addHeader("Access-Control-Expose-Headers", "Content-Disposition");
  94. FileUtils.setAttachmentResponseHeader(response, URLEncoder.encode(sysOss.getOriginalName(), StandardCharsets.UTF_8.toString()));
  95. response.setContentType(MediaType.APPLICATION_OCTET_STREAM_VALUE + "; charset=UTF-8");
  96. long data = HttpUtil.download(sysOss.getUrl(), response.getOutputStream(), false);
  97. response.setContentLength(Convert.toInt(data));
  98. }
  99. /**
  100. * 删除OSS云存储
  101. */
  102. @ApiOperation("删除OSS云存储")
  103. @PreAuthorize("@ss.hasPermi('system:oss:remove')")
  104. @Log(title = "OSS云存储" , businessType = BusinessType.DELETE)
  105. @DeleteMapping("/{ossIds}")
  106. public AjaxResult<Void> remove(@NotEmpty(message = "主键不能为空")
  107. @PathVariable Long[] ossIds) {
  108. return toAjax(iSysOssService.deleteWithValidByIds(Arrays.asList(ossIds), true) ? 1 : 0);
  109. }
  110. /**
  111. * 变更图片列表预览状态
  112. */
  113. @ApiOperation("变更图片列表预览状态")
  114. @PreAuthorize("@ss.hasPermi('system:oss:edit')")
  115. @Log(title = "OSS云存储" , businessType = BusinessType.UPDATE)
  116. @PutMapping("/changePreviewListResource")
  117. public AjaxResult<Void> changePreviewListResource(@RequestBody String body) {
  118. Map<String, Boolean> map = JsonUtils.parseMap(body);
  119. SysConfig config = iSysConfigService.getOne(new LambdaQueryWrapper<SysConfig>()
  120. .eq(SysConfig::getConfigKey, CloudConstant.PEREVIEW_LIST_RESOURCE_KEY));
  121. config.setConfigValue(map.get("previewListResource").toString());
  122. return toAjax(iSysConfigService.updateConfig(config));
  123. }
  124. }