old mode 100644
new mode 100755
| | |
|---|
| | | */ |
|---|
| | | public class CodeDataFlow extends AbstractDataFlowContext { |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 前缀 |
|---|
| | | */ |
|---|
| | |
|---|
| | | return port; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | public void setPort(String port) { |
|---|
| | | this.port = port; |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public CodeDataFlow builder(String reqInfo, Map<String, String> headerAll) throws Exception { |
|---|
| | | public CodeDataFlow doBuilder(String reqInfo, Map<String, String> headerAll) throws Exception { |
|---|
| | | JSONObject reqInfoObj = JSONObject.parseObject(reqInfo); |
|---|
| | | this.setReqJson(reqInfoObj); |
|---|
| | | this.setReqData(reqInfo); |
|---|
| | |
|---|
| | | this.setRequestTime(reqInfoObj.getString("requestTime")); |
|---|
| | | |
|---|
| | | if (headerAll != null && !headerAll.isEmpty()){ |
|---|
| | | this.headers.putAll(headerAll); |
|---|
| | | this.requestCurrentHeaders.putAll(headerAll); |
|---|
| | | this.requestHeaders.putAll(headerAll); |
|---|
| | | } |
|---|
| | | |
|---|
| | | if(headerAll != null && headerAll.containsKey("hostName")) { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public Orders getOrder() { |
|---|
| | | public IOrders getOrder() { |
|---|
| | | return this; |
|---|
| | | } |
|---|
| | | } |
|---|
