package com.java110.core.context;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import java.util.Date;
|
import java.util.Map;
|
|
/**
|
* 主键生成
|
* Created by wuxw on 2018/6/3.
|
*/
|
public class CodeDataFlow extends AbstractDataFlowContext {
|
|
|
|
/**
|
* 前缀
|
*/
|
private String prefix;
|
|
private String hostName;
|
|
private String port;
|
|
public String getPrefix() {
|
return prefix;
|
}
|
|
public void setPrefix(String prefix) {
|
this.prefix = prefix;
|
}
|
|
public String getHostName() {
|
return hostName;
|
}
|
|
public void setHostName(String hostName) {
|
this.hostName = hostName;
|
}
|
|
public String getPort() {
|
return port;
|
}
|
|
public void setPort(String port) {
|
this.port = port;
|
}
|
|
public CodeDataFlow(Date startDate, String code) {
|
super(startDate, code);
|
}
|
|
@Override
|
public CodeDataFlow builder(String reqInfo, Map<String, String> headerAll) throws Exception {
|
JSONObject reqInfoObj = JSONObject.parseObject(reqInfo);
|
this.setReqJson(reqInfoObj);
|
this.setReqData(reqInfo);
|
this.setTransactionId(reqInfoObj.getString("transactionId"));
|
this.setRequestTime(reqInfoObj.getString("requestTime"));
|
|
if (headerAll != null && !headerAll.isEmpty()){
|
this.headers.putAll(headerAll);
|
}
|
|
if(headerAll != null && headerAll.containsKey("hostName")) {
|
this.setHostName(headerAll.get("hostName"));
|
}
|
if(headerAll != null && headerAll.containsKey("port")) {
|
this.setPort(headerAll.get("port"));
|
}
|
this.setPrefix(reqInfoObj.getString("prefix"));
|
return this;
|
}
|
|
@Override
|
public Orders getOrder() {
|
return this;
|
}
|
}
|