修改minio相关。

develop-QA
Tom Li 2 weeks ago
parent dec68ef103
commit 4558f3a858
  1. 27
      blade-ops-api/blade-resource-api/src/main/java/org/springblade/resource/feign/IAttachClient.java
  2. 13
      blade-ops/blade-resource/src/main/java/org/springblade/resource/endpoint/OssEndpoint.java
  3. 25
      blade-ops/blade-resource/src/main/java/org/springblade/resource/feign/AttachClient.java
  4. 8
      blade-ops/blade-resource/src/main/resources/application.yml
  5. 12
      blade-service/blade-desk/pom.xml

@ -0,0 +1,27 @@
package org.springblade.resource.feign;
import org.springblade.core.launch.constant.AppConstant;
import org.springblade.core.tool.api.R;
import org.springblade.resource.pojo.entity.Attach;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
@FeignClient(
value = AppConstant.APPLICATION_RESOURCE_NAME
)
public interface IAttachClient {
String API_PREFIX = "/feign/client/attach";
String DETAIL = API_PREFIX + "/detail";
/**
*
* @param attach
* @return
*/
@PostMapping(DETAIL)
public R<Attach> detail(@RequestBody Attach attach);
}

@ -26,8 +26,12 @@
package org.springblade.resource.endpoint;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import lombok.AllArgsConstructor;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.oss.MinioTemplate;
import org.springblade.core.oss.OssTemplate;
import org.springblade.core.oss.model.BladeFile;
import org.springblade.core.oss.model.OssFile;
import org.springblade.core.secure.annotation.IsAdmin;
@ -50,9 +54,13 @@ import org.springframework.web.multipart.MultipartFile;
@RestController
@AllArgsConstructor
@RequestMapping("/oss/endpoint")
@Slf4j
@Tag(name = "对象存储端点", description = "对象存储端点")
public class OssEndpoint {
private static final String TENANT_ID = "000000";
private static final String CODE = "minio";
/**
* 对象存储构建类
*/
@ -180,7 +188,7 @@ public class OssEndpoint {
@PostMapping("/put-file-attach")
public R<BladeFile> putFileAttach(@RequestParam MultipartFile file) {
String fileName = file.getOriginalFilename();
BladeFile bladeFile = ossBuilder.template().putFile(fileName, file.getInputStream());
BladeFile bladeFile = ossBuilder.template(TENANT_ID, CODE).putFile(fileName, file.getInputStream());
Long attachId = buildAttach(fileName, file.getSize(), bladeFile);
bladeFile.setAttachId(attachId);
return R.data(bladeFile);
@ -196,7 +204,7 @@ public class OssEndpoint {
@SneakyThrows
@PostMapping("/put-file-attach-by-name")
public R<BladeFile> putFileAttach(@RequestParam String fileName, @RequestParam MultipartFile file) {
BladeFile bladeFile = ossBuilder.template().putFile(fileName, file.getInputStream());
BladeFile bladeFile = ossBuilder.template(TENANT_ID, CODE).putFile(fileName, file.getInputStream());
Long attachId = buildAttach(fileName, file.getSize(), bladeFile);
bladeFile.setAttachId(attachId);
return R.data(bladeFile);
@ -250,5 +258,4 @@ public class OssEndpoint {
ossBuilder.template().removeFiles(Func.toStrList(fileNames));
return R.success("操作成功");
}
}

@ -0,0 +1,25 @@
package org.springblade.resource.feign;
import jakarta.annotation.Resource;
import lombok.Data;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tool.api.R;
import org.springblade.resource.pojo.entity.Attach;
import org.springblade.resource.service.IAttachService;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@Data
public class AttachClient implements IAttachClient {
@Resource
private IAttachService attachService;
@Override
@PostMapping(DETAIL)
public R<Attach> detail(Attach attach) {
Attach detail = attachService.getOne(Condition.getQueryWrapper(attach));
return R.data(detail);
}
}

@ -12,12 +12,12 @@ oss:
#租户模式
tenant-mode: false
#oss服务地址
endpoint: http://127.0.0.1:9000
endpoint: http://192.168.0.220:9000
#minio转换服务地址,用于内网上传后将返回地址改为转换的外网地址
transform-endpoint: http://127.0.0.1:9000
transform-endpoint: http://192.168.0.220:9000
#访问key
access-key: WFFVc1UxP9g0yFw1wpaV
access-key: T5PCRlMc5PxxubLCrVhR
#密钥key
secret-key: D9TUQQdHdujfOeAhZDiGkPGu1XpUHffSWzlkU7oO
secret-key: mbIbJKpTWulCdcsalKjoxaFJ8UDapGSU6Zw9QKjz
#存储桶
bucket-name: bladex

@ -46,10 +46,10 @@
<artifactId>minio</artifactId>
</dependency>
<!--QiNiu-->
<dependency>
<groupId>com.qiniu</groupId>
<artifactId>qiniu-java-sdk</artifactId>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.qiniu</groupId>-->
<!-- <artifactId>qiniu-java-sdk</artifactId>-->
<!-- </dependency>-->
<dependency>
<groupId>org.flowable</groupId>
<artifactId>flowable-engine</artifactId>
@ -81,6 +81,10 @@
<artifactId>hutool-all</artifactId>
<version>5.8.16</version>
</dependency>
<dependency>
<groupId>org.springblade</groupId>
<artifactId>blade-resource-api</artifactId>
</dependency>
</dependencies>
<build>

Loading…
Cancel
Save