最近工作中有个需求，是将客户支付的银行回执单上按照客户姓名上传到oss，然后将oss地址反显到pc后台，供客户自己查看下载。
开始的时候感觉很简单，设计思路是根据客户支付单单号，查询数据库中是否存在该支付单的回执单，若存在直接返回，若不返回则通过拉卡拉API申请回执单，然后将结果保存到数据库（因不是频繁操作需求所以没有做缓存处理）。
private static LklSOAClient soaClient;
/**
* 初始化请求
*/
private static void iniLklSOAClient() {
try {
soaClient = new LklSOAClient();
//应用号，钱账通提供的应用ID
soaClient.setAppId(LaKaLaConstant.appId);
//版本号，当前版本为 3.0
soaClient.setVersion(LaKaLaConstant.version);
//商户DSA私钥，钱账通提供的DSA私钥
log.info("privateKeyPwd={}", LaKaLaConstant.privateKeyPwd);
soaClient.setPrivateKey(LklDSAUtil.loadPrivateKey(LaKaLaConstant.private KeyUrl, LaKaLaConstant.privateKeyPwd));
//钱账通DSA公钥，钱账通提供的DSA公钥
soaClient.setPublicKey(LklDSAUtil.loadPublicKey(LaKaLaConstant.publicKey Url));
//钱账通接口地址
soaClient.setServerUrl(LaKaLaConstant.soaServerUrl);
} catch (Exception e) {
log.error(e.toString(), e);
}
}
/**
* 根据订单号查询电子回单文件列表
* @param orderNo
* @return
*/
public static JSONObject receiptQuery(String orderNo){
JSONObject jsonParam = new JSONObject();
jsonParam.put("order_no", orderNo);//订单单号必填
JSONObject response = null;
String service = "order.receipt.query";
try {
log.info("拉卡拉回单查询接口请求参数：{}", JSONUtil.format(jsonParam));
response = soaClient.request(service, jsonParam);
log.info("拉卡拉回单查询接口返回：{}", JSONUtil.format(response));
} catch (Exception e) {
log.error(e.toString(), e);
return null;
} finally {
//此处保存请求日志信息
}
//此处返回请求结果
return Objects.requireNonNull(response).getJSONObject("response");
}
以上是关于获取电子回单的请求，截止到这里还没有问题
下面我们进行oss文件上传
/**
* 上传到oss
* @param path
* @param fileName
* @return
*/
public String fileUploadByFileNo(String path,String fileName){
log.info("文件在服务器地址:{}",path);
File file = new File(path);
if (cn.hutool.core.io.FileUtil.isEmpty(file)) {
log.error("文件不存在,filePath = {}", path);
throw new RuntimeException();
}
log.info("文件长度:{}",file.length());
// 上传到oss
FileInputStream fileInputStream = null;
String ossPath ;
try {
fileInputStream = new FileInputStream(file);
//上传oss工具类方法
ossPath = OSSUtil.uploadFile2OSS(fileInputStream, fileName);
if (StringUtils.isEmpty(ossPath)) {
log.error("oss文件上传失败,fileName={}",fileName);
throw new RuntimeException();
}
} catch (Exception e) {
log.error("oss文件流异常:",e);
throw new RuntimeException();
} finally {
IoUtil.close(fileInputStream);
}
return ossPath;
}
/**
* 上传到OSS服务器 如果同名文件会覆盖服务器上的
*
* @param inStream 文件流
* @param fileName 文件名称 包括后缀名
* @return 出错返回"" ,唯一MD5数字签名
*/
public static String uploadFile2OSS(InputStream inStream, String fileName){
OSSClient ossClient = OSSUtil.getOSSClient();
String ret = "";
try {
//创建上传Object的Metadata
ObjectMetadata objectMetadata = new ObjectMetadata();
objectMetadata.setContentLength(inStream.available());
objectMetadata.setCacheControl("no-cache");
objectMetadata.setHeader("Pragma","no-cache");
//通过文件名判断并获取文件的contentType
objectMetadata.setContentType(getContentType(fileNam e.substring (fileName.lastIndexOf("."))));
objectMetadata.setContentDisposition("inline;filename=" + fileName);
//上传文件
PutObjectResult putResult = ossClient.putObject(bucketName, filedir + fileName, inStream, objectMetadata);
//文件在oss地址
ret = getUrl(fileName),StandardCharsets.UTF_8.toString();
} catch (IOException e) {
logger.error(e.getMessage(), e);
} finally {
try {
if (inStream != null) {
inStream.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
return ret;
}
/**
* 获取文件URL
*
* @Title getUrl
* @param @param
* key
* @param @return
* @return URL
*/
public static String getUrl(String key) throws UnsupportedEncodingException {
if (key.indexOf("http") == -1) {
OSSClient server = new OSSClient(endpoint, accessKeyId, accessKeySecret);// 连接oss云存储服务器
// 设置URL过期时间为10年 3600l* 1000*24*365*10
Date expirations = new Date(new Date().getTime() + 1000 * 60 * 5);// url超时时间
// 生成URL
URL url = server.generatePresignedUrl(bucketName,filedir + key, expirations);
String strUrl = String.valueOf(url);
// 关闭client
server.shutdown();
return splitUrl(strUrl);
} else {
return splitUrl(key);
}
}
/**
* 切割url
*
* @param url
* @return
*/
public static String splitUrl(String url) {
if (url.indexOf("?Expires") != -1) {
return url.split("Expires")[0].substring(0,url.split("Expires")[0].length() -1 );
}
return url;
}
根据fileName获取URL时就会发现获取到地址不是这种
https://img-video.oss-cn-beijing.aliyuncs.com/测试中.pdf
而是一下这种
https://img-video.oss-cn-beijing.aliyuncs.com/%E5%BC%A0%E5%AE%81.pdf
开始的时候以为是自己没有指定上传文件编码导致的，但是在oss后台查看发现已经是中文名称路径了，所以就在上传时指定了编码格式为UTF-8
objectMetadata.setContentEncoding(StandardCharsets.UTF_8.toString());
后来发现并没有用，就去翻了一下oss源码，发现他们在上传时就已经指定了编码为UTF-8
源码路径com.aliyun.oss.internal.OSSOperation#createDefaultContext(com.aliyun.oss.HttpMethod, java.lang.String, java.lang.String)
那就只能是下载url时有问题了，继续查看源码发现文件下载时，又用UTF-8进行了编码
源码地址：
com.aliyun.oss.OSSClient#generatePresignedUrl(com.aliyun.oss.model.GeneratePresignedUrlRequest)
方法中在做http请求时
HttpUtil.paramToQueryString(params, "utf-8");
继续查看HttpUtil.paramToQueryString会发现他对url做了处理，如下
public static String urlEncode(String value, String encoding) {
if (value == null) {
return "";
} else {
try {
String encoded = URLEncoder.encode(value, encoding);
return encoded.replace("+", "%20").replace("*", "%2A").replace("~", "%7E").replace("/", "%2F");
} catch (UnsupportedEncodingException var3) {
throw new IllegalArgumentException(OSSUtils.OSS_RESOURCE_MANAGER.getString("FailedToEncodeUri"), var3);
}
}
}
截止这里就会明白了，因为在获取文件url时进行了URLEncoder.encode(value, encoding)所以获取的结果地址不是中文名称。
所以我们只需要在获取文件url地址后进行再进行编译即可，如下
ret = URLDecoder.decode(getUrl(fileName),StandardCharsets.UTF_8.toString());
会发现结果ret结果变成了我们想要的中文名称，如下
https://img-video.oss-cn-beijing.aliyuncs.com/测试中.pdf
![[牛客复盘] 牛客小白月赛70 20230407](https://img-blog.csdnimg.cn/9309f07f8302441dae756c184f7265f9.png)
