配置山能私有仓库

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 static String userName;
+
     @Value("${order.opentext.userName}")
     public void setUserName(String userNameParam) {
         userName = userNameParam;
     }
+
     public static String password;
+
     @Value("${order.opentext.password}")
     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);

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>