package com.fzzy.push.gd2020.v2;
|
|
import com.fzzy.api.data.AuthToken;
|
import com.fzzy.api.entity.Api1103;
|
import com.fzzy.api.entity.Api1104;
|
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: Andy
|
* @update-time: 2022/10/15
|
*/
|
@Slf4j
|
public class GranaryWebService {
|
|
public static GranaryWebService newInstance() {
|
return new GranaryWebService();
|
}
|
|
public String xml_webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"cfgl_granary\"><kddm desc=\"库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{kddm}</kddm><cfmc desc=\"仓房名称\" type=\"varchar\" length=\"30\" requir=\"必填\">{cfmc}</cfmc><ajmc desc=\"廒间名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{ajmc}</ajmc><ajbh desc=\"廒间编码\" type=\"varchar\" length=\"20\" requir=\"必填\">{ajbh}</ajbh><ajsjcr desc=\"廒间设计仓容\" type=\"decimal\" length=\"20\" requir=\"必填\">{ajsjcr}</ajsjcr><ajzt desc=\"廒间状态\" type=\"varchar\" length=\"50\" requir=\"必填\">{ajzt}</ajzt><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><ajsjcrong desc=\"廒间实际仓容\" type=\"decimal\" length=\"8\" requir=\"必填\">{ajsjcrong}</ajsjcrong><ajjd desc=\"廒间经度\" type=\"decimal\" length=\"12\" requir=\"必填\">{ajjd}</ajjd><ajwd desc=\"廒间纬度\" type=\"decimal\" length=\"12\" requir=\"必填\">{ajwd}</ajwd><ajqyrq desc=\"廒间启用日期\" type=\"varchar\" length=\"14\" requir=\"可选\">{ajqyrq}</ajqyrq><ajlxdh desc=\"廒间联系电话\" type=\"varchar\" length=\"15\" requir=\"可选\">{ajlxdh}</ajlxdh><ajcd desc=\"廒间长度\" type=\"decimal\" length=\"8\" requir=\"可选\">{ajcd}</ajcd><ajkd desc=\"廒间宽度\" type=\"decimal\" length=\"8\" requir=\"可选\">{ajkd}</ajkd><ajgd desc=\"廒间高度\" type=\"decimal\" length=\"8\" requir=\"可选\">{ajgd}</ajgd></row></root>";
|
|
|
|
private String method = "saveGranaryRecordDetail";// 填写数据方法名
|
private String wsdl = "/granaryWebService?wsdl";//填写调用库点信息接口服务
|
private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间
|
|
public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1104 data,Api1103 api1103) {
|
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 = webServiceXml(data,api1103);// 获取接口的输入报文，根据需要填写相应的报文
|
|
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 webServiceXml(Api1104 data,Api1103 api1103) {
|
String xmlStr = xml_webservice;
|
xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//所属库点代码
|
xmlStr = xmlStr.replace("{cfmc}", GDUtils.formatStr(api1103.getCfmc()));//仓房名称
|
xmlStr = xmlStr.replace("{ajmc}", GDUtils.formatStr(data.getAjmc()));//廒间名称
|
xmlStr = xmlStr.replace("{ajbh}", GDUtils.formatStr(data.getAjdh()));//廒间编码
|
xmlStr = xmlStr.replace("{ajsjcr}", GDUtils.formatNum(data.getAjsjcr()));//廒间设计仓容
|
xmlStr = xmlStr.replace("{ajzt}", GDUtils.formatStr(data.getAjzt()));//廒间状态
|
xmlStr = xmlStr.replace("{ajjd}", GDUtils.formatNum(api1103.getJd()));//廒间经度
|
xmlStr = xmlStr.replace("{ajwd}", GDUtils.formatNum(api1103.getWd()));//廒间纬度
|
|
xmlStr = xmlStr.replace("{ajqyrq}", GDUtils.formatDate(data.getAjqyrq(),"yyyy-MM-dd"));//廒间启用日期
|
xmlStr = xmlStr.replace("{ajcd}", GDUtils.formatNum(data.getAjcd()));//廒间长度
|
xmlStr = xmlStr.replace("{ajkd}", GDUtils.formatNum(data.getAjkd()));//廒间宽度
|
xmlStr = xmlStr.replace("{ajgd}", GDUtils.formatNum(data.getAjgd()));//廒间高度
|
xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志
|
xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间
|
return xmlStr;
|
}
|
|
|
}
|
