ci: 相关代码从minio切換到华为云
This commit is contained in:
+2
-2
@@ -13,8 +13,8 @@ import com.jero.common.system.vo.LoginUser;
|
|||||||
import com.jero.common.system.vo.SysDictItemCore;
|
import com.jero.common.system.vo.SysDictItemCore;
|
||||||
import com.jero.common.util.FileUtils;
|
import com.jero.common.util.FileUtils;
|
||||||
import com.jero.common.util.MessageUtils;
|
import com.jero.common.util.MessageUtils;
|
||||||
import com.jero.common.util.MinioUtil;
|
|
||||||
import com.jero.common.util.ZipUtil;
|
import com.jero.common.util.ZipUtil;
|
||||||
|
import com.jero.common.util.obs.ObsBootUtil;
|
||||||
import com.jero.modules.activiti.common.ActivitiCommon;
|
import com.jero.modules.activiti.common.ActivitiCommon;
|
||||||
import com.jero.modules.activiti.entity.ProcessApprovalRecord;
|
import com.jero.modules.activiti.entity.ProcessApprovalRecord;
|
||||||
import com.jero.modules.activiti.enums.ProcessTypeEnum;
|
import com.jero.modules.activiti.enums.ProcessTypeEnum;
|
||||||
@@ -891,7 +891,7 @@ public class ProcessStandardComplianceCheckServiceImpl extends ServiceImpl<Proce
|
|||||||
OSSFile fileInfo = fileInfos.get(0);
|
OSSFile fileInfo = fileInfos.get(0);
|
||||||
String fileName = fileInfo.getFileName();
|
String fileName = fileInfo.getFileName();
|
||||||
String url = fileInfo.getUrl();
|
String url = fileInfo.getUrl();
|
||||||
try (InputStream originalInputStream = MinioUtil.getMinioFile(MinioUtil.getBucketName(), url)) {
|
try (InputStream originalInputStream = ObsBootUtil.getOssFile(url)) {
|
||||||
if (originalInputStream == null) {
|
if (originalInputStream == null) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|||||||
+2
-2
@@ -7,8 +7,8 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
import com.jero.common.exception.JeroBootException;
|
import com.jero.common.exception.JeroBootException;
|
||||||
import com.jero.common.util.FileUtils;
|
import com.jero.common.util.FileUtils;
|
||||||
import com.jero.common.util.MinioUtil;
|
|
||||||
import com.jero.common.util.ZipUtil;
|
import com.jero.common.util.ZipUtil;
|
||||||
|
import com.jero.common.util.obs.ObsBootUtil;
|
||||||
import com.jero.modules.assessmentLibrary.entity.LawsConformityAssessmentLibrary;
|
import com.jero.modules.assessmentLibrary.entity.LawsConformityAssessmentLibrary;
|
||||||
import com.jero.modules.assessmentLibrary.entity.LawsConformityAssessmentLibraryDetail;
|
import com.jero.modules.assessmentLibrary.entity.LawsConformityAssessmentLibraryDetail;
|
||||||
import com.jero.modules.assessmentLibrary.entity.vo.LawsConformityAssessmentLibraryExportVO;
|
import com.jero.modules.assessmentLibrary.entity.vo.LawsConformityAssessmentLibraryExportVO;
|
||||||
@@ -220,7 +220,7 @@ public class LawsConformityAssessmentLibraryServiceImpl extends ServiceImpl<Laws
|
|||||||
vo.setMaterialFileList(materialFileList);
|
vo.setMaterialFileList(materialFileList);
|
||||||
// 写出文件
|
// 写出文件
|
||||||
for (OSSFile ossFile : ossFileList) {
|
for (OSSFile ossFile : ossFileList) {
|
||||||
InputStream inputStream = MinioUtil.getMinioFile(MinioUtil.getBucketName(), ossFile.getUrl());
|
InputStream inputStream = ObsBootUtil.getOssFile(ossFile.getUrl());
|
||||||
// pdf加水印
|
// pdf加水印
|
||||||
if (StringUtils.endsWithIgnoreCase(ossFile.getFileName(), ".pdf")) {
|
if (StringUtils.endsWithIgnoreCase(ossFile.getFileName(), ".pdf")) {
|
||||||
inputStream = sysWaterMarkUtil.addWatermarkToPdf(inputStream);
|
inputStream = sysWaterMarkUtil.addWatermarkToPdf(inputStream);
|
||||||
|
|||||||
+3
-6
@@ -23,8 +23,8 @@ import com.jero.common.system.vo.LoginUser;
|
|||||||
import com.jero.common.system.vo.SysDictItemCore;
|
import com.jero.common.system.vo.SysDictItemCore;
|
||||||
import com.jero.common.util.IntekeyUtils;
|
import com.jero.common.util.IntekeyUtils;
|
||||||
import com.jero.common.util.MessageUtils;
|
import com.jero.common.util.MessageUtils;
|
||||||
import com.jero.common.util.MinioUtil;
|
|
||||||
import com.jero.common.util.oConvertUtils;
|
import com.jero.common.util.oConvertUtils;
|
||||||
|
import com.jero.common.util.obs.ObsBootUtil;
|
||||||
import com.jero.modules.activiti.process.common.enums.StandardStateEnum;
|
import com.jero.modules.activiti.process.common.enums.StandardStateEnum;
|
||||||
import com.jero.modules.laws.common.constant.FieldCommon;
|
import com.jero.modules.laws.common.constant.FieldCommon;
|
||||||
import com.jero.modules.laws.common.mapper.LawsCommonMapper;
|
import com.jero.modules.laws.common.mapper.LawsCommonMapper;
|
||||||
@@ -2413,9 +2413,6 @@ public class LawsCommonServiceImpl implements ILawsCommonService {
|
|||||||
private byte[] getMinioFileContentNormal(OSSFile file, boolean esSpecial) throws Exception {
|
private byte[] getMinioFileContentNormal(OSSFile file, boolean esSpecial) throws Exception {
|
||||||
String fileUrl = file.getUrl();
|
String fileUrl = file.getUrl();
|
||||||
String fileName = file.getFileName();
|
String fileName = file.getFileName();
|
||||||
String minioUrl = MinioUtil.getMinioUrl();
|
|
||||||
minioUrl = minioUrl + MinioUtil.getBucketName() + "/";
|
|
||||||
String url = fileUrl.replace(minioUrl, "");
|
|
||||||
|
|
||||||
try (ByteArrayOutputStream outputStream = new ByteArrayOutputStream()) {
|
try (ByteArrayOutputStream outputStream = new ByteArrayOutputStream()) {
|
||||||
byte[] buf = new byte[1024];
|
byte[] buf = new byte[1024];
|
||||||
@@ -2423,7 +2420,7 @@ public class LawsCommonServiceImpl implements ILawsCommonService {
|
|||||||
if ("pdf".equalsIgnoreCase(FileUtil.extName(fileName))) {
|
if ("pdf".equalsIgnoreCase(FileUtil.extName(fileName))) {
|
||||||
|
|
||||||
// 如果是PDF文件, 添加水印
|
// 如果是PDF文件, 添加水印
|
||||||
try (InputStream originalInputStream = MinioUtil.getMinioFile(MinioUtil.getBucketName(), url);
|
try (InputStream originalInputStream = ObsBootUtil.getOssFile(file.getUrl());
|
||||||
InputStream watermarkedInputStream = sysWaterMarkUtil.addWatermarkToPdf(originalInputStream)) {
|
InputStream watermarkedInputStream = sysWaterMarkUtil.addWatermarkToPdf(originalInputStream)) {
|
||||||
// 如果是系统开启了加密并且处理的是企标 则需要将加水印的pdf文件再次加密
|
// 如果是系统开启了加密并且处理的是企标 则需要将加水印的pdf文件再次加密
|
||||||
InputStream is = watermarkedInputStream;
|
InputStream is = watermarkedInputStream;
|
||||||
@@ -2444,7 +2441,7 @@ public class LawsCommonServiceImpl implements ILawsCommonService {
|
|||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
// 如果不是PDF文件
|
// 如果不是PDF文件
|
||||||
try (InputStream inputStream = MinioUtil.getMinioFile(MinioUtil.getBucketName(), url)) {
|
try (InputStream inputStream = ObsBootUtil.getOssFile(file.getUrl())) {
|
||||||
if (inputStream == null) {
|
if (inputStream == null) {
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user