package jnpf.util;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.Method;
|
import jnpf.model.YozoParams;
|
import jnpf.util.context.SpringContext;
|
import jnpf.yozo.client.AppAuthenticator;
|
import jnpf.yozo.client.UaaAppAuthenticator;
|
import jnpf.yozo.constants.EnumResultCode;
|
import jnpf.yozo.constants.UaaConstant;
|
import jnpf.yozo.utils.DefaultResult;
|
import jnpf.yozo.utils.IResult;
|
import lombok.Cleanup;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.entity.ContentType;
|
import org.apache.http.entity.mime.HttpMultipartMode;
|
import org.apache.http.entity.mime.MultipartEntityBuilder;
|
import org.apache.http.entity.mime.content.FileBody;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.util.EntityUtils;
|
import org.springframework.stereotype.Component;
|
|
import java.io.File;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.nio.charset.StandardCharsets;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 文件预览编辑工具类
|
*
|
* @author JNPF开发平台组
|
* @version V3.1.0
|
* @copyright 引迈信息技术有限公司（https://www.jnpfsoft.com）
|
* @date 2021/5/13
|
*/
|
@Slf4j
|
@Component
|
public class YozoUtils {
|
|
|
private final YozoParams yozoParams = SpringContext.getBean(YozoParams.class);
|
|
/**
|
* 生成签名
|
*
|
* @param appId
|
* @param secret
|
* @param params
|
* @return
|
*/
|
public IResult<String> generateSign(String appId, String secret, Map<String, String[]> params) {
|
AppAuthenticator authenticator = new UaaAppAuthenticator(UaaConstant.SIGN, null, UaaConstant.APPID);
|
try {
|
String[] appIds = params.get(UaaConstant.APPID);
|
if (appIds == null || appIds.length != 1 || StringUtils.isEmpty(appIds[0])) {
|
params.put(UaaConstant.APPID, new String[]{appId});
|
}
|
String sign = authenticator.generateSign(secret, params);
|
return DefaultResult.successResult(sign);
|
} catch (Exception e) {
|
return DefaultResult.failResult(EnumResultCode.E_GENERATE_SIGN_FAIL.getInfo());
|
}
|
}
|
|
/**
|
* 获取文件名
|
*
|
* @param fileName
|
* @param templateType
|
* @return
|
*/
|
public String getFileName(String fileName, String templateType) {
|
String suffix;
|
switch (templateType) {
|
case "1":
|
suffix = ".doc";
|
break;
|
case "2":
|
suffix = ".docx";
|
break;
|
case "3":
|
suffix = ".ppt";
|
break;
|
case "4":
|
suffix = ".pptx";
|
break;
|
case "5":
|
suffix = ".xls";
|
break;
|
case "6":
|
suffix = ".xlsx";
|
break;
|
default:
|
suffix = null;
|
}
|
if (suffix == null) {
|
return null;
|
}
|
return fileName + suffix;
|
}
|
|
/**
|
* 使用httpclint 发送文件
|
*
|
* @param file 上传的文件
|
* @author: qingfeng
|
* @date: 2019-05-27
|
*/
|
public String uploadFile(String url, File file, String appId, String sign) {
|
String result = "";
|
//构建HttpClient对象
|
CloseableHttpResponse response = null;
|
//构建POST请求
|
HttpPost httpPost = new HttpPost(url);
|
try {
|
@Cleanup CloseableHttpClient client = HttpClients.createDefault();
|
//构建文件体
|
String fileName = file.getName();
|
FileBody fileBody = new FileBody(file, ContentType.MULTIPART_FORM_DATA, fileName);
|
HttpEntity httpEntity = MultipartEntityBuilder
|
.create()
|
.setMode(HttpMultipartMode.BROWSER_COMPATIBLE)
|
.addPart("file", fileBody)
|
.addTextBody("appId", appId)
|
.addTextBody("sign", sign)
|
.build();
|
httpPost.setEntity(httpEntity);
|
// 执行http请求
|
response = client.execute(httpPost);
|
result = EntityUtils.toString(response.getEntity(), "utf-8");
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return result;
|
}
|
|
/**
|
* 下载文件到指定目录
|
*
|
* @param fileUrl
|
* @param savePath
|
* @throws Exception
|
*/
|
public void downloadFile(String fileUrl, String savePath) throws IOException {
|
File file = new File(XSSEscape.escapePath(savePath));
|
//判断文件是否存在，不存在则创建文件
|
if (!file.exists()) {
|
boolean newFile = file.createNewFile();
|
if (newFile) {
|
log.info("创建成功");
|
} else {
|
log.info("创建失败");
|
}
|
}
|
HttpRequest request = HttpRequest.of(fileUrl).method(Method.GET);
|
request.setConnectionTimeout(6000);
|
request.setReadTimeout(6000);
|
try {
|
request.execute().body();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 上传文件到永中
|
*
|
* @param
|
* @return
|
*/
|
public String uploadFileInPreview(InputStream inputStream, String fileName) throws IOException {
|
//获取签名
|
Map<String, String[]> parameter = new HashMap<>();
|
parameter.put("appId", new String[]{yozoParams.getAppId()});
|
String sign = this.generateSign(yozoParams.getAppId(), yozoParams.getAppKey(), parameter).getData();
|
String url = "http://dmc.yozocloud.cn/api/file/upload?appId=" + yozoParams.getAppId() + "&sign=" + sign;
|
|
|
String result = "";
|
HttpEntity httpEntity = null;
|
HttpEntity responseEntity = null;
|
@Cleanup CloseableHttpClient httpClient = HttpClients.createDefault();
|
try {
|
|
HttpPost httpPost = new HttpPost(url);
|
MultipartEntityBuilder multipartEntityBuilder = MultipartEntityBuilder.create();
|
multipartEntityBuilder.setCharset(StandardCharsets.UTF_8);
|
multipartEntityBuilder.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);//加上此行代码解决返回中文乱码问题
|
multipartEntityBuilder.addBinaryBody("file", inputStream, ContentType.MULTIPART_FORM_DATA, fileName);
|
|
httpEntity = multipartEntityBuilder.build();
|
httpPost.setEntity(httpEntity);
|
CloseableHttpResponse response = httpClient.execute(httpPost);
|
responseEntity = response.getEntity();
|
result = EntityUtils.toString(responseEntity, StandardCharsets.UTF_8);
|
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
} finally {
|
httpClient.close();
|
if (inputStream != null) {
|
inputStream.close();
|
}
|
|
}
|
return result;
|
}
|
}
|
