package com.gkhy.safePlatform.safeCheck.service.impl;
|
|
|
import com.gkhy.safePlatform.commons.config.file.MinioConfig;
|
import com.gkhy.safePlatform.commons.utils.StringUtils;
|
import com.gkhy.safePlatform.safeCheck.service.SafeCheckMinioAccessService;
|
import com.gkhy.safePlatform.safeCheck.util.UUIDUtil;
|
import io.minio.GetPresignedObjectUrlArgs;
|
import io.minio.MinioClient;
|
import io.minio.RemoveObjectArgs;
|
import io.minio.errors.*;
|
import io.minio.http.Method;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import javax.management.ObjectName;
|
import java.io.IOException;
|
import java.security.InvalidKeyException;
|
import java.security.NoSuchAlgorithmException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Service
|
public class SafeCheckMinioAccessServiceImpl implements SafeCheckMinioAccessService {
|
|
|
// @Value("${safecheckminio.urlPrefix}")
|
// private String externalNetworkPort;
|
@Value("${safecheckminio.floders.safecheck}")
|
private String minioFloders;
|
|
@Value("${safecheckminio.floders.exceorderimage}")
|
private String minioExceOrderImageFloders;
|
|
@Autowired
|
private MinioConfig minioConfig;
|
|
@Autowired
|
private MinioClient minioClient;
|
|
/**
|
* @description 获取文件下载地址
|
*/
|
public String viewFile(String objectName){
|
return viewFileDown(minioFloders+objectName);
|
}
|
|
/**
|
* @description 获取异常文件的下载地址
|
*/
|
public String viewExceFile(String objectName){
|
return viewFileDown(minioExceOrderImageFloders+objectName);
|
}
|
|
|
private String viewFileDown(String objectName){
|
String url = null;
|
// HashMap<String, String> map = new HashMap<>();
|
// map.put("id","123");
|
try {
|
url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
|
.method(Method.GET)
|
.bucket(minioConfig.getBucketName())
|
.object(objectName)
|
//.object(minioExceOrderImageFloders+objectName)
|
// .extraHeaders(map)
|
.expiry(60*60*5).build()
|
);
|
} catch (ErrorResponseException e) {
|
e.printStackTrace();
|
} catch (InsufficientDataException e) {
|
e.printStackTrace();
|
} catch (InternalException e) {
|
e.printStackTrace();
|
} catch (InvalidKeyException e) {
|
e.printStackTrace();
|
} catch (InvalidResponseException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
} catch (XmlParserException e) {
|
e.printStackTrace();
|
} catch (ServerException e) {
|
e.printStackTrace();
|
}
|
url =
|
minioConfig.getUrlPrefix() + url.substring((url.indexOf("//") + 2)).substring(url.substring((url.indexOf("//") + 2)).indexOf(
|
"/"));
|
return url;
|
}
|
|
/**
|
* @description 获取文件上传地址
|
*/
|
public Map<String, String> getPresignUrl(String prefixName ,String suffixName){
|
String uuid= UUIDUtil.initUUID();
|
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
|
String nowTime = formatter.format(new Date());
|
String objName = nowTime+"_"+uuid+"."+suffixName;
|
String url = null;
|
Map<String,String> resMap = new HashMap<>();
|
resMap.put("rfidImage",objName);
|
try {
|
Map<String, String> reqParams = new HashMap<>();
|
reqParams.put("response-content-type", "application/json");
|
url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
|
.method(Method.PUT)
|
.bucket(minioConfig.getBucketName())
|
.object(minioFloders+objName)
|
.expiry(60*60*2)
|
.extraQueryParams(reqParams)
|
.build());
|
resMap.put("uploadUrl",url);
|
} catch (ErrorResponseException e) {
|
e.printStackTrace();
|
} catch (InsufficientDataException e) {
|
e.printStackTrace();
|
} catch (InternalException e) {
|
e.printStackTrace();
|
} catch (InvalidKeyException e) {
|
e.printStackTrace();
|
} catch (InvalidResponseException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
} catch (XmlParserException e) {
|
e.printStackTrace();
|
} catch (ServerException e) {
|
e.printStackTrace();
|
}
|
return resMap;
|
}
|
|
/**
|
* @description 获取巡检异常图片上传地址
|
*/
|
public Map<String, String> getExcPresignUrl(String prefixName ,String suffixName){
|
String uuid= UUIDUtil.initUUID();
|
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
|
String nowTime = formatter.format(new Date());
|
String objName = nowTime+"_"+uuid+"."+suffixName;
|
String url = null;
|
Map<String,String> resMap = new HashMap<>();
|
resMap.put("image",objName);
|
try {
|
Map<String, String> reqParams = new HashMap<>();
|
reqParams.put("response-content-type", "application/json");
|
url = minioClient.getPresignedObjectUrl(GetPresignedObjectUrlArgs.builder()
|
.method(Method.PUT)
|
.bucket(minioConfig.getBucketName())
|
.object(minioExceOrderImageFloders+objName)
|
.expiry(60*60*2)
|
.extraQueryParams(reqParams)
|
.build());
|
resMap.put("uploadUrl",url);
|
} catch (ErrorResponseException e) {
|
e.printStackTrace();
|
} catch (InsufficientDataException e) {
|
e.printStackTrace();
|
} catch (InternalException e) {
|
e.printStackTrace();
|
} catch (InvalidKeyException e) {
|
e.printStackTrace();
|
} catch (InvalidResponseException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
} catch (XmlParserException e) {
|
e.printStackTrace();
|
} catch (ServerException e) {
|
e.printStackTrace();
|
}
|
return resMap;
|
}
|
|
/**
|
* @description 删除文件
|
*/
|
@Override
|
public String deleteFile(String name) {
|
try {
|
minioClient.removeObject(RemoveObjectArgs.builder()
|
.bucket(minioConfig.getBucketName())
|
.object(minioFloders+name)
|
.build());
|
} catch (ErrorResponseException e) {
|
e.printStackTrace();
|
} catch (InsufficientDataException e) {
|
e.printStackTrace();
|
} catch (InternalException e) {
|
e.printStackTrace();
|
} catch (InvalidKeyException e) {
|
e.printStackTrace();
|
} catch (InvalidResponseException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
} catch (XmlParserException e) {
|
e.printStackTrace();
|
} catch (ServerException e) {
|
e.printStackTrace();
|
}
|
return "删除成功";
|
}
|
}
|
