package com.by4cloud.platformx.business.invoice.utils;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.TypeReference;
|
|
import com.by4cloud.platformx.business.entity.invoice.BipResVo;
|
import com.by4cloud.platformx.business.entity.invoice.BipTokenVo;
|
import com.by4cloud.platformx.business.utils.SignHelper;
|
import lombok.RequiredArgsConstructor;
|
import org.apache.http.HttpEntity;
|
import org.apache.http.HttpResponse;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.entity.ContentType;
|
import org.apache.http.entity.mime.MultipartEntityBuilder;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.util.EntityUtils;
|
import org.apache.pdfbox.pdmodel.PDDocument;
|
import org.apache.pdfbox.pdmodel.PDPage;
|
import org.apache.pdfbox.pdmodel.PDPageContentStream;
|
import org.apache.pdfbox.pdmodel.common.PDRectangle;
|
import org.apache.pdfbox.pdmodel.graphics.image.PDImageXObject;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Component;
|
|
import javax.imageio.ImageIO;
|
import java.awt.image.BufferedImage;
|
import java.io.*;
|
import java.net.MalformedURLException;
|
import java.net.URL;
|
import java.net.URLConnection;
|
import java.net.URLDecoder;
|
import java.nio.file.Files;
|
import java.nio.file.Paths;
|
import java.security.InvalidKeyException;
|
import java.security.NoSuchAlgorithmException;
|
import java.util.HashMap;
|
import java.util.Map;
|
import java.util.concurrent.TimeUnit;
|
|
@Component
|
@RequiredArgsConstructor
|
public class BipHttpUtil {
|
private static final Logger log = LoggerFactory.getLogger(BipHttpUtil.class);
|
@Value("${bip.ip}")
|
private String ip;
|
@Value("${bip.filePath}")
|
private String bipFilePath;
|
|
@Value("${bip.appKey}")
|
private String appKey;
|
@Value("${bip.appSecret}")
|
private String appSecret;
|
private final RedisTemplate redisTemplate;
|
public String getToken(){
|
String redisKey="BIP_TOKEN:";
|
// String appKey = "800b2805c5584f0abb8705acbe487dc5";
|
// String appSecret = "59ba72c62a6a27203d7e517787a738be89ba55cb";
|
redisKey+=appKey;
|
if (redisTemplate.hasKey(redisKey)){
|
return (String) redisTemplate.opsForValue().get(redisKey);
|
}
|
for (int i=0;i<10;i++){
|
long timestamp = System.currentTimeMillis();
|
Map<String,Object> paramMap = new HashMap<>();
|
paramMap.put("appKey",appKey);
|
paramMap.put("timestamp",timestamp);
|
String signature = null;
|
try {
|
signature = SignHelper.sign(paramMap,appSecret);
|
} catch (NoSuchAlgorithmException e) {
|
throw new RuntimeException(e);
|
} catch (UnsupportedEncodingException e) {
|
throw new RuntimeException(e);
|
} catch (InvalidKeyException e) {
|
throw new RuntimeException(e);
|
}
|
String url = ip+BipApiEnum.获取TOKEN.getUrl()+"?appKey="+appKey+"×tamp="+timestamp+"&signature="+signature;
|
String result = HttpUtil.get(url);
|
if (result==null){
|
continue;
|
}
|
|
try {
|
BipResVo<BipTokenVo> tokenVo = JSON.parseObject(result,new TypeReference<BipResVo<BipTokenVo>>(){});
|
if (tokenVo.getCode().equals("00000")){
|
redisTemplate.opsForValue().set(redisKey,tokenVo.getData().getAccess_token(),tokenVo.getData().getExpire()-10, TimeUnit.SECONDS);
|
System.out.println("-------bipToken:"+tokenVo.getData().getAccess_token());
|
return tokenVo.getData().getAccess_token();
|
}
|
}catch (Exception e){
|
throw new RuntimeException("bip访问接口异常,请检查网络是否正常");
|
}
|
|
|
}
|
return null;
|
|
}
|
public String post(BipApiEnum apiEnum,Object data){
|
log.warn("-------------bipPost-url:"+ip+apiEnum.getUrl()+"?access_token="+getToken());
|
log.warn("-------------bipPost-req:"+JSONUtil.toJsonStr(data));
|
try {
|
String result = HttpRequest.post(ip+apiEnum.getUrl()+"?access_token="+getToken())
|
.body(JSONUtil.toJsonStr(data))
|
.timeout(10*3000)
|
.execute().body();
|
log.warn("-------------bipPost-res:"+result);
|
return result;
|
}catch (Exception e){
|
e.printStackTrace();
|
log.error("-------------bipPost-res:请求失败");
|
throw new RuntimeException("BIP接口超时,请检查网络后重新尝试");
|
}
|
}
|
|
public String postUploadFile(String businessId,String fileLocalPath){
|
// 创建HttpClient对象
|
CloseableHttpClient httpClient = HttpClients.createDefault();
|
String param = "?access_token="+getToken()+"&businessType=yonbip-fi-earapbill&businessId="+businessId;
|
// 创建HttpPost对象，并设置URL
|
HttpPost httpPost = new HttpPost(ip+BipApiEnum.BIP文件上接口.getUrl()+param);
|
// 创建MultipartEntityBuilder对象，并设置文件和其他参数
|
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
|
builder.addBinaryBody("files", new File(bipFilePath+fileLocalPath), ContentType.MULTIPART_FORM_DATA, fileLocalPath);
|
// 将MultipartEntityBuilder构建的实体对象设置到HttpPost对象中
|
HttpEntity entity = builder.build();
|
httpPost.setEntity(entity);
|
// 执行HttpPost请求，获取响应
|
HttpResponse response = null;
|
String responseBody = null;
|
try {
|
response = httpClient.execute(httpPost);
|
// 解析响应
|
HttpEntity responseEntity = response.getEntity();
|
responseBody= EntityUtils.toString(responseEntity);
|
System.out.println(responseBody);
|
|
// 关闭HttpClient
|
httpClient.close();
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
return responseBody;
|
}
|
|
public String postUploadFileUrl(String businessId,String fileLocalPath){
|
URL url = null;
|
InputStream stream = null;
|
String lastThreeChars = fileLocalPath.substring(fileLocalPath.length() - 3);
|
String lowLast = lastThreeChars.toLowerCase();
|
if (lowLast.equals("png") || lowLast.equals("jpeg") || lowLast.equals("jpg")) {
|
stream = pngToPdf(fileLocalPath, lowLast);
|
} else {
|
try {
|
url = new URL(fileLocalPath);
|
URLConnection connection = url.openConnection();
|
stream = connection.getInputStream();
|
} catch (MalformedURLException e) {
|
throw new RuntimeException(e);
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
}
|
// 创建HttpClient对象
|
CloseableHttpClient httpClient = HttpClients.createDefault();
|
String param = "?access_token="+getToken()+"&businessType=yonbip-fi-earapbill&businessId="+businessId;
|
// 创建HttpPost对象，并设置URL
|
HttpPost httpPost = new HttpPost(ip+BipApiEnum.BIP文件上接口.getUrl()+param);
|
// 创建MultipartEntityBuilder对象，并设置文件和其他参数
|
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
|
// 将MultipartEntityBuilder构建的实体对象设置到HttpPost对象中
|
builder.addBinaryBody("files", stream, ContentType.MULTIPART_FORM_DATA, "MX_"+System.currentTimeMillis()+".pdf");
|
HttpEntity entity = builder.build();
|
httpPost.setEntity(entity);
|
// 执行HttpPost请求，获取响应
|
HttpResponse response = null;
|
String responseBody = null;
|
try {
|
response = httpClient.execute(httpPost);
|
// 解析响应
|
HttpEntity responseEntity = response.getEntity();
|
responseBody= EntityUtils.toString(responseEntity);
|
System.out.println(responseBody);
|
|
// 关闭HttpClient
|
httpClient.close();
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
return responseBody;
|
}
|
|
public InputStream pngToPdf(String filePath,String format){
|
//String bipFilePath = "/Users/kongdeqiang/Desktop/";
|
long l = System.currentTimeMillis();
|
InputStream stream = null;
|
try {
|
// 加载PNG图片
|
URL url1 = new URL(filePath);
|
InputStream inputStream = url1.openStream();
|
OutputStream out = new FileOutputStream(bipFilePath+format+l+"."+format);
|
int bytesRead = 0;
|
byte[] buffer = new byte[8192];
|
while ((bytesRead = inputStream.read(buffer,0,8192)) !=-1){
|
out.write(buffer,0,bytesRead);
|
}
|
out.close();
|
inputStream.close();
|
|
File file = new File(bipFilePath+format+l+"."+format);
|
BufferedImage image = ImageIO.read(file);
|
ByteArrayOutputStream baos = new ByteArrayOutputStream();
|
ImageIO.write(image, format, baos);
|
byte[] bytes = baos.toByteArray();
|
// 创建一个PDF文档
|
PDDocument document = new PDDocument();
|
PDPage page = new PDPage(new PDRectangle(image.getWidth(), image.getHeight()));
|
document.addPage(page);
|
|
// 将图片转换为PDF中的对象
|
PDImageXObject pdImage = PDImageXObject.createFromByteArray(document, bytes, format);
|
PDPageContentStream contents = new PDPageContentStream(document, page);
|
contents.drawImage(pdImage, 0, 0, image.getWidth(), image.getHeight());
|
contents.close();
|
|
// 保存PDF文档
|
document.save(bipFilePath+format+l+".pdf");
|
document.close();
|
stream = Files.newInputStream(Paths.get(bipFilePath+format+l+".pdf"));
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return stream;
|
}
|
|
|
public String postDeleteFile(String businessId, String fid){
|
// 创建HttpClient对象
|
CloseableHttpClient httpClient = HttpClients.createDefault();
|
String param = "?access_token="+getToken()+"&businessType=yonbip-fi-earapbill&businessId="+businessId+"&fid="+fid;
|
// 创建HttpPost对象，并设置URL
|
HttpPost httpPost = new HttpPost(ip+BipApiEnum.BIP文件删除接口.getUrl()+param);
|
// 执行HttpPost请求，获取响应
|
HttpResponse response = null;
|
String responseBody = null;
|
try {
|
response = httpClient.execute(httpPost);
|
// 解析响应
|
HttpEntity responseEntity = response.getEntity();
|
responseBody= EntityUtils.toString(responseEntity);
|
System.out.println(responseBody);
|
|
// 关闭HttpClient
|
httpClient.close();
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
return responseBody;
|
}
|
|
public static void main1(String[] args) {
|
/* File file = new File("/Users/kongdeqiang/Desktop/1725590083564FFDXJS.pdf");
|
Map<String,Object> paramMap = new HashMap<>();
|
paramMap.put("access_token","");
|
paramMap.put("businessType","yonbip-fi-earapbill");
|
paramMap.put("businessId","");
|
paramMap.put("file",file);
|
Map<String,Object> dataBody = new HashMap<>();
|
String result = HttpRequest.post("https://bip01.res.jzeg.cn"+BipApiEnum.BIP文件上接口.getUrl())
|
.form(paramMap)
|
.timeout(10*1000)
|
.execute().body();
|
System.out.println(result);*/
|
}
|
|
public static void main(String[] args) throws Exception {
|
//正式
|
// String appKey = "800b2805c5584f0abb8705acbe487dc5";
|
// String appSecret = "59ba72c62a6a27203d7e517787a738be89ba55cb";
|
//测试
|
// String appKey = "91d28a4b776a4ab992db225958cf2d93";
|
// String appSecret = "77abbe9a3bc647ccf4a2a08629a7a0316ffff830";
|
// for (int i=0;i<100;i++){
|
// long timestamp = System.currentTimeMillis();
|
// Map<String,Object> paramMap = new HashMap<>();
|
// paramMap.put("appKey",appKey);
|
// paramMap.put("timestamp",timestamp);
|
// String signature = SignHelper.sign(paramMap,appSecret);
|
// System.out.println("signature:"+signature);
|
// String url = "https://bip.res.jzeg.cn"+BipApiEnum.获取TOKEN.getUrl()+"?appKey="+appKey+"×tamp="+timestamp+"&signature="+signature;
|
// System.out.println(url);
|
// String result = HttpUtil.get(url);
|
// System.out.println(result);
|
// Thread.sleep(300);
|
// }
|
|
//InputStream pdf = BipHttpUtil.pngToPdf("/Users/kongdeqiang/Desktop/WechatIMG316.png", "png");
|
|
|
}
|
}
|
