From 3055568c3621ec3daa2340464a316fbf90369bc3 Mon Sep 17 00:00:00 2001 From: gsz Date: Tue, 11 Jun 2024 18:29:38 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8D=8E=E4=B8=BA=E4=BA=91OBS=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=E6=8E=A5=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/i3plus-ext-mes-apiservice/pom.xml | 6 + .../apiservice/config/HuaWeiCloudObsConfig.java | 44 ++ .../controller/base/MesMediaFileCfgController.java | 233 ++++++--- .../ext/mes/apiservice/utils/HuaWeiOBSUtil.java | 523 +++++++++++++++++++++ .../src/main/resources/application.properties | 12 +- .../ext/mes/pojo/constant/MesCommonConstant.java | 6 + 6 files changed, 749 insertions(+), 75 deletions(-) create mode 100644 modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/config/HuaWeiCloudObsConfig.java create mode 100644 modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/utils/HuaWeiOBSUtil.java diff --git a/modules/i3plus-ext-mes-apiservice/pom.xml b/modules/i3plus-ext-mes-apiservice/pom.xml index 6b2e26e..0efae82 100644 --- a/modules/i3plus-ext-mes-apiservice/pom.xml +++ b/modules/i3plus-ext-mes-apiservice/pom.xml @@ -14,6 +14,12 @@ jar + + + com.huaweicloud + esdk-obs-java-bundle + 3.23.9 + impp.framework diff --git a/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/config/HuaWeiCloudObsConfig.java b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/config/HuaWeiCloudObsConfig.java new file mode 100644 index 0000000..f0077f0 --- /dev/null +++ b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/config/HuaWeiCloudObsConfig.java @@ -0,0 +1,44 @@ +package cn.estsh.i3plus.ext.mes.apiservice.config; + +import cn.estsh.i3plus.ext.mes.apiservice.utils.HuaWeiOBSUtil; +import com.obs.services.ObsClient; +import lombok.Getter; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +/** + * @Description : HuaWeiCloudObsConfig + * @Author :gsz + * @Date 2024/6/11 13:28 + * @Modify + **/ +@Configuration +public class HuaWeiCloudObsConfig { + + @Value("${huaweiobs.bucketName}") + @Getter + private String bucketName; + + @Value("${huaweiobs.ak}") + @Getter + private String ak; + + @Value("${huaweiobs.sk}") + @Getter + private String sk; + + @Value("${huaweiobs.endPoint}") + @Getter + private String endPoint; + + @Bean + public ObsClient getObsClient() { + ObsClient obsClient = new ObsClient(ak, sk, endPoint); + return obsClient; + } + @Bean + public HuaWeiOBSUtil huaWeiOBSUtil() { + return new HuaWeiOBSUtil(bucketName, ak, sk, endPoint); + } +} diff --git a/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/controller/base/MesMediaFileCfgController.java b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/controller/base/MesMediaFileCfgController.java index a17ba42..63d3b96 100644 --- a/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/controller/base/MesMediaFileCfgController.java +++ b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/controller/base/MesMediaFileCfgController.java @@ -1,5 +1,8 @@ package cn.estsh.i3plus.ext.mes.apiservice.controller.base; +import cn.estsh.i3plus.ext.mes.api.base.IMesMediaFileCfgService; +import cn.estsh.i3plus.ext.mes.apiservice.config.HuaWeiCloudObsConfig; +import cn.estsh.i3plus.ext.mes.apiservice.utils.HuaWeiOBSUtil; import cn.estsh.i3plus.ext.mes.pojo.constant.MesCommonConstant; import cn.estsh.i3plus.icloud.core.sdk.ICoreSysFileCloud; import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum; @@ -12,7 +15,9 @@ import cn.estsh.impp.framework.boot.exception.ImppBusiException; import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder; import cn.estsh.impp.framework.boot.util.ResultBean; import com.aliyun.oss.model.PutObjectRequest; -import com.aliyun.oss.model.PutObjectResult; +import com.obs.services.ObsClient; +import com.obs.services.exception.ObsException; +import com.obs.services.model.*; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.apache.commons.lang.StringUtils; @@ -22,12 +27,15 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; +import org.springframework.web.multipart.commons.CommonsMultipartFile; import org.testng.annotations.Optional; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; +import javax.servlet.http.HttpSession; import java.io.*; import java.net.URLEncoder; +import java.util.List; import java.util.UUID; /** @@ -38,7 +46,7 @@ import java.util.UUID; @Api("媒体文件维护") @RestController @RequestMapping(MesCommonConstant.MES_YANFEN + "/mesMediaFileCfg") -public class MesMediaFileCfgController extends BaseMesController{ +public class MesMediaFileCfgController extends BaseMesController { public static final Logger LOGGER = LoggerFactory.getLogger(MesMediaFileCfgController.class); @Autowired private MesMediaFileCfgRepository mediaFileCfgRepository; @@ -46,9 +54,151 @@ public class MesMediaFileCfgController extends BaseMesController FILE_SIZE) { + throw ImppExceptionBuilder.newInstance() + .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode()) + .setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode()) + .setErrorDetail("文件过大，请重新上传！") + .build(); + } + String fileName = file.getOriginalFilename(); + + PutObjectResult putObjectResult = HuaWeiOBSUtil.putObjectByMultipartFile(MesCommonConstant.OBS_END_POINT, fileName, file); + + String objectUrl = putObjectResult.getObjectUrl(); + + return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(putObjectResult); + } catch (ImppBusiException imppException) { + LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException); + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + + @ApiOperation("下载文件") + @GetMapping("/obs/download") + public ResultBean obsDownloadFile(@RequestParam("filePath") String filePath, HttpServletResponse response, MesMediaFileCfg mesMediaFileCfg) { + InputStream inputStream = null; + OutputStream outputStream = null; + try { + // 读取文件 + inputStream = HuaWeiOBSUtil.getObject(MesCommonConstant.OBS_END_POINT, mesMediaFileCfg.getFileName()); + outputStream = response.getOutputStream(); + response.setContentType("application/octet-stream"); + response.setHeader("Content-Disposition", "attachment; filename=" + URLEncoder.encode(mesMediaFileCfg.getFileName(), "UTF-8")); + byte[] buffer = new byte[4096]; + int bytesRead; + while ((bytesRead = inputStream.read(buffer)) != -1) { + outputStream.write(buffer, 0, bytesRead); + } + outputStream.flush(); + inputStream.close(); + outputStream.close(); + return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + } catch (ImppBusiException imppException) { + LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException); + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + + } + + + @ApiOperation("查看文件") + @GetMapping("/obs/query-file") + public ResultBean queryObjectFile(HttpServletResponse response, MesMediaFileCfg mesMediaFileCfg) { + + InputStream inputStream = null; + OutputStream outputStream = null; + try { + +// InputStream object = HuaWeiOBSUtil.getObject(MesCommonConstant.OBS_END_POINT, mesMediaFileCfg.getFileName()); + // 列举桶 + ListBucketsRequest request = new ListBucketsRequest(); + request.setQueryLocation(true); + ObsClient obsClient = obsConfig.getObsClient(); + List buckets = obsClient.listBuckets(request); + for (ObsBucket bucket : buckets) { + LOGGER.info("BucketName：{},Location{}", bucket.getBucketName(),bucket.getLocation()); + } + + return ResultBean.success("下载成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + } catch (ImppBusiException imppException) { + LOGGER.error(imppException.getErrorMsg() + "：{}", imppException.getErrorDetail(), imppException); + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + + } + + @ApiOperation("创建桶") + @GetMapping("/obs/createMesBucket") + public ResultBean CreateMesBucket() { + + try { + CreateBucketRequest request = new CreateBucketRequest(); + ObsClient obsClient = obsConfig.getObsClient(); + ListBucketsRequest bucketsRequest = new ListBucketsRequest(); + bucketsRequest.setQueryLocation(true); + List buckets = obsClient.listBuckets(bucketsRequest); + for (ObsBucket bucket : buckets) { + if(bucket.getBucketName().equals(MesCommonConstant.OBS_BUCKET_NAME)){ + return ResultBean.success("已创建桶【mesbucket】").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + } + } + //示例桶名 + String exampleBucket = MesCommonConstant.OBS_BUCKET_NAME; + //示例桶区域位置 + String exampleLocation = MesCommonConstant.OBS_LOCATION; + request.setBucketName(exampleBucket); + // 设置桶访问权限为私有读写，默认也是私有读写 + request.setAcl(AccessControlList.REST_CANNED_PRIVATE); + // 设置桶的存储类别为标准存储 + request.setBucketStorageClass(StorageClassEnum.STANDARD); + // 设置桶区域位置(以区域为中国-上海为例)，location 需要与 endpoint的位置信息一致 + request.setLocation(exampleLocation); + // 指定创建多AZ桶，如果不设置，默认创建单AZ桶 + request.setAvailableZone(AvailableZoneEnum.MULTI_AZ); + // 创建桶 + ObsBucket bucket = obsClient.createBucket(request); + + } catch (ObsException e) { + LOGGER.error("Error Message：{}", e.getErrorMessage()); + } catch (Exception e) { + e.printStackTrace(); + } + + return ResultBean.success("创建成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + + } + + @PostMapping(value = "/media-file/insert") @ApiOperation(value = "上传媒体文件") public ResultBean insertProduceCtgyPicture(@RequestParam("file") MultipartFile file, MesMediaFileCfg mesMediaFileCfg) { @@ -63,7 +213,7 @@ public class MesMediaFileCfgController extends BaseMesController FILE_SIZE){ + if (size > FILE_SIZE) { throw ImppExceptionBuilder.newInstance() .setSystemID(CommonEnumUtil.SOFT_TYPE.REPORT.getCode()) .setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode()) @@ -72,17 +222,17 @@ public class MesMediaFileCfgController extends BaseMesController52428800){ -// throw new BusinessException("单次上传不能超过200M"); -// } -// String objectKey = UUIDUtils.getRandomUUID()+file.getOriginalFilename(); -// PutObjectRequest request = new PutObjectRequest(bucketName, objectKey, file.getInputStream()); -// PutObjectResult putObjectResult= obsClient.putObject(request); -// objectUrl=objectKey; -// LOGGER.info("已上传对象的URL:{}", putObjectResult.getObjectUrl()); -// LOGGER.info("生成的文件访问名：{}", objectKey); -// } catch (ObsException e) { -// LOGGER.error("obs上传失败:{}", LogExceptionStackUtil.logExceptionStack(e)); -// return JsonResponse.error("obs上传失败"); -// } catch (Exception e) { -// LOGGER.error("上传失败文件为空或者超过200M:{}", LogExceptionStackUtil.logExceptionStack(e)); -// return JsonResponse.error("上传失败文件为空或者超过200M"); -// } finally { -// hweiOBSConfig.destroy(obsClient); -// } -// -// return JsonResponse.ok(objectUrl); -// } -// @GetMapping("/download") -// @ApiOperation("下载文件") -// public void download(@RequestParam("fileName") String fileName , HttpServletRequest request, HttpServletResponse response) { -// -// try (InputStream inputStream = hweiYunOBSService.fileDownload(fileName); -// BufferedOutputStream outputStream = new BufferedOutputStream(response.getOutputStream())){ -// -// // 为防止 文件名出现乱码 -// final String userAgent = request.getHeader("USER-AGENT"); -// // IE浏览器 -// if (StringUtils.contains(userAgent, "MSIE")) { -// fileName = URLEncoder.encode(fileName, "UTF-8"); -// } else { -// // google,火狐浏览器 -// if (StringUtils.contains(userAgent, "Mozilla")) { -// fileName = new String(fileName.getBytes(), "ISO8859-1"); -// } else { -// // 其他浏览器 -// fileName = URLEncoder.encode(fileName, "UTF-8"); -// } -// } -// response.setContentType("application/x-download"); -// // 设置让浏览器弹出下载提示框，而不是直接在浏览器中打开 -// response.addHeader("Content-Disposition", "attachment;filename=" + fileName); -// IoUtil.copy(inputStream, outputStream); -// } catch (Exception e) { -// LOGGER.error("文件下载失败{}", e.logExceptionStack(e)); -// } -// } } diff --git a/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/utils/HuaWeiOBSUtil.java b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/utils/HuaWeiOBSUtil.java new file mode 100644 index 0000000..32568b9 --- /dev/null +++ b/modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/utils/HuaWeiOBSUtil.java @@ -0,0 +1,523 @@ +package cn.estsh.i3plus.ext.mes.apiservice.utils; + +import com.obs.services.ObsClient; +import com.obs.services.model.*; +import groovy.util.logging.Slf4j; +import org.apache.commons.lang.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.web.multipart.MultipartFile; + +import java.io.*; +import java.util.ArrayList; +import java.util.List; + +/** + * @Description : ObsUtil + * @Author :gsz + * @Date 2024/6/11 14:55 + * @Modify + **/ +@Slf4j +public class HuaWeiOBSUtil { + public static final Logger LOGGER = LoggerFactory.getLogger(HuaWeiOBSUtil.class); +// +// @Autowired +// HuaWeiCloudObsConfig obsConfig; + /** + * 文件外链过期时间，7天 + */ + private static long expire = 7 * 24 * 60 * 60; + + /** + * 文件外链访问端口 + */ + private static String port = ":443"; + + private static String bucketName; + private static String ak; + private static String sk; + private static String endPoint; + + /** + * OBS操作客户端 + */ + private static ObsClient obsClient = null; + + private static final String SEPARATOR = "/"; + + public HuaWeiOBSUtil(String bucketName, String ak, String sk, String endPoint) { + HuaWeiOBSUtil.bucketName = bucketName; + HuaWeiOBSUtil.ak = ak; + HuaWeiOBSUtil.sk = sk; + HuaWeiOBSUtil.endPoint = endPoint; + createObsClientInstance(); + } +// public HuaWeiOBSUtil(HuaWeiCloudObsConfig obsConfig) { +// HuaWeiOBSUtil.bucketName = obsConfig.getBucketName(); +// HuaWeiOBSUtil.ak = obsConfig.getAk(); +// HuaWeiOBSUtil.sk = obsConfig.getSk(); +// HuaWeiOBSUtil.endPoint = obsConfig.getEndPoint(); +// createObsClientInstance(); +// } + + public static String getBucketName() { + return bucketName; + } + + public static String getAk() { + return ak; + } + + public static String getSk() { + return sk; + } + + public static String getEndPoint() { + return endPoint; + } + + /** + * 获取OBS操作客户端 + * + * @return + */ + private static void createObsClientInstance() { + try { + if (obsClient == null) { + synchronized (ObsClient.class) { + if (obsClient == null) { + obsClient = new ObsClient(ak, sk, endPoint); + } + } + } + createBucket(bucketName, endPoint); + } catch (Exception e) { + LOGGER.error("连接华为云存储服务器异常：" + e.getMessage(), e); + } + } + + /** + * 获取上传文件的基础路径 + * + * @return url + */ + public static String getBasisUrl() { + //实示例：http协议 + 存储桶名称 + . + endPoint + port + / + return getHttpProtocol(endPoint) + "://" + bucketName + "." + endPoint.replace(getHttpProtocol(endPoint) + "://", "") + port + SEPARATOR; + } + + /** + * 获取上传文件的基础路径 + * + * @param bucketName + * @return + */ + public static String getBasisUrl(String bucketName) { + //实示例：http协议 + 存储桶名称 + . + endPoint + port + / + return getHttpProtocol(endPoint) + "://" + bucketName + "." + endPoint.replace(getHttpProtocol(endPoint) + "://", "") + port + SEPARATOR; + } + + /** + * 获取区域 + * + * @param endPoint + * @return + */ + public static String getRegion(String endPoint) { + String substring = endPoint.substring(endPoint.indexOf(".") + 1); + return substring.substring(0, substring.indexOf(".")); + } + + /** + * 获取http协议 + * + * @param endPoint + * @return + */ + public static String getHttpProtocol(String endPoint) { + return endPoint.substring(0, endPoint.indexOf(":")); + } + + /** + * 创建存储桶 + * + * @param bucketName + * @return + */ + public static void createBucket(String bucketName, String endPoint) { + if (!headBucket(bucketName)) { + CreateBucketRequest request = new CreateBucketRequest(); + // 设置存储桶名称 + request.setBucketName(bucketName); + // 设置桶区域位置，从endPoint中截取，如果Location设置的区域与endPoint中的区域不是同一个，则创建会报错 + request.setLocation(getRegion(endPoint)); + // 创建桶成功 + obsClient.createBucket(request); + } + } + + /** + * 删除存储桶 + * + * @param bucketName + * @return + */ + public static HeaderResponse deleteBucket(String bucketName) { + return obsClient.deleteBucket(bucketName); + } + + /** + * 判断存储桶是否存在 + * + * @param bucketName + * @return + */ + public static boolean headBucket(String bucketName) { + return obsClient.headBucket(bucketName); + } + + /** + * 上传字符 + * + * @param bucketName + * @param objectName + * @param content + * @return + */ + public static PutObjectResult putObjectByStr(String bucketName, String objectName, String content) { + if (StringUtils.isBlank(content)) { + return null; + } + + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.putObject(bucketName, objectName, new ByteArrayInputStream(content.getBytes())); + } + + /** + * 上传输入流 + * + * @param bucketName + * @param objectName + * @param inputStream + * @return + */ + public static PutObjectResult putObjectByInput(String bucketName, String objectName, InputStream inputStream) { + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.putObject(bucketName, objectName, inputStream); + } + + /** + * 上传文件输入流 + * + * @param bucketName + * @param objectName + * @param fileInputStream + * @return + */ + public static PutObjectResult putObjectByFileInput(String bucketName, String objectName, FileInputStream fileInputStream) { + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.putObject(bucketName, objectName, fileInputStream); + } + + /** + * 通过MultipartFile，上传文件 + * + * @param bucketName + * @param objectName + * @param media + * @return + */ + public static PutObjectResult putObjectByMultipartFile(String bucketName, String objectName, MultipartFile media) throws IOException { + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.putObject(bucketName, objectName, media.getInputStream()); + } + + /** + * 上传本地文件 + * + * @param bucketName + * @param objectName + * @param file + * @return + */ + public static PutObjectResult putObjectByFile(String bucketName, String objectName, File file) { + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.putObject(bucketName, objectName, file); + } + + /** + * 下载文件到本地 + * + * @param bucketName + * @param objectName + * @param filePath + * @return + */ + public static boolean downloadObject(String bucketName, String objectName, String filePath) throws Exception { + if (StringUtils.isBlank(filePath)) { + return false; + } + //重新构建objectName + objectName = buildObjectName(objectName); + + filePath = filePath.replace("\\", SEPARATOR); + + InputStream input = null; + FileOutputStream fileOutputStream = null; + try { + // 获取对象 + ObsObject obsObject = obsClient.getObject(bucketName, objectName); + // 读取对象内容 + input = obsObject.getObjectContent(); + + if (input == null) { + return false; + } + + //获取文件夹路径 + if (filePath.contains(SEPARATOR)) { + String dir = filePath.substring(0, filePath.lastIndexOf(SEPARATOR)); + File difFile = new File(dir); + if (!difFile.exists()) { + //创建文件夹 + boolean mkdirs = difFile.mkdirs(); + } + } + + File file = new File(filePath); + fileOutputStream = new FileOutputStream(file); + + byte[] b = new byte[1024]; + int len; + while ((len = input.read(b)) != -1) { + fileOutputStream.write(b, 0, len); + } + return true; + } finally { + if (fileOutputStream != null) { + fileOutputStream.close(); + } + if (input != null) { + input.close(); + } + } + } + + /** + * 获取文件内容 + * + * @param bucketName + * @param objectName + * @return + */ + public static String getObjectContent(String bucketName, String objectName) throws IOException { + //重新构建objectName + objectName = buildObjectName(objectName); + + InputStream input = null; + ByteArrayOutputStream bos = new ByteArrayOutputStream(); + try { + ObsObject obsObject = obsClient.getObject(bucketName, objectName); + // 读取对象内容 + input = obsObject.getObjectContent(); + + byte[] b = new byte[1024]; + int len; + while ((len = input.read(b)) != -1) { + bos.write(b, 0, len); + } + + return new String(bos.toByteArray()); + } finally { + bos.close(); + if (input != null) { + input.close(); + } + } + } + + /** + * 获取文件输入流 + * + * @param bucketName + * @param objectName + * @return + */ + public static InputStream getObject(String bucketName, String objectName) { + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.getObject(bucketName, objectName).getObjectContent(); + } + + /** + * 指定数目和前缀列举 + * + * @param bucketName + * @param prefix + * @param maxKeys + * @return + */ + public static List listObjects(String bucketName, String prefix, Integer maxKeys) { + prefix = prefix.startsWith("/") ? prefix.substring(1) : prefix; + + ListObjectsRequest request = new ListObjectsRequest(bucketName); + // 设置列举的对象个数 + request.setMaxKeys(maxKeys); + // 设置列举的对象需要带有指定前缀 + request.setPrefix(prefix); + ObjectListing result = obsClient.listObjects(request); + + return result.getObjects(); + } + + /** + * 列举指定前缀的全部对象 + * + * @param bucketName + * @param prefix + * @return + */ + public static List listAllObjects(String bucketName, String prefix) { + prefix = prefix.startsWith("/") ? prefix.substring(1) : prefix; + + List list = new ArrayList<>(); + + ListObjectsRequest request = new ListObjectsRequest(bucketName); + // 设置列举的对象个数 + request.setMaxKeys(1000); + // 设置列举的对象需要带有指定前缀 + request.setPrefix(prefix); + + ObjectListing result; + do { + result = obsClient.listObjects(request); + request.setMarker(result.getNextMarker()); + + list.addAll(result.getObjects()); + } while (result.isTruncated()); + + return list; + } + + /** + * 删除单个对象 + * + * @param bucketName + * @param objectName + * @return + */ + public static DeleteObjectResult deleteObject(String bucketName, String objectName) { + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.deleteObject(bucketName, objectName); + } + + /** + * 复制对象 + * + * @param sourceBucketName + * @param sourceObjectName + * @param destBucketName + * @param destObjectName + * @return + */ + public static CopyObjectResult copyObject(String sourceBucketName, String sourceObjectName, + String destBucketName, String destObjectName) { + return obsClient.copyObject(sourceBucketName, sourceObjectName, destBucketName, destObjectName); + } + + /** + * 判断对象是否存在 + * + * @param bucketName + * @param objectName + * @return + */ + public static boolean doesObjectExist(String bucketName, String objectName) { + //重新构建objectName + objectName = buildObjectName(objectName); + + return obsClient.doesObjectExist(bucketName, objectName); + } + + /** + * 获取文件外链 + * + * @param bucketName + * @param objectName + * @param expires 单位：秒(s) + * @return + */ + public static String getSignedUrl(String bucketName, String objectName, Long expires) { + //重新构建objectName + objectName = buildObjectName(objectName); + + TemporarySignatureRequest request = new TemporarySignatureRequest(HttpMethodEnum.GET, expires); + request.setBucketName(bucketName); + request.setObjectKey(objectName); + TemporarySignatureResponse response = obsClient.createTemporarySignature(request); + return response.getSignedUrl(); + } + + /** + * 获取文件外链-url有效时间默认7天 + * + * @param bucketName + * @param objectName + * @return + */ + public static String getSignedUrl(String bucketName, String objectName) { + return getSignedUrl(bucketName, objectName, expire); + } + + /** + * 重新构建objectName + * + * @param objectName + */ + private static String buildObjectName(String objectName) { + if (StringUtils.isBlank(objectName)) { + return objectName; + } + //去除开头的/ + objectName = objectName.startsWith("/") ? objectName.substring(1) : objectName; + //去除?后边的参数 + objectName = objectName.contains("?") ? objectName.substring(0, objectName.indexOf("?")) : objectName; + + return objectName; + } + + /** + * 传入文件访问外链，返回objectName + * + * @param url + * @return + */ + public static String getObjectNameByUrl(String url) { + if (StringUtils.isBlank(url)) { + return url; + } + + if (url.contains(getBasisUrl())) { + // 去除minio基础路径 + url = url.replace(getBasisUrl(), ""); + // 去除?后边的参数 + url = url.contains("?") ? url.substring(0, url.indexOf("?")) : url; + } + + return url; + } +} diff --git a/modules/i3plus-ext-mes-apiservice/src/main/resources/application.properties b/modules/i3plus-ext-mes-apiservice/src/main/resources/application.properties index d417395..556ec19 100644 --- a/modules/i3plus-ext-mes-apiservice/src/main/resources/application.properties +++ b/modules/i3plus-ext-mes-apiservice/src/main/resources/application.properties @@ -60,4 +60,14 @@ redis.resource.db=0 #\u7528\u6237\u4F1A\u8BDD\u7F13\u5B58\u5E93 redis.session.db=1 #mes\u7F13\u5B58\u5E93 -redis.mes.db=4 \ No newline at end of file +redis.mes.db=4 + +##华为OBS接入配置 +#OBS服务所在地址 +huaweiobs.endPoint=obs.cn-east-3.myhuaweicloud.com +#存储桶名称 +huaweiobs.bucketName=mesbucket +#访问的key +huaweiobs.ak=TPNXQ2LUMRHNYYOBO8QO +#访问的秘钥 +huaweiobs.sk=ppTtbisjdBxQsU124mFnubSojUsB6Wvp9KSaUAeb \ No newline at end of file diff --git a/modules/i3plus-ext-mes-pojo/src/main/java/cn/estsh/i3plus/ext/mes/pojo/constant/MesCommonConstant.java b/modules/i3plus-ext-mes-pojo/src/main/java/cn/estsh/i3plus/ext/mes/pojo/constant/MesCommonConstant.java index 30156bc..5c8ab34 100644 --- a/modules/i3plus-ext-mes-pojo/src/main/java/cn/estsh/i3plus/ext/mes/pojo/constant/MesCommonConstant.java +++ b/modules/i3plus-ext-mes-pojo/src/main/java/cn/estsh/i3plus/ext/mes/pojo/constant/MesCommonConstant.java @@ -33,4 +33,10 @@ public class MesCommonConstant { //CCSC生成任务号 public static final String CCSC_TASK_NO = "CCSC_TASK_NO"; + //OBS + public static final String OBS_AK = "TPNXQ2LUMRHNYYOBO8QO"; + public static final String OBS_SK = "ppTtbisjdBxQsU124mFnubSojUsB6Wvp9KSaUAeb"; + public static final String OBS_END_POINT = "obs.cn-east-3.myhuaweicloud.com"; + public static final String OBS_BUCKET_NAME = "mesbucket"; + public static final String OBS_LOCATION = "cn-east-3"; }