From d0095c429c3ad9a35a835e885e56ede7f8bbf78e Mon Sep 17 00:00:00 2001
From: gongquanlin <1025081659@qq.com>
Date: Fri, 17 Feb 2023 09:03:07 +0800
Subject: [PATCH] =?UTF-8?q?=E9=85=8D=E7=BD=AE=E5=B1=B1=E8=83=BD=E7=A7=81?=
 =?UTF-8?q?=E6=9C=89=E4=BB=93=E5=BA=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../order/consumer/utils/OpentextUtils.java   | 47 +++++++++++++++----
 pom.xml                                       |  4 +-
 2 files changed, 41 insertions(+), 10 deletions(-)

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 @@
                     <![CDATA[jdbc:mysql://10.1.2.148:3306/sales_manager?useUnicode=true&amp;characterEncoding=utf8&amp;useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;allowMultiQueries=true]]></logback.mysql.url>
                 <logback.mysql.user>dxhy</logback.mysql.user>
                 <logback.mysql.pwd>Dxhy@123</logback.mysql.pwd>
-                <repository.url>http://10.1.20.6:8081/nexus/content/groups/public</repository.url>
-                <pluginRepositories.url>http://10.1.20.6:8081/nexus/content/groups/public</pluginRepositories.url>
+                <repository.url>http://172.31.32.53:8081/repository/maven-public/</repository.url>
+                <pluginRepositories.url>http://172.31.32.53:8081/repository/maven-public/</pluginRepositories.url>
 
                 <distribution.repository.release.url>http://10.1.20.6:8081/nexus/content/repositories/releases
                 </distribution.repository.release.url>