UploadAction support to upload a inputStream with a file name in modu…

…le core/httpclient.

closes #72

core/httpclient/src/main/scala/com/webank/wedatasphere/linkis/httpclient/AbstractHttpClient.scala

@@ -14,10 +14,6 @@
  * limitations under the License.
  */
 
-/*
- * Created by ${USER} on ${DATE}.
- */
-
 package com.webank.wedatasphere.linkis.httpclient
 
 import java.io.{File, InputStream}
@@ -138,7 +134,7 @@ abstract class AbstractHttpClient(clientConfig: ClientConfig, clientName: String
     }
     var request = requestAction match {
       case upload: UploadAction =>
-        req.setContentType("multipart/form-data", Configuration.BDP_ENCODING.getValue).POST
+        req = req.setContentType("multipart/form-data", Configuration.BDP_ENCODING.getValue).POST
         if(upload.files != null && upload.files.nonEmpty) {
           val fs = upload.user.map(getFsByUser(_, new FsPath(upload.files.head._2)))
           upload.files.foreach { case (k, v) =>
@@ -157,7 +153,7 @@ abstract class AbstractHttpClient(clientConfig: ClientConfig, clientName: String
             val filePart = new FilePart(k, new PartSource{
               val length = v.available
               override def getLength: Long = length
-              override def getFileName: String = k
+              override def getFileName: String = upload.inputStreamNames.getOrDefault(k, k)
               override def createInputStream(): InputStream = v
             })
             req = req.addBodyPart(filePart)

core/httpclient/src/main/scala/com/webank/wedatasphere/linkis/httpclient/request/UploadAction.scala

@@ -14,10 +14,6 @@
  * limitations under the License.
  */
 
-/*
- * Created by ${USER} on ${DATE}.
- */
-
 package com.webank.wedatasphere.linkis.httpclient.request
 
 import scala.tools.nsc.interpreter.InputStream
@@ -30,15 +26,20 @@ import java.util
 trait UploadAction extends UserAction {
 
   /**
-    * The file to be uploaded, the key is the file name, and the value is the file path.
-    * 需要上传的文件，key为文件名，value为文件路径
+    * The file to be uploaded, the key is the parameter name, and the value is the file path.
+    * 需要上传的文件，key为参数名，value为文件路径
     */
   val files: util.Map[String, String]
   /**
-    * The input stream that needs to be uploaded, the key is the file name, and the value is the input stream.
-    * 需要上传的输入流，key为文件名，value为输入流
+    * The inputStream that needs to be uploaded, the key is the parameter name, and the value is the input stream.
+    * 需要上传的输入流，key为参数名，value为输入流
     */
   def inputStreams: util.Map[String, InputStream] = new util.HashMap[String, InputStream]()
+  /**
+    * The inputStream that needs to be uploaded, the key is the parameter name, and the value is the fileName of inputStream.
+    * 需要上传的输入流，key为参数名，value为输入流的文件名
+    */
+  def inputStreamNames: util.Map[String, String] = new util.HashMap[String, String]()
   def user: Option[String] = Option(getUser)
 
 }