package com.fzzy.push.gd2020.v2;
|
|
import com.fzzy.api.data.AuthToken;
|
import com.fzzy.api.entity.Api1207;
|
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;
|
|
@Slf4j
|
public class TransferGranaryWebservice {
|
|
public static TransferGranaryWebservice newInstance() {
|
return new TransferGranaryWebservice();
|
}
|
|
/**
|
* 倒仓-数据接口 -xml报文
|
*/
|
public String xml_transferGranaryWebservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"transfer_granary\"><dcdbm desc=\"倒仓单编码\" type=\"varchar\" length=\"32\" requir=\"必填\"></dcdbm><kddm desc=\"库点代码\" type=\"varchar\" length=\"30\" requir=\"必填\"></kddm><dclx desc=\"倒仓类型\" type=\"varchar\" length=\"1\" requir=\"必填\"></dclx><dcjhwjbh desc=\"倒仓计划文件编号\" type=\"varchar\" length=\"32\" requir=\"必填\"></dcjhwjbh><tzdbm desc=\"通知单编码\" type=\"varchar\" length=\"32\" requir=\"必填\"></tzdbm><dcdw desc=\"倒仓单位\" type=\"varchar\" length=\"18\" requir=\"必填\"></dcdw><pzbm desc=\"品种编码\" type=\"varchar\" length=\"32\" requir=\"必填\"></pzbm><dchwbm desc=\"倒出货位编码\" type=\"varchar\" length=\"30\" requir=\"必填\"></dchwbm><drhwbm desc=\"倒入货位编码\" type=\"varchar\" length=\"30\" requir=\"必填\"></drhwbm><dcrq desc=\"倒仓日期\" type=\"varchar\" length=\"10\" requir=\"必填\"></dcrq><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\"></czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\"></zhgxsj><dcsl desc=\"倒仓数量\" type=\"Decimal\" length=\"20\" requir=\"必填\"></dcsl><bzw desc=\"包装物\" type=\"varchar\" length=\"1\" requir=\"可选\"></bzw><bzbjs desc=\"标准包件数\" type=\"int\" length=\"\" requir=\"可选\"></bzbjs><bz desc=\"备注\" type=\"varchar\" length=\"200\" requir=\"可选\"></bz></row></root>\t\n";
|
|
/**
|
* @Desc: 倒仓-数据接口
|
*/
|
public InvokeResult transferGranaryWebservice(AuthToken authToken,ApiConfs conf, Api1207 data) {
|
InvokeResult invokeResult = new InvokeResult();
|
|
ClassLoader cl = Thread.currentThread().getContextClassLoader();
|
|
String url = conf.getApiUrl() + "/transferGranaryWebservice?wsdl"; // 填写调用接口服务
|
String method = "transferGranarySaveRecordDetail"; // 填写方法名
|
|
String nameSpace = "http://service.sljt.com"; // 填写调用省平台命名空间
|
Thread.currentThread().setContextClassLoader(cl);
|
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
|
Client client = dcf.createClient(url);
|
QName name = new QName(nameSpace, method);
|
Object[] objects;
|
try {
|
|
String xmlStr = transferGranaryWebserviceXml(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
|
*/
|
public String transferGranaryWebserviceXml(Api1207 data) {
|
String xmlStr = xml_transferGranaryWebservice;
|
xmlStr = xmlStr.replace("{dcdbm}", GDUtils.formatStr(data.getDcdh()));//倒仓单编码
|
xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码
|
xmlStr = xmlStr.replace("{dclx}", GDUtils.formatStr(data.getDclx()));//倒仓类型
|
xmlStr = xmlStr.replace("{dcjhwjbh}", GDUtils.formatStr(data.getDcjhwjbh()));//倒仓计划文件编号
|
xmlStr = xmlStr.replace("{tzdbm}", GDUtils.formatStr(data.getDcjhwjbh()));//通知单号
|
xmlStr = xmlStr.replace("{dcdw}", GDUtils.formatStr(data.getDcdw()));//倒仓单位
|
xmlStr = xmlStr.replace("{pzbm}", GDUtils.formatStr(data.getLspzdm()));//品种编码
|
xmlStr = xmlStr.replace("{dcdw}", GDUtils.formatStr(data.getDcdw()));//倒仓单位
|
xmlStr = xmlStr.replace("{dchwbm}", GDUtils.formatStr(data.getDchwdm()));//倒出货位编码
|
xmlStr = xmlStr.replace("{drhwbm}", GDUtils.formatStr(data.getDchwdm()));//倒入货位编码
|
xmlStr = xmlStr.replace("{dcdw}", GDUtils.formatStr(data.getDcjhwjbh()));//倒仓计划文件编号
|
xmlStr = xmlStr.replace("{dcrq}", GDUtils.formatDate(data.getDcrq(), "yyyy-MM-dd"));//倒仓日期
|
xmlStr = xmlStr.replace("{dcsl}", GDUtils.formatNum(data.getDcsl()));//倒仓数量
|
xmlStr = xmlStr.replace("{bzbjs}", GDUtils.formatNum(data.getBzbjs()));//标准包件数
|
xmlStr = xmlStr.replace("{bzw}", GDUtils.formatStr(data.getBzw()));//包装物
|
xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//备注
|
xmlStr = xmlStr.replace("{bz}", GDUtils.formatStr(data.getCzbz()));//操作标志
|
xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间
|
return xmlStr;
|
}
|
}
|
