package com.fzzy.push.gd2020.v2;
|
|
import com.fzzy.api.data.AuthToken;
|
import com.fzzy.api.entity.Api1102;
|
import com.fzzy.api.entity.ApiConfs;
|
import com.fzzy.push.gd2020.GDResult;
|
import com.fzzy.push.gd2020.GDUtils;
|
import com.fzzy.push.gd2020.InvokeResult;
|
import com.fzzy.push.gd2020.JaxbUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.cxf.endpoint.Client;
|
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
|
|
import javax.xml.namespace.QName;
|
|
/**
|
* @Desc: 库点信息-数据接口
|
* @author: shaoxiang.zheng
|
* @update-time: 2022/10/10
|
*/
|
|
@Slf4j
|
public class StoreLocationWebService {
|
|
public static StoreLocationWebService newInstance() {
|
return new StoreLocationWebService();
|
}
|
|
public String xml_StoreLocationWebService = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"cfgl_store_location\"><kddm desc=\"库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{kddm}</kddm><kqbm desc=\"库点编码\" type=\"varchar\" length=\"21\" requir=\"必填\">{kqbm}</kqbm><kdmc desc=\"库点名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{kdmc}</kdmc><kdwd desc=\"库点纬度\" type=\"decimal\" length=\"10\" requir=\"必填\">{kdwd}</kdwd><kdjd desc=\"库点经度\" type=\"decimal\" length=\"10\" requir=\"必填\">{kdjd}</kdjd><kdxzqhmc desc=\"库点行政区划名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{kdxzqhmc}</kdxzqhmc><kdxzqydm desc=\"库点行政区划代码\" type=\"int\" length=\"12\" requir=\"必填\">{kdxzqydm}</kdxzqydm><cfs desc=\"仓房数\" type=\"int\" length=\"12\" requir=\"必填\">{cfs}</cfs><ygs desc=\"油罐数\" type=\"int\" length=\"12\" requir=\"必填\">{ygs}</ygs><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><kdsjcr desc=\"库点设计仓容\" type=\"decimal\" length=\"12\" requir=\"必填\">{kdsjcr}</kdsjcr><kqcq desc=\"库区产权\" type=\"varchar\" length=\"1\" requir=\"必填\">{kqcq}</kqcq><yxcr desc=\"有效仓容\" type=\"Decimal\" length=\"20\" requir=\"必填\">{yxcr}</yxcr><yxgr desc=\"有效罐容\" type=\"Decimal\" length=\"20\" requir=\"必填\">{yxgr}</yxgr><zdmj desc=\"占地面积\" type=\"decimal\" length=\"12\" requir=\"必填\">{zdmj}</zdmj><czbz desc=\"操作标记\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><kqdz desc=\"库区地址\" type=\"varchar\" length=\"128\" requir=\"可选\">{kqdz}</kqdz><kdssqx desc=\"库点所属区县\" type=\"int\" length=\"12\" requir=\"可选\">{kdssqx}</kdssqx></row></root>";
|
|
private String wsdl = "/storeLocationWebService?wsdl";//填写调用库点信息接口服务
|
private String method = "storeLocationSaveRecordDetail";// 填写数据方法名
|
private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间
|
|
|
public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1102 data) {
|
InvokeResult invokeResult = new InvokeResult();
|
|
ClassLoader cl = Thread.currentThread().getContextClassLoader();
|
|
|
String url = conf.getApiUrl() + wsdl; // 填写调用库点信息接口服务
|
|
|
Thread.currentThread().setContextClassLoader(cl);
|
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
|
Client client = dcf.createClient(url);
|
QName name = new QName(nameSpace, method);
|
Object[] objects;
|
|
try {
|
String xmlStr = storeLocationWebServiceXml(data);// 获取接口的输入报文，根据需要填写相应的报文
|
|
log.debug("------xmlStr--{}", xmlStr);
|
|
objects = client.invoke(name, new Object[]{authToken.getToken(), xmlStr});
|
|
log.debug("-----------返回信息---{}", objects[0].toString());
|
|
invokeResult = JaxbUtil.converyToJavaBean(objects[0].toString(), InvokeResult.class);
|
|
} catch (Exception e) {
|
log.error("----执行异常----{}", e);
|
invokeResult.setCode(GDResult.CODE_500.getCode());
|
invokeResult.setData("后端服务执行异常：+" + e.getMessage());
|
return invokeResult;
|
}
|
|
|
return invokeResult;
|
}
|
|
/**
|
* 报文获取-- 替换数据
|
*
|
* @param data
|
* @return
|
*/
|
|
private String storeLocationWebServiceXml(Api1102 data) {
|
String xmlStr = xml_StoreLocationWebService;
|
|
xmlStr = xmlStr.replace("{kqbm}", GDUtils.formatStr(data.getKqdm()));//库区编码 -- 单位代码
|
|
xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码
|
xmlStr = xmlStr.replace("{kdmc}", GDUtils.formatStr(data.getKqmc()));//库点名称
|
xmlStr = xmlStr.replace("{kdwd}", GDUtils.formatNum(data.getWd()));//库点纬度
|
xmlStr = xmlStr.replace("{kdjd}", GDUtils.formatNum(data.getJd()));//库点经度
|
xmlStr = xmlStr.replace("{kdxzqhmc}", GDUtils.formatStr(data.getXzqhmc()));// 库点行政区划名称
|
xmlStr = xmlStr.replace("{kdxzqydm}", GDUtils.formatStr(data.getXzqhdm()));//库点行政区划代码
|
|
xmlStr = xmlStr.replace("{kqdz}", GDUtils.formatStr(data.getKqdz()));//库区地址
|
xmlStr = xmlStr.replace("{kqcq}", GDUtils.formatStr(data.getKqcq()));//库区产权
|
xmlStr = xmlStr.replace("{kdsjcr}", GDUtils.formatNum(data.getYxcr()));// 库点设计仓容
|
xmlStr = xmlStr.replace("{yxcr}", GDUtils.formatNum(data.getYxcr()));//有效仓容
|
xmlStr = xmlStr.replace("{yxgr}", GDUtils.formatNum(data.getYxgr()));//有效罐容
|
xmlStr = xmlStr.replace("{zdmj}", GDUtils.formatNum(data.getZdmj()));//占地面积
|
xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志
|
xmlStr = xmlStr.replace("{ygs}", GDUtils.formatNum(data.getYgs()));//油罐数
|
xmlStr = xmlStr.replace("{cfs}", GDUtils.formatNum(data.getCfs()));//仓容数
|
xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd"));//最后更新时间
|
|
xmlStr = xmlStr.replace("{kdssqx}", "");// 库点所属区县
|
|
return xmlStr;
|
}
|
|
|
}
|
