diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/OpentextUtils.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/OpentextUtils.java index 7907fa58..edd01663 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/OpentextUtils.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/utils/OpentextUtils.java @@ -1,5 +1,6 @@ package com.dxhy.order.consumer.utils; +import lombok.SneakyThrows; import org.apache.http.HttpEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpPost; @@ -15,6 +16,8 @@ import org.springframework.stereotype.Component; import java.io.File; import java.io.FileInputStream; +import java.io.InputStream; +import java.nio.file.Files; /** * @Description: 文件存储工具类 @@ -26,23 +29,51 @@ import java.io.FileInputStream; public class OpentextUtils { public static String url; + @Value("${order.opentext.url}") - public void setUrl(String urlParam){ - url=urlParam; + public void setUrl(String urlParam) { + url = urlParam; } + public static String userName; + @Value("${order.opentext.userName}") - public void setUserName(String userNameParam){ + public void setUserName(String userNameParam) { userName = userNameParam; } + public static String password; + @Value("${order.opentext.password}") - public void setPassword(String passwordParam){ + public void setPassword(String passwordParam) { password = passwordParam; } - public static String uploadFile(){ - String sTestFile = "C:\\这是一个测试.txt"; + @SneakyThrows + public static String uploadFile(InputStream inputStream, String fileName) { + CloseableHttpClient httpClient = HttpClients.createDefault(); + + HttpPost uploadFile = new HttpPost(url); + + // set header, USEROTAS and INIT1234 are fixed. + uploadFile.setHeader("USERNAME", userName); + uploadFile.setHeader("PASSWORD", password); + + MultipartEntityBuilder builder = MultipartEntityBuilder.create(); + builder.setMode(HttpMultipartMode.RFC6532); + + // add file to request + builder.addBinaryBody("file", inputStream, ContentType.DEFAULT_BINARY, fileName); + + HttpEntity multipart = builder.build(); + uploadFile.setEntity(multipart); + + CloseableHttpResponse response = httpClient.execute(uploadFile); + HttpEntity responseEntity = response.getEntity(); + return EntityUtils.toString(responseEntity, "UTF-8"); + } + + public static String uploadFile(String path) { CloseableHttpClient httpClient = HttpClients.createDefault(); HttpPost uploadFile = new HttpPost(url); @@ -55,9 +86,9 @@ public class OpentextUtils { builder.setMode(HttpMultipartMode.RFC6532); // add file to request - File f = new File(sTestFile); + File f = new File(path); try { - builder.addBinaryBody("file", new FileInputStream(f), ContentType.DEFAULT_BINARY, f.getName()); + builder.addBinaryBody("file", Files.newInputStream(f.toPath()), ContentType.DEFAULT_BINARY, f.getName()); HttpEntity multipart = builder.build(); uploadFile.setEntity(multipart); diff --git a/pom.xml b/pom.xml index 8ea00fe4..2b05b5a5 100644 --- a/pom.xml +++ b/pom.xml @@ -679,8 +679,8 @@ dxhy Dxhy@123 - http://10.1.20.6:8081/nexus/content/groups/public - http://10.1.20.6:8081/nexus/content/groups/public + http://172.31.32.53:8081/repository/maven-public/ + http://172.31.32.53:8081/repository/maven-public/ http://10.1.20.6:8081/nexus/content/repositories/releases