package com.java110.core.context;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.DateUtil;
|
|
import java.util.Date;
|
import java.util.Map;
|
import java.util.UUID;
|
|
/**
|
* @author wux
|
* @create 2019-02-07 上午12:38
|
* @desc 订单通知数据封装对象
|
**/
|
public class OrderNotifyDataFlow extends AbstractOrderNotifyDataFlowContext {
|
|
|
protected OrderNotifyDataFlow(Date startDate, String code) {
|
super(startDate, code);
|
}
|
|
private String oId;
|
|
/**
|
* 构建 对象信息
|
* @param reqInfo
|
* @param headerAll
|
* @return
|
* @throws Exception
|
*/
|
public OrderNotifyDataFlow builder(String reqInfo, Map<String,String> headerAll) throws Exception{
|
|
//校验请求报文格式
|
Assert.isJsonObject(reqInfo,"当前报文不是有效json,请检查"+reqInfo);
|
this.setDataFlowId(UUID.randomUUID().toString().replace("-","").toLowerCase());
|
//赋值请求报文
|
this.setResJson(JSONObject.parseObject(reqInfo));
|
//赋值 请求头信息
|
this.setReqHeaders(headerAll);
|
|
|
//构建 订单信息
|
builderOrderResponse();
|
|
//构建订单项信息
|
builderOrderNotifyInfo();
|
|
return this;
|
}
|
|
/**
|
* 构建订单通知信息
|
*/
|
private void builderOrderNotifyInfo() throws Exception{
|
|
JSONObject tmpReqJson = this.getReqJson();
|
|
Assert.jsonObjectHaveKey(tmpReqJson,"business","没有包含business节点信息,"+tmpReqJson.toJSONString());
|
|
JSONObject tmpBusiness = tmpReqJson.getJSONObject("business");
|
|
this.setbId(tmpBusiness.getString("bId"));
|
this.setBusinessTypeCd(tmpBusiness.getString("businessTypeCd"));
|
|
Assert.jsonObjectHaveKey(tmpReqJson,"orders","没有包含orders节点信息,"+tmpReqJson.toJSONString());
|
|
JSONObject tmpOrders = tmpReqJson.getJSONObject("orders");
|
|
this.setTransactionId(tmpOrders.getString("transactionId"));
|
this.setResponseTime(DateUtil.getDefaultDateFromString(tmpOrders.getString("responseTime")));
|
this.setOrderTypeCd(tmpOrders.getString("orderTypeCd"));
|
this.setDataFlowId(tmpOrders.getString("dataFlowId"));
|
this.setBusinessType(tmpOrders.getString("businessType"));
|
}
|
|
/**
|
* 构建返回状态结果信息
|
*/
|
private void builderOrderResponse() {
|
|
JSONObject tmpReqJson = this.getReqJson();
|
|
Assert.jsonObjectHaveKey(tmpReqJson,"business","没有包含business节点信息,"+tmpReqJson.toJSONString());
|
|
JSONObject tmpBusiness = tmpReqJson.getJSONObject("business");
|
|
Assert.jsonObjectHaveKey(tmpBusiness,"response","没有包含response节点，"+tmpBusiness.toJSONString());
|
|
JSONObject tmpResponse = tmpBusiness.getJSONObject("response");
|
|
this.setCode(tmpResponse.getString("code"));
|
|
this.setMessage(tmpResponse.getString("message"));
|
|
|
}
|
|
public String getoId() {
|
return oId;
|
}
|
|
public void setoId(String oId) {
|
this.oId = oId;
|
}
|
}
|
