Fx.http

// 下载文件的InputStream调用第三方接口上传到客户系统
def(Boolean err, Object fileData, String msg) = Fx.file.downloadStream("N_202111_29_6eb71dca766944c582b87e6a5213f3a3.docx")
if (err) {
  log.info("downloadStream error :" + msg)
} else {
  log.info("file data :" + fileData)
}
InputStream inputStream = fileData['inputStream'] as InputStream

//1、 multipart/form-data 的body请求格式，可以用来传输文件
MultipartBody body = MultipartBody.builder()
  .addPart("name", "tom")
  .addPart("id", "1234")
  .addPart("file", inputStream, '测试附件.docx', 'application/octet-stream')
  .build();
//2、或者使用InputStreamBody传输文件
//InputStreamBody body = InputStreamBody.builder()
//  .content(inputStream)
//  .build()
//3、application/json 的body请求格式
// Map map = ["a": 1, "b": 2]
// StringBody body = StringBody.builder().content(map).build()

//4、 application/x-www-form-urlencoded 的body请求格式
// FormBody body = FormBody.builder()
//   .field("a", "qweasd")
//   .field("b", 12423)
//   .field("c", "hello")
//   .build()

Request request = Request.builder()
  .method("POST")
  .url('http://httpbin.org/post')
  .timeout(7000)
  .retryCount(0)
  .header("Content-Type", "multipart/form-data")
  .body(body)
  .build()

def(Boolean error, HttpResult result, String message) = Fx.http.execute(request)
if (error || result.statusCode != 200) {
  log.info("error :" + message)
} else {
  log.info(result)
}

def (Boolean error,HttpResult result, String errorMessage) = Fx.http.get("http://www.fxiaoke.com", ["X-token":"myToken"], 2000, true, 2, false)
if (error || result.statusCode != 200) {
  log.info("error :" + errorMessage)
} else {
  log.info(result)
}

def (Boolean error,HttpResult result,String errorMessage) = Fx.http.post("http://www.fxiaoke.com", ["X-token":"myToken"], ["id":1], 2000, true, 2, false)
if (error || result.statusCode != 200) {
  log.info("error :" + errorMessage)
} else {
  log.info(result)
}

def (Boolean error, HttpResult result, String errorMessage) = Fx.http.options("http://www.fxiaoke.com", ["X-token":"myToken"], 2000, true, 2)
HttpResult result = (HttpResult) ret.getData();
if (ret.isError() || result.getStatusCode() != 200) {
    log.info(ret.message());
} else {
    log.info(ret.getData());
}

def (Boolean error, HttpResult result, String errorMessage) = Fx.http.put("http://www.fxiaoke.com", ["X-token":"myToken"], ["id":1], 2000, true, 2)
if (error || result.statusCode != 200) {
  log.info("error :" + errorMessage)
} else {
  log.info(result)
}

def (Boolean error, HttpResult result, String errorMessage) = Fx.http.delete("http://www.fxiaoke.com", ["X-token":"myToken"], ["id":1], 2000, true, 2)
if (error || result.statusCode != 200) {
  log.info("error :" + errorMessage)
} else {
  log.info(result)
}

def (Boolean error, HttpResult result, String errorMessage) = Fx.http.patch("http://www.fxiaoke.com", ["X-token":"myToken"], ["id":1], 2000, true, 2)
if (error || result.statusCode != 200) {
  log.info("error :" + errorMessage)
} else {
  log.info(result)
}

// 旧方式的调用方法
// String content = '<soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope" xmlns:tem="http://tempuri.org/"><soap:Header/><soap:Body><tem:CalcPrecoFAC><tem:nCdServico>41106</tem:nCdServico><tem:nVlPeso>10</tem:nVlPeso><tem:strDataCalculo>22/11/2018</tem:strDataCalculo></tem:CalcPrecoFAC></soap:Body></soap:Envelope>'
// String url = 'http://ws.correios.com.br/calculador/CalcPrecoPrazo.asmx?wsdl'
// def(Boolean error, HttpResult result, String message) = Fx.http.post(url, ["Content-Type": "application/soap+xml"], content)
// if (error) {
//   log.info("error :" + message)
// } else {
//   log.info(result)
// }

// 返回结果是个也是个xml需要自己解析内容
// 结果：<?xml version="1.0" encoding="utf-8"?><soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema"><soap:Body><CalcPrecoFACResponse xmlns="http://tempuri.org/"><CalcPrecoFACResult><Servicos><cServico><Codigo>41106</Codigo><Valor>0</Valor><Erro>-1</Erro><MsgErro>Codigo de servico invalido.</MsgErro></cServico></Servicos></CalcPrecoFACResult></CalcPrecoFACResponse></soap:Body></soap:Envelope>// 新的方式不需要自己解析Repsone Body
// 新方式一：
Map map = [
  "nCdServico":"41106",
  "nVlPeso":"10",
  "strDataCalculo":"22/11/2018"
]
SoapRequest request = SoapRequest.builder()
  .url("http://ws.correios.com.br/calculador/CalcPrecoPrazo.asmx?wsdl")
  .namespace("http://tempuri.org/")
  .localPart("CalcPrecoFAC")
  .prefix("tem")
  .bodyParams(map)
  .build();
def(Boolean error, HttpResult result, String message) = Fx.http.postSoap(request)
if (error || result.statusCode != 200) {
  log.info("error :" + result)
} else {
  log.info(result.getContent())
}

// 新方式二：
String xml = '''<soap:Envelope
    xmlns:soap="http://www.w3.org/2003/05/soap-envelope"
    xmlns:tem="http://tempuri.org/"><soap:Header/><soap:Body><tem:CalcPrecoFAC><tem:nCdServico>41106</tem:nCdServico><tem:nVlPeso>10</tem:nVlPeso><tem:strDataCalculo>22/11/2018</tem:strDataCalculo></tem:CalcPrecoFAC></soap:Body></soap:Envelope>'''
SoapRequest request = SoapRequest.builder()
  .url("http://ws.correios.com.br/calculador/CalcPrecoPrazo.asmx?wsdl")
  .fromXml(xml)
  .build();
def(Boolean error, HttpResult result, String message) = Fx.http.postSoap(request)
if (error || result.statusCode != 200) {
  log.info("error :" + result)
} else {
  log.info(result.getContent())
}
//结果： {CalcPrecoFACResponse={CalcPrecoFACResult={Servicos={cServico={MsgErro=Codigo de servico invalido., Codigo=41106, Erro=-1, Valor=0}}}}}